sfcod / jobqueue

Command/RetryCommand.php

<?php

namespace SfCod\QueueBundle\Command;

use Illuminate\Queue\Jobs\Job;
use SfCod\QueueBundle\Failer\MongoFailedJobProvider;
use SfCod\QueueBundle\Service\JobQueue;
use SfCod\QueueBundle\Service\MongoDriverInterface;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;

/**
 * Class ReleaseFailedCommand
 *
 * @author Virchenko Maksim <muslim1992@gmail.com>
 *
 * @package SfCod\QueueBundle\Command
 */
class RetryCommand extends Command
{
    /**
     * @var JobQueue
     */
    protected $queue;

    /**
     * @var MongoFailedJobProvider
     */
    protected $failer;

    /**
     * RetryCommand constructor.
     *
     * @param JobQueue $queue
     * @param MongoDriverInterface $mongoDriver

There is no parameter named $mongoDriver. Was it maybe removed?

     */
    public function __construct(JobQueue $queue, MongoFailedJobProvider $failer)
    {
        $this->queue = $queue;
        $this->failer = $failer;

        parent::__construct();
    }

    /**
     * Configure command
     */
    protected function configure()
    {
        $this->setName('job-queue:retry')
            ->setDescription('Release all failed jobs.')
            ->addOption('id', null, InputOption::VALUE_OPTIONAL, 'Job id to retry', null);
    }

    /**
     * Execute command
     *
     * @param InputInterface $input
     * @param OutputInterface $output
     *
     * @return int|null|void
     */
    public function execute(InputInterface $input, OutputInterface $output)
    {
        $io = new SymfonyStyle($input, $output);

        $jobsCount = 0;
        if (is_null($input->getOption('id'))) {
            foreach ($this->failer->all() as $job) {
                if ($this->retryJob($job)) {
                    ++$jobsCount;
                }
            }
        } else {
            $job = $this->failer->find($input->getOption('id'));
            $this->retryJob($job);

$job is of type array, but the function expects a object<Illuminate\Queue\Jobs\Job>.

            ++$jobsCount;
        }

        $io->success(sprintf("[%d] job(s) has been released.\n", $jobsCount));
    }

    /**
     * Retry job
     *
     * @param Job $job
     *
     * @return bool
     */
    protected function retryJob($job): bool
    {
        $payload = json_decode($job->payload, true);

The property payload does not seem to exist in Illuminate\Queue\Jobs\Job.

        if ($payload && isset($payload['job'], $payload['data'])) {
            $this->queue->push($payload['job'], $payload['data']);
            $this->failer->forget($job->_id);

The property _id does not seem to exist in Illuminate\Queue\Jobs\Job.

            return true;
        }

        return false;
    }
}