Innmind\CommandBusBundle\ContainerAwareCommandBus

Complexity

Total Complexity

7

Size/Duplication

Total Lines	53
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	14	3
A	handle()	0	12	3
A	initialize()	0	15	1

<?php
declare(strict_types = 1);

namespace Innmind\CommandBusBundle;

use Innmind\CommandBusBundle\Exception\InvalidArgumentException;
use Innmind\CommandBus\{
    CommandBusInterface,
    CommandBus,
    Exception\InvalidArgumentException as InvalidCommandException
};
use Innmind\Immutable\{
    Map,
    MapInterface
};
use Symfony\Component\DependencyInjection\ContainerInterface;

final class ContainerAwareCommandBus implements CommandBusInterface
{
    private $container;
    private $handlers;
    private $bus;

    public function __construct(
        ContainerInterface $container,
        MapInterface $handlers
    ) {
        if (
            (string) $handlers->keyType() !== 'string' ||
            (string) $handlers->valueType() !== 'string'
        ) {
            throw new InvalidArgumentException;
        }

        $this->container = $container;
        $this->handlers = $handlers;
    }

    /**
     * {@inheritdoc}
     */
    public function handle($command)
    {
        if (!is_object($command)) {
            throw new InvalidCommandException;
        }

        if (!$this->bus instanceof CommandBusInterface) {
            $this->initialize();
        }

        $this->bus->handle($command);
    }

    private function initialize()
    {
        $handlers = $this
            ->handlers
            ->reduce(
                new Map('string', 'callable'),
                function(Map $carry, string $class, string $service): Map {
                    return $carry->put(
                        $class,

$class is of type string, but the function expects a object<Innmind\Immutable\T>.

                        $this->container->get($service)
                    );
                }
            );
        $this->bus = new CommandBus($handlers);
    }
}