src/EventSubscriber/UserSubscriber.php line 45

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use ApiPlatform\Symfony\EventListener\EventPriorities as EventPrioritiesAlias;
  6. use App\Enum\ActivityLogCategoryEnum;
  7. use App\Enum\ActivityLogMethodEnum;
  8. use App\Traits\SentryNotifyTrait;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use Doctrine\ORM\ORMException;
  11. use Evo\Infrastructure\MappingORM\ActivityLog;
  12. use Evo\Infrastructure\MappingORM\Organization;
  13. use Evo\Infrastructure\MappingORM\User;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Component\HttpFoundation\Request;
  16. use Symfony\Component\HttpKernel\Event\ViewEvent;
  17. use Symfony\Component\HttpKernel\KernelEvents;
  18. use Symfony\Component\Security\Core\Authentication\Token\SwitchUserToken;
  19. use Symfony\Component\Security\Core\Security;
  21. class UserSubscriber implements EventSubscriberInterface
  22. {
  23.     use SentryNotifyTrait;
  24.     private const ROUTE_NAME = 'api_users_put_item';
  25.     private Security $security;
  26.     private EntityManagerInterface $em;
  28.     public function __construct(Security $security, EntityManagerInterface $em)
  29.     {
  30.         $this->security = $security;
  31.         $this->em = $em;
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             KernelEvents::VIEW => ['onWrite', EventPrioritiesAlias::POST_WRITE],
  38.         ];
  39.     }
  41.     /**
  42.      * @throws \JsonException
  43.      * @throws ORMException
  44.      */
  45.     public function onWrite(ViewEvent $event)
  46.     {
  47.         $entity = $event->getControllerResult();
  49.         $request = $event->getRequest();
  50.         if (!$request instanceof Request) {
  51.             return;
  52.         }
  54.         if (!$entity instanceof User) {
  55.             return;
  56.         }
  58.         $routeName = $event->getRequest()->attributes->get('_route');
  59.         if (self::ROUTE_NAME !== $routeName) {
  60.             return;
  61.         }
  63.         $requestData = json_decode($event->getRequest()->getContent(), true, 512, JSON_THROW_ON_ERROR);
  65.         if (isset($requestData['organizations']) && isset($requestData['addedOrganizations'])) {
  66.             $token = $this->security->getToken();
  68.             if ($token instanceof SwitchUserToken) {
  69.                 $user = $token->getOriginalToken()->getUser();
  70.             } else {
  71.                 $user = $this->security->getUser();
  72.             }
  74.             foreach ($requestData['addedOrganizations'] as $orga) {
  75.                 if ('string' !== gettype($orga)) {
  76.                     continue;
  77.                 }
  78.                 $orgaId = explode('/', $orga);
  79.                 $orgaId = end($orgaId);
  80.                 $organization = $this->em->getReference(Organization::class, $orgaId);
  81.                 $activityLog = ActivityLog::create(
  82.                     $user,
  83.                     ActivityLogMethodEnum::CREATE,
  84.                     'AJOUT USER ID: '.$entity->getId(),
  85.                     ActivityLogCategoryEnum::USER,
  86.                     [],
  87.                     $organization,
  88.                     null,
  89.                     $entity->getFullName()
  90.                 );
  91.                 $this->em->persist($activityLog);
  92.             }
  93.             try {
  94.                 $this->em->flush();
  95.             } catch (\Exception $e) {
  96.                 $this->captureSentryException($e);
  97.             }
  98.         }
  99.     }
  100. }