fix: add tests for observing purged tags + fix edge cases

api/src/HttpCache/PurgeHttpCacheListener.php

@@ -31,6 +31,7 @@
 use Doctrine\ORM\Event\OnFlushEventArgs;
 use Doctrine\ORM\Event\PreUpdateEventArgs;
 use Doctrine\ORM\Mapping\AssociationMapping;
+use Doctrine\ORM\Mapping\ClassMetadataInfo;
 use Doctrine\ORM\PersistentCollection;
 use FOS\HttpCacheBundle\CacheManager;
 use Symfony\Component\PropertyAccess\PropertyAccessorInterface;
@@ -72,26 +73,37 @@ public function preUpdate(PreUpdateEventArgs $eventArgs): void {
      * Collects tags from inserted, updated and deleted entities, including relations.
      */
     public function onFlush(OnFlushEventArgs $eventArgs): void {
+        /** @var EntityManagerInterface */
         $em = method_exists($eventArgs, 'getObjectManager') ? $eventArgs->getObjectManager() : $eventArgs->getEntityManager();
         $uow = $em->getUnitOfWork();
 
         foreach ($uow->getScheduledEntityInsertions() as $entity) {
-            $this->gatherResourceTags($entity);
+            $this->gatherResourceTags($em, $entity);
             $this->gatherRelationTags($em, $entity);
         }
 
         foreach ($uow->getScheduledEntityUpdates() as $entity) {
             $originalEntity = $this->getOriginalEntity($entity, $em);
             $this->addTagForItem($entity);
-            $this->gatherResourceTags($entity, $originalEntity);
+            $this->gatherResourceTags($em, $entity, $originalEntity);
         }
 
         foreach ($uow->getScheduledEntityDeletions() as $entity) {
             $originalEntity = $this->getOriginalEntity($entity, $em);
             $this->addTagForItem($originalEntity);
-            $this->gatherResourceTags($originalEntity);
+            $this->gatherResourceTags($em, $originalEntity);
             $this->gatherRelationTags($em, $originalEntity);
         }
+
+        // trigger cache purges for changes on many-to-many relations
+        // for some reason, changes to Many-To-Many relations are not included in the preUpdate changeSet
+        foreach ($uow->getScheduledCollectionUpdates() as $collection) {
+            $this->addTagsForManyToManyRelations($collection, $collection->getInsertDiff());
+            $this->addTagsForManyToManyRelations($collection, $collection->getDeleteDiff());
+        }
+        foreach ($uow->getScheduledCollectionDeletions() as $collection) {
+            $this->addTagsForManyToManyRelations($collection, $collection->getDeleteDiff());
+        }
     }
 
     /**
@@ -101,6 +113,23 @@ public function postFlush(): void {
         $this->cacheManager->flush();
     }
 
+    private function addTagsForManyToManyRelations($collection, $entities) {
+        $associationMapping = $collection->getMapping();
+
+        if (ClassMetadataInfo::MANY_TO_MANY !== $associationMapping['type']) {
+            return;
+        }
+
+        foreach ($entities as $entity) {
+            $relatedProperty = $associationMapping['isOwningSide'] ? $associationMapping['inversedBy'] : $associationMapping['mappedBy'];
+            if (!$relatedProperty) {
+                continue;
+            }
+
+            $this->addTagForItem($entity, $relatedProperty);
+        }
+    }
+
     /**
      * Computes the original state of the entity based on the current entity and on the changeset.
      */
@@ -124,23 +153,35 @@ private function getOriginalEntity($entity, $em) {
      * If oldEntity is provided, purge is only done if the IRI of the collection has changed
      * (e.g. for updating period on a ScheduleEntry and the IRI changes from /periods/1/schedule_entries to /periods/2/schedule_entries)
      */
-    private function gatherResourceTags(object $entity, ?object $oldEntity = null): void {
+    private function gatherResourceTags(EntityManagerInterface $em, object $entity, ?object $oldEntity = null): void {
         $entityClass = $this->getObjectClass($entity);
-        if ($this->resourceClassResolver->isResourceClass($entityClass)) {
-            $resourceClass = $this->resourceClassResolver->getResourceClass($entity);
-            $resourceMetadataCollection = $this->resourceMetadataCollectionFactory->create($resourceClass);
-            $resourceIterator = $resourceMetadataCollection->getIterator();
-            while ($resourceIterator->valid()) {
-                /** @var ApiResource $metadata */
-                $metadata = $resourceIterator->current();
-
-                foreach ($metadata->getOperations() ?? [] as $operation) {
-                    if ($operation instanceof GetCollection) {
-                        $this->invalidateCollection($operation, $entity, $oldEntity);
-                    }
+        if (!$this->resourceClassResolver->isResourceClass($entityClass)) {
+            return;
+        }
+
+        $resourceClass = $this->resourceClassResolver->getResourceClass($entity);
+        $this->gatherResourceTagsForClass($resourceClass, $entity, $oldEntity);
+
+        // also purge parent classes (e.g. /content_nodes)
+        $classMetadata = $em->getClassMetadata(ClassUtils::getClass($entity));
+        foreach ($classMetadata->parentClasses as $parentClass) {
+            $this->gatherResourceTagsForClass($parentClass, $entity, $oldEntity);
+        }
+    }
+
+    private function gatherResourceTagsForClass(string $resourceClass, object $entity, ?object $oldEntity = null): void {
+        $resourceMetadataCollection = $this->resourceMetadataCollectionFactory->create($resourceClass);
+        $resourceIterator = $resourceMetadataCollection->getIterator();
+        while ($resourceIterator->valid()) {
+            /** @var ApiResource $metadata */
+            $metadata = $resourceIterator->current();
+
+            foreach ($metadata->getOperations() ?? [] as $operation) {
+                if ($operation instanceof GetCollection) {
+                    $this->invalidateCollection($operation, $entity, $oldEntity);
                 }
-                $resourceIterator->next();
             }
+            $resourceIterator->next();
         }
     }
 

api/tests/Api/Categories/CreateCategoryTest.php

@@ -552,6 +552,26 @@ public function testCreateCategoryFromCopySourceActivityAcrossCamp() {
         $this->assertResponseStatusCodeSame(201);
     }
 
+    public function testCreateCategoryPurgesCacheTags() {
+        $client = static::createClientWithCredentials();
+        $purgedCacheTags = &$this->getPurgedCacheTags();
+
+        $client->request('POST', '/categories', ['json' => $this->getExampleWritePayload()]);
+
+        $this->assertResponseStatusCodeSame(201);
+
+        $camp1 = static::getFixture('camp1');
+        $contentType = static::getFixture('contentTypeSafetyConcept');
+        self::assertEqualsCanonicalizing([
+            '/categories',
+            '/camps/'.$camp1->getId().'/categories',
+            '/content_nodes',
+            '/content_node/column_layouts',
+            $camp1->getId().'#categories',
+            $contentType->getId().'#categories',
+        ], $purgedCacheTags);
+    }
+
     /**
      * @throws RedirectionExceptionInterface
      * @throws DecodingExceptionInterface

api/tests/Api/Categories/DeleteCategoryTest.php

@@ -97,4 +97,27 @@ public function testDeleteCategoryValidatesThatCategoryHasNoActivities() {
             'detail' => 'activities: It\'s not possible to delete a category as long as it has an activity linked to it.',
         ]);
     }
+
+    public function testDeleteCategoryPurgesCacheTags() {
+        $client = static::createClientWithCredentials();
+        $purgedCacheTags = &$this->getPurgedCacheTags();
+
+        $category = static::getFixture('categoryWithNoActivities');
+        $client->request('DELETE', '/categories/'.$category->getId());
+
+        $this->assertResponseStatusCodeSame(204);
+
+        $camp = $category->getCamp();
+        $rootContentNode = $category->getRootContentNode();
+        self::assertEqualsCanonicalizing([
+            $category->getId(),
+            '/categories',
+            '/camps/'.$camp->getId().'/categories',
+            $camp->getId().'#categories',
+            '/content_nodes',
+            '/content_node/column_layouts',
+            $rootContentNode->getId(),
+            $rootContentNode->getId().'#rootDescendants',
+        ], $purgedCacheTags);
+    }
 }

api/tests/Api/Categories/UpdateCategoryTest.php

@@ -511,4 +511,30 @@ public function testPatchCategoryValidatesInvalidNumberingStyle() {
             ],
         ]);
     }
+
+    public function testPatchCategoryPurgesCacheTags() {
+        $client = static::createClientWithCredentials();
+        $purgedCacheTags = &$this->getPurgedCacheTags();
+
+        $category = static::getFixture('category1');
+        $client->request('PATCH', '/categories/'.$category->getId(), ['json' => [
+            'short' => 'LP',
+            'preferredContentTypes' => [
+                $this->getIriFor('contentTypeColumnLayout'),
+                $this->getIriFor('contentTypeNotes'),
+            ],
+        ], 'headers' => ['Content-Type' => 'application/merge-patch+json']]);
+
+        $this->assertResponseStatusCodeSame(200);
+
+        $contentTypeColumnLayout = static::getFixture('contentTypeColumnLayout');
+        $contentTypeNotes = static::getFixture('contentTypeNotes');
+        $contentTypeSafetyConcept = static::getFixture('contentTypeSafetyConcept');
+        self::assertEqualsCanonicalizing([
+            $category->getId(),
+            $contentTypeColumnLayout->getId().'#categories',
+            $contentTypeNotes->getId().'#categories',
+            $contentTypeSafetyConcept->getId().'#categories', // SafetyConcept was previously in the list, so this is purged because it was removed
+        ], $purgedCacheTags);
+    }
 }

api/tests/Api/ContentNodes/CreateContentNodeTestCase.php

@@ -254,6 +254,21 @@ public function testCreateResponseStructureMatchesReadResponseStructure() {
         assertThat($createArray, CompatibleHalResponse::isHalCompatibleWith($getItemResponse->toArray()));
     }
 
+    public function testCreatePurgesCacheTags() {
+        $client = static::createClientWithCredentials();
+        $purgedCacheTags = &$this->getPurgedCacheTags();
+
+        $client->request('POST', $this->endpoint, ['json' => $this->getExampleWritePayload()]);
+
+        $this->assertResponseStatusCodeSame(201);
+        self::assertEqualsCanonicalizing([
+            '/content_nodes',
+            $this->endpoint,
+            $this->defaultParent->getRoot()->getId().'#rootDescendants',
+            $this->defaultParent->getId().'#children',
+        ], $purgedCacheTags);
+    }
+
     public static function getContentNodesWhichCannotHaveChildren(): array {
         return [
             ContentNode\MaterialNode::class => [

api/tests/Api/ECampApiTestCase.php

@@ -19,6 +19,7 @@
 use App\Util\ArrayDeepSort;
 use Doctrine\Bundle\DoctrineBundle\DataCollector\DoctrineDataCollector;
 use Doctrine\ORM\EntityManagerInterface;
+use FOS\HttpCacheBundle\CacheManager;
 use Hautelook\AliceBundle\PhpUnit\FixtureStore;
 use Hautelook\AliceBundle\PhpUnit\RefreshDatabaseTrait;
 use Spatie\Snapshots\MatchesSnapshots;
@@ -360,6 +361,27 @@ protected function assertMatchesResponseSnapshot(ResponseInterface $response): v
         $this->assertMatchesJsonSnapshot($sortedResponseArray);
     }
 
+    /**
+     * mocks CacheManager and keeps track of purged cache tags.
+     */
+    protected function &getPurgedCacheTags(): array {
+        $container = static::getContainer();
+        $cacheManager = $this->createMock(CacheManager::class);
+
+        $purgedCacheTags = [];
+        $cacheManager
+            ->method('invalidateTags')
+            ->willReturnCallback(function ($tags) use (&$purgedCacheTags, $cacheManager) {
+                $purgedCacheTags = array_unique(array_merge($purgedCacheTags, $tags));
+
+                return $cacheManager;
+            })
+        ;
+        $container->set(CacheManager::class, $cacheManager);
+
+        return $purgedCacheTags;
+    }
+
     private static function escapeValues(mixed &$object): void {
         if (!is_array($object)) {
             $object = 'escaped_value';

api/tests/HttpCache/PurgeHttpCacheListenerTest.php

@@ -171,6 +171,8 @@ public function testOnFlush(): void {
         $uowMock->method('getScheduledEntityInsertions')->willReturn([$toInsert1, $toInsert2]);
         $uowMock->method('getScheduledEntityUpdates')->willReturn([]);
         $uowMock->method('getScheduledEntityDeletions')->willReturn([$toDelete1, $toDelete2, $toDeleteNoPurge]);
+        $uowMock->method('getScheduledCollectionUpdates')->willReturn([]);
+        $uowMock->method('getScheduledCollectionDeletions')->willReturn([]);
         $uowMock->method('getEntityChangeSet')->willReturn([]);
 
         $emProphecy = $this->prophesize(EntityManagerInterface::class);
@@ -327,6 +329,8 @@ public function testPropertyIsNotAResourceClass(): void {
         $uowProphecy->getScheduledEntityInsertions()->willReturn([$containNonResource])->shouldBeCalled();
         $uowProphecy->getScheduledEntityDeletions()->willReturn([])->shouldBeCalled();
         $uowProphecy->getScheduledEntityUpdates()->willReturn([])->shouldBeCalled();
+        $uowProphecy->getScheduledCollectionUpdates()->willReturn([])->shouldBeCalled();
+        $uowProphecy->getScheduledCollectionDeletions()->willReturn([])->shouldBeCalled();
 
         $emProphecy = $this->prophesize(EntityManagerInterface::class);
         $emProphecy->getUnitOfWork()->willReturn($uowProphecy->reveal())->shouldBeCalled();
@@ -361,6 +365,8 @@ public function testInsertingShouldPurgeSubresourceCollections(): void {
         $this->uowProphecy->getScheduledEntityInsertions()->willReturn([$toInsert1]);
         $this->uowProphecy->getScheduledEntityDeletions()->willReturn([]);
         $this->uowProphecy->getScheduledEntityUpdates()->willReturn([])->shouldBeCalled();
+        $this->uowProphecy->getScheduledCollectionUpdates()->willReturn([]);
+        $this->uowProphecy->getScheduledCollectionDeletions()->willReturn([]);
 
         // then
         $this->cacheManagerProphecy->invalidateTags(['/dummies'])->willReturn($this->cacheManagerProphecy)->shouldBeCalled();
@@ -384,6 +390,8 @@ public function testDeleteShouldPurgeSubresourceCollections(): void {
         $uowMock->method('getScheduledEntityInsertions')->willReturn([]);
         $uowMock->method('getScheduledEntityUpdates')->willReturn([]);
         $uowMock->method('getScheduledEntityDeletions')->willReturn([$toDelete1]);
+        $uowMock->method('getScheduledCollectionUpdates')->willReturn([]);
+        $uowMock->method('getScheduledCollectionDeletions')->willReturn([]);
         $uowMock->method('getEntityChangeSet')->willReturn([]);
 
         $this->emProphecy->getUnitOfWork()->willReturn($uowMock)->shouldBeCalled();
@@ -414,6 +422,8 @@ public function testUpdateShouldPurgeSubresourceCollections(): void {
         $uowMock->method('getScheduledEntityInsertions')->willReturn([]);
         $uowMock->method('getScheduledEntityUpdates')->willReturn([$toUpdate1]);
         $uowMock->method('getScheduledEntityDeletions')->willReturn([]);
+        $uowMock->method('getScheduledCollectionUpdates')->willReturn([]);
+        $uowMock->method('getScheduledCollectionDeletions')->willReturn([]);
         $uowMock->method('getEntityChangeSet')->willReturn(['relatedDummy' => [$relatedDummyOld, $relatedDummy]]);
 
         $this->emProphecy->getUnitOfWork()->willReturn($uowMock)->shouldBeCalled();