ADO-313: moves the check for existing event id for purchase event into controller

Author: priyambad

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

@@ -7,7 +7,6 @@
 use Magento\Customer\Model\Session as CustomerSession;
 use Magento\Framework\Serialize\Serializer\Json as JsonSerializer;
 use Magento\Framework\MessageQueue\PublisherInterface;
-use Meta\Conversion\Model\Tracker\Purchase;
 
 class CapiTracker
 {
@@ -28,11 +27,6 @@ public function __construct(
     public function execute(array $payload, string $eventName, string $eventType, bool $useSessionForEventIds = false): void
     {
         if (isset($payload)) {
-            // Purchase event is triggered twice sometimes, to prevent that check if event id is already stored for current request
-            // if it does prevent the message form being added to the message queue.
-            if ((Purchase::EVENT_TYPE == $eventType) && $this->capiEventIdHandler->getMetaEventId($eventName)) {
-                return;
-            }
             $eventId = $this->generateEventId($eventName, $useSessionForEventIds);
             $payload['event_id'] = $eventId;
             $payload['event_type'] = $eventType;

app/code/Meta/Conversion/Observer/Tracker/Purchase.php

@@ -8,6 +8,7 @@
 use Meta\Conversion\Model\Tracker\Purchase as PurchaseTracker;
 use Magento\Checkout\Model\Session as CheckoutSession;
 use Meta\Conversion\Model\CapiTracker;
+use Meta\Conversion\Model\CapiEventIdHandler;
 
 class Purchase implements ObserverInterface
 {
@@ -17,13 +18,16 @@ class Purchase implements ObserverInterface
     public function __construct(
         private readonly PurchaseTracker $purchaseTracker,
         private readonly CheckoutSession $checkoutSession,
-        private readonly CapiTracker $capiTracker
+        private readonly CapiTracker $capiTracker,
+        private readonly CapiEventIdHandler $capiEventIdHandler
     ) { }
 
     public function execute(Observer $observer): void
     {
-        $lastOrderId = $this->checkoutSession->getLastRealOrder()->getEntityId();
-        $payload = $this->purchaseTracker->getPayload(['lastOrder' => $lastOrderId]);
-        $this->capiTracker->execute($payload, self::EVENT_NAME, $this->purchaseTracker->getEventType());
+        if (!$this->capiEventIdHandler->getMetaEventId(self::EVENT_NAME)) {
+            $lastOrderId = $this->checkoutSession->getLastRealOrder()->getEntityId();
+            $payload = $this->purchaseTracker->getPayload(['lastOrder' => $lastOrderId]);
+            $this->capiTracker->execute($payload, self::EVENT_NAME, $this->purchaseTracker->getEventType());
+        }
     }
 }