Function fetchSSEWithHandlers

src/services/utils/sse.ts:81–118

(options: {
  url: string
  method?: 'GET' | 'POST'
  body?: unknown
  signal?: AbortSignal
  onProgress?: (data: unknown) => void
  resultEvent?: string
})

 * 便捷方法：发起 SSE 请求，按 event type 分发解析后的 JSON。
 */
export async function fetchSSEWithHandlers<TResult = unknown>(options: {
  url: string
  method?: 'GET' | 'POST'
  body?: unknown
  signal?: AbortSignal
  onProgress?: (data: unknown) => void
  resultEvent?: string
}): Promise<TResult> {
  const { url, method, body, signal, onProgress, resultEvent = 'result' } = options

  return new Promise<TResult>((resolve, reject) => {
    let resolved = false

    fetchSSE({
      url,
      method,
      body,
      signal,
      onEvent: ({ event, data }) => {
        try {
          const parsed = JSON.parse(data)
          if (event === resultEvent) {
            resolved = true
            resolve(parsed as TResult)
          } else if (event === 'progress' && onProgress) {
            onProgress(parsed)
          }
        } catch {
          // skip malformed JSON
        }
      },
    })
      .then(() => {
        if (!resolved) reject(new Error('SSE stream ended without result event'))
      })
      .catch(reject)
  })
}