holochain_websocket 0.0.4

Holochain utilities for serving and connection with websockets
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

use holochain_serialized_bytes::prelude::*;
use holochain_websocket::*;
use std::time::Duration;
use url2::url2;

#[derive(serde::Serialize, serde::Deserialize, SerializedBytes, Debug)]
struct TestMessage(pub String);

#[tokio::main]
async fn main() {
    let (mut send, _) = connect(
        url2!("ws://127.0.0.1:12345"),
        std::sync::Arc::new(WebsocketConfig::default()),
    )
    .await
    .unwrap();

    send.signal(TestMessage("Hey".to_string())).await.unwrap();
    let resp: TestMessage = send.request(TestMessage("Hey".to_string())).await.unwrap();
    println!("Got {:?}", resp);

    match send
        .request_timeout(TestMessage("Hey".to_string()), Duration::from_secs(1))
        .await
    {
        Ok(r) => {
            let resp: TestMessage = r;
            println!("Got {:?}", resp);
        }
        Err(WebsocketError::RespTimeout) => eprintln!("Failed to get a response in 1 second"),
        Err(e) => eprintln!("Got an error sending a request {:?}", e),
    }
}

// let mut listener = WebsocketListener::bind(
//     url2!("ws://127.0.0.1:12345"),
//     std::sync::Arc::new(WebsocketConfig::default()),
// )
// .await
// .unwrap();

// while let Some(Ok((_send, _recv))) = listener.next().await {
//     // New connection
// }
// let (tx, rx) = tokio::sync::oneshot::channel();
// tokio::task::spawn(listener_handle.close_on(async move { rx.await.unwrap_or(true) }));
// tx.send(true).unwrap();

// while let Some((msg, resp)) = recv.next().await {
//     if resp.is_request() {
//         resp.respond(msg).await.unwrap();
//     }
// }