From 6bb0d16f1d6bda768c679b72a58df6173f106ac1 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Ma=C3=ABl=20Gangloff?= <contact@maelgangloff.fr>
Date: Sat, 3 Aug 2024 19:39:41 +0200
Subject: [PATCH] fix: Watchlists are processed randomly

---
 src/MessageHandler/ProcessWatchListsTriggerHandler.php | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/MessageHandler/ProcessWatchListsTriggerHandler.php b/src/MessageHandler/ProcessWatchListsTriggerHandler.php
index db5847d..ee2085c 100644
--- a/src/MessageHandler/ProcessWatchListsTriggerHandler.php
+++ b/src/MessageHandler/ProcessWatchListsTriggerHandler.php
@@ -6,6 +6,7 @@ use App\Entity\WatchList;
 use App\Message\ProcessWatchListsTrigger;
 use App\Message\ProcessWatchListTrigger;
 use App\Repository\WatchListRepository;
+use Random\Randomizer;
 use Symfony\Component\Messenger\Attribute\AsMessageHandler;
 use Symfony\Component\Messenger\Exception\ExceptionInterface;
 use Symfony\Component\Messenger\MessageBusInterface;
@@ -24,8 +25,11 @@ final readonly class ProcessWatchListsTriggerHandler
      */
     public function __invoke(ProcessWatchListsTrigger $message): void
     {
+        $randomizer = new Randomizer();
+        $watchLists = $randomizer->shuffleArray($this->watchListRepository->findAll());
+
         /** @var WatchList $watchList */
-        foreach ($this->watchListRepository->findAll() as $watchList) {
+        foreach ($watchLists as $watchList) {
             $this->bus->dispatch(new ProcessWatchListTrigger($watchList->getToken()));
         }
     }