Function streamingImport

packages/node-runtime/src/import/streaming-importer.ts:97–122

(
  filePath: string,
  deps: StreamImportDeps,
  formatOptions?: Record<string, unknown>,
  externalSessionId?: string
)

 * with batched transactions. Supports format auto-detection with fallback.
 */
export async function streamingImport(
  filePath: string,
  deps: StreamImportDeps,
  formatOptions?: Record<string, unknown>,
  externalSessionId?: string
): Promise<StreamImportResult> {
  if (formatOptions?.formatId) {
    const formatId = formatOptions.formatId as string
    const feature = getFormatFeatureById(formatId)
    if (!feature) {
      return { success: false, error: 'error.unknown_format_id' }
    }
    return streamImportSingle(filePath, deps, feature, formatOptions, externalSessionId)
  }

  const candidates = detectAllFormats(filePath)
  if (candidates.length === 0) {
    return { success: false, error: 'error.unrecognized_format' }
  }

  if (candidates.length > 1) {
    return streamImportWithFallback(filePath, deps, candidates, formatOptions, externalSessionId)
  }

  return streamImportSingle(filePath, deps, candidates[0], formatOptions, externalSessionId)
}

async function streamImportWithFallback(
  filePath: string,