behest 0.3.3

A Rust-native cloud agent runtime with typed tools, pluggable memory, queues, and observability.
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

//! Demonstrates appending messages to a session and listing message history.
//!
//! Run with:
//! ```bash
//! cargo run --example message_history
//! ```

use behest::provider::{ContentPart, ModelName};
use behest::store::memory::MemorySessionStore;
use behest::store::{MessageRecord, MessageRole, Session, SessionStore};

#[tokio::main]
async fn main() -> Result<(), behest::Error> {
    let store = MemorySessionStore::new();

    let session = Session::new("Demo Chat", ModelName::new("gpt-4o"));
    let session = store
        .create_session(session)
        .await
        .map_err(behest::Error::Storage)?;

    println!("Created session: {}", session.id);

    let user_msg = store
        .append_message(MessageRecord::new(
            session.id,
            MessageRole::User,
            vec![ContentPart::text("What is the capital of France?")],
        ))
        .await
        .map_err(behest::Error::Storage)?;
    println!("Appended user message: {}", user_msg.id);

    let assistant_msg = store
        .append_message(MessageRecord::new(
            session.id,
            MessageRole::Assistant,
            vec![ContentPart::text("The capital of France is Paris.")],
        ))
        .await
        .map_err(behest::Error::Storage)?;
    println!("Appended assistant message: {}", assistant_msg.id);

    let user_msg2 = store
        .append_message(MessageRecord::new(
            session.id,
            MessageRole::User,
            vec![ContentPart::text("What is its population?")],
        ))
        .await
        .map_err(behest::Error::Storage)?;
    println!("Appended user message: {}", user_msg2.id);

    let messages = store
        .list_messages(&session.id)
        .await
        .map_err(behest::Error::Storage)?;

    println!("\nMessage history ({} messages):", messages.len());
    for msg in &messages {
        let text: String = msg
            .content
            .iter()
            .map(|part| match part {
                ContentPart::Text { text } => text.clone(),
                _ => "[non-text]".to_string(),
            })
            .collect();
        println!("  [{:?}] {:?}", msg.role, text);
    }

    Ok(())
}