MontealegreLuis/php-testing-tools

<?php declare(strict_types=1);
/**
 * PHP version 7.4
 *
 * This source file is subject to the license that is bundled with this package in the file LICENSE.
 */

namespace Adapters\Doctrine\Application\DomainEvents;

use Adapters\Doctrine\Application\DataStorage\Repository;
use Application\DomainEvents\EventStore;
use Application\DomainEvents\StoredEvent;
use Doctrine\ORM\OptimisticLockException;
use Doctrine\ORM\ORMException;

final class EventStoreRepository extends Repository implements EventStore
{
    /**
     * @throws ORMException
     * @throws OptimisticLockException
     */
    public function append(StoredEvent $anEvent): void
    {
        $this->manager->persist($anEvent);
        $this->manager->flush($anEvent);
    }

    /**
     * @return StoredEvent[]
     */
    public function eventsStoredAfter(int $lastStoredEventId): array
    {
        $query = $this->manager->createQueryBuilder();
        $query
            ->select('e')
            ->from(StoredEvent::class, 'e')
            ->where('e.id > :eventId')
            ->setParameter('eventId', $lastStoredEventId)
            ->orderBy('e.id');

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

    /**
     * @return StoredEvent[]
     */
    public function allEvents(): array
    {
        $query = $this->manager->createQueryBuilder();
        $query
            ->select('e')
            ->from(StoredEvent::class, 'e')
            ->orderBy('e.id');

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