From d96bf801c6ef50531b6ff38fbffb05f48995f5de Mon Sep 17 00:00:00 2001 From: _ <_@_> Date: Sat, 5 Feb 2022 15:57:40 +0000 Subject: [PATCH] :mute: make logs quieter --- crates/ptth_server/src/file_server.rs | 4 ++-- crates/ptth_server/src/file_server/internal.rs | 2 +- crates/ptth_server/src/lib.rs | 9 +++++---- 3 files changed, 8 insertions(+), 7 deletions(-) diff --git a/crates/ptth_server/src/file_server.rs b/crates/ptth_server/src/file_server.rs index f279ae2..6dcc924 100644 --- a/crates/ptth_server/src/file_server.rs +++ b/crates/ptth_server/src/file_server.rs @@ -139,7 +139,7 @@ async fn serve_dir_json ( Ok (response) } -#[instrument (level = "debug", skip (f))] +// #[instrument (level = "debug", skip (f))] async fn serve_file ( uri: &str, mut f: File, @@ -347,7 +347,7 @@ impl FileServer { /// Passes a request to the internal file server logic. /// Returns an HTTP response as HTML or JSON, depending on the request. - #[instrument (level = "debug", skip (self, headers))] + // #[instrument (level = "debug", skip (self, headers))] pub async fn serve_all ( &self, method: Method, diff --git a/crates/ptth_server/src/file_server/internal.rs b/crates/ptth_server/src/file_server/internal.rs index b14b812..5d319d4 100644 --- a/crates/ptth_server/src/file_server/internal.rs +++ b/crates/ptth_server/src/file_server/internal.rs @@ -259,7 +259,7 @@ pub async fn serve_all ( use std::str::FromStr; use Response::*; - info! ("Client requested {}", uri); + trace! ("Client requested {}", uri); let uri = http::Uri::from_str (uri).map_err (FileServerError::InvalidUri)?; diff --git a/crates/ptth_server/src/lib.rs b/crates/ptth_server/src/lib.rs index bf3ab02..15bfef0 100644 --- a/crates/ptth_server/src/lib.rs +++ b/crates/ptth_server/src/lib.rs @@ -91,8 +91,9 @@ async fn handle_one_req ( response: http_serde::Response, ) -> Result <(), ServerError> { + let url = format! ("{}/http_response/{}", state.config.relay_url, req_id); let mut resp_req = state.client - .post (&format! ("{}/http_response/{}", state.config.relay_url, req_id)) + .post (&url) .header (ptth_core::PTTH_MAGIC_HEADER, base64::encode (rmp_serde::to_vec (&response.parts).map_err (ServerError::MessagePackEncodeResponse)?)) .header ("X-PTTH-SERVER-NAME", &state.config.name); @@ -129,14 +130,14 @@ async fn handle_one_req ( let req = resp_req.build ().map_err (ServerError::Step5Responding)?; - debug! ("{:?}", req.headers ()); + trace! ("{:?}", req.headers ()); //println! ("Step 6"); match state.client.execute (req).await { Ok (r) => { let status = r.status (); let text = r.text ().await.map_err (ServerError::Step7AfterResponse)?; - debug! ("{:?} {:?}", status, text); + debug! ("http_response {} {:?} {:?}", req_id, status, text); }, Err (e) => { if e.is_request () { @@ -183,7 +184,7 @@ SH: Send + FnMut () -> H tokio::spawn (async move { let (req_id, parts) = (wrapped_req.id, wrapped_req.req); - debug! ("Handling request {}", req_id); + info! ("Req {} {}", req_id, parts.uri); let f = handler (parts); let response = f.await?;