src/EventSubscriber/InjectUserSubscriber.php line 40

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use ApiPlatform\Core\Bridge\Doctrine\Orm\Paginator;
  6. use ApiPlatform\Core\EventListener\EventPriorities;
  7. use App\Entity\CheckUserInListInterface;
  8. use App\Entity\UserTokenInterface;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use ReflectionException;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpFoundation\JsonResponse;
  13. use Symfony\Component\HttpFoundation\Request;
  14. use Symfony\Component\HttpKernel\Event\ViewEvent;
  15. use Symfony\Component\HttpKernel\KernelEvents;
  16. use Symfony\Component\Security\Core\Security;
  18. class InjectUserSubscriber implements EventSubscriberInterface
  19. {
  20.     /**
  21.      * @var Security
  22.      */
  23.     private $security;
  24.     /**
  25.      * @var EntityManagerInterface
  26.      */
  27.     private $manager;
  29.     public function __construct(Security $security, EntityManagerInterface $manager)
  30.     {
  31.         $this->security = $security;
  32.         $this->manager = $manager;
  33.     }
  35.     /**
  36.      * @return void
  37.      *
  38.      * @throws ReflectionException
  39.      */
  40.     public function setUser(ViewEvent $event)
  41.     {
  42.         $object = $event->getControllerResult();
  44.         if (($object) && (!is_array($object))) {
  45.             $reflectionClass = new \ReflectionClass($object);
  47.             if ($reflectionClass->implementsInterface(UserTokenInterface::class)) {
  48.                 if ($event->getRequest()->isMethod(Request::METHOD_POST) && $object->getId() === null) {
  49.                     $uniqRelation = $object->setUserToken($this->security->getUser());
  51.                     if ($uniqRelation !== null) {
  52.                         $parentMethod = 'get'.ucfirst($uniqRelation['parent_name']);
  54.                         $old_object = $this->manager->getRepository(get_class($object))->findOneBy([
  55.                             $uniqRelation['property_name'] => $this->security->getUser(),
  56.                             $uniqRelation['parent_name'] => $object->$parentMethod(),
  57.                         ]);
  59.                         if ($old_object) {
  60.                             $this->manager->remove($old_object);
  61.                             $this->manager->flush();
  62.                             if (isset($uniqRelation['uniq']) && $uniqRelation['uniq']) {
  63.                                 $event->setResponse(new JsonResponse([
  64.                                     'data' => [],
  65.                                     'message' => 'success',
  66.                                     'code' => 204,
  67.                                 ]));
  69.                                 return;
  70.                             }
  71.                         }
  72.                     }
  73.                 }
  74.                 if (method_exists($object, 'checkByUserToken')) {
  75.                     $object->checkByUserToken($this->security->getUser());
  76.                 }
  77.             }
  79.             if ($object instanceof Paginator && count($object) > 0) {
  80.                 foreach ($object as $objet) {
  81.                     $reflectionClass = new \ReflectionClass($objet);
  82.                     if (!$reflectionClass->implementsInterface(CheckUserInListInterface::class)) {
  83.                         return;
  84.                     }
  85.                     if (method_exists($objet, 'checkByUserToken')) {
  86.                         $objet->checkByUserToken($this->security->getUser());
  87.                     }
  88.                 }
  89.             }
  90.         }
  91.     }
  93.     /**
  94.      * @return array<string, mixed>
  95.      */
  96.     public static function getSubscribedEvents(): array
  97.     {
  98.         return [
  99.             KernelEvents::VIEW => ['setUser', EventPriorities::PRE_WRITE],
  100.         ];
  101.     }
  102. }