FEATURE: In-Memory Content Graph

Neos.ContentRepository.Core/Classes/Projection/ContentGraph/InMemoryContentGraph/InMemoryContentGraphProjectionFactory.php

@@ -0,0 +1,49 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Neos\ContentRepository\Core\Projection\ContentGraph\InMemoryContentGraph;
+
+use Neos\ContentRepository\Core\Factory\SubscriberFactoryDependencies;
+use Neos\ContentRepository\Core\Projection\ContentGraph\ContentGraphProjectionFactoryInterface;
+use Neos\ContentRepository\Core\Projection\ContentGraph\InMemoryContentGraph\Projection\InMemoryContentGraphStructure;
+use Neos\ContentRepository\Core\Projection\ContentGraph\InMemoryContentGraph\Repository\InMemoryContentStreamRegistry;
+use Neos\ContentRepository\Core\Projection\ContentGraph\InMemoryContentGraph\Repository\InMemoryWorkspaceRegistry;
+use Neos\ContentRepository\Core\Projection\ContentGraph\InMemoryContentGraph\Repository\NodeFactory;
+
+/**
+ * Use this class as ProjectionFactory in your configuration to construct a content graph
+ *
+ * @api
+ */
+final class InMemoryContentGraphProjectionFactory implements ContentGraphProjectionFactoryInterface
+{
+    public function build(
+        SubscriberFactoryDependencies $projectionFactoryDependencies,
+    ): InMemoryContentGraphProjection {
+        $nodeFactory = new NodeFactory(
+            $projectionFactoryDependencies->contentRepositoryId,
+            $projectionFactoryDependencies->getPropertyConverter(),
+        );
+
+        $graphStructure = InMemoryContentGraphStructure::getInstance();
+        $workspaceRegistry = InMemoryWorkspaceRegistry::getInstance();
+        $contentStreamRegistry = InMemoryContentStreamRegistry::getInstance();
+
+        $contentGraphReadModel = new InMemoryContentGraphReadModelAdapter(
+            $projectionFactoryDependencies->contentRepositoryId,
+            $projectionFactoryDependencies->nodeTypeManager,
+            $graphStructure,
+            $workspaceRegistry,
+            $contentStreamRegistry,
+            $nodeFactory,
+        );
+
+        return new InMemoryContentGraphProjection(
+            $contentGraphReadModel,
+            $graphStructure,
+            $workspaceRegistry,
+            $contentStreamRegistry,
+        );
+    }
+}

Neos.ContentRepository.Core/Classes/Projection/ContentGraph/InMemoryContentGraph/InMemoryContentGraphReadModelAdapter.php

@@ -0,0 +1,113 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Neos\ContentRepository\Core\Projection\ContentGraph\InMemoryContentGraph;
+
+use Neos\ContentRepository\Core\NodeType\NodeTypeManager;
+use Neos\ContentRepository\Core\Projection\ContentGraph\ContentGraphReadModelInterface;
+use Neos\ContentRepository\Core\Projection\ContentGraph\InMemoryContentGraph\Projection\InMemoryContentGraphStructure;
+use Neos\ContentRepository\Core\Projection\ContentGraph\InMemoryContentGraph\Projection\InMemoryContentStreamRecord;
+use Neos\ContentRepository\Core\Projection\ContentGraph\InMemoryContentGraph\Projection\InMemoryWorkspaceRecord;
+use Neos\ContentRepository\Core\Projection\ContentGraph\InMemoryContentGraph\Repository\InMemoryContentGraph;
+use Neos\ContentRepository\Core\Projection\ContentGraph\InMemoryContentGraph\Repository\InMemoryContentStreamRegistry;
+use Neos\ContentRepository\Core\Projection\ContentGraph\InMemoryContentGraph\Repository\InMemoryWorkspaceRegistry;
+use Neos\ContentRepository\Core\Projection\ContentGraph\InMemoryContentGraph\Repository\NodeFactory;
+use Neos\ContentRepository\Core\SharedModel\ContentRepository\ContentRepositoryId;
+use Neos\ContentRepository\Core\SharedModel\Exception\WorkspaceDoesNotExist;
+use Neos\ContentRepository\Core\SharedModel\Workspace\ContentStream;
+use Neos\ContentRepository\Core\SharedModel\Workspace\ContentStreamId;
+use Neos\ContentRepository\Core\SharedModel\Workspace\Workspace;
+use Neos\ContentRepository\Core\SharedModel\Workspace\WorkspaceName;
+use Neos\ContentRepository\Core\SharedModel\Workspace\Workspaces;
+use Neos\ContentRepository\Core\SharedModel\Workspace\WorkspaceStatus;
+
+/**
+ * @internal
+ */
+final readonly class InMemoryContentGraphReadModelAdapter implements ContentGraphReadModelInterface
+{
+    public function __construct(
+        private ContentRepositoryId $contentRepositoryId,
+        private NodeTypeManager $nodeTypeManager,
+        private InMemoryContentGraphStructure $graphStructure,
+        private InMemoryWorkspaceRegistry $workspaceRegistry,
+        private InMemoryContentStreamRegistry $contentStreamRegistry,
+        private NodeFactory $nodeFactory,
+    ) {
+    }
+
+    /**
+     * @throws WorkspaceDoesNotExist if the workspace does not exist
+     */
+    public function getContentGraph(WorkspaceName $workspaceName): InMemoryContentGraph
+    {
+        $workspace = $this->workspaceRegistry->workspaces[$workspaceName->value] ?? null;
+        if ($workspace === null) {
+            throw WorkspaceDoesNotExist::butWasSupposedTo($workspaceName);
+        }
+        return new InMemoryContentGraph(
+            $this->graphStructure,
+            $this->nodeFactory,
+            $this->contentRepositoryId,
+            $this->nodeTypeManager,
+            $workspaceName,
+            $workspace->currentContentStreamId,
+        );
+    }
+
+    public function findWorkspaceByName(WorkspaceName $workspaceName): ?Workspace
+    {
+        $workspaceRecord = $this->workspaceRegistry->workspaces[$workspaceName->value] ?? null;
+
+        return $workspaceRecord
+            ? self::mapWorkspaceRecordToWorkspace($workspaceRecord)
+            : null;
+    }
+
+    public function findWorkspaces(): Workspaces
+    {
+        return Workspaces::fromArray(array_map(
+            fn (InMemoryWorkspaceRecord $workspaceRecord): Workspace
+                => self::mapWorkspaceRecordToWorkspace($workspaceRecord),
+            $this->workspaceRegistry->workspaces
+        ));
+    }
+
+    public function findContentStreamById(ContentStreamId $contentStreamId): ?ContentStream
+    {
+        $contentStreamRecord = $this->contentStreamRegistry->contentStreams[$contentStreamId->value] ?? null;
+
+        return $contentStreamRecord
+            ? self::mapContentStreamRecordToContentStream($contentStreamRecord)
+            : null;
+    }
+
+    public function countNodes(): int
+    {
+        return $this->graphStructure->totalNodeCount;
+    }
+
+    private static function mapWorkspaceRecordToWorkspace(InMemoryWorkspaceRecord $workspaceRecord): Workspace
+    {
+        return Workspace::create(
+            $workspaceRecord->workspaceName,
+            $workspaceRecord->baseWorkspaceName,
+            $workspaceRecord->currentContentStreamId,
+            $workspaceRecord->baseWorkspaceName === null || $workspaceRecord->isUpToDateWithBase
+                ? WorkspaceStatus::UP_TO_DATE
+                : WorkspaceStatus::OUTDATED,
+            $workspaceRecord->baseWorkspaceName !== null && $workspaceRecord->hasChanges
+        );
+    }
+
+    private static function mapContentStreamRecordToContentStream(InMemoryContentStreamRecord $contentStreamRecord): ContentStream
+    {
+        return ContentStream::create(
+            $contentStreamRecord->id,
+            $contentStreamRecord->sourceContentStreamId,
+            $contentStreamRecord->version,
+            $contentStreamRecord->isClosed,
+        );
+    }
+}

Neos.ContentRepository.Core/Classes/Projection/ContentGraph/InMemoryContentGraph/Projection/Feature/NodeMove.php

@@ -0,0 +1,198 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Neos\ContentGraph\DoctrineDbalAdapter\Domain\Projection\Feature;
+
+use Neos\ContentGraph\DoctrineDbalAdapter\Domain\Projection\HierarchyRelation;
+use Neos\ContentGraph\DoctrineDbalAdapter\Domain\Projection\NodeRecord;
+use Neos\ContentRepository\Core\DimensionSpace\DimensionSpacePoint;
+use Neos\ContentRepository\Core\DimensionSpace\DimensionSpacePointSet;
+use Neos\ContentRepository\Core\Feature\Common\InterdimensionalSibling;
+use Neos\ContentRepository\Core\Feature\Common\InterdimensionalSiblings;
+use Neos\ContentRepository\Core\SharedModel\Node\NodeAggregateId;
+use Neos\ContentRepository\Core\SharedModel\Workspace\ContentStreamId;
+
+/**
+ * The NodeMove projection feature trait
+ *
+ * @internal
+ */
+trait NodeMove
+{
+    use SubtreeTagging;
+
+    private function moveNodeAggregate(ContentStreamId $contentStreamId, NodeAggregateId $nodeAggregateId, ?NodeAggregateId $newParentNodeAggregateId, InterdimensionalSiblings $succeedingSiblingsForCoverage): void
+    {
+        foreach ($succeedingSiblingsForCoverage as $succeedingSiblingForCoverage) {
+            $nodeToBeMoved = $this->projectionContentGraph->findNodeInAggregate(
+                $contentStreamId,
+                $nodeAggregateId,
+                $succeedingSiblingForCoverage->dimensionSpacePoint
+            );
+
+            if (is_null($nodeToBeMoved)) {
+                throw new \RuntimeException(sprintf('Failed to move node "%s" in sub graph %s@%s because it does not exist', $nodeAggregateId->value, $succeedingSiblingForCoverage->dimensionSpacePoint->toJson(), $contentStreamId->value), 1716471638);
+            }
+
+            if ($newParentNodeAggregateId) {
+                $this->moveNodeBeneathParent(
+                    $contentStreamId,
+                    $nodeToBeMoved,
+                    $newParentNodeAggregateId,
+                    $succeedingSiblingForCoverage
+                );
+                $this->moveSubtreeTags(
+                    $contentStreamId,
+                    $newParentNodeAggregateId,
+                    $succeedingSiblingForCoverage->dimensionSpacePoint
+                );
+            } else {
+                $this->moveNodeBeforeSucceedingSibling(
+                    $contentStreamId,
+                    $nodeToBeMoved,
+                    $succeedingSiblingForCoverage,
+                );
+                // subtree tags stay the same if the parent doesn't change
+            }
+        }
+    }
+
+    /**
+     * This helper is responsible for moving a single incoming HierarchyRelation of $nodeToBeMoved
+     * to a new location without changing the parent. $succeedingSiblingForCoverage specifies
+     * which incoming HierarchyRelation should be moved and where exactly.
+     *
+     * The move target is given as $succeedingSiblingNodeMoveTarget. This also specifies the new parent node.
+     */
+    private function moveNodeBeforeSucceedingSibling(
+        ContentStreamId $contentStreamId,
+        NodeRecord $nodeToBeMoved,
+        InterdimensionalSibling $succeedingSiblingForCoverage,
+    ): void {
+        // find the single ingoing hierarchy relation which we want to move
+        $ingoingHierarchyRelation = $this->findIngoingHierarchyRelationToBeMoved(
+            $nodeToBeMoved,
+            $contentStreamId,
+            $succeedingSiblingForCoverage->dimensionSpacePoint
+        );
+
+        $newSucceedingSibling = null;
+        if ($succeedingSiblingForCoverage->nodeAggregateId) {
+            // find the new succeeding sibling NodeRecord; We need this record because we'll use its RelationAnchorPoint later.
+            $newSucceedingSibling = $this->projectionContentGraph->findNodeInAggregate(
+                $contentStreamId,
+                $succeedingSiblingForCoverage->nodeAggregateId,
+                $succeedingSiblingForCoverage->dimensionSpacePoint
+            );
+            if ($newSucceedingSibling === null) {
+                throw new \RuntimeException(sprintf('Failed to move node "%s" in sub graph %s@%s because target succeeding sibling node "%s" is missing', $nodeToBeMoved->nodeAggregateId->value, $succeedingSiblingForCoverage->dimensionSpacePoint->toJson(), $contentStreamId->value, $succeedingSiblingForCoverage->nodeAggregateId->value), 1716471881);
+            }
+        }
+
+        // fetch...
+        $newPosition = $this->getRelationPosition(
+            $ingoingHierarchyRelation->parentNodeAnchor,
+            null,
+            $newSucceedingSibling?->relationAnchorPoint,
+            $contentStreamId,
+            $succeedingSiblingForCoverage->dimensionSpacePoint
+        );
+
+        // ...and assign the new position
+        $ingoingHierarchyRelation->assignNewPosition(
+            $newPosition,
+            $this->dbal,
+            $this->tableNames
+        );
+    }
+
+    /**
+     * This helper is responsible for moving a single incoming HierarchyRelation of $nodeToBeMoved
+     * to a new location including a change of parent. $succeedingSiblingForCoverage specifies
+     * which incoming HierarchyRelation should be moved and where exactly.
+     *
+     * The move target is given as $parentNodeAggregateId and $succeedingSiblingForCoverage.
+     * We always move beneath the parent before the succeeding sibling if given (or to the end)
+     */
+    private function moveNodeBeneathParent(
+        ContentStreamId $contentStreamId,
+        NodeRecord $nodeToBeMoved,
+        NodeAggregateId $parentNodeAggregateId,
+        InterdimensionalSibling $succeedingSiblingForCoverage,
+    ): void {
+        // find the single ingoing hierarchy relation which we want to move
+        $ingoingHierarchyRelation = $this->findIngoingHierarchyRelationToBeMoved(
+            $nodeToBeMoved,
+            $contentStreamId,
+            $succeedingSiblingForCoverage->dimensionSpacePoint
+        );
+
+        // find the new parent NodeRecord; We need this record because we'll use its RelationAnchorPoints later.
+        $newParent = $this->projectionContentGraph->findNodeInAggregate(
+            $contentStreamId,
+            $parentNodeAggregateId,
+            $succeedingSiblingForCoverage->dimensionSpacePoint
+        );
+        if ($newParent === null) {
+            throw new \RuntimeException(sprintf('Failed to move node "%s" in sub graph %s@%s because target parent node is missing', $nodeToBeMoved->nodeAggregateId->value, $succeedingSiblingForCoverage->dimensionSpacePoint->toJson(), $contentStreamId->value), 1716471955);
+        }
+
+        $newSucceedingSibling = null;
+        if ($succeedingSiblingForCoverage->nodeAggregateId) {
+            // find the new succeeding sibling NodeRecord; We need this record because we'll use its RelationAnchorPoint later.
+            $newSucceedingSibling = $this->projectionContentGraph->findNodeInAggregate(
+                $contentStreamId,
+                $succeedingSiblingForCoverage->nodeAggregateId,
+                $succeedingSiblingForCoverage->dimensionSpacePoint
+            );
+            if ($newSucceedingSibling === null) {
+                throw new \RuntimeException(sprintf('Failed to move node "%s" in sub graph %s@%s because target succeeding sibling node is missing', $nodeToBeMoved->nodeAggregateId->value, $succeedingSiblingForCoverage->dimensionSpacePoint->toJson(), $contentStreamId->value), 1716471995);
+            }
+        }
+
+        // assign new position
+        $newPosition = $this->getRelationPosition(
+            $newParent->relationAnchorPoint,
+            null,
+            $newSucceedingSibling?->relationAnchorPoint,
+            $contentStreamId,
+            $succeedingSiblingForCoverage->dimensionSpacePoint
+        );
+
+        // this is the actual move
+        $ingoingHierarchyRelation->assignNewParentNode(
+            $newParent->relationAnchorPoint,
+            $newPosition,
+            $this->dbal,
+            $this->tableNames
+        );
+    }
+
+    /**
+     * Helper for the move methods.
+     *
+     * @param NodeRecord $nodeToBeMoved
+     * @param ContentStreamId $contentStreamId
+     * @param DimensionSpacePoint $coveredDimensionSpacePointWhereMoveShouldHappen
+     * @return HierarchyRelation
+     */
+    private function findIngoingHierarchyRelationToBeMoved(
+        NodeRecord $nodeToBeMoved,
+        ContentStreamId $contentStreamId,
+        DimensionSpacePoint $coveredDimensionSpacePointWhereMoveShouldHappen
+    ): HierarchyRelation {
+        $restrictToSet = DimensionSpacePointSet::fromArray([$coveredDimensionSpacePointWhereMoveShouldHappen]);
+        $ingoingHierarchyRelations = $this->projectionContentGraph->findIngoingHierarchyRelationsForNode(
+            $nodeToBeMoved->relationAnchorPoint,
+            $contentStreamId,
+            $restrictToSet,
+        );
+        if (count($ingoingHierarchyRelations) !== 1) {
+            // there should always be exactly one incoming relation in the given DimensionSpacePoint; everything
+            // else would be a totally wrong behavior of findIngoingHierarchyRelationsForNode().
+            throw new \RuntimeException(sprintf('Failed move node "%s" in sub graph %s@%s because ingoing source hierarchy relation is missing', $nodeToBeMoved->nodeAggregateId->value, $restrictToSet->toJson(), $contentStreamId->value), 1716472138);
+        }
+        return reset($ingoingHierarchyRelations);
+    }
+}