rain-engine 0.1.0

An event-sourced Rust kernel for building durable AI agent systems
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

use rain_engine::kernel::{
    AgentAction, AgentEngine, AgentTrigger, MockLlmProvider, ProcessRequest,
};
use rain_engine::runtime::run_until_terminal;
use rain_engine::stores::SqliteMemoryStore;
use std::sync::Arc;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let store = Arc::new(SqliteMemoryStore::connect("sqlite::memory:").await?);
    let provider = Arc::new(MockLlmProvider::scripted(vec![AgentAction::Respond {
        content: "sqlite-backed response".to_string(),
    }]));
    let engine = AgentEngine::new(provider, store);

    let outcome = run_until_terminal(
        &engine,
        ProcessRequest::new(
            "sqlite-example",
            AgentTrigger::Message {
                user_id: "user-1".to_string(),
                content: "Run with SQLite".to_string(),
                attachments: Vec::new(),
            },
        ),
    )
    .await?;

    println!("terminal outcome: {:?}", outcome.stop_reason);
    Ok(())
}