src/Service/EventSubscriber/DirectorySubscriber.php line 58

Open in your IDE?
  1. <?php
  4. namespace Harmonizely\Service\EventSubscriber;
  6. use Harmonizely\Background\Data\DirectoryDeleteCompanyEventData;
  7. use Harmonizely\Background\Data\DirectorySaveCompanyEventData;
  8. use Harmonizely\Core\BackgroundWork\Contract\IClient;
  9. use Harmonizely\Core\Security\Contract\ISecurityHelper;
  10. use Harmonizely\Model\EventTypeInterface;
  11. use Harmonizely\Service\Core\Contract\ICompanySelector;
  12. use Harmonizely\Service\Event\CreateEventTypeEvent;
  13. use Harmonizely\Service\Event\DeleteEventTypeEvent;
  14. use Harmonizely\Service\Event\UpdateEventTypeEvent;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class DirectorySubscriber implements EventSubscriberInterface
  18. {
  20.     /**
  21.      * @var IClient
  22.      */
  23.     private IClient $backgroundClient;
  25.     /**
  26.      * @var ISecurityHelper
  27.      */
  28.     private ISecurityHelper $securityHelper;
  30.     /**
  31.      * @var ICompanySelector
  32.      */
  33.     private ICompanySelector $companySelector;
  35.     /**
  36.      * @param IClient $backgroundClient
  37.      * @param ISecurityHelper $securityHelper
  38.      * @param ICompanySelector $companySelector
  39.      */
  40.     public function __construct(
  41.         IClient $backgroundClient,
  42.         ISecurityHelper $securityHelper,
  43.         ICompanySelector $companySelector
  44.     )
  45.     {
  46.         $this->backgroundClient = $backgroundClient;
  47.         $this->securityHelper = $securityHelper;
  48.         $this->companySelector = $companySelector;
  49.     }
  51.     /**
  52.      * @return string[]
  53.      */
  54.     public static function getSubscribedEvents(): array
  55.     {
  56.         return [
  57.             CreateEventTypeEvent::NAME => 'createEventType',
  58.             UpdateEventTypeEvent::NAME => 'updateEventType',
  59.             DeleteEventTypeEvent::NAME => 'deleteEventType',
  60.         ];
  61.     }
  63.     /**
  64.      * @param CreateEventTypeEvent $event
  65.      * @return void
  66.      */
  67.     public function createEventType(CreateEventTypeEvent $event): void
  68.     {
  69.         $this->saveOrDeleteEventType($event->getEventType());
  70.     }
  72.     /**
  73.      * @param UpdateEventTypeEvent $event
  74.      * @return void
  75.      */
  76.     public function updateEventType(UpdateEventTypeEvent $event): void
  77.     {
  78.         $this->saveOrDeleteEventType($event->getEventType());
  79.     }
  81.     /**
  82.      * @param DeleteEventTypeEvent $event
  83.      * @return void
  84.      */
  85.     public function deleteEventType(DeleteEventTypeEvent $event): void
  86.     {
  87.         $user = $this->securityHelper->getUser();
  89.         $this->backgroundClient->add(new DirectoryDeleteCompanyEventData(
  90.             $user->getId(),
  91.             $event->getEventTypeId(),
  92.             $this->companySelector->getCompany()
  93.         ));
  94.         $this->backgroundClient->runJobs();
  95.     }
  97.     /**
  98.      * @param EventTypeInterface $eventType
  99.      * @return void
  100.      */
  101.     private function saveOrDeleteEventType(EventTypeInterface $eventType): void
  102.     {
  103.         $user = $this->securityHelper->getUser();
  105.         if ($eventType->isEnabled() && !$eventType->isSecret()) {
  106.             $this->backgroundClient->add(new DirectorySaveCompanyEventData(
  107.                 $user->getId(),
  108.                 $eventType->getId(),
  109.                 $this->companySelector->getCompany()
  110.             ));
  111.         } else {
  112.             $this->backgroundClient->add(new DirectoryDeleteCompanyEventData(
  113.                 $user->getId(),
  114.                 $eventType->getId(),
  115.                 $this->companySelector->getCompany()
  116.             ));
  117.         }
  118.         $this->backgroundClient->runJobs();
  119.     }
  120. }