Jellyfish\Event\Command\EventQueueConsumeCommand

Complexity

Total Complexity

5

Size/Duplication

Total Lines	68
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	execute()	0	19	3
A	__construct()	0	8	1
A	configure()	0	9	1

<?php

namespace Jellyfish\Event\Command;

use Jellyfish\Event\EventDispatcherInterface;
use Jellyfish\Event\EventListenerInterface;
use Jellyfish\Event\EventQueueConsumerInterface;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

class EventQueueConsumeCommand extends Command
{
    public const NAME = 'event:queue:consume';
    public const DESCRIPTION = 'Consume from event queue';

    /**
     * @param \Jellyfish\Event\EventDispatcherInterface $eventDispatcher
     */
    protected $eventDispatcher;

    /**
     * @param \Jellyfish\Event\EventQueueConsumerInterface $eventQueueConsumer
     */
    protected $eventQueueConsumer;

    /**
     * @param \Jellyfish\Event\EventDispatcherInterface $eventDispatcher
     * @param \Jellyfish\Event\EventQueueConsumerInterface $eventQueueConsumer
     */
    public function __construct(
        EventDispatcherInterface $eventDispatcher,
        EventQueueConsumerInterface $eventQueueConsumer
    ) {
        parent::__construct(null);

        $this->eventDispatcher = $eventDispatcher;
        $this->eventQueueConsumer = $eventQueueConsumer;
    }

    /**
     * @return void
     */
    protected function configure(): void
    {
        parent::configure();

        $this->setName(static::NAME);
        $this->setDescription(static::DESCRIPTION);

        $this->addArgument('eventName', InputArgument::REQUIRED, 'Event name');
        $this->addArgument('listenerIdentifier', InputArgument::REQUIRED, 'Listener identifier');
    }

    /**
     * @param \Symfony\Component\Console\Input\InputInterface $input
     * @param \Symfony\Component\Console\Output\OutputInterface $output
     *
     * @return int|null
     */
    protected function execute(InputInterface $input, OutputInterface $output): ?int
    {
        $eventName = (string) $input->getArgument('eventName');
        $listenerIdentifier = (string) $input->getArgument('listenerIdentifier');

        $event = $this->eventQueueConsumer->dequeueEvent($eventName, $listenerIdentifier);

        if ($event === null) {
            return null;
        }

        $listener = $this->eventDispatcher
            ->getListener(EventListenerInterface::TYPE_ASYNC, $eventName, $listenerIdentifier);

        if ($listener !== null) {
            $listener->handle($event);
        }

        return null;
    }
}