codetether-agent 4.5.2

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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

//! Mock remote backends and sample record builders for tests.
//!
//! Provides `MockOk` (always succeeds), `MockErr` (always fails),
//! and [`sample`] for constructing test `OracleTraceRecord`s.
//!
//! # Examples
//!
//! ```ignore
//! let record = sample("golden");
//! let remote: Arc<dyn OracleRemote> = Arc::new(MockOk);
//! ```

use super::super::remote::OracleRemote;
use crate::rlm::oracle::record::OracleTraceRecord;
use crate::rlm::oracle::{FinalPayload, SemanticPayload, ValidatedTrace, VerificationMethod};
use anyhow::Result;
use async_trait::async_trait;
use chrono::Utc;

pub const MAX: u64 = 500 * 1024 * 1024;

pub struct MockOk;

#[async_trait]
impl OracleRemote for MockOk {
    async fn upload_record(&self, _: &OracleTraceRecord) -> Result<(String, String)> {
        Ok(("oracle/key.jsonl".into(), "http://example/key.jsonl".into()))
    }
}

pub struct MockErr;

#[async_trait]
impl OracleRemote for MockErr {
    async fn upload_record(&self, _: &OracleTraceRecord) -> Result<(String, String)> {
        anyhow::bail!("simulated failure")
    }
}

pub fn sample(verdict: &str) -> OracleTraceRecord {
    OracleTraceRecord {
        verdict: verdict.into(),
        reason: Some("reason".into()),
        agreement_ratio: None,
        trace: ValidatedTrace {
            prompt: "Find async fns".into(),
            trace: vec![],
            final_payload: Some(FinalPayload::Semantic(SemanticPayload {
                file: "src/main.rs".into(),
                answer: "answer".into(),
            })),
            verdict: verdict.into(),
            oracle_diff: None,
            repo_revision: "abc123".into(),
            timestamp: Utc::now().to_rfc3339(),
            answer: "answer".into(),
            iterations: 1,
            subcalls: 0,
            input_tokens: 1,
            output_tokens: 1,
            elapsed_ms: 1,
            source_path: Some("src/main.rs".into()),
            verification_method: VerificationMethod::None,
            trace_id: uuid::Uuid::new_v4().to_string(),
        },
    }
}