src/EventSubscriber/InsuredSubmitInsurersSubscriber.php line 35

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use ApiPlatform\Core\EventListener\EventPriorities;
  6. use App\Entity\InsuredSubmitInsurers;
  7. use App\Message\SendInsuredSubmitInsurers;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\HttpFoundation\Request;
  10. // use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  11. use Symfony\Component\HttpKernel\Event\ViewEvent;
  12. use Symfony\Component\HttpKernel\KernelEvents;
  13. use Symfony\Component\Messenger\MessageBusInterface;
  14. // use App\Entity\User;
  16. final class InsuredSubmitInsurersSubscriber implements EventSubscriberInterface
  17. {
  18.     public function __construct(
  19.         // TokenStorageInterface $tokenStorage,
  20.         MessageBusInterface $messageBus,
  21.     ) {
  22.         // $this->tokenStorage = $tokenStorage;
  23.         $this->messageBus = $messageBus;
  24.     }
  26.     public static function getSubscribedEvents(): array
  27.     {
  28.         return [
  29.             KernelEvents::VIEW => [
  30.                 ['sendInsuredSubmitInsurers', EventPriorities::POST_WRITE],
  31.             ],
  32.         ];
  33.     }
  35.     public function sendInsuredSubmitInsurers(ViewEvent $event): void
  36.     {
  37.         $insuredSubmitInsurers = $event->getControllerResult();
  38.         $method = $event->getRequest()->getMethod();
  40.         if (!$insuredSubmitInsurers instanceof InsuredSubmitInsurers || Request::METHOD_POST !== $method) {
  41.             return;
  42.         }
  44.         // $token = $this->tokenStorage->getToken();
  45.         // if (!$token) {
  46.         //     return;
  47.         // }
  49.         // $user = $token->getUser();
  50.         // if (!$user instanceof User) {
  51.         //     return;
  52.         // }
  54.         $message = new SendInsuredSubmitInsurers();
  55.         $message->setInsuredSubmitInsurersId($insuredSubmitInsurers->getId());
  56.         $this->messageBus->dispatch($message);
  57.     }
  58. }