Function parse_openai_sse_line

src-tauri/src/services/chat_service.rs:680–723

(
    line: &str,
    on_token: &Channel<String>,
    output: &mut String,
    usage: &mut UsageAccumulator,
)

}

fn parse_openai_sse_line(
    line: &str,
    on_token: &Channel<String>,
    output: &mut String,
    usage: &mut UsageAccumulator,
) -> AppResult<bool> {
    let trimmed = line.trim();
    if trimmed.is_empty() {
        return Ok(false);
    }

    let Some(payload) = trimmed.strip_prefix("data:") else {
        return Ok(false);
    };
    let payload = payload.trim();
    if payload == "[DONE]" {
        return Ok(true);
    }

    let value: Value = serde_json::from_str(payload)?;

    if let Some(u) = value.get("usage") {
        if let Some(pt) = u.get("prompt_tokens").and_then(Value::as_u64) {
            usage.prompt_tokens = pt as u32;
        }
        if let Some(ct) = u.get("completion_tokens").and_then(Value::as_u64) {
            usage.completion_tokens = ct as u32;
        }
    }

    if let Some(token) = value
        .get("choices")
        .and_then(Value::as_array)
        .and_then(|c| c.first())
        .and_then(|c| c.get("delta"))
        .and_then(|d| d.get("content"))
        .and_then(Value::as_str)
    {
        output.push_str(token);
        let _ = on_token.send(token.to_string());
    }

    Ok(false)
}

async fn stream_anthropic_sse(
    response: reqwest::Response,