Change the stock adjustment webhook handler from async to sync to mak…

…e it easier to show errors in Peak WMS interface when delivering webhooks

src/Controller/HandleWebhookAction.php

@@ -39,10 +39,9 @@ public function __invoke(Request $request): JsonResponse
 
         try {
             $webhook = $this->webhookFactory->createFromRequest($request);
-            $logger = new WebhookLogger($webhook);
 
             if ($this->webhookHandler instanceof LoggerAwareInterface) {
-                $this->webhookHandler->setLogger($logger);
+                $this->webhookHandler->setLogger(new WebhookLogger($webhook));
             }
 
             $dataClass = WebhookParser::convertNameToDataClass($request->query->getInt('name'));

src/Resources/config/services/webhook_handler.xml

@@ -16,7 +16,7 @@
 
         <service id="Setono\SyliusPeakPlugin\WebhookHandler\StockAdjustmentWebhookHandler">
             <argument type="service" id="Setono\SyliusPeakPlugin\Provider\ProductVariantProviderInterface"/>
-            <argument type="service" id="setono_sylius_peak.command_bus"/>
+            <argument type="service" id="Setono\SyliusPeakPlugin\Updater\InventoryUpdaterInterface"/>
 
             <tag name="setono_sylius_peak.webhook_handler"/>
         </service>

src/WebhookHandler/StockAdjustmentWebhookHandler.php

@@ -9,17 +9,16 @@
 use Psr\Log\NullLogger;
 use Setono\PeakWMS\DataTransferObject\Webhook\WebhookDataStockAdjust;
 use Setono\SyliusPeakPlugin\Exception\UnsupportedWebhookException;
-use Setono\SyliusPeakPlugin\Message\Command\UpdateInventory;
 use Setono\SyliusPeakPlugin\Provider\ProductVariantProviderInterface;
-use Symfony\Component\Messenger\MessageBusInterface;
+use Setono\SyliusPeakPlugin\Updater\InventoryUpdaterInterface;
 
 final class StockAdjustmentWebhookHandler implements WebhookHandlerInterface, LoggerAwareInterface
 {
     private LoggerInterface $logger;
 
     public function __construct(
         private readonly ProductVariantProviderInterface $productVariantProvider,
-        private readonly MessageBusInterface $commandBus,
+        private readonly InventoryUpdaterInterface $inventoryUpdater,
     ) {
         $this->logger = new NullLogger();
     }
@@ -35,9 +34,9 @@ public function handle(object $data): void
             throw new \InvalidArgumentException(sprintf('Product variant with id/code "%s" not found', (string) $data->variantId));
         }
 
-        $this->logger->debug(sprintf('Dispatching a message onto the message to update the inventory for product variant %s', (string) $productVariant->getCode()));
+        $this->inventoryUpdater->update($productVariant);
 
-        $this->commandBus->dispatch(UpdateInventory::for($productVariant));
+        $this->logger->debug(sprintf('Updated inventory for product variant %s', (string) $productVariant->getCode()));
     }
 
     /**