src/EventSubscriber/TrackingInfoSubscriber.php line 68

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\User;
  6. use App\Entity\UserInterface;
  7. use App\Event\ObjectEvent;
  8. use App\Events;
  9. use Doctrine\Persistence\ManagerRegistry;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\HttpFoundation\Exception\SessionNotFoundException;
  12. use Symfony\Component\HttpFoundation\RequestStack;
  13. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  14. use Symfony\Component\HttpKernel\Event\RequestEvent;
  15. use Symfony\Component\HttpKernel\KernelEvents;
  17. /**
  18.  * Tracking information used for marketing.
  19.  */
  20. class TrackingInfoSubscriber implements EventSubscriberInterface
  21. {
  22.     public const SESSION_NAME = 'app_tracking_info';
  24.     /** @var RequestStack */
  25.     private $requestStack;
  27.     /** @var ManagerRegistry */
  28.     private $managerRegistry;
  30.     /**
  31.      * @param RequestStack    $requestStack
  32.      * @param ManagerRegistry $managerRegistry
  33.      */
  34.     public function __construct(RequestStack $requestStack, ManagerRegistry $managerRegistry)
  35.     {
  36.         $this->requestStack = $requestStack;
  37.         $this->managerRegistry = $managerRegistry;
  38.     }
  40.     /**
  41.      * {@inheritdoc}
  42.      */
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             KernelEvents::REQUEST => 'onKernelRequest',
  47.             Events::USER_CREATED => 'onUserCreated',
  48.         ];
  49.     }
  51.     /**
  52.      * @param RequestEvent $event
  53.      */
  54.     public function onKernelRequest(RequestEvent $event): void
  55.     {
  56.         if (!$event->isMainRequest()) {
  57.             return;
  58.         }
  60.         $request = $event->getRequest();
  62.         if ($request->isXmlHttpRequest()) {
  63.             return;
  64.         }
  66.         $session = $request->getSession();
  68.         if ($session->has(self::SESSION_NAME)) {
  69.             return;
  70.         }
  72.         $trackingInfo = [
  73.             'referer' => $request->headers->get('Referer'),
  74.             'ipAddress' => $request->getClientIp(),
  75.             'userAgent' => $request->headers->get('User-Agent'),
  76.         ];
  78.         // Loop through all query parameters and add those starting with "utm_"
  79.         foreach ($request->query->all() as $key => $value) {
  80.             if (0 === strpos($key, 'utm_')) {
  81.                 $trackingInfo[$key] = $value;
  82.             }
  83.         }
  85.         // Ignore requests from referrers with the same HTTP host
  86.         if (null !== $trackingInfo['referer'] && 0 === stripos($trackingInfo['referer'], $request->getSchemeAndHttpHost())) {
  87.             return;
  88.         }
  90.         $filteredTrackingInfo = array_filter($trackingInfo);
  92.         $session->set(self::SESSION_NAME, $filteredTrackingInfo);
  93.     }
  95.     /**
  96.      * @param ObjectEvent $event
  97.      */
  98.     public function onUserCreated(ObjectEvent $event): void
  99.     {
  100.         try {
  101.             /** @var SessionInterface $session */
  102.             $session = $this->requestStack->getSession();
  103.         } catch (SessionNotFoundException $e) {
  104.             return;
  105.         }
  107.         if (!$session->has(self::SESSION_NAME)) {
  108.             return;
  109.         }
  111.         $entity = $event->getObject();
  112.         $trackingInfo = $session->get(self::SESSION_NAME);
  114.         if ($entity instanceof UserInterface && !empty($trackingInfo)) {
  115.             $entity->setTrackingInfo($trackingInfo);
  117.             $this->managerRegistry
  118.                 ->getRepository(User::class)
  119.                 ->update($entity);
  120.         }
  122.         $session->remove(self::SESSION_NAME);
  123.     }
  124. }