src/Aqarmap/Bundle/ListingBundle/EventListener/LocationSearchHistorySubscriber.php line 28

Open in your IDE?
  1. <?php
  3. namespace Aqarmap\Bundle\ListingBundle\EventListener;
  5. use Aqarmap\Bundle\ListingBundle\Event\LocationSearchHistoryEvent;
  6. use Aqarmap\Bundle\MainBundle\Constant\ProducerQueues;
  7. use Aqarmap\Bundle\MainBundle\Contract\ProducerFactoryInterface;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. /**
  11.  * Class LocationSearchHistorySubscriber.
  12.  */
  13. class LocationSearchHistorySubscriber implements EventSubscriberInterface
  14. {
  15.     /**
  16.      * @var ProducerFactoryInterface
  17.      */
  18.     private $producerFactory;
  20.     public function __construct(ProducerFactoryInterface $producerFactory)
  21.     {
  22.         $this->producerFactory = $producerFactory;
  23.     }
  25.     /**
  26.      * Producer.
  27.      */
  28.     public function onLocationSearch(LocationSearchHistoryEvent $locationSearchHistoryEvent): void
  29.     {
  30.         $locationKeyword = $locationSearchHistoryEvent->getLocationKeyword();
  32.         $this->producerFactory
  33.             ->create(ProducerQueues::RECORD_LOCATION_SEARCH_HISTORY)
  34.             ->publish(
  35.                 serialize(
  36.                     [
  37.                         'location_keyword' => $locationKeyword,
  38.                     ]
  39.                 )
  40.             )
  41.         ;
  43.         $locationSearchHistoryEvent->stopPropagation();
  44.     }
  46.     /**
  47.      * @return array
  48.      */
  49.     public static function getSubscribedEvents()
  50.     {
  51.         return [
  52.             LocationSearchHistoryEvent::CREATE => 'onLocationSearch',
  53.         ];
  54.     }
  55. }