src/Products/NotificationsBundle/Subscriber/WebhookSubscriber.php line 55

Open in your IDE?
  1. <?php
  3. namespace Products\NotificationsBundle\Subscriber;
  5. use Cms\CoreBundle\Util\Doctrine\EntityManager;
  6. use Platform\QueueBundle\Event\AsyncEvent;
  7. use Products\NotificationsBundle\Service\ContactMonitor;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. final class WebhookSubscriber implements EventSubscriberInterface
  11. {
  12.     /**
  13.      * @var EntityManager
  14.      */
  15.     protected EntityManager $em;
  17.     /**
  18.      * @var ContactMonitor
  19.      */
  20.     protected ContactMonitor $monitor;
  22.     /**
  23.      * @param EntityManager $em
  24.      * @param ContactMonitor $monitor
  25.      */
  26.     public function __construct(EntityManager $em, ContactMonitor $monitor)
  27.     {
  28.         $this->em = $em;
  29.         $this->monitor = $monitor;
  30.     }
  32.     /**
  33.      * {@inheritDoc}
  34.      */
  35.     public static function getSubscribedEvents(): array
  36.     {
  37.         return [
  38.             ContactMonitor::EVENTS__WEBHOOKS__EMAIL => ['onWebhookEmail', 0],
  39.             ContactMonitor::EVENTS__WEBHOOKS__SMS => ['onWebhookSms', 0],
  40.             ContactMonitor::EVENTS__WEBHOOKS__VOICE => ['onWebhookVoice', 0],
  41.         ];
  42.     }
  44.     /**
  45.      * @param AsyncEvent $event
  46.      */
  47.     public function onWebhookEmail(AsyncEvent $event)
  48.     {
  49.         $this->monitor->handleEmail($event->getBody()->all());
  50.     }
  52.     /**
  53.      * @param AsyncEvent $event
  54.      */
  55.     public function onWebhookSms(AsyncEvent $event)
  56.     {
  57.         $this->monitor->handleSms($event->getBody()->all());
  58.     }
  60.     /**
  61.      * @param AsyncEvent $event
  62.      */
  63.     public function onWebhookVoice(AsyncEvent $event)
  64.     {
  65.         $this->monitor->handleVoice($event->getBody()->all());
  66.     }
  67. }