src/Aqarmap/Bundle/ListingBundle/EventListener/ListingUpdatedListener.php line 43

Open in your IDE?
  1. <?php
  3. namespace Aqarmap\Bundle\ListingBundle\EventListener;
  5. use App\Message\ListingUpdatedMessage;
  6. use Aqarmap\Bundle\ListingBundle\Event\ListingUpdatedEvent;
  7. use Aqarmap\Bundle\ListingBundle\Service\ListingLabelQueueProducer;
  8. use Aqarmap\Bundle\ListingBundle\Service\ListingRateService;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use Doctrine\ORM\UnitOfWork;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\Messenger\MessageBusInterface;
  14. class ListingUpdatedListener implements EventSubscriberInterface
  15. {
  16.     /** @var ListingRateService */
  17.     private $listingRateService;
  19.     /** @var UnitOfWork */
  20.     private $unitOfWork;
  22.     /** @var ListingLabelQueueProducer */
  23.     private $listingLabelQueueProducer;
  24.     private MessageBusInterface $messageBus;
  26.     public function __construct(ListingRateService $listingRateService, EntityManagerInterface $entityManager, ListingLabelQueueProducer $listingLabelQueueProducer, MessageBusInterface $messageBus)
  27.     {
  28.         $this->listingRateService = $listingRateService;
  29.         $this->unitOfWork = $entityManager->getUnitOfWork();
  30.         $this->listingLabelQueueProducer = $listingLabelQueueProducer;
  31.         $this->messageBus = $messageBus;
  32.     }
  34.     public function postUpdate($listing, $event): void
  35.     {
  36.         $this->messageBus->dispatch(new ListingUpdatedMessage($listing->getId()));
  38.         $this->unitOfWork->computeChangeSets();
  39.         $changedFields = $this->unitOfWork->getEntityChangeSet($listing);
  40.         $this->listingLabelQueueProducer->publish($listing, array_keys($changedFields));
  41.     }
  43.     public function onUpdate(ListingUpdatedEvent $event): void
  44.     {
  45.         $this->listingRateService->markRateStatusUpdated($event->getListing(), $event->getFields());
  46.     }
  48.     /**
  49.      * {@inheri tdoc}.
  50.      */
  51.     public static function getSubscribedEvents()
  52.     {
  53.         return [
  54.             ListingUpdatedEvent::UPDATED => 'onUpdate',
  55.         ];
  56.     }
  57. }