League\Tactician\Bundle\DependencyInjection\HandlerMapping\Routing

Complexity

Total Complexity

10

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	2
A	routeToBus()	0	7	1
A	routeToAllBuses()	0	8	2
A	commandToServiceMapping()	0	5	1
A	assertValidBusId()	0	6	2
A	assertValidCommandFQCN()	0	6	2

<?php
declare(strict_types=1);

namespace League\Tactician\Bundle\DependencyInjection\HandlerMapping;

use League\Tactician\Bundle\DependencyInjection\InvalidCommandBusId;
use Symfony\Component\DependencyInjection\Exception\InvalidArgumentException;

final class Routing
{
    /**
     * [
     *     'busId_1' => [
     *         'My\Command\Name1' => 'some.service.id',
     *         'My\Other\Command' => 'some.service.id.or.same.one'
     *     ],
     *     'busId_2' => [
     *         'Legacy\App\Command1' => 'some.old.handler',
     *         ...
     *     ],
     * ]
     *
     * @var array
     */
    private $mapping = [];

    public function __construct(array $validBusIds)
    {
        foreach ($validBusIds as $validBusId) {
            $this->mapping[$validBusId] = [];
        }
    }

    public function routeToBus($busId, $commandClassName, $serviceId)
    {
        $this->assertValidBusId($busId);
        $this->assertValidCommandFQCN($commandClassName, $serviceId);

        $this->mapping[$busId][$commandClassName] = $serviceId;
    }

    public function routeToAllBuses($commandClassName, $serviceId)
    {
        $this->assertValidCommandFQCN($commandClassName, $serviceId);

        foreach($this->mapping as $busId => $mapping) {
            $this->mapping[$busId][$commandClassName] = $serviceId;
        }
    }

    public function commandToServiceMapping(string $busId): array
    {
        $this->assertValidBusId($busId);
        return $this->mapping[$busId];
    }

    private function assertValidBusId(string $busId)
    {
        if (!isset($this->mapping[$busId])) {
            throw InvalidCommandBusId::ofName($busId, array_keys($this->mapping));
        }
    }

    /**
     * @param $commandClassName
     * @param $serviceId
     */
    protected function assertValidCommandFQCN($commandClassName, $serviceId)
    {
        if (!class_exists($commandClassName)) {
            throw new InvalidArgumentException("Can not route $commandClassName to $serviceId, class $commandClassName does not exist!");
        }
    }
}