src/Component/Stats/Event/Listener/StatisticsListener.php line 45

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace BitBag\OpenMarketplace\Component\Stats\Event\Listener;
  7. use BitBag\OpenMarketplace\Component\Channel\Entity\ChannelInterface;
  8. use BitBag\OpenMarketplace\Component\Stats\Assigner\VendorToAnalyticsAssigner;
  9. use BitBag\OpenMarketplace\Component\Stats\Checker\ExcludedRoutesCheckerInterface;
  10. use BitBag\OpenMarketplace\Component\Stats\Entity\AnalyticsInterface;
  11. use BitBag\OpenMarketplace\Component\Stats\Entity\StatisticsInterface;
  12. use BitBag\OpenMarketplace\Component\Stats\Factory\AnalyticsFactoryInterface;
  13. use BitBag\OpenMarketplace\Component\Stats\Factory\CrawlerDetect\CrawlerDetectFactoryInterface;
  14. use BitBag\OpenMarketplace\Component\Stats\Factory\StatisticsFactoryInterface;
  15. use BitBag\OpenMarketplace\Component\Stats\Handler\ImpressionsStatisticsAndAnalyticsHandler;
  16. use BitBag\OpenMarketplace\Component\Stats\Repository\AnalyticsRepositoryInterface;
  17. use BitBag\OpenMarketplace\Component\Stats\Resolver\UserCountryByUserIPResolver;
  18. use Doctrine\ORM\EntityManagerInterface;
  19. use Psr\Log\LoggerInterface;
  20. use Sylius\Component\Channel\Context\ChannelContextInterface;
  21. use Symfony\Component\HttpKernel\Event\TerminateEvent;
  23. final class StatisticsListener
  24. {
  25.     private AnalyticsInterface $analytics;
  27.     private StatisticsInterface $statistics;
  29.     public function __construct(
  30.         private EntityManagerInterface $analyticsManager,
  31.         private AnalyticsRepositoryInterface $analyticsRepository,
  32.         private LoggerInterface $logger,
  33.         private ChannelContextInterface $channelContext,
  34.         private ImpressionsStatisticsAndAnalyticsHandler $impressionsStatisticsAndAnalyticsHandler,
  35.         private VendorToAnalyticsAssigner $vendorToAnalyticsAssigner,
  36.         private UserCountryByUserIPResolver $userCountryByUserIPResolver,
  37.         private ExcludedRoutesCheckerInterface $excludedRoutesChecker,
  38.         private AnalyticsFactoryInterface $analyticsFactory,
  39.         private StatisticsFactoryInterface $statisticsFactory,
  40.         private CrawlerDetectFactoryInterface $crawlerDetectFactory,
  41.         private string $excludedIps,
  42.         ) {
  43.     }
  45.     public function onKernelTerminate(TerminateEvent $event): void
  46.     {
  47.         if ($this->isCrawler()) {
  48.             return;
  49.         }
  51.         $request = $event->getRequest();
  53.         $excludedIps = explode(',', $this->excludedIps);
  54.         if (in_array($request->getClientIp(), $excludedIps)) {
  55.             return;
  56.         }
  58.         if (!$event->isMainRequest()
  59.             || $this->excludedRoutesChecker->shouldSkipRequest($request)) {
  60.             return;
  61.         }
  63.         $route = $request->attributes->get('_route');
  64.         $localeFromRequest = $request->getLocale();
  66.         $url = mb_substr($request->getUri(), 0, 254);
  68.         $this->statistics = $this->statisticsFactory->createStatistics(
  69.             (string) $request->getClientIp(),
  70.             $url,
  71.             (string) $request->headers->get('referer'),
  72.             $localeFromRequest
  73.         );
  75.         /** @var AnalyticsInterface|null $existingAnalytics */
  76.         $existingAnalytics = $this->analyticsRepository->findOneBy(['url' => $url]);
  78.         if (null === $existingAnalytics) {
  79.             $this->analytics = $this->analyticsFactory->createAnalytics(
  80.                 $url,
  81.                 $route,
  82.                 $request->attributes->get('slug'),
  83.                 $localeFromRequest
  84.             );
  85.         } else {
  86.             $this->analytics = $existingAnalytics;
  87.         }
  89.         $request = $event->getRequest();
  90.         if ('sylius_shop_product_show' === $route) {
  91.             $slug = $request->attributes->get('slug');
  93.             /** @var ChannelInterface $channel */
  94.             $channel = $this->channelContext->getChannel();
  96.             $localeCode = $localeFromRequest;
  98.             $this->vendorToAnalyticsAssigner->assignVendorToAnalyticsByProductSlug(
  99.                 $this->analytics,
  100.                 $channel,
  101.                 $localeCode,
  102.                 $slug
  103.             );
  104.         } elseif ('bitbag_sylius_elasticsearch_plugin_shop_list_products' === $route) {
  105.             $locale = $request->getLocale();
  106.             $clientIp = (string) $request->getClientIp();
  108.             $this->impressionsStatisticsAndAnalyticsHandler->handleImpressionsStatisticsAndAnalytics(
  109.                 $locale,
  110.                 $clientIp
  111.             );
  112.         }
  113.         $this->statistics->setUserCountry(
  114.             $this->userCountryByUserIPResolver->getUserCountryByIP(
  115.                 (string) $request->getClientIp()
  116.             )
  117.         );
  119.         $this->persistAndFlushAnalyticsAndStatistics();
  120.     }
  122.     private function persistAndFlushAnalyticsAndStatistics(): void
  123.     {
  124.         try {
  125.             $this->statistics->setAnalytics($this->analytics);
  126.             $this->analytics->addStatistic($this->statistics);
  127.             $this->analyticsManager->persist($this->analytics);
  128.             $this->analyticsManager->flush();
  129.         } catch (\Throwable $exception) {
  130.             $this->logger->error($exception->getMessage());
  131.         }
  132.     }
  134.     private function isCrawler(): bool
  135.     {
  136.         return $this->crawlerDetectFactory->createNew()->isCrawler();
  137.     }
  138. }