src/EventSubscriber/RemoteAuthSubscriber.php line 62

Open in your IDE?
  1. <?php
  2. /**
  3.  * User: Quentin
  4.  * Date: 06/07/2020
  5.  * Time: 22:57
  6.  */
  8. namespace App\EventSubscriber;
  10. use App\Entity\User;
  11. use App\Event\RemoteAuthFailureEvent;
  12. use App\Event\RemoteAuthSuccessEvent;
  13. use App\Services\RemoteAuthService;
  14. use App\Services\RemoteUserData;
  15. use App\Services\RemoteUserDataService;
  16. use Doctrine\ORM\EntityManagerInterface;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\HttpFoundation\Cookie;
  19. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  20. use Symfony\Component\HttpKernel\KernelEvents;
  21. use Symfony\Component\HttpKernel\KernelInterface;
  23. class RemoteAuthSubscriber implements EventSubscriberInterface {
  25.     /**
  26.      * @var EntityManagerInterface
  27.      */
  28.     private $manager;
  30.     /**
  31.      * @var KernelInterface
  32.      */
  33.     private $kernel;
  34.     
  35.     protected $tgt;
  36.     
  37.     /**
  38.      * @var RemoteAuthService
  39.      */
  40.     private $authService;
  41.     
  42.     /**
  43.      * @var RemoteUserDataService
  44.      */
  45.     private $userDataService;
  47.     public function __construct(EntityManagerInterface $manager, KernelInterface $kernel, RemoteAuthService $authService, RemoteUserDataService $userDataService) {
  48.         $this->manager = $manager;
  49.         $this->kernel = $kernel;
  50.         $this->authService = $authService;
  51.         $this->userDataService = $userDataService;
  52.     }
  54.     public static function getSubscribedEvents() {
  55.         return [
  56.             RemoteAuthSuccessEvent::NAME => 'onAuthSuccess',
  57.             RemoteAuthFailureEvent::NAME => 'onAuthFailure',
  58.             KernelEvents::RESPONSE => 'onKernelResponse',
  59.         ];
  60.     }
  62.     public function onAuthSuccess(RemoteAuthSuccessEvent $event) {
  63.         $userData = $event->getUserData();
  64.         $remoteId = $userData->remoteId;
  65.         $this->tgt = $userData->tgt;
  67.         /** @var User|null $user */
  68.         $user = $this->manager->getRepository(User::class)->findOneByRemoteId($remoteId);
  69.         if (is_null($user)) {
  70.             $user = $this->createUser($userData);
  71.         } else {
  72.             $this->userDataService->updateFromData($user, $userData, 'Synchro SQL (connexion)', $user->hasPendingRemoteSubscriptionRequest());
  73.         }
  74.         $this->manager->flush();
  76.         $lines = [
  77.             " ### " . date('r') . " / Success\n",
  78.             "User data: " . var_export($userData, true),
  79.             "User: " . $user->getId()
  80.         ];
  82.         file_put_contents(
  83.             $this->getCurrentLogFilePath(),
  84.             "\n\n" . implode("\n", $lines),
  85.             FILE_APPEND
  86.         );
  87.     }
  89.     protected function createUser(RemoteUserData $userData): User {
  90.         $user = new User();
  91.         $this->userDataService->updateFromData($user, $userData, 'Synchro SQL (connexion)');
  92.         $this->manager->persist($user);
  93.         return $user;
  94.     }
  96.     protected function getCurrentLogFilePath(): string {
  97.         $directory = $this->kernel->getLogDir() . "/" . $this->kernel->getEnvironment() . "/" . date('Y') . "-" . date('m') . "/";
  98.         if (!is_dir($directory)) {
  99.             mkdir($directory, 0777, true);
  100.         }
  101.         return $directory . date('d') . "-cas.log";
  102.     }
  104.     public function onAuthFailure(RemoteAuthFailureEvent $event) {
  105.         $eventData = $event->getData();
  106.         unset($eventData['postFields']['password']);
  107.         
  108.         $lines = [
  109.             " ### " . date('r') . " / Failure (" . $event->getReason() . ")\n",
  110.             "Debug data: " . var_export($eventData, true)
  111.         ];
  113.         file_put_contents(
  114.             $this->getCurrentLogFilePath(),
  115.             "\n\n" . implode("\n", $lines),
  116.             FILE_APPEND
  117.         );
  118.     }
  119.     
  120.     public function onKernelResponse(ResponseEvent $event) {
  121.         if (is_null($this->tgt)) {
  122.             return;
  123.         }
  124.         $this->authService->setCookie($event->getResponse(), $this->tgt);
  125.     }
  127. }