Pyrowman\PheanstalkBundle\DependencyInjection\Compiler\ProxyCompilerPass

Complexity

Total Complexity

8

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	reservedName()	0	9	1
B	process()	0	52	7

<?php

/*
 * (c) 2013 Wozbe
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Pyrowman\PheanstalkBundle\DependencyInjection\Compiler;

use Pyrowman\PheanstalkBundle\Exceptions\PheanstalkException;
use Pheanstalk\Pheanstalk;
use Pheanstalk\PheanstalkInterface;
use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Definition;

/**
 * Description of ProxyCompilerPass.
 *
 * @author Thomas Tourlourat <thomas@tourlourat.com>
 */
class ProxyCompilerPass implements CompilerPassInterface
{
    protected function reservedName()
    {
        return [
            'pheanstalks',
            'pheanstalk_locator',
            'proxy',
            'data_collector',
            'listener',
            'event',
        ];
    }

    /**
     * @inheritdoc
     */
    public function process(ContainerBuilder $container)
    {
        $defaultPheanstalkName = null;
        $pheanstalks           = $container->getParameter('pyrowman.pheanstalk.pheanstalks');

        $pheanstalkLocatorDef = $container->getDefinition('pyrowman.pheanstalk.pheanstalk_locator');

        // For each connection in the configuration file
        foreach ($pheanstalks as $name => $pheanstalk) {
            if (in_array($name, $this->reservedName())) {
                throw new \RuntimeException('Reserved pheanstalk name: '.$name);
            }

            $pheanstalkConfig = [
                $pheanstalk['server'],
                $pheanstalk['user'] ?? null,
                $pheanstalk['password'] ?? null,
                $pheanstalk['port'],
                $pheanstalk['timeout']
            ];
            $isDefault = $pheanstalk['default'];

            # @see https://github.com/armetiz/pyrowmanPheanstalkBundle/issues/61
            $pheanstalkDef = clone $container->getDefinition($pheanstalk['proxy']);

            $pheanstalkDef->addMethodCall('setPheanstalk', [new Definition(Pheanstalk::class, $pheanstalkConfig)]);
            $pheanstalkDef->addMethodCall('setName', [$name]);
            $pheanstalkDef->setPublic(true);

            $container->setDefinition('pyrowman.pheanstalk.'.$name, $pheanstalkDef);

            // Register the connection in the connection locator
            $pheanstalkLocatorDef->addMethodCall('addPheanstalk', [
                $name,
                $container->getDefinition('pyrowman.pheanstalk.'.$name),
                $isDefault,
            ]);

            if ($isDefault) {
                if (null !== $defaultPheanstalkName) {
                    throw new PheanstalkException(sprintf('Default pheanstalk already defined. "%s" & "%s"', $defaultPheanstalkName, $name));

$defaultPheanstalkName of type void is incompatible with the type string expected by parameter $args of sprintf().

                }

                $defaultPheanstalkName = $name;
                $legacyAlias = $container->setAlias('pyrowman.pheanstalk', 'pyrowman.pheanstalk.'.$name);
                if ($legacyAlias) {
                    $legacyAlias->setPublic(true);
                }

                $autoWiringAlias = $container->setAlias(PheanstalkInterface::class, 'pyrowman.pheanstalk');
                if ($autoWiringAlias) {
                    $autoWiringAlias->setPublic(true);
                }
            }
        }
    }
}