!!! FEATURE: Bind ContentGraph to workspace

Neos.ContentGraph.DoctrineDbalAdapter/src/ContentGraphFactory.php

@@ -0,0 +1,64 @@
+<?php
+
+namespace Neos\ContentGraph\DoctrineDbalAdapter;
+
+use Neos\ContentGraph\DoctrineDbalAdapter\Domain\Repository\ContentGraph;
+use Neos\ContentGraph\DoctrineDbalAdapter\Domain\Repository\NodeFactory;
+use Neos\ContentRepository\Core\ContentGraphFactoryInterface;
+use Neos\ContentRepository\Core\Infrastructure\DbalClientInterface;
+use Neos\ContentRepository\Core\NodeType\NodeTypeManager;
+use Neos\ContentRepository\Core\Projection\Workspace\Workspace;
+use Neos\ContentRepository\Core\Projection\Workspace\WorkspaceStatus;
+use Neos\ContentRepository\Core\SharedModel\ContentRepository\ContentRepositoryId;
+use Neos\ContentRepository\Core\SharedModel\Exception\ContentStreamDoesNotExistYet;
+use Neos\ContentRepository\Core\SharedModel\Workspace\ContentStreamId;
+use Neos\ContentRepository\Core\SharedModel\Workspace\WorkspaceDescription;
+use Neos\ContentRepository\Core\SharedModel\Workspace\WorkspaceName;
+use Neos\ContentRepository\Core\SharedModel\Workspace\WorkspaceTitle;
+
+/**
+ * @internal only used inside the
+ * @see ContentGraphFinder
+ */
+readonly final class ContentGraphFactory implements ContentGraphFactoryInterface
+{
+    public function __construct(
+        private DbalClientInterface $client,
+        private NodeFactory $nodeFactory,
+        private ContentRepositoryId $contentRepositoryId,
+        private NodeTypeManager $nodeTypeManager,
+        private string $tableNamePrefix
+    ) {
+    }
+
+    public function buildForWorkspace(WorkspaceName $workspaceName): ContentGraph
+    {
+        // FIXME: Should be part of this projection, this is forbidden
+        $tableName = strtolower(sprintf(
+            'cr_%s_p_%s',
+            $this->contentRepositoryId->value,
+            'Workspace'
+        ));
+
+        $row = $this->client->getConnection()->executeQuery(
+            '
+                SELECT * FROM ' . $tableName . '
+                WHERE workspaceName = :workspaceName
+            ',
+            [
+                'workspaceName' => $workspaceName->value,
+            ]
+        )->fetchAssociative();
+
+        if ($row === false) {
+            throw new ContentStreamDoesNotExistYet('The workspace "' . $workspaceName->value . '" does not exist.', 1714839710);
+        }
+
+        return $this->buildForWorkspaceAndContentStream($workspaceName, ContentStreamId::fromString($row['currentcontentstreamid']));
+    }
+
+    public function buildForWorkspaceAndContentStream(WorkspaceName $workspaceName, ContentStreamId $contentStreamId): ContentGraph
+    {
+        return new ContentGraph($this->client, $this->nodeFactory, $this->contentRepositoryId, $this->nodeTypeManager, $this->tableNamePrefix, $workspaceName, $contentStreamId);
+    }
+}

Neos.ContentGraph.DoctrineDbalAdapter/src/ContentGraphTableNames.php

@@ -0,0 +1,44 @@
+<?php
+
+namespace Neos\ContentGraph\DoctrineDbalAdapter;
+
+/**
+ * Encapsulates table name generation for content graph tables
+ * @internal
+ */
+final class ContentGraphTableNames
+{
+    private function __construct(private readonly string $tableNamePrefix)
+    {
+    }
+
+    public static function withPrefix(string $tableNamePrefix): self
+    {
+        return new self($tableNamePrefix);
+    }
+
+    public function node(): string
+    {
+        return $this->tableNamePrefix . '_node';
+    }
+
+    public function hierachyRelation(): string
+    {
+        return $this->tableNamePrefix . '_hierarchyrelation';
+    }
+
+    public function dimensionSpacePoints(): string
+    {
+        return $this->tableNamePrefix . '_dimensionspacepoints';
+    }
+
+    public function referenceRelation(): string
+    {
+        return $this->tableNamePrefix . '_referencerelation';
+    }
+
+    public function checkpoint(): string
+    {
+        return $this->tableNamePrefix . '_checkpoint';
+    }
+}

Neos.ContentGraph.DoctrineDbalAdapter/src/DoctrineDbalContentGraphProjectionFactory.php

@@ -7,6 +7,7 @@
 use Neos\ContentGraph\DoctrineDbalAdapter\Domain\Repository\DimensionSpacePointsRepository;
 use Neos\ContentGraph\DoctrineDbalAdapter\Domain\Repository\NodeFactory;
 use Neos\ContentGraph\DoctrineDbalAdapter\Domain\Repository\ProjectionContentGraph;
+use Neos\ContentRepository\Core\ContentGraphFinder;
 use Neos\ContentRepository\Core\Factory\ProjectionFactoryDependencies;
 use Neos\ContentRepository\Core\Infrastructure\DbalClientInterface;
 use Neos\ContentRepository\Core\Projection\ContentGraph\ContentGraphProjection;
@@ -43,23 +44,31 @@ public function build(
 
         $dimensionSpacePointsRepository = new DimensionSpacePointsRepository($this->dbalClient->getConnection(), $tableNamePrefix);
 
+        $nodeFactory = new NodeFactory(
+            $projectionFactoryDependencies->contentRepositoryId,
+            $projectionFactoryDependencies->nodeTypeManager,
+            $projectionFactoryDependencies->propertyConverter,
+            $dimensionSpacePointsRepository
+        );
+
+        $contentGraphFactory = new ContentGraphFactory(
+            $this->dbalClient,
+            $nodeFactory,
+            $projectionFactoryDependencies->contentRepositoryId,
+            $projectionFactoryDependencies->nodeTypeManager,
+            $tableNamePrefix
+        );
+
         return new ContentGraphProjection(
             new DoctrineDbalContentGraphProjection(
                 $this->dbalClient,
-                new NodeFactory(
-                    $projectionFactoryDependencies->contentRepositoryId,
-                    $projectionFactoryDependencies->nodeTypeManager,
-                    $projectionFactoryDependencies->propertyConverter,
-                    $dimensionSpacePointsRepository
-                ),
-                $projectionFactoryDependencies->contentRepositoryId,
-                $projectionFactoryDependencies->nodeTypeManager,
                 new ProjectionContentGraph(
                     $this->dbalClient,
                     $tableNamePrefix
                 ),
                 $tableNamePrefix,
-                $dimensionSpacePointsRepository
+                $dimensionSpacePointsRepository,
+                new ContentGraphFinder($contentGraphFactory)
             )
         );
     }

Neos.ContentGraph.DoctrineDbalAdapter/src/DoctrineDbalContentGraphSchemaBuilder.php

@@ -17,9 +17,12 @@ class DoctrineDbalContentGraphSchemaBuilder
 {
     private const DEFAULT_TEXT_COLLATION = 'utf8mb4_unicode_520_ci';
 
+    private readonly ContentGraphTableNames $contentGraphTableNames;
+
     public function __construct(
-        private readonly string $tableNamePrefix
+        string $tableNamePrefix
     ) {
+        $this->contentGraphTableNames = ContentGraphTableNames::withPrefix($tableNamePrefix);
     }
 
     public function buildSchema(AbstractSchemaManager $schemaManager): Schema
@@ -34,7 +37,7 @@ public function buildSchema(AbstractSchemaManager $schemaManager): Schema
 
     private function createNodeTable(): Table
     {
-        $table = new Table($this->tableNamePrefix . '_node', [
+        $table = new Table($this->contentGraphTableNames->node(), [
             DbalSchemaFactory::columnForNodeAnchorPoint('relationanchorpoint')->setAutoincrement(true),
             DbalSchemaFactory::columnForNodeAggregateId('nodeaggregateid')->setNotnull(false),
             DbalSchemaFactory::columnForDimensionSpacePointHash('origindimensionspacepointhash')->setNotnull(false),
@@ -55,7 +58,7 @@ private function createNodeTable(): Table
 
     private function createHierarchyRelationTable(): Table
     {
-        $table = new Table($this->tableNamePrefix . '_hierarchyrelation', [
+        $table = new Table($this->contentGraphTableNames->hierachyRelation(), [
             (new Column('name', Type::getType(Types::STRING)))->setLength(255)->setNotnull(false)->setCustomSchemaOption('charset', 'ascii')->setCustomSchemaOption('collation', 'ascii_general_ci'),
             (new Column('position', Type::getType(Types::INTEGER)))->setNotnull(true),
             DbalSchemaFactory::columnForContentStreamId('contentstreamid')->setNotnull(true),
@@ -75,7 +78,7 @@ private function createHierarchyRelationTable(): Table
 
     private function createDimensionSpacePointsTable(): Table
     {
-        $table = new Table($this->tableNamePrefix . '_dimensionspacepoints', [
+        $table = new Table($this->contentGraphTableNames->dimensionSpacePoints(), [
             DbalSchemaFactory::columnForDimensionSpacePointHash('hash')->setNotnull(true),
             DbalSchemaFactory::columnForDimensionSpacePoint('dimensionspacepoint')->setNotnull(true)
         ]);
@@ -86,7 +89,7 @@ private function createDimensionSpacePointsTable(): Table
 
     private function createReferenceRelationTable(): Table
     {
-        $table = new Table($this->tableNamePrefix . '_referencerelation', [
+        $table = new Table($this->contentGraphTableNames->referenceRelation(), [
             (new Column('name', Type::getType(Types::STRING)))->setLength(255)->setNotnull(true)->setCustomSchemaOption('charset', 'ascii')->setCustomSchemaOption('collation', 'ascii_general_ci'),
             (new Column('position', Type::getType(Types::INTEGER)))->setNotnull(true),
             DbalSchemaFactory::columnForNodeAnchorPoint('nodeanchorpoint'),