FEATURE: ContentGraphAdapter for write side access

Neos.ContentGraph.DoctrineDbalAdapter/src/ContentGraphAdapter.php

@@ -0,0 +1,148 @@
+<?php
+namespace Neos\ContentGraph\DoctrineDbalAdapter;
+
+use Doctrine\DBAL\Connection;
+use Neos\ContentRepository\Core\DimensionSpace\DimensionSpacePoint;
+use Neos\ContentRepository\Core\DimensionSpace\DimensionSpacePointSet;
+use Neos\ContentRepository\Core\DimensionSpace\OriginDimensionSpacePoint;
+use Neos\ContentRepository\Core\Feature\ContentGraphAdapterInterface;
+use Neos\ContentRepository\Core\NodeType\NodeTypeName;
+use Neos\ContentRepository\Core\Projection\ContentGraph\Node;
+use Neos\ContentRepository\Core\Projection\ContentGraph\NodeAggregate;
+use Neos\ContentRepository\Core\Projection\ContentGraph\Nodes;
+use Neos\ContentRepository\Core\Projection\Workspace\Workspace;
+use Neos\ContentRepository\Core\SharedModel\Node\NodeAggregateId;
+use Neos\ContentRepository\Core\SharedModel\Node\NodeName;
+use Neos\ContentRepository\Core\SharedModel\Workspace\ContentStreamId;
+use Neos\ContentRepository\Core\SharedModel\Workspace\ContentStreamState;
+use Neos\ContentRepository\Core\SharedModel\Workspace\WorkspaceName;
+use Neos\EventStore\Model\EventStream\MaybeVersion;
+
+/**
+ *
+ */
+class ContentGraphAdapter implements ContentGraphAdapterInterface
+{
+    private NodeFactory $nodeFactory;
+
+    public function __construct(
+        private readonly Connection $dbalConnection,
+        private readonly string $tableNamePrefix,
+        public readonly ContentStreamId $contentStreamId,
+        public readonly WorkspaceName $workspaceName
+    )
+    {
+    }
+
+    public function rootNodeAggregateWithTypeExists(ContentStreamId $contentStreamId, NodeTypeName $nodeTypeName): bool
+    {
+        // TODO: Implement rootNodeAggregateWithTypeExists() method.
+    }
+
+    public function findParentNodeAggregates(ContentStreamId $contentStreamId, WorkspaceName $workspaceName, NodeAggregateId $childNodeAggregateId): iterable
+    {
+        // TODO: Implement findParentNodeAggregates() method.
+    }
+
+    public function findNodeAggregateById(ContentStreamId $contentStreamId, WorkspaceName $workspaceName, NodeAggregateId $nodeAggregateId): ?NodeAggregate
+    {
+        // TODO: Implement findNodeAggregateById() method.
+    }
+
+    public function findParentNodeAggregateByChildOriginDimensionSpacePoint(ContentStreamId $contentStreamId, WorkspaceName $workspaceName, NodeAggregateId $childNodeAggregateId, OriginDimensionSpacePoint $childOriginDimensionSpacePoint): ?NodeAggregate
+    {
+        // TODO: Implement findParentNodeAggregateByChildOriginDimensionSpacePoint() method.
+    }
+
+    public function findChildNodeAggregates(ContentStreamId $contentStreamId, WorkspaceName $workspaceName, NodeAggregateId $parentNodeAggregateId): iterable
+    {
+        // TODO: Implement findChildNodeAggregates() method.
+    }
+
+    public function findTetheredChildNodeAggregates(ContentStreamId $contentStreamId, WorkspaceName $workspaceName, NodeAggregateId $parentNodeAggregateId): iterable
+    {
+        // TODO: Implement findTetheredChildNodeAggregates() method.
+    }
+
+    public function getDimensionSpacePointsOccupiedByChildNodeName(ContentStreamId $contentStreamId, NodeName $nodeName, NodeAggregateId $parentNodeAggregateId, OriginDimensionSpacePoint $parentNodeOriginDimensionSpacePoint, DimensionSpacePointSet $dimensionSpacePointsToCheck): DimensionSpacePointSet
+    {
+        // TODO: Implement getDimensionSpacePointsOccupiedByChildNodeName() method.
+    }
+
+    public function findChildNodeAggregatesByName(ContentStreamId $contentStreamId, WorkspaceName $workspaceName, NodeAggregateId $parentNodeAggregateId, NodeName $name): iterable
+    {
+        // TODO: Implement findChildNodeAggregatesByName() method.
+    }
+
+    public function subgraphContainsNodes(ContentStreamId $contentStreamId, DimensionSpacePoint $dimensionSpacePoint): bool
+    {
+        // TODO: Implement subgraphContainsNodes() method.
+    }
+
+    public function findNodeInSubgraph(ContentStreamId $contentStreamId, WorkspaceName $workspaceName, DimensionSpacePoint $coveredDimensionSpacePoint, NodeAggregateId $nodeAggregateId): ?Node
+    {
+        // TODO: Implement findNodeInSubgraph() method.
+    }
+
+    public function findParentNodeInSubgraph(ContentStreamId $contentStreamId, WorkspaceName $workspaceName, DimensionSpacePoint $coveredDimensionSpacePoint, NodeAggregateId $childNodeAggregateId): ?Node
+    {
+        // TODO: Implement findParentNodeInSubgraph() method.
+    }
+
+    public function findChildNodeByNameInSubgraph(ContentStreamId $contentStreamId, WorkspaceName $workspaceName, DimensionSpacePoint $coveredDimensionSpacePoint, NodeAggregateId $parentNodeAggregateId, NodeName $nodeNamex): ?Node
+    {
+        // TODO: Implement findChildNodeByNameInSubgraph() method.
+    }
+
+    public function findPreceedingSiblingNodesInSubgraph(ContentStreamId $contentStreamId, WorkspaceName $workspaceName, DimensionSpacePoint $coveredDimensionSpacePoint, NodeAggregateId $startingSiblingNodeAggregateId): Nodesy
+    {
+        // TODO: Implement findPreceedingSiblingNodesInSubgraph() method.
+    }
+
+    public function findSuceedingSiblingNodesInSubgraph(ContentStreamId $contentStreamId, WorkspaceName $workspaceName, DimensionSpacePoint $coveredDimensionSpacePoint, NodeAggregateId $startingSiblingNodeAggregateId): Nodes
+    {
+        // TODO: Implement findSuceedingSiblingNodesInSubgraph() method.
+    }
+
+    public function hasContentStream(ContentStreamId $contentStreamId): bool
+    {
+        // TODO: Implement hasContentStream() method.
+    }
+
+    public function findStateForContentStream(ContentStreamId $contentStreamId): ?ContentStreamState
+    {
+        // TODO: Implement findStateForContentStream() method.
+    }
+
+    public function findVersionForContentStream(ContentStreamId $contentStreamId): MaybeVersion
+    {
+        // TODO: Implement findVersionForContentStream() method.
+    }
+
+    public function findWorkspaceByName(WorkspaceName $workspaceName): ?Workspace
+    {
+        // TODO: Implement findWorkspaceByName() method.
+    }
+
+    public function findWorkspaceByCurrentContentStreamId(ContentStreamId $contentStreamId): ?Workspace
+    {
+        // TODO: Implement findWorkspaceByCurrentContentStreamId() method.
+    }
+
+    private function getTablenameForNode(): string
+    {
+        return $this->tableNamePrefix . '_node';
+    }
+
+    private function getTablenameForHierachyRelation(): string
+    {
+        return $this->tableNamePrefix . '_hierarchyrelation';
+    }
+
+    private function getTablenameForDimensionSpacePoints(): string
+    {
+        return $this->tableNamePrefix . '_dimensionspacepoints';
+    }
+
+
+}

Neos.ContentGraph.DoctrineDbalAdapter/src/ContentGraphAdapterProvider.php

@@ -0,0 +1,36 @@
+<?php
+namespace Neos\ContentGraph\DoctrineDbalAdapter;
+
+use Doctrine\DBAL\Connection;
+use Neos\ContentRepository\Core\Feature\ContentGraphAdapterInterface;
+use Neos\ContentRepository\Core\Feature\ContentGraphAdapterProviderInterface;
+use Neos\ContentRepository\Core\SharedModel\Workspace\ContentStreamId;
+use Neos\ContentRepository\Core\SharedModel\Workspace\WorkspaceName;
+
+/**
+ * @api
+ */
+class ContentGraphAdapterProvider implements ContentGraphAdapterProviderInterface
+{
+    public function __construct(
+        private readonly Connection $dbalConnection,
+        private readonly string $tableNamePrefix,
+    ) {
+    }
+
+    public function resolveWorkspaceNameAndGet(ContentStreamId $contentStreamId): ContentGraphAdapterInterface
+    {
+        // TODO: Implement resolveWorkspaceNameAndGet() method.
+    }
+
+    public function resolveContentStreamIdAndGet(WorkspaceName $workspaceName): ContentGraphAdapterInterface
+    {
+        // TODO: Implement resolveContentStreamIdAndGet() method.
+    }
+
+    public function overrideContentStreamId(WorkspaceName $workspaceName, ContentStreamId $contentStreamId, \Closure $fn): void
+    {
+        // TODO: Implement overrideContentStreamId() method.
+    }
+
+}

Neos.ContentGraph.DoctrineDbalAdapter/src/ContentGraphAdapterProviderFactory.php

@@ -0,0 +1,26 @@
+<?php
+namespace Neos\ContentGraph\DoctrineDbalAdapter;
+
+use Doctrine\DBAL\Connection;
+use Neos\ContentRepository\Core\Feature\ContentGraphAdapterProviderFactoryInterface;
+use Neos\ContentRepository\Core\Feature\ContentGraphAdapterProviderInterface;
+use Neos\ContentRepository\Core\SharedModel\ContentRepository\ContentRepositoryId;
+
+/**
+ * This factory resolves low level dependencies for the ContentGraphAdapterProvider implementation
+ */
+class ContentGraphAdapterProviderFactory implements ContentGraphAdapterProviderFactoryInterface
+{
+    public function __construct(
+        readonly Connection $dbalConnection
+    ) {
+    }
+
+    public function build(ContentRepositoryId $contentRepositoryId, array $options): ContentGraphAdapterProviderInterface
+    {
+        $tableNamePrefix = DoctrineDbalContentGraphProjectionFactory::graphProjectionTableNamePrefix(
+            $contentRepositoryId
+        );
+        return new ContentGraphAdapterProvider($this->dbalConnection, $tableNamePrefix);
+    }
+}

Neos.ContentRepository.Core/Classes/ContentRepository.php

@@ -29,6 +29,7 @@
 use Neos\ContentRepository\Core\NodeType\NodeTypeManager;
 use Neos\ContentRepository\Core\Projection\CatchUp;
 use Neos\ContentRepository\Core\Projection\CatchUpOptions;
+use Neos\ContentRepository\Core\Feature\ContentGraphAdapterInterface;
 use Neos\ContentRepository\Core\Projection\ContentGraph\ContentGraphInterface;
 use Neos\ContentRepository\Core\Projection\ContentStream\ContentStreamFinder;
 use Neos\ContentRepository\Core\Projection\ProjectionInterface;
@@ -258,4 +259,12 @@ public function getContentDimensionSource(): ContentDimensionSourceInterface
     {
         return $this->contentDimensionSource;
     }
+
+    /**
+     * @internal
+     */
+    public function getContentGraphAdapter(): ContentGraphAdapterInterface
+    {
+        return $this->getContentGraph();
+    }
 }

Neos.ContentRepository.Core/Classes/Factory/ContentRepositoryFactory.php

@@ -21,6 +21,7 @@
 use Neos\ContentRepository\Core\DimensionSpace\InterDimensionalVariationGraph;
 use Neos\ContentRepository\Core\EventStore\EventNormalizer;
 use Neos\ContentRepository\Core\EventStore\EventPersister;
+use Neos\ContentRepository\Core\Feature\ContentGraphAdapterProviderInterface;
 use Neos\ContentRepository\Core\Feature\ContentStreamCommandHandler;
 use Neos\ContentRepository\Core\Feature\DimensionSpaceAdjustment\DimensionSpaceCommandHandler;
 use Neos\ContentRepository\Core\Feature\NodeAggregateCommandHandler;
@@ -56,6 +57,7 @@ public function __construct(
         private readonly ProjectionCatchUpTriggerInterface $projectionCatchUpTrigger,
         private readonly UserIdProviderInterface $userIdProvider,
         private readonly ClockInterface $clock,
+        private readonly ContentGraphAdapterProviderInterface $contentGraphAdapterProvider,
     ) {
         $contentDimensionZookeeper = new ContentDimensionZookeeper($contentDimensionSource);
         $interDimensionalVariationGraph = new InterDimensionalVariationGraph(
@@ -125,6 +127,7 @@ public function buildService(
             $this->getOrBuild(),
             $this->buildEventPersister(),
             $this->projectionsAndCatchUpHooks->projections,
+            $this->contentGraphAdapterProvider
         );
         return $serviceFactory->build($serviceFactoryDependencies);
     }
@@ -134,26 +137,31 @@ private function buildCommandBus(): CommandBus
         if (!$this->commandBus) {
             $this->commandBus = new CommandBus(
                 new ContentStreamCommandHandler(
+                    $this->contentGraphAdapterProvider
                 ),
                 new WorkspaceCommandHandler(
                     $this->buildEventPersister(),
                     $this->projectionFactoryDependencies->eventStore,
                     $this->projectionFactoryDependencies->eventNormalizer,
+                    $this->contentGraphAdapterProvider
                 ),
                 new NodeAggregateCommandHandler(
                     $this->projectionFactoryDependencies->nodeTypeManager,
                     $this->projectionFactoryDependencies->contentDimensionZookeeper,
                     $this->projectionFactoryDependencies->interDimensionalVariationGraph,
-                    $this->projectionFactoryDependencies->propertyConverter
+                    $this->projectionFactoryDependencies->propertyConverter,
+                    $this->contentGraphAdapterProvider
                 ),
                 new DimensionSpaceCommandHandler(
                     $this->projectionFactoryDependencies->contentDimensionZookeeper,
-                    $this->projectionFactoryDependencies->interDimensionalVariationGraph
+                    $this->projectionFactoryDependencies->interDimensionalVariationGraph,
+                    $this->contentGraphAdapterProvider
                 ),
                 new NodeDuplicationCommandHandler(
                     $this->projectionFactoryDependencies->nodeTypeManager,
                     $this->projectionFactoryDependencies->contentDimensionZookeeper,
-                    $this->projectionFactoryDependencies->interDimensionalVariationGraph
+                    $this->projectionFactoryDependencies->interDimensionalVariationGraph,
+                    $this->contentGraphAdapterProvider
                 )
             );
         }

Neos.ContentRepository.Core/Classes/Factory/ContentRepositoryServiceFactoryDependencies.php

@@ -20,6 +20,7 @@
 use Neos\ContentRepository\Core\DimensionSpace\InterDimensionalVariationGraph;
 use Neos\ContentRepository\Core\EventStore\EventNormalizer;
 use Neos\ContentRepository\Core\EventStore\EventPersister;
+use Neos\ContentRepository\Core\Feature\ContentGraphAdapterProviderInterface;
 use Neos\ContentRepository\Core\Infrastructure\Property\PropertyConverter;
 use Neos\ContentRepository\Core\NodeType\NodeTypeManager;
 use Neos\ContentRepository\Core\Projection\Projections;
@@ -47,6 +48,7 @@ private function __construct(
         // we don't need CommandBus, because this is included in ContentRepository->handle()
         public EventPersister $eventPersister,
         public Projections $projections,
+        public ContentGraphAdapterProviderInterface $contentGraphAdapterProvider
     ) {
     }
 
@@ -58,6 +60,7 @@ public static function create(
         ContentRepository $contentRepository,
         EventPersister $eventPersister,
         Projections $projections,
+        ContentGraphAdapterProviderInterface $contentGraphAdapterProvider
     ): self {
         return new self(
             $projectionFactoryDependencies->contentRepositoryId,
@@ -71,6 +74,7 @@ public static function create(
             $contentRepository,
             $eventPersister,
             $projections,
+            $contentGraphAdapterProvider
         );
     }
 }