Simple\Queue\MessageHydrator

Complexity

Total Complexity

11

Size/Duplication

Total Lines	128
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	1

10 Methods

Rating	Name	Duplication	Size	Complexity
A	increaseAttempt()	0	5	1
A	getMessage()	0	3	1
A	changeProperty()	0	5	1
A	__construct()	0	3	1
A	createMessage()	0	20	2
A	changeStatus()	0	5	1
A	setError()	0	5	1
A	jobable()	0	5	1
A	changeAttempts()	0	5	1
A	hydrate()	0	6	1

<?php

declare(strict_types=1);

namespace Simple\Queue;

use Exception;
use DateTimeImmutable;
use ReflectionProperty;
use ReflectionException;
use Laminas\Hydrator\ReflectionHydrator;
use Laminas\Hydrator\Strategy\HydratorStrategy;

/**
 * Class MessageHydrator
 *
 * Hydrator which changes system data
 *
 * @package Simple\Queue
 */
class MessageHydrator
{
    /** @var Message */
    private Message $message;

    /**
     * MessageHydrator constructor.
     * @param Message $message
     */
    public function __construct(Message $message)
    {
        $this->message = clone $message;
    }

    /**
     * @param string $status
     * @return MessageHydrator
     */
    public function changeStatus(string $status): self
    {
        $this->message = $this->hydrate(['status' => new Status($status)]);

        return $this;
    }

    /**
     * @param bool $isJob
     * @return $this
     */
    public function jobable(bool $isJob = true): self
    {
        $this->message = $this->hydrate(['isJob' => $isJob]);

        return $this;
    }

    /**
     * @param string|null $error
     * @return $this
     */
    public function setError(?string $error): self
    {
        $this->message = $this->hydrate(['error' => $error]);

        return $this;
    }

    /**
     * @return $this
     */
    public function increaseAttempt(): self
    {
        $this->hydrate(['attempts' => $this->message->getAttempts() + 1]);

        return $this;
    }

    /**
     * @param int $amount
     * @return $this
     */
    public function changeAttempts(int $amount): self
    {
        $this->hydrate(['attempts' => $amount]);

        return $this;
    }

    /**
     * @return Message
     */
    public function getMessage(): Message
    {
        return $this->message;
    }

    /**
     * @param Message $message
     * @param string $property
     * @param $value
     * @throws ReflectionException
     */
    public static function changeProperty(Message $message, string $property, $value): void
    {
        $r = new ReflectionProperty($message, $property);
        $r->setAccessible(true);
        $r->setValue($message, $value);
    }

    /**
     * Create entity Message from array data
     *
     * @param array $data
     * @return Message
     * @throws Exception
     */
    public static function createMessage(array $data): Message
    {
        $strategy = new HydratorStrategy(new ReflectionHydrator(), Message::class);

        /** @var Message $message */
        $message = $strategy->hydrate(array_merge($data, [
            'queue' => $data['queue'] ?? 'default',
            'event' => $data['event'] ?? null,
            'isJob' => $data['is_job'] ?? false,
            'body' => $data['body'] ?? '',
            'error' => $data['error'] ?? null,
            'attempts' => $data['attempts'] ?? 0,
            'status' => new Status($data['status'] ?? Status::NEW),
            'priority' => new Priority((int)($data['priority'] ?? Priority::DEFAULT)),
            'exactTime' => $data['exact_time'] ?? time(),
            'createdAt' => new DateTimeImmutable($data['created_at'] ?? 'now'),
            'redeliveredAt' => isset($data['redelivered_at']) ? new DateTimeImmutable($data['redelivered_at']) : null,
        ]));

        return $message;
    }

    /**
     * @param array $data
     * @return Message
     */
    protected function hydrate(array $data): Message
    {
        /** @var Message $redeliveredMessage */
        $redeliveredMessage = (new ReflectionHydrator())->hydrate($data, $this->message);

        return $redeliveredMessage;
    }
}