adding more tests, integration tests doesnt cover now

infection.json.dist

@@ -13,6 +13,6 @@
   "mutators": {
     "@default": true
   },
-  "minMsi": 59,
-  "minCoveredMsi": 83
+  "minMsi": 51,
+  "minCoveredMsi": 90
 }

tests/Integration/BasicImplementation/BasicIntegrationTest.php

@@ -24,6 +24,9 @@
 use function file_exists;
 use function unlink;
 
+/**
+ * @coversNothing
+ */
 final class BasicIntegrationTest extends TestCase
 {
     private Connection $connection;

tests/Integration/Pipeline/PipelineChangeStoreTest.php

@@ -27,6 +27,9 @@
 use function file_exists;
 use function unlink;
 
+/**
+ * @coversNothing
+ */
 final class PipelineChangeStoreTest extends TestCase
 {
     private Connection $connectionOld;

tests/Unit/Aggregate/AggregateChangedTest.php

@@ -6,6 +6,7 @@
 
 use DateTimeImmutable;
 use Error;
+use Patchlevel\EventSourcing\Aggregate\AggregateException;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\Email;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileCreated;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileId;
@@ -95,6 +96,18 @@ public function testSerialize(): void
         );
     }
 
+    public function testSerializeNotRecorded(): void
+    {
+        $id = ProfileId::fromString('1');
+        $email = Email::fromString('d.a.badura@gmail.com');
+
+        $event = ProfileCreated::raise($id, $email);
+
+        $this->expectException(AggregateException::class);
+        $this->expectExceptionMessage('The change was not recorded.');
+        $event->serialize();
+    }
+
     public function testDeserialize(): void
     {
         $id = ProfileId::fromString('1');

tests/Unit/Aggregate/SnapshotableAggregateRootTest.php

@@ -0,0 +1,153 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Tests\Unit\Aggregate;
+
+use Patchlevel\EventSourcing\Snapshot\Snapshot;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\Email;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\Message;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\MessageId;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\MessagePublished;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileCreated;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileId;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileWithSnapshot;
+use PHPUnit\Framework\TestCase;
+
+class SnapshotableAggregateRootTest extends TestCase
+{
+    public function testCreateAggregate(): void
+    {
+        $id = ProfileId::fromString('1');
+        $email = Email::fromString('d.a.badura@gmail.com');
+
+        $profile = ProfileWithSnapshot::createProfile($id, $email);
+
+        self::assertEquals('1', $profile->aggregateRootId());
+        self::assertEquals(0, $profile->playhead());
+        self::assertEquals($id, $profile->id());
+        self::assertEquals($email, $profile->email());
+
+        $events = $profile->releaseEvents();
+
+        self::assertCount(1, $events);
+        $event = $events[0];
+        self::assertEquals(0, $event->playhead());
+    }
+
+    public function testExecuteMethod(): void
+    {
+        $profileId = ProfileId::fromString('1');
+        $email = Email::fromString('d.a.badura@gmail.com');
+
+        $messageId = MessageId::fromString('2');
+
+        $profile = ProfileWithSnapshot::createProfile($profileId, $email);
+
+        $events = $profile->releaseEvents();
+
+        self::assertCount(1, $events);
+        self::assertEquals(0, $profile->playhead());
+        $event = $events[0];
+        self::assertEquals(0, $event->playhead());
+
+        $profile->publishMessage(
+            Message::create(
+                $messageId,
+                'foo'
+            )
+        );
+
+        self::assertEquals('1', $profile->aggregateRootId());
+        self::assertEquals(1, $profile->playhead());
+        self::assertEquals($profileId, $profile->id());
+        self::assertEquals($email, $profile->email());
+
+        $events = $profile->releaseEvents();
+
+        self::assertCount(1, $events);
+        $event = $events[0];
+        self::assertEquals(1, $event->playhead());
+    }
+
+    public function testEventWithoutApplyMethod(): void
+    {
+        $visitorProfile = ProfileWithSnapshot::createProfile(
+            ProfileId::fromString('1'),
+            Email::fromString('visitor@test.com')
+        );
+
+        $events = $visitorProfile->releaseEvents();
+        self::assertCount(1, $events);
+        self::assertEquals(0, $visitorProfile->playhead());
+        $event = $events[0];
+        self::assertEquals(0, $event->playhead());
+
+        $visitedProfile = ProfileWithSnapshot::createProfile(
+            ProfileId::fromString('2'),
+            Email::fromString('visited@test.com')
+        );
+
+        $events = $visitedProfile->releaseEvents();
+        self::assertCount(1, $events);
+        self::assertEquals(0, $visitedProfile->playhead());
+        $event = $events[0];
+        self::assertEquals(0, $event->playhead());
+
+        $visitorProfile->visitProfile($visitedProfile->id());
+
+        $events = $visitedProfile->releaseEvents();
+        self::assertCount(0, $events);
+        self::assertEquals(0, $visitedProfile->playhead());
+    }
+
+    public function testInitliazingState(): void
+    {
+        $eventStream = [
+            ProfileCreated::raise(
+                ProfileId::fromString('1'),
+                Email::fromString('profile@test.com')
+            ),
+            MessagePublished::raise(
+                ProfileId::fromString('1'),
+                Message::create(
+                    MessageId::fromString('2'),
+                    'message value'
+                )
+            ),
+        ];
+
+        $profile = ProfileWithSnapshot::createFromEventStream($eventStream);
+
+        self::assertEquals('1', $profile->id()->toString());
+        self::assertCount(1, $profile->messages());
+    }
+
+    public function testCreateFromSnapshot(): void
+    {
+        $eventStream = [
+            MessagePublished::raise(
+                ProfileId::fromString('1'),
+                Message::create(
+                    MessageId::fromString('2'),
+                    'message value'
+                )
+            ),
+        ];
+
+        $snapshot = new Snapshot(
+            ProfileWithSnapshot::class,
+            '1',
+            1,
+            [
+                'id' => '1',
+                'email' => 'profile@test.com',
+            ]
+        );
+
+        $profile = ProfileWithSnapshot::createFromSnapshot($snapshot, $eventStream);
+
+        self::assertEquals('1', $profile->id()->toString());
+        self::assertCount(1, $profile->messages());
+    }
+}

tests/Unit/Pipeline/Middleware/RecalculatePlayheadMiddlewareTest.php

@@ -35,4 +35,26 @@ public function testReculatePlayhead(): void
 
         self::assertEquals(0, $event->playhead());
     }
+
+    public function testReculatePlayheadWithSamePlayhead(): void
+    {
+        $middleware = new RecalculatePlayheadMiddleware();
+
+        $bucket = new EventBucket(
+            Profile::class,
+            ProfileCreated::raise(
+                ProfileId::fromString('1'),
+                Email::fromString('d.a.badura@gmail.com')
+            )->recordNow(0)
+        );
+
+        $result = $middleware($bucket);
+
+        self::assertCount(1, $result);
+        self::assertEquals(Profile::class, $result[0]->aggregateClass());
+
+        $event = $result[0]->event();
+
+        self::assertEquals(0, $event->playhead());
+    }
 }

tests/Unit/Pipeline/Middleware/ReplaceEventMiddlewareTest.php

@@ -7,6 +7,7 @@
 use Patchlevel\EventSourcing\Pipeline\EventBucket;
 use Patchlevel\EventSourcing\Pipeline\Middleware\ReplaceEventMiddleware;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\Email;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\MessagePublished;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\Profile;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileCreated;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileId;
@@ -45,4 +46,35 @@ static function (ProfileCreated $event) {
         self::assertInstanceOf(ProfileVisited::class, $event);
         self::assertEquals(5, $event->playhead());
     }
+
+    public function testReplaceInvalidClass(): void
+    {
+        $middleware = new ReplaceEventMiddleware(
+            MessagePublished::class,
+            static function (ProfileCreated $event) {
+                return ProfileVisited::raise(
+                    $event->profileId(),
+                    $event->profileId()
+                );
+            }
+        );
+
+        $bucket = new EventBucket(
+            Profile::class,
+            ProfileCreated::raise(
+                ProfileId::fromString('1'),
+                Email::fromString('d.a.badura@gmail.com')
+            )->recordNow(5)
+        );
+
+        $result = $middleware($bucket);
+
+        self::assertCount(1, $result);
+        self::assertEquals(Profile::class, $result[0]->aggregateClass());
+
+        $event = $result[0]->event();
+
+        self::assertInstanceOf(ProfileCreated::class, $event);
+        self::assertEquals(5, $event->playhead());
+    }
 }

tests/Unit/Pipeline/Target/InMemoryTargetTest.php

@@ -0,0 +1,31 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Tests\Unit\Pipeline\Target;
+
+use Patchlevel\EventSourcing\Pipeline\EventBucket;
+use Patchlevel\EventSourcing\Pipeline\Target\InMemoryTarget;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\Email;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\Profile;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileCreated;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileId;
+use PHPUnit\Framework\TestCase;
+
+class InMemoryTargetTest extends TestCase
+{
+    public function testSave(): void
+    {
+        $inMemoryTarget = new InMemoryTarget();
+
+        $bucket = new EventBucket(
+            Profile::class,
+            ProfileCreated::raise(ProfileId::fromString('1'), Email::fromString('foo@test.com'))
+        );
+        $inMemoryTarget->save($bucket);
+
+        $buckets = $inMemoryTarget->buckets();
+        self::assertCount(1, $buckets);
+        self::assertEquals($bucket, $buckets[0]);
+    }
+}

tests/Unit/Pipeline/Target/ProjectionRepositoryTargetTest.php

@@ -0,0 +1,35 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Tests\Unit\Pipeline\Target;
+
+use Patchlevel\EventSourcing\Pipeline\EventBucket;
+use Patchlevel\EventSourcing\Pipeline\Target\ProjectionRepositoryTarget;
+use Patchlevel\EventSourcing\Projection\ProjectionRepository;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\Email;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\Profile;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileCreated;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileId;
+use PHPUnit\Framework\TestCase;
+use Prophecy\PhpUnit\ProphecyTrait;
+
+class ProjectionRepositoryTargetTest extends TestCase
+{
+    use ProphecyTrait;
+
+    public function testSave(): void
+    {
+        $bucket = new EventBucket(
+            Profile::class,
+            ProfileCreated::raise(ProfileId::fromString('1'), Email::fromString('foo@test.com'))
+        );
+
+        $projectionRepository = $this->prophesize(ProjectionRepository::class);
+        $projectionRepository->handle($bucket->event())->shouldBeCalledOnce();
+
+        $projectionRepositoryTarget = new ProjectionRepositoryTarget($projectionRepository->reveal());
+
+        $projectionRepositoryTarget->save($bucket);
+    }
+}

tests/Unit/Pipeline/Target/ProjectionTargetTest.php

@@ -0,0 +1,37 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Tests\Unit\Pipeline\Target;
+
+use Patchlevel\EventSourcing\Pipeline\EventBucket;
+use Patchlevel\EventSourcing\Pipeline\Target\ProjectionTarget;
+use Patchlevel\EventSourcing\Projection\Projection;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\Email;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\Profile;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileCreated;
+use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileId;
+use PHPUnit\Framework\TestCase;
+use Prophecy\PhpUnit\ProphecyTrait;
+
+class ProjectionTargetTest extends TestCase
+{
+    use ProphecyTrait;
+
+    public function testSave(): void
+    {
+        $this->markTestIncomplete('Testing not finished, needs discussion');
+
+        $bucket = new EventBucket(
+            Profile::class,
+            ProfileCreated::raise(ProfileId::fromString('1'), Email::fromString('foo@test.com'))
+        );
+
+        $projectionRepository = $this->prophesize(Projection::class);
+        $projectionRepository->handledEvents()->will(static fn () => yield ProfileCreated::class => 'applyProfileCreated');
+
+        $projectionTarget = new ProjectionTarget($projectionRepository->reveal());
+
+        $projectionTarget->save($bucket);
+    }
+}