jt1078 0.1.0

jt1078协议库实现
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

use jt808::models::{Jt808, Jt808BodySerialize, Jt808BodyTrans, Ver808};
use jt_util::{
    bytes::{IBuffRead, IBuffWrite},
    bytes_gbk::BytesGBK,
};

/// 0100 注册信息
#[derive(Debug, Default)]
pub struct Jt0x9101 {
    /// 服务器地址
    pub ipaddress: BytesGBK,
    /// 服务器视频通道监听端口号(TCP)
    pub tcp_port: u16,
    /// 服务器视频通道监听端口号(UDP)
    pub udp_port: u16,
    /// 逻辑通道号
    pub channel: u8,
    /// 数据类型（0：音视频，1：视频，2：双向对讲，3：监听，4：中心广播，5：透传）
    pub data_type: u8,
    /// 码流类型（0：主码流，1：子码流）
    pub stream_type: u8,
}
impl Jt808BodySerialize for Jt0x9101 {
    fn write(&mut self, _ver: &Ver808, buf: &mut dyn IBuffWrite) {
        buf.put_u8(self.ipaddress.bytes_len() as u8);
        buf.put(self.ipaddress.get_bytes());
        buf.put_u16(self.tcp_port);
        buf.put_u16(self.udp_port);
        buf.put_u8(self.channel);
        buf.put_u8(self.data_type);
        buf.put_u8(self.stream_type);
    }

    fn len(&self, _ver: &Ver808) -> usize {
        self.ipaddress.bytes_len() + 8
    }
}
impl Jt808BodyTrans for Jt0x9101 {
    fn fill_new<T>(buf: &mut T, _jt808: &Jt808) -> Self
    where
        T: IBuffRead,
    {
        let len = buf.get_u8();

        Self {
            ipaddress: BytesGBK::new_with_bytes(buf.split_to(len as usize)),
            tcp_port: buf.get_u16(),
            udp_port: buf.get_u16(),
            channel: buf.get_u8(),
            data_type: buf.get_u8(),
            stream_type: buf.get_u8(),
        }
    }
}