diff --git a/server/Cargo.toml b/server/Cargo.toml index 4667538..817ce59 100644 --- a/server/Cargo.toml +++ b/server/Cargo.toml @@ -11,10 +11,10 @@ path = "rocket_server.rs" [dependencies] chashmap = "2.2.2" -flate2 = "1.0.25" -fnv = "1.0.7" +#flate2 = "1.0.25" +#fnv = "1.0.7" lazy_static = "1.4.0" -log = "0.4.17" +#log = "0.4.17" measure_time = "0.8.2" rocket = { version = "0.5.0", features = ["json"] } rocket_cors = "0.6" @@ -22,20 +22,9 @@ serde = "1.0.156" serde_derive = "1.0.156" serde_json = "1.0.94" -# fix rocket build -proc-macro2 = "<= 1.0.51" - -#[dependencies.multipart] -#features = ["rocket"] -#version = "0.18.0" - [dependencies.veloci] path = "../" -[dependencies.uuid] -features = ["v4"] -version = "1.3.0" - [dev-dependencies] criterion = "0.4.0" pretty_assertions = "1.3.0" diff --git a/server/rocket_server.rs b/server/rocket_server.rs index 8d788b8..39bfb11 100644 --- a/server/rocket_server.rs +++ b/server/rocket_server.rs @@ -1,5 +1,5 @@ /// -/// A werserver connecting the search engine +/// A webserver connecting the search engine /// The api is a horrible mess, don't use it. /// @@ -23,8 +23,6 @@ use chashmap::CHashMap; // }; use rocket::serde::{json::Json, Serialize}; -//use rocket::json::Json; -//use rocket::form::Form; use rocket::{ http::{ContentType, Status}, response::{self, status::Custom, Responder, Response}, @@ -45,7 +43,6 @@ lazy_static! { #[derive(Debug)] struct SearchResult(search::SearchResultWithDoc); -// struct SearchErroro(VelociError); #[derive(Debug)] struct SuggestResult(search_field::SuggestFieldResult); @@ -56,15 +53,6 @@ impl<'r, 'o: 'r> Responder<'r, 'o> for SearchResult { Response::build().header(ContentType::JSON).sized_body(json.len(), Cursor::new(json)).ok() } } -//impl<'r> Responder<'r> for SearchErroro { -//fn respond_to(self, _req: &Request) -> response::Result<'r> { -//let formatted_error: String = format!("{:?}", &self.0); -//Response::build() -//.header(ContentType::JSON) -//.sized_body(Cursor::new(serde_json::to_string(&json!({ "error": formatted_error })).unwrap())) -//.ok() -//} -//} impl<'r, 'o: 'r> Responder<'r, 'o> for SuggestResult { fn respond_to(self, _req: &'r Request) -> response::Result<'o> { @@ -99,41 +87,6 @@ struct QueryParams { filter: Option, } -// struct MyParam { -// key: String, -// value: usize -// } - -// use rocket::request::FromParam; -// use rocket::http::RawStr; - -// impl FromParam for MyParam { -// type Error = RawStr; - -// fn from_param(param: RawStr) -> Result { -// let (key, val_str) = match param.find(':') { -// Some(i) if i > 0 => (¶m[..i], ¶m[(i + 1)..]), -// _ => return Err(param) -// }; - -// if !key.chars().all(|c| (c >= 'a' && c <= 'z') || (c >= 'A' && c <= 'Z')) { -// return Err(param); -// } - -// val_str.parse().map(|value| { -// MyParam { -// key: key, -// value: value -// } -// }).map_err(|_| param) -// } -// } - -// #[get("/test")] -// fn test() -> String { -// "0.5".to_string() -// } - fn query_param_to_vec(name: Option) -> Option> { // TODO Replace with FromForm ? directly in QueryParams name.map(|el| el.split(',').map(|f| f.to_string()).collect()) @@ -202,7 +155,6 @@ fn get_doc_for_id_tree(database: String, id: u32) -> Json { #[get("//_id/")] fn get_doc_for_id_direct(database: String, id: u32) -> Json { - // let persistence = PERSISTENCES.get(&database).unwrap(); // let fields = persistence.get_all_fields(); // let tree = search::get_read_tree_from_fields(&persistence, &fields); ensure_database(&database).unwrap(); @@ -242,7 +194,6 @@ fn search_from_query_params(database: String, params: QueryParams) -> Result> = query_param_to_vec(params.boost_terms).map(|mkay| { mkay.into_iter() @@ -252,7 +203,6 @@ fn search_from_query_params(database: String, params: QueryParams) -> Result) -> Result { // // let params = params.map_err(|err| Custom(Status::BadRequest, format!("{:let params: QueryParams = params.into_inner();?}", err)))?; // let params: QueryParams = params.into_inner(); - // let q_params = request.0; // let persistence = PERSISTENCES.get(&database).unwrap(); - // let mut request = query_generator::search_query(&persistence, q_params.clone()).map_err(|err| Custom(Status::BadRequest, format!("query_generation failed: {:?}", err)))?; - // request.select = query_param_to_vec(q_params.select); - // search::explain_plan(request, &persistence) // } #[get("//search?")] -fn search_get(database: String, params: QueryParams) -> Result> { +fn search_get(database: String, params: QueryParams) -> Result { // let params = params.map_err(|err| Custom(Status::BadRequest, format!("{:let params: QueryParams = params.into_inner();?}", err)))?; search_from_query_params(database, params) }