Method parse_openai_sse_line

src-tauri/src/agents/runner.rs:1314–1417

(
        &self,
        line: &str,
        agent_run_id: &str,
        token_sink: &S,
        output: &mut String,
        pending_calls: &mut HashMap<usize, StreamingToolCall>,
        stop_reason

    #[allow(clippy::too_many_arguments)]
    fn parse_openai_sse_line<S: TokenSink + Sync>(
        &self,
        line: &str,
        agent_run_id: &str,
        token_sink: &S,
        output: &mut String,
        pending_calls: &mut HashMap<usize, StreamingToolCall>,
        stop_reason: &mut Option<String>,
    ) -> AppResult<bool> {
        let trimmed = line.trim();
        if trimmed.is_empty() {
            return Ok(false);
        }

        let Some(payload_raw) = trimmed.strip_prefix("data:") else {
            return Ok(false);
        };

        let payload = payload_raw.trim();
        if payload == "[DONE]" {
            return Ok(true);
        }

        let value: Value = serde_json::from_str(payload)?;
        let Some(choice) = value
            .get("choices")
            .and_then(Value::as_array)
            .and_then(|items| items.first())
        else {
            return Ok(false);
        };

        if let Some(reason) = choice.get("finish_reason").and_then(Value::as_str) {
            *stop_reason = Some(reason.to_string());
        }

        if let Some(token) = choice
            .get("delta")
            .and_then(|delta| delta.get("content"))
            .and_then(Value::as_str)
        {
            output.push_str(token);
            token_sink.send(token);
            let _ = self.app_handle.emit(
                "agent-token",
                AgentTokenEvent {
                    agent_run_id: agent_run_id.to_string(),
                    token: token.to_string(),
                },
            );
        }

        if let Some(tool_calls) = choice
            .get("delta")
            .and_then(|delta| delta.get("tool_calls"))
            .and_then(Value::as_array)
        {
            for chunk in tool_calls {