module-integration/Order/Observer/OrderSync.php

<?php
namespace ActiveCampaign\Order\Observer;

use ActiveCampaign\Core\Helper\Curl;
use ActiveCampaign\Order\Helper\Data as ActiveCampaignOrderHelper;
use ActiveCampaign\Order\Model\OrderData\OrderDataSend;
use Magento\Framework\Event\Observer;
use Magento\Framework\Event\ObserverInterface;
use Magento\Framework\Exception\NoSuchEntityException;
use Magento\Quote\Api\CartRepositoryInterface;
use Magento\Sales\Model\Order as OrderModel;
use Psr\Log\LoggerInterface;

class OrderSync implements ObserverInterface
{
    public const DELETE_METHOD = "DELETE";
    public const URL_ENDPOINT = "ecomOrders/";

    /**
     * @var ActiveCampaignOrderHelper
     */
    private $activeCampaignHelper;

    /**
     * @var OrderDataSend
     */
    protected $orderdataSend;

    /**
     * @var Curl
     */
    protected $curl;

    /**
     * @var CartRepositoryInterface
     */
    protected $quoteRepository;
    /**
     * @var LoggerInterface
     */
    private $logger;
    /**
     * @var OrderModel
     */
    private $orderModel;

    /**
     * OrderSync constructor.
     * @param OrderDataSend $orderdataSend
     * @param Curl $curl
     * @param ActiveCampaignOrderHelper $activeCampaignHelper
     * @param OrderModel $orderModel
     * @param CartRepositoryInterface $quoteRepository
     * @param LoggerInterface $logger
     */
    public function __construct(
        OrderDataSend $orderdataSend,
        Curl $curl,
        ActiveCampaignOrderHelper $activeCampaignHelper,
        OrderModel $orderModel,
        CartRepositoryInterface $quoteRepository,
        LoggerInterface $logger
    ) {
        $this->orderdataSend = $orderdataSend;
        $this->curl = $curl;
        $this->activeCampaignHelper = $activeCampaignHelper;
        $this->orderModel = $orderModel;
        $this->quoteRepository = $quoteRepository;
        $this->logger = $logger;
    }

    /**
     * @param Observer $observer
     * @return void
     */
    public function execute(Observer $observer)
    {
        $isEnabled = $this->activeCampaignHelper->isOrderSyncEnabled();
        $synInRealTime = $this->activeCampaignHelper->isOrderSyncInRealTime();

        $orderIds = $observer->getEvent()->getOrderIds();

        if ($isEnabled && $synInRealTime) {
            foreach ($orderIds as $orderId) {
                $orderData = $this->orderModel->load($orderId);
                $acOrderStatus = $orderData->getAcOrderSyncStatus();
                if ($acOrderStatus == 0) {
                    $this->orderdataSend->orderDataSend($orderData);
                }

                $quote = $this->quoteRepository->get($orderData->getQuoteId());
                $this->curl->orderDataDelete(self::DELETE_METHOD, self::URL_ENDPOINT, $quote->getAcOrderSyncId());
                if ($orderData->getStatus() == 'canceled') {
                    $orderSyncId = $orderData->getAcOrderSyncId();
                    $this->curl->orderDataDelete(self::DELETE_METHOD, self::URL_ENDPOINT, $orderSyncId);
                }
            }
        }
    }
}