Gember\RdbmsEventStoreDoctrineDbal\Test\DoctrineDbalRdbmsEventStoreRepositoryTest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	126
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	47	1
A	itShouldReturnNullWhenGetLastEventIdPersistedIsNotFound()	0	15	1
A	itShouldGetEvents()	0	37	1
A	itShouldGetLastEventIdPersisted()	0	15	1

<?php

declare(strict_types=1);

namespace Gember\RdbmsEventStoreDoctrineDbal\Test;

use Doctrine\DBAL\DriverManager;
use Doctrine\DBAL\Tools\DsnParser;
use Gember\EventSourcing\EventStore\Rdbms\RdbmsEvent;
use Gember\RdbmsEventStoreDoctrineDbal\DoctrineDbalRdbmsEventFactory;

The type Gember\RdbmsEventStoreDoctrineDbal\DoctrineDbalRdbmsEventFactory was not found. Maybe you did not declare it correctly or list all dependencies?

use Gember\RdbmsEventStoreDoctrineDbal\DoctrineDbalRdbmsEventStoreRepository;

The type Gember\RdbmsEventStoreDoctrineDbal\DoctrineDbalRdbmsEventStoreRepository was not found. Maybe you did not declare it correctly or list all dependencies?

use Gember\RdbmsEventStoreDoctrineDbal\TableSchema\TableSchemaFactory;

The type Gember\RdbmsEventStoreDoctrineDbal\TableSchema\TableSchemaFactory was not found. Maybe you did not declare it correctly or list all dependencies?

use PHPUnit\Framework\Attributes\Test;

The type PHPUnit\Framework\Attributes\Test was not found. Maybe you did not declare it correctly or list all dependencies?

use PHPUnit\Framework\TestCase;
use Override;

The type Override was not found. Maybe you did not declare it correctly or list all dependencies?

use DateTimeImmutable;

/**
 * @internal
 */
final class DoctrineDbalRdbmsEventStoreRepositoryTest extends TestCase
{
    private DoctrineDbalRdbmsEventStoreRepository $repository;

    #[Override]
    protected function setUp(): void
    {
        parent::setUp();

        $connection = DriverManager::getConnection((new DsnParser())->parse('pdo-sqlite:///:memory:'));
        $connection->executeStatement((string) file_get_contents(__DIR__ . '/schema.sql'));

        $this->repository = new DoctrineDbalRdbmsEventStoreRepository(
            $connection,
            TableSchemaFactory::createDefaultEventStore(),
            TableSchemaFactory::createDefaultEventStoreRelation(),
            new DoctrineDbalRdbmsEventFactory(),
        );

        $this->repository->saveEvents([
            new RdbmsEvent(
                '63129dc3-4a27-4242-a8bc-6f79636a6fa9',
                ['6ae07469-0f43-4f33-979b-c783b6824ce0', '0c1ff409-a4be-42f1-90dd-5d7b0130a426'],
                'event_name',
                '{"data":"some"}',
                ['metadata' => 'some'],
                new DateTimeImmutable('2024-12-06 12:05:04.456344'),
            ),
            new RdbmsEvent(
                '707678d3-c91d-4864-9729-555b22496853',
                ['0e76f2bd-2aae-44a4-b149-740c080e4d05'],
                'event_name',
                '{"data":"another_event"}',
                ['metadata' => 'another_event'],
                new DateTimeImmutable('2024-12-01 13:16:24.467784'),
            ),
            new RdbmsEvent(
                '7ac51abe-9176-4794-8246-24b75c2ba914',
                ['0c1ff409-a4be-42f1-90dd-5d7b0130a426'],
                'event_name_2',
                '{"data":"another"}',
                ['metadata' => 'another'],
                new DateTimeImmutable('2024-12-04 13:15:26.755844'),
            ),
            new RdbmsEvent(
                'd404e3c1-c782-4115-b8ec-d8cb341d87cb',
                ['6ae07469-0f43-4f33-979b-c783b6824ce0'],
                'event_name_3',
                '{"data":"another"}',
                ['metadata' => 'another3'],
                new DateTimeImmutable('2024-12-02 13:16:24.467784'),
            ),
        ]);
    }

    #[Test]
    public function itShouldGetEvents(): void
    {
        $events = $this->repository->getEvents(
            [
                '0c1ff409-a4be-42f1-90dd-5d7b0130a426',
                '6ae07469-0f43-4f33-979b-c783b6824ce0',
            ],
            [
                'event_name',
                'event_name_2',
            ],
        );

        self::assertEquals([
            new RdbmsEvent(
                '7ac51abe-9176-4794-8246-24b75c2ba914',
                [
                    '0c1ff409-a4be-42f1-90dd-5d7b0130a426',
                ],
                'event_name_2',
                '{"data":"another"}',
                ['metadata' => 'another'],
                new DateTimeImmutable('2024-12-04 13:15:26.755844'),
            ),
            new RdbmsEvent(
                '63129dc3-4a27-4242-a8bc-6f79636a6fa9',
                [
                    '0c1ff409-a4be-42f1-90dd-5d7b0130a426',
                    '6ae07469-0f43-4f33-979b-c783b6824ce0',
                ],
                'event_name',
                '{"data":"some"}',
                ['metadata' => 'some'],
                new DateTimeImmutable('2024-12-06 12:05:04.456344'),
            ),
        ], $events);
    }

    #[Test]
    public function itShouldReturnNullWhenGetLastEventIdPersistedIsNotFound(): void
    {
        $lastEventIdPersisted = $this->repository->getLastEventIdPersisted(
            [
                '072fd355-bd4e-423b-a7ba-fb1a77e32d7c',
                '60a8635c-c769-4d19-8cae-a9571401848f',
            ],
            [
                'event_name',
                'event_name_2',
            ],
        );

        self::assertNull($lastEventIdPersisted);
    }

    #[Test]
    public function itShouldGetLastEventIdPersisted(): void
    {
        $lastEventIdPersisted = $this->repository->getLastEventIdPersisted(
            [
                '0c1ff409-a4be-42f1-90dd-5d7b0130a426',
                '6ae07469-0f43-4f33-979b-c783b6824ce0',
            ],
            [
                'event_name',
                'event_name_2',
            ],
        );

        self::assertSame('63129dc3-4a27-4242-a8bc-6f79636a6fa9', $lastEventIdPersisted);
    }
}