ahp-ws

WebSocket transport for the Agent Host Protocol (AHP) Rust SDK.

Implements ahp::Transport using tokio-tungstenite, supporting both ws:// and wss:// (TLS via native-tls).

Usage

[dependencies]
ahp = "0.1"
ahp-ws = "0.1"
tokio = { version = "1", features = ["full"] }

use ahp::{Client, ClientConfig, SubscriptionEvent};
use ahp_ws::WebSocketTransport;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let transport = WebSocketTransport::connect("ws://localhost:12345").await?;
    let client = Client::connect(transport, ClientConfig::default()).await?;

    client.initialize("my-client".into(), vec![ahp_types::PROTOCOL_VERSION.to_string()], vec![ahp_types::ROOT_RESOURCE_URI.to_string()]).await?;

    let mut sub = client.attach_subscription(ahp_types::ROOT_RESOURCE_URI).await;
    while let Some(SubscriptionEvent::Action(a)) = sub.recv().await {
        println!("{:?}", a.action);
    }

    client.shutdown().await;
    Ok(())
}

API

• WebSocketTransport::connect(url) — open a new connection
• WebSocketTransport::from_stream(stream) — wrap an existing tokio-tungstenite stream for custom TLS or connection options

See also

• ahp — the main client crate
• ahp-types — wire types only
• Protocol documentation