src/Service/Panel/Api/Zapier/EventSubscriber/ZapierNotificationSubscriber.php line 70

Open in your IDE?
  1. <?php
  4. namespace Harmonizely\Service\Panel\Api\Zapier\EventSubscriber;
  6. use Harmonizely\Background\Data\ZapierNotificationData;
  7. use Harmonizely\CalendarEvents;
  8. use Harmonizely\Core\BackgroundWork\Contract\IClient;
  9. use Harmonizely\Model\Event;
  10. use Harmonizely\Service\Core\Contract\ICompanySelector;
  11. use Harmonizely\Types\Company\ZapierNotificationType;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Component\EventDispatcher\GenericEvent;
  15. class ZapierNotificationSubscriber implements EventSubscriberInterface
  16. {
  18.     /**
  19.      * @var IClient
  20.      */
  21.     private IClient $backgroundClient;
  23.     /**
  24.      * @var ICompanySelector
  25.      */
  26.     private ICompanySelector $companySelector;
  28.     /**
  29.      * @param IClient $backgroundClient
  30.      * @param ICompanySelector $companySelector
  31.      */
  32.     public function __construct(
  33.         IClient $backgroundClient,
  34.         ICompanySelector $companySelector
  35.     )
  36.     {
  37.         $this->backgroundClient = $backgroundClient;
  38.         $this->companySelector = $companySelector;
  39.     }
  41.     /**
  42.      * @return string[]
  43.      */
  44.     public static function getSubscribedEvents(): array
  45.     {
  46.         return [
  47.             CalendarEvents::EVENT_POST_CREATE => 'create',
  48.             CalendarEvents::EVENT_POST_RESCHEDULE => 'reschedule',
  49.             CalendarEvents::EVENT_POST_CANCEL => 'cancel',
  50.         ];
  51.     }
  53.     /**
  54.      * @param GenericEvent $genericEvent
  55.      * @return void
  56.      */
  57.     public function create(GenericEvent $genericEvent): void
  58.     {
  59.         /** @var Event $event */
  60.         $event = $genericEvent->getSubject();
  61.         $this->backgroundClient->add(new ZapierNotificationData(
  62.             ZapierNotificationType::TYPE_EVENT_CREATE,
  63.             $event->getId(),
  64.             $this->companySelector->getCompany()
  65.         ));
  66.         $this->backgroundClient->runJobs();
  67.     }
  69.     /**
  70.      * @param GenericEvent $genericEvent
  71.      * @return void
  72.      */
  73.     public function reschedule(GenericEvent $genericEvent): void
  74.     {
  75.         /** @var Event $event */
  76.         $event = $genericEvent->getSubject();
  77.         $this->backgroundClient->add(new ZapierNotificationData(
  78.             ZapierNotificationType::TYPE_EVENT_RESCHEDULE,
  79.             $event->getId(),
  80.             $this->companySelector->getCompany()
  81.         ));
  82.         $this->backgroundClient->runJobs();
  83.     }
  85.     /**
  86.      * @param GenericEvent $genericEvent
  87.      * @return void
  88.      */
  89.     public function cancel(GenericEvent $genericEvent): void
  90.     {
  91.         /** @var Event $event */
  92.         $event = $genericEvent->getSubject();
  93.         $this->backgroundClient->add(new ZapierNotificationData(
  94.             ZapierNotificationType::TYPE_EVENT_CANCEL,
  95.             $event->getId(),
  96.             $this->companySelector->getCompany()
  97.         ));
  98.         $this->backgroundClient->runJobs();
  99.     }
  101. }