register CatchUpHook for flushing Subgraph

Neos.ContentRepositoryRegistry/Classes/SubgraphCachingInMemory/FlushSubgraphCachePoolCatchUpHook.php

@@ -0,0 +1,47 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Neos\ContentRepositoryRegistry\SubgraphCachingInMemory;
+
+use Neos\Flow\Annotations as Flow;
+use Neos\ContentRepository\Core\EventStore\EventInterface;
+use Neos\ContentRepository\Core\Projection\CatchUpHookInterface;
+use Neos\EventStore\Model\EventEnvelope;
+
+/**
+ * Ensures that the {@see SubgraphCachePool} is flushed always when content changes. This CatchUpHook
+ * is triggered when projections change.
+ *
+ * @internal
+ */
+#[Flow\Proxy(false)]
+final class FlushSubgraphCachePoolCatchUpHook implements CatchUpHookInterface
+{
+
+    public function __construct(private readonly SubgraphCachePool $subgraphCachePool)
+    {
+    }
+
+    public function onBeforeCatchUp(): void
+    {
+    }
+
+    public function onBeforeEvent(EventInterface $eventInstance, EventEnvelope $eventEnvelope): void
+    {
+    }
+
+    public function onAfterEvent(EventInterface $eventInstance, EventEnvelope $eventEnvelope): void
+    {
+        $this->subgraphCachePool->reset();
+    }
+
+    public function onBeforeBatchCompleted(): void
+    {
+    }
+
+    public function onAfterCatchUp(): void
+    {
+        $this->subgraphCachePool->reset();
+    }
+}

Neos.ContentRepositoryRegistry/Classes/SubgraphCachingInMemory/FlushSubgraphCachePoolCatchUpHookFactory.php

@@ -0,0 +1,27 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Neos\ContentRepositoryRegistry\SubgraphCachingInMemory;
+
+use Neos\ContentRepository\Core\ContentRepository;
+use Neos\ContentRepository\Core\Projection\CatchUpHookFactoryInterface;
+use Neos\ContentRepository\Core\Projection\CatchUpHookInterface;
+
+/**
+ * Factory for {@see FlushSubgraphCachePoolCatchUpHook}, auto-registered in Settings.yaml for GraphProjection
+ *
+ * @internal
+ */
+class FlushSubgraphCachePoolCatchUpHookFactory implements CatchUpHookFactoryInterface
+{
+
+    public function __construct(
+        private readonly SubgraphCachePool $subgraphCachePool
+    ) {
+    }
+    public function build(ContentRepository $contentRepository): CatchUpHookInterface
+    {
+        return new FlushSubgraphCachePoolCatchUpHook($this->subgraphCachePool);
+    }
+}

Neos.ContentRepositoryRegistry/Configuration/Settings.yaml

@@ -77,3 +77,7 @@ Neos:
           'Neos.ContentRepository:ContentGraph':
             # NOTE: This introduces a soft-dependency to the neos/contentgraph-doctrinedbaladapter package, but it can be overridden when a different adapter is used
             factoryObjectName: Neos\ContentGraph\DoctrineDbalAdapter\DoctrineDbalContentGraphProjectionFactory
+
+            catchUpHooks:
+              'Neos.ContentRepositoryRegistry:FlushSubgraphCachePool':
+                factoryObjectName: Neos\ContentRepositoryRegistry\SubgraphCachingInMemory\FlushSubgraphCachePoolCatchUpHookFactory