src/Core/Application/EventSubscriber/Chat/KickUserOutOfChannelSubscriber.php line 35

  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Core\Application\EventSubscriber\Chat;
  7. use App\Core\Application\Event\Chat\KickUserOutOfChannelEvent;
  8. use App\Core\Application\Service\RocketChat\RocketChatClientServiceInterface;
  9. use App\Core\Domain\Entity\ChatSetting\ChatChannel;
  10. use App\Core\Domain\Entity\Student\Student;
  11. use Doctrine\ORM\EntityManagerInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class KickUserOutOfChannelSubscriber implements EventSubscriberInterface
  16. {
  17.     private readonly RocketChatClientServiceInterface $rocketChatClientService;
  18.     private readonly EntityManagerInterface $em;
  20.     public function __construct(
  21.         EntityManagerInterface $em,
  22.         RocketChatClientServiceInterface $rocketChatClientService,
  23.     ) {
  24.         $this->rocketChatClientService = $rocketChatClientService;
  25.         $this->em = $em;
  26.     }
  28.     public static function getSubscribedEvents(): array
  29.     {
  30.         return [
  31.             KickUserOutOfChannelEvent::class => 'kickUserOfChannel',
  32.         ];
  33.     }
  35.     public function kickUserOfChannel(KickUserOutOfChannelEvent $event): void
  36.     {
  37.         $user = $event->user;
  39.         if ($user instanceof Student) {
  40.             $channels = $user->getChatSetting()->getChatChannels();
  42.             /* @var ChatChannel $channel */
  43.             foreach ($channels as $channel) {
  44.                 /** @TODO Add logic that will retrieve the information about the completed subscription for the course and pass the channel */
  45.                 $this->rocketChatClientService->kickUserOurOfChannel($channel->getChatChannelId(), $user->getChatSetting()->getChatUserId());
  46.             }
  47.         }
  48.     }
  49. }