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

  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 UnitOfWork */
  17. private $unitOfWork;
  19. public function __construct(private readonly ListingRateService $listingRateService, EntityManagerInterface $entityManager, private readonly ListingLabelQueueProducer $listingLabelQueueProducer, private readonly MessageBusInterface $messageBus)
  20. {
  21. $this->unitOfWork = $entityManager->getUnitOfWork();
  22. }
  24. public function postUpdate($listing, $event): void
  25. {
  26. $this->messageBus->dispatch(new ListingUpdatedMessage($listing->getId()));
  28. $this->unitOfWork->computeChangeSets();
  29. $changedFields = $this->unitOfWork->getEntityChangeSet($listing);
  30. $this->listingLabelQueueProducer->publish($listing, array_keys($changedFields));
  31. }
  33. public function onUpdate(ListingUpdatedEvent $event): void
  34. {
  35. $this->listingRateService->markRateStatusUpdated($event->getListing(), $event->getFields());
  36. }
  38. /**
  39. * {@inheri tdoc}.
  40. */
  41. public static function getSubscribedEvents(): array
  42. {
  43. return [
  44. ListingUpdatedEvent::UPDATED => 'onUpdate',
  45. ];
  46. }
  47. }