Function createServer

packages/server/src/legacy-node-server.ts:89–590

(options?: ServerOptions)

}

export function createServer(options?: ServerOptions) {
  const dbSource = !!options?.storage
    ? typeof options.storage === 'string'
      ? createTriplitStorageProvider(
          // @ts-ignore TODO: check why this is not working...might be module resolution issue?
          options.storage
        )
      : typeof options.storage === 'function'
        ? options.storage()
        : options.storage
    : undefined;
  if (options?.verboseLogs) logger.verbose = true;
  const triplitServers = new Map<string, TriplitServer>();

  function getServer(projectId: string, upstream?: ServerOptions['upstream']) {
    if (triplitServers.has(projectId)) return triplitServers.get(projectId)!;
    const dbOptions: Partial<DBConfig> = {
      experimental: {},
    };
    if (process.env.ENTITY_CACHE_ENABLED) {
      dbOptions.experimental!.entityCache = {
        capacity: process.env.ENTITY_CACHE_CAPACITY
          ? parseInt(process.env.ENTITY_CACHE_CAPACITY)
          : 100000,
      };
    }
    Object.assign(dbOptions, options?.dbOptions);
    const db = upstream
      ? new TriplitClient({
          clientId: projectId,
          serverUrl: upstream.url,
          token: upstream.token,
          syncSchema: true,
          skipRules: false,
        })
      : new DB({
          source: dbSource,
          tenantId: projectId,
          clock: new DurableClock(),
          ...dbOptions,
        });
    // @ts-expect-error
    const server = new TriplitServer(db, captureException);
    triplitServers.set(projectId, server);
    return server;
  }
  initSentry();
  const app = express();
  app.use(express.json());
  app.use((req, res, next) => {
    const start = new Date();
    let send = res.send;
    res.send = (c) => {
      const end = new Date();
      let body = c;
      const resWithBody = {
        ...res,
        body,