RabbitMQManager::getConnections() - Code Metrics - Inspection of "Merge branch 'release/0.1.0'" - kunalvarma05/laravel-rabbitmq - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Branch — master (74fab5)

by Kunal

created 2020-02-24 12:02 UTC

RabbitMQManager::getConnections() A

↳ Parent: RabbitMQManager

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
eloc	1
c	0
b	0
f	0
nc	1
nop	0
dl	0
loc	3
rs	10

<?php

namespace Kunnu\RabbitMQ;

use Illuminate\Config\Repository;
use Illuminate\Support\Collection;
use PhpAmqpLib\Channel\AMQPChannel;
use PhpAmqpLib\Connection\AMQPSSLConnection;
use Illuminate\Contracts\Container\Container;
use PhpAmqpLib\Connection\AbstractConnection;

class RabbitMQManager
{
    /**
     * Configuration key.
     *
     * @var string
     */
    const CONFIG_KEY = 'rabbitmq';

    /**
     * IoC Container/Application.
     *
     * @var Container $app
     */
    protected Container $app;

    /**
     * Configuration repository.
     *
     * @var Repository $config
     */
    protected Repository $config;

    /**
     * Connection pool.
     *
     * @var Collection $connections
     */
    protected Collection $connections;

    /**
     * Channel pool.
     *
     * @var Collection $channels
     */
    protected Collection $channels;

    /**
     * Create a new RabbitMQManager instance.
     *
     * @param Container $app
     */
    public function __construct(Container $app)
    {
        $this->app = $app;
        $this->config = $this->app->get('config');
        $this->connections = new Collection([]);
        $this->channels = new Collection([]);
    }

    /**
     * Get Connections.
     *
     * @return Collection
     */
    public function getConnections(): Collection
    {
        return $this->connections;
    }

    /**
     * Get Config.
     *
     * @return Repository
     */
    public function getConfig(): Repository
    {
        return $this->config;
    }

    /**
     * Get Application Container.
     *
     * @return Container
     */
    public function getApp(): Container
    {
        return $this->app;
    }

    /**
     * Get Channels.
     *
     * @return Collection
     */
    public function getChannels(): Collection
    {
        return $this->channels;
    }

    /**
     * Resolve default connection name.
     *
     * @return string|null
     */
    public function resolveDefaultConfigName(): ?string
    {
        $configKey = self::CONFIG_KEY;
        return $this->config->get("{$configKey}.defaultConnection");
    }

    /**
     * Resolve connection instance by name.
     *
     * @param string|null $name
     * @param ConnectionConfig|null $config
     * @return AbstractConnection
     */
    public function resolveConnection(?string $name = null, ?ConnectionConfig $config = null): AbstractConnection
    {
        $name = $name ?? $this->resolveDefaultConfigName();

        if (!$this->connections->has($name)) {
            $this->connections->put(
                $name,
                $this->makeConnection($config ?? $this->resolveConfig($name))
                $this->makeConnection($config ?? $this->resolveConfig(/** @scrutinizer ignore-type */ $name))
            );
        }

        return $this->connections->get($name);
    }

    /**
     * Resolve connection configuration.
     *
     * @return ConnectionConfig
     */
    public function resolveConfig(string $connectionName): ConnectionConfig
    {
        $configKey = self::CONFIG_KEY;
        $connectionKey = "{$configKey}.connections.{$connectionName}";
        return new ConnectionConfig($this->config->get($connectionKey, []));
    }

    /**
     * Get the publisher.
     *
     * @return RabbitMQPublisher
     */
    public function publisher(): RabbitMQPublisher
    {
        return new RabbitMQPublisher($this);
    }

    /**
     * Get the consumer.
     *
     * @return RabbitMQConsumer
     */
    public function consumer(): RabbitMQConsumer
    {
        return new RabbitMQConsumer($this);
    }

    /**
     * Resolve the channel ID.
     *
     * @param string|null $channelId
     * @param string|null $connectionName
     * @return string|null
     */
    public function resolveChannelId(?string $channelId, ?string $connectionName): ?string
    public function resolveChannelId(?string $channelId, /** @scrutinizer ignore-unused */ ?string $connectionName): ?string
    {
        $configKey = self::CONFIG_KEY;
        return $channelId ?? $this->config->get("{$configKey}.defaults.channel_id", $channelId);
    }

    /**
     * Resolve channel for the given connection.
     *
     * @param string|null $connectionName
     * @param string|null $channelId
     * @param AbstractConnection|null $connection
     *
     * @return AMQPChannel|null
     */
    public function resolveChannel(
        ?string $connectionName = null,
        ?string $channelId = null,
        ?AbstractConnection $connection = null
    ): AMQPChannel {
        if (!$connection) {
            $connection = $this->resolveConnection($connectionName);
        }

        if (!$this->channels->has("{$connectionName}.{$channelId}")) {
            $this->channels->put("{$connectionName}.{$channelId}", $connection->channel($channelId));
            $this->channels->put("{$connectionName}.{$channelId}", $connection->channel(/** @scrutinizer ignore-type */ $channelId));
        }

        return $this->channels->get("{$connectionName}.{$channelId}");
    }

    /**
     * Create a new connection.
     *
     * @param ConnectionConfig $config
     *
     * @return AbstractConnection
     */
    protected function makeConnection(ConnectionConfig $config): AbstractConnection
    {
        return new AMQPSSLConnection(
            $config->getHost(),
            $config->getPort(),
            $config->getUser(),
            $config->getPassword(),
            $config->getVhost(),
            $config->getSSLOptions(),
            $config->getOptions(),
            $config->getSSLProtocol(),
        );
    }
}


kunalvarma05 / laravel-rabbitmq

Branch — master (74fab5)

RabbitMQManager::getConnections() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like