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

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_RESCHEDULE => 'reschedule',
  51.             CalendarEvents::EVENT_POST_CANCEL => 'cancel',
  52.             OrganizationEvents::MEMBER_POST_JOIN => 'memberPostJoin',
  53.         ];
  54.     }
  56.     /**
  57.      * @param GenericEvent $genericEvent
  58.      * @return void
  59.      */
  60.     public function create(GenericEvent $genericEvent): void
  61.     {
  62.         /** @var Event $event */
  63.         $event = $genericEvent->getSubject();
  65.         if ($event->isRecurring()) {
  66.             return;
  67.         }
  69.         $this->backgroundClient->add(new PushNotificationData(
  70.             UserDeviceNotificationType::TYPE_CREATE,
  71.             $event->getId(),
  72.             null,
  73.             $this->companySelector->getCompany()
  74.         ));
  75.         $this->backgroundClient->runJobs();
  76.     }
  78.     /**
  79.      * @param GenericEvent $genericEvent
  80.      * @return void
  81.      */
  82.     public function reschedule(GenericEvent $genericEvent): void
  83.     {
  84.         /** @var Event $event */
  85.         $event = $genericEvent->getSubject();
  86.         $this->backgroundClient->add(new PushNotificationData(
  87.             UserDeviceNotificationType::TYPE_RESCHEDULE,
  88.             $event->getId(),
  89.             null,
  90.             $this->companySelector->getCompany()
  91.         ));
  92.         $this->backgroundClient->runJobs();
  93.     }
  95.     /**
  96.      * @param GenericEvent $genericEvent
  97.      * @return void
  98.      */
  99.     public function cancel(GenericEvent $genericEvent): void
  100.     {
  101.         /** @var Event $event */
  102.         $event = $genericEvent->getSubject();
  104.         if ($event->isRecurring()) {
  105.             if ($event->getCancellation() && !$event->getCancellation()->isSendNotification()) {
  106.                 return;
  107.             }
  108.         }
  110.         $this->backgroundClient->add(new PushNotificationData(
  111.             UserDeviceNotificationType::TYPE_CANCEL,
  112.             $event->getId(),
  113.             null,
  114.             $this->companySelector->getCompany()
  115.         ));
  116.         $this->backgroundClient->runJobs();
  117.     }
  119.     /**
  120.      * @param GenericEvent $genericEvent
  121.      * @return void
  122.      */
  123.     public function memberPostJoin(GenericEvent $genericEvent)
  124.     {
  125.         /** @var Member $member */
  126.         $member = $genericEvent->getSubject();
  127.         $user = $member->getUser()->getId();
  129.         $this->backgroundClient->add(new PushNotificationData(
  130.             UserDeviceNotificationType::TYPE_ORGANIZATION,
  131.             null,
  132.             $user,
  133.             $this->companySelector->getCompany()
  134.         ));
  135.         $this->backgroundClient->runJobs();
  136.     }
  138. }