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,
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",
}
}
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 => {
if raw_input.len() < 2 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
}
IRCCommand::NICK => {
if raw_input.len() < 1 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
if raw_input[0].len() < 1 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
}
IRCCommand::RPL_NAMREPLY => {
if raw_input.len() < 2 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
}
IRCCommand::RPL_ENDOFNAMES => {
if raw_input.len() < 2 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
}
IRCCommand::RPL_WELCOME => {
if raw_input.len() < 2 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
}
IRCCommand::PING => {
if raw_input.len() < 1 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
if raw_input[0].len() < 1 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
}
IRCCommand::PONG => {
if raw_input.len() < 1 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
if raw_input[0].len() < 1 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
}
IRCCommand::USER => {
if raw_input.len() < 4 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
}
IRCCommand::QUIT => {
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
}
IRCCommand::NOTICE => {
if raw_input.len() < 2 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
}
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 => {
if raw_input.len() < 1 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
}
IRCCommand::RPL_YOURHOST => {
if raw_input.len() < 2 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::RPL_CREATED => {
if raw_input.len() < 2 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::RPL_MYINFO => {
if raw_input.len() < 2 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::RPL_LUSERCLIENT => {
if raw_input.len() < 2 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::RPL_LUSEROP => {
if raw_input.len() < 3 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::RPL_LUSERUNKNOWN => {
if raw_input.len() < 3 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::RPL_LUSERCHANNELS => {
if raw_input.len() < 3 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::RPL_LUSERME => {
if raw_input.len() < 1 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::RPL_WHOISUSER => {
if raw_input.len() < 6 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::RPL_WHOISSERVER => {
if raw_input.len() < 4 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::RPL_ENDOFWHOIS => {
if raw_input.len() < 3 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::ERR_NONICKNAMEGIVEN => {
if raw_input.len() < 1 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::ERR_NICKNAMEINUSE => {
if raw_input.len() < 2 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::ERR_ALREADYREGISTRED => {
if raw_input.len() < 2 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::ERR_NEEDMOREPARAMS => {
if raw_input.len() < 3 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::ERR_NOTREGISTERED => {
if raw_input.len() < 1 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::ERR_UNKNOWNCOMMAND => {
if raw_input.len() < 3 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::ERR_NORECIPIENT => {
if raw_input.len() < 2 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::ERR_NOTEXTTOSEND => {
if raw_input.len() < 2 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::ERR_NOSUCHNICK => {
if raw_input.len() < 3 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
IRCCommand::ERR_NOMOTD => {
if raw_input.len() < 2 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_irc_params(&raw_input, &mut return_vec);
Ok(return_vec)
},
}
}
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,
MessageErrorDetails::NotEnoughParams
);
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,
MessageErrorDetails::NotEnoughParams
);
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,
MessageErrorDetails::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());
}