Innmind\AMQP\Transport\Protocol\v091\Channel

Complexity

Total Complexity

7

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	flow()	0	6	1
A	flowOk()	0	6	1
A	open()	0	6	1
A	closeOk()	0	5	1
A	close()	0	22	3

<?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 Frame::method(
            $channel,
            Methods::get('channel.open'),
            new ShortString(new Str('')) //out of band (reserved)
        );
    }

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

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

    public function close(FrameChannel $channel, Close $command): Frame
    {
        $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 Frame::method(
            $channel,
            Methods::get('channel.close'),
            UnsignedShortInteger::of(new Integer($replyCode)),
            ShortString::of(new Str($replyText)),
            UnsignedShortInteger::of(new Integer($method->class())),
            UnsignedShortInteger::of(new Integer($method->method()))
        );
    }

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