Class FetchImportAdapter

src/services/import/fetch.ts:57–271

}

export class FetchImportAdapter implements ImportAdapter {
  async importFile(
    file: File | string,
    options?: ImportOptions,
    onProgress?: (p: ImportProgress) => void
  ): Promise<ImportResult> {
    if (typeof file === 'string') {
      return { success: false, error: 'File path import is not supported in Web mode' }
    }

    const form = new FormData()
    form.append('file', file)
    if (options?.formatId) form.append('formatId', options.formatId)
    if (options?.chatIndex !== undefined) form.append('chatIndex', String(options.chatIndex))

    const res = await fetchWithAuth(`${getBaseUrl()}/import`, { method: 'POST', body: form })

    if (!res.ok) {
      const text = await res.text()
      return { success: false, error: `HTTP ${res.status}: ${text}` }
    }

    return consumeSseStream<ImportResult>(res, { success: false, error: 'Unknown error' }, onProgress)
  }

  async detectFormat(file: File | string): Promise<FormatInfo | null> {
    if (typeof file === 'string') return null
    const form = new FormData()
    form.append('file', file)
    const res = await fetchWithAuth(`${getBaseUrl()}/detect-format`, { method: 'POST', body: form })
    if (!res.ok) return null
    const data = (await res.json()) as { format: FormatInfo | null }
    return data.format
  }

  async scanMultiChatFile(file: File | string): Promise<MultiChatEntry[]> {
    if (typeof file === 'string') return []
    const form = new FormData()
    form.append('file', file)
    const res = await fetchWithAuth(`${getBaseUrl()}/scan-multi-chat`, { method: 'POST', body: form })
    if (!res.ok) return []
    const data = (await res.json()) as { chats: MultiChatEntry[] }
    return data.chats
  }

  async prepareImportSource(file: File | string): Promise<PreparedImportSourceResult> {
    if (typeof file === 'string') {
      return { success: false, error: 'File path import is not supported in Web mode' }
    }

    const form = new FormData()
    form.append('file', file)
    const res = await fetchWithAuth(`${getBaseUrl()}/import-sources`, { method: 'POST', body: form })
    const data = (await res.json().catch(() => null)) as PreparedImportSourceResult | null
    if (!res.ok) {
      return { success: false, error: data?.error || `HTTP ${res.status}` }
    }
    return data ?? { success: false, error: 'Invalid import source response' }