Function streamImport

apps/desktop/main/worker/workerManager.ts:518–548

(
  filePath: string,
  onProgress?: (progress: ParseProgress) => void,
  formatOptions?: Record<string, unknown>,
  externalSessionId?: string
)

 * @param formatOptions 格式特定选项（如 Telegram 的 chatIndex）
 */
export async function streamImport(
  filePath: string,
  onProgress?: (progress: ParseProgress) => void,
  formatOptions?: Record<string, unknown>,
  externalSessionId?: string
): Promise<StreamImportResult> {
  assertDataDirCompatibleNow()

  const result = await sendToWorkerWithProgress<StreamImportResult>(
    'streamImport',
    { filePath, formatOptions, externalSessionId },
    onProgress
  )
  if (!result.success || !result.sessionId) return result

  try {
    raiseChatDbCompatibilityGate(getPathProvider(), {
      version: getDesktopAppVersion(app.getVersion()),
      kind: 'desktop',
    })
  } catch (error) {
    deleteImportedSessionFiles(result.sessionId)
    return {
      success: false,
      error: error instanceof Error ? error.message : String(error),
      diagnostics: result.diagnostics,
    }
  }

  return result
}

function deleteImportedSessionFiles(sessionId: string): void {
  const dbPath = path.join(getDbDir(), `${sessionId}.db`)