Dispatch event when a webhook has been handled

src/Controller/HandleWebhookAction.php

@@ -5,10 +5,12 @@
 namespace Setono\SyliusPeakPlugin\Controller;
 
 use Doctrine\Persistence\ManagerRegistry;
+use Psr\EventDispatcher\EventDispatcherInterface;
 use Psr\Log\LoggerAwareInterface;
 use Setono\Doctrine\ORMTrait;
 use Setono\PeakWMS\Parser\WebhookParser;
 use Setono\PeakWMS\Parser\WebhookParserInterface;
+use Setono\SyliusPeakPlugin\Event\WebhookHandledEvent;
 use Setono\SyliusPeakPlugin\Factory\WebhookFactoryInterface;
 use Setono\SyliusPeakPlugin\Logger\WebhookLogger;
 use Setono\SyliusPeakPlugin\WebhookHandler\WebhookHandlerInterface;
@@ -26,6 +28,7 @@ public function __construct(
         private readonly WebhookHandlerInterface $webhookHandler,
         private readonly WebhookFactoryInterface $webhookFactory,
         ManagerRegistry $managerRegistry,
+        private readonly EventDispatcherInterface $eventDispatcher,
     ) {
         $this->managerRegistry = $managerRegistry;
     }
@@ -47,6 +50,8 @@ public function __invoke(Request $request): JsonResponse
             $data = $this->webhookParser->parse($request->getContent(), $dataClass);
 
             $this->webhookHandler->handle($data);
+
+            $this->eventDispatcher->dispatch(new WebhookHandledEvent($webhook));
         } catch (\InvalidArgumentException $e) {
             throw new BadRequestHttpException($e->getMessage());
         } finally {

src/Event/WebhookHandledEvent.php

@@ -0,0 +1,16 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Setono\SyliusPeakPlugin\Event;
+
+final class WebhookHandledEvent
+{
+    public function __construct(
+        /**
+         * This is one of the Webhook DTO classes from the Setono\PeakWMS\DataTransferObject\Webhook namespace
+         */
+        public readonly object $webhook,
+    ) {
+    }
+}

src/Resources/config/services/controller.xml

@@ -19,6 +19,7 @@
             <argument type="service" id="Setono\SyliusPeakPlugin\WebhookHandler\WebhookHandlerInterface"/>
             <argument type="service" id="setono_sylius_peak.factory.webhook"/>
             <argument type="service" id="doctrine"/>
+            <argument type="service" id="event_dispatcher"/>
         </service>
     </services>
 </container>