src/WellCommerce/Bundle/AppBundle/Controller/Front/GraphController.php line 49

Open in your IDE?
  1. <?php
  3. namespace WellCommerce\Bundle\AppBundle\Controller\Front;
  5. use GraphQL\Error\DebugFlag;
  6. use GraphQL\Executor\ExecutionResult;
  7. use GraphQL\Server\ServerConfig;
  8. use GraphQL\Server\StandardServer;
  9. use GraphQL\Upload\UploadMiddleware;
  10. use Laminas\Diactoros\ResponseFactory;
  11. use Laminas\Diactoros\ServerRequestFactory;
  12. use Laminas\Diactoros\StreamFactory;
  13. use Laminas\Diactoros\UploadedFileFactory;
  14. use Psr\Http\Message\ServerRequestInterface;
  15. use RuntimeException;
  16. use Symfony\Bridge\PsrHttpMessage\Factory\PsrHttpFactory;
  17. use Symfony\Bridge\PsrHttpMessage\HttpMessageFactoryInterface;
  18. use Symfony\Component\HttpFoundation\JsonResponse;
  19. use Symfony\Component\HttpFoundation\Request;
  20. use Symfony\Component\HttpFoundation\Response;
  21. use Symfony\Component\Routing\Annotation\Route;
  22. use TheCodingMachine\GraphQLite\Bundle\Context\SymfonyGraphQLContext;
  23. use TheCodingMachine\GraphQLite\Http\HttpCodeDecider;
  24. use WellCommerce\Bundle\CoreBundle\Controller\Front\AbstractFrontController;
  25. use function array_map;
  26. use function class_exists;
  27. use function json_decode;
  29. /**
  30.  * Listens to every single request and forward Graphql requests to Graphql Webonix standardServer.
  31.  */
  32. class GraphController extends AbstractFrontController
  33. {
  34.     private HttpMessageFactoryInterface $httpMessageFactory;
  35.     private                             $debug;
  36.     private ServerConfig                $serverConfig;
  38.     public function __construct(ServerConfig $serverConfig, HttpMessageFactoryInterface $httpMessageFactory = null, ?int $debug = null)
  39.     {
  40.         $this->serverConfig       = $serverConfig;
  41.         $this->httpMessageFactory = $httpMessageFactory ?: new PsrHttpFactory(new ServerRequestFactory(), new StreamFactory(),
  42.             new UploadedFileFactory(), new ResponseFactory());
  43.         $this->debug              = DebugFlag::RETHROW_UNSAFE_EXCEPTIONS;
  44.     }
  46.     /**
  47.      * @Route("/graphql/{_locale}", name="graphql", options={"expose"="true"}, defaults={"_locale": "pl"})
  48.      */
  49.     public function handleRequest(Request $request): Response
  50.     {
  51.         $psr7Request = $this->httpMessageFactory->createRequest($request);
  53.         if (strtoupper($request->getMethod()) === "POST" && empty($psr7Request->getParsedBody())) {
  54.             $content    = $psr7Request->getBody()->getContents();
  55.             $parsedBody = json_decode($content, true);
  56.             if (json_last_error() !== JSON_ERROR_NONE) {
  57.                 throw new \RuntimeException('Invalid JSON received in POST body: ' . json_last_error_msg());
  58.             }
  59.             $psr7Request = $psr7Request->withParsedBody($parsedBody);
  60.         }
  62.         // Let's parse the request and adapt it for file uploads.
  63.         if (class_exists(UploadMiddleware::class)) {
  64.             $uploadMiddleware = new UploadMiddleware();
  65.             $psr7Request      = $uploadMiddleware->processRequest($psr7Request);
  66.         }
  68.         return $this->handlePsr7Request($psr7Request, $request);
  69.     }
  71.     private function handlePsr7Request(ServerRequestInterface $request, Request $symfonyRequest): JsonResponse
  72.     {
  73.         // Let's put the request in the context.
  74.         $serverConfig = clone $this->serverConfig;
  75.         $serverConfig->setContext(new SymfonyGraphQLContext($symfonyRequest));
  76.         $serverConfig->setDebugFlag($this->debug);
  78.         $standardService = new StandardServer($serverConfig);
  79.         $result          = $standardService->executePsrRequest($request);
  81.         $httpCodeDecider = new HttpCodeDecider();
  82.         if ($result instanceof ExecutionResult) {
  83.             return new JsonResponse($result->toArray($this->debug), $httpCodeDecider->decideHttpStatusCode($result));
  84.         }
  85.         if (is_array($result)) {
  86.             $finalResult = array_map(function (ExecutionResult $executionResult): array {
  87.                 return $executionResult->toArray($this->debug);
  88.             }, $result);
  89.             // Let's return the highest result.
  90.             $statuses = array_map([$httpCodeDecider, 'decideHttpStatusCode'], $result);
  91.             $status   = empty($statuses) ? 500 : max($statuses);
  93.             return new JsonResponse($finalResult, $status);
  94.         }
  96.         throw new RuntimeException('Only SyncPromiseAdapter is supported');
  97.     }
  98. }