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

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 Drosalys\Bundle\ApiBundle\Routing\Attributes\AbstractRoute;
  27. use Psr\EventDispatcher\EventDispatcherInterface;
  28. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  29. use Symfony\Component\HttpFoundation\Request;
  30. use Symfony\Component\HttpFoundation\Response;
  31. use Symfony\Component\HttpKernel\Event\ViewEvent;
  32. use Symfony\Component\HttpKernel\KernelEvents;
  34. /**
  35.  * Class ActionResponseSubscriber
  36.  *
  37.  * @author Benjamin Georgeault
  38.  */
  39. class ActionResponseSubscriber implements EventSubscriberInterface
  40. {
  41.     use ActionRequestTrait;
  43.     /**
  44.      * ActionResponseSubscriber constructor.
  45.      * @param ResponseHandlerInterface[] $responseHandlers
  46.      * @param PersisterHandlerInterface[] $persisterHandlers
  47.      */
  48.     public function __construct(
  49.         private EventDispatcherInterface $dispatcher,
  50.         private iterable $responseHandlers,
  51.         private iterable $persisterHandlers,
  52.     ) {
  53.     }
  55.     public static function getSubscribedEvents(): array
  56.     {
  57.         return [
  58.             KernelEvents::VIEW => ['__invoke', 63],
  59.         ];
  60.     }
  62.     public function __invoke(ViewEvent $event): void
  63.     {
  64.         if (null === $action = $this->retrieveActionFromRequest($request = $event->getRequest())) {
  65.             return;
  66.         }
  68.         $this->applyPersister($action, $request, $data = $event->getControllerResult());
  69.         if (null !== $response = $this->buildResponse($action, $request, $data)) {
  70.             $event->setResponse($response);
  71.         }
  72.     }
  74.     private function buildResponse(Action $action, Request $request, mixed $data): ?Response
  75.     {
  76.         if ((null !== $info = $action->getBuildResponseInfo()) && ($info->hasReplace())) {
  77.             return ($info->getReplace())(new ReplaceBuildResponseEvent($action, $request, $data));
  78.         }
  80.         foreach ($this->responseHandlers as $handler) {
  81.             if ($handler->support($action, $request, $data)) {
  82.                 if ((null !== $info = $action->getBuildResponseInfo()) && ($info->hasPre())) {
  83.                     ($info->getPre())(new PreBuildResponseEvent($action, $request, $data));
  84.                 }
  86.                 $this->dispatcher->dispatch(new PreBuildResponseEvent($action, $request, $data));
  88.                 $response = $handler->buildResponse($action, $request, $data);
  90.                 if ((null !== $info) && ($info->hasPost())) {
  91.                     ($info->getPost())(new PostBuildResponseEvent($action, $request, $data, $response));
  92.                 }
  94.                 $this->dispatcher->dispatch(new PostBuildResponseEvent($action, $request, $data, $response));
  96.                 return $response;
  97.             }
  98.         }
  100.         return null;
  101.     }
  103.     private function applyPersister(Action $action, Request $request, mixed $data): void
  104.     {
  105.         if ($request->attributes->has(DeserializeActionControllerSubscriber::REQUEST_ERROR_KEY)) {
  106.             return;
  107.         }
  109.         if ((null !== $info = $action->getPersistInfo()) && ($info->hasReplace())) {
  110.             ($info->getReplace())(new ReplacePersistEvent($action, $request, $data));
  111.             return;
  112.         }
  114.         if (null === $action->getDeserializeInfo() && $action->getMethod() !== AbstractRoute::DELETE) {
  115.             return;
  116.         }
  118.         foreach ($this->persisterHandlers as $handler) {
  119.             if ($handler->support($action, $request, $data)) {
  120.                 if ((null !== $info) && ($info->hasPre())) {
  121.                     ($info->getPre())(new PrePersistEvent($action, $request, $data));
  122.                 }
  124.                 $this->dispatcher->dispatch(new PrePersistEvent($action, $request, $data));
  126.                 $handler->persist($action, $request, $data);
  128.                 if ((null !== $info) && ($info->hasPost())) {
  129.                     ($info->getPost())(new PostPersistEvent($action, $request, $data));
  130.                 }
  132.                 $this->dispatcher->dispatch(new PostPersistEvent($action, $request, $data));
  134.                 break;
  135.             }
  136.         }
  137.     }
  138. }