Method start

extensions/graphql/src/graphql.server.ts:158–214

()

  }

  async start() {
    const schema = await this._setupSchema();
    this.schema = schema;
    // Allow a graphql context resolver to be bound to GRAPHQL_CONTEXT_RESOLVER
    const graphqlContextResolver: ExpressMiddlewareOptions<BaseContext>['context'] =
      (await this.get(GraphQLBindings.GRAPHQL_CONTEXT_RESOLVER, {
        optional: true,
      })) ?? (async context => context);
    // Allow a graphql context resolver to be bound to GRAPHQL_CONTEXT_RESOLVER
    const graphqlWsContextResolver =
      (await this.get(GraphQLBindings.GRAPHQL_WS_CONTEXT_RESOLVER, {
        optional: true,
      })) ??
      (async (context: object) => {
        return context;
      });

    // Create ApolloServerExpress GraphQL server
    const serverConfig = {
      ...this.options.apollo,
      schema,
      // plugins: [ApolloServerPluginDrainHttpServer({ httpServer: this.httpServer })],
    } as ApolloServerOptionsWithSchema<BaseContext>;
    const graphQLServer = new ApolloServer(serverConfig);
    await graphQLServer.start();
    this.expressApp.use(
      this.options.graphQLPath ?? '/',
      cors<cors.CorsRequest>(),
      json(),
      expressMiddleware(graphQLServer, {
        context: graphqlContextResolver,
        ...this.options.middlewareOptions,
      }),
    );
    // Start the http server if created
    await this.httpServer?.start();

    let server;
    if (this.options.asMiddlewareOnly) {
      const rest: RestServer = await this.get(RestBindings.SERVER);
      server = rest.httpServer?.server;
    } else {
      server = this.httpServer?.server;
    }
    const wsServer = new WebSocketServer({
      server: server,
      path: this.options.path,
    });
    this.wsServer = wsServer;
    useServer(
      {
        schema,
        context: graphqlWsContextResolver,
      },
      wsServer,
    );
  }