src/IlaveU/FrontBundle/EventSubscriber/KernelListener.php line 120

  1. <?php
  2. namespace App\IlaveU\FrontBundle\EventSubscriber;
  4. use App\Entity\Settings;
  5. use App\Service\IlaveUGeoIp2Provider;
  6. use App\Service\IlaveUGeolocationProvider;
  7. use Doctrine\Persistence\ManagerRegistry;
  8. use Symfony\Component\HttpFoundation\Response;
  9. use Symfony\Component\HttpKernel\Event\ExceptionEvent;
  10. use Symfony\Component\HttpKernel\Exception\HttpExceptionInterface;
  13. use Symfony\Component\EventDispatcher\Attribute\AsEventListener;
  14. use Symfony\Component\HttpFoundation\JsonResponse;
  15. use Symfony\Component\HttpFoundation\RedirectResponse;
  16. use Symfony\Component\HttpKernel\Event\RequestEvent;
  17. use Symfony\Component\RateLimiter\RateLimiterFactory;
  19. #[AsEventListener(event: RequestEvent::class, method: 'onKernelRequest')]
  20. #[AsEventListener(event: ExceptionEvent::class, method: 'onKernelException')]
  22. class KernelListener
  23. {
  26.     public function __construct(
  27.         private readonly ManagerRegistry $doctrine,
  28.         private readonly IlaveUGeolocationProvider $ilaveGeolocationProvider,
  29.         private readonly RateLimiterFactory $apiLimitLimiter
  30.         ){
  32.     }
  33.     
  35.     public function onKernelException(ExceptionEvent $event): void
  36.     {
  37.         // You get the exception object from the received event
  38.         
  39.        
  41.         $request = $event->getRequest();
  43.         
  45.         $exception = $event->getThrowable();
  46.         $message = $exception->getMessage();
  48.         
  50.         // Example pattern - adjust based on actual exception message format
  51.         if (preg_match('/Invalid upload directory "(.+)"/', $message, $matches)) {
  52.             $directory = $matches[1];
  54.             
  55.             
  56.             if (!is_dir($directory)) {
  57.                 mkdir($directory, 0777, true);
  58.                 // Optionally, you might want to reload the request or redirect after fixing the issue
  59.                 $event->setResponse(new RedirectResponse($event->getRequest()->getRequestUri()));
  60.             }
  61.         }
  62.          
  63.         //$statusCode = $event->getThrowable()->getStatusCode();
  64.         // To check with code later
  66.         $request = $event->getRequest();
  68.         $pathInfo = $request->getPathInfo();
  69.         $locale = $request->getLocale();
  71.         
  72.         
  74.         $bddLang = $this->doctrine->getRepository(Settings::class)->findOneBy(["code"=>"main"])->getDefaultLang();
  75.         
  76.         
  77.         
  78.         
  79.     
  80.         if($request->query->get("_locale")){
  81.             if($request->query->get("_locale") != $locale){
  82.                 $request->setLocale($request->query->get("_locale"));
  83.             }
  84.         }
  86.         
  87.         if($request->server->get("APP_ENV") == "prod"){
  88.             //dd($event->getThrowable());
  90.             
  91.             if(strpos($pathInfo, '/' . $locale) === 0){
  92.                 if(method_exists($event->getThrowable(),"getStatusCode")  ){
  93.                     $response = new RedirectResponse('/'.$request->getLocale().'/page-not-found?message='.$event->getThrowable()->getMessage());
  94.                     $event->setResponse($response);
  95.                  }else{
  96.                     $response = new RedirectResponse('/'.$request->getLocale().'/page-not-found');
  97.                     $event->setResponse($response);
  98.                  }
  99.             }
  100.             elseif (strpos($pathInfo, '/' . $locale) !== 0) {
  102.                 // If the path does not start with the locale, redirect by adding the locale
  103.                 $newUrl = '/' . $locale . $pathInfo;
  104.                 //dd($newUrl);
  105.                 $response = new RedirectResponse($newUrl);
  106.                 //dd($response);
  107.                 $event->setResponse($response);
  108.             }
  110.             
  111.         }
  112.          
  113.         
  116.  
  117.     }
  120.         public function onKernelRequest(RequestEvent $event)
  121.     {
  124.         // if (!$event->isMainRequest()) {
  125.         //     return; // Ensure this odnly runs for the main request
  126.         // }
  128.         $request = $event->getRequest();
  130.        
  131.         // Get the rate limiter for a specific limit name
  132.         $limiter = $this->apiLimitLimiter->create($request->getClientIp());
  133.         
  134.         // Consume one token from the limit
  135.         $limit = $limiter->consume(1);
  137.         
  139.         // If the limit is exceeded, deny access
  140.         if (!$limit->isAccepted()) {
  141.             $event->setResponse(new JsonResponse(['error' => 'Rate limit exceeded'], 429));
  142.         }
  144.         $pathInfo = $request->getPathInfo();
  147.          // Define a list of file extensions that should be treated as assets
  148.          $assetExtensions = ['css', 'js', 'jpg', 'jpeg', 'png', 'gif', 'ico', 'woff', 'woff2', 'ttf', 'eot'];
  150.          // Check if the request path ends with one of the asset extensions
  151.          $isAsset = preg_match('/\.(' . implode('|', $assetExtensions) . ')$/i', $pathInfo);
  152.  
  153.          
  155.         $mainSettings = $this->doctrine->getRepository(Settings::class)->findOneBy(["code"=>"main"]);
  158.         $accepredCurrencies = [
  159.             "USD","EUR","MAD"
  160.         ];
  162.         $ipAddress = $request->server->get("REMOTE_ADDR");
  164.         
  165.         $session =  $request->getSession();
  166.         $defaultCurrency = $mainSettings->getCurrency();
  167.         $defaultCountryCode = "US";
  168.         
  169.         if(!$session->get("_currency")){
  170.             if($mainSettings->isIsGeoLocalisationApiEnabled()){
  171.                 $geoData = $this->ilaveGeolocationProvider->getCountryCodeAndLanguage($ipAddress);
  172.                 if($geoData){
  173.                     if(array_key_exists("currency",$geoData)){
  174.                         $defaultCurrency  = $geoData['currency'];
  175.                     }
  176.                    
  177.                 }
  178.             }
  179.             
  181.             
  182.             if(!$defaultCurrency){
  183.                 $session->set("_currency","USD");
  184.             }else{
  185.                 $session->set("_currency",$defaultCurrency);
  186.             }
  187.         }else{
  188.             if( !in_array($session->get("_currency"),$accepredCurrencies) and !$request->query->get("_currency")){
  189.                 $defaultCurrency = $this->doctrine->getRepository(Settings::class)->findOneBy(["code"=>"main"])->getCurrency();
  190.                 $session->set("_currency",$defaultCurrency );
  191.             }
  192.         }
  194.         
  197.         if(!$session->get("_countryCode")){
  198.             
  199.             
  200.              if($mainSettings->isIsGeoLocalisationApiEnabled()){
  201.                 $geoData = $this->ilaveGeolocationProvider->getCountryCodeAndLanguage($ipAddress);
  202.                     if($geoData){
  203.                         //dd($geoData);
  204.                         $defaultCountryCode  = $geoData['country_code'];
  205.                     }
  206.             }
  208.              if(!$defaultCountryCode)
  209.              {
  210.                 $defaultCountryCode = "US";
  211.              }
  212.              $session->set("_countryCode",$defaultCountryCode);
  213.         }
  216.         // if(!$session->get("_locale")){
  217.             
  218.         //     $geoData = $this->ilaveGeolocationProvider->getCountryCodeAndLanguage($ipAddress);
  219.         //      if($geoData){
  220.         //         $defaultLang  = $geoData['language'];
  221.         //         $request->setLocale(strtolower($defaultLang));
  222.         //         $session->set("_locale",strtolower($defaultLang));
  223.         //      }
  224.         // }else{
  225.         //     $request->setLocale($session->get("_locale"));
  226.         // }
  229.             
  231.         $locale = $request->getLocale();
  233.         
  234.         
  236.         $bddLang = $mainSettings->getDefaultLang();
  237.         
  238.         
  239.         
  240.         
  241.     
  242.         if($request->query->get("_locale")){
  243.             if($request->query->get("_locale") != $locale){
  244.                 
  247.                 $request->setLocale($request->query->get("_locale"));
  249.                 
  250.                 if($request->attributes->get("_route") == "front_home"){
  251.                     $pattern = '#^/([a-z]{2}(?:_[a-z]{2})?)#'; // This pattern matches standard locale formats like en, en_US, etc.
  252.                 }else{
  253.                     $pattern = '#^/([a-z]{2}(?:_[a-z]{2})?)/#'; // This pattern matches standard locale formats like en, en_US, etc.
  254.                 }
  255.                 
  257.                 // Remove the locale part from the path
  258.                 $newUrl = preg_replace($pattern,"/".$request->query->get("_locale")."/", $pathInfo);
  259.                 
  260.                 
  261.                 
  262.                 $response = new RedirectResponse($newUrl);
  263.                 $event->setResponse($response);
  265.             }
  266.         }
  269.         if($request->query->get("_currency")){
  270.             
  271.             if( in_array($request->query->get("_currency"),$accepredCurrencies)){
  272.                 $session->set("_currency",$request->query->get("_currency"));
  273.             }
  274.             
  275.             
  276.         }
  279.         if($request->query->get("_countryCode")){
  280.             
  281.             
  282.         $session->set("_countryCode",$request->query->get("_countryCode"));
  283.         
  284.             // Reset Cart
  285.              $cart = $session->get("cart",[]);
  286.              if(array_key_exists("ready_to_checkout",$cart)){
  287.                 $cart["ready_to_checkout"] = false;
  288.                 $session->set("cart",$cart);
  289.              }
  291.         
  292.             
  293.             
  294.         }
  295.         /*
  296.         elseif($bddLang){
  297.             $request->setLocale($bddLang);
  298.         }*/
  299.         
  300.         
  301.         //dd(strpos($pathInfo, '/' . $locale.'/') !== 0);
  302.         //dd($pathInfo);
  303.         $exeptionPaths = [
  304.             "/api_login_check"
  305.         ];
  307.         
  309.         if (strpos($pathInfo, '/' . $locale) !== 0 and !$isAsset) {
  310.             
  311.           
  312.             
  313.             // If the path does not start with the locale, redirect by adding the locale
  314.             $newUrl = '/' . $locale . $pathInfo;
  315.             //dd($newUrl);
  316.             $response = new RedirectResponse($newUrl);
  319.             
  320.             
  321.         
  322.         if (strpos($request->attributes->get("_controller"), 'web_profiler')  !== false)  {
  324.             return;
  325.         } else {
  326.             
  327.             $event->setResponse($response);
  328.         }
  330.        
  331.     }
  332.       
  333.             
  334.         
  335.             
  337.             
  338.         
  341.         // Check if the requested locale is in the allowed locales
  342.         
  343.         if (!in_array($request->getLocale(), ["en","ar","fr"])) {
  344.             // Set a default locale if the requested locale is not allowed
  345.             $request->setLocale('en'); // Set your default locale here
  346.             $response = new RedirectResponse('/'.$request->getLocale());
  347.             $event->setResponse($response);
  348.         }
  349.         
  350.         
  351.         
  355.         
  356.        
  359.     }
  362. }