adk-core 0.6.0

Core traits and types for Rust Agent Development Kit (ADK-Rust) agents, tools, sessions, and 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
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94

//! Integration tests for SharedState coordination primitives.

use adk_core::{SharedState, SharedStateError};
use std::sync::Arc;
use std::time::Duration;

#[tokio::test]
async fn test_wait_for_key_wakes_on_set() {
    let state = Arc::new(SharedState::new());
    let state2 = state.clone();

    let handle =
        tokio::spawn(async move { state2.wait_for_key("workbook", Duration::from_secs(5)).await });

    // Small delay to ensure waiter is blocked
    tokio::time::sleep(Duration::from_millis(50)).await;

    state.set_shared("workbook", serde_json::json!("wb-123")).await.unwrap();

    let result = handle.await.unwrap().unwrap();
    assert_eq!(result, serde_json::json!("wb-123"));
}

#[tokio::test]
async fn test_multiple_waiters_all_wake() {
    let state = Arc::new(SharedState::new());

    let mut handles = Vec::new();
    for _ in 0..3 {
        let s = state.clone();
        handles.push(tokio::spawn(async move {
            s.wait_for_key("handle", Duration::from_secs(5)).await
        }));
    }

    tokio::time::sleep(Duration::from_millis(50)).await;
    state.set_shared("handle", serde_json::json!(42)).await.unwrap();

    for handle in handles {
        let result = handle.await.unwrap().unwrap();
        assert_eq!(result, serde_json::json!(42));
    }
}

#[tokio::test]
async fn test_shared_state_serialize() {
    let state = SharedState::new();
    state.set_shared("a", serde_json::json!(1)).await.unwrap();
    state.set_shared("b", serde_json::json!("hello")).await.unwrap();

    let json = serde_json::to_value(&state).unwrap();
    assert_eq!(json["a"], 1);
    assert_eq!(json["b"], "hello");
}

#[tokio::test]
async fn test_shared_state_debug() {
    let state = SharedState::new();
    state.set_shared("key", serde_json::json!("val")).await.unwrap();
    let debug = format!("{state:?}");
    assert!(!debug.is_empty());
}

#[tokio::test]
async fn test_concurrent_set_and_get() {
    let state = Arc::new(SharedState::new());
    let mut handles = Vec::new();

    // 10 concurrent writers
    for i in 0..10 {
        let s = state.clone();
        handles.push(tokio::spawn(async move {
            s.set_shared(format!("key-{i}"), serde_json::json!(i)).await.unwrap();
        }));
    }

    for handle in handles {
        handle.await.unwrap();
    }

    // All 10 keys should be present
    let snapshot = state.snapshot().await;
    assert_eq!(snapshot.len(), 10);
    for i in 0..10 {
        assert_eq!(snapshot[&format!("key-{i}")], serde_json::json!(i));
    }
}

#[tokio::test]
async fn test_wait_for_key_timeout() {
    let state = SharedState::new();
    let err = state.wait_for_key("missing", Duration::from_millis(10)).await.unwrap_err();
    assert!(matches!(err, SharedStateError::Timeout { .. }));
}