Configuration::configureSharedPluginNodes() - Code Metrics - Inspection of "Allow to configure plugins specifically for a clie..." - php-http/HttplugBundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#112)

by David

created 2016-08-07 13:00 UTC

Configuration::configureSharedPluginNodes() B

↳ Parent: Configuration

Complexity

Conditions	6
Paths	32

Size

Total Lines	133
Code Lines	109

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	75
CRAP Score	6

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	133
ccs	75
cts	75
cp	1
rs	8.1463
cc	6
eloc	109
nc	32
nop	2
crap	6

How to fix Long Method

<?php

namespace Http\HttplugBundle\DependencyInjection;

use Symfony\Component\Config\Definition\ArrayNode;
use Symfony\Component\Config\Definition\Builder\ArrayNodeDefinition;
use Symfony\Component\Config\Definition\Builder\NodeDefinition;
use Symfony\Component\Config\Definition\Builder\TreeBuilder;
use Symfony\Component\Config\Definition\ConfigurationInterface;
use Symfony\Component\Config\Definition\Exception\InvalidConfigurationException;

/**
 * This class contains the configuration information for the bundle.
 *
 * This information is solely responsible for how the different configuration
 * sections are normalized, and merged.
 *
 * @author David Buchmann <[email protected]>
 * @author Tobias Nyholm <[email protected]>
 */
class Configuration implements ConfigurationInterface
{
    /**
     * Whether to use the debug mode.
     *
     * @see https://github.com/doctrine/DoctrineBundle/blob/v1.5.2/DependencyInjection/Configuration.php#L31-L41
     *
     * @var bool
     */
    private $debug;

    /**
     * @param bool $debug
     */
    public function __construct($debug)
    {
        $this->debug = (bool) $debug;
    }

    /**
     * {@inheritdoc}
     */
    public function getConfigTreeBuilder()
    {
        $treeBuilder = new TreeBuilder();
        $rootNode = $treeBuilder->root('httplug');

        $this->configureClients($rootNode);
        $this->configurePlugins($rootNode);

        $rootNode
            ->validate()
                ->ifTrue(function ($v) {
                    return !empty($v['classes']['client'])
                        || !empty($v['classes']['message_factory'])
                        || !empty($v['classes']['uri_factory'])
                        || !empty($v['classes']['stream_factory']);
                })
                ->then(function ($v) {
                    foreach ($v['classes'] as $key => $class) {
                        if (null !== $class && !class_exists($class)) {
                            throw new InvalidConfigurationException(sprintf(
                                'Class %s specified for httplug.classes.%s does not exist.',
                                $class,
                                $key
                            ));
                        }
                    }

                    return $v;
                })
            ->end()
            ->beforeNormalization()
                ->ifTrue(function ($v) {
                    return is_array($v) && array_key_exists('toolbar', $v) && is_array($v['toolbar']);
                })
                ->then(function ($v) {
                    if (array_key_exists('profiling', $v)) {
                        throw new InvalidConfigurationException('Can\'t configure both "toolbar" and "profiling" section. The "toolbar" config is deprecated as of version 1.3.0, please only use "profiling".');
                    }

                    @trigger_error('"httplug.toolbar" config is deprecated since version 1.3 and will be removed in 2.0. Use "httplug.profiling" instead.', E_USER_DEPRECATED);
// For example instead of
@mkdir($dir);

// Better use
if (@mkdir($dir) === false) {
    throw new \RuntimeException('The directory '.$dir.' could not be created.');
}

                    if (array_key_exists('enabled', $v['toolbar']) && 'auto' === $v['toolbar']['enabled']) {
                        @trigger_error('"auto" value in "httplug.toolbar" config is deprecated since version 1.3 and will be removed in 2.0. Use a boolean value instead.', E_USER_DEPRECATED);
// For example instead of
@mkdir($dir);

// Better use
if (@mkdir($dir) === false) {
    throw new \RuntimeException('The directory '.$dir.' could not be created.');
}
                        $v['toolbar']['enabled'] = $this->debug;
                    }

                    $v['profiling'] = $v['toolbar'];

                    unset($v['toolbar']);

                    return $v;
                })
            ->end()
            ->fixXmlConfig('client')
            ->children()
                ->arrayNode('main_alias')
                    ->addDefaultsIfNotSet()
                    ->info('Configure which service the main alias point to.')
                    ->children()
                        ->scalarNode('client')->defaultValue('httplug.client.default')->end()
                        ->scalarNode('message_factory')->defaultValue('httplug.message_factory.default')->end()
                        ->scalarNode('uri_factory')->defaultValue('httplug.uri_factory.default')->end()
                        ->scalarNode('stream_factory')->defaultValue('httplug.stream_factory.default')->end()
                    ->end()
                ->end()
                ->arrayNode('classes')
                    ->addDefaultsIfNotSet()
                    ->info('Overwrite a service class instead of using the discovery mechanism.')
                    ->children()
                        ->scalarNode('client')->defaultNull()->end()
                        ->scalarNode('message_factory')->defaultNull()->end()
                        ->scalarNode('uri_factory')->defaultNull()->end()
                        ->scalarNode('stream_factory')->defaultNull()->end()
                    ->end()
                ->end()
                ->arrayNode('profiling')
                    ->addDefaultsIfNotSet()
                    ->treatFalseLike(['enabled' => false])
                    ->treatTrueLike(['enabled' => true])
                    ->treatNullLike(['enabled' => $this->debug])
                    ->info('Extend the debug profiler with information about requests.')
                    ->children()
                        ->booleanNode('enabled')
                            ->info('Turn the toolbar on or off. Defaults to kernel debug mode.')
                            ->defaultValue($this->debug)
                        ->end()
                        ->scalarNode('formatter')->defaultNull()->end()
                        ->integerNode('captured_body_length')
                            ->defaultValue(0)
                            ->info('Limit long HTTP message bodies to x characters. If set to 0 we do not read the message body. Only available with the default formatter (FullHttpMessageFormatter).')
                        ->end()
                    ->end()
                ->end()
                ->arrayNode('discovery')
                    ->addDefaultsIfNotSet()
                    ->info('Control what clients should be found by the discovery.')
                    ->children()
                        ->scalarNode('client')
                            ->defaultValue('auto')
                            ->info('Set to "auto" to see auto discovered client in the web profiler. If provided a service id for a client then this client will be found by auto discovery.')
                        ->end()
                        ->scalarNode('async_client')
                            ->defaultNull()
                            ->info('Set to "auto" to see auto discovered client in the web profiler. If provided a service id for a client then this client will be found by auto discovery.')
                        ->end()
                    ->end()
                ->end()
            ->end();

        return $treeBuilder;
    }

    private function configureClients(ArrayNodeDefinition $root)
    {
        $root->children()
            ->arrayNode('clients')
                ->validate()
                    ->ifTrue(function ($clients) {
                        foreach ($clients as $name => $config) {
                            // Make sure we only allow one of these to be true
                            return (bool) $config['flexible_client'] + (bool) $config['http_methods_client'] + (bool) $config['batch_client'] >= 2;
                        }

                        return false;
                    })
                    ->thenInvalid('A http client can\'t be decorated with both FlexibleHttpClient and HttpMethodsClient. Only one of the following options can be true. ("flexible_client", "http_methods_client")')->end()
                ->useAttributeAsKey('name')
                ->prototype('array')
                ->children()
                    ->scalarNode('factory')
                        ->isRequired()
                        ->cannotBeEmpty()
                        ->info('The service id of a factory to use when creating the adapter.')
                    ->end()
                    ->booleanNode('flexible_client')
                        ->defaultFalse()
                        ->info('Set to true to get the client wrapped in a FlexibleHttpClient which emulates async or sync behavior.')
                    ->end()
                    ->booleanNode('http_methods_client')
                        ->defaultFalse()
                        ->info('Set to true to get the client wrapped in a HttpMethodsClient which emulates provides functions for HTTP verbs.')
                    ->end()
                    ->booleanNode('batch_client')
                        ->defaultFalse()
                        ->info('Set to true to get the client wrapped in a BatchClient which allows you to send multiple request at the same time.')
                    ->end()
                    ->arrayNode('plugins')
                        ->info('A list of service ids of plugins. The order is important.')
                        ->prototype('scalar')->end()
                    ->end()
                    ->variableNode('config')->defaultValue([])->end()
                    ->append($this->createExtraPluginsNode())
                ->end()
            ->end();
    }

    /**
     * @param ArrayNodeDefinition $root
     */
    private function configurePlugins(ArrayNodeDefinition $root)
    {
        $pluginsNode = $root
            ->children()
                ->arrayNode('plugins')
                ->addDefaultsIfNotSet()
        ;
        $this->configureSharedPluginNodes($pluginsNode);
    }

    /**
     * Create configuration for the extra_plugins node inside the client.
     *
     * @return NodeDefinition Definition of the extra_plugins node in the client.
     */
    private function createExtraPluginsNode()
    {
        $builder = new TreeBuilder();
        $node = $builder->root('extra_plugins');
        $node->validate()
            ->always(function ($plugins) {
                if (!count($plugins['authentication'])) {
                    unset($plugins['authentication']);
                }
                foreach ($plugins as $name => $definition) {
                    if (!$definition['enabled']) {
                        unset($plugins[$name]);
                    }
                }

                return $plugins;
            })
        ;
        $this->configureSharedPluginNodes($node, true);
        $node
            ->children()
                ->arrayNode('add_host')
                    ->canBeEnabled()
                    ->addDefaultsIfNotSet()
                    ->info('Configure the AddHostPlugin for this client.')
                    ->children()
                        ->scalarNode('host')
                            ->info('Host name including protocol and optionally the port number, e.g. https://api.local:8000')
                            ->isRequired()
                            ->cannotBeEmpty()
                        ->end()
                        ->scalarNode('replace')
                            ->info('Whether to replace the host if request already specifies it')
                            ->defaultValue(false)
                        ->end()
                    ->end()
                ->end()
            ->end()
        ->end();

        return $node;
    }

    /**
     * @param ArrayNodeDefinition $pluginNode
     * @param bool                $disableAll Some shared plugins are enabled by default. On the client, all are disabled by default.
     */
    private function configureSharedPluginNodes(ArrayNodeDefinition $pluginNode, $disableAll = false)
    {
        $children = $pluginNode->children();

        $children->append($this->createAuthenticationPluginNode());

        $children->arrayNode('cache')
            ->canBeEnabled()
            ->addDefaultsIfNotSet()
                ->children()
                    ->scalarNode('cache_pool')
                        ->info('This must be a service id to a service implementing Psr\Cache\CacheItemPoolInterface')
                        ->isRequired()
                        ->cannotBeEmpty()
                    ->end()
                    ->scalarNode('stream_factory')
                        ->info('This must be a service id to a service implementing Http\Message\StreamFactory')
                        ->defaultValue('httplug.stream_factory')
                        ->cannotBeEmpty()
                    ->end()
                    ->arrayNode('config')
                        ->addDefaultsIfNotSet()
                        ->children()
                            ->scalarNode('default_ttl')->defaultNull()->end()
                            ->scalarNode('respect_cache_headers')->defaultTrue()->end()
                        ->end()
                    ->end()
                ->end()
            ->end();
        // End cache plugin

        $children->arrayNode('cookie')
            ->canBeEnabled()
                ->children()
                    ->scalarNode('cookie_jar')
                        ->info('This must be a service id to a service implementing Http\Message\CookieJar')
                        ->isRequired()
                        ->cannotBeEmpty()
                    ->end()
                ->end()
            ->end();
        // End cookie plugin

        $decoder = $children->arrayNode('decoder');
        if ($disableAll) {
            $decoder->canBeEnabled();
        } else {
            $decoder->canBeDisabled();
        }
        $decoder->addDefaultsIfNotSet()
            ->children()
                ->scalarNode('use_content_encoding')->defaultTrue()->end()
            ->end()
        ->end();
        // End decoder plugin

        $children->arrayNode('history')
            ->canBeEnabled()
                ->children()
                    ->scalarNode('journal')
                        ->info('This must be a service id to a service implementing Http\Client\Plugin\Journal')
                        ->isRequired()
                        ->cannotBeEmpty()
                    ->end()
                ->end()
            ->end();
        // End history plugin

        $logger = $children->arrayNode('logger');
        if ($disableAll) {
            $logger->canBeEnabled();
        } else {
            $logger->canBeDisabled();
        }
        $logger->addDefaultsIfNotSet()
            ->children()
                ->scalarNode('logger')
                    ->info('This must be a service id to a service implementing Psr\Log\LoggerInterface')
                    ->defaultValue('logger')
                    ->cannotBeEmpty()
                ->end()
                ->scalarNode('formatter')
                    ->info('This must be a service id to a service implementing Http\Message\Formatter')
                    ->defaultNull()
                ->end()
            ->end()
        ->end();
        // End logger plugin

        $redirect = $children->arrayNode('redirect');
        if ($disableAll) {
            $redirect->canBeEnabled();
        } else {
            $redirect->canBeDisabled();
        }
        $redirect->addDefaultsIfNotSet()
            ->children()
                ->scalarNode('preserve_header')->defaultTrue()->end()
                ->scalarNode('use_default_for_multiple')->defaultTrue()->end()
            ->end()
        ->end();
        // End redirect plugin

        $retry = $children->arrayNode('retry');
        if ($disableAll) {
            $retry->canBeEnabled();
        } else {
            $retry->canBeDisabled();
        }
        $retry->addDefaultsIfNotSet()
            ->children()
                ->scalarNode('retry')->defaultValue(1)->end() // TODO: should be called retries for consistency with the class
            ->end()
        ->end();
        // End retry plugin

        $stopwatch = $children->arrayNode('stopwatch');
        if ($disableAll) {
            $stopwatch->canBeEnabled();
        } else {
            $stopwatch->canBeDisabled();
        }
        $stopwatch->addDefaultsIfNotSet()
            ->children()
                ->scalarNode('stopwatch')
                    ->info('This must be a service id to a service extending Symfony\Component\Stopwatch\Stopwatch')
                    ->defaultValue('debug.stopwatch')
                    ->cannotBeEmpty()
                ->end()
            ->end()
        ->end();
        // End stopwatch plugin
    }

    /**
     * Create configuration for authentication plugin.
     *
     * @return NodeDefinition Definition for the authentication node in the plugins list.
     */
    private function createAuthenticationPluginNode()
    {
        $builder = new TreeBuilder();
        $node = $builder->root('authentication');
        $node
            ->useAttributeAsKey('name')
            ->prototype('array')
                ->validate()
                    ->always()
                    ->then(function ($config) {
                        switch ($config['type']) {
                            case 'basic':
                                $this->validateAuthenticationType(['username', 'password'], $config, 'basic');
                                break;
                            case 'bearer':
                                $this->validateAuthenticationType(['token'], $config, 'bearer');
                                break;
                            case 'service':
                                $this->validateAuthenticationType(['service'], $config, 'service');
                                break;
                            case 'wsse':
                                $this->validateAuthenticationType(['username', 'password'], $config, 'wsse');
                                break;
                        }

                        return $config;
                    })
                ->end()
                ->children()
                    ->enumNode('type')
                        ->values(['basic', 'bearer', 'wsse', 'service'])
                        ->isRequired()
                        ->cannotBeEmpty()
                    ->end()
                    ->scalarNode('username')->end()
                    ->scalarNode('password')->end()
                    ->scalarNode('token')->end()
                    ->scalarNode('service')->end()
                    ->end()
                ->end()
            ->end(); // End authentication plugin

        return $node;
    }

    /**
     * Validate that the configuration fragment has the specified keys and none other.
     *
     * @param array  $expected Fields that must exist
     * @param array  $actual   Actual configuration hashmap
     * @param string $authName Name of authentication method for error messages
     *
     * @throws InvalidConfigurationException If $actual does not have exactly the keys specified in $expected (plus 'type')
     */
    private function validateAuthenticationType(array $expected, array $actual, $authName)
    {
        unset($actual['type']);
        $actual = array_keys($actual);
        sort($actual);
        sort($expected);

        if ($expected === $actual) {
            return;
        }

        throw new InvalidConfigurationException(sprintf(
            'Authentication "%s" requires %s but got %s',
            $authName,
            implode(', ', $expected),
            implode(', ', $actual)
        ));
    }
}


1		<?php
2
3		namespace Http\HttplugBundle\DependencyInjection;
4
5		use Symfony\Component\Config\Definition\ArrayNode;
6		use Symfony\Component\Config\Definition\Builder\ArrayNodeDefinition;
7		use Symfony\Component\Config\Definition\Builder\NodeDefinition;
8		use Symfony\Component\Config\Definition\Builder\TreeBuilder;
9		use Symfony\Component\Config\Definition\ConfigurationInterface;
10		use Symfony\Component\Config\Definition\Exception\InvalidConfigurationException;
11
12		/**
13		* This class contains the configuration information for the bundle.
14		*
15		* This information is solely responsible for how the different configuration
16		* sections are normalized, and merged.
17		*
18		* @author David Buchmann <[email protected]>
19		* @author Tobias Nyholm <[email protected]>
20		*/
21		class Configuration implements ConfigurationInterface
22		{
23		/**
24		* Whether to use the debug mode.
25		*
26		* @see https://github.com/doctrine/DoctrineBundle/blob/v1.5.2/DependencyInjection/Configuration.php#L31-L41
27		*
28		* @var bool
29		*/
30		private $debug;
31
32		/**
33		* @param bool $debug
34	12	*/
35		public function __construct($debug)
36	12	{
37	12	$this->debug = (bool) $debug;
38		}
39
40		/**
41		* {@inheritdoc}
42	12	*/
43		public function getConfigTreeBuilder()
44	12	{
45	12	$treeBuilder = new TreeBuilder();
46		$rootNode = $treeBuilder->root('httplug');
47	12
48	12	$this->configureClients($rootNode);
49		$this->configurePlugins($rootNode);
50
51	12	$rootNode
52		->validate()
53	11	->ifTrue(function ($v) {
54	11	return !empty($v['classes']['client'])
55	8	\|\| !empty($v['classes']['message_factory'])
56	11	\|\| !empty($v['classes']['uri_factory'])
57	12	\|\| !empty($v['classes']['stream_factory']);
58		})
59	3	->then(function ($v) {
60	3	foreach ($v['classes'] as $key => $class) {
61	1	if (null !== $class && !class_exists($class)) {
62	1	throw new InvalidConfigurationException(sprintf(
63	1	'Class %s specified for httplug.classes.%s does not exist.',
64		$class,
65	1	$key
66		));
67	2	}
68		}
69	2
70	12	return $v;
71	12	})
72	12	->end()
73	12	->beforeNormalization()
74	12	->ifTrue(function ($v) {
75	12	return is_array($v) && array_key_exists('toolbar', $v) && is_array($v['toolbar']);
76	12	})
77	12	->then(function ($v) {
78	12	if (array_key_exists('profiling', $v)) {
79	12	throw new InvalidConfigurationException('Can\'t configure both "toolbar" and "profiling" section. The "toolbar" config is deprecated as of version 1.3.0, please only use "profiling".');
80	12	}
81	12
82	12	@trigger_error('"httplug.toolbar" config is deprecated since version 1.3 and will be removed in 2.0. Use "httplug.profiling" instead.', E_USER_DEPRECATED);
		0 ignored issues – show Security Best Practice introduced 2016-07-28 13:21 UTC by Report Bug Copy Issue Report It seems like you do not handle an error condition here. This can introduce security issues, and is generally not recommended. If you suppress an error, we recommend checking for the error condition explicitly: // For example instead of @mkdir($dir); // Better use if (@mkdir($dir) === false) { throw new \RuntimeException('The directory '.$dir.' could not be created.'); } Loading history...
83	12
84	12	if (array_key_exists('enabled', $v['toolbar']) && 'auto' === $v['toolbar']['enabled']) {
85	12	@trigger_error('"auto" value in "httplug.toolbar" config is deprecated since version 1.3 and will be removed in 2.0. Use a boolean value instead.', E_USER_DEPRECATED);
		1 ignored issue – show Security Best Practice introduced 2016-07-28 13:21 UTC by Report Bug Copy Issue Report It seems like you do not handle an error condition here. This can introduce security issues, and is generally not recommended. If you suppress an error, we recommend checking for the error condition explicitly: // For example instead of @mkdir($dir); // Better use if (@mkdir($dir) === false) { throw new \RuntimeException('The directory '.$dir.' could not be created.'); } Loading history...
86	12	$v['toolbar']['enabled'] = $this->debug;
87	12	}
88	12
89	12	$v['profiling'] = $v['toolbar'];
90	12
91	12	unset($v['toolbar']);
92	12
93	12	return $v;
94	12	})
95	12	->end()
96	12	->fixXmlConfig('client')
97	12	->children()
98	12	->arrayNode('main_alias')
99	12	->addDefaultsIfNotSet()
100		->info('Configure which service the main alias point to.')
101	1	->children()
102	12	->scalarNode('client')->defaultValue('httplug.client.default')->end()
103	12	->scalarNode('message_factory')->defaultValue('httplug.message_factory.default')->end()
104	12	->scalarNode('uri_factory')->defaultValue('httplug.uri_factory.default')->end()
105	12	->scalarNode('stream_factory')->defaultValue('httplug.stream_factory.default')->end()
106	12	->end()
107	12	->end()
108	12	->arrayNode('classes')
109	12	->addDefaultsIfNotSet()
110	12	->info('Overwrite a service class instead of using the discovery mechanism.')
111	12	->children()
112	12	->scalarNode('client')->defaultNull()->end()
113	12	->scalarNode('message_factory')->defaultNull()->end()
114	12	->scalarNode('uri_factory')->defaultNull()->end()
115	12	->scalarNode('stream_factory')->defaultNull()->end()
116	12	->end()
117	12	->end()
118	12	->arrayNode('profiling')
119	12	->addDefaultsIfNotSet()
120	12	->treatFalseLike(['enabled' => false])
121	12	->treatTrueLike(['enabled' => true])
122	12	->treatNullLike(['enabled' => $this->debug])
123	12	->info('Extend the debug profiler with information about requests.')
124	12	->children()
125	12	->booleanNode('enabled')
126	12	->info('Turn the toolbar on or off. Defaults to kernel debug mode.')
127	12	->defaultValue($this->debug)
128	12	->end()
129		->scalarNode('formatter')->defaultNull()->end()
130	12	->integerNode('captured_body_length')
131		->defaultValue(0)
132		->info('Limit long HTTP message bodies to x characters. If set to 0 we do not read the message body. Only available with the default formatter (FullHttpMessageFormatter).')
133	12	->end()
134		->end()
135	12	->end()
136	12	->arrayNode('discovery')
137	12	->addDefaultsIfNotSet()
138		->info('Control what clients should be found by the discovery.')
139	3	->children()
140		->scalarNode('client')
141	3	->defaultValue('auto')
142		->info('Set to "auto" to see auto discovered client in the web profiler. If provided a service id for a client then this client will be found by auto discovery.')
143		->end()
144		->scalarNode('async_client')
145	12	->defaultNull()
146	12	->info('Set to "auto" to see auto discovered client in the web profiler. If provided a service id for a client then this client will be found by auto discovery.')
147	12	->end()
148	12	->end()
149	12	->end()
150	12	->end();
151	12
152	12	return $treeBuilder;
153	12	}
154	12
155	12	private function configureClients(ArrayNodeDefinition $root)
156	12	{
157	12	$root->children()
158	12	->arrayNode('clients')
159	12	->validate()
160	12	->ifTrue(function ($clients) {
161	12	foreach ($clients as $name => $config) {
162	12	// Make sure we only allow one of these to be true
163	12	return (bool) $config['flexible_client'] + (bool) $config['http_methods_client'] + (bool) $config['batch_client'] >= 2;
164	12	}
165	12
166	12	return false;
167	12	})
168	12	->thenInvalid('A http client can\'t be decorated with both FlexibleHttpClient and HttpMethodsClient. Only one of the following options can be true. ("flexible_client", "http_methods_client")')->end()
169	12	->useAttributeAsKey('name')
170	12	->prototype('array')
171	12	->children()
172	12	->scalarNode('factory')
173	12	->isRequired()
174	12	->cannotBeEmpty()
175		->info('The service id of a factory to use when creating the adapter.')
176		->end()
177		->booleanNode('flexible_client')
178		->defaultFalse()
179	12	->info('Set to true to get the client wrapped in a FlexibleHttpClient which emulates async or sync behavior.')
180		->end()
181	12	->booleanNode('http_methods_client')
182	12	->defaultFalse()
183	12	->info('Set to true to get the client wrapped in a HttpMethodsClient which emulates provides functions for HTTP verbs.')
184	12	->end()
185	12	->booleanNode('batch_client')
186		->defaultFalse()
187	12	->info('Set to true to get the client wrapped in a BatchClient which allows you to send multiple request at the same time.')
188	12	->end()
189	12	->arrayNode('plugins')
190	12	->info('A list of service ids of plugins. The order is important.')
191	12	->prototype('scalar')->end()
192	12	->end()
193	12	->variableNode('config')->defaultValue([])->end()
194	12	->append($this->createExtraPluginsNode())
195	12	->end()
196	12	->end();
197	12	}
198	12
199	12	/**
200	12	* @param ArrayNodeDefinition $root
201	12	*/
202	12	private function configurePlugins(ArrayNodeDefinition $root)
203	12	{
204	12	$pluginsNode = $root
205	12	->children()
206	12	->arrayNode('plugins')
207	12	->addDefaultsIfNotSet()
208	12	;
209	12	$this->configureSharedPluginNodes($pluginsNode);
210		}
211	12
212	12	/**
213	12	* Create configuration for the extra_plugins node inside the client.
214	12	*
215	12	* @return NodeDefinition Definition of the extra_plugins node in the client.
216	12	*/
217	12	private function createExtraPluginsNode()
218	12	{
219	12	$builder = new TreeBuilder();
220	12	$node = $builder->root('extra_plugins');
221		$node->validate()
222	12	->always(function ($plugins) {
223	12	if (!count($plugins['authentication'])) {
224	12	unset($plugins['authentication']);
225	12	}
226	12	foreach ($plugins as $name => $definition) {
227	12	if (!$definition['enabled']) {
228	12	unset($plugins[$name]);
229		}
230	12	}
231	12
232	12	return $plugins;
233	12	})
234	12	;
235	12	$this->configureSharedPluginNodes($node, true);
236	12	$node
237	12	->children()
238	12	->arrayNode('add_host')
239	12	->canBeEnabled()
240		->addDefaultsIfNotSet()
241	12	->info('Configure the AddHostPlugin for this client.')
242	12	->children()
243	12	->scalarNode('host')
244	12	->info('Host name including protocol and optionally the port number, e.g. https://api.local:8000')
245	12	->isRequired()
246	12	->cannotBeEmpty()
247	12	->end()
248	12	->scalarNode('replace')
249	12	->info('Whether to replace the host if request already specifies it')
250	12	->defaultValue(false)
251	12	->end()
252	12	->end()
253	12	->end()
254	12	->end()
255	12	->end();
256
257	12	return $node;
258	12	}
259	12
260	12	/**
261	12	* @param ArrayNodeDefinition $pluginNode
262	12	* @param bool $disableAll Some shared plugins are enabled by default. On the client, all are disabled by default.
263	12	*/
264	12	private function configureSharedPluginNodes(ArrayNodeDefinition $pluginNode, $disableAll = false)
265		{
266	12	$children = $pluginNode->children();
267	12
268	12	$children->append($this->createAuthenticationPluginNode());
269	12
270	12	$children->arrayNode('cache')
271	12	->canBeEnabled()
272	12	->addDefaultsIfNotSet()
273		->children()
274	12	->scalarNode('cache_pool')
275	12	->info('This must be a service id to a service implementing Psr\Cache\CacheItemPoolInterface')
276	12	->isRequired()
277	12	->cannotBeEmpty()
278	12	->end()
279	12	->scalarNode('stream_factory')
280	12	->info('This must be a service id to a service implementing Http\Message\StreamFactory')
281	12	->defaultValue('httplug.stream_factory')
282	12	->cannotBeEmpty()
283	12	->end()
284	12	->arrayNode('config')
285		->addDefaultsIfNotSet()
286	12	->children()
287	12	->scalarNode('default_ttl')->defaultNull()->end()
288	12	->scalarNode('respect_cache_headers')->defaultTrue()->end()
289	12	->end()
290		->end()
291		->end()
292		->end();
293		// End cache plugin
294
295		$children->arrayNode('cookie')
296	12	->canBeEnabled()
297		->children()
298	12	->scalarNode('cookie_jar')
299	12	->info('This must be a service id to a service implementing Http\Message\CookieJar')
300		->isRequired()
301	12	->cannotBeEmpty()
302	12	->end()
303	12	->end()
304	12	->end();
305	12	// End cookie plugin
306	2
307	2	$decoder = $children->arrayNode('decoder');
308	1	if ($disableAll) {
309	1	$decoder->canBeEnabled();
310	2	} else {
311	1	$decoder->canBeDisabled();
312	1	}
313	2	$decoder->addDefaultsIfNotSet()
314	2	->children()
315	1	->scalarNode('use_content_encoding')->defaultTrue()->end()
316	1	->end()
317	1	->end();
318	1	// End decoder plugin
319	1
320		$children->arrayNode('history')
321	1	->canBeEnabled()
322	12	->children()
323	12	->scalarNode('journal')
324	12	->info('This must be a service id to a service implementing Http\Client\Plugin\Journal')
325	12	->isRequired()
326	12	->cannotBeEmpty()
327	12	->end()
328	12	->end()
329	12	->end();
330	12	// End history plugin
331	12
332	12	$logger = $children->arrayNode('logger');
333	12	if ($disableAll) {
334	12	$logger->canBeEnabled();
335	12	} else {
336	12	$logger->canBeDisabled();
337		}
338	12	$logger->addDefaultsIfNotSet()
339		->children()
340		->scalarNode('logger')
341		->info('This must be a service id to a service implementing Psr\Log\LoggerInterface')
342		->defaultValue('logger')
343		->cannotBeEmpty()
344		->end()
345		->scalarNode('formatter')
346		->info('This must be a service id to a service implementing Http\Message\Formatter')
347		->defaultNull()
348		->end()
349		->end()
350	2	->end();
351		// End logger plugin
352	2
353	2	$redirect = $children->arrayNode('redirect');
354	2	if ($disableAll) {
355	2	$redirect->canBeEnabled();
356		} else {
357	2	$redirect->canBeDisabled();
358	1	}
359		$redirect->addDefaultsIfNotSet()
360		->children()
361	1	->scalarNode('preserve_header')->defaultTrue()->end()
362	1	->scalarNode('use_default_for_multiple')->defaultTrue()->end()
363	1	->end()
364	1	->end();
365	1	// End redirect plugin
366	1
367		$retry = $children->arrayNode('retry');
368		if ($disableAll) {
369		$retry->canBeEnabled();
370		} else {
371		$retry->canBeDisabled();
372		}
373		$retry->addDefaultsIfNotSet()
374		->children()
375		->scalarNode('retry')->defaultValue(1)->end() // TODO: should be called retries for consistency with the class
376		->end()
377		->end();
378		// End retry plugin
379
380		$stopwatch = $children->arrayNode('stopwatch');
381		if ($disableAll) {
382		$stopwatch->canBeEnabled();
383		} else {
384		$stopwatch->canBeDisabled();
385		}
386		$stopwatch->addDefaultsIfNotSet()
387		->children()
388		->scalarNode('stopwatch')
389		->info('This must be a service id to a service extending Symfony\Component\Stopwatch\Stopwatch')
390		->defaultValue('debug.stopwatch')
391		->cannotBeEmpty()
392		->end()
393		->end()
394		->end();
395		// End stopwatch plugin
396		}
397
398		/**
399		* Create configuration for authentication plugin.
400		*
401		* @return NodeDefinition Definition for the authentication node in the plugins list.
402		*/
403		private function createAuthenticationPluginNode()
404		{
405		$builder = new TreeBuilder();
406		$node = $builder->root('authentication');
407		$node
408		->useAttributeAsKey('name')
409		->prototype('array')
410		->validate()
411		->always()
412		->then(function ($config) {
413		switch ($config['type']) {
414		case 'basic':
415		$this->validateAuthenticationType(['username', 'password'], $config, 'basic');
416		break;
417		case 'bearer':
418		$this->validateAuthenticationType(['token'], $config, 'bearer');
419		break;
420		case 'service':
421		$this->validateAuthenticationType(['service'], $config, 'service');
422		break;
423		case 'wsse':
424		$this->validateAuthenticationType(['username', 'password'], $config, 'wsse');
425		break;
426		}
427
428		return $config;
429		})
430		->end()
431		->children()
432		->enumNode('type')
433		->values(['basic', 'bearer', 'wsse', 'service'])
434		->isRequired()
435		->cannotBeEmpty()
436		->end()
437		->scalarNode('username')->end()
438		->scalarNode('password')->end()
439		->scalarNode('token')->end()
440		->scalarNode('service')->end()
441		->end()
442		->end()
443		->end(); // End authentication plugin
444
445		return $node;
446		}
447
448		/**
449		* Validate that the configuration fragment has the specified keys and none other.
450		*
451		* @param array $expected Fields that must exist
452		* @param array $actual Actual configuration hashmap
453		* @param string $authName Name of authentication method for error messages
454		*
455		* @throws InvalidConfigurationException If $actual does not have exactly the keys specified in $expected (plus 'type')
456		*/
457		private function validateAuthenticationType(array $expected, array $actual, $authName)
458		{
459		unset($actual['type']);
460		$actual = array_keys($actual);
461		sort($actual);
462		sort($expected);
463
464		if ($expected === $actual) {
465		return;
466		}
467
468		throw new InvalidConfigurationException(sprintf(
469		'Authentication "%s" requires %s but got %s',
470		$authName,
471		implode(', ', $expected),
472		implode(', ', $actual)
473		));
474		}
475		}
476

php-http / HttplugBundle

Pull Request — master (#112)

Configuration::configureSharedPluginNodes() B

Complexity

Size

Duplication

Code Coverage

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like