app/GraphQL/EventSubscriber/GraphQLExceptionSubscriber.php line 32

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Sq\GraphQL\EventSubscriber;
  5. use Sq\GraphQL\Exception\SqGraphQLException;
  6. use Sq\Service\Environment;
  7. use Sq\Service\Log\ExceptionLogger;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\HttpFoundation\JsonResponse;
  10. use Symfony\Component\HttpFoundation\Response;
  11. use Symfony\Component\HttpKernel\Event\ExceptionEvent;
  12. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  13. use Symfony\Component\HttpKernel\KernelEvents;
  14. use Symfony\Component\Routing\Exception\ResourceNotFoundException;
  16. class GraphQLExceptionSubscriber implements EventSubscriberInterface
  17. {
  18.     public function __construct(
  19.         protected Environment $environment,
  20.         protected ExceptionLogger $exceptionLogger,
  21.     ) {
  22.     }
  24.     /** @inheritDoc */
  25.     public static function getSubscribedEvents(): array
  26.     {
  27.         return [
  28.             KernelEvents::EXCEPTION => ['onException'],
  29.         ];
  30.     }
  32.     public function onException(ExceptionEvent $event): void
  33.     {
  34.         $throwable = $event->getThrowable();
  35.         $request = $event->getRequest();
  37.         is_graphql_request($request) && $event->setResponse(static::createInternalServerErrorGraphQLResponse($this->environment->isDebug(), $throwable));
  39.         if ($throwable instanceof NotFoundHttpException || $throwable instanceof ResourceNotFoundException)
  40.         {
  41.             return;
  42.         }
  44.         if ($throwable instanceof \RuntimeException && str_contains($throwable->getMessage(), 'Invalid JSON received in POST body'))
  45.         {
  46.             $this->exceptionLogger->logInvalidJsonRequest(
  47.                 $throwable,
  48.                 $request->getContent(),
  49.                 $request->headers->all(),
  50.                 $request->getClientIp(),
  51.                 $request->server->get('HTTP_USER_AGENT')
  52.             );
  54.             return;
  55.         }
  57.         $this->exceptionLogger->logInternalServerError($event->getThrowable());
  58.     }
  60.     public static function createInternalServerErrorGraphQLResponse($debug = false, ?\Throwable $e = null): Response
  61.     {
  62.         $error = new \GraphQL\Error\Error("INTERNAL_SERVER_ERROR");
  63.         $res = new \GraphQL\Executor\ExecutionResult(null, [$error]);
  64.         $resArray = $res->toArray();
  65.         if ($e instanceof SqGraphQLException)
  66.         {
  67.             $resArray['errors'][0]['extensions']['gql_message'] = $e->getMessage();
  68.         }
  69.         if ($debug && $e)
  70.         {
  71.             if ($e->getPrevious())
  72.             {
  73.                 $previous = $e->getPrevious();
  74.                 $resArray['errors'][0]['debug_previous'] = [
  75.                     'message' => $previous->getMessage(),
  76.                     'code' => $previous->getCode(),
  77.                     'line' => $previous->getLine(),
  78.                     'file' => $previous->getFile(),
  79.                 ];
  80.             }
  81.             $resArray['errors'][0]['debug_message'] = $e->getMessage();
  82.             $resArray['errors'][0]['debug_file'] = $e->getFile();
  83.             $resArray['errors'][0]['debug_line'] = $e->getLine();
  84.             $resArray['errors'][0]['debug_trace'] = $e->getTraceAsString();
  85.         }
  87.         return new JsonResponse($resArray, 500);
  88.     }
  89. }