Function callSummarizeAPIStreaming

testing/panel/tests/helpers.ts:300–364

(
  request: APIRequestContext,
  baseURL: string,
  options: SummarizeOptions,
)

 * Call the summarize API with streaming
 */
export async function callSummarizeAPIStreaming(
  request: APIRequestContext,
  baseURL: string,
  options: SummarizeOptions,
): Promise<{
  summary: string
  provider: string
  model: string
  chunkCount: number
}> {
  const response = await request.post(`${baseURL}/api/summarize`, {
    data: {
      text: options.text,
      provider: options.provider,
      model: options.model,
      maxLength: options.maxLength || 100,
      style: options.style || 'concise',
      stream: true,
    },
  })

  if (!response.ok()) {
    const errorBody = await response.text()
    throw new Error(
      `Summarize API streaming failed: ${response.status()} - ${errorBody}`,
    )
  }

  // Parse SSE response
  const text = await response.text()
  const lines = text.split('\n')

  let summary = ''
  let provider = ''
  let model = ''
  let chunkCount = 0

  for (const line of lines) {
    if (line.startsWith('data: ')) {
      const data = line.slice(6)
      if (data === '[DONE]') continue

      try {
        const parsed = JSON.parse(data)
        if (parsed.type === 'error') {
          throw new Error(parsed.error)
        }
        if (parsed.type === 'TEXT_MESSAGE_CONTENT') {
          chunkCount++
          if (parsed.delta) {
            summary += parsed.delta
          } else if (parsed.content) {
            summary = parsed.content
          }
          provider = parsed.provider || provider
          model = parsed.model || model
        }
      } catch {