Gember\RdbmsEventStoreDoctrineDbal\Test\Saga\DoctrineRdbmsSagaStoreRepositoryTest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	itShouldSaveExistingSaga()	0	29	1
A	itShouldSaveAndGetSaga()	0	21	1
A	itShouldThrowExceptionWhenSagaNotFound()	0	6	1
A	setUp()	0	14	1

<?php

declare(strict_types=1);

namespace Gember\RdbmsEventStoreDoctrineDbal\Test\Saga;

use Doctrine\DBAL\DriverManager;
use Doctrine\DBAL\Tools\DsnParser;
use Gember\DependencyContracts\EventStore\Saga\RdbmsSagaNotFoundException;
use Gember\RdbmsEventStoreDoctrineDbal\Saga\DoctrineDbalRdbmsSagaFactory;

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

use Gember\RdbmsEventStoreDoctrineDbal\Saga\DoctrineRdbmsSagaStoreRepository;

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

use Gember\RdbmsEventStoreDoctrineDbal\Saga\TableSchema\SagaTableSchemaFactory;

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

use Gember\RdbmsEventStoreDoctrineDbal\Test\TestDoubles\TestIdentityGenerator;
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 DoctrineRdbmsSagaStoreRepositoryTest extends TestCase
{
    private DoctrineRdbmsSagaStoreRepository $repository;
    private TestIdentityGenerator $identityGenerator;

    #[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 DoctrineRdbmsSagaStoreRepository(
            $connection,
            SagaTableSchemaFactory::createDefaultSagaStore(),
            SagaTableSchemaFactory::createDefaultSagaStoreRelation(),
            new DoctrineDbalRdbmsSagaFactory(),
            $this->identityGenerator = new TestIdentityGenerator(),
        );
    }

    #[Test]
    public function itShouldThrowExceptionWhenSagaNotFound(): void
    {
        self::expectException(RdbmsSagaNotFoundException::class);

The method PHPUnit\Framework\TestCase::expectException() is not static, but was called statically.

        $this->repository->get('some.saga', '01K76GDQ5RT71G7HQVNR264KD4');
    }

    #[Test]
    public function itShouldSaveAndGetSaga(): void
    {
        $this->identityGenerator->ids[] = '01K7Q083CX4T7Z0NT5CKEX8NEJ';

        $this->repository->save(
            'some.saga',
            '{"some":"data"}',
            new DateTimeImmutable('2025-10-10 12:00:34'),
            '01K76GDQ5RT71G7HQVNR264KD4',
            '01K7Q033P5174AXA054FFAHW2F',
        );

        $saga = $this->repository->get('some.saga', '01K76GDQ5RT71G7HQVNR264KD4');

        self::assertSame('01K7Q083CX4T7Z0NT5CKEX8NEJ', $saga->id);
        self::assertSame('some.saga', $saga->sagaName);
        self::assertSame(['01K76GDQ5RT71G7HQVNR264KD4', '01K7Q033P5174AXA054FFAHW2F'], $saga->sagaIds);
        self::assertSame('{"some":"data"}', $saga->payload);
        self::assertEquals(new DateTimeImmutable('2025-10-10 12:00:34'), $saga->createdAt);
        self::assertNull($saga->updatedAt);
    }

    #[Test]
    public function itShouldSaveExistingSaga(): void
    {
        $this->identityGenerator->ids[] = '01K7Q083CX4T7Z0NT5CKEX8NEJ';

        $this->repository->save(
            'some.saga',
            '{"some":"data"}',
            new DateTimeImmutable('2025-10-10 12:00:34'),
            '01K76GDQ5RT71G7HQVNR264KD4',
            '01K7Q0GR8ABHBZG8QCGTXJXJ7T',
        );

        $this->repository->save(
            'some.saga',
            '{"some":"updated"}',
            new DateTimeImmutable('2025-10-10 13:30:12'),
            '01K76GDQ5RT71G7HQVNR264KD4',
            '01K7Q0JGY9ZMX11K75AAY5J78R',
        );

        $saga = $this->repository->get('some.saga', '01K76GDQ5RT71G7HQVNR264KD4');

        self::assertSame('01K7Q083CX4T7Z0NT5CKEX8NEJ', $saga->id);
        self::assertSame('some.saga', $saga->sagaName);
        self::assertSame(['01K76GDQ5RT71G7HQVNR264KD4', '01K7Q0JGY9ZMX11K75AAY5J78R'], $saga->sagaIds);
        self::assertSame('{"some":"updated"}', $saga->payload);
        self::assertEquals(new DateTimeImmutable('2025-10-10 12:00:34'), $saga->createdAt);
        self::assertEquals(new DateTimeImmutable('2025-10-10 13:30:12'), $saga->updatedAt);
    }
}