BrainExe\Core\MessageQueue\Command\ExecuteJob

Complexity

Total Complexity

5

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	configure()	0	7	1
A	execute()	0	16	3

<?php

namespace BrainExe\Core\MessageQueue\Command;

use BrainExe\Core\MessageQueue\Job;
use BrainExe\Core\MessageQueue\Worker;
use Exception;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use BrainExe\Core\Annotations\Command as CommandAnnotation;
use BrainExe\Annotations\Annotations\Inject;

/**
 * @CommandAnnotation("MessageQueue.Command.ExecuteJob")
 */
class ExecuteJob extends Command
{

    /**
     * @Inject("@MessageQueue.Worker")
     * @param Worker $worker
     */
    public function __construct(Worker $worker)
    {
        $this->worker = $worker;

The property worker does not exist. Did you maybe forget to declare it?

        parent::__construct(null);
    }

    /**
     * {@inheritdoc}
     */
    protected function configure()
    {
        $this
            ->setName('messagequeue:execute')
            ->setDescription('Runs message queue job')
            ->addArgument('job', InputArgument::REQUIRED);
    }

    /**
     * {@inheritdoc}
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $data = $input->getArgument('job');
        if (strpos($data, '#') !== false) {
            list (, $data) = explode('#', $data, 2);
        }

        $raw = @base64_decode($data);
        $job = @unserialize($raw);

        if (!$job instanceof Job) {
            throw new Exception(sprintf('Invalid job: %s', $input->getArgument('job')));
        }

        $this->worker->executeJob($job);
    }
}