aboutsummaryrefslogtreecommitdiff
path: root/src/server/parser.rs
diff options
context:
space:
mode:
authorFuwn <[email protected]>2021-04-26 13:26:53 +0000
committerFuwn <[email protected]>2021-04-26 13:26:53 +0000
commit6bf261e243b11b376a0cbfbe9ab6f9d6cb398aed (patch)
tree326e64552b6223d21feb3cc5b525f792e252ccc1 /src/server/parser.rs
parentetc: Prepend license identifier to *most* files (diff)
downloadwhirl-6bf261e243b11b376a0cbfbe9ab6f9d6cb398aed.tar.xz
whirl-6bf261e243b11b376a0cbfbe9ab6f9d6cb398aed.zip
etc: Remove legacy server module
Diffstat (limited to 'src/server/parser.rs')
-rw-r--r--src/server/parser.rs35
1 files changed, 0 insertions, 35 deletions
diff --git a/src/server/parser.rs b/src/server/parser.rs
deleted file mode 100644
index f856650..0000000
--- a/src/server/parser.rs
+++ /dev/null
@@ -1,35 +0,0 @@
-use bytes::BytesMut;
-
-/// Read all commands from the given buffer.
-///
-/// # Process
-/// 1. Get a command from `buffer` based on first byte.
-/// 2. Push command to `commands`.
-/// 3. Remove command from `buffer`.
-/// 4. Iterate and do this for all commands within `buffer`.
-pub fn get_commands_from_buffer(mut buffer: BytesMut) -> Vec<BytesMut> {
- let mut commands: Vec<BytesMut> = Vec::new();
- trace!("initial buffer: {:?}, length: {}", buffer, buffer.len());
-
- let data_length = buffer.get(0).unwrap().to_owned() as usize;
- if buffer.len() > data_length {
- loop {
- trace!("loop: {:?}, length: {}", buffer, buffer.len());
- let command_length = buffer.get(0).unwrap().to_owned() as usize;
- commands.push(BytesMut::from(buffer.get(0..command_length).unwrap()));
-
- // Remove command from buffer
- buffer = buffer.split_off(command_length);
-
- // Check if any more commands are present
- if buffer.is_empty() {
- break;
- }
- }
- } else {
- // There will always be at least one command, push it.
- commands.push(BytesMut::from(buffer.get(0..data_length).unwrap()));
- }
-
- commands // Return command (s)
-}