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 Psr\Log\LoggerInterface;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class WebhookSubscriber implements EventSubscriberInterface
  13. {
  14.     /**
  15.      * @var LoggerInterface
  16.      */
  17.     private $logger;
  19.     /**
  20.      * @param LoggerInterface $webhookLogger
  21.      */
  22.     public function __construct(LoggerInterface $webhookLogger)
  23.     {
  24.         $this->logger = $webhookLogger;
  25.     }
  27.     public static function getSubscribedEvents()
  28.     {
  29.         return [
  30.             WebhookTriggeredEvent::class => 'onTriggered'
  31.         ];
  32.     }
  34.     public function onTriggered(WebhookTriggeredEvent $event) : void
  35.     {
  36.         $webhookName = $event->getWebhookName();
  37.         $actionName = $event->getAction();
  38.         $data = $event->getData();
  40.         if (isset($data['error']) && $data['error']) {
  41.             $this->logger->error(\sprintf('[webhook.triggerred] webhook \'%s\' triggered on action \'%s\' with data \'%s\'',
  42.                 $webhookName,
  43.                 $actionName,
  44.                 \is_scalar($data) ? $data : \json_encode($data)
  45.             ));
  46.         } else {
  47.             $this->logger->info(\sprintf('[webhook.triggerred] webhook \'%s\' triggered on action \'%s\' with data \'%s\'',
  48.                 $webhookName,
  49.                 $actionName,
  50.                 \is_scalar($data) ? $data : \json_encode($data)
  51.             ));
  52.         }
  53.     }
  55. }