kristoferssolo/transmission-rpc
1
0
Fork 0
mirror of https://github.com/kristoferssolo/transmission-rpc.git synced 2025-10-21 20:10:37 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

chore: fix log level

Browse Source
This commit is contained in:
George Miao 2022-10-23 09:28:00 -04:00 committed by Aleksandr
parent 598171837c
commit 6791807f3f
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/lib.rs
View File

@ -764,14 +764,14 @@ impl TransClient {
.checked_sub(1) .checked_sub(1)
.ok_or(TransError::MaxRetriesReached)?; .ok_or(TransError::MaxRetriesReached)?;
info!("Loaded auth: {:?}", &self.auth); debug!("Loaded auth: {:?}", &self.auth);
let rq = match &self.session_id { let rq = match &self.session_id {
None => self.rpc_request(), None => self.rpc_request(),
Some(id) => self.rpc_request().header("X-Transmission-Session-Id", id), Some(id) => self.rpc_request().header("X-Transmission-Session-Id", id),
} }
.json(&request); .json(&request);
info!( debug!(
"Request body: {:?}", "Request body: {:?}",
rq.try_clone() rq.try_clone()
.expect("Unable to get the request body") .expect("Unable to get the request body")
@ -787,10 +787,10 @@ impl TransClient {
.to_str()?; .to_str()?;
self.session_id = Some(String::from(session_id)); self.session_id = Some(String::from(session_id));
info!("Got new session_id: {}. Retrying request.", session_id); debug!("Got new session_id: {}. Retrying request.", session_id);
} else { } else {
let rpc_response: RpcResponse<RS> = rsp.json().await?; let rpc_response: RpcResponse<RS> = rsp.json().await?;
info!("Response body: {:#?}", rpc_response); debug!("Response body: {:#?}", rpc_response);
return Ok(rpc_response); return Ok(rpc_response);
} }

8
src/sync.rs
View File

@ -743,14 +743,14 @@ impl SharableTransClient {
.checked_sub(1) .checked_sub(1)
.ok_or(TransError::MaxRetriesReached)?; .ok_or(TransError::MaxRetriesReached)?;
info!("Loaded auth: {:?}", &self.auth); debug!("Loaded auth: {:?}", &self.auth);
let rq = match &self.session_id.read().expect("lock being poisoned").deref() { let rq = match &self.session_id.read().expect("lock being poisoned").deref() {
None => self.rpc_request(), None => self.rpc_request(),
Some(id) => self.rpc_request().header("X-Transmission-Session-Id", id), Some(id) => self.rpc_request().header("X-Transmission-Session-Id", id),
} }
.json(&request); .json(&request);
info!( debug!(
"Request body: {:?}", "Request body: {:?}",
rq.try_clone() rq.try_clone()
.expect("Unable to get the request body") .expect("Unable to get the request body")
@ -767,10 +767,10 @@ impl SharableTransClient {
*self.session_id.write().expect("lock being poisoned") = *self.session_id.write().expect("lock being poisoned") =
Some(String::from(session_id)); Some(String::from(session_id));
info!("Got new session_id: {}. Retrying request.", session_id); debug!("Got new session_id: {}. Retrying request.", session_id);
} else { } else {
let rpc_response: RpcResponse<RS> = rsp.json().await?; let rpc_response: RpcResponse<RS> = rsp.json().await?;
info!("Response body: {:#?}", rpc_response); debug!("Response body: {:#?}", rpc_response);
return Ok(rpc_response); return Ok(rpc_response);
} }