Innmind\AMQP\Transport\Protocol\v091\Exchange

Complexity

Total Complexity

3

Size/Duplication

Total Lines	50
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	delete()	0	10	1
A	declare()	0	24	1

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Transport\Protocol\v091;

use Innmind\AMQP\{
    Model\Exchange\Declaration,
    Model\Exchange\Deletion,
    Transport\Frame,
    Transport\Frame\Channel as FrameChannel,
    Transport\Frame\Type,
    Transport\Frame\Value,
    Transport\Frame\Value\UnsignedShortInteger,
    Transport\Frame\Value\ShortString,
    Transport\Frame\Value\Bits,
    Transport\Frame\Value\Table,
    Transport\Protocol\Exchange as ExchangeInterface,
    Transport\Protocol\ArgumentTranslator,
};
use Innmind\Math\Algebra\Integer;
use Innmind\Immutable\{
    Str,
    Map,
};

final class Exchange implements ExchangeInterface
{
    private $translate;

    public function __construct(ArgumentTranslator $translator)
    {
        $this->translate = $translator;
    }

    public function declare(FrameChannel $channel, Declaration $command): Frame
    {
        return Frame::method(
            $channel,
            Methods::get('exchange.declare'),
            new UnsignedShortInteger(new Integer(0)), //ticket (reserved)
            ShortString::of(new Str($command->name())),
            ShortString::of(new Str((string) $command->type())),
            new Bits(
                $command->isPassive(),
                $command->isDurable(),
                $command->isAutoDeleted(), //reserved
                false, //internal (reserved)
                !$command->shouldWait()
            ),
            new Table(
                $command
                    ->arguments()
                    ->reduce(
                        new Map('string', Value::class),
                        function(Map $carry, string $key, $value): Map {
                            return $carry->put(
                                $key,
                                ($this->translate)($value)
                            );
                        }
                    )
            )
        );
    }

    public function delete(FrameChannel $channel, Deletion $command): Frame
    {
        return Frame::method(
            $channel,
            Methods::get('exchange.delete'),
            new UnsignedShortInteger(new Integer(0)), //ticket (reserved)
            ShortString::of(new Str($command->name())),
            new Bits(
                $command->onlyIfUnused(),
                !$command->shouldWait()
            )
        );
    }
}