Upgrade sky-bench to use client driver
Sayan Nandan
3 years ago
parent
f55fa85174
commit
5847cf1da9
@ -1,177 +0,0 @@
|
||||
/*
|
||||
* Created on Sat Jul 18 2020
|
||||
*
|
||||
* This file is a part of Skytable
|
||||
* Skytable (formerly known as TerrabaseDB or Skybase) is a free and open-source
|
||||
* NoSQL database written by Sayan Nandan ("the Author") with the
|
||||
* vision to provide flexibility in data modelling without compromising
|
||||
* on performance, queryability or scalability.
|
||||
*
|
||||
* Copyright (c) 2020, Sayan Nandan <ohsayan@outlook.com>
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU Affero General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Affero General Public License
|
||||
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
*
|
||||
*/
|
||||
|
||||
//! # The Terrapipe protocol
|
||||
//! This module implements primitives for the Terrapipe protocol
|
||||
//!
|
||||
|
||||
pub const ADDR: &'static str = "127.0.0.1";
|
||||
use std::str::FromStr;
|
||||
|
||||
lazy_static::lazy_static! {
|
||||
static ref RE: regex::Regex = regex::Regex::from_str(r#"("[^"]*"|'[^']*'|[\S]+)+"#).unwrap();
|
||||
}
|
||||
|
||||
/// Response codes returned by the server
|
||||
#[derive(Debug, PartialEq)]
|
||||
pub enum RespCodes {
|
||||
/// `0`: Okay (Empty Response) - use the `ResponseBuilder` for building
|
||||
/// responses that contain data
|
||||
Okay,
|
||||
/// `1`: Not Found
|
||||
NotFound,
|
||||
/// `2`: Overwrite Error
|
||||
OverwriteError,
|
||||
/// `3`: Action Error
|
||||
ActionError,
|
||||
/// `4`: Packet Error
|
||||
PacketError,
|
||||
/// `5`: Server Error
|
||||
ServerError,
|
||||
/// `6`: Some other error - the wrapped `String` will be returned in the response body.
|
||||
/// Just a note, this gets quite messy, especially when we're using it for deconding responses
|
||||
OtherError(Option<String>),
|
||||
}
|
||||
|
||||
impl From<RespCodes> for u8 {
|
||||
fn from(rcode: RespCodes) -> u8 {
|
||||
use RespCodes::*;
|
||||
match rcode {
|
||||
Okay => 0,
|
||||
NotFound => 1,
|
||||
OverwriteError => 2,
|
||||
ActionError => 3,
|
||||
PacketError => 4,
|
||||
ServerError => 5,
|
||||
OtherError(_) => 6,
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
impl From<RespCodes> for char {
|
||||
fn from(rcode: RespCodes) -> char {
|
||||
use RespCodes::*;
|
||||
match rcode {
|
||||
Okay => '0',
|
||||
NotFound => '1',
|
||||
OverwriteError => '2',
|
||||
ActionError => '3',
|
||||
PacketError => '4',
|
||||
ServerError => '5',
|
||||
OtherError(_) => '6',
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
impl RespCodes {
|
||||
pub fn from_str(val: &str, extra: Option<String>) -> Option<Self> {
|
||||
use RespCodes::*;
|
||||
let res = match val.parse::<u8>() {
|
||||
Ok(val) => match val {
|
||||
0 => Okay,
|
||||
1 => NotFound,
|
||||
2 => OverwriteError,
|
||||
3 => ActionError,
|
||||
4 => PacketError,
|
||||
5 => ServerError,
|
||||
6 => OtherError(extra),
|
||||
_ => return None,
|
||||
},
|
||||
Err(_) => return None,
|
||||
};
|
||||
Some(res)
|
||||
}
|
||||
pub fn from_u8(val: u8, extra: Option<String>) -> Option<Self> {
|
||||
use RespCodes::*;
|
||||
let res = match val {
|
||||
0 => Okay,
|
||||
1 => NotFound,
|
||||
2 => OverwriteError,
|
||||
3 => ActionError,
|
||||
4 => PacketError,
|
||||
5 => ServerError,
|
||||
6 => OtherError(extra),
|
||||
_ => return None,
|
||||
};
|
||||
Some(res)
|
||||
}
|
||||
pub fn from_utf8(val: u8) -> Option<Self> {
|
||||
let result = match val.checked_sub(48) {
|
||||
Some(r) => r,
|
||||
None => return None,
|
||||
};
|
||||
if result > 6 {
|
||||
return None;
|
||||
}
|
||||
return RespCodes::from_u8(result, None);
|
||||
}
|
||||
}
|
||||
|
||||
/// Prepare a query packet from a string of whitespace separated values
|
||||
pub fn proc_query<T>(querystr: T) -> Vec<u8>
|
||||
where
|
||||
T: AsRef<str>,
|
||||
{
|
||||
let mut bytes = Vec::with_capacity(querystr.as_ref().len());
|
||||
let args: Vec<String> = RE
|
||||
.find_iter(&querystr.as_ref())
|
||||
.map(|val| val.as_str().replace("'", "").replace("\"", "").to_owned())
|
||||
.collect();
|
||||
bytes.extend(b"#2\n*1\n#");
|
||||
let arg_len_bytes = args.len().to_string().into_bytes();
|
||||
let arg_len_bytes_len = (arg_len_bytes.len() + 1).to_string().into_bytes();
|
||||
bytes.extend(arg_len_bytes_len);
|
||||
bytes.extend(b"\n&");
|
||||
bytes.extend(arg_len_bytes);
|
||||
bytes.push(b'\n');
|
||||
args.into_iter().for_each(|arg| {
|
||||
bytes.push(b'#');
|
||||
let len_bytes = arg.len().to_string().into_bytes();
|
||||
bytes.extend(len_bytes);
|
||||
bytes.push(b'\n');
|
||||
bytes.extend(arg.as_bytes());
|
||||
bytes.push(b'\n');
|
||||
});
|
||||
bytes
|
||||
}
|
||||
|
||||
#[test]
|
||||
fn test_queryproc() {
|
||||
let query = "GET x y".to_owned();
|
||||
assert_eq!(
|
||||
"#2\n*1\n#2\n&3\n#3\nGET\n#1\nx\n#1\ny\n"
|
||||
.as_bytes()
|
||||
.to_owned(),
|
||||
proc_query(query)
|
||||
);
|
||||
let q_escaped = proc_query(r#"SET X 'sayan with spaces'"#);
|
||||
assert_eq!(
|
||||
"#2\n*1\n#2\n&3\n#3\nSET\n#1\nX\n#17\nsayan with spaces\n"
|
||||
.as_bytes()
|
||||
.to_owned(),
|
||||
q_escaped
|
||||
);
|
||||
}
|
||||
Loading…
Reference in New Issue