src/Aqarmap/Bundle/CRMBundle/EventListener/CRMLeadListener.php line 63

Open in your IDE?
  1. <?php
  3. namespace Aqarmap\Bundle\CRMBundle\EventListener;
  5. use App\Exception\LogicHttpException;
  6. use Aqarmap\Bundle\FeatureToggleBundle\Service\FeatureToggleManager;
  7. use Aqarmap\Bundle\ListingBundle\Event\LeadEvent;
  8. use Aqarmap\Bundle\ListingBundle\Service\LeadsCRMService;
  9. use Aqarmap\Bundle\NotificationBundle\Types\LeadGenerated;
  10. use Doctrine\ORM\EntityManagerInterface;
  11. use Psr\Log\LoggerInterface;
  12. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class CRMLeadListener implements EventSubscriberInterface
  16. {
  17.     /**
  18.      * @var EntityManagerInterface
  19.      */
  20.     protected $em;
  22.     /**
  23.      * @var EventDispatcherInterface
  24.      */
  25.     protected $dispatcher;
  27.     /**
  28.      * @var FeatureToggleManager
  29.      */
  30.     protected $featuresToggleManager;
  32.     /**
  33.      * @var LeadsCRMService
  34.      */
  35.     private $leadsCRMService;
  37.     /**
  38.      * @var LoggerInterface
  39.      */
  40.     private $logger;
  42.     /**
  43.      * @var LeadGenerated
  44.      */
  45.     private $leadGenerated;
  47.     public function __construct(
  48.         EntityManagerInterface $em,
  49.         EventDispatcherInterface $dispatcher,
  50.         FeatureToggleManager $featuresToggleManager,
  51.         LeadsCRMService $leadsCRMService,
  52.         LoggerInterface $logger,
  53.         LeadGenerated $leadGenerated
  54.     ) {
  55.         $this->em = $em;
  56.         $this->dispatcher = $dispatcher;
  57.         $this->featuresToggleManager = $featuresToggleManager;
  58.         $this->leadsCRMService = $leadsCRMService;
  59.         $this->logger = $logger;
  60.         $this->leadGenerated = $leadGenerated;
  61.     }
  63.     public function onAddLead(LeadEvent $event): void
  64.     {
  65.         $listing = $event->getListing();
  67.         if ($this->featuresToggleManager->isEnabled('web.leads.crm.sync')) {
  68.             try {
  69.                 $this->leadsCRMService->sendLead($listing, $event->getLead());
  70.             } catch (LogicHttpException $e) {
  71.                 $this->logger->info(sprintf('CRM Lead Listener: %s', $e->getMessage()));
  72.             } catch (\Exception $e) {
  73.                 $this->logger->error(sprintf('CRM Lead Listener: %s', $e->getMessage()));
  74.             }
  75.         }
  77.         if ($this->featuresToggleManager->isEnabled('web.leads.generate.mail')) {
  78.             $this->dispatcher->dispatch($this->leadGenerated->setSubject($event->getLead()), 'lead.generated');
  79.         }
  80.     }
  82.     public static function getSubscribedEvents()
  83.     {
  84.         return [
  85.             'aqarmap.listing.lead.add' => ['onAddLead'],
  86.         ];
  87.     }
  88. }