Function incrementalImport

apps/cli/src/import/stream-import.ts:174–205

(
  dbManager: DatabaseManager,
  sessionId: string,
  filePath: string,
  options?: ImportOptions & { onProgress?: ImportProgressCallback }
)

}

export async function incrementalImport(
  dbManager: DatabaseManager,
  sessionId: string,
  filePath: string,
  options?: ImportOptions & { onProgress?: ImportProgressCallback }
): Promise<IncrementalImportResult> {
  const { onProgress, ...importOpts } = options || {}
  let compatibilityError: DataDirCompatibilityError | null = null
  const result = await sharedIncrementalImport(
    sessionId,
    filePath,
    buildIncrementalDeps(dbManager, onProgress, (error) => {
      compatibilityError = error
    }),
    importOpts
  )
  if (compatibilityError) throw compatibilityError
  if (!result.success) return result

  try {
    dbManager.raiseCurrentChatDbCompatibilityGate()
  } catch (error) {
    return {
      ...result,
      success: false,
      newMessageCount: 0,
      error: error instanceof Error ? error.message : String(error),
    }
  }

  return result
}

export async function analyzeIncrementalImport(
  dbManager: DatabaseManager,