Method createServer

packages/query/src/graphql/graphql.module.ts:133–236

()

  }

  private async createServer() {
    const app = this.httpAdapterHost.httpAdapter.getInstance();
    const httpServer = this.httpAdapterHost.httpAdapter.getHttpServer();

    const schemaName = this.config.get<string>('name');
    if (!schemaName) throw new Error('Unable to get schema name from config');

    const dbSchema = await this.projectService.getProjectSchema(schemaName);
    let options: PostGraphileCoreOptions = {
      replaceAllPlugins: plugins,
      subscriptions: true,
      dynamicJson: true,
      graphileBuildOptions: {
        connectionFilterRelations: false, // We use our own forked version with historical support

        // cockroach db does not support pgPartition
        pgUsePartitionedParent: true,
      },
    };

    if (argv.subscription) {
      const pluginHook = makePluginHook([PgPubSub]);
      // Must be called manually to init PgPubSub since we're using Apollo Server and not postgraphile
      options = pluginHook('postgraphile:options', options, {pgPool: this.pgPool});
      options.replaceAllPlugins ??= [];
      options.appendPlugins ??= [];
      options.replaceAllPlugins.push(PgSubscriptionPlugin as Plugin);
      while (options.appendPlugins.length) {
        const replaceAllPlugin = options.appendPlugins.pop();
        if (replaceAllPlugin) options.replaceAllPlugins.push(replaceAllPlugin);
      }
    }

    if (!argv['disable-hot-schema']) {
      try {
        const pgClient = await this.pgPool.connect();
        await pgClient.query(`LISTEN "${hashName(dbSchema, 'schema_channel', '_metadata')}"`);

        // Set up a keep-alive interval to prevent the connection from being killed
        this.setupKeepAlive(pgClient);

        pgClient.on('error', (err: Error) => {
          getLogger('db').error('PostgreSQL schema listener client error: ', err);
          process.exit(1);
        });

        pgClient.on('notification', (msg) => {
          if (msg.payload === 'schema_updated') {
            void this.schemaListener(dbSchema, options);
          }
        });
      } catch (e) {
        logger.warn('Failed to init hot-schema reload', e);
      }
    }
    const schema = await this.buildSchema(dbSchema, options);

    const apolloServerPlugins = [