Innmind\AMQP\Transport\Connection\FrameReader::__invoke()

Complexity

Conditions	4
Paths	4

Size

Total Lines	42
Code Lines	26

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	20

Importance

Changes

0

<?php
    public function __invoke(Readable $stream, Protocol $protocol): Frame
    {
        $type = Type::fromInt(
            UnsignedOctet::fromString($stream->read(1))->original()->value()
        );
        $channel = new Channel(
            UnsignedShortInteger::fromString($stream->read(2))->original()->value()
        );
        $payload = $stream
            ->read(UnsignedLongInteger::fromString($stream->read(4))->original()->value())
            ->toEncoding('ASCII');

        if ($payload->length() < 4) {
            throw new PayloadTooShort;
        }

        $end = $stream->read(1)->toEncoding('ASCII');

        if ($end->length() !== 1) {
            throw new ReceivedFrameNotDelimitedCorrectly;
        }

        $end = UnsignedOctet::fromString($end)->original()->value();

        if ($end !== 0xCE) {
            throw new ReceivedFrameNotDelimitedCorrectly;
        }

        $method = $payload->substring(0, 4);
        $method = new Method(
            UnsignedShortInteger::fromString($method->substring(0, 2))->original()->value(),
            UnsignedShortInteger::fromString($method->substring(2, 4))->original()->value()
        );
        $arguments = $payload->substring(4);

        return new Frame(
            $type,
            $channel,
            $method,
            ...$protocol->read($method, $arguments)
        );
    }
}