src/EventSubscriber/AlertEventSubscriber.php line 38

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use ApiPlatform\Core\EventListener\EventPriorities;
  6. use App\Entity\Alert;
  7. use App\Entity\TheProperty;
  8. use App\Message\AlertMessage;
  9. use App\Message\ShowInterestMessage;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\HttpFoundation\Request;
  12. use Symfony\Component\HttpKernel\Event\ViewEvent;
  13. use Symfony\Component\HttpKernel\KernelEvents;
  14. use Symfony\Component\Messenger\MessageBusInterface;
  16. class AlertEventSubscriber implements EventSubscriberInterface
  17. {
  18.     /**
  19.      * @var MessageBusInterface
  20.      */
  21.     private $messageBus;
  23.     public function __construct(MessageBusInterface $messageBus)
  24.     {
  25.         $this->messageBus = $messageBus;
  26.     }
  28.     /**
  29.      * @return array<string, mixed>
  30.      */
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             KernelEvents::VIEW => ['alert', EventPriorities::POST_WRITE],
  35.         ];
  36.     }
  38.     public function alert(ViewEvent $event): void
  39.     {
  40.         $object = $event->getControllerResult();
  42.         if ($object instanceof Alert && $object->getAddress() != null) {
  43.             $this->messageBus->dispatch(new ShowInterestMessage($object->getId()));
  44.         } elseif ($object instanceof TheProperty) {
  45.             if ($event->getRequest()->isMethod(Request::METHOD_PUT)) {
  46.                 $this->messageBus->dispatch(new AlertMessage($object->getId(), true));
  47.             } elseif ($event->getRequest()->isMethod(Request::METHOD_POST)) {
  48.                 $this->messageBus->dispatch(new AlertMessage($object->getId()));
  49.             }
  50.         }
  51.     }
  52. }