<?php
namespace App\EventSubscriber;
use ApiPlatform\Symfony\EventListener\EventPriorities as EventPrioritiesAlias;
use App\Entity\TheProperty;
use App\Message\AlertMessage;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpKernel\Event\ViewEvent;
use Symfony\Component\HttpKernel\KernelEvents;
use Symfony\Component\Messenger\MessageBusInterface;
class AlertEventSubscriber implements EventSubscriberInterface
{
/**
* @var MessageBusInterface
*/
private $messageBus;
public function __construct(MessageBusInterface $messageBus)
{
$this->messageBus = $messageBus;
}
/**
* @return array<string, mixed>
*/
public static function getSubscribedEvents(): array
{
return [
KernelEvents::VIEW => ['alert', EventPrioritiesAlias::POST_WRITE],
];
}
public function alert(ViewEvent $event): void
{
$object = $event->getControllerResult();
$request = $event->getRequest();
if (!$object instanceof TheProperty) {
return;
}
if (!$request->isMethod(Request::METHOD_POST) && !$request->isMethod(Request::METHOD_PUT)) {
return;
}
$this->messageBus->dispatch(new AlertMessage($object->getId()));
}
}