ConnectionDriverFactory::createDriver() - Code Metrics - Inspection of "feat: Adding support of ConnectionDriverFactoryInt..." - b2pweb/bdf-queue-bundle - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( add0cc...b0f8c9 )

by Sébastien

created 2022-04-25 13:16 UTC

ConnectionDriverFactory::createDriver() B

↳ Parent: ConnectionDriverFactory

Complexity

Conditions	10
Paths	9

Size

Total Lines	50
Code Lines	37

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	8
CRAP Score	58.1521

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	10
eloc	37
c	1
b	0
f	0
nc	9
nop	2
dl	0
loc	50
ccs	8
cts	37
cp	0.2162
crap	58.1521
rs	7.6666

How to fix Complexity

<?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;


    /**
     * @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;
    }

    /**
     * Create the connection driver instance
     *
     * @param Configuration $config
     * @param SerializerInterface $serializer
     *
     * @return ConnectionDriverInterface
     */
    public function createDriver(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

Push — master ( add0cc...b0f8c9 )

ConnectionDriverFactory::createDriver() B

Complexity

Size

Duplication

Code Coverage

Importance

How to fix Complexity

Long Method

Duplication Side-by-Side

Filter issues like