lavende-core 0.1.3

Core in-process Discord voice connection and playback engine
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

use std::sync::Arc;

#[derive(Clone)]
pub struct EventSender {
    callback: Arc<dyn Fn(&str, serde_json::Value) + Send + Sync>,
}

impl EventSender {
    pub fn new<F>(callback: F) -> Self
    where
        F: Fn(&str, serde_json::Value) + Send + Sync + 'static,
    {
        Self {
            callback: Arc::new(callback),
        }
    }

    pub fn send(&self, event_type: &str, payload: serde_json::Value) {
        let mut full_payload = payload.clone();
        if let serde_json::Value::Object(ref mut map) = full_payload {
            map.insert(
                "type".to_string(),
                serde_json::Value::String(event_type.to_string()),
            );
        } else {
            full_payload = serde_json::json!({
                "type": event_type,
                "data": payload
            });
        }
        (self.callback)(event_type, full_payload);
    }
}