src/EventSubscriber/InsurerSubscriber.php line 89

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use ApiPlatform\Core\EventListener\EventPriorities;
  6. use App\Entity\Insurer;
  7. use App\Message\CreateInsurerLimits;
  8. use App\Message\UpdateInsurerLimits;
  9. use App\Message\CreateInsuredLimitsByInsurer;
  10. use App\Message\UpdateInsuredLimitsByInsurer;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpFoundation\Request;
  13. // use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  14. use Symfony\Component\HttpKernel\Event\ViewEvent;
  15. use Symfony\Component\HttpKernel\KernelEvents;
  16. use Symfony\Component\Messenger\MessageBusInterface;
  17. // use App\Entity\User;
  19. final class InsurerSubscriber implements EventSubscriberInterface
  20. {
  21.     public function __construct(
  22.         // TokenStorageInterface $tokenStorage,
  23.         MessageBusInterface $messageBus,
  24.     ) {
  25.         // $this->tokenStorage = $tokenStorage;
  26.         $this->messageBus = $messageBus;
  27.     }
  29.     public static function getSubscribedEvents()
  30.     {
  31.         return [
  32.             KernelEvents::VIEW => [
  33.                 ['createInsurerLimits', EventPriorities::POST_WRITE],
  34.                 ['updateInsurerLimits', EventPriorities::POST_WRITE],
  35.                 ['createInsuredLimits', EventPriorities::POST_WRITE],
  36.                 ['updateInsuredLimits', EventPriorities::POST_WRITE],
  37.             ],
  38.         ];
  39.     }
  41.     public function createInsurerLimits(ViewEvent $event)
  42.     {
  43.         $insurer = $event->getControllerResult();
  44.         $method = $event->getRequest()->getMethod();
  46.         if (!$insurer instanceof Insurer || Request::METHOD_POST !== $method) {
  47.             return;
  48.         }
  50.         // $token = $this->tokenStorage->getToken();
  51.         // if (!$token) {
  52.         //     return;
  53.         // }
  55.         // $user = $token->getUser();
  56.         // if (!$user instanceof User) {
  57.         //     return;
  58.         // }
  60.         $message = new CreateInsurerLimits();
  61.         $message->setInsurerId($insurer->getId());
  62.         $this->messageBus->dispatch($message);
  63.     }
  65.     public function updateInsurerLimits(ViewEvent $event)
  66.     {
  67.         $insurer = $event->getControllerResult();
  68.         $method = $event->getRequest()->getMethod();
  70.         if (!$insurer instanceof Insurer || Request::METHOD_PUT !== $method) {
  71.             return;
  72.         }
  74.         // $token = $this->tokenStorage->getToken();
  75.         // if (!$token) {
  76.         //     return;
  77.         // }
  79.         // $user = $token->getUser();
  80.         // if (!$user instanceof User) {
  81.         //     return;
  82.         // }
  84.         $message = new UpdateInsurerLimits();
  85.         $message->setInsurerId($insurer->getId());
  86.         $this->messageBus->dispatch($message);
  87.     }
  89.     public function createInsuredLimits(ViewEvent $event)
  90.     {
  91.         $insurer = $event->getControllerResult();
  92.         $method = $event->getRequest()->getMethod();
  94.         if (!$insurer instanceof Insurer || Request::METHOD_POST !== $method) {
  95.             return;
  96.         }
  98.         // $token = $this->tokenStorage->getToken();
  99.         // if (!$token) {
  100.         //     return;
  101.         // }
  103.         // $user = $token->getUser();
  104.         // if (!$user instanceof User) {
  105.         //     return;
  106.         // }
  108.         $message = new CreateInsuredLimitsByInsurer();
  109.         $message->setInsurerId($insurer->getId());
  110.         $this->messageBus->dispatch($message);
  111.     }
  113.     public function updateInsuredLimits(ViewEvent $event)
  114.     {
  115.         $insurer = $event->getControllerResult();
  116.         $method = $event->getRequest()->getMethod();
  118.         if (!$insurer instanceof Insurer || Request::METHOD_PUT !== $method) {
  119.             return;
  120.         }
  122.         // $token = $this->tokenStorage->getToken();
  123.         // if (!$token) {
  124.         //     return;
  125.         // }
  127.         // $user = $token->getUser();
  128.         // if (!$user instanceof User) {
  129.         //     return;
  130.         // }
  132.         $message = new UpdateInsuredLimitsByInsurer();
  133.         $message->setInsurerId($insurer->getId());
  134.         $this->messageBus->dispatch($message);
  135.     }
  136. }