Puzzle\AMQP\Commands\Worker\Run

Complexity

Total Complexity

6

Size/Duplication

Total Lines	68
Duplicated Lines	14.71 %

Coupling/Cohesion

Components	2
Dependencies	11

Test Coverage

Coverage

0%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	10	10	1
A	setMessageAdapterFactory()	0	6	1
A	configure()	0	6	1
A	execute()	0	20	2
A	createProcessor()	0	11	1

<?php

namespace Puzzle\AMQP\Commands\Worker;

use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Input\InputArgument;
use Puzzle\AMQP\Workers\ProcessorInterfaceAdapter;
use Puzzle\AMQP\Client;
use Puzzle\AMQP\Workers\WorkerProvider;
use Puzzle\AMQP\Workers\WorkerContext;
use Puzzle\Pieces\OutputInterfaceAware;
use Puzzle\Pieces\EventDispatcher\EventDispatcherAware;
use Puzzle\Pieces\EventDispatcher\NullEventDispatcher;
use Puzzle\AMQP\Workers\MessageAdapterFactory;

class Run extends Command
{
    use EventDispatcherAware;

    private
        $client,
        $workerProvider,
        $messageAdapterFactory,
        $outputInterfaceAware;

    public function __construct(Client $client, WorkerProvider $workerProvider, OutputInterfaceAware $outputInterfaceAware)

This method seems to be duplicated in your project.

    {
        parent::__construct();

        $this->client = $client;
        $this->workerProvider = $workerProvider;
        $this->messageAdapterFactory = null;
        $this->outputInterfaceAware = $outputInterfaceAware;
        $this->eventDispatcher = new NullEventDispatcher();
    }
    
    public function setMessageAdapterFactory(MessageAdapterFactory $factory)
    {
        $this->messageAdapterFactory = $factory;
        
        return $this;
    }

    protected function configure()
    {
        $this->setName('run')
            ->setDescription('Launch AMQP worker')
            ->addArgument('task', InputArgument::REQUIRED, 'worker name to run');
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $this->outputInterfaceAware->register($output);

        $workerName = $input->getArgument('task');
        $workerContext = $this->workerProvider->getWorker($workerName);

        if($workerContext instanceof WorkerContext)
        {
            $output->writeln("Launching <info>$workerName</info>");

            $processor = $this->createProcessor($workerContext);

            $this->eventDispatcher->dispatch('worker.run');

            return $workerContext->getConsumer()->consume($processor, $this->client, $workerContext);
        }

        $output->writeln("<error>Worker $workerName not found</error>");
    }

    private function createProcessor(WorkerContext $workerContext)
    {
        $processor = new ProcessorInterfaceAdapter($workerContext, $this->messageAdapterFactory);
        $processor->setEventDispatcher($this->eventDispatcher);

        $processor->setMessageProcessors(
            $this->workerProvider->getMessageProcessors()
        );

        return $processor;
    }
}