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
use std::net::SocketAddr;
use super::swap_cmd::SwapCmd;
#[derive(PartialEq, Debug, Clone)]
pub struct Swap {
pub cmd: u8,
pub id: String,
pub address: SocketAddr,
}
impl Swap {
pub fn new(buf: &Vec<u8>, me: SocketAddr, total: usize) -> Self {
let ids = {
if let Ok(i) = std::str::from_utf8(&buf[1..total ]) {
i
} else {
""
}
};
Self {
cmd: buf[0],
id: ids.to_string(),
address: me,
}
}
pub fn pack_open( &self) -> Vec<u8> {
let address=self.address.to_string();
let open_code = SwapCmd::Open;
let open_u = open_code.enum2int();
let mut v = vec![];
v.push(open_u);
let ss = address.as_bytes();
for i in ss.iter() {
v.push(*i);
}
v
}
pub fn pack_err(err: &str) -> Vec<u8> {
let err_code = SwapCmd::ServerErr;
let err_u = err_code.enum2int();
let mut v = vec![];
v.push(err_u);
let ss = err.as_bytes();
for i in ss.iter() {
v.push(*i);
}
v
}
pub fn pack(&self, b: &[u8]) -> Vec<u8> {
let mut v = vec![];
v.push(self.cmd);
for i in b.iter() {
v.push(*i);
}
v
}
}