<?php
namespace App\EventSubscriber;
use ApiPlatform\Core\EventListener\EventPriorities;
use App\Entity\Modality;
use App\Message\CreateInsurerLimitsByModality;
use App\Message\UpdateInsurerLimitsByModality;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\HttpFoundation\Request;
// use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
use Symfony\Component\HttpKernel\Event\ViewEvent;
use Symfony\Component\HttpKernel\KernelEvents;
use Symfony\Component\Messenger\MessageBusInterface;
// use App\Entity\User;
final class ModalitySubscriber implements EventSubscriberInterface
{
public function __construct(
// TokenStorageInterface $tokenStorage,
MessageBusInterface $messageBus,
) {
// $this->tokenStorage = $tokenStorage;
$this->messageBus = $messageBus;
}
public static function getSubscribedEvents(): array
{
return [
KernelEvents::VIEW => [
['createInsurerLimits', EventPriorities::POST_WRITE],
['updateInsurerLimits', EventPriorities::POST_WRITE],
],
];
}
public function createInsurerLimits(ViewEvent $event): void
{
$modality = $event->getControllerResult();
$method = $event->getRequest()->getMethod();
if (!$modality instanceof Modality || Request::METHOD_POST !== $method) {
return;
}
// $token = $this->tokenStorage->getToken();
// if (!$token) {
// return;
// }
// $user = $token->getUser();
// if (!$user instanceof User) {
// return;
// }
$message = new CreateInsurerLimitsByModality();
$message->setModalityId($modality->getId());
$this->messageBus->dispatch($message);
}
public function updateInsurerLimits(ViewEvent $event): void
{
$modality = $event->getControllerResult();
$method = $event->getRequest()->getMethod();
if (!$modality instanceof Modality || Request::METHOD_PUT !== $method) {
return;
}
// $token = $this->tokenStorage->getToken();
// if (!$token) {
// return;
// }
// $user = $token->getUser();
// if (!$user instanceof User) {
// return;
// }
$message = new UpdateInsurerLimitsByModality();
$message->setModalityId($modality->getId());
$this->messageBus->dispatch($message);
}
}