Innmind\AMQP\Transport\Frame

Complexity

Total Complexity

10

Size/Duplication

Total Lines	124
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	11

Test Coverage

Coverage

100%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	22	1
A	command()	0	22	1
A	header()	0	21	1
A	body()	0	11	1
A	heartbeat()	0	7	1
A	type()	0	4	1
A	channel()	0	4	1
A	method()	0	4	1
A	values()	0	4	1
A	__toString()	0	4	1

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Transport;

use Innmind\AMQP\Transport\Frame\{
    Type,
    Channel,
    Method,
    Value,
    Value\UnsignedOctet,
    Value\UnsignedShortInteger,
    Value\UnsignedLongInteger,
    Value\Text
};
use Innmind\Math\Algebra\Integer;
use Innmind\Immutable\{
    Sequence,
    Stream,
    StreamInterface,
    Str
};

final class Frame
{
    private $type;
    private $channel;
    private $method;
    private $values;
    private $string;

    private function __construct(
        Type $type,
        Channel $channel,
        Value ...$values
    ) {
        $this->type = $type;
        $this->channel = $channel;
        $this->values = new Stream(Value::class);

        $values = new Sequence(...$values);
        $payload = $values->join('')->toEncoding('ASCII');

        $frame = new Sequence(
            new UnsignedOctet(new Integer($type->toInt())),
            new UnsignedShortInteger(new Integer($channel->toInt())),
            new UnsignedLongInteger(new Integer($payload->length())),
            ...$values
        );
        $this->string = (string) $frame
            ->add(new UnsignedOctet(new Integer(0xCE)))
            ->join('');
    }

    public static function command(
        Channel $channel,
        Method $method,
        Value ...$values
    ): self {
        $self = new self(
            Type::method(),
            $channel,
            new UnsignedShortInteger(new Integer($method->class())),
            new UnsignedShortInteger(new Integer($method->method())),
            ...$values
        );
        $self->method = $method;
        $self->values = (new Sequence(...$values))->reduce(
            $self->values,
            static function(Stream $stream, Value $value): Stream {
                return $stream->add($value);
            }
        );

        return $self;
    }

    public static function header(
        Channel $channel,
        int $class,
        Value ...$values
    ): self {
        $self = new self(
            Type::header(),
            $channel,
            new UnsignedShortInteger(new Integer($class)),
            new UnsignedShortInteger(new Integer(0)), //weight
            ...$values
        );
        $self->values = (new Sequence(...$values))->reduce(
            $self->values,
            static function(Stream $stream, Value $value): Stream {
                return $stream->add($value);
            }
        );

        return $self;
    }

    public static function body(Channel $channel, Str $payload): self
    {
        $self = new self(
            Type::body(),
            $channel,
            $value = new Text($payload)
        );
        $self->values = $self->values->add($value);

        return $self;
    }

    public static function heartbeat(): self
    {
        return new self(
            Type::heartbeat(),
            new Channel(0)
        );
    }

    public function type(): Type
    {
        return $this->type;
    }

    public function channel(): Channel
    {
        return $this->channel;
    }

    public function method(): Method
    {
        return $this->method;
    }

    /**
     * @return StreamInterface<Value>

The doc-type StreamInterface<Value> could not be parsed: Expected "|" or "end of type", but got "<" at position 15. (view supported doc-types)

     */
    public function values(): StreamInterface
    {
        return $this->values;
    }

    public function __toString(): string
    {
        return $this->string;
    }
}