codetether-agent 4.7.0-a-002.4

A2A-native AI coding agent for the CodeTether ecosystem
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

//! Analysis bridge implementation.

use anyhow::Result;
use std::time::Instant;

use super::RlmExecutor;
use crate::rlm::router::RlmRouter;
use crate::rlm::{RlmAnalysisResult, RlmConfig, RlmStats, SubQuery};

/// Execute one bridge analysis through the crate router.
pub async fn analyze(exec: &mut RlmExecutor, query: &str) -> Result<RlmAnalysisResult> {
    let started = Instant::now();
    let ctx = super::context::auto_context(exec, query);
    let cfg = RlmConfig {
        max_iterations: exec.max_iterations,
        ..Default::default()
    };
    let result = RlmRouter::auto_process(&exec.context, ctx, &cfg).await?;
    let answer = answer_text(&result.processed);
    super::trace::record_trace(exec, query, &answer, &result);
    Ok(RlmAnalysisResult {
        sub_queries: vec![SubQuery {
            query: query.into(),
            context_slice: None,
            response: answer.clone(),
            tokens_used: result.stats.output_tokens,
        }],
        iterations: result.stats.iterations,
        stats: RlmStats {
            elapsed_ms: started.elapsed().as_millis() as u64,
            ..result.stats
        },
        answer,
    })
}

fn answer_text(processed: &str) -> String {
    processed
        .split_once("\n\n")
        .map_or(processed, |(_, answer)| answer)
        .trim()
        .to_string()
}