Innmind\AMQP\Client\AutoDeclare

Complexity

Total Complexity

6

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	declareThrough()	0	19	2
A	close()	0	4	1
A	closed()	0	3	1
A	__construct()	0	14	1
A	channel()	0	6	1

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Client;

use Innmind\AMQP\{
    Client,
    Model\Exchange\Declaration as Exchange,
    Model\Queue\Declaration as Queue,
    Model\Queue\Binding,
};
use Innmind\Immutable\{
    SetInterface,
    Set,
};
use function Innmind\Immutable\assertSet;

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

    /**
     * @param SetInterface<Exchange>|null $exchanges
     * @param SetInterface<Queue>|null $queues
     * @param SetInterface<Binding>|null $bindings
     */
    public function __construct(
        Client $client,
        SetInterface $exchanges = null,
        SetInterface $queues = null,
        SetInterface $bindings = null
    ) {
        $this->client = $client;
        $this->exchanges = $exchanges ?? Set::of(Exchange::class);
        $this->queues = $queues ?? Set::of(Queue::class);
        $this->bindings = $bindings ?? Set::of(Binding::class);

        assertSet(Exchange::class, $this->exchanges, 2);
        assertSet(Queue::class, $this->queues, 3);
        assertSet(Binding::class, $this->bindings, 4);
    }

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

        $exchange = $channel->exchange();
        $queue = $channel->queue();

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