GraphQL HTTP and WS Server

Note: The server will only intercept WS connections that have the graphQL subscription path

Options

| Option | Description | Default | |------------------- |--------------------------------------------------- |-------------------------- | | schema | Executable schema | null | | typeDefs | GraphQL type definitions (combine with resolvers) | null | | resolvers | GraphQL type definitions (combine with typeDefs) | null | | port | Port for HTTP Server to listen on | 80 | | graphQLPath | Path under HTTP server for GraphQL | /graphql | | subscriptionsPath | Path under WS server for GraphQL | /graphql | | listen | Start HTTP Server | true | | logger | Pass extrernal logger (eg: Winston) | null | | plugins | Apollo plugins | [] | | expressApp | Pass in an express app | null, module will create | | httpServer | Pass in an HTTP server | null, module will create | | wsServer | pass in a WS server | null, module will create |

Example

import { makeExecutableSchema } from "@graphql-tools/schema";
import gql from 'graphql-tag'
import { EventEmitterAsyncIterator } from 'event-emitter-async-iterator';
import createGraphQLHTTPServer from "graphql-http-ws-server";

const typeDefs = gql(`
    type Query {
        hello: String
    }
    type Subscription {
        time: String
    }
`);

const resolvers = {
    Query: {
        hello: (obj, args, context) => {
            return 'world';
        }
    },
    Subscription: {
        time: {
            subscribe: (obj, args, context, info) => {
                const asyncIterator = new EventEmitterAsyncIterator();

                const sendDate = () => {
                    asyncIterator.pushValue({
                        time: (new Date()).toISOString()
                    });
                };

                const sendInterval = setInterval(() => {
                    sendDate()
                }, 1000);


                asyncIterator.once('return', () => {
                    clearInterval(sendInterval);
                });

                sendDate();

                return asyncIterator;
            }
        },
    }
};

const schema = makeExecutableSchema({
    typeDefs,
    resolvers,
});

createGraphQLHTTPServer({
    schema,
    port: 80,
    playground: true,
    graphqlPath: '/graphql',
    subscriptionsPath: '/graphql',
    onConnect: async (params) => { // WS
        console.log("LEGACY WS CONNECT", params);
        return {connection: "Legacy WS Connect"};
    },
    wsContext: (params) => {
        console.log("WS CONNECT", params.connectionParams)
        return {connection: "New WS Connect"};
    },
    httpContext: async ({req}) => { // HTTP
        console.log("HTTP CONNECT", req.headers);
        return {connection: "HTTP Connect"};
    }
});