use crate::error::{MessageError, MessageErrorDetails};
#[derive(Debug, PartialEq)]
#[allow(non_camel_case_types)]
pub enum IRCCommand {
NONE,
NAMES,
PRIVMSG,
NICK,
RPL_WELCOME,
RPL_NAMREPLY,
RPL_ENDOFNAMES,
PING,
PONG,
}
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",
}
}
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_two_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_one_param(raw_input, &mut return_vec);
Ok(return_vec)
}
IRCCommand::RPL_NAMREPLY => {
if raw_input.len() < 2 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
return Ok(raw_input);
}
IRCCommand::RPL_ENDOFNAMES => {
if raw_input.len() < 2 {
return Err(MessageError {
detail: MessageErrorDetails::NotEnoughParams,
});
}
IRCCommand::parse_two_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_two_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_one_param(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_one_param(raw_input, &mut return_vec);
Ok(return_vec)
},
}
}
fn parse_two_params(raw_input: Vec<Vec<u8>>, return_vec: &mut Vec<Vec<u8>>) {
return_vec.insert(0, raw_input[0].clone());
let mut message: Vec<u8> = Vec::new();
for (i, r) in raw_input.into_iter().enumerate() {
if i == 1 {
message = [message, r[1..].to_vec()].concat();
} else if i > 1 {
message = [message, [[32].to_vec(), r].concat()].concat();
}
}
return_vec.insert(1, message);
}
fn parse_one_param(raw_input: Vec<Vec<u8>>, return_vec: &mut Vec<Vec<u8>>) {
return_vec.insert(0, raw_input[0].clone());
}
}
#[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(), 1);
}
#[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());
}