use crate::error::{MessageError, MessageErrorDetails::*};
#[derive(Debug, PartialEq)]
#[allow(non_camel_case_types)]
pub enum IRCCommand {
NONE,
NAMES,
PRIVMSG,
NOTICE,
NICK,
USER,
QUIT,
MOTD,
LUSERS,
WHOIS,
TOPIC,
RPL_WELCOME,
RPL_YOURHOST,
RPL_CREATED,
RPL_MYINFO,
RPL_NAMREPLY,
RPL_ENDOFNAMES,
RPL_LUSERCLIENT,
RPL_LUSEROP,
RPL_LUSERUNKNOWN,
RPL_LUSERCHANNELS,
RPL_LUSERME,
RPL_WHOISUSER,
RPL_WHOISSERVER,
RPL_ENDOFWHOIS,
PING,
PONG,
ERR_NONICKNAMEGIVEN,
ERR_NICKNAMEINUSE,
ERR_ALREADYREGISTRED,
ERR_NEEDMOREPARAMS,
ERR_NOTREGISTERED,
ERR_UNKNOWNCOMMAND,
ERR_NORECIPIENT,
ERR_NOTEXTTOSEND,
ERR_NOSUCHNICK,
ERR_NOMOTD,
}
impl IRCCommand {
pub fn command_text(&self) -> &str {
match *self {
IRCCommand::NONE => "NONE",
IRCCommand::NAMES => "NAMES",
IRCCommand::PRIVMSG => "PRIVMSG",
IRCCommand::NICK => "NICK",
IRCCommand::RPL_NAMREPLY => "353",
IRCCommand::RPL_ENDOFNAMES => "366",
IRCCommand::RPL_WELCOME => "001",
IRCCommand::PING => "PING",
IRCCommand::PONG => "PONG",
IRCCommand::USER => "USER",
IRCCommand::QUIT => "QUIT",
IRCCommand::NOTICE => "NOTICE",
IRCCommand::MOTD => "MOTD",
IRCCommand::LUSERS => "LUSERS",
IRCCommand::WHOIS => "WHOIS",
IRCCommand::RPL_YOURHOST => "002",
IRCCommand::RPL_CREATED => "003",
IRCCommand::RPL_MYINFO => "004",
IRCCommand::RPL_LUSERCLIENT => "251",
IRCCommand::RPL_LUSEROP => "252",
IRCCommand::RPL_LUSERUNKNOWN => "253",
IRCCommand::RPL_LUSERCHANNELS => "254",
IRCCommand::RPL_LUSERME => "255",
IRCCommand::RPL_WHOISUSER => "311",
IRCCommand::RPL_WHOISSERVER => "312",
IRCCommand::RPL_ENDOFWHOIS => "318",
IRCCommand::ERR_NONICKNAMEGIVEN => "431",
IRCCommand::ERR_NICKNAMEINUSE => "433",
IRCCommand::ERR_ALREADYREGISTRED => "462",
IRCCommand::ERR_NEEDMOREPARAMS => "461",
IRCCommand::ERR_NOTREGISTERED => "451",
IRCCommand::ERR_UNKNOWNCOMMAND => "421",
IRCCommand::ERR_NORECIPIENT => "411",
IRCCommand::ERR_NOTEXTTOSEND => "412",
IRCCommand::ERR_NOSUCHNICK => "401",
IRCCommand::ERR_NOMOTD => "422",
IRCCommand::TOPIC => "TOPIC",
}
}
pub fn text_command(text: &str) -> IRCCommand {
match text {
"NAMES" => return IRCCommand::NAMES,
"NICK" => return IRCCommand::NICK,
"PRIVMSG" => return IRCCommand::PRIVMSG,
"001" => return IRCCommand::RPL_WELCOME,
"353" => return IRCCommand::RPL_NAMREPLY,
"366" => return IRCCommand::RPL_ENDOFNAMES,
"PING" => return IRCCommand::PING,
"PONG" => return IRCCommand::PONG,
"USER" => return IRCCommand::USER,
"QUIT" => return IRCCommand::QUIT,
"NOTICE" => return IRCCommand::NOTICE,
"MOTD" => return IRCCommand::MOTD,
"LUSERS" => return IRCCommand::LUSERS,
"WHOIS" => return IRCCommand::WHOIS,
"TOPIC" => return IRCCommand::TOPIC,
"002" => return IRCCommand::RPL_YOURHOST,
"003" => return IRCCommand::RPL_CREATED,
"004" => return IRCCommand::RPL_MYINFO,
"251" => return IRCCommand::RPL_LUSERCLIENT,
"252" => return IRCCommand::RPL_LUSEROP,
"253" => return IRCCommand::RPL_LUSERUNKNOWN,
"254" => return IRCCommand::RPL_LUSERCHANNELS,
"255" => return IRCCommand::RPL_LUSERME,
"311" => return IRCCommand::RPL_WHOISUSER,
"312" => return IRCCommand::RPL_WHOISSERVER,
"318" => return IRCCommand::RPL_ENDOFWHOIS,
"431" => return IRCCommand::ERR_NONICKNAMEGIVEN,
"433" => return IRCCommand::ERR_NICKNAMEINUSE,
"462" => return IRCCommand::ERR_ALREADYREGISTRED,
"461" => return IRCCommand::ERR_NEEDMOREPARAMS,
"451" => return IRCCommand::ERR_NOTREGISTERED,
"421" => return IRCCommand::ERR_UNKNOWNCOMMAND,
"411" => return IRCCommand::ERR_NORECIPIENT,
"412" => return IRCCommand::ERR_NOTEXTTOSEND,
"401" => return IRCCommand::ERR_NOSUCHNICK,
"422" => return IRCCommand::ERR_NOMOTD,
_ => return IRCCommand::NONE,
}
}
pub fn params_before_colon(&self) -> usize {
match *self {
IRCCommand::PRIVMSG => 1,
IRCCommand::USER => 3,
IRCCommand::TOPIC => 1,
_ => 0,
}
}
pub fn parse_params(&self, raw_input: Vec<Vec<u8>>) -> Result<Vec<Vec<u8>>, MessageError> {
let mut return_vec: Vec<Vec<u8>> = Vec::new();
match *self {
IRCCommand::NONE => Ok(Vec::new()),
IRCCommand::NAMES => Ok(Vec::new()),
IRCCommand::PRIVMSG => IRCCommand::number_and_presence(&raw_input, 2),
IRCCommand::NICK => IRCCommand::number_and_presence(&raw_input, 1),
IRCCommand::RPL_NAMREPLY => IRCCommand::number_and_presence(&raw_input, 2),
IRCCommand::RPL_ENDOFNAMES => IRCCommand::number_and_presence(&raw_input, 2),
IRCCommand::RPL_WELCOME => IRCCommand::number_and_presence(&raw_input, 2),
IRCCommand::PING => IRCCommand::number_and_presence(&raw_input, 1),
IRCCommand::PONG => IRCCommand::number_and_presence(&raw_input, 1),
IRCCommand::USER => IRCCommand::number_and_presence(&raw_input, 4),
IRCCommand::QUIT => {
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
}
IRCCommand::NOTICE => IRCCommand::number_and_presence(&raw_input, 2),
IRCCommand::MOTD => {
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
}
IRCCommand::LUSERS => {
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
}
IRCCommand::WHOIS => IRCCommand::number_and_presence(&raw_input, 1),
IRCCommand::RPL_YOURHOST => IRCCommand::number_and_presence(&raw_input, 2),
IRCCommand::RPL_CREATED => IRCCommand::number_and_presence(&raw_input, 2),
IRCCommand::RPL_MYINFO => IRCCommand::number_and_presence(&raw_input, 2),
IRCCommand::RPL_LUSERCLIENT => IRCCommand::number_and_presence(&raw_input, 2),
IRCCommand::RPL_LUSEROP => IRCCommand::number_and_presence(&raw_input, 3),
IRCCommand::RPL_LUSERUNKNOWN => IRCCommand::number_and_presence(&raw_input, 3),
IRCCommand::RPL_LUSERCHANNELS => IRCCommand::number_and_presence(&raw_input, 3),
IRCCommand::RPL_LUSERME => IRCCommand::number_and_presence(&raw_input, 1),
IRCCommand::RPL_WHOISUSER => IRCCommand::number_and_presence(&raw_input, 6),
IRCCommand::RPL_WHOISSERVER => IRCCommand::number_and_presence(&raw_input, 4),
IRCCommand::RPL_ENDOFWHOIS => IRCCommand::number_and_presence(&raw_input, 3),
IRCCommand::ERR_NONICKNAMEGIVEN => IRCCommand::number_and_presence(&raw_input, 1),
IRCCommand::ERR_NICKNAMEINUSE => IRCCommand::number_and_presence(&raw_input, 2),
IRCCommand::ERR_ALREADYREGISTRED => IRCCommand::number_and_presence(&raw_input, 2),
IRCCommand::ERR_NEEDMOREPARAMS => IRCCommand::number_and_presence(&raw_input, 3),
IRCCommand::ERR_NOTREGISTERED => IRCCommand::number_and_presence(&raw_input, 1),
IRCCommand::ERR_UNKNOWNCOMMAND => IRCCommand::number_and_presence(&raw_input, 3),
IRCCommand::ERR_NORECIPIENT => IRCCommand::number_and_presence(&raw_input, 2),
IRCCommand::ERR_NOTEXTTOSEND => IRCCommand::number_and_presence(&raw_input, 2),
IRCCommand::ERR_NOSUCHNICK => IRCCommand::number_and_presence(&raw_input, 3),
IRCCommand::ERR_NOMOTD => IRCCommand::number_and_presence(&raw_input, 2),
IRCCommand::TOPIC => IRCCommand::parse_topic(&raw_input),
}
}
fn parse_topic(params: &Vec<Vec<u8>>) -> Result<Vec<Vec<u8>>, MessageError> {
if params.len() < 1 {
return Err(MessageError {
detail: NotEnoughParams,
});
}
let mut return_vec: Vec<Vec<u8>> = Vec::new();
IRCCommand::parse_irc_params(¶ms, &mut return_vec);
Ok(return_vec)
}
fn number_and_presence(
params: &Vec<Vec<u8>>,
number: usize,
) -> Result<Vec<Vec<u8>>, MessageError> {
let mut return_vec: Vec<Vec<u8>> = Vec::new();
if !IRCCommand::validate_param_presence(¶ms) {
return Err(MessageError {
detail: BlankParams,
});
}
if params.len() < number {
return Err(MessageError {
detail: NotEnoughParams,
});
}
IRCCommand::parse_irc_params(¶ms, &mut return_vec);
Ok(return_vec)
}
fn validate_param_presence(params: &Vec<Vec<u8>>) -> bool {
for p in params {
if p.len() < 1 {
return false;
}
}
true
}
fn parse_irc_params(raw_input: &Vec<Vec<u8>>, return_vec: &mut Vec<Vec<u8>>) {
for (i, r) in raw_input.into_iter().enumerate() {
if r[0] != 58 {
return_vec.push(r.to_vec());
} else {
let rest = raw_input.clone().split_off(i);
let mut message: Vec<u8> = Vec::new();
for (j, s) in rest.into_iter().enumerate() {
if j == 0 {
message = [message, s[1..].to_vec()].concat();
} else {
message = [message, [[32].to_vec(), s].concat()].concat();
}
}
return_vec.push(message);
return;
}
}
}
}
#[test]
fn test_no_params() {
let command_params = vec!["".as_bytes().to_vec()];
let res = IRCCommand::NAMES.parse_params(command_params);
assert!(res.is_ok());
assert_eq!(res.ok().unwrap().len(), 0);
let command_params = vec!["abc".as_bytes().to_vec()];
let res = IRCCommand::NAMES.parse_params(command_params);
assert!(res.is_ok());
assert_eq!(res.ok().unwrap().len(), 0);
let command_params = vec!["abc :Hello".as_bytes().to_vec()];
let res = IRCCommand::NAMES.parse_params(command_params);
assert!(res.is_ok());
assert_eq!(res.ok().unwrap().len(), 0);
}
#[test]
fn test_one_param() {
let command_params = vec!["".as_bytes().to_vec()];
let res = IRCCommand::NICK.parse_params(command_params);
assert!(res.is_err());
assert_eq!(res.err().unwrap().detail, BlankParams);
let command_params = vec!["Anon".as_bytes().to_vec()];
let res = IRCCommand::NICK.parse_params(command_params);
assert!(res.is_ok());
assert_eq!(res.ok().unwrap()[0][0], 65);
let command_params = vec!["Anon".as_bytes().to_vec(), "B".as_bytes().to_vec()];
let res = IRCCommand::NICK.parse_params(command_params);
assert!(res.is_ok());
assert_eq!(res.ok().unwrap().len(), 2);
}
#[test]
fn test_message_param() {
let command_params = vec!["".as_bytes().to_vec()];
let res = IRCCommand::PRIVMSG.parse_params(command_params);
assert!(res.is_err());
assert_eq!(res.err().unwrap().detail, BlankParams);
let command_params = vec!["Anon".as_bytes().to_vec()];
let res = IRCCommand::PRIVMSG.parse_params(command_params);
assert!(res.is_err());
assert_eq!(res.err().unwrap().detail, NotEnoughParams);
let command_params = vec![
"Anon".as_bytes().to_vec(),
":Hello".as_bytes().to_vec(),
"anon".as_bytes().to_vec(),
];
let res = IRCCommand::PRIVMSG.parse_params(command_params);
assert!(res.is_ok());
assert_eq!(res.as_ref().ok().unwrap().len(), 2);
assert_eq!(res.as_ref().ok().unwrap()[1][0], 72);
}
#[test]
fn test_welcome() {
let raw_input = vec![
"Anon".as_bytes().to_vec(),
":Welcome".as_bytes().to_vec(),
"to".as_bytes().to_vec(),
"the".as_bytes().to_vec(),
"server".as_bytes().to_vec(),
];
let res = IRCCommand::RPL_WELCOME.parse_params(raw_input);
println!("{:?}", res);
assert!(res.is_ok());
assert_eq!(res.as_ref().unwrap().len(), 2);
assert_eq!(res.as_ref().unwrap()[1].len(), 21);
let raw_input = vec!["Anon".as_bytes().to_vec()];
let res = IRCCommand::RPL_WELCOME.parse_params(raw_input);
println!("{:?}", res);
assert!(res.is_err());
}