src/Core/Application/EventSubscriber/Chat/SetUserChatSubscriber.php line 41

  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Core\Application\EventSubscriber\Chat;
  7. use App\Core\Application\Event\Chat\ChatUserPersonalTokenGeneratedEvent;
  8. use App\Core\Application\Event\Chat\SetUserChatEvent;
  9. use App\Core\Application\Service\RocketChat\RocketChatClientServiceInterface;
  10. use App\Core\Domain\Entity\ChatSetting\ChatSetting;
  11. use App\Core\Domain\Entity\ChatSetting\ChatUserInterface;
  12. use App\Core\Domain\Entity\Student\Student;
  13. use App\Core\Domain\Entity\User\User;
  14. use App\Core\Domain\Repository\ChatSetting\ChatChannelRepositoryInterface;
  15. use Doctrine\ORM\EntityManagerInterface;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\Uid\Uuid;
  19. class SetUserChatSubscriber implements EventSubscriberInterface
  20. {
  21.     private readonly EntityManagerInterface $em;
  22.     private readonly RocketChatClientServiceInterface $rocketChatClientService;
  24.     public function __construct(
  25.         EntityManagerInterface $em,
  26.         RocketChatClientServiceInterface $rocketChatClientService,
  27.         private readonly  ChatChannelRepositoryInterface $chatChannelRepository
  28.     )
  29.     {
  30.         $this->em = $em;
  31.         $this->rocketChatClientService = $rocketChatClientService;
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             SetUserChatEvent::class => 'setUserToChat',
  38.         ];
  39.     }
  41.     public function setUserToChat(SetUserChatEvent $event): void
  42.     {
  43.         $user = $event->user;
  44.         $dto = $event->dto;
  45.         $channelId = $event->chatChannelId;
  47.         $userId = $this->rocketChatClientService->createUser($dto);
  48.         $chatSetting = new ChatSetting(Uuid::v4());
  49.         $chatSetting->setChatUserId($userId);
  51.         if ($user instanceof Student) {
  52.             $user->setChatSetting($chatSetting);
  53.             $this->addUserToChannel($channelId, $user);
  54.             $this->generateToken($user);
  55.         }
  57.         if ($user instanceof User) {
  58.             $user->setChatSetting($chatSetting);
  59.             $this->addUserToChannel($channelId, $user);
  60.             $this->generateToken($user);
  61.         }
  63.         $this->em->flush();
  64.     }
  66.     private function addUserToChannel(string $channelId, ChatUserInterface $user): void
  67.     {
  68.         $chatChannel = $this->chatChannelRepository->findOneBy(['chatChannelId' => $channelId]);
  70.         if ($user instanceof Student) {
  71.             $this->rocketChatClientService->inviteUserToChannel($user->getChatSetting()->getChatUserId(), $channelId);
  72.         }
  74.         if ($user instanceof User) {
  75.             $this->rocketChatClientService->inviteUserToChannel($user->getChatSetting()->getChatUserId(), $channelId);
  76.         }
  78.         $user->getChatSetting()->addChatChannel($chatChannel);
  79.         $this->em->persist($user);
  80.     }
  82.     private function generateToken(ChatUserInterface $user): void
  83.     {
  84.         $token = '';
  85.         if ($user instanceof Student) {
  86.             $token = $this->rocketChatClientService->createToken($user->getChatSetting()->getChatUserId());
  87.         }
  89.         if ($user instanceof User) {
  90.             $token = $this->rocketChatClientService->createToken($user->getChatSetting()->getChatUserId());
  91.         }
  93.         $user->getChatSetting()->setToken($token);
  94.     }
  95. }