exocortex-client 0.1.0

The Exocortex MCP client: local cache, WAL offline capture, the session-wrapup tool, and the reconnecting SSE subscriber.
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

use exocortex_client::wal::{WalEntry, WalState};

#[test]
fn wal_entry_bincode_roundtrip() {
    let e = WalEntry {
        local_lsn: 1,
        session_id: "s".into(),
        memories: vec![],
        memory_ids: vec![exocortex_kernel::MemoryId::new_v7()],
        state: WalState::Pending,
    };
    let bytes = bincode::serialize(&e).unwrap();
    let back: WalEntry = bincode::deserialize(&bytes).unwrap();
    assert_eq!(back.state, WalState::Pending);
}

#[test]
fn wal_pending_count_diagnostics() {
    let dir = std::env::temp_dir().join(format!("exocortex-wal-diag-{}", std::process::id()));
    let _ = std::fs::remove_dir_all(&dir);
    let wal = exocortex_client::wal::Wal::open(&dir).unwrap();
    let lsn = wal.append_batch("s", vec![], vec![]).unwrap();
    let tree_entries: usize = { wal.db_len() };
    println!(
        "lsn={lsn} entries={tree_entries} pending={}",
        wal.pending_count()
    );
    assert_eq!(wal.pending_count(), 1);
    std::fs::remove_dir_all(&dir).unwrap();
}