ADO-313: changes to add event to message queue instead of direct calling from controller

Author: priyambad

app/code/Meta/Conversion/Controller/Pixel/Tracker.php

@@ -6,11 +6,11 @@
 
 use Magento\Framework\App\Action\HttpPostActionInterface;
 use Magento\Framework\App\RequestInterface;
-use Meta\Conversion\Helper\ServerSideHelper;
-use Meta\Conversion\Helper\ServerEventFactory;
 use Meta\BusinessExtension\Helper\FBEHelper;
 use Magento\Framework\Controller\Result\JsonFactory;
 use Magento\Framework\Controller\Result\Json;
+use Magento\Framework\MessageQueue\PublisherInterface;
+use Magento\Framework\Serialize\Serializer\Json as JsonSerializer;
 
 class Tracker implements HttpPostActionInterface
 {
@@ -19,11 +19,6 @@ class Tracker implements HttpPostActionInterface
      */
     private $request;
 
-    /**
-     * @var ServerSideHelper
-     */
-    private $serverSideHelper;
-
     /**
      * @var FBEHelper
      */
@@ -40,33 +35,36 @@ class Tracker implements HttpPostActionInterface
     private $jsonFactory;
 
     /**
-     * @var ServerEventFactory
+     * @var PublisherInterface
      */
-    private $serverEventFactory;
+    private $publisher;
+
+    /**
+     * @var JsonSerializer
+     */
+    private $jsonSerializer;
 
     /**
-     * Constructor
-     *
      * @param RequestInterface $request
-     * @param ServerSideHelper $serverSideHelper
      * @param FBEHelper $fbeHelper
      * @param JsonFactory $jsonFactory
-     * @param ServerEventFactory $serverEventFactory
+     * @param PublisherInterface $publisher
+     * @param JsonSerializer $jsonSerializer
      * @param array $pixelEvents
      */
     public function __construct(
         RequestInterface $request,
-        ServerSideHelper $serverSideHelper,
         FBEHelper $fbeHelper,
         JsonFactory $jsonFactory,
-        ServerEventFactory $serverEventFactory,
+        PublisherInterface $publisher,
+        JsonSerializer $jsonSerializer,
         array $pixelEvents = []
     ) {
         $this->request = $request;
-        $this->serverSideHelper = $serverSideHelper;
         $this->fbeHelper = $fbeHelper;
         $this->jsonFactory = $jsonFactory;
-        $this->serverEventFactory = $serverEventFactory;
+        $this->publisher = $publisher;
+        $this->jsonSerializer = $jsonSerializer;
         $this->pixelEvents = $pixelEvents;
     }
 
@@ -81,22 +79,13 @@ public function execute(): Json
         try {
             $params = $this->request->getParams();
             $eventName = $params['eventName'];
-            $eventId = $params['eventId'];
 
             if ($eventName) {
                 $payload = $this->pixelEvents[$eventName]->getPayload($params);
+                $payload['event_id'] = $params['eventId'];
+                $payload['event_type'] = $this->pixelEvents[$eventName]->getEventType();
                 if (isset($payload)) {
-                    // Add source and pluginVersion in the payload as custom properties
-                    $payload['custom_properties'] = [];
-                    $payload['custom_properties']['source'] = $this->fbeHelper->getSource();
-                    $payload['custom_properties']['pluginVersion'] = $this->fbeHelper->getPluginVersion();
-                    $eventType = $this->pixelEvents[$eventName]->getEventType();
-                    $event = $this->serverEventFactory->createEvent($eventType, array_filter($payload), $eventId);
-                    if (isset($payload['userDataFromOrder'])) {
-                        $this->serverSideHelper->sendEvent($event, $payload['userDataFromOrder']);
-                    } else {
-                        $this->serverSideHelper->sendEvent($event);
-                    }
+                    $this->publisher->publish('send.conversion.event.to.meta', $this->jsonSerializer->serialize($payload));
                     $response['success'] = true;
                 }
             }