Configuration::validateAuthenticationType() - 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-12 13:03 UTC

Configuration::validateAuthenticationType() A

↳ Parent: Configuration

Complexity

Conditions	2
Paths	2

Size

Total Lines	18
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	18
ccs	0
cts	0
cp	0
rs	9.4285
cc	2
eloc	12
nc	2
nop	3
crap	6

<?php

namespace Http\HttplugBundle\DependencyInjection;

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->configureSharedPlugins($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)
    {
        $pluginNode = $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')
                ->fixXmlConfig('plugin')
                ->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()
                    ->variableNode('config')->defaultValue([])->end()
                    ->arrayNode('plugins')
                        ->info('A list of plugin service ids and client specific plugin definitions. The order is important.')
                        ->prototype('array')
        ;

        $this->configureClientPlugins($pluginNode);
    }

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

    /**
     * Configure plugins node of a client.
     *
     * @param ArrayNodeDefinition $pluginNode The node to add plugin definitions to.
     */
    private function configureClientPlugins(ArrayNodeDefinition $pluginNode)
    {
        $pluginNode
            // support having just a service id in the list
            ->beforeNormalization()
                ->always(function ($plugin) {
                    if (is_string($plugin)) {
                        return [
                            'reference' => [
                                'enabled' => true,
                                'id' => $plugin,
                            ],
                        ];
                    }

                    return $plugin;
                })
            ->end()

            ->validate()
                ->always(function ($plugins) {
                    foreach ($plugins as $name => $definition) {
                        if ('authentication' === $name) {
                            if (!count($definition)) {
                                unset($plugins['authentication']);
                            }
                        } elseif (!$definition['enabled']) {
                            unset($plugins[$name]);
                        }
                    }

                    return $plugins;
                })
            ->end()
        ;
        $this->addSharedPluginNodes($pluginNode, true);

        $pluginNode
            ->children()
                ->arrayNode('reference')
                    ->canBeEnabled()
                    ->info('Reference to a plugin service')
                    ->children()
                        ->scalarNode('id')
                            ->info('Service id of a plugin')
                            ->isRequired()
                            ->cannotBeEmpty()
                        ->end()
                    ->end()
                ->end()
                ->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()
                ->arrayNode('header_append')
                    ->canBeEnabled()
                    ->info('Append headers to the request. If the header already exists the value will be appended to the current value.')
                    ->fixXmlConfig('header')
                    ->children()
                        ->arrayNode('headers')
                            ->info('Keys are the header names, values the header values')
                            ->normalizeKeys(false)
                            ->useAttributeAsKey('name')
                            ->prototype('scalar')->end()
                        ->end()
                    ->end()
                ->end()
                ->arrayNode('header_defaults')
                    ->canBeEnabled()
                    ->info('Set header to default value if it does not exist.')
                    ->fixXmlConfig('header')
                    ->children()
                        ->arrayNode('headers')
                            ->info('Keys are the header names, values the header values')
                            ->normalizeKeys(false)
                            ->useAttributeAsKey('name')
                            ->prototype('scalar')->end()
                        ->end()
                    ->end()
                ->end()
                ->arrayNode('header_set')
                    ->canBeEnabled()
                    ->info('Set headers to requests. If the header does not exist it wil be set, if the header already exists it will be replaced.')
                    ->fixXmlConfig('header')
                    ->children()
                        ->arrayNode('headers')
                            ->info('Keys are the header names, values the header values')
                            ->normalizeKeys(false)
                            ->useAttributeAsKey('name')
                            ->prototype('scalar')->end()
                        ->end()
                    ->end()
                ->end()
                ->arrayNode('header_remove')
                    ->canBeEnabled()
                    ->info('Remove headers from requests.')
                    ->fixXmlConfig('header')
                    ->children()
                        ->arrayNode('headers')
                            ->info('List of header names to remove')
                            ->prototype('scalar')->end()
                        ->end()
                    ->end()
                ->end()
            ->end()
        ->end();
    }

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

php-http / HttplugBundle

Pull Request — master (#112)

Configuration::validateAuthenticationType() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like