src/Core/Application/EventSubscriber/Chat/ChatChannelCreatedSubscriber.php line 36

  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Core\Application\EventSubscriber\Chat;
  7. use App\Admin\Domain\Repository\Course\CourseRepositoryInterface;
  8. use App\Core\Application\Event\Chat\ChatChannelCreatedEvent;
  9. use App\Core\Application\Service\RocketChat\RocketChatClientServiceInterface;
  10. use App\Core\Domain\Entity\ChatSetting\ChatChannel;
  11. use Doctrine\ORM\EntityManagerInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Component\Uid\Uuid;
  15. class ChatChannelCreatedSubscriber implements EventSubscriberInterface
  16. {
  17.     private readonly RocketChatClientServiceInterface $rocketChatClientService;
  18.     private readonly EntityManagerInterface $em;
  20.     public function __construct(
  21.         EntityManagerInterface $em,
  22.         RocketChatClientServiceInterface $rocketChatClientService,
  23.         private readonly CourseRepositoryInterface $courseRepository
  24.     ) {
  25.         $this->rocketChatClientService = $rocketChatClientService;
  26.         $this->em = $em;
  27.     }
  29.     public static function getSubscribedEvents(): array
  30.     {
  31.         return [
  32.             ChatChannelCreatedEvent::class => 'createChannel',
  33.         ];
  34.     }
  36.     public function createChannel(ChatChannelCreatedEvent $event): void
  37.     {
  38.         $courseId = $event->courseId;
  39.         $course = $this->courseRepository->find(['id' => $courseId]);
  41.         $channelId = $this->rocketChatClientService->createChannel($this->parseName($course->getName()));
  42.         if (!$channelId) {
  43.             throw new \RuntimeException('Nie udało się utworzyć kanału czatu w RocketChat.');
  44.         }
  46.         $chatChannel = new ChatChannel(Uuid::v4());
  47.         $chatChannel->setCourse($course);
  48.         $chatChannel->setChatChannelId($channelId);
  49.         $this->em->persist($chatChannel);
  50.         $this->em->flush();
  51.     }
  53.     private function parseName(string $input): string
  54.     {
  55.         $lowercase = mb_strtolower($input, 'UTF-8');
  56.         $transliterated = iconv('UTF-8', 'ASCII//TRANSLIT', $lowercase);
  57.         $cleaned = preg_replace('/[^a-z0-9]+/', '_', $transliterated);
  59.         return trim($cleaned, '_');
  60.     }
  61. }