OldSound\RabbitMqBundle\Declarations\DeclarationsRegistry

Complexity

Total Complexity

7

Size/Duplication

Total Lines	35
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getBindingsByExchange()	0	4	3
A	addQueue()	0	3	1
A	addBinding()	0	3	1
A	addExchange()	0	6	2

<?php

namespace OldSound\RabbitMqBundle\Declarations;

class DeclarationsRegistry
{
    /** @var ExchangeDeclaration[] */
    public $exchanges;
    /** @var QueueDeclaration[] */
    public $queues;
    /** @var BindingDeclaration[] */
    public $bindings = [];
    
    public function addExchange(ExchangeDeclaration $exchangeDeclaration)
    {
        if (isset($this->exchanges[$exchangeDeclaration->name])) {
            throw new \InvalidArgumentException(sprintf('Exchange declartion with %s name already registerd', $exchangeDeclaration->name));
        }
        $this->exchanges[$exchangeDeclaration->name] = $exchangeDeclaration;
    }
    
    public function addQueue(QueueDeclaration $queueDeclaration)
    {
        $this->queues[] = $queueDeclaration;    
    }

    public function addBinding(BindingDeclaration $bindingDeclaration)
    {
        $this->bindings[] = $bindingDeclaration;
    }

    /**
     * @param ExchangeDeclaration $exchange
     * @return BindingDeclaration[]
     */
    public function getBindingsByExchange(ExchangeDeclaration $exchange): array
    {
        return array_filter($this->bindings, function ($binding) use ($exchange) {
            return $binding->exchange === $exchange->name || ($binding->destinationIsExchange && $binding->destination === $exchange->name);
        });
    }
}