vendor/overblog/graphql-bundle/src/Controller/GraphController.php line 48

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Overblog\GraphQLBundle\Controller;
  7. use Overblog\GraphQLBundle\Request\BatchParser;
  8. use Overblog\GraphQLBundle\Request\Executor;
  9. use Overblog\GraphQLBundle\Request\Parser;
  10. use Symfony\Component\HttpFoundation\JsonResponse;
  11. use Symfony\Component\HttpFoundation\Request;
  12. use Symfony\Component\HttpFoundation\Response;
  13. use function in_array;
  15. class GraphController
  16. {
  17. private BatchParser $batchParser;
  18. private Executor $requestExecutor;
  19. private Parser $requestParser;
  20. private bool $shouldHandleCORS;
  21. private bool $useApolloBatchingMethod;
  23. public function __construct(
  24. BatchParser $batchParser,
  25. Executor $requestExecutor,
  26. Parser $requestParser,
  27. bool $shouldHandleCORS,
  28. string $graphQLBatchingMethod
  29. ) {
  30. $this->batchParser = $batchParser;
  31. $this->requestExecutor = $requestExecutor;
  32. $this->requestParser = $requestParser;
  33. $this->shouldHandleCORS = $shouldHandleCORS;
  34. $this->useApolloBatchingMethod = 'apollo' === $graphQLBatchingMethod;
  35. }
  37. /**
  38. * @return JsonResponse|Response
  39. */
  40. public function endpointAction(Request $request, string $schemaName = null)
  41. {
  42. return $this->createResponse($request, $schemaName, false);
  43. }
  45. /**
  46. * @return JsonResponse|Response
  47. */
  48. public function batchEndpointAction(Request $request, string $schemaName = null)
  49. {
  50. return $this->createResponse($request, $schemaName, true);
  51. }
  53. /**
  54. * @return JsonResponse|Response
  55. */
  56. private function createResponse(Request $request, ?string $schemaName, bool $batched)
  57. {
  58. if ('OPTIONS' === $request->getMethod()) {
  59. $response = new JsonResponse([], 200);
  60. } else {
  61. if (!in_array($request->getMethod(), ['POST', 'GET'])) {
  62. return new JsonResponse('', 405);
  63. }
  64. $payload = $this->processQuery($request, $schemaName, $batched);
  65. $response = new JsonResponse($payload, 200);
  66. }
  67. $this->addCORSHeadersIfNeeded($response, $request);
  69. return $response;
  70. }
  72. private function addCORSHeadersIfNeeded(Response $response, Request $request): void
  73. {
  74. if ($this->shouldHandleCORS && $request->headers->has('Origin')) {
  75. $response->headers->set('Access-Control-Allow-Origin', $request->headers->get('Origin'), true);
  76. $response->headers->set('Access-Control-Allow-Credentials', 'true', true);
  77. $response->headers->set('Access-Control-Allow-Headers', 'Content-Type, Authorization', true);
  78. $response->headers->set('Access-Control-Allow-Methods', 'OPTIONS, GET, POST', true);
  79. $response->headers->set('Access-Control-Max-Age', '3600', true);
  80. }
  81. }
  83. private function processQuery(Request $request, ?string $schemaName, bool $batched): array
  84. {
  85. if ($batched) {
  86. $payload = $this->processBatchQuery($request, $schemaName);
  87. } else {
  88. $payload = $this->processNormalQuery($request, $schemaName);
  89. }
  91. return $payload;
  92. }
  94. private function processBatchQuery(Request $request, string $schemaName = null): array
  95. {
  96. $queries = $this->batchParser->parse($request);
  97. $payloads = [];
  99. foreach ($queries as $query) {
  100. $payload = $this->requestExecutor
  101. ->execute($schemaName, $query)
  102. ->toArray();
  103. if (!$this->useApolloBatchingMethod) {
  104. $payload = ['id' => $query['id'], 'payload' => $payload];
  105. }
  106. $payloads[] = $payload;
  107. }
  109. return $payloads;
  110. }
  112. private function processNormalQuery(Request $request, string $schemaName = null): array
  113. {
  114. $params = $this->requestParser->parse($request);
  116. return $this->requestExecutor->execute($schemaName, $params)->toArray();
  117. }
  118. }