Fix composer json

Author: tatevikg1

composer.json

@@ -29,19 +29,26 @@
             "role": "Maintainer"
         }
     ],
+    "repositories": [
+      {
+        "type": "vcs",
+        "url": "https://github.com/TatevikGr/rss-bundle.git"
+      }
+    ],
     "support": {
         "issues": "https://github.com/phpList/rest-api/issues",
         "forum": "https://discuss.phplist.org/",
         "source": "https://github.com/phpList/rest-api"
     },
     "require": {
         "php": "^8.1",
-        "phplist/core": "dev-dev",
+        "phplist/core": "dev-em-flush",
         "friendsofsymfony/rest-bundle": "*",
         "symfony/test-pack": "^1.0",
         "symfony/process": "^6.4",
         "zircote/swagger-php": "^4.11",
-        "ext-dom": "*"
+        "ext-dom": "*",
+        "tatevikgr/rss-feed": "dev-main as 0.1.0"
     },
     "require-dev": {
         "phpunit/phpunit": "^10.0",
@@ -123,5 +130,10 @@
                 }
             }
         }
+    },
+    "config": {
+        "allow-plugins": {
+            "php-http/discovery": true
+        }
     }
 }

src/Messaging/Controller/CampaignController.php

@@ -6,7 +6,6 @@
 
 use OpenApi\Attributes as OA;
 use PhpList\Core\Domain\Messaging\Model\Message;
-use PhpList\Core\Domain\Messaging\Service\Processor\CampaignProcessor;
 use PhpList\Core\Security\Authentication;
 use PhpList\RestBundle\Common\Controller\BaseController;
 use PhpList\RestBundle\Common\Validator\RequestValidator;
@@ -17,7 +16,9 @@
 use Symfony\Component\HttpFoundation\JsonResponse;
 use Symfony\Component\HttpFoundation\Request;
 use Symfony\Component\HttpFoundation\Response;
+use Symfony\Component\Messenger\MessageBusInterface;
 use Symfony\Component\Routing\Attribute\Route;
+use Symfony\Component\Messenger\Stamp\TransportNamesStamp;
 
 /**
  * This controller provides REST API to manage campaigns.
@@ -28,17 +29,17 @@
 class CampaignController extends BaseController
 {
     private CampaignService $campaignService;
-    private CampaignProcessor $campaignProcessor;
+    private MessageBusInterface $messageBus;
 
     public function __construct(
         Authentication $authentication,
         RequestValidator $validator,
         CampaignService $campaignService,
-        CampaignProcessor $campaignProcessor,
+        MessageBusInterface $messageBus,
     ) {
         parent::__construct($authentication, $validator);
         $this->campaignService = $campaignService;
-        $this->campaignProcessor = $campaignProcessor;
+        $this->messageBus = $messageBus;
     }
 
     #[Route('', name: 'get_list', methods: ['GET'])]
@@ -388,8 +389,10 @@ public function sendMessage(
             throw $this->createNotFoundException('Campaign not found.');
         }
 
-        $this->campaignProcessor->process($message);
-
+        $this->messageBus->dispatch(
+            new CampaignProcessorMessage($message->getId()),
+            [new TransportNamesStamp(['sync'])]
+        );
         return $this->json($this->campaignService->getMessage($message), Response::HTTP_OK);
     }
 }