vendor/drosalys/api-bundle/src/EventSubscriber/ActionResponseSubscriber.php line 61

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the drosalys/api-bundle package.
  5.  *
  6.  * (c) Benjamin Georgeault
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Drosalys\Bundle\ApiBundle\EventSubscriber;
  14. use Drosalys\Bundle\ApiBundle\Action\Action;
  15. use Drosalys\Bundle\ApiBundle\Action\Info\EventInfo;
  16. use Drosalys\Bundle\ApiBundle\Event\AbstractViewEvent;
  17. use Drosalys\Bundle\ApiBundle\Event\PostPersistEvent;
  18. use Drosalys\Bundle\ApiBundle\Event\PostBuildResponseEvent;
  19. use Drosalys\Bundle\ApiBundle\Event\PrePersistEvent;
  20. use Drosalys\Bundle\ApiBundle\Event\PreBuildResponseEvent;
  21. use Drosalys\Bundle\ApiBundle\Event\ReplaceBuildResponseEvent;
  22. use Drosalys\Bundle\ApiBundle\Event\ReplacePersistEvent;
  23. use Drosalys\Bundle\ApiBundle\Persister\PersisterHandler\PersisterHandlerInterface;
  24. use Drosalys\Bundle\ApiBundle\Request\ActionRequestTrait;
  25. use Drosalys\Bundle\ApiBundle\Response\ResponseHandler\ResponseHandlerInterface;
  26. use Psr\EventDispatcher\EventDispatcherInterface;
  27. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  28. use Symfony\Component\HttpFoundation\Request;
  29. use Symfony\Component\HttpFoundation\Response;
  30. use Symfony\Component\HttpKernel\Event\ViewEvent;
  31. use Symfony\Component\HttpKernel\KernelEvents;
  33. /**
  34.  * Class ActionResponseSubscriber
  35.  *
  36.  * @author Benjamin Georgeault
  37.  */
  38. class ActionResponseSubscriber implements EventSubscriberInterface
  39. {
  40.     use ActionRequestTrait;
  42.     /**
  43.      * ActionResponseSubscriber constructor.
  44.      * @param ResponseHandlerInterface[] $responseHandlers
  45.      * @param PersisterHandlerInterface[] $persisterHandlers
  46.      */
  47.     public function __construct(
  48.         private EventDispatcherInterface $dispatcher,
  49.         private iterable $responseHandlers,
  50.         private iterable $persisterHandlers,
  51.     ) {
  52.     }
  54.     public static function getSubscribedEvents(): array
  55.     {
  56.         return [
  57.             KernelEvents::VIEW => ['__invoke', 63],
  58.         ];
  59.     }
  61.     public function __invoke(ViewEvent $event): void
  62.     {
  63.         if (null === $action = $this->retrieveActionFromRequest($request = $event->getRequest())) {
  64.             return;
  65.         }
  67.         $this->applyPersister($action, $request, $data = $event->getControllerResult());
  68.         if (null !== $response = $this->buildResponse($action, $request, $data)) {
  69.             $event->setResponse($response);
  70.         }
  71.     }
  73.     private function buildResponse(Action $action, Request $request, mixed $data): ?Response
  74.     {
  75.         if ((null !== $info = $action->getBuildResponseInfo()) && ($info->hasReplace())) {
  76.             return ($info->getReplace())(new ReplaceBuildResponseEvent($action, $request, $data));
  77.         }
  79.         foreach ($this->responseHandlers as $handler) {
  80.             if ($handler->support($action, $request, $data)) {
  81.                 if ((null !== $info = $action->getBuildResponseInfo()) && ($info->hasPre())) {
  82.                     ($info->getPre())(new PreBuildResponseEvent($action, $request, $data));
  83.                 }
  85.                 $this->dispatcher->dispatch(new PreBuildResponseEvent($action, $request, $data));
  87.                 $response = $handler->buildResponse($action, $request, $data);
  89.                 if ((null !== $info) && ($info->hasPost())) {
  90.                     ($info->getPost())(new PostBuildResponseEvent($action, $request, $data, $response));
  91.                 }
  93.                 $this->dispatcher->dispatch(new PostBuildResponseEvent($action, $request, $data, $response));
  95.                 return $response;
  96.             }
  97.         }
  99.         return null;
  100.     }
  102.     private function applyPersister(Action $action, Request $request, mixed $data): void
  103.     {
  104.         if ($request->attributes->has(DeserializeActionControllerSubscriber::REQUEST_ERROR_KEY)) {
  105.             return;
  106.         }
  108.         if ((null !== $info = $action->getPersistInfo()) && ($info->hasReplace())) {
  109.             ($info->getReplace())(new ReplacePersistEvent($action, $request, $data));
  110.             return;
  111.         }
  113.         if (null === $action->getDeserializeInfo() && $action->getMethod() !== 'DELETE') {
  114.             return;
  115.         }
  117.         foreach ($this->persisterHandlers as $handler) {
  118.             if ($handler->support($action, $request, $data)) {
  119.                 if ((null !== $info) && ($info->hasPre())) {
  120.                     ($info->getPre())(new PrePersistEvent($action, $request, $data));
  121.                 }
  123.                 $this->dispatcher->dispatch(new PrePersistEvent($action, $request, $data));
  125.                 $handler->persist($action, $request, $data);
  127.                 if ((null !== $info) && ($info->hasPost())) {
  128.                     ($info->getPost())(new PostPersistEvent($action, $request, $data));
  129.                 }
  131.                 $this->dispatcher->dispatch(new PostPersistEvent($action, $request, $data));
  133.                 break;
  134.             }
  135.         }
  136.     }
  137. }