Shippinno\Job\Infrastructure\Domain\Model\DoctrineJobStore

Complexity

Total Complexity

6

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

70%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	append()	0	13	1
A	storedJobsSince()	0	12	2
A	storedJobOfId()	0	7	1
A	storedJobsOfIds()	0	9	1

<?php

namespace Shippinno\Job\Infrastructure\Domain\Model;

use Doctrine\ORM\EntityManager;
use Doctrine\ORM\EntityRepository;
use Doctrine\ORM\Mapping\ClassMetadata;
use Shippinno\Job\Application\Messaging\JobFlightManager;
use Shippinno\Job\Domain\Model\Job;
use Shippinno\Job\Domain\Model\JobSerializer;
use Shippinno\Job\Domain\Model\JobStore;
use Shippinno\Job\Domain\Model\StoredJob;

class DoctrineJobStore extends EntityRepository implements JobStore
{
    /**
     * @var JobSerializer
     */
    private $jobSerializer;

    /**
     * @param EntityManager $em
     * @param ClassMetadata $class
     * @param JobSerializer $jobSerializer
     */
    public function __construct(
        EntityManager $em,
        ClassMetadata $class,
        JobSerializer $jobSerializer
    ) {
        parent::__construct($em, $class);
        $this->jobSerializer = $jobSerializer;
    }

    /**
     * {@inheritdoc}
     */
    public function append(Job $job): StoredJob
    {
        $storedJob = new StoredJob(
            get_class($job),
            $this->jobSerializer->serialize($job),
            $job->createdAt(),
            $job->isExpendable(),
            $job->fifoGroupId()
        );
        $this->getEntityManager()->persist($storedJob);

        return $storedJob;
    }

    /**
     * {@inheritdoc}
     */
    public function storedJobsSince(?int $jobId): array
    {
        $query = $this->createQueryBuilder('j');
        if (null !== $jobId) {
            $query->where('j.id > :id');
            $query->setParameters(['id' => $jobId]);
        }
        $query->setMaxResults(100);
        $query->orderBy('j.id');

        return $query->getQuery()->getResult();
    }

    /**
     * {@inheritdoc}
     */
    public function storedJobOfId(int $jobId): ?StoredJob
    {
        /** @var StoredJob|null $storedJob */
        $storedJob = $this->find($jobId);

        return $storedJob;
    }

    /**
     * @param int[] $jobIds
     * @return StoredJob[]
     */
    public function storedJobsOfIds(array $jobIds): array
    {
        $query = $this->createQueryBuilder('j');
        $query->where('j.id in :ids');
        $query->setParameter('ids', $jobIds);
        $query->orderBy('j.id');

        return $query->getQuery()->getResult();
    }
}