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
|
use std::vec::Vec;
use failure::Error;
use crate::protocol::primitive::deserialize::{Deserialize, DeserializeUTF8};
use crate::protocol::primitive::serialize::{Serialize, SerializeUTF8};
use crate::protocol::primitive::String;
extern crate bytes;
#[derive(Clone, Debug, std::cmp::PartialEq)]
pub struct BufferInfo {
pub id: i32, // a unique, sequential id for the buffer
pub network_id: i32, // NetworkId of the network the buffer belongs to
pub buffer_type: BufferType,
pub name: String, // BufferName as displayed to the user
}
impl Serialize for BufferInfo {
fn serialize(&self) -> Result<Vec<u8>, Error> {
let mut values: Vec<u8> = Vec::new();
values.append(&mut i32::serialize(&self.id)?);
values.append(&mut i32::serialize(&self.network_id)?);
values.append(&mut i16::serialize(&(self.buffer_type as i16))?);
values.append(&mut vec![0, 0, 0, 0]);
values.append(&mut String::serialize_utf8(&self.name)?);
Ok(values)
}
}
impl Deserialize for BufferInfo {
fn parse(b: &[u8]) -> Result<(usize, Self), Error> {
let (_, id) = i32::parse(&b[0..4])?;
let (_, network_id) = i32::parse(&b[4..8])?;
let (_, buffer_type) = i16::parse(&b[8..10])?;
// There are 4 additional undocumted Bytes in the BufferInfo
// so we start at byte 14
let (size, name) = String::parse_utf8(&b[14..])?;
return Ok((
14 + size,
Self {
id,
network_id,
buffer_type: BufferType::from(buffer_type),
name,
},
));
}
}
#[repr(i16)]
#[derive(Copy, Clone, Debug, std::cmp::PartialEq)]
pub enum BufferType {
Status = 0x01,
Channel = 0x02,
Query = 0x04,
Group = 0x08,
}
impl From<i16> for BufferType {
fn from(value: i16) -> Self {
match value {
0x01 => return Self::Status,
0x02 => return Self::Channel,
0x04 => return Self::Query,
0x08 => return Self::Group,
_ => unimplemented!(),
}
}
}
|
