natty
/
magnetar
1
0
Fork 0
Code Issues 4 Pull Requests 1 Packages Projects Releases Wiki Activity

Print RPC errors in Debug instead of Display
ci/woodpecker/push/ociImagePush Pipeline was successful Details

This commit is contained in:
Natty 2024-11-16 00:11:18 +01:00
parent ad3b0e1ffb
commit e53afb3313
Signed by: natty
GPG Key ID: BF6CB659ADEE60EC
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/rpc_v1/proto.rs
View File

@ -1,22 +1,21 @@
use crate::service::MagnetarService; use crate::service::MagnetarService;
use bytes::BufMut;
use futures::{FutureExt, Stream, StreamExt}; use futures::{FutureExt, Stream, StreamExt};
use miette::{miette, IntoDiagnostic}; use miette::{miette, IntoDiagnostic};
use serde::de::DeserializeOwned; use serde::de::DeserializeOwned;
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use std::any::Any; use std::any::Any;
use std::collections::HashMap; use std::collections::HashMap;
use std::fmt::Display; use std::fmt::Debug;
use std::future::Future; use std::future::Future;
use std::net::SocketAddr; use std::net::SocketAddr;
use std::path::{Path, PathBuf}; use std::path::{Path, PathBuf};
use std::pin::Pin; use std::pin::Pin;
use std::sync::Arc; use std::sync::Arc;
use tokio::io::{AsyncRead, AsyncReadExt, AsyncWriteExt, BufReader, ReadBuf}; use tokio::io::{AsyncRead, AsyncReadExt, AsyncWriteExt, BufReader};
use tokio::net::{TcpListener, UnixSocket}; use tokio::net::{TcpListener, UnixSocket};
use tokio::select; use tokio::select;
use tokio::task::JoinSet; use tokio::task::JoinSet;
use tracing::{debug, error, info, Instrument}; use tracing::{debug, error, info, warn, Instrument};
#[derive(Debug, Clone)] #[derive(Debug, Clone)]
pub enum RpcSockAddr { pub enum RpcSockAddr {
@ -56,7 +55,7 @@ pub struct RpcResult<T> {
data: T, data: T,
} }
impl<T: Serialize + Send + 'static, E: Serialize + Display + Send + 'static> IntoRpcResponse impl<T: Serialize + Send + 'static, E: Serialize + Debug + Send + 'static> IntoRpcResponse
for Result<T, E> for Result<T, E>
{ {
fn into_rpc_response(self) -> Option<RpcResponse> { fn into_rpc_response(self) -> Option<RpcResponse> {
@ -67,7 +66,7 @@ impl<T: Serialize + Send + 'static, E: Serialize + Display + Send + 'static> Int
}) })
.into_rpc_response(), .into_rpc_response(),
Err(data) => { Err(data) => {
error!("{}", data); warn!("{:?}", data);
RpcMessage(RpcResult { RpcMessage(RpcResult {
success: false, success: false,
data, data,