Method importDemo

src/services/import/fetch.ts:144–191

(locale: string, onProgress?: (p: DemoProgress) => void)

  }

  async importDemo(locale: string, onProgress?: (p: DemoProgress) => void): Promise<DemoImportResult> {
    return new Promise((resolve) => {
      fetchWithAuth(`${getBaseUrl()}/demo/import`, {
        method: 'POST',
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify({ locale }),
      })
        .then(async (resp) => {
          if (!resp.ok || !resp.body) {
            resolve({ success: false, error: `HTTP ${resp.status}` })
            return
          }

          const reader = resp.body.getReader()
          const decoder = new TextDecoder()
          let buffer = ''

          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') {
                  if (data.stage === 'downloading' || data.stage === 'importing') {
                    onProgress?.({ stage: data.stage })
                  }
                } else if (eventType === 'result') {
                  resolve(data as DemoImportResult)
                  return
                }
                eventType = ''
              }
            }
          }
          resolve({ success: false, error: 'Stream ended without result' })
        })
        .catch((e) => resolve({ success: false, error: String(e) }))
    })
  }

  async analyzeIncrementalImport(sessionId: string, file: File | string): Promise<IncrementalAnalysis> {
    if (typeof file === 'string') {