Innmind\AMQP\Model\Basic\Message\Generic

Complexity

Total Complexity

41

Size/Duplication

Total Lines	265
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

41 Methods

Rating	Name	Duplication	Size	Complexity
A	type()	0	3	1
A	withContentType()	0	6	1
A	hasId()	0	3	1
A	correlationId()	0	3	1
A	body()	0	3	1
A	id()	0	3	1
A	headers()	0	3	1
A	withUserId()	0	6	1
A	hasContentType()	0	3	1
A	withTimestamp()	0	6	1
A	withExpiration()	0	6	1
A	hasContentEncoding()	0	3	1
A	withAppId()	0	6	1
A	withId()	0	6	1
A	hasAppId()	0	3	1
A	__construct()	0	4	1
A	hasCorrelationId()	0	3	1
A	hasExpiration()	0	3	1
A	withPriority()	0	6	1
A	hasReplyTo()	0	3	1
A	replyTo()	0	3	1
A	withDeliveryMode()	0	6	1
A	hasUserId()	0	3	1
A	hasType()	0	3	1
A	priority()	0	3	1
A	contentEncoding()	0	3	1
A	withReplyTo()	0	6	1
A	contentType()	0	3	1
A	expiration()	0	3	1
A	withContentEncoding()	0	6	1
A	hasDeliveryMode()	0	3	1
A	timestamp()	0	3	1
A	userId()	0	3	1
A	hasHeaders()	0	3	1
A	withType()	0	6	1
A	deliveryMode()	0	3	1
A	hasPriority()	0	3	1
A	withHeaders()	0	8	1
A	withCorrelationId()	0	6	1
A	appId()	0	3	1
A	hasTimestamp()	0	3	1

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Model\Basic\Message;

use Innmind\AMQP\Model\Basic\Message;
use Innmind\TimeContinuum\{
    PointInTimeInterface,
    ElapsedPeriod,
};
use Innmind\Immutable\{
    MapInterface,
    Map,
    Str,
};
use function Innmind\Immutable\assertMap;

final class Generic implements Message
{
    private $contentType;
    private $contentEncoding;
    private $headers;
    private $deliveryMode;
    private $priority;
    private $correlationId;
    private $replyTo;
    private $expiration;
    private $id;
    private $timestamp;
    private $type;
    private $userId;
    private $appId;
    private $body;

    public function __construct(Str $body)
    {
        $this->body = $body->toEncoding('ASCII');
        $this->headers = new Map('string', 'mixed');
    }

    public function hasContentType(): bool
    {
        return $this->contentType instanceof ContentType;
    }

    public function contentType(): ContentType
    {
        return $this->contentType;
    }

    public function withContentType(ContentType $contentType): Message
    {
        $self = clone $this;
        $self->contentType = $contentType;

        return $self;
    }

    public function hasContentEncoding(): bool
    {
        return $this->contentEncoding instanceof ContentEncoding;
    }

    public function contentEncoding(): ContentEncoding
    {
        return $this->contentEncoding;
    }

    public function withContentEncoding(ContentEncoding $contentEncoding): Message
    {
        $self = clone $this;
        $self->contentEncoding = $contentEncoding;

        return $self;
    }

    public function hasHeaders(): bool
    {
        return $this->headers->size() > 0;
    }

    /**
     * {@inheritdoc}
     */
    public function headers(): MapInterface
    {
        return $this->headers;
    }

    public function withHeaders(MapInterface $headers): Message
    {
        assertMap('string', 'mixed', $headers, 1);

        $self = clone $this;
        $self->headers = $headers;

        return $self;
    }

    public function hasDeliveryMode(): bool
    {
        return $this->deliveryMode instanceof DeliveryMode;
    }

    public function deliveryMode(): DeliveryMode
    {
        return $this->deliveryMode;
    }

    public function withDeliveryMode(DeliveryMode $deliveryMode): Message
    {
        $self = clone $this;
        $self->deliveryMode = $deliveryMode;

        return $self;
    }

    public function hasPriority(): bool
    {
        return $this->priority instanceof Priority;
    }

    public function priority(): Priority
    {
        return $this->priority;
    }

    public function withPriority(Priority $priority): Message
    {
        $self = clone $this;
        $self->priority = $priority;

        return $self;
    }

    public function hasCorrelationId(): bool
    {
        return $this->correlationId instanceof CorrelationId;
    }

    public function correlationId(): CorrelationId
    {
        return $this->correlationId;
    }

    public function withCorrelationId(CorrelationId $correlationId): Message
    {
        $self = clone $this;
        $self->correlationId = $correlationId;

        return $self;
    }

    public function hasReplyTo(): bool
    {
        return $this->replyTo instanceof ReplyTo;
    }

    public function replyTo(): ReplyTo
    {
        return $this->replyTo;
    }

    public function withReplyTo(ReplyTo $replyTo): Message
    {
        $self = clone $this;
        $self->replyTo = $replyTo;

        return $self;
    }

    public function hasExpiration(): bool
    {
        return $this->expiration instanceof ElapsedPeriod;
    }

    public function expiration(): ElapsedPeriod
    {
        return $this->expiration;
    }

    public function withExpiration(ElapsedPeriod $expiration): Message
    {
        $self = clone $this;
        $self->expiration = $expiration;

        return $self;
    }

    public function hasId(): bool
    {
        return $this->id instanceof Id;
    }

    public function id(): Id
    {
        return $this->id;
    }

    public function withId(Id $id): Message
    {
        $self = clone $this;
        $self->id = $id;

        return $self;
    }

    public function hasTimestamp(): bool
    {
        return $this->timestamp instanceof PointInTimeInterface;
    }

    public function timestamp(): PointInTimeInterface
    {
        return $this->timestamp;
    }

    public function withTimestamp(PointInTimeInterface $timestamp): Message
    {
        $self = clone $this;
        $self->timestamp = $timestamp;

        return $self;
    }

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

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

    public function withType(Type $type): Message
    {
        $self = clone $this;
        $self->type = $type;

        return $self;
    }

    public function hasUserId(): bool
    {
        return $this->userId instanceof UserId;
    }

    public function userId(): UserId
    {
        return $this->userId;
    }

    public function withUserId(UserId $userId): Message
    {
        $self = clone $this;
        $self->userId = $userId;

        return $self;
    }

    public function hasAppId(): bool
    {
        return $this->appId instanceof AppId;
    }

    public function appId(): AppId
    {
        return $this->appId;
    }

    public function withAppId(AppId $appId): Message
    {
        $self = clone $this;
        $self->appId = $appId;

        return $self;
    }

    public function body(): Str
    {
        return $this->body;
    }
}