src/FlexApp/EventSubscriber/RetieChatMessagesOnPortalSubscriber.php line 44

Open in your IDE?
  1. <?php
  2. namespace FlexApp\EventSubscriber;
  4. use FlexApp\Entity\ChatB;
  5. use FlexApp\Events\Style43\RegistrationSuccessEvent;
  6. use FlexApp\Events\UserEvent;
  7. use FlexApp\Exceptions\PortalApiClientException;
  8. use FlexApp\Repository\ChatBRepository;
  9. use Psr\Log\LoggerInterface;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use WebBundle\Helper\PortalHelper;
  13. class RetieChatMessagesOnPortalSubscriber implements EventSubscriberInterface
  14. {
  15.     private PortalHelper $portalHelper;
  17.     private LoggerInterface $logger;
  19.     private ChatBRepository $chatBRepository;
  21.     /**
  22.      * RetieChatMessagesOnPortalSubscriber constructor.
  23.      *
  24.      * @param PortalHelper $portalHelper
  25.      * @param LoggerInterface $logger
  26.      * @param ChatBRepository $chatBRepository
  27.      */
  28.     public function __construct(PortalHelper $portalHelper, LoggerInterface $logger, ChatBRepository $chatBRepository)
  29.     {
  30.         $this->portalHelper = $portalHelper;
  31.         $this->logger = $logger;
  32.         $this->chatBRepository = $chatBRepository;
  33.     }
  35.     public static function getSubscribedEvents(): array
  36.     {
  37.         return [
  38.             RegistrationSuccessEvent::class => [
  39.                 ['retieChatMessagesOnPortal', 0],
  40.             ],
  41.         ];
  42.     }
  44.     public function retieChatMessagesOnPortal(UserEvent $userEvent)
  45.     {
  46.         $user = $userEvent->getUser();
  47.         $token = $user->getToken();
  48.         /** @var ChatB $chat */
  49.         $chat = $this->chatBRepository->findOneBy(['token' => $token]);
  51.         if (!$chat) {
  52.             return;
  53.         }
  55.         if (0 === sizeof($chat->getMessages())) {
  56.             return;
  57.         }
  59.         try {
  60.             $this->portalHelper->retieChatMessagesOnPortal($token, $user, true);
  61.         } catch (PortalApiClientException $e) {
  62.             $this->logger->warning($e->getMessage());
  63.         }
  64.     }
  65. }