harness-rs-core 0.0.13

Core traits and types for the harness-rs agent framework: Model, Tool, Guide, Sensor, Hook, Compactor, Skill, plus Context, World, Block, Event, FixPatch and 27 lifecycle events.
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

//! Reusable conformance suite for [`crate::RecallStore`] backends. Each backend
//! crate calls `recall_contract(store)` from a `#[tokio::test]` so all impls are
//! held to identical behaviour — including the privacy-critical owner isolation.

use crate::{RecallMessage, RecallStore, SessionMeta};
use std::sync::Arc;

/// Run the full contract against a fresh, empty `store`.
pub async fn recall_contract(store: Arc<dyn RecallStore>) {
    // ── append + search round-trip ──
    store
        .ensure_session("alice", "s1", &SessionMeta::new("s1", 100))
        .await
        .unwrap();
    store
        .append(
            "alice",
            "s1",
            &RecallMessage::new("user", "refactor the auth module today", 100),
        )
        .await
        .unwrap();
    store
        .append(
            "alice",
            "s1",
            &RecallMessage::new("assistant", "starting the auth refactor now", 101),
        )
        .await
        .unwrap();
    store
        .append(
            "alice",
            "s1",
            &RecallMessage::new("tool", "edited auth.rs", 102).with_tool_name("edit"),
        )
        .await
        .unwrap();

    let hits = store.search("alice", "auth refactor", 5).await.unwrap();
    assert_eq!(hits.len(), 1, "search should find the session");
    assert_eq!(hits[0].session.session_id, "s1");
    assert!(!hits[0].bookend_start.is_empty(), "hit carries bookends");

    // ── scroll window ──
    let scrolled = store.scroll("alice", "s1", 2, 1).await.unwrap();
    assert!(scrolled.iter().all(|m| (m.id - 2).abs() <= 1));
    assert!(scrolled.iter().any(|m| m.id == 2));

    // ── recent ordering ──
    store
        .ensure_session("alice", "s2", &SessionMeta::new("s2", 200))
        .await
        .unwrap();
    store
        .append(
            "alice",
            "s2",
            &RecallMessage::new("user", "a newer session", 200),
        )
        .await
        .unwrap();
    let recent = store.recent("alice", 10).await.unwrap();
    assert_eq!(recent.len(), 2);
    assert_eq!(recent[0].session_id, "s2", "newest first");

    // ── OWNER ISOLATION (privacy-critical) ──
    let bob_search = store.search("bob", "auth refactor", 5).await.unwrap();
    assert!(bob_search.is_empty(), "bob must not see alice's sessions");
    let bob_recent = store.recent("bob", 10).await.unwrap();
    assert!(bob_recent.is_empty(), "bob has no sessions");
    let bob_scroll = store.scroll("bob", "s1", 1, 5).await.unwrap();
    assert!(bob_scroll.is_empty(), "bob cannot scroll alice's session");

    // ── empty query is not an error ──
    let empty = store.search("alice", "", 5).await.unwrap();
    assert!(empty.is_empty());
}