ADO-313: Added message queue to process server capi events

Author: priyambad

app/code/Meta/Conversion/Model/CapiEventHandler.php

@@ -0,0 +1,52 @@
+<?php
+declare(strict_types=1);
+
+namespace Meta\Conversion\Model;
+
+use Magento\Framework\Serialize\Serializer\Json as JsonSerializer;
+use Meta\BusinessExtension\Helper\FBEHelper;
+use Meta\Conversion\Helper\ServerEventFactory;
+use Meta\Conversion\Helper\ServerSideHelper;
+
+class CapiEventHandler
+{
+
+    /**
+     * @param ServerSideHelper $serverSideHelper
+     * @param FBEHelper $fbeHelper
+     * @param ServerEventFactory $serverEventFactory
+     * @param JsonSerializer $jsonSerializer
+     */
+    public function __construct(
+        private readonly ServerSideHelper $serverSideHelper,
+        private readonly FBEHelper $fbeHelper,
+        private readonly ServerEventFactory $serverEventFactory,
+        private readonly JsonSerializer $jsonSerializer
+    ) { }
+
+    public function process(string $message): void
+    {
+        try {
+            $payload = $this->jsonSerializer->unserialize($message);
+            $eventId = $payload['event_id'];
+            $eventType = $payload['event_type'];
+            // remove values from array
+            unset($payload['event_id']);
+            unset($payload['event_type']);
+
+            // 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();
+
+            $event = $this->serverEventFactory->createEvent($eventType, array_filter($payload), $eventId);
+            if (isset($payload['userDataFromOrder'])) {
+                $this->serverSideHelper->sendEvent($event, $payload['userDataFromOrder']);
+            } else {
+                $this->serverSideHelper->sendEvent($event);
+            }
+        } catch (\Exception $e) {
+            $this->fbeHelper->logException($e);
+        }
+    }
+}

app/code/Meta/Conversion/etc/communication.xml

@@ -0,0 +1,4 @@
+<?xml version="1.0"?>
+<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework:Communication/etc/communication.xsd">
+    <topic name="send.conversion.event.to.meta" request="string" />
+</config>

app/code/Meta/Conversion/etc/queue_consumer.xml

@@ -0,0 +1,4 @@
+<?xml version="1.0"?>
+<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/consumer.xsd">
+    <consumer name="send.conversion.event.to.meta.consumer" queue="send_conversion_event_to_meta" connection="db" handler="Meta\Conversion\Model\CapiEventHandler::process" consumerInstance="Magento\Framework\MessageQueue\Consumer"/>
+</config>

app/code/Meta/Conversion/etc/queue_publisher.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0"?>
+<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/publisher.xsd">
+    <publisher topic="send.conversion.event.to.meta">
+        <connection name="db" exchange="send-conversion-event-to-meta-exchange" disabled="false"/>
+    </publisher>
+</config>

app/code/Meta/Conversion/etc/queue_topology.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0"?>
+<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/topology.xsd">
+    <exchange name="send-conversion-event-to-meta-exchange" type="topic" connection="db">
+        <binding id="SendConversionEventToMeta" topic="send.conversion.event.to.meta" destinationType="queue" destination="send_conversion_event_to_meta"/>
+    </exchange>
+</config>