Method execute_agent_leaf

src-tauri/src/agents/runner.rs:733–779

(
        &self,
        agent_run_id: &str,
        ctx: &InternalRunContext<'_>,
        token_sink: &S,
    )

    #[allow(dead_code)]
    async fn execute_agent_leaf<S: TokenSink + Sync>(
        &self,
        agent_run_id: &str,
        ctx: &InternalRunContext<'_>,
        token_sink: &S,
    ) -> AppResult<String> {
        let system_prompt = get_prompt(ctx.agent_type).ok_or_else(|| {
            AppError::Validation(format!("Unknown agent type for prompt lookup: {}", ctx.agent_type))
        })?;

        let provider = provider_service::get_provider_for_chat(&self.db, ctx.provider_id).await?;
        let model = ctx.model_id.unwrap_or(&provider.model);
        let tool_executor = ToolExecutor::new(PathBuf::from(ctx.project_path));

        let system_content = if ctx.flux_enabled {
            if needs_full_preview_guide(ctx.task) {
                format!("{}\n\n{}\n\n{}", system_prompt, LANGUAGE_GUARD, PREVIEW_GUIDE)
            } else {
                format!("{}\n\n{}\n\n{}", system_prompt, LANGUAGE_GUARD, PREVIEW_HINT)
            }
        } else {
            format!("{}\n\n{}", system_prompt, LANGUAGE_GUARD)
        };

        // Load conversation history for context
        let history = self.load_conversation_history(ctx.session_id).await?;

        let mut messages = vec![ConversationMessage::system(&system_content)];
        if history.len() > 1 {
            let history_without_last = &history[..history.len() - 1];
            messages.extend_from_slice(history_without_last);
        }
        messages.push(ConversationMessage::user(ctx.task));

        self.run_react_loop(
            &provider,
            model,
            agent_run_id,
            ctx.agent_type,
            ctx.project_path,
            &tool_executor,
            &mut messages,
            MAX_REACT_ITERATIONS,
            token_sink,
        )
        .await
    }

    #[allow(clippy::too_many_arguments)]
    async fn run_react_loop<S: TokenSink + Sync>(