roder-core 0.3.2

Agentic software development tools and SDKs for Roder.
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

use super::Runtime;
use roder_api::thread::{ThreadItem, ThreadItemEventKind};
use time::OffsetDateTime;

#[tokio::test]
async fn independent_runtimes_do_not_reuse_projected_event_identity() {
    let left = Runtime::fake().expect("runtime");
    let right = Runtime::fake().expect("runtime");
    let kind = ThreadItemEventKind::ItemStarted {
        item: ThreadItem::UserMessage {
            id: "item".into(),
            text: "hello".into(),
            images: Vec::new(),
            status: None,
        },
    };
    let thread = "shared-thread".to_string();
    let turn = "shared-turn".to_string();
    let a = left
        .record_thread_item_event_kind(&thread, &turn, OffsetDateTime::UNIX_EPOCH, kind.clone())
        .await
        .expect("left event");
    let b = right
        .record_thread_item_event_kind(&thread, &turn, OffsetDateTime::UNIX_EPOCH, kind)
        .await
        .expect("right event");
    assert_eq!(
        a.seq, b.seq,
        "independent caches start at the same sequence"
    );
    assert_ne!(
        a.event_id, b.event_id,
        "different events must not deduplicate at persistence"
    );
}