ahp 0.5.2

//! Minimal example: connect over WebSocket, initialize, and stream
//! events from the root resource until Ctrl+C.
//!
//! Run with:
//!
//! ```sh
//! cargo run --example connect_ws --features ws -- ws://localhost:12345
//! ```
//!
//! Requires the companion `ahp-ws` crate. Passing a `--features` flag is
//! only needed because this example depends on an optional dev dependency
//! on `ahp-ws`; the core `ahp` crate stays transport-agnostic.

use std::env;

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

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    tracing_subscriber::fmt::try_init().ok();

    let url = env::args()
        .nth(1)
        .unwrap_or_else(|| "ws://localhost:12345".into());

    let transport = ahp_ws::WebSocketTransport::connect(&url).await?;
    let client = Client::connect(transport, ClientConfig::default()).await?;

    let init = client
        .initialize(
            "rust-example".into(),
            vec![ahp_types::PROTOCOL_VERSION.to_string()],
            vec![ahp_types::ROOT_RESOURCE_URI.to_string()],
        )
        .await?;
    println!("connected (protocolVersion={})", init.protocol_version);

    let mut sub = client
        .attach_subscription(ahp_types::ROOT_RESOURCE_URI)
        .await;
    println!("subscribed; streaming events (Ctrl+C to quit)...");

    loop {
        tokio::select! {
            ev = sub.recv() => match ev {
                Some(SubscriptionEvent::Action(a)) => {
                    println!("action seq={} {}", a.server_seq, serde_json::to_string(&a.action)?);
                }
                Some(other) => {
                    println!("notification {}", serde_json::to_string(&serde_notif(&other))?);
                }
                None => break,
            },
            _ = tokio::signal::ctrl_c() => {
                println!("shutting down");
                break;
            }
        }
    }

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

fn serde_notif(ev: &SubscriptionEvent) -> serde_json::Value {
    match ev {
        SubscriptionEvent::SessionAdded(n) => serde_json::to_value(n).unwrap_or_default(),
        SubscriptionEvent::SessionRemoved(n) => serde_json::to_value(n).unwrap_or_default(),
        SubscriptionEvent::SessionSummaryChanged(n) => serde_json::to_value(n).unwrap_or_default(),
        SubscriptionEvent::AuthRequired(n) => serde_json::to_value(n).unwrap_or_default(),
        _ => serde_json::Value::Null,
    }
}