From bd3c60c28cd800caeb87f2ce4826ed91cd9887a9 Mon Sep 17 00:00:00 2001
From: Felix Gradinaru <felix@gradinaru.me>
Date: Wed, 9 Jul 2025 15:42:42 +0200
Subject: [PATCH] FEATURE: Flush cache upon indexing

---
 .../FlushContentCacheAfterIndexingAspect.php  | 35 +++++++++++++++++++
 1 file changed, 35 insertions(+)
 create mode 100644 Classes/Aop/FlushContentCacheAfterIndexingAspect.php

diff --git a/Classes/Aop/FlushContentCacheAfterIndexingAspect.php b/Classes/Aop/FlushContentCacheAfterIndexingAspect.php
new file mode 100644
index 0000000..2a84ccd
--- /dev/null
+++ b/Classes/Aop/FlushContentCacheAfterIndexingAspect.php
@@ -0,0 +1,35 @@
+<?php
+
+namespace Flowpack\ElasticSearch\ContentRepositoryQueueIndexer\Aop;
+
+use Neos\ContentRepository\Domain\Model\Node;
+use Neos\Flow\Annotations as Flow;
+use Neos\Flow\Aop\JoinPointInterface;
+use Neos\Neos\Fusion\Cache\ContentCacheFlusher;
+
+/**
+ * @Flow\Aspect
+ */
+class FlushContentCacheAfterIndexingAspect
+{
+    /**
+     * @Flow\Inject
+     * @var ContentCacheFlusher
+     */
+    protected $contentCacheFlusher;
+
+    /**
+     * @param  JoinPointInterface  $joinPoint
+     * @return void
+     *
+     * @Flow\AfterReturning("method(Flowpack\ElasticSearch\ContentRepositoryAdaptor\Driver\Version6\IndexerDriver->document())")
+     */
+    public function afterDocumentIndexing(JoinPointInterface $joinPoint): void
+    {
+        $node = $joinPoint->getMethodArgument('node');
+        if (!$node instanceof Node) {
+            return;
+        }
+        $this->contentCacheFlusher->registerNodeChange($node);
+    }
+}