Function buildRuntimeApiServer

runtime/api-server/src/app.ts:3719–12183

(options: BuildRuntimeApiServerOptions = {})

}

export function buildRuntimeApiServer(options: BuildRuntimeApiServerOptions = {}): FastifyInstance {
  const ownsStore = !options.store;
  const store =
    options.store ??
    new RuntimeStateStore({
      dbPath: options.dbPath,
      workspaceRoot: options.workspaceRoot ?? defaultWorkspaceRoot()
    });

  const app = Fastify({
    logger: options.logger ?? false,
    bodyLimit: DEFAULT_BODY_LIMIT_BYTES,
  });
  void app.register(websocket);
  const backgroundTasks = new Set<Promise<void>>();
  const appSetupTasks = new Map<string, Promise<void>>();
  const appEnsureRunningTasks = new Map<string, Promise<void>>();
  // Serializes /api/v1/apps/install-archive against itself for the same
  // (workspaceId, appId). Without this, two concurrent installs both pass
  // the empty-appDir check, both extract on top of each other, and both
  // race-write app.runtime.yaml producing corrupt state.
  const appInstallTasks = new Map<string, Promise<unknown>>();
  const appLifecycleExecutor = options.appLifecycleExecutor ?? new RuntimeAppLifecycleExecutor({ store });
  const memoryService = options.memoryService ?? new FilesystemMemoryService({
    workspaceRoot: store.workspaceRoot,
    resolveWorkspaceDir: (workspaceId) => store.workspaceDir(workspaceId),
    store,
  });
  const runtimeConfigService = options.runtimeConfigService ?? new FileRuntimeConfigService();
  const browserToolService = options.browserToolService ?? new DesktopBrowserToolService({ artifactStore: store });
  const terminalSessionManager =
    options.terminalSessionManager === undefined
      ? new TerminalSessionManager({
        store,
        logger: app.log,
        captureRuntimeException,
      })
      : options.terminalSessionManager;
  const integrationContextFetchManager = createIntegrationContextFetchManager({
    store,
    runFetch: options.integrationContextFetchRunner
      ?? fetchIntegrationContextForConnection,
    logger: {
      warn: (meta, message) => app.log.warn(meta, message),
    },
  });
  // Deferred holders: queue worker + composio MCP manager are both
  // constructed after the integration service, but onConnectionActive
  // needs to call into them. We pass closures that read the holders
  // at call time — by then the dependents are set.
  const queueWorkerHolder: { worker: { wake: () => void } | null } = { worker: null };
  const composioMcpManagerHolder: {
    manager: { restart: (workspaceId: string) => Promise<unknown> } | null;
  } = { manager: null };
  const runtimeAgentToolsHolder: {
    service: { queuePolishForCompletedBindings: (workspaceId: string) => unknown } | null;
  } = { service: null };
  const integrationContextAutofetchWorkerHolder: {