Better error reporting

src/error.rs

@@ -67,6 +67,7 @@ impl Error {
 		match self {
 			Error::BadRequest(_) => StatusCode::BAD_REQUEST,
 			Error::NotFound => StatusCode::NOT_FOUND,
+			Error::RPC(_) => StatusCode::SERVICE_UNAVAILABLE,
 			_ => StatusCode::INTERNAL_SERVER_ERROR,
 		}
 	}

src/main.rs

@@ -326,7 +326,7 @@ async fn cmd_status(rpc_cli: RpcAddrClient<Message>, rpc_host: SocketAddr) -> Re
 					cfg.tag,
 					cfg.datacenter,
 					cfg.n_tokens,
-					(now_msec() - adv.last_seen)/1000,
+					(now_msec() - adv.last_seen) / 1000,
 				);
 			}
 		}

src/rpc_client.rs

@@ -41,6 +41,8 @@ pub enum RPCError {
 	RMPEncode(#[error(source)] rmp_serde::encode::Error),
 	#[error(display = "Messagepack decode error: {}", _0)]
 	RMPDecode(#[error(source)] rmp_serde::decode::Error),
+	#[error(display = "Too many errors: {:?}", _0)]
+	TooManyErrors(Vec<String>),
 }
 
 #[derive(Copy, Clone)]
@@ -222,11 +224,8 @@ impl<M: RpcMessage + 'static> RpcClient<M> {
 
 			Ok(results)
 		} else {
-			let mut msg = "Too many failures:".to_string();
-			for e in errors {
-				msg += &format!("\n{}", e);
-			}
-			Err(Error::Message(msg))
+			let errors = errors.iter().map(|e| format!("{}", e)).collect::<Vec<_>>();
+			Err(Error::from(RPCError::TooManyErrors(errors)))
 		}
 	}
 }