Declarator::declareQueues() - Code Metrics - Inspection of "[WIP] Experimental 3.0" - eMAGTechLabs/RabbitMqBundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed
Pull Request — master (#39)

by Aleksandr
created 2020-11-28 14:06 UTC
Declarator::declareQueues() A

↳ Parent: Declarator
Complexity

Conditions	3
Paths	3
Size

Total Lines	23
Code Lines	16
Duplication

Lines	0
Ratio	0 %
Importance

Changes	1
Bugs	0	Features	0
Metric	Value
cc	3
eloc	16
c	1
b	0
f	0
nc	3
nop	1
dl	0
loc	23
rs	9.7333
<?php

namespace OldSound\RabbitMqBundle\Declarations;

use OldSound\RabbitMqBundle\RabbitMq\Consumer;
use PhpAmqpLib\Channel\AMQPChannel;
use Psr\Log\LoggerAwareTrait;
use Psr\Log\NullLogger;
use Symfony\Component\Console\Output\OutputInterface;

class Declarator
{
    use LoggerAwareTrait;
    /** @var AMQPChannel */
    private $channel;
    
    public function __construct(AMQPChannel $channel)
    {
        $this->channel = $channel;
        $this->logger = new NullLogger();
    }

    /**
     * @param ExchangeDeclaration[] $exchanges
     */
    public function declareExchanges(array $exchanges) 
    {
        foreach ($exchanges as $exchange) {
            $this->channel->exchange_declare(
                $exchange->name,
                $exchange->type,
                $exchange->passive,
                $exchange->durable,
                $exchange->autoDelete,
                $exchange->internal,
                $exchange->nowait,
                $exchange->arguments,
                $exchange->ticket,
            );

            $this->logger->info(sprintf('Exchange is declared successfully', ['exchange' => $exchange]));
            $this->logger->info(sprintf('Exchange is declared successfully', /** @scrutinizer ignore-type */ ['exchange' => $exchange]));
        }
    }

    /**
     * @param QueueDeclaration[] $queues
     * @return string[]
     */
    public function declareQueues(array $queues): array
    {
        $results = [];
        foreach ($queues as $queue) {
            $result = $this->channel->queue_declare(
                $queue->name,
                $queue->passive,
                $queue->durable,
                $queue->exclusive,
                $queue->autoDelete,
                $queue->nowait,
                $queue->arguments,
                $queue->ticket,
            );

            if ($result === null) {
                // TODO
            } else {
                $results[] = $result[0];
                $this->logger->info(sprintf('Queue is declared successfully', ['queue' => $queue]));
                $this->logger->info(sprintf('Queue is declared successfully', /** @scrutinizer ignore-type */ ['queue' => $queue]));
            }
        }
        return $results;
    }

    /**
     * @param BindingDeclaration[] $bindings
     */
    public function declareBindings(array $bindings) 
    {
        foreach ($bindings as $binding) {
            if ($binding->destinationIsExchange) {
                foreach ($binding->routingKeys as $routingKey) {
                    $this->channel->exchange_bind(
                        $binding->destination,
                        $binding->exchange,
                        /** @scrutinizer ignore-type */ $binding->exchange,
                        $routingKey,
                        $binding->nowait,
                        $binding->arguments
                    );
                }
            } else {
                foreach ($binding->routingKeys as $routingKey) {
                    $this->channel->queue_bind(
                        $binding->destination,
                        $binding->exchange,
                        /** @scrutinizer ignore-type */ $binding->exchange,
                        $routingKey,
                        $binding->nowait,
                        $binding->arguments
                    );
                }
            }

            $this->logger->info(sprintf('Binding is declared successfully', ['binding' => $binding]));
            $this->logger->info(sprintf('Binding is declared successfully', /** @scrutinizer ignore-type */ ['binding' => $binding]));
        }
    }

    public function declareForExchange(ExchangeDeclaration $exchange, DeclarationsRegistry $declarationsRegistry) 
    {
        $bindings = $declarationsRegistry->getBindingsByExchange($exchange);
        $queues = array_filter($bindings, function ($binding) use($exchange) {
            false === $binding->destinationIsExchange && $binding->destination == $exchange->name;
        });

        $this->declareExchanges([$exchange]);
        $this->declareQueues($queues);
        $this->declareBindings($bindings);
    }

    public function declareForQueueDeclaration(string $queueName, DeclarationsRegistry $declarationsRegistry)
    {
        $consumerQueues = array_filter($declarationsRegistry->queues, function ($queue) use ($queueName) {
            return $queue->name === $queueName;
            // TODO not found! exception?
        });

        /** @var BindingDeclaration[] $bindings */
        $bindings = [];
        $exchanges = [];
        foreach ($consumerQueues as $queue) {
            $b = array_filter($declarationsRegistry->bindings, function ($binding) use ($queue) {
                return !$binding->destinationIsExchange && $binding->destination === $queue->name;
            });
            $bindings = array_merge($bindings, $b);
            foreach ($b as $binding) {
                $exchanges[] = $binding->exchange;
                if ($binding->destinationIsExchange) {
                    $exchanges[] = $binding->destination;
                }
            }
        }

        $exchanges = array_map(fn ($exchange) => $declarationsRegistry->exchanges[$exchange], array_unique($exchanges));
        $this->declareExchanges($exchanges);
        $this->declareQueues($consumerQueues);
        $this->declareBindings($bindings);
    }
    
    public function declareForQueue(QueueDeclaration $queue)
    {
        $exchanges = array_map(function ($binding) {
            return $binding->exchange;
        }, $queue->bindings);


        $this->declareExchanges($exchanges);
        $this->declareQueues([$queue]);
        $this->declareBindings($queue->bindings);
    }
    
    public function purgeQueue(QueueDeclaration $queue, $nowait = true, ?int $ticket = null)
    {
        $this->channel->queue_purge($queue->name, $nowait, $ticket);
    }
    
    public function deleteQueue(
        QueueDeclaration $queue, 
        bool $ifUnsed = true, 
        bool $ifEmpry = false,
        bool $nowait = false, 
        ?int $ticket = null
    ) {
        $this->channel->queue_delete($queue->name, $ifUnsed, $ifEmpry, $nowait, $ticket);
    }
}
eMAGTechLabs / RabbitMqBundle

Pull Request — master (#39)

Declarator::declareQueues() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
