logos-co
/
nomos-node
mirror of
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Simplify handlers for post and other data methods

This commit is contained in:
Gusto Bacvinka 2023-01-17 00:04:53 +02:00
parent 02628915e3
commit 96f2b1821e
1 changed files with 13 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
nomos-services/http/src/backends/axum.rs
View File

@ -138,27 +138,22 @@ impl AxumBackend {
} }
fn add_data_route(&self, method: HttpMethod, path: &str, req_stream: Sender<HttpRequest>) { fn add_data_route(&self, method: HttpMethod, path: &str, req_stream: Sender<HttpRequest>) {
let handler = match method { let handler_fn = |Query(query): Query<HashMap<String, String>>, payload: Option<Bytes>| async move {
HttpMethod::POST => post( handle_req(req_stream, query, payload).await
|Query(query): Query<HashMap<String, String>>, payload: Option<Bytes>| async move {
handle_req(req_stream, query, payload).await
},
),
HttpMethod::PUT => put(
|Query(query): Query<HashMap<String, String>>, payload: Option<Bytes>| async move {
handle_req(req_stream, query, payload).await
},
),
HttpMethod::PATCH => patch(
|Query(query): Query<HashMap<String, String>>, payload: Option<Bytes>| async move {
handle_req(req_stream, query, payload).await
},
),
_ => unimplemented!(),
}; };
let handlers = {
let mut handlers = HashMap::new();
handlers.insert(HttpMethod::POST, post(handler_fn.clone()));
handlers.insert(HttpMethod::PUT, put(handler_fn.clone()));
handlers.insert(HttpMethod::PATCH, patch(handler_fn));
handlers
};
let handler = handlers.get(&method).unwrap_or_else(|| unimplemented!());
let mut router = self.router.lock(); let mut router = self.router.lock();
*router = router.clone().route(path, handler) *router = router.clone().route(path, handler.clone())
} }
} }