Itkg\DelayEventBundle\Command\ProcessEventCommand

Complexity

Total Complexity

10

Size/Duplication

Total Lines	129
Duplicated Lines	10.08 %

Coupling/Cohesion

Components	1
Dependencies	8

Test Coverage

Coverage

0%

Importance

Changes	8
Bugs	2	Features	2

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	15	1
A	configure()	13	13	1
B	execute()	0	57	8

<?php

namespace Itkg\DelayEventBundle\Command;

use Itkg\DelayEventBundle\DomainManager\EventManager;
use Itkg\DelayEventBundle\Exception\LockException;
use Itkg\DelayEventBundle\Handler\LockHandlerInterface;
use Itkg\DelayEventBundle\Model\Event;
use Itkg\DelayEventBundle\Processor\EventProcessor;
use Itkg\DelayEventBundle\Repository\EventRepository;
use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;

/**
 * Class ProcessEventCommand
 */
class ProcessEventCommand extends ContainerAwareCommand
{
    /**
     * @var EventRepository
     */
    private $eventRepository;

    /**
     * @var EventProcessor
     */
    private $eventProcessor;

    /**
     * @var LockHandlerInterface
     */
    private $lockHandler;

    /**
     * @var array
     */
    private $channels;

    /**
     * @param EventRepository      $eventRepository
     * @param EventProcessor       $eventProcessor
     * @param LockHandlerInterface $lockHandler
     * @param array                $channels
     * @param null|string          $name
     */
    public function __construct(
        EventRepository $eventRepository,
        EventProcessor $eventProcessor,
        LockHandlerInterface $lockHandler,
        array $channels = [],
        $name = null
    )
    {
        $this->eventRepository = $eventRepository;
        $this->eventProcessor = $eventProcessor;
        $this->lockHandler = $lockHandler;
        $this->channels = $channels;

        parent::__construct($name);
    }

    /**
     * {@inheritDoc}
     */
    protected function configure()

This method seems to be duplicated in your project.

    {
        $this
            ->setName('itkg_delay_event:process')
            ->setDescription('Process async events')
            ->addOption(
                'channel',
                'c',
                InputOption::VALUE_IS_ARRAY | InputOption::VALUE_REQUIRED,
                'Specify the channels to process (default: [\'default\'])',
                ['default']
            );
    }

    /**
     * @param InputInterface  $input
     * @param OutputInterface $output
     *
     * @throws LockException
     * @throws \Exception
     *
     * @return int|null|void
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $channels = $input->getOption('channel');

        foreach ($channels as $channel) {
            if (!isset($this->channels[$channel])) {
                $output->writeln(sprintf(
                    '<error>Channel <info>%s</info> is not configured.</error>',
                    $channel
                ));
            }

            if ($this->lockHandler->isLocked($channel)) {
                $output->writeln(
                    sprintf(
                        'Command is locked by another process for channel <info>%s</info>.',
                        $channel
                    )
                );

                continue;
            }

            $output->writeln(
                sprintf(
                    'Process events for channel <info>%s</info>',
                    $channel
                )
            );

            $this->lockHandler->lock($channel);

            $event = null;
            try {
                while (true) {
                    if (!$event = $this->eventRepository->findFirstTodoEvent(false, $this->channels[$channel]['include'], $this->channels[$channel]['exclude'])) {
                        break;
                    }
                    $event->setDelayed(false);
                    $this->eventProcessor->process($event);
                }
            } catch (\Exception $e) {
                if ($event instanceof Event) {
                    $output->writeln(sprintf(
                        '<info>[%s]</info> <error> An error occurred while processing event "%s".</error>',
                        $channel,
                        $event->getOriginalName()
                    ));
                }

                $output->writeln(sprintf('<info>[%s]</info> <error>%s</error>',$channel, $e->getMessage()));
                $output->writeln($e->getTraceAsString());
            }

            $this->lockHandler->release($channel);
        }
    }
}