[Ohme] Refresh adherent tags after import (#11535)

Co-authored-by: Rémi <[email protected]>

src/Ohme/PaymentImporter.php

@@ -2,16 +2,20 @@
 
 namespace App\Ohme;
 
+use App\Adherent\Tag\Command\AsyncRefreshAdherentTagCommand;
 use App\Entity\Contribution\Payment;
 use App\Repository\Contribution\PaymentRepository;
 use App\Repository\Ohme\ContactRepository;
+use Ramsey\Uuid\Uuid;
+use Symfony\Component\Messenger\MessageBusInterface;
 
 class PaymentImporter
 {
     public function __construct(
         private readonly ClientInterface $client,
         private readonly ContactRepository $contactRepository,
         private readonly PaymentRepository $paymentRepository,
+        private readonly MessageBusInterface $bus,
     ) {
     }
 
@@ -32,6 +36,7 @@ public function importPayments(int $limit = 100, int $offset = 0, array $options
 
         $total = 0;
 
+        $adherentsUuidToRefresh = [];
         foreach ($payments['data'] as $paymentData) {
             ++$total;
 
@@ -74,6 +79,15 @@ public function importPayments(int $limit = 100, int $offset = 0, array $options
 
                 $this->contactRepository->save($contact);
             }
+
+            $adherentUuid = $contact->adherent->getUuid()->toString();
+            if (!\in_array($adherentUuid, $adherentsUuidToRefresh)) {
+                $adherentsUuidToRefresh[] = $adherentUuid;
+            }
+        }
+
+        foreach ($adherentsUuidToRefresh as $adherentUuid) {
+            $this->bus->dispatch(new AsyncRefreshAdherentTagCommand(Uuid::fromString($adherentUuid)));
         }
 
         return $total;

tests/Command/OhmeImportCommandTest.php

@@ -16,11 +16,11 @@ public function testCommandSuccess(): void
     {
         self::assertCount(0, $this->contactRepository->findAll());
 
-        $output = $this->runCommand('app:ohme:import');
+        $output = $this->runCommand('app:ohme:import', ['--with-payments' => true]);
         $output = $output->getDisplay();
 
         self::assertStringContainsString('[OK] 3 contacts handled successfully.', $output);
-
+        self::assertStringContainsString('[OK] 3 payments handled successfully.', $output);
         self::assertCount(3, $this->contactRepository->findAll());
     }