Function createSyncServer

engine/server/index.ts:34–100

(config: SyncServerConfig)

 */

export function createSyncServer(config: SyncServerConfig) {
  const app = express();
  const httpServer = http.createServer(app);
  const socketServer = new SocketServer(httpServer);

  const realTimeManager = createRealTimeManager(socketServer);

  const dbConnection = knex({
    connection: config.dbConnection,
  });

  const { requestHandlers, schema } = config;

  async function createContext(req: Request) {
    const context = await createRequestContext(
      req,
      requestHandlers,
      schema,
      dbConnection
    );

    return context;
  }

  app.get("/init", async (req, res) => {
    const context = await createContext(req);

    const bootData = await fetchInitialData(context);
    res.json(bootData);
  });

  app.get("/sync", async (req, res) => {
    const context = await createContext(req);

    const result = await fetchSyncDelta(context);

    res.json(result);
  });

  app.post("/mutate", async (req, res) => {
    const context = await createContext(req);

    const {
      body: { input },
    } = req;

    const result = await performMutation(context, input);

    res.json(result);

    realTimeManager.requestEveryoneToSync();
  });

  function listen(port: number) {
    return new Promise<void>((resolve) => {
      app.listen(port, () => {
        console.log(`Sync server listening on port ${port}`);
        resolve();