!!! FEATURE: Publishing Version 3

Neos.ContentGraph.DoctrineDbalAdapter/src/DoctrineDbalContentGraphProjection.php

@@ -260,6 +260,24 @@ public function apply(EventInterface $event, EventEnvelope $eventEnvelope): void
         }
     }
 
+    /**
+     * @template T
+     * @param \Closure(): T $fn
+     * @return T
+     */
+    public function inSimulation(\Closure $fn): mixed
+    {
+        if ($this->dbal->isTransactionActive()) {
+            throw new \RuntimeException();
+        }
+        $this->dbal->beginTransaction();
+        try {
+            return $fn();
+        } finally {
+            $this->dbal->rollBack();
+        }
+    }
+
     private function whenContentStreamWasClosed(ContentStreamWasClosed $event): void
     {
         $this->updateContentStreamStatus($event->contentStreamId, ContentStreamStatus::CLOSED);

Neos.ContentRepository.BehavioralTests/Tests/Behavior/Features/W6-WorkspaceRebasing/02-RebasingWithAutoCreatedNodes.feature

@@ -69,6 +69,8 @@ Feature: Rebasing auto-created nodes works
       | propertyValues            | {"text": {"value":"Modified","type":"string"}} |
       | propertiesToUnset         | {}                                             |
 
+    # rebase of SetSerializedNodeProperties
+    # More than one node anchor point for content stream: b2a1d336-38a7-4183-815c-c49b2c7eba8c, node aggregate id: 7ef3c166-16d5-4aed-b8cb-5a44670607b7 and origin dimension space point: [] – this should not happen and might be a conceptual problem!
     When the command RebaseWorkspace is executed with payload:
       | Key           | Value       |
       | workspaceName | "user-test" |

Neos.ContentRepository.BehavioralTests/Tests/Behavior/Features/W8-IndividualNodePublication/02-BasicFeatures.feature

@@ -41,7 +41,6 @@ Feature: Individual node publication
   Scenario: It is possible to publish a single node; and only this one is live.
     # create nodes in user WS
     Given I am in workspace "user-test"
-    And I am in workspace "user-test"
     And I am in dimension space point {}
     And the following CreateNodeAggregateWithNode commands are executed:
       | nodeAggregateId        | nodeTypeName                            | parentNodeAggregateId  | nodeName | tetheredDescendantNodeAggregateIds |

Neos.ContentRepository.BehavioralTests/Tests/Behavior/Features/W8-IndividualNodePublication/03-MoreBasicFeatures.feature

@@ -134,40 +134,40 @@ Feature: Publishing individual nodes (basics)
       | Key   | Value            |
       | image | "Modified image" |
 
-  Scenario: It is possible to publish no node
-    When the command PublishIndividualNodesFromWorkspace is executed with payload:
-      | Key                             | Value                          |
-      | workspaceName                   | "user-test"                    |
-      | nodesToPublish                  | []                             |
-      | contentStreamIdForRemainingPart | "user-cs-identifier-remaining" |
-
-    When I am in workspace "live" and dimension space point {}
-    Then I expect node aggregate identifier "sir-david-nodenborough" to lead to node cs-identifier;sir-david-nodenborough;{}
-    And I expect this node to have the following properties:
-      | Key  | Value        |
-      | text | "Initial t1" |
-    And I expect node aggregate identifier "nody-mc-nodeface" to lead to node cs-identifier;nody-mc-nodeface;{}
-    And I expect this node to have the following properties:
-      | Key  | Value        |
-      | text | "Initial t2" |
-    And I expect node aggregate identifier "sir-nodeward-nodington-iii" to lead to node cs-identifier;sir-nodeward-nodington-iii;{}
-    And I expect this node to have the following properties:
-      | Key   | Value           |
-      | image | "Initial image" |
-
-    When I am in workspace "user-test" and dimension space point {}
-    Then I expect node aggregate identifier "sir-david-nodenborough" to lead to node user-cs-identifier-remaining;sir-david-nodenborough;{}
-    And I expect this node to have the following properties:
-      | Key  | Value         |
-      | text | "Modified t1" |
-    Then I expect node aggregate identifier "nody-mc-nodeface" to lead to node user-cs-identifier-remaining;nody-mc-nodeface;{}
-    And I expect this node to have the following properties:
-      | Key  | Value         |
-      | text | "Modified t2" |
-    Then I expect node aggregate identifier "sir-nodeward-nodington-iii" to lead to node user-cs-identifier-remaining;sir-nodeward-nodington-iii;{}
-    And I expect this node to have the following properties:
-      | Key   | Value            |
-      | image | "Modified image" |
+#  Scenario: It is possible to publish no node
+#    When the command PublishIndividualNodesFromWorkspace is executed with payload:
+#      | Key                             | Value                          |
+#      | workspaceName                   | "user-test"                    |
+#      | nodesToPublish                  | []                             |
+#      | contentStreamIdForRemainingPart | "user-cs-identifier-remaining" |
+#
+#    When I am in workspace "live" and dimension space point {}
+#    Then I expect node aggregate identifier "sir-david-nodenborough" to lead to node cs-identifier;sir-david-nodenborough;{}
+#    And I expect this node to have the following properties:
+#      | Key  | Value        |
+#      | text | "Initial t1" |
+#    And I expect node aggregate identifier "nody-mc-nodeface" to lead to node cs-identifier;nody-mc-nodeface;{}
+#    And I expect this node to have the following properties:
+#      | Key  | Value        |
+#      | text | "Initial t2" |
+#    And I expect node aggregate identifier "sir-nodeward-nodington-iii" to lead to node cs-identifier;sir-nodeward-nodington-iii;{}
+#    And I expect this node to have the following properties:
+#      | Key   | Value           |
+#      | image | "Initial image" |
+#
+#    When I am in workspace "user-test" and dimension space point {}
+#    Then I expect node aggregate identifier "sir-david-nodenborough" to lead to node user-cs-identifier-remaining;sir-david-nodenborough;{}
+#    And I expect this node to have the following properties:
+#      | Key  | Value         |
+#      | text | "Modified t1" |
+#    Then I expect node aggregate identifier "nody-mc-nodeface" to lead to node user-cs-identifier-remaining;nody-mc-nodeface;{}
+#    And I expect this node to have the following properties:
+#      | Key  | Value         |
+#      | text | "Modified t2" |
+#    Then I expect node aggregate identifier "sir-nodeward-nodington-iii" to lead to node user-cs-identifier-remaining;sir-nodeward-nodington-iii;{}
+#    And I expect this node to have the following properties:
+#      | Key   | Value            |
+#      | image | "Modified image" |
 
   Scenario: It is possible to publish all nodes
     When the command PublishIndividualNodesFromWorkspace is executed with payload:

Neos.ContentRepository.Core/Classes/CommandHandlingDependencies.php

@@ -14,8 +14,11 @@
 
 namespace Neos\ContentRepository\Core;
 
+use Neos\ContentGraph\DoctrineDbalAdapter\DoctrineDbalContentGraphProjection;
+use Neos\ContentRepository\Core\CommandHandler\CommandBus;
 use Neos\ContentRepository\Core\CommandHandler\CommandInterface;
 use Neos\ContentRepository\Core\CommandHandler\CommandResult;
+use Neos\ContentRepository\Core\EventStore\EventNormalizer;
 use Neos\ContentRepository\Core\EventStore\EventPersister;
 use Neos\ContentRepository\Core\EventStore\EventsToPublish;
 use Neos\ContentRepository\Core\Projection\ContentGraph\ContentGraphInterface;
@@ -24,6 +27,11 @@
 use Neos\ContentRepository\Core\SharedModel\Workspace\ContentStreamId;
 use Neos\ContentRepository\Core\SharedModel\Workspace\ContentStreamStatus;
 use Neos\ContentRepository\Core\SharedModel\Workspace\WorkspaceName;
+use Neos\EventStore\Helper\InMemoryEventStore;
+use Neos\EventStore\Model\Event\SequenceNumber;
+use Neos\EventStore\Model\Events;
+use Neos\EventStore\Model\EventStream\ExpectedVersion;
+use Neos\EventStore\Model\EventStream\VirtualStreamName;
 use Neos\EventStore\Model\Event\Version;
 
 /**
@@ -40,15 +48,88 @@ final class CommandHandlingDependencies
      */
     private array $overriddenContentGraphInstances = [];
 
+    private InMemoryEventStore|null $inMemoryStoreForSimulation = null;
+
     public function __construct(
         private readonly ContentRepository $contentRepository,
-        private readonly EventPersister $eventPersister
+        private readonly EventPersister $eventPersister,
+        private readonly CommandBus $commandBus,
+        private readonly EventNormalizer $eventNormalizer,
+        // todo use GraphProjectionInterface!!!
+        private readonly DoctrineDbalContentGraphProjection $contentRepositoryProjection
     ) {
     }
 
+
     public function handle(CommandInterface $command): CommandResult
     {
-        return $this->contentRepository->handle($command);
+        if ($this->inMemoryStoreForSimulation !== null) {
+            $this->hanldeInSimulation($command, $this->inMemoryStoreForSimulation);
+        } else {
+            $this->contentRepository->handle($command);
+        }
+        return new CommandResult();
+    }
+
+    /**
+     * @template T
+     * @param \Closure(): T $fn
+     * @return T
+     */
+    public function inSimulation(\Closure $fn, InMemoryEventStore $inMemoryEventStore): mixed
+    {
+        if ($this->inMemoryStoreForSimulation) {
+            throw new \RuntimeException();
+        }
+        $this->inMemoryStoreForSimulation = $inMemoryEventStore;
+        try {
+            return $this->contentRepositoryProjection->inSimulation($fn);
+        } finally {
+            $this->inMemoryStoreForSimulation = null;
+        }
+    }
+
+    private function hanldeInSimulation(CommandInterface $command, InMemoryEventStore $inMemoryEventStore): CommandResult
+    {
+        $eventsToPublish = $this->commandBus->handle($command, $this);
+
+        if ($eventsToPublish->events->isEmpty()) {
+            return new CommandResult();
+        }
+
+        // the following logic could also be done in an AppEventStore::commit method (being called
+        // directly from the individual Command Handlers).
+        $normalizedEvents = Events::fromArray(
+            $eventsToPublish->events->map($this->eventNormalizer->normalize(...))
+        );
+
+        $commitResult = $inMemoryEventStore->commit(
+            $eventsToPublish->streamName,
+            $normalizedEvents,
+            ExpectedVersion::ANY() // The version of the stream in the IN MEMORY event store does not matter to us,
+        // because this is only used in memory during the partial publish or rebase operation; so it cannot be written to
+            // concurrently.
+            // HINT: We cannot use $eventsToPublish->expectedVersion, because this is based on the PERSISTENT event stream (having different numbers)
+        );
+
+
+        $eventStream = $inMemoryEventStore->load(VirtualStreamName::all())->withMinimumSequenceNumber(
+            // fetch all events that were now committed. Plus one because the first sequence number is one too otherwise we get one event to many.
+            // (all elephants shall be placed shamefully placed on my head)
+            SequenceNumber::fromInteger($commitResult->highestCommittedSequenceNumber->value - $eventsToPublish->events->count() + 1)
+        );
+
+        foreach ($eventStream as $eventEnvelope) {
+            $event = $this->eventNormalizer->denormalize($eventEnvelope->event);
+
+            if (!$this->contentRepositoryProjection->canHandle($event)) {
+                continue;
+            }
+
+            $this->contentRepositoryProjection->apply($event, $eventEnvelope);
+        }
+
+        return new CommandResult();
     }
 
     public function publishEvents(EventsToPublish $eventsToPublish): void

Neos.ContentRepository.Core/Classes/ContentRepository.php

@@ -14,6 +14,7 @@
 
 namespace Neos\ContentRepository\Core;
 
+use Neos\ContentGraph\DoctrineDbalAdapter\DoctrineDbalContentGraphProjection;
 use Neos\ContentRepository\Core\CommandHandler\CommandBus;
 use Neos\ContentRepository\Core\CommandHandler\CommandInterface;
 use Neos\ContentRepository\Core\CommandHandler\CommandResult;
@@ -88,7 +89,7 @@ public function __construct(
         private readonly UserIdProviderInterface $userIdProvider,
         private readonly ClockInterface $clock,
     ) {
-        $this->commandHandlingDependencies = new CommandHandlingDependencies($this, $eventPersister);
+        $this->commandHandlingDependencies = new CommandHandlingDependencies($this, $eventPersister, $this->commandBus, $this->eventNormalizer, $this->projectionsAndCatchUpHooks->projections->get(DoctrineDbalContentGraphProjection::class));
     }
 
     /**