mmucklo / DtcQueueBundle

Manager/RunManager.php

<?php

namespace Dtc\QueueBundle\Manager;

use Dtc\QueueBundle\Exception\UnsupportedException;
use Dtc\QueueBundle\Model\Job;
use Dtc\QueueBundle\Model\Run;
use Dtc\QueueBundle\Util\Util;

class RunManager
{
    /** @var string */
    protected $runClass;

    public function __construct($runClass)
    {
        $this->runClass = $runClass;
    }

    /**
     * @return string
     */
    public function getRunClass()
    {
        return $this->runClass;
    }

    /**
     * @param string $runClass
     */
    public function setRunClass($runClass)
    {
        $this->runClass = $runClass;
    }

    /**
     * @return int Number of archived runs pruned
     *
     * @throws UnsupportedException
     */
    public function pruneArchivedRuns(\DateTime $olderThan)
    {
        throw new UnsupportedException('not supported - '.$olderThan->getTimestamp());
    }

    /**
     * Prunes stalled runs.
     *
     * @return int Number of stalled runs pruned
     *
     * @throws UnsupportedException
     */
    public function pruneStalledRuns()
    {
        throw new UnsupportedException('not supported');
    }

    /**
     * @param float $start
     */
    public function recordHeartbeat(Run $run, $start, Job $job = null)
    {
        $jobId = null;
        if (null !== $job) {
            $jobId = $job->getId();
        }

        $heartbeat = microtime(true);
        $run->setLastHeartbeatAt(Util::getMicrotimeFloatDateTime($heartbeat));
        $run->setCurrentJobId($jobId);
        $run->setElapsed($heartbeat - $start);
        $this->persistRun($run);
    }

    /**
     * @param string $action
     */
    protected function persistRun(Run $run, $action = 'persist')

The parameter $action is not used and could be removed.

The parameter $run is not used and could be removed.

    {
        // To be overridden
    }

    /**
     * @param int $count
     */
    public function updateProcessed(Run $run, $count)
    {
        $run->setProcessed($count);
        $this->persistRun($run);
    }

    /**
     * Sets up the runManager (document / entity persister) if appropriate.
     *
     * @param float    $start
     * @param int|null $maxCount
     * @param int|null $duration
     * @param int      $processTimeout
     *
     * @return Run
     */
    public function runStart($start, $maxCount = null, $duration = null, $processTimeout = null)
    {
        $runClass = $this->getRunClass();
        /** @var Run $run */
        $run = new $runClass();
        $startDate = Util::getMicrotimeFloatDateTime($start);
        $run->setLastHeartbeatAt($startDate);
        $run->setStartedAt($startDate);
        if (null !== $maxCount) {
            $run->setMaxCount($maxCount);
        }
        if (null !== $duration) {
            $run->setDuration($duration);
        }
        $run->setHostname(gethostname());
        $run->setPid(getmypid());
        $run->setProcessed(0);
        $run->setProcessTimeout($processTimeout);
        $this->persistRun($run);

        return $run;
    }

    /**
     * @param int|null $start
     */
    public function runStop(Run $run, $start)
    {
        $end = microtime(true);
        $run->setEndedAt(Util::getMicrotimeFloatDateTime($end));
        $run->setElapsed($end - $start);
        $this->persistRun($run, 'remove');
    }
}