Method run_react_loop

src-tauri/src/agents/runner.rs:782–863

(
        &self,
        provider: &crate::models::Provider,
        model: &str,
        agent_run_id: &str,
        agent_type: &str,
        project_path: &str,
        tool_executor: &ToolExecutor

    #[allow(clippy::too_many_arguments)]
    async fn run_react_loop<S: TokenSink + Sync>(
        &self,
        provider: &crate::models::Provider,
        model: &str,
        agent_run_id: &str,
        agent_type: &str,
        project_path: &str,
        tool_executor: &ToolExecutor,
        messages: &mut Vec<ConversationMessage>,
        max_iterations: usize,
        token_sink: &S,
    ) -> AppResult<String> {
        let mut final_text = String::new();

        for _ in 0..max_iterations {
            // Check cancellation before each iteration
            if self.cancel_token.is_cancelled() {
                return Err(AppError::Cancelled);
            }

            let turn = if provider.uses_anthropic_format() {
                self.send_anthropic_with_tools(
                    &provider.base_url,
                    &provider.api_key,
                    &provider.provider_type,
                    model,
                    messages,
                    agent_run_id,
                    token_sink,
                )
                .await?
            } else {
                self.send_openai_compatible_with_tools(
                    &provider.base_url,
                    &provider.api_key,
                    model,
                    messages,
                    agent_run_id,
                    token_sink,
                )
                .await?
            };

            messages.push(ConversationMessage::assistant(
                turn.text.clone(),
                turn.tool_calls.clone(),
            ));

            if turn.tool_calls.is_empty() {
                final_text = turn.text.trim().to_string();
                break;
            }

            for tool_call in turn.tool_calls {
                // Check cancellation before each tool execution
                if self.cancel_token.is_cancelled() {
                    return Err(AppError::Cancelled);
                }