Innmind\AMQP\Transport\Protocol\v091\Channel

Complexity

Total Complexity

7

Size/Duplication

Total Lines	67
Duplicated Lines	64.18 %

Coupling/Cohesion

Components	0
Dependencies	12

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	open()	0	9	1
A	flow()	9	9	1
A	flowOk()	9	9	1
B	close()	25	25	3
A	closeOk()	0	8	1

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Transport\Protocol\v091;

use Innmind\AMQP\{
    Model\Channel\Flow,
    Model\Channel\FlowOk,
    Model\Channel\Close,
    Transport\Protocol\Channel as ChannelInterface,
    Transport\Frame,
    Transport\Frame\Method,
    Transport\Frame\Channel as FrameChannel,
    Transport\Frame\Type,
    Transport\Frame\Value\ShortString,
    Transport\Frame\Value\Bits,
    Transport\Frame\Value\UnsignedShortInteger
};
use Innmind\Math\Algebra\Integer;
use Innmind\Immutable\Str;

final class Channel implements ChannelInterface
{
    public function open(FrameChannel $channel): Frame
    {
        return new Frame(
            Type::method(),
            $channel,
            Methods::get('channel.open'),
            new ShortString(new Str('')) //out of band (reserved)
        );
    }

    public function flow(FrameChannel $channel, Flow $command): Frame

This method seems to be duplicated in your project.

    {
        return new Frame(
            Type::method(),
            $channel,
            Methods::get('channel.flow'),
            new Bits($command->active())
        );
    }

    public function flowOk(FrameChannel $channel, FlowOk $command): Frame

This method seems to be duplicated in your project.

    {
        return new Frame(
            Type::method(),
            $channel,
            Methods::get('channel.flow-ok'),
            new Bits($command->active())
        );
    }

    public function close(FrameChannel $channel, Close $command): Frame

This method seems to be duplicated in your project.

    {
        $replyCode = 0;
        $replyText = '';
        $method = new Method(0, 0);

        if ($command->hasReply()) {
            $replyCode = $command->replyCode();
            $replyText = $command->replyText();
        }

        if ($command->causedKnown()) {
            $method = Methods::get($command->cause());
        }

        return new Frame(
            Type::method(),
            $channel,
            Methods::get('channel.close'),
            new UnsignedShortInteger(new Integer($replyCode)),
            new ShortString(new Str($replyText)),
            new UnsignedShortInteger(new Integer($method->class())),
            new UnsignedShortInteger(new Integer($method->method()))
        );
    }

    public function closeOk(FrameChannel $channel): Frame
    {
        return new Frame(
            Type::method(),
            $channel,
            Methods::get('channel.close-ok')
        );
    }
}