src/Service/Panel/Api/PushNotification/EventSubscriber/PushNotificationSubscriber.php line 61

Open in your IDE?
  1. <?php
  4. namespace Harmonizely\Service\Panel\Api\PushNotification\EventSubscriber;
  6. use Harmonizely\Background\Data\PushNotificationData;
  7. use Harmonizely\CalendarEvents;
  8. use Harmonizely\Core\BackgroundWork\Contract\IClient;
  9. use Harmonizely\Model\Event;
  10. use Harmonizely\Model\Member;
  11. use Harmonizely\Organization\OrganizationEvents;
  12. use Harmonizely\Service\Core\Contract\ICompanySelector;
  13. use Harmonizely\Types\Company\UserDeviceNotificationType;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Component\EventDispatcher\GenericEvent;
  17. class PushNotificationSubscriber implements EventSubscriberInterface
  18. {
  20.     /**
  21.      * @var IClient
  22.      */
  23.     private IClient $backgroundClient;
  25.     /**
  26.      * @var ICompanySelector
  27.      */
  28.     private ICompanySelector $companySelector;
  30.     /**
  31.      * @param IClient $backgroundClient
  32.      * @param ICompanySelector $companySelector
  33.      */
  34.     public function __construct(
  35.         IClient $backgroundClient,
  36.         ICompanySelector $companySelector
  37.     )
  38.     {
  39.         $this->backgroundClient = $backgroundClient;
  40.         $this->companySelector = $companySelector;
  41.     }
  43.     /**
  44.      * @return string[]
  45.      */
  46.     public static function getSubscribedEvents(): array
  47.     {
  48.         return [
  49.             CalendarEvents::EVENT_POST_CREATE => 'create',
  50.             CalendarEvents::EVENT_POST_REQUEST => 'request',
  51.             CalendarEvents::EVENT_POST_RESCHEDULE => 'reschedule',
  52.             CalendarEvents::EVENT_POST_CANCEL => 'cancel',
  53.             OrganizationEvents::MEMBER_POST_JOIN => 'memberPostJoin',
  54.         ];
  55.     }
  57.     /**
  58.      * @param GenericEvent $genericEvent
  59.      * @return void
  60.      */
  61.     public function create(GenericEvent $genericEvent): void
  62.     {
  63.         /** @var Event $event */
  64.         $event = $genericEvent->getSubject();
  66.         if ($event->isRecurring()) {
  67.             return;
  68.         }
  70.         $this->backgroundClient->add(new PushNotificationData(
  71.             UserDeviceNotificationType::TYPE_CREATE,
  72.             $event->getId(),
  73.             null,
  74.             $this->companySelector->getCompany()
  75.         ));
  76.         $this->backgroundClient->runJobs();
  77.     }
  79.     /**
  80.      * @param GenericEvent $genericEvent
  81.      * @return void
  82.      */
  83.     public function request(GenericEvent $genericEvent): void
  84.     {
  85.         /** @var Event $event */
  86.         $event = $genericEvent->getSubject();
  88.         $this->backgroundClient->add(new PushNotificationData(
  89.             UserDeviceNotificationType::TYPE_REQUEST,
  90.             $event->getId(),
  91.             null,
  92.             $this->companySelector->getCompany()
  93.         ));
  94.         $this->backgroundClient->runJobs();
  95.     }
  97.     /**
  98.      * @param GenericEvent $genericEvent
  99.      * @return void
  100.      */
  101.     public function reschedule(GenericEvent $genericEvent): void
  102.     {
  103.         /** @var Event $event */
  104.         $event = $genericEvent->getSubject();
  105.         $this->backgroundClient->add(new PushNotificationData(
  106.             UserDeviceNotificationType::TYPE_RESCHEDULE,
  107.             $event->getId(),
  108.             null,
  109.             $this->companySelector->getCompany()
  110.         ));
  111.         $this->backgroundClient->runJobs();
  112.     }
  114.     /**
  115.      * @param GenericEvent $genericEvent
  116.      * @return void
  117.      */
  118.     public function cancel(GenericEvent $genericEvent): void
  119.     {
  120.         /** @var Event $event */
  121.         $event = $genericEvent->getSubject();
  123.         if ($event->isRecurring()) {
  124.             if ($event->getCancellation() && !$event->getCancellation()->isSendNotification()) {
  125.                 return;
  126.             }
  127.         }
  129.         $this->backgroundClient->add(new PushNotificationData(
  130.             UserDeviceNotificationType::TYPE_CANCEL,
  131.             $event->getId(),
  132.             null,
  133.             $this->companySelector->getCompany()
  134.         ));
  135.         $this->backgroundClient->runJobs();
  136.     }
  138.     /**
  139.      * @param GenericEvent $genericEvent
  140.      * @return void
  141.      */
  142.     public function memberPostJoin(GenericEvent $genericEvent)
  143.     {
  144.         /** @var Member $member */
  145.         $member = $genericEvent->getSubject();
  146.         $user = $member->getUser()->getId();
  148.         $this->backgroundClient->add(new PushNotificationData(
  149.             UserDeviceNotificationType::TYPE_ORGANIZATION,
  150.             null,
  151.             $user,
  152.             $this->companySelector->getCompany()
  153.         ));
  154.         $this->backgroundClient->runJobs();
  155.     }
  157. }