Duplicate code is one of the most pungent code smells. A rule that is often used is to re-structure code once it is duplicated in three or more places.
Common duplication problems, and corresponding solutions are:
Complex classes like HttplugExtension often do a lot of different things. To break such a class down, we need to identify a cohesive component within that class. A common approach to find such a component is to look for fields/methods that share the same prefixes, or suffixes. You can also have a look at the cohesion graph to spot any un-connected, or weakly-connected components.
Once you have determined the fields that belong together, you can apply the Extract Class refactoring. If the component makes sense as a sub-class, Extract Subclass is also a candidate, and is often faster.
While breaking up the class, it is a good idea to analyze how other classes use HttplugExtension, and based on these observations, apply Extract Interface, too.
1 | <?php |
||
30 | class HttplugExtension extends Extension |
||
31 | { |
||
32 | /** |
||
33 | 8 | * {@inheritdoc} |
|
34 | */ |
||
35 | 8 | public function load(array $configs, ContainerBuilder $container) |
|
36 | 8 | { |
|
37 | $configuration = $this->getConfiguration($configs, $container); |
||
38 | 8 | $config = $this->processConfiguration($configuration, $configs); |
|
1 ignored issue
–
show
|
|||
39 | |||
40 | 8 | $loader = new XmlFileLoader($container, new FileLocator(__DIR__.'/../Resources/config')); |
|
41 | 8 | ||
42 | $loader->load('services.xml'); |
||
43 | $loader->load('plugins.xml'); |
||
44 | 8 | ||
45 | 8 | // Register default services |
|
46 | 1 | foreach ($config['classes'] as $service => $class) { |
|
47 | 1 | if (!empty($class)) { |
|
48 | 8 | $container->register(sprintf('httplug.%s.default', $service), $class); |
|
49 | } |
||
50 | } |
||
51 | 8 | ||
52 | 8 | // Set main aliases |
|
53 | 8 | foreach ($config['main_alias'] as $type => $id) { |
|
54 | $container->setAlias(sprintf('httplug.%s', $type), $id); |
||
55 | } |
||
56 | 8 | ||
57 | 5 | // Configure toolbar |
|
58 | if ($this->isConfigEnabled($container, $config['profiling'])) { |
||
59 | 5 | $loader->load('data-collector.xml'); |
|
60 | |||
61 | if (!empty($config['profiling']['formatter'])) { |
||
62 | // Add custom formatter |
||
63 | $container |
||
64 | ->getDefinition('httplug.collector.debug_collector') |
||
65 | ->replaceArgument(0, new Reference($config['profiling']['formatter'])) |
||
66 | ; |
||
67 | } |
||
68 | 5 | ||
69 | 5 | $container |
|
70 | ->getDefinition('httplug.formatter.full_http_message') |
||
71 | 5 | ->addArgument($config['profiling']['captured_body_length']) |
|
72 | ; |
||
73 | 8 | } |
|
74 | 8 | ||
75 | 8 | $this->configureClients($container, $config); |
|
76 | 8 | $this->configureSharedPlugins($container, $config['plugins']); // must be after clients, as clients.X.plugins might use plugins as templates that will be removed |
|
77 | $this->configureAutoDiscoveryClients($container, $config); |
||
78 | } |
||
79 | |||
80 | /** |
||
81 | * Configure client services. |
||
82 | * |
||
83 | * @param ContainerBuilder $container |
||
84 | 8 | * @param array $config |
|
85 | */ |
||
86 | 8 | private function configureClients(ContainerBuilder $container, array $config) |
|
108 | |||
109 | /** |
||
110 | * @param ContainerBuilder $container |
||
111 | 8 | * @param array $config |
|
112 | */ |
||
113 | 8 | private function configureSharedPlugins(ContainerBuilder $container, array $config) |
|
131 | |||
132 | /** |
||
133 | * @param string $name |
||
134 | * @param Definition $definition |
||
135 | 8 | * @param array $config |
|
136 | * @param ContainerBuilder $container In case we need to add additional services for this plugin |
||
137 | * @param string $serviceId Service id of the plugin, in case we need to add additional services for this plugin. |
||
138 | 8 | */ |
|
139 | private function configurePluginByName($name, Definition $definition, array $config, ContainerInterface $container, $serviceId) |
||
140 | { |
||
141 | switch ($name) { |
||
142 | case 'cache': |
||
143 | $definition |
||
144 | 8 | ->replaceArgument(0, new Reference($config['cache_pool'])) |
|
145 | ->replaceArgument(1, new Reference($config['stream_factory'])) |
||
146 | ->replaceArgument(2, $config['config']); |
||
147 | 8 | break; |
|
148 | 8 | case 'cookie': |
|
149 | 8 | $definition->replaceArgument(0, new Reference($config['cookie_jar'])); |
|
150 | 8 | break; |
|
151 | 8 | case 'decoder': |
|
152 | 8 | $definition->addArgument([ |
|
153 | 'use_content_encoding' => $config['use_content_encoding'], |
||
154 | ]); |
||
155 | 8 | break; |
|
156 | 8 | case 'history': |
|
157 | 8 | $definition->replaceArgument(0, new Reference($config['journal'])); |
|
158 | break; |
||
159 | case 'logger': |
||
160 | 8 | $definition->replaceArgument(0, new Reference($config['logger'])); |
|
161 | 8 | if (!empty($config['formatter'])) { |
|
162 | 8 | $definition->replaceArgument(1, new Reference($config['formatter'])); |
|
163 | 8 | } |
|
164 | 8 | break; |
|
165 | 8 | case 'redirect': |
|
166 | 8 | $definition->addArgument([ |
|
167 | 8 | 'preserve_header' => $config['preserve_header'], |
|
168 | 8 | 'use_default_for_multiple' => $config['use_default_for_multiple'], |
|
169 | 8 | ]); |
|
170 | 8 | break; |
|
171 | 8 | case 'retry': |
|
172 | 8 | $definition->addArgument([ |
|
173 | 8 | 'retries' => $config['retry'], |
|
174 | 8 | ]); |
|
175 | break; |
||
176 | case 'stopwatch': |
||
177 | $definition->replaceArgument(0, new Reference($config['stopwatch'])); |
||
178 | break; |
||
179 | 8 | ||
180 | /* client specific plugins */ |
||
181 | |||
182 | case 'add_host': |
||
183 | $uriService = $serviceId.'.host_uri'; |
||
184 | $this->createUri($container, $uriService, $config['host']); |
||
185 | $definition->replaceArgument(0, new Reference($uriService)); |
||
186 | $definition->replaceArgument(1, [ |
||
187 | 'replace' => $config['replace'], |
||
188 | ]); |
||
189 | break; |
||
190 | case 'header_append': |
||
191 | case 'header_defaults': |
||
192 | case 'header_set': |
||
193 | case 'header_remove': |
||
194 | $definition->replaceArgument(0, $config['headers']); |
||
195 | break; |
||
196 | |||
197 | default: |
||
198 | throw new \InvalidArgumentException(sprintf('Internal exception: Plugin %s is not handled', $name)); |
||
199 | } |
||
200 | } |
||
201 | |||
202 | /** |
||
203 | * @param ContainerBuilder $container |
||
204 | * @param array $config |
||
205 | */ |
||
206 | private function configureAuthentication(ContainerBuilder $container, array $config) |
||
207 | { |
||
208 | foreach ($config as $name => $values) { |
||
209 | $authServiceKey = sprintf('httplug.plugin.authentication.%s.auth', $name); |
||
210 | switch ($values['type']) { |
||
211 | case 'bearer': |
||
212 | $container->register($authServiceKey, Bearer::class) |
||
213 | ->addArgument($values['token']); |
||
214 | break; |
||
215 | case 'basic': |
||
216 | $container->register($authServiceKey, BasicAuth::class) |
||
217 | ->addArgument($values['username']) |
||
218 | ->addArgument($values['password']); |
||
219 | break; |
||
220 | case 'wsse': |
||
221 | $container->register($authServiceKey, Wsse::class) |
||
222 | ->addArgument($values['username']) |
||
223 | ->addArgument($values['password']); |
||
224 | break; |
||
225 | case 'service': |
||
226 | $authServiceKey = $values['service']; |
||
227 | break; |
||
228 | default: |
||
229 | throw new \LogicException(sprintf('Unknown authentication type: "%s"', $values['type'])); |
||
230 | } |
||
231 | |||
232 | $container->register('httplug.plugin.authentication.'.$name, AuthenticationPlugin::class) |
||
233 | ->addArgument(new Reference($authServiceKey)); |
||
234 | } |
||
235 | } |
||
236 | |||
237 | /** |
||
238 | * @param ContainerBuilder $container |
||
239 | * @param string $clientName |
||
240 | * @param array $arguments |
||
241 | * @param bool $profiling |
||
242 | */ |
||
243 | private function configureClient(ContainerBuilder $container, $clientName, array $arguments, $profiling) |
||
244 | { |
||
245 | $serviceId = 'httplug.client.'.$clientName; |
||
246 | |||
247 | $plugins = []; |
||
248 | foreach ($arguments['plugins'] as $plugin) { |
||
249 | list($pluginName, $pluginConfig) = each($plugin); |
||
250 | if ('reference' === $pluginName) { |
||
251 | $plugins[] = $pluginConfig['id']; |
||
252 | } elseif ('authentication' === $pluginName) { |
||
253 | // TODO handle custom authentication |
||
254 | } else { |
||
255 | $pluginServiceId = $serviceId.'.plugin.'.$pluginName; |
||
256 | $def = clone $container->getDefinition('httplug.plugin'.'.'.$pluginName); |
||
257 | $def->setAbstract(false); |
||
258 | $this->configurePluginByName($pluginName, $def, $pluginConfig, $container, $pluginServiceId); |
||
259 | $container->setDefinition($pluginServiceId, $def); |
||
260 | $plugins[] = $pluginServiceId; |
||
261 | } |
||
262 | } |
||
263 | |||
264 | $pluginClientOptions = []; |
||
265 | if ($profiling) { |
||
266 | // Add the stopwatch plugin |
||
267 | if (!in_array('httplug.plugin.stopwatch', $arguments['plugins'])) { |
||
268 | array_unshift($plugins, 'httplug.plugin.stopwatch'); |
||
269 | } |
||
270 | |||
271 | // Tell the plugin journal what plugins we used |
||
272 | $container |
||
273 | ->getDefinition('httplug.collector.plugin_journal') |
||
274 | ->addMethodCall('setPlugins', [$clientName, $plugins]) |
||
275 | ; |
||
276 | |||
277 | $debugPluginServiceId = $this->registerDebugPlugin($container, $serviceId); |
||
278 | |||
279 | $pluginClientOptions['debug_plugins'] = [new Reference($debugPluginServiceId)]; |
||
280 | } |
||
281 | |||
282 | $container |
||
283 | ->register($serviceId, DummyClient::class) |
||
284 | ->setFactory([PluginClientFactory::class, 'createPluginClient']) |
||
285 | ->addArgument( |
||
286 | array_map( |
||
287 | function ($id) { |
||
288 | return new Reference($id); |
||
289 | }, |
||
290 | $plugins |
||
291 | ) |
||
292 | ) |
||
293 | ->addArgument(new Reference($arguments['factory'])) |
||
294 | ->addArgument($arguments['config']) |
||
295 | ->addArgument($pluginClientOptions) |
||
296 | ; |
||
297 | |||
298 | |||
299 | /* |
||
300 | * Decorate the client with clients from client-common |
||
301 | */ |
||
302 | View Code Duplication | if ($arguments['flexible_client']) { |
|
303 | $container |
||
304 | ->register($serviceId.'.flexible', FlexibleHttpClient::class) |
||
305 | ->addArgument(new Reference($serviceId.'.flexible.inner')) |
||
306 | ->setPublic(false) |
||
307 | ->setDecoratedService($serviceId) |
||
308 | ; |
||
309 | } |
||
310 | |||
311 | View Code Duplication | if ($arguments['http_methods_client']) { |
|
312 | $container |
||
313 | ->register($serviceId.'.http_methods', HttpMethodsClient::class) |
||
314 | ->setArguments([new Reference($serviceId.'.http_methods.inner'), new Reference('httplug.message_factory')]) |
||
315 | ->setPublic(false) |
||
316 | ->setDecoratedService($serviceId) |
||
317 | ; |
||
318 | } |
||
319 | |||
320 | View Code Duplication | if ($arguments['batch_client']) { |
|
321 | $container |
||
322 | ->register($serviceId.'.batch_client', BatchClient::class) |
||
323 | ->setArguments([new Reference($serviceId.'.batch_client.inner')]) |
||
324 | ->setPublic(false) |
||
325 | ->setDecoratedService($serviceId) |
||
326 | ; |
||
327 | } |
||
328 | } |
||
329 | |||
330 | /** |
||
331 | * Create a URI object with the default URI factory. |
||
332 | * |
||
333 | * @param ContainerBuilder $container |
||
334 | * @param string $serviceId Name of the private service to create |
||
335 | * @param string $uri String representation of the URI |
||
336 | */ |
||
337 | private function createUri(ContainerBuilder $container, $serviceId, $uri) |
||
346 | |||
347 | /** |
||
348 | * Make the user can select what client is used for auto discovery. If none is provided, a service will be created |
||
349 | * by finding a client using auto discovery. |
||
350 | * |
||
351 | * @param ContainerBuilder $container |
||
352 | * @param array $config |
||
353 | */ |
||
354 | private function configureAutoDiscoveryClients(ContainerBuilder $container, array $config) |
||
355 | { |
||
356 | $httpClient = $config['discovery']['client']; |
||
357 | |||
358 | View Code Duplication | if (!empty($httpClient)) { |
|
359 | if ($httpClient === 'auto') { |
||
360 | $httpClient = $this->registerAutoDiscoverableClient( |
||
361 | $container, |
||
362 | 'auto_discovered_client', |
||
363 | [HttpClientDiscovery::class, 'find'], |
||
364 | $this->isConfigEnabled($container, $config['profiling']) |
||
365 | ); |
||
366 | } |
||
367 | |||
368 | $httpClient = new Reference($httpClient); |
||
369 | } |
||
370 | |||
371 | $asyncHttpClient = $config['discovery']['async_client']; |
||
372 | |||
373 | View Code Duplication | if (!empty($asyncHttpClient)) { |
|
374 | if ($asyncHttpClient === 'auto') { |
||
375 | $asyncHttpClient = $this->registerAutoDiscoverableClient( |
||
376 | $container, |
||
377 | 'auto_discovered_async', |
||
378 | [HttpAsyncClientDiscovery::class, 'find'], |
||
379 | $this->isConfigEnabled($container, $config['profiling']) |
||
380 | ); |
||
381 | } |
||
382 | |||
383 | $asyncHttpClient = new Reference($asyncHttpClient); |
||
384 | } |
||
385 | |||
386 | $container |
||
387 | ->getDefinition('httplug.strategy') |
||
388 | ->addArgument($httpClient) |
||
389 | ->addArgument($asyncHttpClient) |
||
390 | ; |
||
391 | } |
||
392 | |||
393 | /** |
||
394 | * Find a client with auto discovery and return a service Reference to it. |
||
395 | * |
||
396 | * @param ContainerBuilder $container |
||
397 | * @param string $name |
||
398 | * @param callable $factory |
||
399 | * @param bool $profiling |
||
400 | * |
||
401 | * @return string service id |
||
402 | */ |
||
403 | private function registerAutoDiscoverableClient(ContainerBuilder $container, $name, $factory, $profiling) |
||
429 | |||
430 | /** |
||
431 | * Create a new plugin service for this client. |
||
432 | * |
||
433 | * @param ContainerBuilder $container |
||
434 | * @param string $serviceId |
||
435 | * |
||
436 | * @return string |
||
437 | */ |
||
438 | private function registerDebugPlugin(ContainerBuilder $container, $serviceId) |
||
451 | |||
452 | /** |
||
453 | * {@inheritdoc} |
||
454 | */ |
||
455 | public function getConfiguration(array $config, ContainerBuilder $container) |
||
459 | } |
||
460 |
Unless you are absolutely sure that the expression can never be null because of other conditions, we strongly recommend to add an additional type check to your code: