diff options
Diffstat (limited to 'src/server_dev/cmd')
| -rw-r--r-- | src/server_dev/cmd/action.rs | 6 | ||||
| -rw-r--r-- | src/server_dev/cmd/buddy_list.rs | 14 | ||||
| -rw-r--r-- | src/server_dev/cmd/mod.rs | 5 | ||||
| -rw-r--r-- | src/server_dev/cmd/property.rs | 7 | ||||
| -rw-r--r-- | src/server_dev/cmd/session.rs | 6 | ||||
| -rw-r--r-- | src/server_dev/cmd/text.rs | 55 |
6 files changed, 93 insertions, 0 deletions
diff --git a/src/server_dev/cmd/action.rs b/src/server_dev/cmd/action.rs new file mode 100644 index 0000000..1cf9086 --- /dev/null +++ b/src/server_dev/cmd/action.rs @@ -0,0 +1,6 @@ +pub fn create_action_command() -> [u8; 18] { + [ + 0x12, 0x01, 0x11, 0x00, 0x05, 0x54, 0x52, 0x41, 0x44, 0x45, 0x07, 0x26, 0x7c, 0x2b, 0x69, 0x6e, + 0x76, 0x3e, + ] +} diff --git a/src/server_dev/cmd/buddy_list.rs b/src/server_dev/cmd/buddy_list.rs new file mode 100644 index 0000000..ba938f5 --- /dev/null +++ b/src/server_dev/cmd/buddy_list.rs @@ -0,0 +1,14 @@ +pub fn create_buddy_list_notify_command(buddy: &str) -> Vec<u8> { + let mut buddy_list_notify = Vec::with_capacity(5 + buddy.len()); + buddy_list_notify.push(0x01); // ? + buddy_list_notify.push(0x1E); // BUDDYLISTNOTIFY + buddy_list_notify.push(buddy.len() as u8); // Buddy name length + for i in buddy.bytes() { + buddy_list_notify.push(i); + } // Buddy name + buddy_list_notify.push(0x01); // Is buddy logged on? + // Insert data length as first byte. + buddy_list_notify.insert(0, buddy_list_notify.len() as u8 + 1); // ^ + + buddy_list_notify // Return created array +} diff --git a/src/server_dev/cmd/mod.rs b/src/server_dev/cmd/mod.rs new file mode 100644 index 0000000..6db7826 --- /dev/null +++ b/src/server_dev/cmd/mod.rs @@ -0,0 +1,5 @@ +pub mod action; +pub mod buddy_list; +pub mod property; +pub mod session; +pub mod text; diff --git a/src/server_dev/cmd/property.rs b/src/server_dev/cmd/property.rs new file mode 100644 index 0000000..1530f58 --- /dev/null +++ b/src/server_dev/cmd/property.rs @@ -0,0 +1,7 @@ +use std::str::from_utf8; + +use bytes::BytesMut; + +pub fn parse_property_set_command(command: BytesMut) -> String { + from_utf8(command.get(8..).unwrap()).unwrap().to_string() +} diff --git a/src/server_dev/cmd/session.rs b/src/server_dev/cmd/session.rs new file mode 100644 index 0000000..97efc8f --- /dev/null +++ b/src/server_dev/cmd/session.rs @@ -0,0 +1,6 @@ +pub struct SessionInitializationCommand { + // pub protocol: usize, + // pub client: String, + pub username: String, + // pub password: String, +} diff --git a/src/server_dev/cmd/text.rs b/src/server_dev/cmd/text.rs new file mode 100644 index 0000000..cc306db --- /dev/null +++ b/src/server_dev/cmd/text.rs @@ -0,0 +1,55 @@ +pub fn create_text_command(user: &str, message: &str) -> Vec<u8> { + let mut text = Vec::with_capacity(6 + user.len() + message.len()); + text.push(0x01); // ? + text.push(0x0E); // Command type + text.push(0x00); // Assumed to be a divider. + text.push(user.len() as u8); // 'user' length + for i in user.bytes() { + text.push(i); + } // Pushing 'user' + text.push(message.len() as u8); // 'message' length + for i in message.bytes() { + text.push(i); + } // Pushing `message` + text.insert(0, text.len() as u8 + 1); // Insert data length as first byte. + + text // Return created array +} + +// TODO: Get this working! +// pub fn get_message_from_text_command(buffer: &'static [u8; 1024]) -> &'static +// str { from_utf8( +// &buffer[6..*&buffer.get(0).unwrap().to_owned() as usize] +// ).unwrap() +// } + +pub fn create_text_command_with_action( + user: &str, + message: &str, + // action: &str // Not accepting input until I figure out how actions work. +) -> Vec<u8> { + let mut text = Vec::with_capacity(6 + user.len() + message.len()); + text.push(0x01); // ? + text.push(0x0E); // Command type + text.push(0x00); // Assumed to be a divider. + text.push(user.len() as u8); // 'user' length + for i in user.bytes() { + text.push(i); + } // Pushing 'user' + text.push(message.len() as u8); // 'message' length + for i in message.bytes() { + text.push(i); + } // Pushing `message` + + let action: [u8; 18] = [ + 0x12, 0x01, 0x11, 0x00, 0x05, 0x54, 0x52, 0x41, 0x44, 0x45, 0x07, 0x26, 0x7c, 0x2b, 0x69, 0x6e, + 0x76, 0x3e, + ]; + for i in action.iter() { + text.push(*i); + } + + text.insert(0, text.len() as u8 + 1); // Insert data length as first byte. + + text // Return created array +} |