hyperapi 0.2.2

An easy to use API Gateway
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

use tokio::sync::mpsc;
use crate::config::ConfigUpdate;
use async_tungstenite::tokio::connect_async;
use async_tungstenite::tungstenite::Message;
use futures_util::{StreamExt, SinkExt};
use tracing::{event, Level};

pub async fn watch_config(ws_url: String, sender: mpsc::Sender<ConfigUpdate>) {
    event!(Level::INFO, "connecting to websocket");
    let result = connect_async(ws_url.clone()).await;
    if let Ok((mut ws, _)) = result {
        while let Some(res) = ws.next().await {
            if let Ok(msg) = res {
                match msg {
                    Message::Text(txt) => {
                        let update = serde_json::from_str::<ConfigUpdate>(&txt);
                        if let Ok(up) = update {
                            let _ = sender.send(up).await;
                        } else {
                            event!(Level::ERROR, "bad config update message: {:?}", update);
                        }
                    },
                    Message::Ping(sn) => {
                        let _ = ws.send(Message::Pong(sn)).await;
                    },
                    Message::Close(_) => {
                        break;
                    },
                    _ => {},
                }
            }
        }
    }

}