Shippinno\Job\Infrastructure\Application\Messaging\DoctrineJobFlightManager

Complexity

Total Complexity

7

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

0%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	departed()	0	5	1
A	latestJobFlightOfJobId()	0	4	1
A	acknowledged()	0	5	1
A	abandoned()	0	5	1
A	requeued()	0	7	1
A	rejected()	0	5	1
A	letGo()	0	5	1

<?php

namespace Shippinno\Job\Infrastructure\Application\Messaging;

use Doctrine\ORM\EntityRepository;
use Shippinno\Job\Application\Messaging\JobFlight;
use Shippinno\Job\Application\Messaging\JobFlightManager;

class DoctrineJobFlightManager extends EntityRepository implements JobFlightManager
{
    /**
     * {@inheritdoc}
     */
    public function departed(int $jobId, string $queue): void
    {
        $this->getEntityManager()->persist(new JobFlight($jobId, $queue));
        $this->getEntityManager()->flush();
    }

    /**
     * {@inheritdoc}
     */
    public function latestJobFlightOfJobId(int $jobId): JobFlight
    {
        return $this->findOneBy(['jobId' => $jobId], ['id' => 'DESC']);
    }

    /**
     * {@inheritdoc}
     */
    public function acknowledged(int $jobId): void
    {
        $this->latestJobFlightOfJobId($jobId)->acknowledge();
        $this->getEntityManager()->flush();
    }

    /**
     * {@inheritdoc}
     */
    public function abandoned(int $jobId): void
    {
        $this->latestJobFlightOfJobId($jobId)->abandoned();
        $this->getEntityManager()->flush();
    }

    /**
     * {@inheritdoc}
     */
    public function requeued(int $jobId): void
    {
        $jobFlight = $this->latestJobFlightOfJobId($jobId);
        $jobFlight->requeued();
        $this->departed($jobFlight->jobId(), $jobFlight->queue());
        $this->getEntityManager()->flush();
    }

    /**
     * {@inheritdoc}
     */
    public function rejected(int $jobId): void
    {
        $this->latestJobFlightOfJobId($jobId)->rejected();
        $this->getEntityManager()->flush();
    }

    /**
     * {@inheritdoc}
     */
    public function letGo(int $jobId): void
    {
        $this->latestJobFlightOfJobId($jobId)->letGo();
        $this->getEntityManager()->flush();
    }
}