src/EventSubscriber/Chat/ChatPostSerializerSubscriber.php line 50

Open in your IDE?
  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: SUSAN MEDINA
  5.  * Date: 21/05/2019
  6.  * Time: 08:43 PM
  7.  */
  9. namespace App\EventSubscriber\Chat;
  11. use App\Entity\App\User;
  12. use App\Entity\Chat\Chat;
  13. use Symfony\Component\HttpFoundation\Response;
  14. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Component\Security\Core\Authorization\AuthorizationCheckerInterface;
  17. use Symfony\Component\HttpKernel\Event\ViewEvent;
  18. use ApiPlatform\Core\EventListener\EventPriorities;
  19. use Symfony\Component\HttpKernel\KernelEvents;
  20. use Symfony\Contracts\Translation\TranslatorInterface;
  21. use App\Services\ChatService;
  22. use App\Services\UtilsService;
  24. class ChatPostSerializerSubscriber implements EventSubscriberInterface
  25. {
  26.     private $tokenStorage;
  27.     private $authorizationChecker;
  28.     private $chatService;
  29.     private $utilsService;
  30.     private $translator;
  32.     public function __construct(
  33.         TokenStorageInterface $tokenStorage,
  34.         AuthorizationCheckerInterface $checker,
  35.         UtilsService $utilsService,
  36.         ChatService $chatService,
  37.         TranslatorInterface $translator
  38.     ) {
  39.         $this->tokenStorage = $tokenStorage;
  40.         $this->authorizationChecker = $checker;
  41.         $this->utilsService = $utilsService;
  42.         $this->chatService = $chatService;
  43.         $this->translator = $translator;
  44.     }
  46.     /**
  47.      * @param ViewEvent $event
  48.      * @throws \Doctrine\ORM\NonUniqueResultException
  49.      */
  50.     public function onKernelView(ViewEvent $event)
  51.     {
  52.         if ($this->utilsService->isAPublicRequest($event)) {
  53.             return;
  54.         }
  55.         $request = $event->getRequest();
  56.         $chatResult = $event->getControllerResult();
  58.         $routes = array(
  59.             'api_chats_get_collection',
  60.             'api_chats_post_collection',
  61.             'api_chats_get_item'
  62.         );
  63.         $route = $request->attributes->get('_route');
  65.         if (!in_array($route, $routes)) {
  66.             return;
  67.         }
  69.         $userCurrent = $this->tokenStorage->getToken()->getUser();
  70.         if (!$userCurrent instanceof User) {
  71.             $response = new Response();
  72.             $response->setContent(json_encode([
  73.                 'detail' => $this->translator->trans(
  74.                         'User not found',
  75.                         [],
  76.                         null,
  77.                         $request->getLocale()
  78.                     )
  79.             ]));
  80.             $response->setStatusCode(Response::HTTP_UNAUTHORIZED);
  81.             $event->setResponse($response);
  83.             return;
  84.         }
  86.         $chatResult = json_decode($chatResult, true);
  88.         //var_dump($chatResult);
  89.         //exit();
  91.         if ('api_chats_get_collection' === $route) {
  92.             foreach ($chatResult as $key => &$chat) {
  93.                 $chat = $this->chatService->formatNormalize($chat, $userCurrent);
  94.             }
  95.         } else {
  96.             $chatResult = $this->chatService->formatNormalize($chatResult, $userCurrent);
  97.         }
  99.         $chatResultMain['chats'] = $chatResult;
  100.         $chatResultMain['messagesPendingToReadGlobalCounter'] = $this->chatService
  101.             ->calculateMessagesPendingToReadForAllChats($userCurrent);
  102.         $chatResultMain['messagesPendingToReadGlobalTicketCounter'] = $this->chatService
  103.             ->calculateMessagesPendingToReadForTypeChats($userCurrent, Chat::TYPE_TICKET);
  104.         $chatResultMain['messagesPendingToReadGlobalTaskCounter'] = $this->chatService
  105.             ->calculateMessagesPendingToReadForTypeChats($userCurrent, Chat::TYPE_TASK);
  106.         $chatResultMain['messagesGlobalCounter'] = $this->chatService
  107.             ->calculateMessagesTotalForAllChats($userCurrent);
  109.         $event->setControllerResult(json_encode($chatResultMain));
  110.     }
  112.     public static function getSubscribedEvents()
  113.     {
  114.         return [
  115.             KernelEvents::VIEW => ['onKernelView', EventPriorities::POST_SERIALIZE]
  116.         ];
  117.     }
  118. }