Method pre_analyze

core/src/planning/llm_planner.rs:215–249

Perform pre-analysis in a single LLM call: intent classification, goal extraction, execution plan, and input optimization. Falls back to heuristics on failure.

(llm: &Arc<dyn LlmClient>, prompt: &str)

    /// Perform pre-analysis in a single LLM call: intent classification, goal extraction,
    /// execution plan, and input optimization. Falls back to heuristics on failure.
    pub async fn pre_analyze(llm: &Arc<dyn LlmClient>, prompt: &str) -> Result<PreAnalysis> {
        let system = crate::prompts::PRE_ANALYSIS_SYSTEM;

        // One initial attempt plus one repair round: if the model returns
        // unparseable JSON, re-prompt it once to emit strictly valid JSON before
        // giving up (callers fall back to heuristics on the returned error).
        const MAX_ATTEMPTS: usize = 2;
        let mut messages = vec![Message::user(prompt)];
        let mut last_err: Option<anyhow::Error> = None;

        for attempt in 0..MAX_ATTEMPTS {
            let response = llm
                .complete(&messages, Some(system), &[])
                .await
                .context("LLM pre-analysis call failed")?;

            let text = response.text();
            match Self::parse_pre_analysis_response(&text, prompt) {
                Ok(analysis) => return Ok(analysis),
                Err(e) => {
                    last_err = Some(e);
                    if attempt + 1 < MAX_ATTEMPTS {
                        messages.push(response.message.clone());
                        messages.push(Message::user(
                            "Your previous response was not valid JSON matching the required \
                             schema. Respond again with ONLY the JSON object — no markdown \
                             fences, no prose, no explanation.",
                        ));
                    }
                }
            }
        }

        Err(last_err.unwrap_or_else(|| anyhow::anyhow!("pre-analysis produced no result")))
    }

    fn parse_pre_analysis_response(text: &str, original_prompt: &str) -> Result<PreAnalysis> {
        let parsed: PreAnalysisResponse = Self::parse_json_lenient(text)