Spiral\Queue\Core\QueueInjector

Complexity

Total Complexity

8

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	createInjection()	0	21	4
A	matchType()	0	9	3

<?php

declare(strict_types=1);

namespace Spiral\Queue\Core;

use ReflectionClass;
use Spiral\Core\Container\InjectorInterface;
use Spiral\Core\Exception\Container\ContainerException;
use Spiral\Queue\Exception\InvalidArgumentException;
use Spiral\Queue\QueueConnectionProviderInterface;
use Spiral\Queue\QueueInterface;

/**
 * @implements InjectorInterface<QueueInterface>
 */
final class QueueInjector implements InjectorInterface
{
    private QueueConnectionProviderInterface $queueManager;

    public function __construct(QueueConnectionProviderInterface $queueManager)
    {
        $this->queueManager = $queueManager;
    }

    public function createInjection(ReflectionClass $class, string $context = null): QueueInterface
    {
        try {
            if ($context === null) {
                $connection = $this->queueManager->getConnection();
            } else {
                // Get Queue by context
                try {
                    $connection = $this->queueManager->getConnection($context);
                } catch (InvalidArgumentException $e) {
                    // Case when context doesn't match to configured connections
                    return $this->queueManager->getConnection();
                }
            }

            $this->matchType($class, $context, $connection);

It seems like $context can also be of type null; however, parameter $context of Spiral\Queue\Core\QueueInjector::matchType() does only seem to accept string, maybe add an additional type check?

        } catch (\Throwable $e) {
            throw new ContainerException(sprintf("Can't inject the required queue. %s", $e->getMessage()), 0, $e);
        }

        return $connection;
    }

    /**
     * Check the resolved connection implements required type
     *
     * @throws \RuntimeException
     */
    private function matchType(ReflectionClass $class, string $context, QueueInterface $connection): void
    {
        $className = $class->getName();
        if ($className !== QueueInterface::class && !$connection instanceof $className) {
            throw new \RuntimeException(
                \sprintf(
                    "The queue obtained by the context `%s` doesn't match the type `%s`.",
                    $context,
                    $className
                )
            );
        }
    }
}