Spiral\Queue\QueueableDetector

Complexity

Total Complexity

7

Size/Duplication

Total Lines	40
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getQueue()	0	14	4
A	__construct()	0	3	1
A	isQueueable()	0	9	2

<?php

declare(strict_types=1);

namespace Spiral\Queue;

use Spiral\Attributes\ReaderInterface;
use Spiral\Queue\Attribute\Queueable;

class QueueableDetector
{
    private ReaderInterface $reader;

    public function __construct(ReaderInterface $reader)
    {
        $this->reader = $reader;
    }

    /**
     * @psalm-param class-string|object $object
     */
    public function isQueueable($object): bool
    {
        $reflection = new \ReflectionClass($object);

        if ($reflection->implementsInterface(QueueableInterface::class)) {
            return true;
        }

        return $this->reader->firstClassMetadata($reflection, Queueable::class) !== null;
    }

    /**
     * @psalm-param class-string|object $object
     */
    public function getQueue($object): ?string
    {
        $reflection = new \ReflectionClass($object);

        $attribute = $this->reader->firstClassMetadata($reflection, Queueable::class);
        if ($attribute !== null) {
            return $attribute->queue;
        }

        if (\is_object($object) && $reflection->hasMethod('getQueue')) {
            return $reflection->getMethod('getQueue')->invoke($object);
        }

        return null;
    }
}