#![allow(non_camel_case_types)] use std::str::FromStr; use std::string::{ ToString }; use std::borrow::{ ToOwned }; use std::ops::{ Deref, Range }; use ::IrscError; use ident::Ident; #[derive(Copy, Clone, Debug, PartialEq, Eq, Hash)] pub enum MsgType { /// Plain old IRC messages, as defined in [rfc2812][rfc] /// rfc: http://tools.ietf.org/html/rfc2812 Irc, /// Ctcp messages, wrapped in \u{1} Ctcp } /// Byte indices, be careful. #[derive(Debug, PartialEq, Eq, Clone)] pub struct Message { pub source: String, prefix: Option>, command: Range, content: Vec>, suffix: Option>, pub msg_type: MsgType } impl Message { pub fn new(source: String, prefix: Option>, command: Range, content: Vec>, suffix: Option>, msg_type: MsgType) -> Message { Message { source: source, prefix: prefix, command: command, content: content, suffix: suffix, msg_type: msg_type } } #[allow(unused_assignments)] pub fn format>(prefix: Option, command: T, content: Vec, suffix: Option, msg_type: MsgType) -> Message { let mut s = String::with_capacity(512); let mut i = 0; let mut i_prefix = None; if let Some(ref p) = prefix { i_prefix = Some((i + 1) as u16..(i + 2 + p.len()) as u16); s.push(':'); s.push_str(p); s.push(' '); i += 2 + p.len(); } let i_command = i as u16..(i + command.len()) as u16; s.push_str(&*command); s.push(' '); i += 1 + command.len(); let mut i_content = Vec::new(); for part in content.iter() { i_content.push(i as u16..(i + part.len()) as u16); s.push_str(part); s.push(' '); i += 1 + part.len(); } let mut i_suffix = None; if let Some(ref p) = suffix { s.push(':'); if let MsgType::Ctcp = msg_type { s.push('\u{1}'); i += 1; } let n = i; s.push_str(p); if let MsgType::Ctcp = msg_type { s.push('\u{1}'); i += 1; } i_suffix = Some(n as u16..(n + p.len()) as u16); i += 1 + p.len(); } s.push_str("\r\n"); i += 2; Message::new(s, i_prefix, i_command, i_content, i_suffix, msg_type) } pub fn range(&self, r: &Range) -> &str { &self.source[r.start as usize..r.end as usize] } pub fn prefix(&self) -> Option<&str> { self.prefix.as_ref().map(|r| self.range(r)) } pub fn command(&self) -> &str { self.range(&self.command) } pub fn content(&self) -> Vec<&str> { self.content.iter().map(|r| self.range(&r)).collect() } pub fn suffix(&self) -> Option<&str> { self.suffix.as_ref().map(|r| self.range(r)) } pub fn elements(&self) -> Vec<&str> { let mut s = self.content(); self.suffix().map(|f| s.push(f)); s } pub fn ident(&self) -> Option { self.prefix().and_then(Ident::parse) } } impl FromStr for Message { type Err = IrscError; fn from_str(i: &str) -> Result { let len = i.len(); // remember, bytes, not chars let mut s = 0; let prefix = if len >= 1 && i[s..].as_bytes()[0] == ':' as u8 { i[s..].find(' ').map(|i| { let n = 1u16..(s + i) as u16; s += i + 1; n }) } else { None }; let command = i[s..].find(' ').map(|n| { let p = s as u16..(s + n) as u16; s += n; p }); let mut content = Vec::with_capacity(15); let mut suffix = None; while s < len - 3 { if i[s..].as_bytes()[0] == ':' as u8 { suffix = Some(s as u16 + 1 as u16..i.len() as u16); break } i[s..].find(' ').map(|i| { if i > 0 { content.push(s as u16..(s + i) as u16); s += i; } }); // if s.chars().next() == Some(' ') { s = &s[1..] }; s += 1; } let msg_type = if suffix.as_ref().map(|s| i[s.start as usize..].as_bytes()[0] == 1 && i[(s.end - 3) as usize..].as_bytes()[0] == 1) == Some(true) { MsgType::Ctcp } else { MsgType::Irc }; command.map(move |c| Ok(Message::new( i.to_owned(), prefix, c, content, // strip \{1} if CTCP message // strip \r\n for each line, relying on their existence match msg_type { MsgType::Irc => suffix.map(|s| s.start..s.end - 1), MsgType::Ctcp => suffix.map(|s| s.start + 1..s.end - 2) }, msg_type )) ).unwrap() } } impl ToString for Message { fn to_string(&self) -> String { self.source.clone() } } #[derive(Clone, PartialEq, Eq, Hash)] pub enum Mode { Away, Invisible, Wallops, Restricted, Operator, LocalOperator, ServerNotices, Custom(String) } #[derive(Copy, Clone, PartialEq, Eq, Hash)] pub enum SetMode { Plus, Minus } /// If you hoped it couldn't get any uglier... I'm sorry, it does. /// Why a giant match? API. /// /// I tried structuring it as a bunch of structs that impl a `Command` trait, /// but the user would have to use Any and lots of cats. Also, extensibility isn't /// really a goal; the IRC protocol doesn't seem to evolve very fast. /// /// Granted, I *could* have used a phf-map to map to functions to parse this, which /// - while more readable - shouldn't have resulted in performance gains. /// /// Please don't cry. #[cfg(test)] mod test { use std::borrow::{ ToOwned }; use message::{ Message, MsgType }; #[test] fn parse_message1() { let b = ":d PRIVMSG You :\u{1}ACTION sends you funny pictures of cats!\u{1}\r\n"; let b2 = Message::new( b.to_owned(), Some(1..2), 3..10, vec![11..14], Some(17..58), MsgType::Ctcp ); assert_eq!(b.parse::().unwrap(), b2.clone()); assert_eq!(b2.to_string(), b); } #[test] fn parse_message2() { let a = ":a.b.c NOTICE AUTH :*** Looking up your hostname...\r\n"; // I'm not even kidding... let a2 = Message::new( a.to_owned(), Some(1..6), 7..13, vec![14..18], Some(20..52), MsgType::Irc ); assert_eq!(a.parse::().unwrap(), a2.clone()); assert_eq!(a2.to_string(), a); } #[test] fn format_message() { let a = Message::format(Some("a.b.c"), "NOTICE", vec!["AUTH"], Some("*** Looking up your hostname..."), MsgType::Irc); let a2 = ":a.b.c NOTICE AUTH :*** Looking up your hostname...\r\n"; assert_eq!(a.to_string(), a2); } }