reactor
/
ptth
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

🔇 make logs quieter

main
_ 2022-02-05 15:57:40 +00:00
parent c47ab6d282
commit d96bf801c6
3 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
crates/ptth_server/src/file_server.rs
View File

@ -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,

2
crates/ptth_server/src/file_server/internal.rs
View File

@ -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)?;

9
crates/ptth_server/src/lib.rs
View File

@ -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?;