Zenstruck\ScheduleBundle\Schedule\Task\MessageTask

Complexity

Total Complexity

9

Size/Duplication

Total Lines	61
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getStamps()	0	3	1
A	messageClass()	0	3	2
A	getMissingDependencyMessage()	0	3	1
A	getMessage()	0	3	1
A	getContext()	0	17	3
A	__construct()	0	6	1

<?php

namespace Zenstruck\ScheduleBundle\Schedule\Task;

use Symfony\Component\Messenger\Envelope;
use Symfony\Component\Messenger\Stamp\StampInterface;
use Zenstruck\ScheduleBundle\Schedule\HasMissingDependencyMessage;
use Zenstruck\ScheduleBundle\Schedule\Task;

/**
 * @experimental This is experimental and may experience BC breaks
 *
 * @author Kevin Bond <kevinbond@gmail.com>
 */
final class MessageTask extends Task implements HasMissingDependencyMessage
{
    private $message;
    private $stamps;

    /**
     * @param object|Envelope  $message
     * @param StampInterface[] $stamps
     */
    public function __construct(object $message, array $stamps = [])
    {
        $this->message = $message;
        $this->stamps = $stamps;

        parent::__construct($this->messageClass());
    }

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

    /**
     * @return StampInterface[]
     */
    public function getStamps(): array
    {
        return $this->stamps;
    }

    public function getContext(): array
    {
        $stamps = \array_merge(
            $this->message instanceof Envelope ? \array_keys($this->message->all()) : [],
            \array_map(static function(StampInterface $stamp) { return \get_class($stamp); }, $this->stamps)
        );
        $stamps = \array_map(
            static function($stamp) {
                return (new \ReflectionClass($stamp))->getShortName();
            },
            $stamps
        );
        $stamps = \implode(', ', \array_unique($stamps));

        return [
            'Message' => $this->messageClass(),
            'Stamps' => $stamps ?: '(none)',
        ];
    }

    public static function getMissingDependencyMessage(): string
    {
        return 'To use the message task you must install symfony/messenger (composer require symfony/messenger) and enable (config path: "zenstruck_schedule.messenger").';
    }

    private function messageClass(): string
    {
        return $this->message instanceof Envelope ? \get_class($this->message->getMessage()) : \get_class($this->message);
    }
}