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

use bytes::{Buf, Bytes};

use crate::structs::OtherClientInfo;
use crate::{jce, RQError, RQResult};

impl super::super::super::Engine {
    // RegPrxySvc.PushParam
    pub fn decode_push_param_packet(&self, payload: &[u8]) -> RQResult<Vec<OtherClientInfo>> {
        let mut payload = Bytes::from(payload.to_owned());
        let mut request: jce::RequestPacket =
            jcers::from_buf(&mut payload).map_err(RQError::from)?;
        let mut data: jce::RequestDataVersion2 =
            jcers::from_buf(&mut request.s_buffer).map_err(RQError::from)?;
        let mut req = data
            .map
            .remove("SvcRespParam")
            .ok_or_else(|| RQError::Decode("SvcRespParam is none".to_string()))?;
        let mut reader = req
            .remove("RegisterProxySvcPack.SvcRespParam")
            .ok_or_else(|| {
                RQError::Decode("RegisterProxySvcPack.SvcRespParam is none".to_string())
            })?;
        reader.advance(1);
        let rsp: jce::SvcRespParam = jcers::from_buf(&mut reader).map_err(RQError::from)?;
        Ok(rsp
            .online_infos
            .iter()
            .map(|i| OtherClientInfo {
                app_id: i.instance_id as i64,
                instance_id: i.instance_id,
                sub_platform: String::from_utf8_lossy(&i.sub_platform).to_string(),
                device_kind: match i.u_client_type {
                    65793 => "Windows".to_string(),
                    65805 | 68104 => "aPad".to_string(),
                    66818 | 66831 | 81154 => "Mac".to_string(),
                    68361 | 72194 => "iPad".to_string(),
                    75023 | 78082 | 78096 => "Watch".to_string(),
                    77313 => "Windows TIM".to_string(),
                    _ => String::from_utf8_lossy(&i.sub_platform).to_string(),
                },
            })
            .collect())
    }
}