Innmind\AMQP\Transport\Protocol\v091\Exchange

Complexity

Total Complexity

2

Size/Duplication

Total Lines	33
Duplicated Lines	36.36 %

Coupling/Cohesion

Components	0
Dependencies	12

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	declare()	0	17	1
A	delete()	12	12	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
};
use Innmind\Math\Algebra\Integer;
use Innmind\Immutable\{
    Str,
    Map
};

final class Exchange implements ExchangeInterface
{
    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()),
            new Bits($command->isDurable()),
            new Bits($command->isAutoDeleted()), //reserved
            new Bits(false), //internal (reserved)
            new Bits(!$command->shouldWait()),
            new Table(new Map('string', Value::class)) //todo: use $command->arguments()

56% of this comment could be valid code. Did you maybe forget this after debugging?

        );
    }

    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()),
            new Bits(!$command->shouldWait())
        );
    }
}