src/Subscriber/WebhookSubscriber.php line 34

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Subscriber;
  8. use App\Event\Webhook\WebhookTriggeredEvent;
  9. use App\Service\Request\ContextInterface;
  10. use Psr\Log\LoggerInterface;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. readonly class WebhookSubscriber implements EventSubscriberInterface
  14. {
  15.     public function __construct(
  16.         private ContextInterface $context,
  17.         private LoggerInterface $logger
  18.     ) {}
  20.     public static function getSubscribedEvents(): array
  21.     {
  22.         return [
  23.             WebhookTriggeredEvent::class => 'onTriggered'
  24.         ];
  25.     }
  27.     public function onTriggered(WebhookTriggeredEvent $event) : void
  28.     {
  29.         $webhookName = $event->getWebhookName();
  30.         $actionName = $event->getAction();
  31.         $data = $event->getData();
  33.         if (isset($data['error']) && $data['error']) {
  34.             $this->logger->error(\sprintf('[webhook.triggerred] webhook \'%s\' triggered on action \'%s\' with data \'%s\'',
  35.                 $webhookName,
  36.                 $actionName,
  37.                 \is_scalar($data) ? $data : \json_encode($data)
  38.             ),
  39.                 [
  40.                     'request-id' => $this->context->getRequestId()?->toString(),
  41.                     'correlation-id' => $this->context->getCorrelationId()?->toString()
  42.                 ]
  43.             );
  44.         } else {
  45.             $this->logger->info(\sprintf('[webhook.triggerred] webhook \'%s\' triggered on action \'%s\' with data \'%s\'',
  46.                 $webhookName,
  47.                 $actionName,
  48.                 \is_scalar($data) ? $data : \json_encode($data)
  49.             ),
  50.                 [
  51.                     'request-id' => $this->context->getRequestId()?->toString(),
  52.                     'correlation-id' => $this->context->getCorrelationId()?->toString()
  53.                 ]
  54.             );
  55.         }
  56.     }
  58. }