Method parse_anthropic_sse_line

src-tauri/src/agents/runner.rs:1464–1617

(
        &self,
        line: &str,
        current_event: &mut String,
        agent_run_id: &str,
        token_sink: &S,
        output: &mut String,
        pending_calls: &mut HashMap<usize, Str

    #[allow(clippy::too_many_arguments)]
    fn parse_anthropic_sse_line<S: TokenSink + Sync>(
        &self,
        line: &str,
        current_event: &mut String,
        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);
        }

        if let Some(event_name) = trimmed.strip_prefix("event:") {
            let event_name = event_name.trim();
            *current_event = event_name.to_string();
            if event_name == "message_stop" {
                return Ok(true);
            }
            return Ok(false);
        }

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

        let value: Value = match serde_json::from_str(payload) {
            Ok(value) => value,
            Err(_) => return Ok(false),
        };

        // Prefer `"type"` from JSON payload; fall back to the preceding
        // `event:` line when the gateway strips it.
        let event_type = value
            .get("type")
            .and_then(Value::as_str)
            .unwrap_or(current_event.as_str());

        match event_type {
            "content_block_start" => {
                let is_tool_use = value
                    .get("content_block")
                    .and_then(|block| block.get("type"))
                    .and_then(Value::as_str)
                    == Some("tool_use");

                if is_tool_use {
                    let index_u64 = value
                        .get("index")
                        .and_then(Value::as_u64)
                        .ok_or_else(|| {
                            AppError::Json(
                                "Anthropic tool_use content_block_start missing index".to_string(),
                            )
                        })?;