ConnectionDriverFactory::defaultConnectionName() - Code Metrics - Inspection of "[FRAM-27] Add support of connection factories and..." - b2pweb/bdf-queue-bundle - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#3)

by Sébastien

created 2022-05-04 14:34 UTC

ConnectionDriverFactory::defaultConnectionName() A

↳ Parent: ConnectionDriverFactory

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes	1
Bugs	0	Features	0

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

<?php

namespace Bdf\QueueBundle\ConnectionFactory;

use Bdf\Queue\Connection\AmqpLib\AmqpLibConnection;
use Bdf\Queue\Connection\ConnectionDriverInterface;
use Bdf\Queue\Connection\Doctrine\DoctrineConnection;
use Bdf\Queue\Connection\Factory\ConnectionDriverFactoryInterface;
use Bdf\Queue\Connection\Gearman\GearmanConnection;
use Bdf\Queue\Connection\Memory\MemoryConnection;
use Bdf\Queue\Connection\Null\NullConnection;
use Bdf\Queue\Connection\Pheanstalk\PheanstalkConnection;
use Bdf\Queue\Connection\RdKafka\RdKafkaConnection;
use Bdf\Queue\Connection\Redis\RedisConnection;
use Bdf\Queue\Serializer\SerializerInterface;
use InvalidArgumentException;
use Psr\Container\ContainerInterface;

/**
 *
 */
final class ConnectionDriverFactory implements ConnectionDriverFactoryInterface
{
    /**
     * @var ContainerInterface
     */
    private $container;

    /**
     * @var string
     */
    private $containerId;

    /**
     * @var string
     */
    private $defaultConnection;

    /**
     * @var string[]
     */
    private $connectionNames;

    /**
     * @var ConnectionDriverConfiguratorInterface[]
     */
    private $configurators;


    /**
     * @param ContainerInterface $container
     * @param string|null $defaultConnection The default connection name
     * @param string[] $connectionNames All the connection names
     * @param string $containerId
     */
    public function __construct(ContainerInterface $container, string $defaultConnection = null, array $connectionNames = [], string $containerId = 'bdf_queue.connection_definition.%s')
    {
        $this->container = $container;
        $this->containerId = $containerId;
        $this->defaultConnection = $defaultConnection;
        $this->connectionNames = $connectionNames;
    }

    /**
     * {@inheritdoc}
     */
    public function create(?string $name): ConnectionDriverInterface
    {
        $id = sprintf($this->containerId, $name);

        if (!$this->container->has($id)) {
            throw new InvalidArgumentException('No queue driver has been set for '.$name);
        }

        return $this->container->get($id);
    }

    /**
     * {@inheritdoc}
     */
    public function defaultConnectionName(): string
    {
        return $this->defaultConnection;
    }

    /**
     * {@inheritdoc}
     */
    public function defaultConnection(): ConnectionDriverInterface
    {
        return $this->create($this->defaultConnection);
    }

    /**
     * {@inheritdoc}
     */
    public function connectionNames(): array
    {
        return $this->connectionNames;
    }

    /**
     * Register a custom configurator
     *
     * @param string $name  The name of the driver
     * @param ConnectionDriverConfiguratorInterface $configurator
     */
    public function registerConfigurator(ConnectionDriverConfiguratorInterface $configurator): void
    {
        foreach ($configurator->getSupportedDrivers() as $driver) {
            $this->configurators[$driver] = $configurator;
        }
    }

    /**
     * Create the connection driver instance
     *
     * @param Configuration $config
     * @param SerializerInterface $serializer
     *
     * @return ConnectionDriverInterface
     *
     * @internal
     */
    public function createDriver(Configuration $config, SerializerInterface $serializer)
    {
        if (isset($this->configurators[$config->getDriver()])) {
            return $this->configurators[$config->getDriver()]->configure($config, $serializer);
        }

        return $this->configureKnownDriver($config, $serializer);
    }

    /**
     * Create the known driver instance
     *
     * @param Configuration $config
     * @param SerializerInterface $serializer
     *
     * @return ConnectionDriverInterface
     *
     * @internal
     */
    private function configureKnownDriver(Configuration $config, SerializerInterface $serializer)
    {
        switch ($config->getDriver()) {
            case 'null':
                $connection = new NullConnection($config->getConnection());
                $connection->setConfig($config->toArray());
                return $connection;

            case 'memory':
                $connection = new MemoryConnection($config->getConnection(), $serializer);
                $connection->setConfig($config->toArray());
                return $connection;

            case 'gearman':
                $connection = new GearmanConnection($config->getConnection(), $serializer);
                $connection->setConfig($config->toArray());
                return $connection;

            case 'amqp-lib':
                $connection = new AmqpLibConnection(
                    $config->getConnection(),
                    $serializer,
                    $config->has('exchange_resolver') ? $this->container->get($config->get('exchange_resolver')) : null
                    $config->has('exchange_resolver') ? $this->container->get(/** @scrutinizer ignore-type */ $config->get('exchange_resolver')) : null
                );
                $connection->setConfig($config->toArray());
                return $connection;

            case 'pheanstalk':
                $connection = new PheanstalkConnection($config->getConnection(), $serializer);
                $connection->setConfig($config->toArray());
                return $connection;

            case 'rdkafka':
                $connection = new RdKafkaConnection($config->getConnection(), $serializer);
                $connection->setConfig($config->toArray());
                return $connection;

            case 'redis':
                $connection = new RedisConnection($config->getConnection(), $serializer);
                $connection->setConfig($config->toArray());
                return $connection;

            case 'doctrine':
                $connection = new DoctrineConnection($config->getConnection(), $serializer);
                $connection->setConfig($config->toArray());
                return $connection;
        }

        throw new InvalidArgumentException('The queue driver "'.$config->getDriver().'" does not exist. Did you forget to add "connection_factory" option ?');
    }
}


b2pweb / bdf-queue-bundle

Pull Request — master (#3)

ConnectionDriverFactory::defaultConnectionName() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like