Function createDefaultExportDeps

apps/kimi-code/src/cli/sub/export.ts:131–201

(overrides: Partial<ExportDeps> = {})

}

function createDefaultExportDeps(overrides: Partial<ExportDeps> = {}): ExportDeps {
  let harness: KimiHarness | undefined;
  let telemetryBootstrap: ReturnType<typeof createCliTelemetryBootstrap> | undefined;
  let telemetryInitialized = false;
  let telemetryShutdown = false;
  const identity = createKimiCodeHostIdentity();
  const telemetryClient: TelemetryClient = {
    track,
    withContext: withTelemetryContext,
    setContext: setTelemetryContext,
  };
  const getTelemetryBootstrap = (): ReturnType<typeof createCliTelemetryBootstrap> => {
    telemetryBootstrap ??= createCliTelemetryBootstrap();
    return telemetryBootstrap;
  };
  const getHarness = (): KimiHarness => {
    const currentTelemetryBootstrap = getTelemetryBootstrap();
    harness ??= createKimiHarness({
      homeDir: currentTelemetryBootstrap.homeDir,
      identity,
      telemetry: telemetryClient,
    });
    return harness;
  };
  const initializeDefaultTelemetry = async (): Promise<void> => {
    if (telemetryInitialized) return;
    const currentTelemetryBootstrap = getTelemetryBootstrap();
    const currentHarness = getHarness();
    await currentHarness.ensureConfigFile();
    const config = await currentHarness.getConfig();
    initializeCliTelemetry({
      harness: currentHarness,
      bootstrap: currentTelemetryBootstrap,
      config,
      version: identity.version,
      uiMode: CLI_UI_MODE,
    });
    telemetryInitialized = true;
  };
  const shutdownDefaultTelemetry = async (): Promise<void> => {
    if (!telemetryInitialized || telemetryShutdown) return;
    telemetryShutdown = true;
    await shutdownTelemetry({ timeoutMs: CLI_SHUTDOWN_TIMEOUT_MS });
  };
  return {
    listSessions:
      overrides.listSessions ??
      ((workDir: string) =>
        getHarness().listSessions({
          workDir,
        })),
    exportSession:
      overrides.exportSession ??
      (async (input: ExportSessionInput) => {
        await initializeDefaultTelemetry();
        try {
          return await getHarness().exportSession(input);
        } finally {