Xervice\RabbitMQ\Communication\Console\Command\ConsumeCommand

Complexity

Total Complexity

3

Size/Duplication

Total Lines	29
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	5	1
A	execute()	0	10	2

<?php


namespace Xervice\RabbitMQ\Communication\Console\Command;


use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Xervice\Console\Business\Model\Command\AbstractCommand;
use Xervice\Core\Business\Exception\XerviceException;

/**
 * @method \Xervice\RabbitMQ\Business\RabbitMQFacade getFacade()
 */
class ConsumeCommand extends AbstractCommand
{
    /**
     * @throws \Symfony\Component\Console\Exception\InvalidArgumentException
     */
    protected function configure(): void
    {
        $this
            ->setName('queue:listener:run')
            ->addArgument('listener', InputArgument::REQUIRED, 'Listener classname');
    }

    /**
     * @param \Symfony\Component\Console\Input\InputInterface $input
     * @param \Symfony\Component\Console\Output\OutputInterface $output
     *
     * @return int|void
     * @throws \Xervice\Core\Business\Exception\XerviceException
     */
    public function execute(InputInterface $input, OutputInterface $output)
    {
        $listenerClass = $input->getArgument('listener');

        if (!class_exists($listenerClass)) {

It seems like $listenerClass can also be of type string[]; however, parameter $class_name of class_exists() does only seem to accept string, maybe add an additional type check?

            throw new XerviceException('Listener not found ' . $listenerClass);

Are you sure $listenerClass of type null|string|string[] can be used in concatenation?

        }

        $listener = new $listenerClass();
        $this->getFacade()->consumeQueries($listener);
    }
}