Dispatch gateway webhook event

Author: root

src/Application/Services/PagarmeWebhookService.php

@@ -3,6 +3,7 @@
 namespace Kaninstein\MultiAcquirerCheckout\Application\Services;
 
 use Illuminate\Contracts\Events\Dispatcher;
+use Kaninstein\MultiAcquirerCheckout\Domain\Webhooks\Events\GatewayWebhookReceived;
 use Kaninstein\MultiAcquirerCheckout\Infrastructure\Repositories\Contracts\PaymentRepositoryInterface;
 
 final readonly class PagarmeWebhookService
@@ -31,6 +32,17 @@ public function handle(array $payload): array
             return ['status' => 'ignored'];
         }
 
+        $status = $this->normalizeStatusForEvent($eventType);
+        if ($status !== null) {
+            $this->events->dispatch(new GatewayWebhookReceived(
+                gatewayName: 'pagarme',
+                gatewayTransactionId: $gatewayTransactionId,
+                status: $status,
+                eventType: $eventType,
+                payload: $payload,
+            ));
+        }
+
         $payment = $this->payments->findByGatewayTransactionId($gatewayTransactionId);
         if ($payment === null) {
             return ['status' => 'ignored'];
@@ -110,5 +122,16 @@ private function extractGatewayTransactionId(string $eventType, array $data): ?s
 
         return null;
     }
-}
 
+    private function normalizeStatusForEvent(string $eventType): ?string
+    {
+        return match ($eventType) {
+            'charge.paid', 'charge.payment_succeeded', 'order.paid' => 'paid',
+            'charge.pending', 'charge.waiting_payment', 'order.pending' => 'pending',
+            'charge.failed', 'charge.payment_failed' => 'failed',
+            'charge.refunded' => 'refunded',
+            'charge.canceled', 'order.canceled' => 'canceled',
+            default => null,
+        };
+    }
+}

src/Domain/Webhooks/Events/GatewayWebhookReceived.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace Kaninstein\MultiAcquirerCheckout\Domain\Webhooks\Events;
+
+final readonly class GatewayWebhookReceived
+{
+    /**
+     * @param array<string,mixed> $payload
+     */
+    public function __construct(
+        public string $gatewayName,
+        public string $gatewayTransactionId,
+        public string $status,
+        public string $eventType,
+        public array $payload,
+    ) {}
+}
+