add tests & docs

docs/pages/projection.md

@@ -118,12 +118,7 @@ Otherwise the projectionist will not recognize that the projection has changed a
 To do this, you can add a version to the `projectorId`:
 
 ```php
-use Doctrine\DBAL\Connection;
-use Patchlevel\EventSourcing\Attribute\Setup;
-use Patchlevel\EventSourcing\Attribute\Teardown;
-use Patchlevel\EventSourcing\Attribute\Handle;
 use Patchlevel\EventSourcing\Attribute\Projector;
-use Patchlevel\EventSourcing\EventBus\Message;
 
 #[Projector('profile_1')]
 final class ProfileProjector
@@ -140,16 +135,20 @@ final class ProfileProjector
 
     You can also use the `ProjectorUtil` to build the table/collection name.
 
-## Projector Repository
+## From Now
 
-The projector repository is responsible for managing the projectors.
+Certain projectors operate exclusively on post-release events, disregarding historical data. 
+Consider, for instance, the scenario of launching a fresh email service. 
+Its primary function is to dispatch welcome emails to newly registered users triggered by a `ProfileCreated` event. 
 
 ```php
-use Patchlevel\EventSourcing\Projection\Projector\InMemoryProjectorRepository;
+use Patchlevel\EventSourcing\Attribute\Projector;
 
-$projectorRepository = new InMemoryProjectorRepository([
-    new ProfileProjection($connection)
-]);
+#[Projector('profile_1', fromNow: true)]
+final class WelcomeEmailProjector
+{
+   // ...
+}
 ```
 
 ## Projectionist
@@ -305,7 +304,7 @@ use Patchlevel\EventSourcing\Projection\Projectionist\DefaultProjectionist;
 $projectionist = new DefaultProjectionist(
     $eventStore,
     $projectionStore,
-    $projectorRepository
+    [$projector1, $projector2, $projector3]
 );
 ```
 

tests/Unit/Projection/Projectionist/DefaultProjectionistTest.php

@@ -317,6 +317,43 @@ public function handle(Message $message): void
         self::assertSame([$message1, $message2], $projector->messages);
     }
 
+    public function testBootingWithFromNow(): void
+    {
+        $projectionId = 'test';
+        $projector = new #[ProjectionAttribute('test', fromNow: true)]
+        class {
+            /** @var list<Message> */
+            public Message|null $message = null;
+
+            #[Subscribe(ProfileVisited::class)]
+            public function handle(Message $message): void
+            {
+                $this->message = $message;
+            }
+        };
+
+        $projectionStore = new DummyStore([new Projection($projectionId, ProjectionStatus::Booting)]);
+
+        $message1 = new Message(new ProfileVisited(ProfileId::fromString('test')));
+
+        $streamableStore = $this->prophesize(Store::class);
+        $streamableStore->load(null, 1, null, true)->willReturn(new ArrayStream([$message1]))->shouldBeCalledOnce();
+
+        $projectionist = new DefaultProjectionist(
+            $streamableStore->reveal(),
+            $projectionStore,
+            [$projector],
+        );
+
+        $projectionist->boot();
+
+        self::assertEquals([
+            new Projection($projectionId, ProjectionStatus::Active, 1),
+        ], $projectionStore->savedProjections);
+
+        self::assertNull($projector->message);
+    }
+
     public function testRunning(): void
     {
         $projectionId = 'test';