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

//! Tests for single-record persist operations.

use super::super::manager::OracleTraceStorage;
use super::fixtures::{MAX, MockErr, MockOk, sample};
use std::path::Path;
use std::sync::Arc;

#[tokio::test]
async fn keeps_spool_when_remote_fails() {
    let tmp = tempfile::tempdir().unwrap();
    let s = OracleTraceStorage::new_for_test(tmp.path().into(), MAX, Some(Arc::new(MockErr)));
    let r = s.persist_record(&sample("failed")).await.unwrap();
    assert!(!r.uploaded);
    assert_eq!(r.pending_count, 1);
    assert!(Path::new(&r.spooled_path).exists());
}

#[tokio::test]
async fn removes_spool_when_remote_succeeds() {
    let tmp = tempfile::tempdir().unwrap();
    let s = OracleTraceStorage::new_for_test(tmp.path().into(), MAX, Some(Arc::new(MockOk)));
    let r = s.persist_record(&sample("golden")).await.unwrap();
    assert!(r.uploaded);
    assert_eq!(r.pending_count, 0);
    assert!(!Path::new(&r.spooled_path).exists());
}