ApiClients\Foundation\Factory::createCommandBus()

Complexity

Conditions	1
Paths	1

Size

Total Lines	20
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	Factory::createHydrator()	8	8	2

<?php declare(strict_types=1);

namespace ApiClients\Foundation;

use ApiClients\Foundation\Hydrator\Factory as HydratorFactory;
use ApiClients\Foundation\Hydrator\Hydrator;
use ApiClients\Foundation\Transport\Client as TransportClient;
use ApiClients\Foundation\Transport\Factory as TransportFactory;
use ApiClients\Tools\CommandBus\CommandBus;
use ApiClients\Tools\CommandBus\Factory as CommandBusFactory;
use DI\ContainerBuilder;
use Interop\Container\ContainerInterface;
use InvalidArgumentException;
use League\Event\Emitter;
use League\Event\EmitterInterface;
use React\EventLoop\LoopInterface;

final class Factory
{
    public static function create(
        LoopInterface $loop,
        array $options = []
    ): Client {
        return new Client(
            self::createContainer($loop, $options)
        );
    }

    private static function createContainer(LoopInterface $loop, array $options): ContainerInterface
    {
        $container = new ContainerBuilder();

        $container->addDefinitions([
            EmitterInterface::class => new Emitter(),
            LoopInterface::class => $loop,
            TransportClient::class => function (ContainerInterface $container, LoopInterface $loop) use ($options) {
                return self::createTransport($container, $loop, $options);
            },
            Hydrator::class => function (ContainerInterface $container) use ($options) {
                return self::createHydrator($container, $options);
            },
            CommandBus::class => function (ContainerInterface $container) {
                return CommandBusFactory::create($container);
            },
        ]);

        return $container->build();
    }

    private static function createTransport(

This method seems to be duplicated in your project.

        ContainerInterface $container,
        LoopInterface $loop,
        array $options = []
    ): TransportClient {
        if (!isset($options[Options::TRANSPORT_OPTIONS])) {
            throw new InvalidArgumentException('Missing Transport options');
        }

        return TransportFactory::create($container, $loop, $options[Options::TRANSPORT_OPTIONS]);
    }

    private static function createHydrator(ContainerInterface $container, array $options = [])

This method seems to be duplicated in your project.

    {
        if (!isset($options[Options::HYDRATOR_OPTIONS])) {
            throw new InvalidArgumentException('Missing Hydrator options');
        }

        return HydratorFactory::create($container, $options[Options::HYDRATOR_OPTIONS]);
    }
}