ApiClients\Tools\CommandBus\Factory

Complexity

Total Complexity

6

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	7

Test Coverage

Coverage

92.59%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	create()	0	24	2
A	resolveMapping()	0	28	4

<?php declare(strict_types=1);

namespace ApiClients\Tools\CommandBus;

use Composed\Package;
use League\Tactician\Container\ContainerLocator;
use League\Tactician\Handler\CommandHandlerMiddleware;
use League\Tactician\Handler\CommandNameExtractor\ClassNameExtractor;
use League\Tactician\Handler\MethodNameInflector\HandleInflector;
use Psr\Container\ContainerInterface;
use React\EventLoop\LoopInterface;
use Traversable;
use function Composed\packages;
use function igorw\get_in;

final class Factory
{
    public static function create(ContainerInterface $container, array $options = [])
    {
        $commandToHandlerMap = self::resolveMapping($options[Options::COMMAND_HANDLER_MAP_CACHE_FILE] ?? null);

        if ($commandToHandlerMap instanceof Traversable) {
            $commandToHandlerMap = iterator_to_array($commandToHandlerMap);
        }

        $containerLocator = new ContainerLocator(
            $container,
            $commandToHandlerMap
        );

        $commandHandlerMiddleware = new CommandHandlerMiddleware(
            new ClassNameExtractor(),
            $containerLocator,
            new HandleInflector()
        );

        return new CommandBus(
            $container->get(LoopInterface::class),
            $commandHandlerMiddleware
        );
    }

    private static function resolveMapping(?string $cacheFile): array
    {
        $directories = [];
        /** @var Package $package */
        foreach (packages() as $package) {
            $config = $package->getConfig('extra');

            if ($config === null) {
                continue;
            }

            $mapping = get_in(
                $config,
                [
                    'api-clients',
                    'command-bus',
                ]
            );

            if ($mapping === null) {
                continue;
            }

            $directories[$package->getPath($mapping['path'])] = $mapping['namespace'];
        }

        return Mapping::resolve($directories, $cacheFile);
    }
}