src/Aqarmap/Bundle/ListingBundle/EventListener/SearchKeywordHistorySubscriber.php line 51

Open in your IDE?
  1. <?php
  3. namespace Aqarmap\Bundle\ListingBundle\EventListener;
  5. use Aqarmap\Bundle\ListingBundle\Event\SearchTriggerEvent;
  6. use Aqarmap\Bundle\MainBundle\Constant\ProducerQueues;
  7. use Aqarmap\Bundle\MainBundle\Contract\ProducerFactoryInterface;
  8. use Aqarmap\Bundle\MainBundle\Service\MobileDetectionService;
  9. use Aqarmap\Bundle\SearchBundle\Constant\SearchKeywordConstant;
  10. use Psr\Log\LoggerInterface;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpFoundation\Request;
  14. class SearchKeywordHistorySubscriber implements EventSubscriberInterface
  15. {
  16.     /**
  17.      * @var ProducerFactoryInterface
  18.      */
  19.     private $producer;
  21.     private $source;
  23.     private $searchKeyword;
  25.     /**
  26.      * @var MobileDetectionService
  27.      */
  28.     private $mobileService;
  30.     /**
  31.      * @var LoggerInterface
  32.      */
  33.     private $logger;
  35.     /**
  36.      * SearchKeywordHistorySubscriber constructor.
  37.      */
  38.     public function __construct(
  39.         ProducerFactoryInterface $producerFactory,
  40.         MobileDetectionService $mobileService,
  41.         LoggerInterface $logger
  42.     ) {
  43.         $this->producer = $producerFactory->create(ProducerQueues::RECORD_KEYWORD_SEARCH_HISTORY);
  44.         $this->mobileService = $mobileService;
  45.         $this->logger = $logger;
  46.     }
  48.     /**
  49.      * Producer.
  50.      */
  51.     public function onSearchKeyword(SearchTriggerEvent $searchTriggerEvent): void
  52.     {
  53.         try {
  54.             $this->setSource($searchTriggerEvent->getRequest());
  55.             $this->setSearchKeyword($searchTriggerEvent->getRequest());
  57.             if (!empty($this->getSearchKeyword())) {
  58.                 $this
  59.                     ->producer
  60.                     ->publish(serialize([
  61.                         'searchKeyword' => $this->getSearchKeyword(),
  62.                         'userAgentOS' => $this->getSource(),
  63.                     ]))
  64.                 ;
  65.             }
  66.         } catch (\Exception $e) {
  67.             $this->logger->info($e->getMessage());
  68.         }
  69.     }
  71.     /**
  72.      * @param int
  73.      */
  74.     public function getSource()
  75.     {
  76.         return $this->source;
  77.     }
  79.     /**
  80.      * @param string
  81.      */
  82.     public function setSource(Request $request): self
  83.     {
  84.         $userAgent = $request->cookies->get('user-agent');
  85.         if (!$userAgent) {
  86.             $userAgent = $request->headers->get('user-agent');
  87.         }
  89.         $userAgentInfo = $this->mobileService->getInfo($userAgent);
  91.         switch ($userAgentInfo['os']) {
  92.             case SearchKeywordConstant::IOS_USER_AGENT_LABEL:
  93.                 $this->source = SearchKeywordConstant::IOS_USER_AGENT;
  94.                 break;
  96.             case SearchKeywordConstant::ANDROID_USER_AGENT_LABEL:
  97.                 $this->source = SearchKeywordConstant::ANDROID_USER_AGENT;
  98.                 break;
  100.             default:
  101.                 $this->source = SearchKeywordConstant::WEB_USER_AGENT;
  102.                 break;
  103.         }
  105.         return $this;
  106.     }
  108.     /**
  109.      * @param string
  110.      */
  111.     public function getSearchKeyword()
  112.     {
  113.         return $this->searchKeyword;
  114.     }
  116.     public function setSearchKeyword(Request $request): self
  117.     {
  118.         $this->searchKeyword = trim((string) $request->query->get('keywordSearch'));
  120.         return $this;
  121.     }
  123.     /**
  124.      * @return array
  125.      */
  126.     public static function getSubscribedEvents()
  127.     {
  128.         return [
  129.             SearchTriggerEvent::class => 'onSearchKeyword',
  130.         ];
  131.     }
  132. }