3666: Add cleanup for detection results to only keep X results for each server/type combo

Author: turegjorup

config/services.yaml

@@ -27,14 +27,13 @@ services:
         App\Handler\DetectionResultHandlerInterface:
             tags: [ app.handler.detection_result_handler ]
 
-    App\MessageHandler\ProcessDetectionResultHandler:
-        arguments:
-            $resultHandlers: !tagged_iterator app.handler.detection_result_handler
-
     App\EventListener\RemovedRelationsListener:
         tags:
             -
                 name: 'doctrine.event_listener'
                 event: 'postFlush'
 
-
+    App\MessageHandler\ProcessDetectionResultHandler:
+        arguments:
+            $resultHandlers: !tagged_iterator app.handler.detection_result_handler
+            $keepResults: '%env(int:APP_KEEP_RESULTS)%'

src/MessageHandler/ProcessDetectionResultHandler.php

@@ -17,6 +17,7 @@ public function __construct(
         private EntityManagerInterface $entityManager,
         private DetectionResultRepository $detectionResultRepository,
         private iterable $resultHandlers,
+        private int $keepResults,
     ) {
     }
 
@@ -33,6 +34,9 @@ public function __invoke(ProcessDetectionResult $message): void
             }
 
             $this->entityManager->flush();
+
+            $this->detectionResultRepository->cleanup($detectionResult, $this->keepResults, true);
+
             $this->entityManager->clear();
             gc_collect_cycles();
         }

src/Repository/DetectionResultRepository.php

@@ -39,4 +39,30 @@ public function remove(\DateTime $date): mixed
             ->getQuery()
             ->getResult();
     }
+
+    public function cleanup(DetectionResult $detectionResult, int $keep = 5, bool $flush = false): void
+    {
+        if ($keep < 1) {
+            return;
+        }
+
+        $em = $this->getEntityManager();
+
+        $results = $this->findBy(
+            [
+                'server' => $detectionResult->getServer(),
+                'type' => $detectionResult->getType(),
+                'rootDir' => $detectionResult->getRootDir(),
+            ],
+            ['lastContact' => 'DESC'], null, $keep
+        );
+
+        foreach ($results as $result) {
+            $em->remove($result);
+        }
+
+        if ($flush) {
+            $em->flush();
+        }
+    }
 }