Spiral\Queue\ContainerRegistry

Complexity

Total Complexity

5

Size/Duplication

Total Lines	31
Duplicated Lines	0 %

Test Coverage

Coverage

76.92%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getHandler()	0	13	3
A	className()	0	6	1

<?php

declare(strict_types=1);

namespace Spiral\Queue;

use Doctrine\Inflector\Inflector;
use Doctrine\Inflector\Rules\English\InflectorFactory;
use Psr\Container\ContainerInterface;
use Spiral\Core\Exception\Container\ContainerException;
use Spiral\Queue\Exception\JobException;

final class ContainerRegistry implements HandlerRegistryInterface
{
    private readonly Inflector $inflector;

    public function __construct(
        private readonly ContainerInterface $container
    ) {
        $this->inflector = (new InflectorFactory())->build();

The property inflector is declared read-only in Spiral\Queue\ContainerRegistry.

    }

    public function getHandler(string $jobType): HandlerInterface
    {
        try {
            $handler = $this->container->get($this->className($jobType));
        } catch (ContainerException $e) {
            throw new JobException($e->getMessage(), $e->getCode(), $e);
        }

        if (!$handler instanceof HandlerInterface) {
            throw new JobException(\sprintf('Unable to resolve job handler for `%s`', $jobType));
        }

        return $handler;
    }

    private function className(string $jobType): string
    {
        $names = \explode('.', $jobType);
        $names = \array_map(fn (string $value) => $this->inflector->classify($value), $names);

        return \implode('\\', $names);
    }
}