src/EventSubscriber/JWTCreatedListener.php line 38

Open in your IDE?
  1. <?php 
  2. // src/App/EventListener/JWTDecodedListener.php
  3. namespace App\EventSubscriber;
  6. use Lexik\Bundle\JWTAuthenticationBundle\Event\JWTDecodedEvent;
  7. use Lexik\Bundle\JWTAuthenticationBundle\Event\JWTCreatedEvent;
  8. use Symfony\Component\HttpFoundation\RequestStack;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use App\Entity\User;
  15. class JWTCreatedListener{
  16.             
  17.             /**
  18.          * @var RequestStack
  19.          */
  20.         private $requestStack;
  21.         private $entityManager;
  22.         
  23.         /**
  24.          * @param RequestStack $requestStack
  25.          */
  26.         public function __construct(RequestStack $requestStack,EntityManagerInterface $entityManager)
  27.         {
  28.             $this->requestStack = $requestStack;
  29.             $this->entityManager = $entityManager;
  30.         }
  31.         
  32.         
  33.         /**
  34.          * @param JWTCreatedEvent $event
  35.          *
  36.          * @return void
  37.          */
  38.         public function onJWTCreated(JWTCreatedEvent $event)
  39.         {
  40.             $request = $this->requestStack->getCurrentRequest();
  41.          
  42.             $payload       = $event->getData();
  43.             $user = $this->entityManager->getRepository(User::class)->findOneByEmail($payload['email']);
  44.             
  45.                     $uuid = "profile-id-".$user->getProfile()->getId();              
  46.                                                 
  47.                     $curl = curl_init();
  48.                     curl_setopt_array($curl, [
  49.                         CURLOPT_URL => "https://247548211a9ed919.api-eu.cometchat.io/v3/users/".$uuid,
  50.                         CURLOPT_RETURNTRANSFER => true,
  51.                         CURLOPT_ENCODING => '',
  52.                         CURLOPT_MAXREDIRS => 10,
  53.                         CURLOPT_TIMEOUT => 30,
  54.                         CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  55.                         CURLOPT_CUSTOMREQUEST => 'GET',
  56.                         //CURLOPT_POSTFIELDS => $jsonString,
  57.                         CURLOPT_HTTPHEADER => [
  58.                             'Content-Type: application/json',
  59.                             'Accept: application/json',
  60.                             'Apikey:7f0e4f8cd1613c00b49ef0f7146868dd6d57099f'
  61.                         ],
  62.                     
  63.                     ]);
  64.                     
  65.                     $response = curl_exec($curl);
  66.                     
  67.                     
  68.                     
  69.                     $dataArray = json_decode($response,true);
  70.                     
  71.                     
  72.                     if(array_key_exists("error",$dataArray)){
  73.                         
  74.                             
  75.                             
  76.                             $pseudoName = "User-".$user->getProfile()->getId();
  77.                             
  78.                             if($user->getProfile()->getPseudoName()){
  79.                                 $pseudoName = $user->getProfile()->getPseudoName();
  80.                             }
  81.                             
  82.                             $jsonString = '{"uid": "profile-id-'.$user->getProfile()->getId().'","name": "'.$pseudoName.'"}';
  83.                                         
  84.                                         
  85.                             $curlCreate = curl_init();
  86.                             curl_setopt_array($curlCreate, [
  87.                                 CURLOPT_URL => "https://247548211a9ed919.api-eu.cometchat.io/v3/users",
  88.                                 CURLOPT_RETURNTRANSFER => true,
  89.                                 CURLOPT_ENCODING => '',
  90.                                 CURLOPT_MAXREDIRS => 10,
  91.                                 CURLOPT_TIMEOUT => 30,
  92.                                 CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  93.                                 CURLOPT_CUSTOMREQUEST => 'POST',
  94.                                 CURLOPT_POSTFIELDS => $jsonString,
  95.                                 CURLOPT_HTTPHEADER => [
  96.                                     'Content-Type: application/json',
  97.                                     'Accept: application/json',
  98.                                     'Apikey:7f0e4f8cd1613c00b49ef0f7146868dd6d57099f'
  99.                                 ],
  100.                             
  101.                             ]);
  102.                             
  103.                             $responseCreate = curl_exec($curlCreate);
  104.                             
  105.                             $dataArrayCreate = json_decode($responseCreate,true);
  106.                             
  107.                             //dd($dataArrayCreate);
  108.                             
  109.                             
  110.                             $err = curl_error($curlCreate);
  111.                     
  112.                              curl_close($curlCreate);
  113.                         
  114.                     }
  115.                     
  116.                     
  117.                     
  118.                     $err = curl_error($curl);
  119.                     
  120.                     curl_close($curl);
  121.                 
  122.             
  123.             
  124.             $payload['ip'] = $request->getClientIp();
  125.             
  126.             $profileID = null;
  127.             if($user->getProfile()){
  128.                 $profileID = $user->getProfile()->getId();
  129.             }
  130.             $payload['profileID'] = $profileID;
  131.             $event->setData($payload);
  132.         
  133.             $header        = $event->getHeader();
  134.             $header['cty'] = 'JWT';
  135.         
  136.             $event->setHeader($header);
  137.         }
  138.             
  139.          
  140. }