|
7 | 7 | use Laminas\Diactoros\ServerRequestFactory; |
8 | 8 | use Laminas\Diactoros\StreamFactory; |
9 | 9 | use Laminas\Diactoros\UploadedFileFactory; |
| 10 | +use LogicException; |
10 | 11 | use Symfony\Bridge\PsrHttpMessage\Factory\PsrHttpFactory; |
| 12 | +use TheCodingMachine\GraphQLite\Bundle\UploadMiddlewareUtils\DummyResponseWithRequest; |
| 13 | +use TheCodingMachine\GraphQLite\Bundle\UploadMiddlewareUtils\RequestExtractorMiddleware; |
11 | 14 | use TheCodingMachine\GraphQLite\Http\HttpCodeDecider; |
12 | 15 | use TheCodingMachine\GraphQLite\Http\HttpCodeDeciderInterface; |
13 | 16 | use GraphQL\Executor\ExecutionResult; |
|
27 | 30 |
|
28 | 31 | use function array_map; |
29 | 32 | use function class_exists; |
| 33 | +use function get_debug_type; |
30 | 34 | use function json_decode; |
31 | 35 |
|
32 | 36 | /** |
33 | | - * Listens to every single request and forward Graphql requests to Graphql Webonix standardServer. |
| 37 | + * Listens to every single request and forwards GraphQL requests to Webonyx's {@see \GraphQL\Server\StandardServer}. |
34 | 38 | */ |
35 | 39 | class GraphQLiteController |
36 | 40 | { |
37 | | - /** |
38 | | - * @var HttpMessageFactoryInterface |
39 | | - */ |
40 | | - private $httpMessageFactory; |
41 | | - /** @var int */ |
42 | | - private $debug; |
43 | | - /** |
44 | | - * @var ServerConfig |
45 | | - */ |
46 | | - private $serverConfig; |
47 | | - /** |
48 | | - * @var HttpCodeDeciderInterface |
49 | | - */ |
50 | | - private $httpCodeDecider; |
| 41 | + private HttpMessageFactoryInterface $httpMessageFactory; |
| 42 | + private int $debug; |
| 43 | + private ServerConfig $serverConfig; |
| 44 | + private HttpCodeDeciderInterface $httpCodeDecider; |
51 | 45 |
|
52 | 46 | public function __construct(ServerConfig $serverConfig, ?HttpMessageFactoryInterface $httpMessageFactory = null, ?int $debug = null, ?HttpCodeDeciderInterface $httpCodeDecider = null) |
53 | 47 | { |
@@ -98,11 +92,14 @@ public function handleRequest(Request $request): Response |
98 | 92 | $psr7Request = $psr7Request->withParsedBody($parsedBody); |
99 | 93 | } |
100 | 94 |
|
101 | | - // Let's parse the request and adapt it for file uploads. |
| 95 | + // Let's parse the request and adapt it for file uploads by extracting it from the middleware. |
102 | 96 | if (class_exists(UploadMiddleware::class)) { |
103 | 97 | $uploadMiddleware = new UploadMiddleware(); |
104 | | - $psr7Request = $uploadMiddleware->processRequest($psr7Request); |
105 | | - \assert($psr7Request instanceof ServerRequestInterface); |
| 98 | + $dummyResponseWithRequest = $uploadMiddleware->process($psr7Request, new RequestExtractorMiddleware()); |
| 99 | + if (! $dummyResponseWithRequest instanceof DummyResponseWithRequest) { |
| 100 | + throw new LogicException(DummyResponseWithRequest::class . ' expect, got ' . get_debug_type($dummyResponseWithRequest)); |
| 101 | + } |
| 102 | + $psr7Request = $dummyResponseWithRequest->getRequest(); |
106 | 103 | } |
107 | 104 |
|
108 | 105 | return $this->handlePsr7Request($psr7Request, $request); |
|
0 commit comments