Dreaded_X/rust-mqtt
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Clean up

Browse Source
This commit is contained in:
Ondrej Babec 2022-02-21 16:23:36 +01:00
parent 4ed1c7bd2b
commit 5fda98525c
No known key found for this signature in database
GPG Key ID: 13E577E3769B2079
2 changed files with 4 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main.rs
View File

@ -15,13 +15,13 @@ fn main() {
.format_timestamp_nanos()
.init();
let mut pckt: SubscriptionPacket<1> = SubscriptionPacket::new();
let mut pckt: SubscriptionPacket<1, 0> = SubscriptionPacket::new();
let mut res = vec![0; 140];
let lnsub = pckt.encode(&mut res);
println!("{:02X?}", &res[0..lnsub]);
let mut res2 = vec![0; 260];
let mut x = b"hello world";
let mut pblsh: PublishPacket = PublishPacket::new(x);
let mut pblsh = PublishPacket::<0>::new(x);
let lnpblsh = pblsh.encode(&mut res2);
println!("{:02X?}", &res2[0..lnpblsh]);
log::info!("xxx");
@ -51,8 +51,3 @@ fn main() {
let prot = std::str::from_utf8(&bytes).unwrap();
log::info!("Protocol name: {}", prot)*/
}
/*fn test(tst: &str) {
log::info!("xx");
log::info!("Prvni: {}", )
}*/

18
src/utils/buffer_writer.rs
View File

@ -10,20 +10,6 @@ pub struct BuffWriter<'a> {
}
impl<'a> BuffWriter<'a> {
pub fn insert<const LEN: usize>(&mut self, array: [u8; LEN]) {
let mut x: usize = 0;
if LEN != 0 {
loop {
self.buffer[self.position] = array[x];
self.increment_position(1);
x = x + 1;
if x == LEN {
break;
}
}
}
}
pub fn insert_ref(&mut self, len: usize, array: &[u8]) {
let mut x: usize = 0;
if len != 0 {
@ -56,12 +42,12 @@ impl<'a> BuffWriter<'a> {
pub fn write_u16(&mut self, two_bytes: u16) {
let bytes: [u8; 2] = two_bytes.to_be_bytes();
self.insert::<2>(bytes);
self.insert_ref(2, &bytes);
}
pub fn write_u32(&mut self, four_bytes: u32) {
let bytes: [u8; 4] = four_bytes.to_be_bytes();
self.insert::<4>(bytes);
self.insert_ref(4,&bytes);
}
pub fn write_string_ref(&mut self, str: &EncodedString<'a>) {