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

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