Glooby\TaskBundle\Queue\QueueScheduler

Complexity

Total Complexity

9

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	setDoctrine()	0	4	1
A	setTaskManager()	0	4	1
A	schedule()	0	11	2
B	queue()	0	29	5

<?php

namespace Glooby\TaskBundle\Queue;

use Doctrine\Common\Persistence\ManagerRegistry;
use Doctrine\ORM\NoResultException;
use Glooby\TaskBundle\Entity\QueuedTask;
use Glooby\TaskBundle\Entity\QueuedTaskRepository;
use Glooby\TaskBundle\Manager\TaskManager;
use Glooby\TaskBundle\Model\ScheduleInterface;

/**
 * @author Emil Kilhage
 */
class QueueScheduler
{
    /**
     * @var ManagerRegistry
     */
    protected $doctrine;

    /**
     * @param ManagerRegistry $doctrine
     */
    public function setDoctrine($doctrine)
    {
        $this->doctrine = $doctrine;
    }

    /**
     * @var TaskManager
     */
    private $taskManager;

    /**
     * @param TaskManager $taskManager
     */
    public function setTaskManager(TaskManager $taskManager)
    {
        $this->taskManager = $taskManager;
    }

    /**
     *
     */
    public function schedule()
    {
        $repo = $this->doctrine->getManager()
            ->getRepository('GloobyTaskBundle:Schedule');

        foreach ($repo->findActive() as $schedule) {
            $this->queue($schedule);
        }

        $this->doctrine->getManager()->flush();
    }

    /**
     * @param ScheduleInterface $schedule
     */
    private function queue(ScheduleInterface $schedule)
    {
        /** @var QueuedTaskRepository $queueRepo */
        $queueRepo = $this->doctrine->getManager()
            ->getRepository('GloobyTaskBundle:QueuedTask');

        $expression = $schedule->parseExpression();
        $nextExecuteAt = $expression->getNextRunDate();
        $prevExecuteAt = $expression->getPreviousRunDate();
        $executeAt = null;

        try {
            $queueRepo->getByNameAndExecuteAtBeforeNow($schedule->getName());
        } catch (NoResultException $e) {
            $executeAt = $prevExecuteAt;
        }

        if (null === $executeAt) {
            try {
                $queueRepo->getByNameAndExecuteAt($schedule->getName(), $nextExecuteAt);
            } catch (NoResultException $e) {
                $executeAt = $nextExecuteAt;
            }
        }

        if (null !== $executeAt) {
            $this->taskManager->queue($schedule->getName(), $executeAt, $schedule->getParams());
        }
    }
}