src/EventSubscriber/ClientSubscriber.php line 37

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\JobQueue;
  6. use App\Service\EsJobQueue;
  7. use App\Handler\UserHandler;
  8. use App\Handler\ClientHandler;
  9. use App\Event\ClientPreUpdateEvent;
  10. use App\Event\ClientPostUpdateEvent;
  11. use App\Event\ClientPrePersistEvent;
  12. use App\Event\ClientPostPersistEvent;
  13. use Symfony\Contracts\Cache\TagAwareCacheInterface;
  14. use App\Service\JobQueueAction\UserSyncContainerAction;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class ClientSubscriber implements EventSubscriberInterface
  18. {
  19.     public function __construct(
  20.         private ClientHandler $handler,
  21.         private UserHandler $userHandler,
  22.         private TagAwareCacheInterface $esComCache,
  23.         private EsJobQueue $esJobQueue,
  24.     ) {
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             ClientPrePersistEvent::NAME => 'preCreate',
  31.             ClientPostPersistEvent::NAME => 'onCreate',
  32.             ClientPreUpdateEvent::NAME => 'onUpdate',
  33.             ClientPostUpdateEvent::NAME => 'onPostUpdate'
  34.         ];
  35.     }
  37.     public function preCreate(ClientPrePersistEvent $event)
  38.     {
  39.         $object = $event->getObject();
  40.         $this->updateDisclaimerConfigurations($object);
  41.     }
  43.     public function onCreate(ClientPostPersistEvent $event)
  44.     {
  45.         $object = $event->getObject();
  46.         $this->handler->createDefaultUser($object);
  47.     }
  49.     public function onUpdate(ClientPreUpdateEvent $event)
  50.     {
  51.         $object = $event->getObject();
  52.         $this->updateDisclaimerConfigurations($object);
  53.         $this->esComCache->invalidateTags(['ES_CLIENT', 'ES_CONTAINER', 'ES_MY_CONTAINER', 'ES_CLIENT_CID']);
  54.     }
  56.     public function onPostUpdate(ClientPostUpdateEvent $event)
  57.     {
  58.         $object = $event->getObject();
  60.         if ($object->getIsSyncContainerChanged()) {
  61.             $this->esJobQueue->create(
  62.                 UserSyncContainerAction::NAME,
  63.                 json_encode(['clientId' => $object->getId()]),
  64.                 JobQueue::PRIORITY_LOW
  65.             );
  66.         }
  67.     }
  69.     private function updateDisclaimerConfigurations($object)
  70.     {
  71.         $configurations = $object->getConfiguration();
  72.         if (isset($configurations['isDisclaimerPublish']) && $configurations['isDisclaimerPublish'] === true) {
  73.             $configurations['isDisclaimerPublish'] = false;
  74.             $object->replaceConfiguration($configurations);
  75.             $this->userHandler->resetDisclaimerStatus();
  76.         }
  77.     }
  78. }