WIP: Standalone usage

Classes/Command/ProjectionCommandController.php

@@ -14,7 +14,7 @@
 
 use Neos\EventSourcing\EventListener\Exception\EventCouldNotBeAppliedException;
 use Neos\EventSourcing\Projection\Projection;
-use Neos\EventSourcing\Projection\ProjectionManager;
+use Neos\EventSourcing\Projection\ProjectionManagerInterface;
 use Neos\Flow\Annotations as Flow;
 use Neos\Flow\Cli\CommandController;
 use Neos\Flow\Cli\Exception\StopCommandException;
@@ -28,7 +28,7 @@ class ProjectionCommandController extends CommandController
 {
     /**
      * @Flow\Inject
-     * @var ProjectionManager
+     * @var ProjectionManagerInterface
      */
     protected $projectionManager;
 

Classes/Event/Resolver/FullyQualifiedClassNameResolver.php

@@ -0,0 +1,22 @@
+<?php
+
+
+namespace Neos\EventSourcing\Event\Resolver;
+
+
+use Neos\EventSourcing\Event\DomainEventInterface;
+use Neos\EventSourcing\Event\EventTypeResolverInterface;
+
+class FullyQualifiedClassNameResolver implements EventTypeResolverInterface
+{
+
+    public function getEventType(DomainEventInterface $event): string
+    {
+        return get_class($event);
+    }
+
+    public function getEventClassNameByType(string $eventType): string
+    {
+        return $eventType;
+    }
+}

Classes/EventListener/AppliedEventsStorage/DoctrineAppliedEventsStorage.php

@@ -21,6 +21,8 @@
 
 /**
  * Doctrine DBAL adapter for the AppliedEventsStorageInterface
+ *
+ * TODO: we should have one doctrine applied events storage table PER BOUNDED CONTEXT, i.e. per storage.
  */
 final class DoctrineAppliedEventsStorage implements AppliedEventsStorageInterface
 {

Classes/Projection/ProjectionManager.php

@@ -30,7 +30,7 @@
  * @api
  * @Flow\Scope("singleton")
  */
-class ProjectionManager
+class ProjectionManager implements ProjectionManagerInterface
 {
     /**
      * @var ObjectManagerInterface

Classes/Projection/ProjectionManagerInterface.php

@@ -0,0 +1,85 @@
+<?php
+declare(strict_types=1);
+namespace Neos\EventSourcing\Projection;
+
+/*
+ * This file is part of the Neos.EventSourcing package.
+ *
+ * (c) Contributors of the Neos Project - www.neos.io
+ *
+ * This package is Open Source Software. For the full copyright and license
+ * information, please view the LICENSE file which was distributed with this
+ * source code.
+ */
+
+use Closure;
+use Doctrine\ORM\EntityManagerInterface;
+use Neos\EventSourcing\EventListener\EventListenerInvoker;
+use Neos\EventSourcing\EventListener\Exception\EventCouldNotBeAppliedException;
+use Neos\EventSourcing\EventListener\Mapping\DefaultEventToListenerMappingProvider;
+use Neos\EventSourcing\EventStore\EventStoreFactory;
+use Neos\Flow\Annotations as Flow;
+use Neos\Flow\ObjectManagement\ObjectManagerInterface;
+use Neos\Flow\Reflection\ClassReflection;
+use Neos\Flow\Reflection\Exception\ClassLoadingForReflectionFailedException;
+use Neos\Flow\Reflection\ReflectionService;
+
+interface ProjectionManagerInterface
+{
+    /**
+     * Return all detected projections
+     *
+     * @return Projection[]
+     * @api
+     */
+    public function getProjections(): array;
+
+    /**
+     * Returns information about a specific projection in form of a Projection DTO
+     *
+     * @param string $projectionIdentifier The short or full projection identifier
+     * @return Projection
+     * @api
+     */
+    public function getProjection(string $projectionIdentifier): Projection;
+
+    /**
+     * Replay events of the specified projection
+     *
+     * @param string $projectionIdentifier unambiguous identifier of the projection to replay
+     * @param Closure|null $progressCallback If set, this callback is invoked for every applied event during replay with the arguments $sequenceNumber and $eventStreamVersion
+     * @return void
+     * @throws EventCouldNotBeAppliedException
+     * @api
+     */
+    public function replay(string $projectionIdentifier, Closure $progressCallback = null): void;
+
+    /**
+     * Replay events of the specified projection until the specified event sequence number
+     *
+     * @param string $projectionIdentifier unambiguous identifier of the projection to replay
+     * @param int $maximumSequenceNumber The sequence number of the event until which events should be replayed. The specified event will be included in the replay.
+     * @param Closure|null $progressCallback If set, this callback is invoked for every applied event during replay with the arguments $sequenceNumber and $eventStreamVersion
+     * @throws EventCouldNotBeAppliedException
+     */
+    public function replayUntilSequenceNumber(string $projectionIdentifier, int $maximumSequenceNumber, Closure $progressCallback = null): void;
+
+    /**
+     * Catch up on events for the specified projection
+     *
+     * @param string $projectionIdentifier unambiguous identifier of the projection to catch up for
+     * @param Closure|null $progressCallback If set, this callback is invoked for every applied event during catch-up with the arguments $sequenceNumber and $eventStreamVersion
+     * @throws EventCouldNotBeAppliedException
+     */
+    public function catchUp(string $projectionIdentifier, Closure $progressCallback = null): void;
+
+    /**
+     * Catch up on events for the specified projection up to the specified event
+     *
+     * @param string $projectionIdentifier unambiguous identifier of the projection to catch up for
+     * @param int $maximumSequenceNumber The sequence number of the event until which events should be applied. The specified event will be included in the replay.
+      * @param Closure|null $progressCallback If set, this callback is invoked for every applied event during catch-up with the arguments $sequenceNumber and $eventStreamVersion
+     * @throws EventCouldNotBeAppliedException
+     */
+    public function catchUpUntilSequenceNumber(string $projectionIdentifier, int $maximumSequenceNumber, Closure $progressCallback = null): void;
+}

composer.json

@@ -5,16 +5,19 @@
     "license": "MIT",
     "require": {
         "php": ">=7.2",
-        "neos/flow": "^5.3 || ^6.0",
-        "flowpack/jobqueue-common": "^3.0 || dev-master",
         "symfony/serializer": "^5.1",
         "symfony/property-access": "^5.1",
+        "neos/error-messages": "*",
+        "neos/utility-objecthandling": "*",
         "ramsey/uuid": "^3.9"
     },
     "require-dev": {
         "roave/security-advisories": "dev-master",
         "dg/bypass-finals": "^1.2"
     },
+    "suggest": {
+        "flowpack/jobqueue-common": "Needed for Neos/Flow usage only"
+    },
     "autoload": {
         "psr-4": {
             "Neos\\EventSourcing\\": "Classes"