Fixed potential multiple purchase webhook events.

CHANGELOG.md

@@ -1,4 +1,8 @@
 # Changelog
+
+v1.0.18
+- Fixed potential issue with sending multiple purchase webhook events.
+
 v1.0.17
 - Hyva theme compatibility added.
 

Observer/OrderSaveCommitAfter.php

@@ -5,6 +5,7 @@
 use Magento\Framework\Event\Observer;
 use Magento\Framework\Event\ObserverInterface;
 use Magento\Framework\Stdlib\CookieManagerInterface;
+use \Magento\Sales\Api\OrderPaymentRepositoryInterface;
 use Psr\Log\LoggerInterface;
 use Stape\Gtm\Model\ConfigProvider;
 use Stape\Gtm\Model\Webhook\Adapter;
@@ -26,6 +27,11 @@ class OrderSaveCommitAfter implements ObserverInterface
      */
     private $cookieManager;
 
+    /**
+     * @var OrderPaymentRepositoryInterface $orderPaymentRepository
+     */
+    private $orderPaymentRepository;
+
     /**
      * @var LoggerInterface $logger
      */
@@ -46,17 +52,20 @@ class OrderSaveCommitAfter implements ObserverInterface
      * @param ConfigProvider $configProvider
      * @param Adapter $adapter
      * @param CookieManagerInterface $cookieManager
+     * @param OrderPaymentRepositoryInterface $orderPaymentRepository
      * @param LoggerInterface $logger
      */
     public function __construct(
         ConfigProvider $configProvider,
         Adapter $adapter,
         CookieManagerInterface $cookieManager,
+        OrderPaymentRepositoryInterface $orderPaymentRepository,
         LoggerInterface $logger
     ) {
         $this->configProvider = $configProvider;
         $this->adapter = $adapter;
         $this->cookieManager = $cookieManager;
+        $this->orderPaymentRepository = $orderPaymentRepository;
         $this->logger = $logger;
     }
 
@@ -98,8 +107,16 @@ public function execute(Observer $observer)
             return;
         }
 
+        $payment = $order->getPayment();
+
+        if ($payment->getAdditionalInformation('stape_purchase_webhook_processed')) {
+            return;
+        }
+
         try {
             $this->adapter->purchase($order, $this->prepareAdditionalInfo());
+            $payment->setAdditionalInformation('stape_purchase_webhook_processed', true);
+            $this->orderPaymentRepository->save($payment);
         } catch (\Exception $e) {
             $this->logger->notice($e->getMessage());
         }

composer.json

@@ -5,7 +5,7 @@
     "license": [
         "GPL-3.0-only"
     ],
-    "version": "1.0.17",
+    "version": "1.0.18",
     "require": {
         "php": ">=7.4.0"
     },

etc/module.xml

@@ -1,7 +1,7 @@
 <?xml version="1.0"?>
 
 <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="../../../../../lib/internal/Magento/Framework/Module/etc/module.xsd">
-    <module name="Stape_Gtm" schema_version="1.0.17" setup_version="1.0.17">
+    <module name="Stape_Gtm" schema_version="1.0.18" setup_version="1.0.18">
         <sequence>
             <module name="Magento_Backend" />
             <module name="Magento_Catalog" />