ScheduledJobRepository::findScheduledJobToReschedule()

Complexity

Conditions	4
Paths	4

Size

Total Lines	44
Code Lines	20

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function findScheduledJobToReschedule(Job $originalJob)
    {
        // fetching scheduled job that was not started before - it can be rescheduled
        $queryString = <<<'QUERY'
            SELECT sj FROM WorkflowExtensionsBundle:ScheduledJob sj
            JOIN sj.job j
            WHERE
                j.state in (:stateNew, :statePending) AND
                j.command = :command AND
                j.args = :args AND
                sj.reschedulable = 1
QUERY;

        /** @var ScheduledJob[] $scheduledJobsToReschedule */
        $scheduledJobsToReschedule = $this->_em
            ->createQuery($queryString)
            ->setParameters([
                'stateNew'     => Job::STATE_NEW,
                'statePending' => Job::STATE_PENDING,
                'command'      => $originalJob->getCommand(),
                'args'         => json_encode($originalJob->getArgs())
            ])
            ->getResult()
        ;

        if (!$scheduledJobsToReschedule) {

The expression $scheduledJobsToReschedule of type Gtt\Bundle\WorkflowExtensionsBundle\Entity\ScheduledJob[] is implicitly converted to a boolean; are you sure this is intended? If so, consider using empty($expr) instead to make it clear that you intend to check for an array without elements.

            return null;
        }

        if (count($scheduledJobsToReschedule) > 1) {
            // since there is normally only one scheduled pending/new job here
            // (because an attempt to schedule duplicate job raises rescheduling of the first one)
            // we throwing exception in case of several results here
            // TODO probably we need support several jobs for the same transition, workflow and subject scheduled for different times?
            $duplicateReschedulableJobsIds = [];
            foreach ($scheduledJobsToReschedule as $scheduledJobToReschedule) {
                $duplicateReschedulableJobsIds[] = $scheduledJobToReschedule->getJob()->getId();
            }

            throw new NonUniqueReschedulabeJobFoundException($originalJob, $duplicateReschedulableJobsIds);
        }

        return reset($scheduledJobsToReschedule);
    }
}