Setono\MessageSchedulerBundle\Entity\ScheduledMessage

Complexity

Total Complexity

10

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Test Coverage

Coverage

25.81%

Importance

Changes	1
Bugs	0	Features	0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	getStates()	0	8	1
A	__construct()	0	6	1
A	getState()	0	3	1
A	getDispatchAt()	0	3	1
A	resetErrors()	0	3	1
A	setState()	0	5	1
A	addError()	0	3	1
A	getSerializedMessage()	0	3	1
A	getId()	0	3	1
A	getBus()	0	3	1

<?php

declare(strict_types=1);

namespace Setono\MessageSchedulerBundle\Entity;

use DateTimeInterface;
use Ramsey\Uuid\Uuid;
use Webmozart\Assert\Assert;

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 static function getStates(): array
    {
        return [
            self::STATE_PENDING => self::STATE_PENDING,
            self::STATE_DISPATCHED => self::STATE_DISPATCHED,
            self::STATE_PROCESSING => self::STATE_PROCESSING,
            self::STATE_SUCCESSFUL => self::STATE_SUCCESSFUL,
            self::STATE_FAILED => self::STATE_FAILED,
        ];
    }

    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 setState(string $state): void
    {
        Assert::oneOf($state, self::getStates());

        $this->state = $state;
    }

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

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