Innmind\AMQPBundle\Client\AutoDeclare

Complexity

Total Complexity

15

Size/Duplication

Total Lines	92
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

92%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	declareExchange()	0	11	3
A	declareQueue()	0	15	4
A	declareBinding()	0	10	2
A	channel()	0	7	1
A	closed()	0	4	1
A	close()	0	5	1
A	declareThrough()	0	17	2

<?php
declare(strict_types = 1);

namespace Innmind\AMQPBundle\Client;

use Innmind\AMQP\{
    Client,
    Client\Channel,
    Model\Exchange\Declaration as Exchange,
    Model\Exchange\Type,
    Model\Queue\Declaration as Queue,
    Model\Queue\Binding
};
use Innmind\Immutable\Set;

final class AutoDeclare implements Client
{
    private $client;
    private $exchanges;
    private $queues;
    private $bindings;
    private $declared = false;

    public function __construct(Client $client)
    {
        $this->client = $client;
        $this->exchanges = new Set(Exchange::class);
        $this->queues = new Set(Queue::class);
        $this->bindings = new Set(Binding::class);
    }

    public function declareExchange(string $name, string $type, bool $durable, array $arguments): void
    {
        $constructor = $durable ? 'durable' : 'temporary';
        $exchange = Exchange::$constructor($name, Type::$type());

        foreach ($arguments as $key => $value) {
            $exchange = $exchange->withArgument($key, $value);
        }

        $this->exchanges = $this->exchanges->add($exchange);
    }

    public function declareQueue(string $name, bool $durable, bool $exclusive, array $arguments): void
    {
        $constructor = $durable ? 'durable' : 'temporary';
        $queue = Queue::$constructor()->withName($name);

        if ($exclusive) {
            $queue = $queue->exclusive();
        }

        foreach ($arguments as $key => $value) {
            $queue = $queue->withArgument($key, $value);
        }

        $this->queues = $this->queues->add($queue);
    }

    public function declareBinding(string $exchange, string $queue, string $routingKey, array $arguments): void
    {
        $binding = new Binding($exchange, $queue, $routingKey);

        foreach ($arguments as $key => $value) {
            $binding = $binding->withArgument($key, $value);
        }

        $this->bindings = $this->bindings->add($binding);
    }

    public function channel(): Channel
    {
        $channel = $this->client->channel();
        $this->declareThrough($channel);

        return $channel;
    }

    public function closed(): bool
    {
        return $this->client->closed();
    }

    public function close(): void
    {
        $this->client->close();
        $this->declared = true;
    }

    private function declareThrough(Channel $channel): void
    {
        if ($this->declared) {
            return;
        }

        $this->exchanges->foreach(static function(Exchange $command) use ($channel): void {
            $channel->exchange()->declare($command);
        });
        $this->queues->foreach(static function(Queue $command) use ($channel): void {
            $channel->queue()->declare($command);
        });
        $this->bindings->foreach(static function(Binding $command) use ($channel): void {
            $channel->queue()->bind($command);
        });
        $this->declared = true;
    }
}