Shippinno\Job\Infrastructure\Application\Messaging\DoctrineJobFlightManager

Complexity

Total Complexity

10

Size/Duplication

Total Lines	95
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

0%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	created()	0	5	1
A	boarding()	0	5	1
A	departed()	0	5	1
A	arrived()	0	5	1
A	acknowledged()	0	6	1
A	abandoned()	0	5	1
A	requeued()	0	5	1
A	rejected()	0	6	1
A	letGo()	0	5	1
A	latestJobFlightOfJobId()	0	4	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
{
    /**
     * @param int $jobId
     * @param string $jobName
     * @param string $queue
     */
    public function created(int $jobId, string $jobName, string $queue): void
    {
        $this->getEntityManager()->persist(new JobFlight($jobId, $jobName, $queue));
        $this->getEntityManager()->flush();
    }

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

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

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

    /**
     * {@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(string $jobId, string $requeuedJobId): void
    {
        $this->latestJobFlightOfJobId($jobId)->requeued();
        $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();
    }

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