honcho-ai 0.1.1

Rust SDK for Honcho — AI agent memory and social cognition infrastructure
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

#![allow(clippy::print_stdout)]
//! Queue status: check background processing progress.
//!
//! Demonstrates checking the deriver queue at both the workspace
//! and session levels, and scheduling a dream task.
//!
//! Run with `cargo run --example queue_status`

use honcho_ai::Honcho;

#[tokio::main]
async fn main() -> honcho_ai::error::Result<()> {
    let honcho = Honcho::from_params(
        Honcho::builder()
            .base_url("http://localhost:8000")
            .workspace_id("queue-demo")
            .build(),
    )?;

    let peer = honcho.peer("observer-1", None, None).await?;
    let session = honcho.session("sess-1", None, None, None).await?;

    session
        .add_messages(vec![peer.message("Trigger some background work").build()?])
        .await?;

    let ws_status = honcho.queue_status(None, None, None).await?;
    println!(
        "Workspace queue: total={}, pending={}, in_progress={}, completed={}",
        ws_status.total_work_units,
        ws_status.pending_work_units,
        ws_status.in_progress_work_units,
        ws_status.completed_work_units,
    );

    let sess_status = session.queue_status(None, None).await?;
    println!(
        "Session queue: total={}, pending={}, in_progress={}, completed={}",
        sess_status.total_work_units,
        sess_status.pending_work_units,
        sess_status.in_progress_work_units,
        sess_status.completed_work_units,
    );

    honcho.schedule_dream("observer-1", None, None).await?;
    println!("Dream scheduled for observer-1");

    Ok(())
}