feat: support passing options to graphql validate and parse

mercurius-js · Nov 8, 2023 · 54d1f70 · 54d1f70
1 parent 62f41ee
commit 54d1f70
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 3 deletions.
diff --git a/index.d.ts b/index.d.ts
@@ -17,6 +17,7 @@ import {
 import { SocketStream } from "@fastify/websocket"
 import { IncomingMessage, IncomingHttpHeaders, OutgoingHttpHeaders } from "http";
 import { Readable } from "stream";
+import { GraphQLParseOptions } from "@graphql-tools/utils";
 
 export interface PubSub {
   subscribe<TResult = any>(topics: string | string[]): Promise<Readable & AsyncIterableIterator<TResult>>;
@@ -356,6 +357,15 @@ export interface MercuriusGraphiQLOptions {
   }>
 }
 
+export interface GrapQLValidateOptions {
+  maxErrors?: number;
+}
+
+export interface MercuriusGraphQLOptions {
+  parseOptions?: GraphQLParseOptions,
+  validateOptions?: GrapQLValidateOptions
+}
+
 export interface MercuriusCommonOptions {
   /**
    * Serve GraphiQL on /graphiql if true or 'graphiql' and if routes is true
@@ -413,6 +423,10 @@ export interface MercuriusCommonOptions {
    * The maximum depth allowed for a single query.
    */
   queryDepth?: number;
+  /**
+   * GraphQL function optional option overrides
+   */
+  graphql?: MercuriusGraphQLOptions,
   context?: (
     request: FastifyRequest,
     reply: FastifyReply

diff --git a/index.js b/index.js
@@ -78,6 +78,10 @@ const plugin = fp(async function (app, opts) {
   const queryDepthLimit = opts.queryDepth
   const errorFormatter = typeof opts.errorFormatter === 'function' ? opts.errorFormatter : defaultErrorFormatter
 
+  opts.graphql = opts.graphql || {}
+  const gqlParseOpts = opts.graphql.parseOptions || {}
+  const gqlValidateOpts = opts.graphql.validateOptions || {}
+
   if (opts.persistedQueries) {
     if (opts.onlyPersisted) {
       opts.persistedQueryProvider = persistedQueryDefaults.preparedOnly(opts.persistedQueries)
@@ -246,7 +250,7 @@ const plugin = fp(async function (app, opts) {
 
   fastifyGraphQl.extendSchema = fastifyGraphQl.extendSchema || function (s) {
     if (typeof s === 'string') {
-      s = parse(s)
+      s = parse(s, gqlParseOpts)
     } else if (!s || typeof s !== 'object') {
       throw new MER_ERR_INVALID_OPTS('Must provide valid Document AST')
     }
@@ -428,7 +432,7 @@ const plugin = fp(async function (app, opts) {
       }
 
       try {
-        document = parse(source)
+        document = parse(source, gqlParseOpts)
       } catch (syntaxError) {
         try {
           // Try to parse the source as ast
@@ -454,7 +458,7 @@ const plugin = fp(async function (app, opts) {
           validationRules = opts.validationRules({ source, variables, operationName })
         }
       }
-      const validationErrors = validate(fastifyGraphQl.schema, document, [...specifiedRules, ...validationRules])
+      const validationErrors = validate(fastifyGraphQl.schema, document, [...specifiedRules, ...validationRules], gqlValidateOpts)
 
       if (validationErrors.length > 0) {
         if (lruErrors) {