diff options
Diffstat (limited to 'src/protocol/primitive/message.rs')
| -rw-r--r-- | src/protocol/primitive/message.rs | 184 |
1 files changed, 0 insertions, 184 deletions
diff --git a/src/protocol/primitive/message.rs b/src/protocol/primitive/message.rs deleted file mode 100644 index 4ae895d..0000000 --- a/src/protocol/primitive/message.rs +++ /dev/null @@ -1,184 +0,0 @@ -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::BufferInfo; -use crate::protocol::primitive::String; - -extern crate bytes; - -#[derive(Clone, Debug, std::cmp::PartialEq)] -pub struct Message { - pub msg_id: i32, // The unique, sequential id for the message - pub timestamp: i64, // The timestamp of the message in UNIX time (32-bit, seconds, 64-bit if LONGMESSAGE feature enabled) - pub msg_type: MessageType, - pub flags: i8, - pub buffer: BufferInfo, // The buffer the message belongs to, usually everything but BufferId is set to NULL - pub sender: String, // The sender as nick!ident@host - pub sender_prefixes: Option<String>, // The prefix modes of the sender - pub real_name: Option<String>, // The realName of the sender - pub avatar_url: Option<String>, // The avatarUrl of the sender, if available - pub content: String, // The message content, already stripped from CTCP formatting, but containing mIRC format codes -} - -impl Serialize for Message { - fn serialize(&self) -> Result<Vec<u8>, Error> { - let mut values: Vec<u8> = Vec::new(); - - values.append(&mut i32::serialize(&self.msg_id)?); - - // TODO LONGMESSAGE feature - if false { - values.append(&mut i64::serialize(&self.timestamp)?); - } else { - values.append(&mut i32::serialize(&(self.timestamp as i32))?); - } - - values.append(&mut i32::serialize(&(self.msg_type as i32))?); - values.append(&mut i8::serialize(&(self.flags as i8))?); - values.append(&mut BufferInfo::serialize(&self.buffer)?); - values.append(&mut String::serialize_utf8(&self.sender)?); - - // TODO SenderPrefixes feature - if false { - if let Some(x) = &self.sender_prefixes { - values.append(&mut String::serialize_utf8(&x)?); - } - } - - // TODO RichMessages feature - if false { - if let Some(x) = &self.real_name { - values.append(&mut String::serialize_utf8(&x)?); - } - if let Some(x) = &self.avatar_url { - values.append(&mut String::serialize_utf8(&x)?); - } - } - - values.append(&mut String::serialize_utf8(&self.content)?); - - return Ok(values); - } -} - -impl Deserialize for Message { - fn parse(b: &[u8]) -> Result<(usize, Self), Error> { - let mut pos = 0; - let (parsed, msg_id) = i32::parse(&b[pos..])?; - pos += parsed; - - // TODO LONGMESSAGES feature - let timestamp; - if false { - let (parsed, temp_timestamp) = i64::parse(&b[pos..])?; - pos += parsed; - timestamp = temp_timestamp; - } else { - let (parsed, temp_timestamp) = i32::parse(&b[pos..])?; - pos += parsed; - timestamp = temp_timestamp as i64; - } - - let (parsed, msg_type) = i32::parse(&b[pos..])?; - pos += parsed; - let (parsed, flags) = i8::parse(&b[pos..])?; - pos += parsed; - let (parsed, buffer) = BufferInfo::parse(&b[pos..])?; - pos += parsed; - let (parsed, sender) = String::parse_utf8(&b[pos..])?; - pos += parsed; - - // TODO SenderPrefixes feature - let mut sender_prefixes = None; - if false { - let (parsed, temp) = String::parse_utf8(&b[pos..])?; - sender_prefixes = Some(temp); - pos += parsed; - } - - // TODO SenderPrefixes feature - let mut real_name = None; - let mut avatar_url = None; - if false { - let (parsed, temp) = String::parse_utf8(&b[pos..])?; - real_name = Some(temp); - pos += parsed; - - let (parsed, temp) = String::parse_utf8(&b[pos..])?; - avatar_url = Some(temp); - pos += parsed; - } - - let (parsed, content) = String::parse_utf8(&b[pos..])?; - pos += parsed; - - return Ok(( - pos, - Self { - msg_id, - timestamp, - msg_type: MessageType::from(msg_type), - flags, - buffer, - sender, - sender_prefixes, - real_name, - avatar_url, - content, - }, - )); - } -} - -#[repr(i32)] -#[derive(Copy, Clone, Debug, std::cmp::PartialEq)] -pub enum MessageType { - Plain = 0x00000001, - Notice = 0x00000002, - Action = 0x00000004, - Nick = 0x00000008, - Mode = 0x00000010, - Join = 0x00000020, - Part = 0x00000040, - Quit = 0x00000080, - Kick = 0x00000100, - Kill = 0x00000200, - Server = 0x00000400, - Info = 0x00000800, - Error = 0x00001000, - DayChange = 0x00002000, - Topic = 0x00004000, - NetsplitJoin = 0x00008000, - NetsplitQuit = 0x00010000, - Invite = 0x00020000, -} - -impl From<i32> for MessageType { - fn from(val: i32) -> Self { - match val { - 0x00000001 => MessageType::Plain, - 0x00000002 => MessageType::Notice, - 0x00000004 => MessageType::Action, - 0x00000008 => MessageType::Nick, - 0x00000010 => MessageType::Mode, - 0x00000020 => MessageType::Join, - 0x00000040 => MessageType::Part, - 0x00000080 => MessageType::Quit, - 0x00000100 => MessageType::Kick, - 0x00000200 => MessageType::Kill, - 0x00000400 => MessageType::Server, - 0x00000800 => MessageType::Info, - 0x00001000 => MessageType::Error, - 0x00002000 => MessageType::DayChange, - 0x00004000 => MessageType::Topic, - 0x00008000 => MessageType::NetsplitJoin, - 0x00010000 => MessageType::NetsplitQuit, - 0x00020000 => MessageType::Invite, - _ => unimplemented!(), - } - } -} |