External/domain-watchdog
1
0
Fork 0
mirror of https://github.com/maelgangloff/domain-watchdog.git synced 2025-12-21 19:55:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: Watchlists are processed randomly

Browse Source
This commit is contained in:
Maël Gangloff 2024-08-03 19:39:41 +02:00
parent 1f10ea5429
commit 6bb0d16f1d
No known key found for this signature in database
GPG Key ID: 11FDC81C24A7F629
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/MessageHandler/ProcessWatchListsTriggerHandler.php
View File

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