wscall 0.1.1

Facade crate for the WSCALL protocol, server, and client
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

use serde_json::json;
use tokio::time::{Duration, sleep};
use wscall::{WscallClient, WscallServer};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let address = "127.0.0.1:9010";
    let url = "ws://127.0.0.1:9010/socket";

    let server_task = tokio::spawn(async move {
        let mut server = WscallServer::new();
        server.route("system.echo", |ctx| async move {
            Ok(json!({
                "route": ctx.route(),
                "params": ctx.params(),
            }))
        });

        server.listen(address).await
    });

    sleep(Duration::from_millis(100)).await;

    let client = WscallClient::connect(url).await?;
    let response = client
        .call("system.echo", json!({ "message": "hello" }), Vec::new())
        .await?;

    println!("response: {response}");
    client.close().await?;

    server_task.abort();
    Ok(())
}