custom/plugins/WydnBackendStatistic/src/Storefront/Subscriber/StorefrontRenderSubscriber.php line 46

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace WydnBackendStatistic\Storefront\Subscriber;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  10. use Shopware\Core\Framework\Uuid\Uuid;
  11. use Shopware\Storefront\Event\StorefrontRenderEvent;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class StorefrontRenderSubscriber implements EventSubscriberInterface
  15. {
  16.     /** @var EntityRepository $sessionRepository */
  17.     private EntityRepository $sessionRepository;
  19.     /** @var Connection $connection */
  20.     private Connection $connection;
  22.     /**
  23.      * @param EntityRepository $sessionRepository
  24.      * @param Connection $connection
  25.      */
  26.     public function __construct(EntityRepository $sessionRepository, Connection $connection)
  27.     {
  28.         $this->sessionRepository = $sessionRepository;
  29.         $this->connection = $connection;
  30.     }
  32.     /**
  33.      * @return array[]
  34.      */
  35.     public static function getSubscribedEvents(): array
  36.     {
  37.         return [
  38.             StorefrontRenderEvent::class => ['onRender', -1],
  39.         ];
  40.     }
  42.     /**
  43.      * @param StorefrontRenderEvent $event
  44.      * @return void
  45.      */
  46.     public function onRender(StorefrontRenderEvent $event): void
  47.     {
  48.         // remove old sessions to avoid performance issues
  49.         $this->removeOldSessions(65); // 65 minutes
  51.         $session = $event->getRequest()->getSession();
  52.         $server = $event->getRequest()->server;
  54.         // exclude bots
  55.         if(empty($server->get('HTTP_USER_AGENT')) || stristr($server->get('HTTP_USER_AGENT'), 'Bot') !== false) {
  56.             return;
  57.         }
  59.         // cloudflare ip
  60.         $ip = $server->get('HTTP_CF_CONNECTING_IP');
  62.         if (empty($ip)) {
  63.             // forwarded ip
  64.             $ip = $server->get('HTTP_X_FORWARDED_FOR');
  65.             $ip = explode(', ', $ip);
  66.             $ip = reset ($ip);
  67.         }
  69.         if (empty($ip)) {
  70.             // default
  71.             $ip = $server->get('REMOTE_ADDR');
  72.         }
  74.         $criteria = new Criteria();
  75.         $criteria->addFilter(new MultiFilter(
  76.             MultiFilter::CONNECTION_OR,
  77.             [
  78.                 new EqualsFilter('ipHash', md5($ip)),
  79.                 new EqualsFilter('sessionId', $session->getId())
  80.             ]
  81.         ));
  83.         $sessionRequest = $this->sessionRepository->search($criteria, $event->getContext())->first();
  85.         $this->sessionRepository->upsert([
  86.             [
  87.                 'id' => ($sessionRequest != null ? $sessionRequest->getId() : Uuid::randomHex()),
  88.                 'sessionId' => $session->getId(),
  89.                 'ipHash' => md5($ip)
  90.             ]
  91.         ], $event->getContext());
  92.     }
  94.     /**
  95.      * @param int $maxTimeMinutes
  96.      * @return void
  97.      */
  98.     private function removeOldSessions(int $maxTimeMinutes = 5) : void
  99.     {
  100.         try {
  101.             $this->connection->executeStatement('DELETE FROM wydn_session_request 
  102.                 WHERE (created_at < DATE_SUB(:nowDate, INTERVAL :maxTime MINUTE) AND updated_at IS NULL) OR 
  103.                       (updated_at < DATE_SUB(:nowDate, INTERVAL :maxTime MINUTE) and updated_at IS NOT NULL)', [
  104.                 'maxTime' => $maxTimeMinutes,
  105.                 'nowDate' => (new \DateTime())->format('Y-m-d H:i:s')
  106.             ]);
  107.         } catch (\Exception $e) {
  108.             // do nothing
  109.         }
  110.     }
  111. }