Shippinno\Job\Infrastructure\Domain\Model\DoctrineJobStore

Complexity

Total Complexity

4

Size/Duplication

Total Lines	43
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	append()	0	9	1
A	storedJobsSince()	0	11	2

<?php

namespace Shippinno\Job\Infrastructure\Domain\Model;

use Doctrine\ORM\EntityRepository;
use Doctrine\ORM\Mapping\ClassMetadata;
use JMS\Serializer\SerializerBuilder;
use Shippinno\Job\Domain\Model\Job;
use Shippinno\Job\Domain\Model\JobStore;
use Shippinno\Job\Domain\Model\StoredJob;
use Shippinno\Job\Infrastructure\Serialization\JMS\BuildsSerializer;

class DoctrineJobStore extends EntityRepository implements JobStore
{
    use BuildsSerializer;

    /**
     * @param $em
     * @param ClassMetadata $class
     * @param SerializerBuilder $serializerBuilder
     */
    public function __construct($em, ClassMetadata $class, SerializerBuilder $serializerBuilder)
    {
        parent::__construct($em, $class);
        $this->buildSerializer($serializerBuilder);
    }

    /**
     * {@inheritdoc}
     */
    public function append(Job $job): void
    {
        $storedEvent = new StoredJob(
            get_class($job),
            $this->serializer->serialize($job, 'json'),
            $job->createdAt()
        );
        $this->getEntityManager()->persist($storedEvent);
    }

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

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