Jellyfish\QueueRabbitMq\QueueRabbitMqServiceProvider

Complexity

Total Complexity

3

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	registerQueueClient()	0	7	1
A	createConnection()	0	38	1
A	register()	0	3	1

<?php

namespace Jellyfish\QueueRabbitMq;

use Jellyfish\Config\ConfigInterface;
use Jellyfish\Queue\MessageMapperInterface;
use Jellyfish\Queue\QueueClientInterface;
use PhpAmqpLib\Connection\AbstractConnection;
use PhpAmqpLib\Connection\AMQPLazyConnection;
use Pimple\Container;
use Pimple\ServiceProviderInterface;

class QueueRabbitMqServiceProvider implements ServiceProviderInterface
{
    /**
     * @param \Pimple\Container $pimple
     *
     * @return void
     */
    public function register(Container $pimple): void
    {
        $this->registerQueueClient($pimple);
    }

    protected function registerQueueClient(Container $container): QueueRabbitMqServiceProvider
    {
        $self = $this;
        $container->offsetSet('queue_client', function (Container $container) use ($self) {
            return new QueueClient(
                $self->createConnection($container),
                $container->offsetGet('message_mapper')
            );
        });

In this branch, the function will implicitly return null which is incompatible with the type-hinted return Jellyfish\QueueRabbitMq\QueueRabbitMqServiceProvider. Consider adding a return statement or allowing null as return value.

    }

    /**
     * @param \Pimple\Container $container
     *
     * @return \PhpAmqpLib\Connection\AbstractConnection
     */
    protected function createConnection(Container $container): AbstractConnection
    {
        $config = $container->offsetGet('config');

        $rabbitMqHost = $config->get(
            QueueRabbitMqConstants::RABBIT_MQ_HOST,
            QueueRabbitMqConstants::DEFAULT_RABBIT_MQ_HOST
        );

        $rabbitMqPort = $config->get(
            QueueRabbitMqConstants::RABBIT_MQ_PORT,
            QueueRabbitMqConstants::DEFAULT_RABBIT_MQ_PORT
        );

        $rabbitMqUser = $config->get(
            QueueRabbitMqConstants::RABBIT_MQ_USER,
            QueueRabbitMqConstants::DEFAULT_RABBIT_MQ_USER
        );

        $rabbitMqPassword = $config->get(
            QueueRabbitMqConstants::RABBIT_MQ_PASSWORD,
            QueueRabbitMqConstants::DEFAULT_RABBIT_MQ_PASSWORD
        );

        $rabbitMqVhost = $config->get(
            QueueRabbitMqConstants::RABBIT_MQ_VHOST,
            QueueRabbitMqConstants::DEFAULT_RABBIT_MQ_VHOST
        );

        $connection = new AMQPLazyConnection(
            $rabbitMqHost,
            $rabbitMqPort,
            $rabbitMqUser,
            $rabbitMqPassword,
            $rabbitMqVhost
        );

        return $connection;
    }
}