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. }