src/Webhooks/EventSubscriber/SendWebhookPayloadSubscriber.php line 61

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Harmonizely\Webhooks\EventSubscriber;
  7. use FOS\RestBundle\Context\Context;
  8. use FOS\RestBundle\Serializer\JMSSerializerAdapter;
  9. use Harmonizely\CalendarEvents;
  10. use Harmonizely\Model\EventInterface;
  11. use Harmonizely\Webhooks\Client\WebhookClient;
  12. use Harmonizely\Webhooks\Client\WebhookPayload;
  13. use Harmonizely\Webhooks\Query\FindWebhookForEventQuery;
  14. use Harmonizely\Webhooks\Webhooks;
  15. use Psr\Log\LoggerInterface;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\EventDispatcher\GenericEvent;
  18. use Webmozart\Assert\Assert;
  20. final class SendWebhookPayloadSubscriber implements EventSubscriberInterface
  21. {
  22.     private JMSSerializerAdapter $serializer;
  24.     private LoggerInterface $logger;
  26.     private FindWebhookForEventQuery $findWebhookForEventQuery;
  28.     private WebhookClient $webhookClient;
  30.     public function __construct(
  31.         JMSSerializerAdapter $serializer,
  32.         FindWebhookForEventQuery $findWebhookForEventQuery,
  33.         LoggerInterface $logger,
  34.         WebhookClient $webhookClient
  35.     ) {
  36.         $this->serializer = $serializer;
  37.         $this->findWebhookForEventQuery = $findWebhookForEventQuery;
  38.         $this->logger = $logger;
  39.         $this->webhookClient = $webhookClient;
  40.     }
  42.     public static function getSubscribedEvents(): array
  43.     {
  44.         return [
  45.             CalendarEvents::EVENT_POST_CREATE => 'sendScheduled',
  46.             CalendarEvents::EVENT_POST_CANCEL => 'sendCancelled',
  47.             CalendarEvents::EVENT_POST_RESCHEDULE => 'sendRescheduled',
  48.         ];
  49.     }
  51.     public function sendScheduled(GenericEvent $event): void
  52.     {
  53.         /** @var EventInterface $event */
  54.         $event = $event->getSubject();
  56.         Assert::isInstanceOf($event, EventInterface::class);
  58.         $this->sendPayload($event, Webhooks::MEETING_SCHEDULED);
  59.     }
  61.     public function sendRescheduled(GenericEvent $event): void
  62.     {
  63.         /** @var EventInterface $event */
  64.         $event = $event->getSubject();
  66.         Assert::isInstanceOf($event, EventInterface::class);
  68.         $this->sendPayload($event, Webhooks::MEETING_RESCHEDULED);
  69.     }
  71.     public function sendCancelled(GenericEvent $event): void
  72.     {
  73.         /** @var EventInterface $event */
  74.         $event = $event->getSubject();
  76.         Assert::isInstanceOf($event, EventInterface::class);
  78.         $this->sendPayload($event, Webhooks::MEETING_CANCELLED);
  79.     }
  81.     private function sendPayload(EventInterface $event, string $webhookEventName): void
  82.     {
  83.         $user = $event->getUser();
  85.         $webhook = ($this->findWebhookForEventQuery)((int) $user->getId(), $webhookEventName);
  87.         if (null === $webhook) {
  88.             return;
  89.         }
  91.         $webhookPayload = new WebhookPayload($event, $webhookEventName, $webhook->getUuid());
  93.         $context = new Context();
  94.         $context->setGroups(['integration']);
  95.         $context->setSerializeNull(true);
  97.         $payload = $this->serializer->serialize($webhookPayload, 'json', $context);
  99.         try {
  100.             $this->webhookClient->post($webhook->getUrl(), $payload, $webhook->getSecret());
  101.         } catch (\Throwable $e) {
  102.             $this->logger->error($e->getMessage());
  103.         }
  104.     }
  105. }