src/FlexApp/EventSubscriber/RetieChatMessagesOnPortalSubscriber.php line 53

Open in your IDE?
  1. <?php
  3. namespace FlexApp\EventSubscriber;
  5. use FlexApp\Entity\ChatB;
  6. use FlexApp\Enum\LoggerJobNameEnum;
  7. use FlexApp\Events\Style43\RegistrationSuccessEvent;
  8. use FlexApp\Events\UserEvent;
  9. use FlexApp\Exceptions\PortalApiClientException;
  10. use FlexApp\Repository\ChatBRepository;
  11. use FlexApp\Service\LogsManager;
  12. use Psr\Log\LoggerInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use WebBundle\Helper\PortalHelper;
  16. class RetieChatMessagesOnPortalSubscriber implements EventSubscriberInterface
  17. {
  18.     private PortalHelper $portalHelper;
  20.     private LoggerInterface $logger;
  22.     private ChatBRepository $chatBRepository;
  23.     private LogsManager $logsManager;
  25.     /**
  26.      * RetieChatMessagesOnPortalSubscriber constructor.
  27.      *
  28.      * @param PortalHelper $portalHelper
  29.      * @param LoggerInterface $logger
  30.      * @param ChatBRepository $chatBRepository
  31.      */
  32.     public function __construct(
  33.         PortalHelper $portalHelper,
  34.         LoggerInterface $logger,
  35.         ChatBRepository $chatBRepository,
  36.         LogsManager $logsManager
  37.     ) {
  38.         $this->portalHelper = $portalHelper;
  39.         $this->logger = $logger;
  40.         $this->chatBRepository = $chatBRepository;
  41.         $this->logsManager = $logsManager;
  42.     }
  44.     public static function getSubscribedEvents(): array
  45.     {
  46.         return [
  47.             RegistrationSuccessEvent::class => [
  48.                 ['retieChatMessagesOnPortal', 0],
  49.             ],
  50.         ];
  51.     }
  53.     public function retieChatMessagesOnPortal(UserEvent $userEvent)
  54.     {
  55.         $user = $userEvent->getUser();
  56.         $token = $user->getToken();
  57.         /** @var ChatB $chat */
  58.         $chat = $this->chatBRepository->findOneBy(['token' => $token]);
  60.         if (!$chat) {
  61.             return;
  62.         }
  64.         if (0 === sizeof($chat->getMessages())) {
  65.             return;
  66.         }
  68.         try {
  69.             $this->portalHelper->retieChatMessagesOnPortal($token, $user, true);
  70.         } catch (PortalApiClientException $e) {
  71.             $this->logger->warning($e->getMessage());
  72.             $this->logsManager->logError(
  73.                 [
  74.                     'message' => $e->getMessage(),
  75.                 ],
  76.                 LoggerJobNameEnum::RETIE_CHAT_MESSAGE_LOG
  77.             );
  78.         }
  79.     }
  80. }