Glooby\TaskBundle\Entity\QueuedTaskRepository

Complexity

Total Complexity

3

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getByNameAndExecuteAt()	0	11	1
A	getByNameAndExecuteAtBeforeNow()	0	12	1
A	findPending()	0	13	1

<?php

namespace Glooby\TaskBundle\Entity;

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

/**
 * @author Emil Kilhage
 */
class QueuedTaskRepository extends EntityRepository
{
    /**
     * @param string $name
     * @param \DateTime $executeAt
     * @return QueuedTaskInterface
     */
    public function getByNameAndExecuteAt(string $name, \DateTime $executeAt): QueuedTaskInterface
    {
        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(string $name): QueuedTaskInterface
    {
        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 findPending(int $limit): array
    {
        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_PENDING)
            ->setParameter('now', new \DateTime())
            ->setMaxResults($limit)
            ->useQueryCache(true)
            ->getResult();
    }
}