Dtc\QueueBundle\Manager\StallableJobManager

Complexity

Total Complexity

14

Size/Duplication

Total Lines	97
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	2

Test Coverage

Coverage

93.55%

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
	stallableSave()	0	1	?
A	getAllStatuses()	0	8	1
	pruneStalledJobs()	0	1	?
	resetStalledJobs()	0	1	?
	stallableSaveHistory()	0	1	?
A	retryableSaveHistory()	0	16	4
A	updateJobStalled()	0	4	1
A	getDefaultMaxStalls()	0	4	1
A	setDefaultMaxStalls()	0	4	1
A	prioritySave()	0	14	4
A	setStallableJobDefaults()	0	6	2

<?php

namespace Dtc\QueueBundle\Manager;

use Dtc\QueueBundle\Model\RetryableJob;
use Dtc\QueueBundle\Model\Job;
use Dtc\QueueBundle\Model\StallableJob;

abstract class StallableJobManager extends PriorityJobManager
{
    protected $defaultMaxStalls;

    abstract protected function stallableSave(StallableJob $job);

    abstract public function pruneStalledJobs($workerName = null, $method = null, callable $progressCallback = null);

    abstract public function resetStalledJobs($workerName = null, $method = null, callable $progressCallback = null);

    public static function getAllStatuses()
    {
        $statuses = parent::getAllStatuses();
        $statuses[StallableJob::STATUS_STALLED] = 0;
        $statuses[StallableJob::STATUS_MAX_STALLS] = 0;

        return $statuses;
    }

    protected function prioritySave(Job $job)
    {
        if (!$job instanceof StallableJob) {
            throw new \InvalidArgumentException('Job is not instanceof '.StallableJob::class);
        }

        if (!$job->getId()) {
            if ($job instanceof StallableJob) {
                $this->setStallableJobDefaults($job);
            }
        }

        return $this->stallableSave($job);
    }

    /**
     * @param StallableJob $job
     * @param $retry true if retry
     *
     * @return bool true if retry
     */
    abstract protected function stallableSaveHistory(StallableJob $job, $retry);

    /**
     * @return bool true if retry
     *
     * @param Job $job
     */
    protected function retryableSaveHistory(RetryableJob $job, $retry)
    {
        if (!$job instanceof StallableJob) {
            throw new \InvalidArgumentException('job not instance of '.StallableJob::class);
        }

        if ($retry) {
            return $this->stallableSaveHistory($job, $retry);
        }

        if (StallableJob::STATUS_STALLED === $job->getStatus()) {
            return $this->stallableSaveHistory($job, $this->updateJobStalled($job));
        }

        return $this->stallableSaveHistory($job, false);
    }

    /**
     * @param StallableJob $job
     *
     * @return bool false if
     */
    private function updateJobStalled(StallableJob $job)
    {
        return $this->updateJobMax($job, 'Stalls', StallableJob::STATUS_MAX_STALLS, true);
    }

    protected function setStallableJobDefaults(StallableJob $job)
    {
        if (null === $job->getMaxStalls()) {
            $job->setMaxStalls($this->defaultMaxStalls);
        }
    }

    /**
     * @return int|null
     */
    public function getDefaultMaxStalls()
    {
        return $this->defaultMaxStalls;
    }

    /**
     * @param int|null $defaultMaxStalls
     */
    public function setDefaultMaxStalls($defaultMaxStalls)
    {
        $this->defaultMaxStalls = $defaultMaxStalls;
    }
}