src/EventSubscriber/InsuredSubscriber.php line 61

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use ApiPlatform\Core\EventListener\EventPriorities;
  6. use App\Entity\Insured;
  7. use App\Message\CreateInsuredLimits;
  8. use App\Message\UpdateInsuredLimits;
  9. use App\Message\SendNewInsuredNotification;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\HttpFoundation\Request;
  12. // use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  13. use Symfony\Component\HttpKernel\Event\ViewEvent;
  14. use Symfony\Component\HttpKernel\KernelEvents;
  15. use Symfony\Component\Messenger\MessageBusInterface;
  17. // use App\Entity\User;
  19. final class InsuredSubscriber implements EventSubscriberInterface
  20. {
  21.     public function __construct(
  22.         // TokenStorageInterface $tokenStorage,
  23.         private readonly MessageBusInterface $messageBus
  24.     ) {}
  26.     public static function getSubscribedEvents(): array
  27.     {
  28.         return [
  29.             KernelEvents::VIEW => [
  30.                 ['createInsuredLimits', EventPriorities::POST_WRITE],
  31.                 ['updateInsuredLimits', EventPriorities::POST_WRITE],
  32.                 ['sendNewInsuredNotification', EventPriorities::POST_WRITE],
  33.             ],
  34.         ];
  35.     }
  37.     public function createInsuredLimits(ViewEvent $event): void
  38.     {
  39.         $insured = $event->getControllerResult();
  40.         $method = $event->getRequest()->getMethod();
  42.         if (!$insured instanceof Insured || Request::METHOD_POST !== $method) {
  43.             return;
  44.         }
  46.         // $token = $this->tokenStorage->getToken();
  47.         // if (!$token) {
  48.         //     return;
  49.         // }
  51.         // $user = $token->getUser();
  52.         // if (!$user instanceof User) {
  53.         //     return;
  54.         // }
  56.         $message = new CreateInsuredLimits();
  57.         $message->setInsuredId($insured->getId());
  58.         $this->messageBus->dispatch($message);
  59.     }
  61.     public function updateInsuredLimits(ViewEvent $event): void
  62.     {
  63.         $insured = $event->getControllerResult();
  64.         $method = $event->getRequest()->getMethod();
  66.         if (!$insured instanceof Insured || Request::METHOD_PUT !== $method) {
  67.             return;
  68.         }
  70.         // $token = $this->tokenStorage->getToken();
  71.         // if (!$token) {
  72.         //     return;
  73.         // }
  75.         // $user = $token->getUser();
  76.         // if (!$user instanceof User) {
  77.         //     return;
  78.         // }
  80.         $message = new UpdateInsuredLimits();
  81.         $message->setInsuredId($insured->getId());
  82.         $this->messageBus->dispatch($message);
  83.     }
  85.     public function sendNewInsuredNotification(ViewEvent $event): void
  86.     {
  87.         $insured = $event->getControllerResult();
  88.         $method = $event->getRequest()->getMethod();
  90.         if (!$insured instanceof Insured || Request::METHOD_POST !== $method) {
  91.             return;
  92.         }
  94.         // $token = $this->tokenStorage->getToken();
  95.         // if (!$token) {
  96.         //     return;
  97.         // }
  99.         // $user = $token->getUser();
  100.         // if (!$user instanceof User) {
  101.         //     return;
  102.         // }
  104.         $message = new SendNewInsuredNotification();
  105.         $message->setInsuredId($insured->getId());
  106.         $this->messageBus->dispatch($message);
  107.     }
  108. }