Start webhook implementation

Observer/OrderCreateWebhook.php

@@ -3,129 +3,17 @@
 namespace BobGroup\BobGo\Observer;
 
 use Magento\Framework\Event\Observer;
-use Magento\Framework\Event\ObserverInterface;
-use Magento\Framework\HTTP\Client\Curl;
-use BobGroup\BobGo\Model\Carrier\UData;
-use Psr\Log\LoggerInterface;
-use Magento\Store\Model\StoreManagerInterface;
 
-class OrderCreateWebhook implements ObserverInterface
+class OrderCreateWebhook extends OrderWebhookBase
 {
-    protected Curl $curl;
-    protected LoggerInterface $logger;
-    protected StoreManagerInterface $storeManager;
-
-    public function __construct(LoggerInterface $logger, Curl $curl, StoreManagerInterface $storeManager)
-    {
-        $this->logger = $logger;
-        $this->curl = $curl;
-        $this->storeManager = $storeManager;
-    }
-
     public function execute(Observer $observer)
     {
         $order = $observer->getEvent()->getOrder();
         if (!$order) {
-            //$this->logger->error('OrderCreateWebhook: No order object found in observer');
             return;
         }
 
         // Extract order data and send to the webhook URL
-        $this->sendWebhook($order, 'order_create');
-    }
-
-    private function sendWebhook($order, $eventType)
-    {
-        // Webhook URL
-        $url = $this->getWebhookUrl();
-
-        // Extract order items
-        $itemsData = [];
-        foreach ($order->getAllItems() as $item) {
-            $itemsData[] = $item->getData();
-        }
-
-        // Extract shipping address
-        $shippingAddress = $order->getShippingAddress();
-        $shippingAddressData = $shippingAddress ? $shippingAddress->getData() : [];
-
-        // Extract billing address
-        $billingAddress = $order->getBillingAddress();
-        $billingAddressData = $billingAddress ? $billingAddress->getData() : [];
-
-        // Prepare payload
-        $data = [
-            'event' => $eventType,
-            'order_id' => $order->getId(),
-            'channel_identifier' => $this->getStoreUrl(),
-            'store_id' => $this->getStoreId(),
-            'order_data' => $order->getData(),
-            'items' => $itemsData,
-            'shipping_address' => $shippingAddressData,
-            'billing_address'  => $billingAddressData,
-        ];
-
-        // Send the webhook
-        $this->makeHttpPostRequest($url, $data);
-    }
-
-    private function makeHttpPostRequest($url, $data)
-    {
-        // Generate the signature using a secret key and the payload (example using HMAC SHA256)
-        $secretKey = 'your_secret_key';
-        $payloadJson = json_encode($data);
-        $signature = hash_hmac('sha256', $payloadJson, $secretKey);
-
-        // Set headers and post the data
-        $this->curl->addHeader('Content-Type', 'application/json');
-        $this->curl->addHeader('X-M-Webhook-Signature', $signature); // Add your custom header here
-
-        // Perform the API request
-        $payloadJson = json_encode($data);
-        if ($payloadJson === false) {
-            //$this->logger->error('Payload Webhook failed: Unable to encode JSON.');
-            throw new \RuntimeException('Failed to encode payload to JSON.');
-        }
-
-        // Set headers and post the data
-        $this->curl->addHeader('Content-Type', 'application/json');
-        $this->curl->post($url, $payloadJson);
-        $statusCode = $this->curl->getStatus();
-        $responseBody = $this->curl->getBody();
-
-        // Decode the response
-        $response = json_decode($responseBody, true);
-    }
-
-    private function getWebhookUrl(): string
-    {
-        return UData::WEBHOOK_URL;
-    }
-
-    private function getStoreId(): string
-    {
-        $storeId = $this->storeManager->getStore()->getId();
-        return $storeId;
-    }
-
-    private function getStoreUrl(): string
-    {
-        $url = $this->storeManager->getStore()->getBaseUrl();
-
-        // Remove protocol (http:// or https://)
-        $host = preg_replace('#^https?://#', '', $url);
-
-        // Ensure $host is a string before using it in explode
-        $host = $host ?? '';
-
-        // Remove everything after the host (e.g., paths, query strings)
-        $host = explode('/', $host)[0];
-
-        // If the host starts with 'www.', remove it
-        if (strpos($host, 'www.') === 0) {
-            $host = substr($host, 4);
-        }
-
-        return $host;
+        $this->sendWebhook($order);
     }
 }