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
44
45
46
47
48
49
50
51
52
53
54
55
56
57

use std::sync::Arc;

use serde_json::Value;

use crate::channel::Channel;
use crate::transport::Transport;
use crate::types::{Event, Route, User};

pub struct OutgoingContext {
    pub channel: Arc<Channel>,
    pub event: Event,
    pub user: User,
    pub transport: Arc<dyn Transport>,
    pub route: Route,
    blocked: bool,
    transformed: bool,
}

impl OutgoingContext {
    pub fn new(
        channel: Arc<Channel>,
        event: Event,
        user: User,
        transport: Arc<dyn Transport>,
    ) -> Self {
        Self {
            channel,
            event,
            user,
            transport,
            route: Route::default(),
            blocked: false,
            transformed: false,
        }
    }

    pub fn block(&mut self) {
        self.blocked = true;
    }

    pub fn unblock(&mut self) {
        self.blocked = false;
    }

    pub fn is_blocked(&self) -> bool {
        self.blocked
    }

    pub fn transform(&mut self, payload: Value) {
        self.event.payload = payload;
        self.transformed = true;
    }

    pub fn has_transformed(&self) -> bool {
        self.transformed
    }
}