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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115

use super::super::*;
use crate::router_handler::*;
use cyfs_base::*;

use serde_json::{Map, Value};



#[derive(Debug)]
pub struct RouterWSAddEventParam {
    pub category: RouterEventCategory,
    pub id: String,
    pub dec_id: Option<ObjectId>,
    pub index: i32,
    pub routine: String,
}

pub struct RouterWSRemoveEventParam {
    pub category: RouterEventCategory,
    pub id: String,
    pub dec_id: Option<ObjectId>,
}

impl JsonCodec<Self> for RouterWSAddEventParam {
    fn encode_json(&self) -> Map<String, Value> {
        let mut obj = Map::new();

        JsonCodecHelper::encode_string_field(&mut obj, "category", &self.category);
        JsonCodecHelper::encode_string_field(&mut obj, "id", &self.id);
        JsonCodecHelper::encode_option_string_field(&mut obj, "dec_id", self.dec_id.as_ref());
        JsonCodecHelper::encode_string_field(&mut obj, "index", &self.index);
        JsonCodecHelper::encode_string_field(&mut obj, "routine", &self.routine);

        obj
    }

    fn decode_json(req_obj: &Map<String, Value>) -> BuckyResult<Self> {
        Ok(Self {
            category: JsonCodecHelper::decode_string_field(req_obj, "category")?,
            id: JsonCodecHelper::decode_string_field(req_obj, "id")?,
            dec_id: JsonCodecHelper::decode_option_string_field(req_obj, "dec_id")?,
            index: JsonCodecHelper::decode_string_field(req_obj, "index")?,
            routine: JsonCodecHelper::decode_string_field(req_obj, "routine")?,
        })
    }
}

impl JsonCodec<Self> for RouterWSRemoveEventParam {
    fn encode_json(&self) -> Map<String, Value> {
        let mut obj = Map::new();

        JsonCodecHelper::encode_string_field(&mut obj, "category", &self.category);
        JsonCodecHelper::encode_string_field(&mut obj, "id", &self.id);
        JsonCodecHelper::encode_option_string_field(&mut obj, "dec_id", self.dec_id.as_ref());

        obj
    }

    fn decode_json(req_obj: &Map<String, Value>) -> BuckyResult<Self> {
        Ok(Self {
            category: JsonCodecHelper::decode_string_field(req_obj, "category")?,
            id: JsonCodecHelper::decode_string_field(req_obj, "id")?,
            dec_id: JsonCodecHelper::decode_option_string_field(req_obj, "dec_id")?,
        })
    }
}

pub type RouterWSEventResponse = RouterWSHandlerResponse;

pub struct RouterWSEventEmitParam {
    pub category: RouterEventCategory,

    pub id: String,

    pub param: String,
}

impl RouterWSEventEmitParam {
    pub fn encode_json_impl<P>(
        category: &RouterEventCategory,
        id: &str,
        param: &P,
    ) -> Map<String, Value>
    where
        P: JsonCodec<P>,
    {
        let mut obj = Map::new();

        JsonCodecHelper::encode_string_field(&mut obj, "category", &category);
        JsonCodecHelper::encode_string_field(&mut obj, "id", &id);
        obj.insert("param".to_string(), Value::String(param.encode_string()));

        obj
    }
}

impl JsonCodec<Self> for RouterWSEventEmitParam {
    fn encode_json(&self) -> Map<String, Value> {
        let mut obj = Map::new();

        JsonCodecHelper::encode_string_field(&mut obj, "category", &self.category);
        JsonCodecHelper::encode_string_field(&mut obj, "id", &self.id);
        JsonCodecHelper::encode_string_field(&mut obj, "param", &self.param);

        obj
    }

    fn decode_json(req_obj: &Map<String, Value>) -> BuckyResult<Self> {
        Ok(Self {
            category: JsonCodecHelper::decode_string_field(req_obj, "category")?,
            id: JsonCodecHelper::decode_string_field(req_obj, "id")?,
            param: JsonCodecHelper::decode_string_field(req_obj, "param")?,
        })
    }
}