silverstripe-australia / silverstripe-queuedjobs

src/Tasks/ProcessJobQueueTask.php

<?php

namespace Symbiote\QueuedJobs\Tasks;

use Symbiote\QueuedJobs\Services\QueuedJob;
use SilverStripe\Dev\BuildTask;

/**
 * Task used to process the job queue
 *
 * @author Marcus Nyeholt <marcus@symbiote.com.au>
 * @license BSD http://silverstripe.org/bsd-license/
 */
class ProcessJobQueueTask extends BuildTask
{
    /**
     * {@inheritDoc}
     * @var string
     */
    private static $segment = 'ProcessJobQueueTask';

Consider using a different property name as you override a private property of the parent class.

The property $segment is not used and could be removed.

    /**
     * @return string
     */
    public function getDescription()
    {
        return _t(
            'ProcessJobQueueTask.Description',
            'Used via a cron job to execute queued jobs that need to be run.'
        );
    }

    /**
     * @param HTTPRequest $request
     */
    public function run($request)
    {
        $service = $this->getService();

        if ($request->getVar('list')) {
            // List helper
            $service->queueRunner->listJobs();
            return;
        }

        // Check if there is a job to run
        if (($job = $request->getVar('job')) && strpos($job, '-')) {
            // Run from a isngle job
            $parts = explode('-', $job);
            $id = $parts[1];
            $service->runJob($id);
            return;
        }

        // Run the queue
        $queue = $this->getQueue($request);
        $service->runQueue($queue);
    }

    /**
     * Resolves the queue name to one of a few aliases.
     *
     * @todo Solve the "Queued"/"queued" mystery!
     *
     * @param HTTPRequest $request
     * @return string
     */
    protected function getQueue($request)
    {
        $queue = $request->getVar('queue');

        if (!$queue) {
            $queue = 'Queued';
        }

        switch (strtolower($queue)) {
            case 'immediate':
                $queue = QueuedJob::IMMEDIATE;
                break;
            case 'queued':
                $queue = QueuedJob::QUEUED;
                break;
            case 'large':
                $queue = QueuedJob::LARGE;
                break;
            default:
                break;
        }

        return $queue;
    }

    /**
     * Returns an instance of the QueuedJobService.
     *
     * @return QueuedJobService
     */
    public function getService()
    {
        return singleton('Symbiote\\QueuedJobs\\Services\\QueuedJobService');
    }
}