Symbiote\QueuedJobs\Workers\JobWorker

Complexity

Total Complexity

4

Size/Duplication

Total Lines	33
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	getName()	0	4	1
A	jobqueueExecute()	0	13	3

<?php

namespace Symbiote\QueuedJobs\Workers;

use SilverStripe\ORM\DataList;
use SilverStripe\ORM\FieldType\DBDatetime;
use Symbiote\QueuedJobs\DataObjects\QueuedJobDescriptor;
use Symbiote\QueuedJobs\Services\QueuedJobService;

/**
 * @author marcus@symbiote.com.au
 * @license BSD License http://silverstripe.org/bsd-license/
 */

// GearmanHandler is an extension that could be not available.
/**
 * @todo Test and implement against it for SilverStripe 4.x compatibility
 */
if (interface_exists('GearmanHandler')) {
    class JobWorker implements \GearmanHandler
    {
        /**
         * @var QueuedJobService
         */
        public $queuedJobService;

        /**
         * @return string
         */
        public function getName()
        {
            return 'jobqueueExecute';
        }

        /**
         * @param int $jobId
         * @return void
         */
        public function jobqueueExecute($jobId)
        {
            $this->queuedJobService->checkJobHealth();
            $job = QueuedJobDescriptor::get()->byID($jobId);
            if ($job) {
                // check that we're not trying to execute something tooo soon
                if (strtotime($job->StartAfter) > DBDatetime::now()->getTimestamp()) {
                    return;
                }

                $this->queuedJobService->runJob($jobId);
            }
        }
    }
}