Innmind\AMQP\Transport\Protocol\v091\Exchange

Complexity

Total Complexity

3

Size/Duplication

Total Lines	56
Duplicated Lines	25 %

Coupling/Cohesion

Components	1
Dependencies	13

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
B	declare()	0	31	1
A	delete()	14	14	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

Possible parse error: non-abstract method defined as abstract

    {
        return new Frame(
            Type::method(),
            $channel,
            Methods::get('exchange.declare'),
            new UnsignedShortInteger(new Integer(0)), //ticket (reserved)
            new ShortString(new Str($command->name())),
            new ShortString(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

This method seems to be duplicated in your project.

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