oris-runtime 0.61.0

An agentic workflow runtime and programmable AI execution system in Rust: stateful graphs, agents, tools, and multi-step execution.
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

// Example: Message injection based on context
// This demonstrates how to inject file context, compliance rules, etc.

use std::sync::Arc;
use tokio::sync::Mutex;

use oris_runtime::{
    agent::{
        context_engineering::middleware::{InjectionPosition, MessageInjectionMiddleware},
        create_agent, AgentState,
    },
    schemas::messages::Message,
    tools::{InMemoryStore, SimpleContext},
};
use serde_json::json;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // env_logger::init(); // Uncomment if env_logger is available

    // Create message injection middleware for file context
    let file_context_injector =
        MessageInjectionMiddleware::inject_file_context(InjectionPosition::End);

    // Create message injection middleware for compliance rules
    let compliance_injector =
        MessageInjectionMiddleware::inject_compliance_rules(InjectionPosition::End);

    // Create state with uploaded files
    let mut state = AgentState::new();
    state.set_field(
        "uploaded_files".to_string(),
        json!([
            {
                "name": "project_proposal.pdf",
                "type": "pdf",
                "summary": "Q4 project proposal document"
            },
            {
                "name": "budget.xlsx",
                "type": "excel",
                "summary": "Budget spreadsheet for Q4"
            }
        ]),
    );

    // Create agent with message injection middleware
    let agent = create_agent(
        "gpt-4o-mini",
        &[],
        Some("You are a helpful assistant"),
        Some(vec![
            Arc::new(file_context_injector),
            Arc::new(compliance_injector),
        ]),
    )?
    .with_context(Arc::new(
        SimpleContext::new()
            .with_user_id("user_123".to_string())
            .with_custom("user_jurisdiction".to_string(), "EU".to_string())
            .with_custom("compliance_frameworks".to_string(), "GDPR".to_string())
            .with_custom("industry".to_string(), "finance".to_string()),
    ))
    .with_store(Arc::new(InMemoryStore::new()))
    .with_state(Arc::new(Mutex::new(state)));

    // Use the agent
    let result = agent
        .invoke_messages(vec![Message::new_human_message(
            "What files do I have access to?",
        )])
        .await?;

    println!("Agent response: {}", result);

    Ok(())
}