wm-tools 9.2.2

Curated tool implementations for the WhiteMagic MCP server.
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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93

//! Invented fixture: a corrected fact keeps its history reconstructible and the
//! answer evidence discloses supersession and the absence of event-time tracking.
use serde_json::json;
use std::sync::Arc;
use wm_core::episodic::{EpisodicKind, EpisodicRecord, Provenance, ProvenanceSource};
use wm_core::{Context, Galaxy, Tool};
use wm_memory::revision::RevisionActor;
use wm_memory::{Memory, MemoryStore};
use wm_tools::{MemoryReadTool, expansion::MemoryHybridRecallTool};

#[tokio::test]
async fn corrected_fact_stays_reconstructible_and_disclosed() {
    let dir = tempfile::tempdir().unwrap();
    let store = Arc::new(MemoryStore::open_default(dir.path().join("lmdb")).unwrap());
    let mut current = Memory::new(
        Galaxy::Research,
        "zxqtemporalcontract drink is tea".to_string(),
    );
    current.metadata.id = uuid::Uuid::from_u128(0x801);
    current.metadata.importance = 0.9;
    store.put(Galaxy::Research, &current).unwrap();
    let mut record = EpisodicRecord::new(
        Some(uuid::Uuid::from_u128(0x800)),
        1,
        EpisodicKind::UserStatement,
        "zxqtemporalcontract drink is tea".to_string(),
        Provenance::new(ProvenanceSource::User),
    );
    record.id = current.metadata.id;
    store.episodic().append(&record).unwrap();

    let original = Memory::new(
        Galaxy::Research,
        "zxqtemporalcontract drink is coffee".to_string(),
    );
    let intermediate = Memory::new(
        Galaxy::Research,
        "zxqtemporalcontract drink is matcha".to_string(),
    );
    for (old, new) in [
        (
            &original.metadata.content_hash,
            &intermediate.metadata.content_hash,
        ),
        (
            &intermediate.metadata.content_hash,
            &current.metadata.content_hash,
        ),
    ] {
        store
            .record_revision(
                Galaxy::Research,
                current.metadata.id,
                old,
                new,
                RevisionActor::default(),
            )
            .unwrap();
    }
    let chain = store
        .revisions(Galaxy::Research, current.metadata.id)
        .unwrap();
    assert_eq!(chain.len(), 2);
    assert!(wm_memory::revision::verify_chain(&chain, &current.metadata.content_hash).valid);

    let response = MemoryHybridRecallTool::as_search(store.clone(), None, None)
        .call(
            &mut Context::default(),
            json!({"query": "zxqtemporalcontract", "limit": 5}),
        )
        .await
        .unwrap();
    assert_eq!(response["count"], 1, "{response}");
    let entry = &response["evidence_bundle"]["entries"][0];
    assert_eq!(entry["history"]["revision_count"], 2);
    assert_eq!(entry["history"]["superseded"], true);
    assert_eq!(entry["history"]["chain_valid"], true);
    assert_eq!(entry["history"]["current"], true);
    assert!(entry["source_time"]["event_time"].is_null());
    assert_eq!(entry["source_time"]["event_time_basis"], "not_tracked");
    assert_eq!(entry["source_time"]["basis"], "recorded_at");

    assert_eq!(chain[0].old_hash, original.metadata.content_hash);
    assert_eq!(chain[1].old_hash, intermediate.metadata.content_hash);
    let read = MemoryReadTool::new(store.clone())
        .call(
            &mut Context::default(),
            json!({"id": current.metadata.id, "galaxy": "research"}),
        )
        .await
        .unwrap();
    assert_eq!(read["content"], "zxqtemporalcontract drink is tea");
}