deepstrike-sdk 0.2.37

DeepStrike Rust SDK — agent framework built on deepstrike-core
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

//! Fixture helpers for `ReplayProvider`.
//!
//! Rust port of node/src/runtime/replay-fixture.ts. Walks `llm_completed` events from a
//! recorded session log and returns the ordered list of assistant Messages that
//! `ReplayProvider` consumes.

use deepstrike_core::runtime::session::SessionEvent;
use deepstrike_core::types::message::Message;

use super::session_log::SessionEntry;

/// Walk `SessionEntry`s (the wrapped `{ seq, event }` shape `SessionLog::read()` returns)
/// and produce the ordered list of assistant messages.
pub fn extract_recorded_messages_from_entries(entries: &[SessionEntry]) -> Vec<Message> {
    entries
        .iter()
        .filter_map(|e| message_from_event(&e.event))
        .collect()
}

/// Walk bare `SessionEvent`s — useful when reading a `serde_json::Value` log file rather
/// than a `SessionLog`.
pub fn extract_recorded_messages(events: &[SessionEvent]) -> Vec<Message> {
    events.iter().filter_map(message_from_event).collect()
}

fn message_from_event(event: &SessionEvent) -> Option<Message> {
    if let SessionEvent::LlmCompleted { message, .. } = event {
        Some(message.clone())
    } else {
        None
    }
}