Setono\MessageSchedulerBundle\Entity\ScheduledMessage

Complexity

Total Complexity

7

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Test Coverage

Coverage

44.44%

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getState()	0	3	1
A	getDispatchAt()	0	3	1
A	addError()	0	3	1
A	getSerializedMessage()	0	3	1
A	getBus()	0	3	1
A	__construct()	0	6	1
A	getId()	0	3	1

<?php

declare(strict_types=1);

namespace Setono\MessageSchedulerBundle\Entity;

use DateTimeInterface;
use Ramsey\Uuid\Uuid;

class ScheduledMessage
{
    public const STATE_PENDING = 'pending';

    public const STATE_DISPATCHED = 'dispatched';

    public const STATE_PROCESSING = 'processing';

    public const STATE_FAILED = 'failed';

    public const STATE_SUCCESSFUL = 'successful';

    protected string $id;

    protected string $serializedMessage;

    protected DateTimeInterface $dispatchAt;

    protected ?string $bus;

    protected string $state = self::STATE_PENDING;

    protected array $errors = [];

    protected ?int $version = null;

    public function __construct(string $serializedMessage, DateTimeInterface $dispatchAt, string $bus = null)
    {
        $this->id = (string) Uuid::uuid4();
        $this->serializedMessage = $serializedMessage;
        $this->dispatchAt = $dispatchAt;
        $this->bus = $bus;
    }

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

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

    public function getDispatchAt(): DateTimeInterface
    {
        return $this->dispatchAt;
    }

    public function getBus(): ?string
    {
        return $this->bus;
    }

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

    public function addError(string $error): void
    {
        $this->errors[] = $error;
    }
}