Merge 7dafe95 into c709369

src/AggregateRootBehaviourWithRequiredHistory.php

@@ -0,0 +1,25 @@
+<?php
+
+declare(strict_types=1);
+
+namespace EventSauce\EventSourcing;
+
+use Generator;
+
+trait AggregateRootBehaviourWithRequiredHistory
+{
+    use AggregateRootBehaviour {
+        AggregateRootBehaviour::reconstituteFromEvents as private defaultAggregateRootReconstitute;
+    }
+
+    public static function reconstituteFromEvents(AggregateRootId $aggregateRootId, Generator $events): AggregateRoot
+    {
+        $aggregateRoot = static::defaultAggregateRootReconstitute($aggregateRootId, $events);
+
+        if ($aggregateRoot->aggregateRootVersion() === 0) {
+            throw new InvalidAggregateRootReconstitutionException();
+        }
+
+        return $aggregateRoot;
+    }
+}

src/Integration/TestingAggregates/DummyAggregateRootId.php → src/Integration/DummyAggregateRootId.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace EventSauce\EventSourcing\Integration\TestingAggregates;
+namespace EventSauce\EventSourcing\Integration;
 
 use EventSauce\EventSourcing\AggregateRootId;
 use Ramsey\Uuid\Uuid;

src/Integration/RequiringHistoryWithAggregateRootConstruction/AggregateRootConstructionTest.php

@@ -0,0 +1,52 @@
+<?php
+
+namespace EventSauce\EventSourcing\Integration\RequiringHistoryWithAggregateRootConstruction;
+
+use EventSauce\EventSourcing\AggregateRoot;
+use EventSauce\EventSourcing\ConstructingAggregateRootRepository;
+use EventSauce\EventSourcing\InMemoryMessageRepository;
+use EventSauce\EventSourcing\Integration\DummyAggregateRootId;
+use EventSauce\EventSourcing\InvalidAggregateRootReconstitutionException;
+use PHPUnit\Framework\TestCase;
+
+class AggregateRootConstructionTest extends TestCase
+{
+    /**
+     * @test
+     */
+    public function expecting_an_exception_without_history()
+    {
+        $this->expectException(InvalidAggregateRootReconstitutionException::class);
+        $repository = new ConstructingAggregateRootRepository(
+            AggregateThatRequiredHistoryForReconstitutionStub::class,
+            new InMemoryMessageRepository()
+        );
+
+        $repository->retrieve(DummyAggregateRootId::fromString('nope'));
+    }
+
+    /**
+     * @test
+     */
+    public function expecting_an_aggregate_when_there_is_history()
+    {
+        $repository = new ConstructingAggregateRootRepository(
+            AggregateThatRequiredHistoryForReconstitutionStub::class,
+            new InMemoryMessageRepository()
+        );
+        $id = DummyAggregateRootId::fromString('nope');
+        $repository->persistEvents($id, 1, new DummyInternalEvent());
+        $aggregateRoot = $repository->retrieve($id);
+        $this->assertInstanceOf(AggregateThatRequiredHistoryForReconstitutionStub::class, $aggregateRoot);
+    }
+
+    /**
+     * @test
+     */
+    public function constructing_the_aggregate_using_a_named_constructor()
+    {
+        $id = DummyAggregateRootId::fromString('nope');
+        $aggregate = AggregateThatRequiredHistoryForReconstitutionStub::start($id);
+        $this->assertInstanceOf(AggregateRoot::class, $aggregate);
+    }
+}

src/Integration/RequiringHistoryWithAggregateRootConstruction/AggregateThatRequiredHistoryForReconstitutionStub.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace EventSauce\EventSourcing\Integration\RequiringHistoryWithAggregateRootConstruction;
+
+use EventSauce\EventSourcing\AggregateRoot;
+use EventSauce\EventSourcing\AggregateRootBehaviourWithRequiredHistory;
+use EventSauce\EventSourcing\Integration\DummyAggregateRootId;
+
+class AggregateThatRequiredHistoryForReconstitutionStub implements AggregateRoot
+{
+    use AggregateRootBehaviourWithRequiredHistory;
+
+    public static function start(DummyAggregateRootId $id)
+    {
+        $aggregate = new static($id);
+        $aggregate->recordThat(new DummyInternalEvent());
+
+        return $aggregate;
+    }
+
+    protected function applyDummyInternalEvent(DummyInternalEvent $event)
+    {
+        // can be ignored
+    }
+}

src/Integration/RequiringHistoryWithAggregateRootConstruction/DummyInternalEvent.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace EventSauce\EventSourcing\Integration\RequiringHistoryWithAggregateRootConstruction;
+
+class DummyInternalEvent
+{
+
+}

src/Integration/TestingAggregates/DummyAggregate.php

@@ -6,6 +6,7 @@
 
 use EventSauce\EventSourcing\AggregateRoot;
 use EventSauce\EventSourcing\AggregateRootBehaviour;
+use EventSauce\EventSourcing\Integration\DummyAggregateRootId;
 
 class DummyAggregate implements AggregateRoot
 {

src/Integration/TestingAggregates/ExampleAggregateRootTest.php

@@ -8,6 +8,7 @@
 use EventSauce\EventSourcing\AggregateRootRepository;
 use EventSauce\EventSourcing\AggregateRootTestCase;
 use EventSauce\EventSourcing\Header;
+use EventSauce\EventSourcing\Integration\DummyAggregateRootId;
 use EventSauce\EventSourcing\Message;
 use EventSauce\EventSourcing\PointInTime;
 use EventSauce\EventSourcing\Time\Clock;

src/Integration/TestingAggregates/InitiatorCommand.php

@@ -3,6 +3,8 @@
 namespace EventSauce\EventSourcing\Integration\TestingAggregates;
 
 
+use EventSauce\EventSourcing\Integration\DummyAggregateRootId;
+
 class InitiatorCommand
 {
     /**

src/InvalidAggregateRootReconstitutionException.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace EventSauce\EventSourcing;
+
+use RuntimeException;
+use Throwable;
+
+class InvalidAggregateRootReconstitutionException extends RuntimeException
+{
+}