Innmind\AMQP\Transport\Protocol\v091\Reader\Queue

Complexity

Total Complexity

11

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	deleteOk()	0	4	1
A	purgeOk()	0	4	1
A	bindOk()	0	3	1
A	__invoke()	0	28	6
A	unbindOk()	0	3	1
A	declareOk()	0	6	1

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Transport\Protocol\v091\Reader;

use Innmind\AMQP\{
    Transport\Frame\Method,
    Transport\Frame\Visitor\ChunkArguments,
    Transport\Frame\Value\ShortString,
    Transport\Frame\Value\UnsignedLongInteger,
    Transport\Protocol\v091\Methods,
    Exception\UnknownMethod,
};
use Innmind\Stream\Readable;
use Innmind\Immutable\StreamInterface;

final class Queue
{
    /**
     * @return StreamInterface<Value>
     */
    public function __invoke(Method $method, Readable $arguments): StreamInterface
    {
        switch (true) {
            case Methods::get('queue.declare-ok')->equals($method):
                $chunk = $this->declareOk();
                break;

            case Methods::get('queue.bind-ok')->equals($method):
                $chunk = $this->bindOk();
                break;

            case Methods::get('queue.unbind-ok')->equals($method):
                $chunk = $this->unbindOk();
                break;

            case Methods::get('queue.purge-ok')->equals($method):
                $chunk = $this->purgeOk();
                break;

            case Methods::get('queue.delete-ok')->equals($method):
                $chunk = $this->deleteOk();
                break;

            default:
                throw new UnknownMethod($method);
        }

        return $chunk($arguments);
    }

    private function declareOk(): ChunkArguments
    {
        return new ChunkArguments(
            ShortString::class, //queue
            UnsignedLongInteger::class, //message count
            UnsignedLongInteger::class //consumer count
        );
    }

    private function bindOk(): ChunkArguments
    {
        return new ChunkArguments; //no arguments
    }

    private function unbindOk(): ChunkArguments
    {
        return new ChunkArguments; //no arguments
    }

    private function purgeOk(): ChunkArguments
    {
        return new ChunkArguments(
            UnsignedLongInteger::class //message count
        );
    }

    private function deleteOk(): ChunkArguments
    {
        return new ChunkArguments(
            UnsignedLongInteger::class //message count
        );
    }
}