Dtc\QueueBundle\Model\Worker

Complexity

Total Complexity

14

Size/Duplication

Total Lines	96
Duplicated Lines	0 %

Test Coverage

Coverage

93.94%

Importance

Changes	2
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	setCurrentJob()	0	3	1
A	getCurrentJob()	0	3	1
A	getJobManager()	0	3	1
A	setJobManager()	0	3	1
A	batchOrLaterDelay()	0	6	1
A	at()	0	18	6
A	batchLater()	0	3	1
A	later()	0	3	1
A	batchAt()	0	3	1

<?php

namespace Dtc\QueueBundle\Model;

use Dtc\QueueBundle\Manager\JobManagerInterface;
use Dtc\QueueBundle\Util\Util;

abstract class Worker
{
    const RESULT_SUCCESS = 0;
    const RESULT_FAILURE = 1;

    /** @var JobManagerInterface */
    private $jobManager;
    private $currentJob;

    public function setCurrentJob(BaseJob $job)
    {
        $this->currentJob = $job;
    }

    public function getCurrentJob()
    {
        return $this->currentJob;
    }

    /**
     * @param JobManagerInterface $jobManager
     */
    public function setJobManager(JobManagerInterface $jobManager)
    {
        $this->jobManager = $jobManager;
    }

    /**
     * @return
     */
    public function getJobManager()
    {
        return $this->jobManager;
    }

    /**
     * @param int|null $time
     * @param bool     $batch
     * @param int|null $priority
     */
    public function at($time = null, $batch = false, $priority = null)
    {
        $timeU = $time;
        $localeInfo = localeconv();
        $decimalPoint = isset($localeInfo['decimal_point']) ? $localeInfo['decimal_point'] : '.';
        if (null === $time) {
            $timeU = Util::getMicrotimeStr();
        } elseif (false === strpos(strval($time), $decimalPoint)) {
            $timeU = strval($time).$decimalPoint.'000000';
        }

        $dateTime = \DateTime::createFromFormat('U'.$decimalPoint.'u', (string) $timeU, new \DateTimeZone(date_default_timezone_get()));
        if (!$dateTime) {
            throw new \InvalidArgumentException("Invalid time: $time".($timeU != $time ? " - (micro: $timeU)" : ''));
        }
        $jobClass = $this->jobManager->getJobClass();

        return new $jobClass($this, $batch, $priority, $dateTime);
    }

    /**
     * @param int      $delay    Amount of time to delay
     * @param int|null $priority
     */
    public function later($delay = 0, $priority = null)
    {
        return $this->batchOrLaterDelay($delay, false, $priority);
    }

    public function batchOrLaterDelay($delay = 0, $batch = false, $priority = null)
    {
        $job = $this->at(microtime(true) + $delay, $batch, $priority);
        $job->setDelay($delay);

        return $job;
    }

    /**
     * @param int      $delay    Amount of time to delay
     * @param int|null $priority
     */
    public function batchLater($delay = 0, $priority = null)
    {
        return $this->batchOrLaterDelay($delay, true, $priority);
    }

    /**
     * @param int|null $time
     * @param int|null $priority
     */
    public function batchAt($time = null, $priority = null)
    {
        return $this->at($time, true, $priority);
    }

    abstract public function getName();
}