Ynlo\GraphQLBundle\Controller\GraphQLEndpointController::__invoke()

Complexity

Conditions	17
Paths	1985

Size

Total Lines	94
Code Lines	56

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	306

Importance

Changes	7
Bugs	0	Features	0

<?php
    public function __invoke(Request $request): JsonResponse
    {
        $operationEvent = null;

        if (!$this->debug && $request->getMethod() !== Request::METHOD_POST) {
            throw new HttpException(Response::HTTP_BAD_REQUEST, 'The method should be POST to talk with GraphQL API');
        }

        try {
            $query = new ExecuteQuery();
            foreach ($this->middlewares as $middleware) {
                if ($middleware instanceof RequestMiddlewareInterface) {
                    $middleware->processRequest($request, $query);
                }
            }

            $endpoint = $this->resolver->resolveEndpoint($request);
            if (!$endpoint) {
                throw new AccessDeniedHttpException();
            }

            if ($this->dispatcher) {
                $operationEvent = new GraphQLOperationEvent($query, $endpoint);
                $this->dispatcher->dispatch(GraphQLEvents::OPERATION_START, $operationEvent);

The call to Symfony\Contracts\EventDispatcher\EventDispatcherInterface::dispatch() has too many arguments starting with $operationEvent.

Ynlo\GraphQLBundle\Events\GraphQLEvents::OPERATION_START of type string is incompatible with the type object expected by parameter $event of Symfony\Contracts\EventDispatcher\EventDispatcherInterface::dispatch().

            }

            $context = new ResolverContext($endpoint);
            $validationRules = null;

            $schema = $this->compiler->compile($endpoint);
            $schema->assertValid();

            if ($subscriptionRequest = $query->getSubscriptionRequest()) {
                $context->setMeta('subscriptionRequest', $subscriptionRequest);
            }

            $result = GraphQL::executeQuery(
                $schema,
                $query->getRequestString(),
                null,
                $context,
                $query->getVariables(),
                $query->getOperationName(),
                null,
                $validationRules
            );

            //https://webonyx.github.io/graphql-php/error-handling/
            $formatter = $this->errorFormatter;
            $handler = $this->errorHandler;

            //get queued errors
            $exceptions = ErrorQueue::all();
            foreach ($exceptions as $exception) {
                $result->errors[] = Error::createLocatedError($exception);
            }

            $result->setErrorFormatter([$formatter, 'format']);
            $result->setErrorsHandler(
                function ($errors) use ($handler, $formatter) {
                    return $handler->handle($errors, $formatter, $this->getDebugMode());
                }
            );

            $output = $result->toArray($this->getDebugMode());
            $statusCode = Response::HTTP_OK;
        } catch (\Exception $e) {
            $error = Error::createLocatedError($e);
            $errors = $this->errorHandler->handle([$error], $this->errorFormatter, $this->debug);
            if ($e instanceof HttpException) {
                $statusCode = $e->getStatusCode();
            } elseif ($e instanceof ClientAware) {
                // usually client's exceptions do not arrive until here
                // but sometimes this exception happen during compilation time, like: Ynlo\GraphQLBundle\Type\Registry\InvalidTypeException
                // due to invalid user request
                $statusCode = Response::HTTP_BAD_REQUEST;
            } else {
                $statusCode = Response::HTTP_INTERNAL_SERVER_ERROR;
            }

            $output = [
                'errors' => $errors,
            ];
        }

        if ($this->dispatcher && $operationEvent) {
            $this->dispatcher->dispatch(GraphQLEvents::OPERATION_END, $operationEvent);
        }

        if ($this->publisher && isset($subscriptionRequest) && $subscriptionRequest instanceof SubscriptionRequest) {
            ($this->publisher)(new Update($subscriptionRequest->getId(), json_encode($output)));
        }

        return JsonResponse::create($output, $statusCode);
    }