src/WellCommerce/Bundle/AppBundle/Controller/Front/ShopDataController.php line 51

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