datex_core/generator/
header.rs

1
2use crate::{global::dxb_block::DXBHeader, utils::buffers::{append_u8, append_u16, append_u32, append_u64}};
3
4
5pub fn append_dxb_header<'a>(header:&DXBHeader, _dxb: &[u8]) -> Vec<u8> {
6
7	let pre_header = &mut generate_pre_header(header);
8	let block_header = generate_block_header(header);
9
10	pre_header.extend_from_slice(&block_header);
11
12	return pre_header.to_vec();
13}
14
15
16fn generate_block_header(header:&DXBHeader) -> Vec<u8> {
17	let block_header = &mut Vec::<u8>::with_capacity(200);
18
19	// sid
20	append_u32(block_header, header.scope_id);
21	// block index
22	append_u16(block_header, header.block_index);
23	// block increment
24	append_u16(block_header, header.block_increment);
25
26	// type
27	append_u8(block_header, header.block_type as u8);
28
29	// TODO: flags
30	append_u8(block_header, 0);
31
32	// timestamp
33	append_u64(block_header, header.timestamp);
34
35	return block_header.to_vec();
36}
37
38fn generate_pre_header(header:&DXBHeader) -> Vec<u8> {
39	let pre_header = &mut Vec::<u8>::with_capacity(200);
40
41	let _index = &mut 0;
42
43	// magic number
44	append_u8(pre_header, 0x01);
45	append_u8(pre_header, 0x64);
46
47	// version
48	append_u8(pre_header, header.version);
49
50	// size
51	append_u16(pre_header, header.size);
52	// routing
53	append_u8(pre_header, header.routing.ttl);
54	append_u8(pre_header, header.routing.priority);
55
56	// signed/encrypted
57	let signed_encrypted = if header.signed && header.encrypted {2} else if header.signed {1} else if header.encrypted {3} else {0};
58	append_u8(pre_header, signed_encrypted);
59
60	// sender
61	if header.routing.sender.is_some() {
62		pre_header.extend_from_slice(&header.routing.sender.as_ref().unwrap().get_binary());
63	}
64	// no sender - anonymous
65	else {
66		append_u8(pre_header, std::u8::MAX); // 0xff
67	}
68
69	// TODO: 
70	// no receiver - flood
71	// else {
72	// 	append_u16(dxb, std::u16::MAX); // 0xffff
73	// }
74	append_u16(pre_header, std::u16::MAX); // 0xffff
75
76	return pre_header.to_vec()
77}