Dazzle\Channel\ChannelFactory

Complexity

Total Complexity

5

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	8

Test Coverage

Coverage

56%

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
B	__construct()	0	36	5

<?php

namespace Dazzle\Channel;

use Dazzle\Channel\Encoder\Encoder;
use Dazzle\Channel\Encoder\EncoderInterface;
use Dazzle\Channel\Model\ModelFactoryInterface;
use Dazzle\Channel\Router\Router;
use Dazzle\Channel\Router\RouterComposite;
use Dazzle\Loop\LoopInterface;
use Dazzle\Util\Factory\Factory;
use Dazzle\Util\Parser\Json\JsonParser;

class ChannelFactory extends Factory implements ChannelFactoryInterface
{
    /**
     * @param string $name
     * @param ModelFactoryInterface $modelFactory
     * @param LoopInterface|null $loop
     */
    public function __construct($name, ModelFactoryInterface $modelFactory, LoopInterface $loop = null)
    {
        parent::__construct();

        $factory = $this;
        $factory
            ->bindParam('name', $name)
            ->bindParam('encoder', new Encoder(new JsonParser))
            ->bindParam('router', function() {
                return new RouterComposite([
                    'input'  => new Router(),
                    'output' => new Router()
                ]);
            })
            ->bindParam('loop', $loop)
        ;
        $factory
            ->define(Channel::class, function($model, $config = []) use($factory, $modelFactory) {
                return new Channel(
                    isset($config['name']) ? $config['name'] : $factory->getParam('name'),
                    $modelFactory->create($model, [ $config ]),
                    $factory->getParam('router'),
                    $factory->getParam('encoder'),
                    isset($config['loop']) ? $config['loop'] : $factory->getParam('loop')
                );
            })
            ->define(ChannelComposite::class, function($channels = [], $config = []) use($factory) {
                return new ChannelComposite(
                    isset($config['name']) ? $config['name'] : $factory->getParam('name'),
                    $channels,
                    $factory->getParam('router'),
                    isset($config['loop']) ? $config['loop'] : $factory->getParam('loop')
                );
            })
        ;
    }
}