src/WellCommerce/Bundle/AppBundle/EventListener/RedirectSubscriber.php line 57

Open in your IDE?
  1. <?php
  3. declare(strict_types=0);
  4. /*
  5.  * WellCommerce Foundation
  6.  *
  7.  * This file is part of the WellCommerce package.
  8.  *
  9.  * (c) Adam Piotrowski <adam@wellcommerce.org>, Adrian Potepa <adrian@wellcommerce.org>
  10.  *
  11.  * For the full copyright and license information,
  12.  * please view the LICENSE file that was distributed with this source code.
  13.  */
  15. namespace WellCommerce\Bundle\AppBundle\EventListener;
  17. use Doctrine\ORM\QueryBuilder;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. use Symfony\Component\HttpFoundation\RedirectResponse;
  20. use Symfony\Component\HttpFoundation\Request;
  21. use Symfony\Component\HttpFoundation\Response;
  22. use Symfony\Component\HttpKernel\Event\RequestEvent;
  23. use Symfony\Component\HttpKernel\HttpKernelInterface;
  24. use Symfony\Component\HttpKernel\KernelEvents;
  25. use WellCommerce\Bundle\AppBundle\Entity\Redirect;
  26. use WellCommerce\Bundle\CoreBundle\DependencyInjection\AbstractServiceSubscriber;
  28. class RedirectSubscriber extends AbstractServiceSubscriber implements EventSubscriberInterface
  29. {
  30.     public static function getSubscribedEvents()
  31.     {
  32.         return [
  33.             KernelEvents::REQUEST => 'onKernelRequest',
  34.         ];
  35.     }
  37.     public function onKernelRequest(RequestEvent $event)
  38.     {
  39.         if ($event->getRequestType() == HttpKernelInterface::SUB_REQUEST) {
  40.             return;
  41.         }
  43.         if ($this->getRequestHelper()->isGraphQLRequest()) {
  44.             return;
  45.         }
  47.         if ($this->getSecurityHelper()->isActiveAdminFirewall()) {
  48.             return;
  49.         }
  51.         $request     = $event->getRequest();
  52.         $queryString = $request->getQueryString();
  53.         $repository  = $this->getEntityManager()->getRepository(Redirect::class);
  55.         if (false !== strpos($request->getRequestUri(), '/index.php')) {
  56.             $target   = str_replace('/index.php', '', $request->getRequestUri());
  57.             $response = new RedirectResponse($target, Response::HTTP_MOVED_PERMANENTLY);
  58.             $event->setResponse($response);
  59.             return;
  60.         }
  62.         if (!empty($queryString) && strlen($queryString) > 5 && false === strpos($queryString, 'utm')) {
  63.             $redirect = $repository->findOneBy(['source' => '?' . $queryString]);
  65.             if ($redirect instanceof Redirect) {
  66.                 $response = new RedirectResponse($redirect->getTarget(), $redirect->getStatus());
  67.                 $event->setResponse($response);
  68.             }
  69.         }
  71.         $forcedRedirect = $this->getForcedRedirect($request);
  73.         if ($forcedRedirect instanceof Redirect) {
  74.             $response = new RedirectResponse($forcedRedirect->getTarget(), $forcedRedirect->getStatus());
  75.             $event->setResponse($response);
  76.         }
  77.     }
  79.     public function getForcedRedirect(Request $request): ?Redirect
  80.     {
  81.         $path       = $request->getPathInfo();
  82.         $repository = $this->getEntityManager()->getRepository(Redirect::class);
  84.         /** @var QueryBuilder $queryBuilder */
  85.         $queryBuilder = $repository->createQueryBuilder('redirect');
  86.         $queryBuilder->andWhere('REGEXP(:path, redirect.source) = true');
  87.         $queryBuilder->andWhere($queryBuilder->expr()->eq('redirect.forced', true));
  88.         $queryBuilder->orderBy('redirect.hierarchy', 'ASC');
  89.         $queryBuilder->setMaxResults(1);
  90.         $queryBuilder->setParameter('path', $path);
  91.         $query  = $queryBuilder->getQuery();
  92.         $result = $query->getOneOrNullResult();
  94.         return $result;
  95.     }
  96. }