diff -r b06b33cf0a89 -r 747278149393 rust/hedgewars-server/src/protocol.rs --- a/rust/hedgewars-server/src/protocol.rs Wed Jun 23 15:32:48 2021 -0400 +++ b/rust/hedgewars-server/src/protocol.rs Wed Jun 23 23:41:51 2021 +0200 @@ -1,13 +1,11 @@ -use self::parser::message; +use hedgewars_network_protocol::{ + messages::HwProtocolMessage, + parser::{malformed_message, message}, +}; use log::*; use netbuf; use std::io::{Read, Result}; -pub mod messages; -mod parser; -#[cfg(test)] -pub mod test; - pub struct ProtocolDecoder { buf: netbuf::Buf, is_recovering: bool, @@ -22,7 +20,7 @@ } fn recover(&mut self) -> bool { - self.is_recovering = match parser::malformed_message(&self.buf[..]) { + self.is_recovering = match malformed_message(&self.buf[..]) { Ok((tail, ())) => { let length = tail.len(); self.buf.consume(self.buf.len() - length); @@ -44,11 +42,11 @@ Ok(count) } - pub fn extract_messages(&mut self) -> Vec { + pub fn extract_messages(&mut self) -> Vec { let mut messages = vec![]; if !self.is_recovering { while !self.buf.is_empty() { - match parser::message(&self.buf[..]) { + match message(&self.buf[..]) { Ok((tail, message)) => { messages.push(message); let length = tail.len();