src/EventSubscriber/WebmasterReferenceRequestSubscriber.php line 46

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Service\Client\Webmaster\WebmasterTrafficService;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Symfony\Component\HttpFoundation\RedirectResponse;
  8. use Symfony\Component\HttpFoundation\Request;
  9. use Symfony\Component\HttpKernel\Event\RequestEvent;
  10. use Symfony\Component\HttpKernel\KernelEvents;
  12. class WebmasterReferenceRequestSubscriber implements EventSubscriberInterface
  13. {
  14.     const SESSION_KEY = 'webmaster_reference';
  16.     /**
  17.      * @var WebmasterTrafficService
  18.      */
  19.     protected WebmasterTrafficService $trafficService;
  21.     /**
  22.      * @param WebmasterTrafficService $trafficService+
  23.      */
  24.     public function __construct(WebmasterTrafficService $trafficService)
  25.     {
  26.         $this->trafficService = $trafficService;
  27.     }
  29.     public static function getSubscribedEvents(): array
  30.     {
  31.         return [
  32.             KernelEvents::REQUEST => [
  33.                 ['onKernelRequest', 1],
  34.             ],
  35.         ];
  36.     }
  38.     /**
  39.      * @param RequestEvent $event
  40.      * @return void
  41.      * @throws \Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface
  42.      * @throws \Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface
  43.      * @throws \Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface
  44.      * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
  45.      */
  46.     public function onKernelRequest(RequestEvent $event)
  47.     {
  48.         $request = $event->getRequest();
  49.         if(!$event->isMainRequest() || !$request->isMethod('GET')) {
  50.             return;
  51.         }
  52.         $param = $request->query->get('wmid', $request->query->get('c', ''));
  53.         $campaignId = null;
  54.         $webmasterId = null;
  55.         if (preg_match('/6[0-9]{6}/', $param)) {
  56.             $webmasterId = $param;
  57.         } else {
  58.             $dec = base64_decode($param);
  60.             if (preg_match('/^([0-9]+)\|(6[0-9]{6})$/', $dec, $matches)) {
  61.                 $campaignId = $matches[1];
  62.                 $webmasterId = $matches[2];
  63.             } elseif (preg_match('/^(6[0-9]{6})\|([0-9]+)$/', $dec, $matches)) {
  64.                 $webmasterId = $matches[1];
  65.                 $campaignId = $matches[2];
  66.             }
  67.         }
  68.         if($webmasterId) {
  69.             if ($refererUrl = $request->server->get('HTTP_REFERER')) {
  70.                 $referer = parse_url($refererUrl);
  71.                 $refererHost = $referer['host'] ?? null;
  72.             }
  74.             $referenceData = [
  75.                 'webmaster_id' => $webmasterId,
  76.                 'campaign_id' => $campaignId,
  77.                 'tracking_id' => (string) $request->query->get('trackingId')
  78.             ];
  79.             $request->getSession()->set(self::SESSION_KEY, $referenceData);
  81.             $this->trafficService->createWebmasterTraffic((int)$webmasterId, [
  82.                 // required in api
  83.                 'http_request_uri' => $request->getRequestUri(),
  84.                 'client_ip' => $request->server->get('HTTP_X_FORWARDED_FOR', $request->getClientIp()),
  86.                 // optional in api
  87.                 'referer_host' => $refererHost ?? null,
  88.                 'referer_url' => $refererUrl,
  89.                 'campaign_id' => $campaignId
  90.             ]);
  92.             $event->setResponse($this->redirectToNonReferenceUrl($request));
  93.         }
  94.     }
  96.     /**
  97.      * @param Request $request
  98.      * @return RedirectResponse
  99.      */
  100.     protected function redirectToNonReferenceUrl(Request $request): RedirectResponse
  101.     {
  102.         $parameters = array();
  103.         foreach ($request->query->all() as $key => $val) {
  104.             if ($key != 'wmid' && $key != 'c') {
  105.                 $parameters[$key] = $val;
  106.             }
  107.         }
  108.         $url = $request->getPathInfo();
  109.         if ($queryString = http_build_query($parameters)) {
  110.             $url .= '?' . $queryString;
  111.         }
  112.         $baseUrl = $request->getBaseUrl();
  113.         if ($baseUrl && $baseUrl != '/') {
  114.             $url = $baseUrl . $url;
  115.         }
  116.         return new RedirectResponse($url);
  117.     }
  118. }