GraphQL HTTP Server Middleware

Create a GraphQL HTTP server with Express.

Installation

1npm install --save @bluesialia/express-graphql

This package needs Express and GraphQL as peer dependencies. So if you don't have those installed yet, install them with:

1npm install --save express graphql

TypeScript

This module includes a TypeScript declaration file to enable auto complete in compatible editors and type information for TypeScript projects.

Simple Setup

Just mount express-graphql as a route handler:

1import { graphqlHTTP } from '@bluesialia/express-graphql';
2import express from 'express';
3import { buildSchema } from 'graphql';
4
5const PORT = 12000;
6
7// Construct a schema, using GraphQL schema language
8const schema = buildSchema(`
9  type Query {
10    hello: String
11  }
12`);
13
14// The root provides a resolver function for each API endpoint
15const rootValue = {
16  hello: () => 'Hello world!',
17};
18
19const app = express();
20app.use(
21  '/graphql',
22  graphqlHTTP({
23    schema,
24    rootValue,
25    graphiql: true,
26  }),
27);
28app.listen(PORT);

Setup with Subscription Support

1import { graphqlHTTP } from '@bluesialia/express-graphql';
2import express from 'express';
3import { buildSchema, execute, subscribe } from 'graphql';
4import { useServer } from 'graphql-ws/lib/use/ws';
5import { createServer } from 'http';
6import { WebSocketServer } from 'ws';
7
8const sleep = ms => new Promise(r => setTimeout(r, ms));
9
10const PORT = 12000;
11const subscriptionUrl = `ws://localhost:${PORT}/subscriptions`;
12
13// Construct a schema, using GraphQL schema language
14const schema = buildSchema(`
15  type Query {
16    hello: String
17  }
18  type Subscription {
19    countDown: Int
20  }
21`);
22
23// The root provides a resolver function for each API endpoint
24const roots = {
25  Query: {
26    hello: () => 'Hello World!',
27  },
28  subscription: {
29    countDown: async function* fiveToOne() {
30      for (const number of [5, 4, 3, 2, 1]) {
31        await sleep(1000);
32        yield { countDown: number };
33      }
34    },
35  },
36};
37
38const rootValue = {
39  hello: roots.Query.hello,
40  countDown: roots.subscription.countDown,
41};
42
43const app = express();
44app.use(
45  '/graphql',
46  graphqlHTTP({
47    schema,
48    rootValue,
49    graphiql: {
50      fetcher: {
51        url: `http://localhost:${PORT}/graphql`,
52        subscriptionUrl,
53      },
54    },
55  }),
56);
57
58const server = createServer(app);
59
60const wsServer = new WebSocketServer({
61  server,
62  path: '/subscriptions',
63});
64
65server.listen(PORT, () => {
66  // Set up the WebSocket for handling GraphQL subscriptions.
67  useServer(
68    {
69      schema,
70      roots,
71      execute,
72      subscribe,
73    },
74    wsServer,
75  );
76});

Options

The graphqlHTTP function accepts the following options:

• schema: A GraphQLSchema instance from GraphQL.js. A schema must be provided.

• graphiql: A boolean to optionally enable GraphiQL when the GraphQL endpoint is loaded in a browser. We recommend that you set graphiql to true when your app is in development, because it's quite useful. You may or may not want it in production. Alternatively, instead of true you can pass in an altered GraphiQLProps object:

  • fetcher: GraphiQLProps requires a fetcher property that evaluates to a Fetcher object. In express-graphql's case the fetcher property contains an object containing the following properties that will be used to create the Fetcher object:

    • url: URL for HTTP(S) requests. Required if you provide a fetcher property. Otherwise, the URL where you exposed the GraphiQL will be used.

    • subscriptionUrl: URL for websocket subscription requests.

    • headers: Headers you can provide statically. If you enable the headers editor and the user provides a header you set statically here, it will be overriden by their value.

• rootValue: A value to pass as the rootValue to the execute() function from GraphQL.js/src/execution/execute.ts.

• context: A value to pass as the contextValue to the execute() function from GraphQL.js/src/execution/execute.ts. If context is not provided, the request object is passed as the context.

• pretty: A boolean to configure whether the output should be pretty-printed.

• extensions: An optional function for adding additional metadata to the GraphQL response as a key-value object. The result will be added to the "extensions" field in the resulting JSON. This is often a useful place to add development time metadata such as the runtime of a query or the amount of resources consumed. This may be an async function. The function is given one object as an argument: { document, variables, operationName, result, context }.

• validationRules: An optional array of validation rules that will be applied on the document in addition to those defined by the GraphQL spec.

• validateFn: An optional function which will be used to validate instead of default validate from graphql-js.

• executeFn: An optional function which will be used to execute instead of default execute from graphql-js.

• formatErrorFn: An optional function which will be used to format any errors produced by fulfilling a GraphQL operation. If no function is provided, GraphQL's default function will be used.

• parseFn: An optional function which will be used to create a document instead of the default parse from graphql-js.

In addition to an object defining each option, options can also be provided as a function (or async function) which returns this options object. This function is provided the arguments (request, response, graphQLParams) and is called after the request has been parsed.

The graphQLParams is provided as the object { query, variables, operationName, raw }.

1app.use(
2  '/graphql',
3  graphqlHTTP(async (request, response, graphQLParams) => ({
4    schema: MyGraphQLSchema,
5    rootValue: await someFunctionToGetRootValue(request),
6    graphiql: true,
7  })),
8);

HTTP Usage

Once installed at a path, express-graphql will accept requests with the parameters:

• query: A string GraphQL document to be executed.

• variables: The runtime values to use for any GraphQL query variables as a JSON object.

• operationName: If the provided query contains multiple named operations, this specifies which operation should be executed. If not provided, a 400 error will be returned if the query contains multiple named operations.

• raw: If the graphiql option is enabled and the raw parameter is provided, raw JSON will always be returned instead of GraphiQL even when loaded from a browser.

GraphQL will first look for each parameter in the query string of a URL:

/graphql?query=query+getUser($id:ID){user(id:$id){name}}&variables={"id":"4"}

If not found in the query string, it will look in the POST request body.

If a previous middleware has already parsed the POST body, the request.body value will be used. Use multer or a similar middleware to add support for multipart/form-data content, which may be useful for GraphQL mutations involving uploading files. See an example using multer.

If the POST body has not yet been parsed, express-graphql will interpret it depending on the provided Content-Type header.

• application/json: the POST body will be parsed as a JSON object of parameters.

• application/x-www-form-urlencoded: the POST body will be parsed as a url-encoded string of key-value pairs.

• application/graphql: the POST body will be parsed as GraphQL query string, which provides the query parameter.

Combining with Other Express Middleware

By default, the express request is passed as the GraphQL context. Since most express middleware operates by adding extra data to the request object, this means you can use most express middleware just by inserting it before graphqlHTTP is mounted. This covers scenarios such as authenticating the user, handling file uploads, or mounting GraphQL on a dynamic endpoint.

This example uses [express-session][] to provide GraphQL with the currently logged-in session.

1import { graphqlHTTP } from '@bluesialia/express-graphql';
2import express from 'express';
3import session from 'express-session';
4
5const app = express();
6
7app.use(session({ secret: 'keyboard cat', cookie: { maxAge: 60000 } }));
8
9app.use(
10  '/graphql',
11  graphqlHTTP({
12    schema: MySessionAwareGraphQLSchema,
13    graphiql: true,
14  }),
15);

Then in your type definitions, you can access the request via the third "context" argument in your resolve function:

1new GraphQLObjectType({
2  name: 'MyType',
3  fields: {
4    myField: {
5      type: GraphQLString,
6      resolve(parentValue, args, request) {
7        // use `request.session` here
8      },
9    },
10  },
11});

Providing Extensions

The GraphQL response allows for adding additional information in a response to a GraphQL query via a field in the response called "extensions". This is added by providing an extensions function when using graphqlHTTP. The function must return a JSON-serializable Object.

When called, this is provided an argument which you can use to get information about the GraphQL request:

{ document, variables, operationName, result, context }

This example illustrates adding the amount of time consumed by running the provided query, which could perhaps be used by your development tools.

1import { graphqlHTTP } from '@bluesialia/express-graphql';
2import express from 'express';
3
4const app = express();
5
6const extensions = ({
7  document,
8  variables,
9  operationName,
10  result,
11  context,
12}) => {
13  return {
14    runTime: Date.now() - context.startTime,
15  };
16};
17
18app.use(
19  '/graphql',
20  graphqlHTTP((request) => {
21    return {
22      schema: MyGraphQLSchema,
23      context: { startTime: Date.now() },
24      graphiql: true,
25      extensions,
26    };
27  }),
28);

When querying this endpoint, it would include this information in the result, for example:

1{
2  "data": { /*...*/ },
3  "extensions": {
4    "runTime": 135
5  }
6}

Additional Validation Rules

GraphQL's validation phase checks the query to ensure that it can be successfully executed against the schema. The validationRules option allows for additional rules to be run during this phase. Rules are applied to each node in an AST representing the query using the Visitor pattern.

A validation rule is a function which returns a visitor for one or more node Types. Below is an example of a validation preventing the specific field name metadata from being queried. For more examples, see the specifiedRules in the graphql-js package. 0

1import { GraphQLError } from 'graphql';
2
3export function DisallowMetadataQueries(context) {
4  return {
5    Field(node) {
6      const fieldName = node.name.value;
7
8      if (fieldName === 'metadata') {
9        context.reportError(
10          new GraphQLError(
11            `Validation: Requesting the field ${fieldName} is not allowed`,
12          ),
13        );
14      }
15    },
16  };
17}

Disabling introspection

Disabling introspection does not reflect best practices and does not necessarily make your application any more secure. Nevertheless, disabling introspection is possible by utilizing the NoSchemaIntrospectionCustomRule provided by the graphql-js package.

1import { NoSchemaIntrospectionCustomRule } from 'graphql';
2
3app.use(
4  '/graphql',
5  graphqlHTTP((request) => {
6    return {
7      schema: MyGraphQLSchema,
8      validationRules: [NoSchemaIntrospectionCustomRule],
9    };
10  }),
11);

Other Exports

getGraphQLParams(request: Request): Promise<GraphQLParams>

Given an HTTP Request, this returns a Promise for the parameters relevant to running a GraphQL request. This function is used internally to handle the incoming request, you may use it directly for building other similar services.

1import { getGraphQLParams } from '@bluesialia/express-graphql';
2
3getGraphQLParams(request).then((params) => {
4  // do something...
5});

Debugging Tips

During development, it's useful to get more information from errors, such as stack traces. Providing a function to formatErrorFn enables this:

1formatErrorFn: (error) => ({
2  message: error.message,
3  locations: error.locations,
4  stack: error.stack ? error.stack.split('\n') : [],
5  path: error.path,
6});