weavegraph 0.7.0

Graph-driven, concurrent agent workflow framework with versioned state, deterministic barrier merges, and rich diagnostics.
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

//! [`From`] conversions between weavegraph [`Message`] and Rig's [`RigMessage`].
use crate::message::{Message, Role};
use rig::completion::message::{
    AssistantContent, Message as RigMessage, ToolResultContent, UserContent,
};

impl From<Message> for RigMessage {
    fn from(msg: Message) -> Self {
        match msg.role {
            Role::User => RigMessage::user(msg.content),
            Role::Assistant => RigMessage::assistant(msg.content),
            // Rig history is user/assistant only; fold remaining roles into user.
            Role::System | Role::Tool | Role::Custom(_) => RigMessage::user(msg.content),
        }
    }
}

impl From<RigMessage> for Message {
    fn from(msg: RigMessage) -> Self {
        match msg {
            RigMessage::User { content } => Message::with_role(
                Role::User,
                &content.iter().find_map(user_text).unwrap_or_default(),
            ),
            RigMessage::Assistant { content, .. } => Message::with_role(
                Role::Assistant,
                &content.iter().find_map(assistant_text).unwrap_or_default(),
            ),
        }
    }
}

fn user_text(content: &UserContent) -> Option<String> {
    match content {
        UserContent::Text(t) => Some(t.text.clone()),
        UserContent::ToolResult(r) => r.content.iter().find_map(|chunk| match chunk {
            ToolResultContent::Text(t) => Some(t.text.clone()),
            ToolResultContent::Image(_) => None,
        }),
        UserContent::Image(_)
        | UserContent::Audio(_)
        | UserContent::Video(_)
        | UserContent::Document(_) => None,
    }
}

fn assistant_text(content: &AssistantContent) -> Option<String> {
    match content {
        AssistantContent::Text(t) => Some(t.text.clone()),
        AssistantContent::Reasoning(r) => r.reasoning.first().cloned(),
        AssistantContent::ToolCall(c) => Some(format!("[tool_call:{}]", c.function.name)),
        AssistantContent::Image(_) => None,
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    fn first_user_text(msg: RigMessage) -> Option<String> {
        match msg {
            RigMessage::User { content } => content.iter().find_map(user_text),
            RigMessage::Assistant { .. } => None,
        }
    }

    #[test]
    fn maps_weavegraph_roles_to_rig_messages() {
        let user = RigMessage::from(Message::user("u"));
        let assistant = RigMessage::from(Message::assistant("a"));
        let system = RigMessage::from(Message::system("s"));
        let tool = RigMessage::from(Message::tool("t"));
        let custom = RigMessage::from(Message::with_role(Role::Custom("worker".into()), "c"));

        assert_eq!(first_user_text(user), Some("u".to_string()));
        assert_eq!(first_user_text(system), Some("s".to_string()));
        assert_eq!(first_user_text(tool), Some("t".to_string()));
        assert_eq!(first_user_text(custom), Some("c".to_string()));

        match assistant {
            RigMessage::Assistant { content, .. } => {
                assert_eq!(
                    content.iter().find_map(assistant_text),
                    Some("a".to_string())
                );
            }
            RigMessage::User { .. } => panic!("assistant role should map to rig assistant"),
        }
    }

    #[test]
    fn maps_rig_messages_to_weavegraph_messages() {
        let user: Message = RigMessage::user("hello").into();
        assert_eq!(user.role, Role::User);
        assert_eq!(user.content, "hello");

        let assistant: Message = RigMessage::assistant("world").into();
        assert_eq!(assistant.role, Role::Assistant);
        assert_eq!(assistant.content, "world");
    }

    #[test]
    fn preserves_text_from_rig_tool_result_user_messages() {
        let tool_result: Message = RigMessage::tool_result("tool-1", "ok").into();
        assert_eq!(tool_result.role, Role::User);
        assert_eq!(tool_result.content, "ok");
    }
}