ApiClients\Tools\CommandBus\Factory

Complexity

Total Complexity

4

Size/Duplication

Total Lines	48
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	7

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	create()	0	20	1
B	gatherMapping()	0	24	3

<?php declare(strict_types=1);

namespace ApiClients\Tools\CommandBus;

use Composed\Package;
use function Composed\packages;
use function igorw\get_in;
use Interop\Container\ContainerInterface;
use League\Tactician\Container\ContainerLocator;
use League\Tactician\Handler\CommandHandlerMiddleware;
use League\Tactician\Handler\CommandNameExtractor\ClassNameExtractor;
use League\Tactician\Handler\MethodNameInflector\HandleInflector;
use React\EventLoop\LoopInterface;
use WyriHaximus\Tactician\CommandHandler\Mapper;

final class Factory
{
    public static function create(ContainerInterface $container)
    {
        $commandToHandlerMap = self::gatherMapping();

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

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

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

    private static function gatherMapping()
    {
        $map = [];
        /** @var Package $package */
        foreach (packages() as $package) {
            $config = $package->getConfig('extra');
            $mapping = get_in(
                $config,
                [
                    'api-clients',
                    'command-bus'
                ],
                false
            );

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

            $map += Mapper::map($package->getPath($mapping['path']), $mapping['namespace']);
        }

        return $map;
    }
}