nexo-core 0.1.12

Agent runtime: event bus, sessions, plugin trait, heartbeat, A2A delegation.
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
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117

//! Phase 10.5 integration test — MemoryTool.recall auto-logs recall events
//! so the signal store can drive the dreaming sweep later.

use std::sync::Arc;
use std::time::Duration;

use nexo_broker::AnyBroker;
use nexo_config::types::agents::{AgentConfig, AgentRuntimeConfig, HeartbeatConfig, ModelConfig};
use nexo_core::agent::{AgentContext, MemoryTool, ToolHandler};
use nexo_core::session::SessionManager;
use nexo_memory::LongTermMemory;
use serde_json::json;

#[tokio::test]
async fn memory_recall_records_events_for_every_hit() -> anyhow::Result<()> {
    let memory = Arc::new(LongTermMemory::open(":memory:").await?);
    let a = memory
        .remember("kate", "Cristian likes dark mode", &[])
        .await?;
    let b = memory
        .remember("kate", "Cristian prefers dark colors", &[])
        .await?;
    let _c = memory.remember("kate", "Kate runs on MiniMax", &[]).await?;

    let cfg = Arc::new(AgentConfig {
        id: "kate".into(),
        model: ModelConfig {
            provider: "stub".into(),
            model: "m1".into(),
        },
        plugins: vec![],
        heartbeat: HeartbeatConfig::default(),
        config: AgentRuntimeConfig::default(),
        system_prompt: String::new(),
        workspace: String::new(),
        skills: vec![],
        skills_dir: "./skills".into(),
        skill_overrides: Default::default(),
        transcripts_dir: String::new(),
        dreaming: Default::default(),
        workspace_git: Default::default(),
        tool_rate_limits: None,
        tool_args_validation: None,
        extra_docs: Vec::new(),
        inbound_bindings: Vec::new(),
        allowed_tools: Vec::new(),
        sender_rate_limit: None,
        allowed_delegates: Vec::new(),
        accept_delegates_from: Vec::new(),
        description: String::new(),
        outbound_allowlist: Default::default(),
        google_auth: None,
        credentials: Default::default(),
        link_understanding: serde_json::Value::Null,
        web_search: serde_json::Value::Null,
        pairing_policy: serde_json::Value::Null,
        language: None,
        context_optimization: None,
        dispatch_policy: Default::default(),
        plan_mode: Default::default(),
        remote_triggers: Vec::new(),
        lsp: nexo_config::types::lsp::LspPolicy::default(),
        config_tool: nexo_config::types::config_tool::ConfigToolPolicy::default(),
        team: nexo_config::types::team::TeamPolicy::default(),
        proactive: Default::default(),
        repl: Default::default(),
        auto_dream: None,
        assistant_mode: None,
        away_summary: None,
        brief: None,
        channels: None,
        auto_approve: false,
        extract_memories: None,
        event_subscribers: Vec::new(),
        tenant_id: None,
        extensions_config: std::collections::BTreeMap::new(),
        active: true,
    });
    let broker = AnyBroker::local();
    let sessions = Arc::new(SessionManager::new(Duration::from_secs(60), 20));
    let ctx = AgentContext::new("kate", cfg, broker, sessions).with_memory(Arc::clone(&memory));

    let tool = MemoryTool::new(Arc::clone(&memory));
    let out = tool
        .call(
            &ctx,
            json!({ "action": "recall", "query": "dark", "limit": 5 }),
        )
        .await?;
    let results = out["results"].as_array().unwrap();
    assert_eq!(results.len(), 2, "two memories match 'dark'");

    // Both surfaced memories must have one recall event each.
    let sig_a = memory.recall_signals("kate", a, None).await?;
    let sig_b = memory.recall_signals("kate", b, None).await?;
    assert_eq!(sig_a.recall_count, 1);
    assert_eq!(sig_b.recall_count, 1);
    // Position 1 → score 1.0, position 2 → 0.5. Exact order depends on FTS5 bm25,
    // so just assert the relevance values sum to 1.5 (top + second hit).
    let total = sig_a.relevance + sig_b.relevance;
    assert!(
        (total - 1.5).abs() < 1e-4,
        "expected 1.0+0.5 total, got {total}"
    );

    // Second recall with a different query → signals accumulate.
    tool.call(
        &ctx,
        json!({ "action": "recall", "query": "Cristian", "limit": 5 }),
    )
    .await?;
    let sig_a2 = memory.recall_signals("kate", a, None).await?;
    assert_eq!(sig_a2.recall_count, 2);
    // Two distinct queries → diversity must be > 0.
    assert!(sig_a2.diversity > 0.0);
    Ok(())
}