Setono\MessageSchedulerBundle\Repository\ScheduledMessageRepository

Complexity

Total Complexity

2

Size/Duplication

Total Lines	17
Duplicated Lines	0 %

Test Coverage

Coverage

25%

Importance

Changes	2
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	findDispatchable()	0	10	1

<?php

declare(strict_types=1);

namespace Setono\MessageSchedulerBundle\Repository;

use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
use Doctrine\Persistence\ManagerRegistry;
use Safe\DateTime;
use Setono\MessageSchedulerBundle\Entity\ScheduledMessage;

class ScheduledMessageRepository extends ServiceEntityRepository implements ScheduledMessageRepositoryInterface
{
    public function __construct(ManagerRegistry $registry)
    {
        parent::__construct($registry, ScheduledMessage::class);
    }

    public function findDispatchable(): array
    {
        return $this->createQueryBuilder('o')
            ->andWhere('o.dispatchAt <= :now')
            ->andWhere('o.state = :state')
            ->setParameter('now', new DateTime())
            ->setParameter('state', ScheduledMessage::STATE_PENDING)
            ->setMaxResults(100) // this is just a very basic 'hack' to prevent memory problems
            ->getQuery()
            ->getResult()
        ;
    }
}