Function consumeSseStream

src/services/import/fetch.ts:22–55

(res: Response, fallback: T, onProgress?: (p: ImportProgress) => void)

import { get, fetchWithAuth, getBaseUrl } from '../utils/http'

async function consumeSseStream<T>(res: Response, fallback: T, onProgress?: (p: ImportProgress) => void): Promise<T> {
  const reader = res.body?.getReader()
  if (!reader) return fallback

  const decoder = new TextDecoder()
  let buffer = ''
  let result: T = fallback

  while (true) {
    const { done, value } = await reader.read()
    if (done) break

    buffer += decoder.decode(value, { stream: true })
    const lines = buffer.split('\n')
    buffer = lines.pop() || ''

    let eventType = ''
    for (const line of lines) {
      if (line.startsWith('event: ')) {
        eventType = line.slice(7).trim()
      } else if (line.startsWith('data: ')) {
        const data = JSON.parse(line.slice(6))
        if (eventType === 'progress') {
          onProgress?.(data as ImportProgress)
        } else if (eventType === 'done' || eventType === 'error') {
          result = data as T
        }
        eventType = ''
      }
    }
  }

  return result
}

export class FetchImportAdapter implements ImportAdapter {
  async importFile(