Glooby\TaskBundle\Entity\QueuedTaskRepository

Complexity

Total Complexity

7

Size/Duplication

Total Lines	96
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getByNameAndExecuteAt()	0	11	1
A	getByNameAndExecuteAtBeforeNow()	0	12	1
A	findQueued()	0	13	1
A	isRunning()	0	4	1
A	isQueued()	0	4	1
A	isStatus()	0	18	2

<?php

namespace Glooby\TaskBundle\Entity;

use Doctrine\ORM\EntityRepository;
use Doctrine\ORM\NoResultException;
use Glooby\TaskBundle\Model\QueuedTaskInterface;

/**
 * @author Emil Kilhage
 */
class QueuedTaskRepository extends EntityRepository
{
    /**
     * @param string $name
     * @param \DateTime $executeAt
     * @return QueuedTaskInterface
     */
    public function getByNameAndExecuteAt($name, \DateTime $executeAt)
    {
        return $this->getEntityManager()
            ->createQuery('SELECT r
              FROM GloobyTaskBundle:QueuedTask r
              WHERE r.name = :name AND r.executeAt = :executeAt')
            ->setParameter('name', $name)
            ->setParameter('executeAt', $executeAt)
            ->useQueryCache(true)
            ->getSingleResult();
    }

    /**
     * @param string $name
     * @return QueuedTaskInterface
     */
    public function getByNameAndExecuteAtBeforeNow($name)
    {
        return $this->getEntityManager()
            ->createQuery('SELECT r
              FROM GloobyTaskBundle:QueuedTask r
              WHERE r.name = :name AND r.executeAt <= :now')
            ->setParameter('name', $name)
            ->setParameter('now', new \DateTime())
            ->useQueryCache(true)
            ->setMaxResults(1)
            ->getSingleResult();
    }

    /**
     * @param int $limit
     * @return QueuedTaskInterface[]
     */
    public function findQueued($limit)
    {
        return $this->getEntityManager()
            ->createQuery('SELECT r
              FROM GloobyTaskBundle:QueuedTask r
              WHERE r.status = :status AND r.executeAt <= :now
              ORDER BY r.executeAt ASC')
            ->setParameter('status', QueuedTaskInterface::STATUS_QUEUED)
            ->setParameter('now', new \DateTime())
            ->setMaxResults($limit)
            ->useQueryCache(true)
            ->getResult();
    }

    /**
     * @param string $name
     * @return bool
     */
    public function isRunning($name)
    {
        return $this->isStatus($name, QueuedTaskInterface::STATUS_RUNNING);
    }

    /**
     * @param string $name
     * @return bool
     */
    public function isQueued($name)
    {
        return $this->isStatus($name, QueuedTaskInterface::STATUS_QUEUED);
    }

    /**
     * @param string $name
     * @param string $status
     * @return bool
     */
    private function isStatus($name, $status)
    {
        try {
            $this->getEntityManager()
                ->createQuery('SELECT r
                  FROM GloobyTaskBundle:QueuedTask r
                  WHERE r.name = :name AND r.status = :status')
                ->setParameter('name', $name)
                ->setParameter('status', $status)
                ->useQueryCache(true)
                ->setMaxResults(1)
                ->getSingleResult();

            return true;
        } catch (NoResultException $e) {
            return false;
        }
    }
}