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://2153412396212362.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:f8054b918f9a896c147e7ffdb186e8128609f2a3'
  61.                         ],
  62.                     
  63.                     ]);
  64.                     
  65.                     $response = curl_exec($curl);
  66.                     
  67.                     
  68.                     
  69.                     $dataArray = json_decode($response,true);
  70.                     
  71.                    
  72.                     
  73.                     
  74.                     if(array_key_exists("error",$dataArray)){
  75.                         
  76.                             
  77.                             
  78.                             $pseudoName = "User-".$user->getProfile()->getId();
  79.                             
  80.                             if($user->getProfile()->getPseudoName()){
  81.                                 $pseudoName = $user->getProfile()->getPseudoName();
  82.                             }
  83.                             
  84.                             $jsonString = '{"avatar":"https://kwl.gebanalysis.cloud/"'.$user->getProfile()->getProfileImage().',uid": "profile-id-'.$user->getProfile()->getId().'","name": "'.$pseudoName.'"}';
  85.                                         
  86.                                         
  87.                             $curlCreate = curl_init();
  88.                             curl_setopt_array($curlCreate, [
  89.                                 CURLOPT_URL => "https://2153412396212362.api-eu.cometchat.io/v3/users",
  90.                                 CURLOPT_RETURNTRANSFER => true,
  91.                                 CURLOPT_ENCODING => '',
  92.                                 CURLOPT_MAXREDIRS => 10,
  93.                                 CURLOPT_TIMEOUT => 30,
  94.                                 CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  95.                                 CURLOPT_CUSTOMREQUEST => 'POST',
  96.                                 CURLOPT_POSTFIELDS => $jsonString,
  97.                                 CURLOPT_HTTPHEADER => [
  98.                                     'Content-Type: application/json',
  99.                                     'Accept: application/json',
  100.                                     'Apikey:f8054b918f9a896c147e7ffdb186e8128609f2a3'
  101.                                 ],
  102.                             
  103.                             ]);
  104.                             
  105.                             $responseCreate = curl_exec($curlCreate);
  106.                             
  107.                             $dataArrayCreate = json_decode($responseCreate,true);
  108.                             
  109.                             
  110.                             
  111.                             
  112.                             $err = curl_error($curlCreate);
  113.                     
  114.                              curl_close($curlCreate);
  115.                         
  116.                     }
  117.                     
  118.                     
  119.                     
  120.                     $err = curl_error($curl);
  121.                     
  122.                     curl_close($curl);
  123.                 
  124.             
  125.             
  126.             $payload['ip'] = $request->getClientIp();
  127.             
  128.             $profileID = null;
  129.             if($user->getProfile()){
  130.                 $profileID = $user->getProfile()->getId();
  131.             }
  132.             $payload['profileID'] = $profileID;
  133.             $event->setData($payload);
  134.         
  135.             $header        = $event->getHeader();
  136.             $header['cty'] = 'JWT';
  137.         
  138.             $event->setHeader($header);
  139.         }
  140.             
  141.          
  142. }