pondsocket 0.1.4

Channel-based realtime server framework with distributed pubsub support.
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

use pondsocket_common::{ValidationError, parse_client_message};
use serde_json::{Map, Value};

use crate::types::Event;

pub fn event_to_json(event: &Event) -> serde_json::Result<String> {
    serde_json::to_string(event)
}

pub fn parse_inbound_text(text: &str) -> Result<Event, ValidationError> {
    let msg = parse_client_message(text)?;
    Ok(Event {
        action: serde_json::to_string(&msg.action)
            .unwrap_or_default()
            .trim_matches('"')
            .to_owned(),
        channel_name: msg.channel_name,
        request_id: msg.request_id,
        event: msg.event,
        payload: Value::Object(msg.payload),
        node_id: String::new(),
        recipients: Vec::new(),
        from_user_id: String::new(),
        recipient_descriptor: String::new(),
    })
}

pub fn event_to_pubsub_bytes(event: &Event) -> serde_json::Result<Vec<u8>> {
    serde_json::to_vec(event)
}

pub fn pubsub_bytes_to_event(data: &[u8]) -> Option<Event> {
    serde_json::from_slice(data).ok()
}

pub fn object(entries: impl IntoIterator<Item = (impl Into<String>, Value)>) -> Value {
    Value::Object(
        entries
            .into_iter()
            .map(|(k, v)| (k.into(), v))
            .collect::<Map<String, Value>>(),
    )
}