soyuka · Oct 19, 2026
diff --git a/src/Symfony/Bundle/DependencyInjection/ApiPlatformExtension.php b/src/Symfony/Bundle/DependencyInjection/ApiPlatformExtension.php
@@ -904,6 +904,10 @@ private function registerHttpCacheConfiguration(ContainerBuilder $container, arr
             $loader->load('doctrine_orm_http_cache_purger.php');
         }
 
+        if ($this->isConfigEnabled($container, $config['doctrine_mongodb_odm'])) {
+            $loader->load('doctrine_odm_http_cache_purger.php');
+        }
+
         $loader->load('state/http_cache_purger.php');
 
         foreach ($config['http_cache']['invalidation']['scoped_clients'] as $client) {

diff --git a/src/Symfony/Bundle/Resources/config/doctrine_odm_http_cache_purger.php b/src/Symfony/Bundle/Resources/config/doctrine_odm_http_cache_purger.php
@@ -0,0 +1,33 @@
+<?php
+
+/*
+ * This file is part of the API Platform project.
+ *
+ * (c) Kévin Dunglas <dunglas@gmail.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Symfony\Component\DependencyInjection\Loader\Configurator;
+
+use ApiPlatform\Symfony\Doctrine\Odm\EventListener\PurgeHttpCacheListener;
+
+return static function (ContainerConfigurator $container) {
+    $services = $container->services();
+
+    $services->set('api_platform.doctrine_mongodb.odm.listener.http_cache.purge', PurgeHttpCacheListener::class)
+        ->args([
+            service('api_platform.http_cache.purger'),
+            service('api_platform.iri_converter'),
+            service('api_platform.resource_class_resolver'),
+            service('api_platform.property_accessor'),
+            service('api_platform.object_mapper')->nullOnInvalid(),
+            service('api_platform.object_mapper.metadata_factory')->nullOnInvalid(),
+            service('api_platform.metadata.resource.metadata_collection_factory'),
+        ])
+        ->tag('doctrine_mongodb.odm.event_listener', ['event' => 'onFlush'])
+        ->tag('doctrine_mongodb.odm.event_listener', ['event' => 'postFlush']);
+};
diff --git a/src/Symfony/Doctrine/EventListener/PurgeHttpCacheListener.php b/src/Symfony/Doctrine/EventListener/PurgeHttpCacheListener.php
@@ -14,17 +14,9 @@
 namespace ApiPlatform\Symfony\Doctrine\EventListener;
 
 use ApiPlatform\HttpCache\PurgerInterface;
-use ApiPlatform\Metadata\CollectionOperationInterface;
-use ApiPlatform\Metadata\Exception\InvalidArgumentException;
-use ApiPlatform\Metadata\Exception\OperationNotFoundException;
-use ApiPlatform\Metadata\GetCollection;
-use ApiPlatform\Metadata\HttpOperation;
 use ApiPlatform\Metadata\IriConverterInterface;
-use ApiPlatform\Metadata\Operation;
 use ApiPlatform\Metadata\Resource\Factory\ResourceMetadataCollectionFactoryInterface;
 use ApiPlatform\Metadata\ResourceClassResolverInterface;
-use ApiPlatform\Metadata\UrlGeneratorInterface;
-use ApiPlatform\Metadata\Util\ClassInfoTrait;
 use Doctrine\ORM\EntityManagerInterface;
 use Doctrine\ORM\Event\OnFlushEventArgs;
 use Doctrine\ORM\Event\PreUpdateEventArgs;
@@ -43,10 +35,8 @@
  */
 final class PurgeHttpCacheListener
 {
-    use ClassInfoTrait;
+    use PurgeHttpCacheTagsTrait;
     private readonly PropertyAccessorInterface $propertyAccessor;
-    private array $tags = [];
-
     private array $scheduledInsertions = [];
 
     public function __construct(private readonly PurgerInterface $purger,
@@ -127,51 +117,6 @@ public function postFlush(): void
         $this->tags = [];
     }
 
-    private function gatherResourceAndItemTags(object $entity, bool $purgeItem): void
-    {
-        $resources = $this->getResourcesForEntity($entity);
-
-        foreach ($resources as $resource) {
-            try {
-                foreach ($this->getCollectionOperations($resource) as $operation) {
-                    $iri = $this->iriConverter->getIriFromResource($resource, UrlGeneratorInterface::ABS_PATH, $operation);
-                    $this->tags[$iri] = $iri;
-                }
-
-                if ($purgeItem) {
-                    $this->addTagForItem($entity);
-                }
-            } catch (OperationNotFoundException|InvalidArgumentException) {
-            }
-        }
-    }
-
-    /**
-     * @return iterable<Operation&CollectionOperationInterface>
-     */
-    private function getCollectionOperations(object $resource): iterable
-    {
-        if (!$this->resourceMetadataCollectionFactory) {
-            yield new GetCollection();
-
-            return;
-        }
-
-        foreach ($this->resourceMetadataCollectionFactory->create($this->getObjectClass($resource)) as $apiResource) {
-            foreach ($apiResource->getOperations() ?? [] as $operation) {
-                if (!$operation instanceof CollectionOperationInterface || !$operation instanceof HttpOperation) {
-                    continue;
-                }
-
-                if (!empty($operation->getUriVariables())) {
-                    continue;
-                }
-
-                yield $operation;
-            }
-        }
-    }
-
     private function gatherRelationTags(EntityManagerInterface $em, object $entity): void
     {
         $associationMappings = $em->getClassMetadata($entity::class)->getAssociationMappings();
@@ -229,58 +174,4 @@ private function addTagsFor(mixed $value): void
             $this->addTagForItem($v);
         }
     }
-
-    private function addTagForItem(mixed $value): void
-    {
-        $resources = $this->getResourcesForEntity($value);
-
-        foreach ($resources as $resource) {
-            try {
-                $iri = $this->iriConverter->getIriFromResource($resource);
-                $this->tags[$iri] = $iri;
-            } catch (OperationNotFoundException|InvalidArgumentException) {
-            }
-        }
-    }
-
-    private function getResourcesForEntity(object $entity): array
-    {
-        $resources = [];
-
-        if (!$this->resourceClassResolver->isResourceClass($class = $this->getObjectClass($entity))) {
-            // is the entity mapped to resource(s)?
-            if (!$this->objectMapper) {
-                return [];
-            }
-
-            if ($this->objectMapperMetadata) {
-                $mappings = $this->objectMapperMetadata->create($entity);
-
-                if (!$mappings) {
-                    return [];
-                }
-
-                $resources = array_map(
-                    fn ($mapping) => $this->objectMapper->map($entity, $mapping->target),
-                    $mappings
-                );
-            } else {
-                $mapAttributes = (new \ReflectionClass($class))->getAttributes(Map::class);
-
-                if (!$mapAttributes) {
-                    return [];
-                }
-
-                // loop over all mappings to fetch all resources mapped to this entity
-                $resources = array_map(
-                    fn ($mapAttribute) => $this->objectMapper->map($entity, $mapAttribute->newInstance()->target),
-                    $mapAttributes
-                );
-            }
-        } else {
-            $resources[] = $entity;
-        }
-
-        return $resources;
-    }
 }
diff --git a/src/Symfony/Doctrine/EventListener/PurgeHttpCacheTagsTrait.php b/src/Symfony/Doctrine/EventListener/PurgeHttpCacheTagsTrait.php
@@ -0,0 +1,134 @@
+<?php
+
+/*
+ * This file is part of the API Platform project.
+ *
+ * (c) Kévin Dunglas <dunglas@gmail.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace ApiPlatform\Symfony\Doctrine\EventListener;
+
+use ApiPlatform\Metadata\CollectionOperationInterface;
+use ApiPlatform\Metadata\Exception\InvalidArgumentException;
+use ApiPlatform\Metadata\Exception\OperationNotFoundException;
+use ApiPlatform\Metadata\GetCollection;
+use ApiPlatform\Metadata\HttpOperation;
+use ApiPlatform\Metadata\Operation;
+use ApiPlatform\Metadata\UrlGeneratorInterface;
+use ApiPlatform\Metadata\Util\ClassInfoTrait;
+use Symfony\Component\ObjectMapper\Attribute\Map;
+
+/**
+ * Resolves the API resources of persisted objects and collects the HTTP cache tags to purge.
+ *
+ * @internal
+ */
+trait PurgeHttpCacheTagsTrait
+{
+    use ClassInfoTrait;
+    private array $tags = [];
+
+    private function gatherResourceAndItemTags(object $entity, bool $purgeItem): void
+    {
+        $resources = $this->getResourcesForEntity($entity);
+
+        foreach ($resources as $resource) {
+            try {
+                foreach ($this->getCollectionOperations($resource) as $operation) {
+                    $iri = $this->iriConverter->getIriFromResource($resource, UrlGeneratorInterface::ABS_PATH, $operation);
+                    $this->tags[$iri] = $iri;
+                }
+
+                if ($purgeItem) {
+                    $this->addTagForItem($entity);
+                }
+            } catch (OperationNotFoundException|InvalidArgumentException) {
+            }
+        }
+    }
+
+    /**
+     * @return iterable<Operation&CollectionOperationInterface>
+     */
+    private function getCollectionOperations(object $resource): iterable
+    {
+        if (!$this->resourceMetadataCollectionFactory) {
+            yield new GetCollection();
+
+            return;
+        }
+
+        foreach ($this->resourceMetadataCollectionFactory->create($this->getObjectClass($resource)) as $apiResource) {
+            foreach ($apiResource->getOperations() ?? [] as $operation) {
+                if (!$operation instanceof CollectionOperationInterface || !$operation instanceof HttpOperation) {
+                    continue;
+                }
+
+                if (!empty($operation->getUriVariables())) {
+                    continue;
+                }
+
+                yield $operation;
+            }
+        }
+    }
+
+    private function addTagForItem(mixed $value): void
+    {
+        $resources = $this->getResourcesForEntity($value);
+
+        foreach ($resources as $resource) {
+            try {
+                $iri = $this->iriConverter->getIriFromResource($resource);
+                $this->tags[$iri] = $iri;
+            } catch (OperationNotFoundException|InvalidArgumentException) {
+            }
+        }
+    }
+
+    private function getResourcesForEntity(object $entity): array
+    {
+        $resources = [];
+
+        if (!$this->resourceClassResolver->isResourceClass($class = $this->getObjectClass($entity))) {
+            // is the entity mapped to resource(s)?
+            if (!$this->objectMapper) {
+                return [];
+            }
+
+            if ($this->objectMapperMetadata) {
+                $mappings = $this->objectMapperMetadata->create($entity);
+
+                if (!$mappings) {
+                    return [];
+                }
+
+                $resources = array_map(
+                    fn ($mapping) => $this->objectMapper->map($entity, $mapping->target),
+                    $mappings
+                );
+            } else {
+                $mapAttributes = (new \ReflectionClass($class))->getAttributes(Map::class);
+
+                if (!$mapAttributes) {
+                    return [];
+                }
+
+                // loop over all mappings to fetch all resources mapped to this entity
+                $resources = array_map(
+                    fn ($mapAttribute) => $this->objectMapper->map($entity, $mapAttribute->newInstance()->target),
+                    $mapAttributes
+                );
+            }
+        } else {
+            $resources[] = $entity;
+        }
+
+        return $resources;
+    }
+}