agentyk 0.1.1

Compose agents from values and run them: turn loop, event log, capabilities, MCP, multi-provider LLM drivers.
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

//! Multi-actor sessions: host-owned membership, shared history, per-turn agents.

use std::sync::Arc;

use agentyk::{
    Agent, ChatDriver, ChatRequest, ChatResponse, ModelSpec, Result, SimDriver, SimTurn,
};

struct SharedSim(Arc<SimDriver>);

#[async_trait::async_trait]
impl ChatDriver for SharedSim {
    fn id(&self) -> agentyk::DriverId {
        agentyk::DriverId::llmsim()
    }

    async fn complete(&self, request: ChatRequest) -> Result<ChatResponse> {
        self.0.complete(request).await
    }
}

#[tokio::test]
async fn addressed_agent_overlays_behavior_on_the_hosts_harness_and_history() -> Result<()> {
    let host_driver = Arc::new(SimDriver::new([
        SimTurn::text("host answer"),
        SimTurn::text("guest answer"),
    ]));
    let guest_driver = Arc::new(SimDriver::new([SimTurn::text(
        "must not run on the guest harness",
    )]));
    let host = Agent::builder()
        .name("host")
        .system_prompt("You are the host.")
        .model(ModelSpec::llmsim())
        .driver(SharedSim(host_driver.clone()))
        .build()?;
    let guest = Agent::builder()
        .name("reviewer")
        .system_prompt("You are the reviewer.")
        .model(ModelSpec::llmsim())
        .driver(SharedSim(guest_driver.clone()))
        .build()?;

    let mut session = host.session();
    session.run("draft this").await?;
    let turn = session.run_with_agent(&guest, "review it").await?;

    assert_eq!(turn.response, "guest answer");
    assert_eq!(session.messages().len(), 4);
    assert!(guest_driver.recorded_requests().is_empty());
    let requests = host_driver.recorded_requests();
    assert_eq!(requests.len(), 2);
    let request = &requests[1];
    assert_eq!(
        request.system_prompt.as_deref(),
        Some("You are the reviewer.")
    );
    assert_eq!(
        request
            .messages
            .iter()
            .map(|message| message.text())
            .collect::<Vec<_>>(),
        ["draft this", "host answer", "review it"]
    );
    Ok(())
}