Add sync

Author: tatevikg1

config/packages/messenger.yaml

@@ -29,3 +29,5 @@ framework:
             'PhpList\Core\Domain\Messaging\Message\SubscriptionConfirmationMessage': async_email
             'PhpList\Core\Domain\Messaging\Message\PasswordResetMessage': async_email
             'PhpList\Core\Domain\Messaging\Message\CampaignProcessorMessage': async_email
+            'PhpList\Core\Domain\Messaging\Message\SyncCampaignProcessorMessage': sync
+

config/services/messenger.yml

@@ -24,7 +24,7 @@ services:
             $passwordResetUrl: '%app.password_reset_url%'
 
     PhpList\Core\Domain\Messaging\MessageHandler\SubscriptionConfirmationMessageHandler:
-      autowire: true
-      autoconfigure: true
-      tags: [ 'messenger.message_handler' ]
+        autowire: true
+        autoconfigure: true
+        tags: [ 'messenger.message_handler' ]
 

src/Domain/Messaging/Message/SyncCampaignProcessorMessage.php

@@ -0,0 +1,20 @@
+<?php
+
+declare(strict_types=1);
+
+namespace PhpList\Core\Domain\Messaging\Message;
+
+class SyncCampaignProcessorMessage
+{
+    private int $messageId;
+
+    public function __construct(int $messageId)
+    {
+        $this->messageId = $messageId;
+    }
+
+    public function getMessageId(): int
+    {
+        return $this->messageId;
+    }
+}

src/Domain/Messaging/MessageHandler/CampaignProcessorMessageHandler.php

@@ -20,6 +20,7 @@
 use PhpList\Core\Domain\Subscription\Service\Manager\SubscriberHistoryManager;
 use PhpList\Core\Domain\Subscription\Service\Provider\SubscriberProvider;
 use Psr\Log\LoggerInterface;
+use Symfony\Component\Messenger\Attribute\AsMessageHandler;
 use Symfony\Contracts\Translation\TranslatorInterface;
 use Throwable;
 
@@ -28,6 +29,7 @@
  * @SuppressWarnings(PHPMD.StaticAccess)
  * @SuppressWarnings(PHPMD.ExcessiveParameterList)
  */
+#[AsMessageHandler]
 class CampaignProcessorMessageHandler
 {
     private RateLimitedCampaignMailer $mailer;
@@ -68,7 +70,7 @@ public function __construct(
         $this->messageRepository = $messageRepository;
     }
 
-    public function __invoke(CampaignProcessorMessage $message): void
+    public function __invoke(CampaignProcessorMessage|SyncCampaignProcessorMessage $message): void
     {
         $campaign = $this->messageRepository->findByIdAndStatus($message->getMessageId(), MessageStatus::Submitted);
         if (!$campaign) {

tests/Integration/Domain/Identity/Repository/AdministratorRepositoryTest.php

@@ -177,7 +177,7 @@ public function testRemoveRemovesModel(): void
         $this->assertNotEmpty($allModels);
 
         $model = $allModels[0];
-        $this->repository->remove($model);
+        $this->repository->delete($model);
 
         $remainingModels = $this->repository->findAll();
         $this->assertCount(count($allModels) - 1, $remainingModels);

tests/Integration/Domain/Identity/Repository/AdministratorTokenRepositoryTest.php

@@ -146,7 +146,7 @@ public function testRemoveRemovesModel()
         $numberOfModelsBeforeRemove = count($allModels);
         $firstModel = $allModels[0];
 
-        $this->repository->remove($firstModel);
+        $this->repository->delete($firstModel);
 
         $numberOfModelsAfterRemove = count($this->repository->findAll());
         self::assertSame(1, $numberOfModelsBeforeRemove - $numberOfModelsAfterRemove);

tests/Integration/Domain/Messaging/Repository/SubscriberListRepositoryTest.php

@@ -206,7 +206,7 @@ public function testRemoveRemovesModel()
         $numberOfModelsBeforeRemove = count($allModels);
         $firstModel = $allModels[0];
 
-        $this->subscriberListRepository->remove($firstModel);
+        $this->subscriberListRepository->delete($firstModel);
 
         $numberOfModelsAfterRemove = count($this->subscriberListRepository->findAll());
         self::assertSame(1, $numberOfModelsBeforeRemove - $numberOfModelsAfterRemove);

tests/Integration/Domain/Subscription/Repository/SubscriberRepositoryTest.php

@@ -227,7 +227,7 @@ public function testRemoveAlsoRemovesAssociatedSubscriptions()
         $numberOfAssociatedSubscriptions = count($model->getSubscriptions());
         self::assertGreaterThan(0, $numberOfAssociatedSubscriptions);
 
-        $this->subscriberRepository->remove($model);
+        $this->subscriberRepository->delete($model);
 
         $newNumberOfSubscriptions = count($this->subscriptionRepository->findAll());
         $numberOfRemovedSubscriptions = $initialNumberOfSubscriptions - $newNumberOfSubscriptions;
@@ -246,7 +246,7 @@ public function testRemoveRemovesModel()
         $numberOfModelsBeforeRemove = count($allModels);
         $firstModel = $allModels[0];
 
-        $this->subscriberRepository->remove($firstModel);
+        $this->subscriberRepository->delete($firstModel);
 
         $numberOfModelsAfterRemove = count($this->subscriberRepository->findAll());
         self::assertSame(1, $numberOfModelsBeforeRemove - $numberOfModelsAfterRemove);

tests/Integration/Domain/Subscription/Repository/SubscriptionRepositoryTest.php

@@ -161,7 +161,7 @@ public function testRemoveRemovesModel()
         $numberOfModelsBeforeRemove = count($allModels);
         $firstModel = $allModels[0];
 
-        $this->subscriptionRepository->remove($firstModel);
+        $this->subscriptionRepository->delete($firstModel);
 
         $numberOfModelsAfterRemove = count($this->subscriptionRepository->findAll());
         self::assertSame(1, $numberOfModelsBeforeRemove - $numberOfModelsAfterRemove);