send original error in ProxyGetRequest

server/src/middleware/http/proxy_get_request.rs

@@ -36,7 +36,7 @@ use hyper::header::{ACCEPT, CONTENT_TYPE};
 use hyper::http::HeaderValue;
 use hyper::{Method, Uri};
 use jsonrpsee_core::BoxError;
-use jsonrpsee_types::{Id, RequestSer};
+use jsonrpsee_types::{ErrorCode, ErrorObject, Id, RequestSer};
 use std::collections::HashMap;
 use std::future::Future;
 use std::pin::Pin;
@@ -179,16 +179,27 @@ where
 						bytes.extend(data);
 					}
 
-					#[derive(serde::Deserialize)]
-					struct RpcPayload<'a> {
+					#[derive(serde::Deserialize, serde::Serialize, Debug)]
+					struct SuccessResponse<'a> {
 						#[serde(borrow)]
 						result: &'a serde_json::value::RawValue,
 					}
 
-					let response = if let Ok(payload) = serde_json::from_slice::<RpcPayload>(&bytes) {
+					#[derive(serde::Deserialize, serde::Serialize, Debug)]
+					struct ErrorResponse<'a> {
+						#[serde(borrow)]
+						error: &'a serde_json::value::RawValue,
+					}
+
+					let response = if let Ok(payload) = serde_json::from_slice::<SuccessResponse>(&bytes) {
 						http::response::ok_response(payload.result.to_string())
 					} else {
-						http::response::internal_error()
+						serde_json::from_slice::<ErrorResponse>(&bytes)
+							.and_then(|payload| serde_json::from_str::<ErrorObject>(&payload.error.to_string()))
+							.map_or_else(
+								|_| http::response::error_response(ErrorCode::InternalError.to_string()),
+								|error| http::response::error_response(error.to_string()),
+							)
 					};
 
 					Ok(response)

server/src/transport/http.rs

@@ -18,7 +18,7 @@
 
 /// Returns true if the `content_type` header indicates a valid JSON message.
 pub fn is_json(content_type: Option<&hyper::header::HeaderValue>) -> bool {
 	content_type.and_then(|val| val.to_str().ok()).map_or(false, |content| {
 		content.eq_ignore_ascii_case("application/json")
 			|| content.eq_ignore_ascii_case("application/json; charset=utf-8")
 			|| content.eq_ignore_ascii_case("application/json;charset=utf-8")
@@ -174,6 +174,11 @@
 		from_template(hyper::StatusCode::OK, body, JSON)
 	}
 
+	/// Create a general internal error response.
+	pub fn error_response(body: impl Into<HttpBody>) -> HttpResponse {
+		from_template(hyper::StatusCode::INTERNAL_SERVER_ERROR, body, JSON)
+	}
+
 	/// Create a response for unsupported content type.
 	pub fn unsupported_content_type() -> HttpResponse {
 		from_template(

types/src/error.rs

@@ -39,7 +39,6 @@ pub type ErrorObjectOwned = ErrorObject<'static>;
 /// [Failed JSON-RPC response object](https://www.jsonrpc.org/specification#response_object).
 #[derive(Debug, Deserialize, Serialize, Clone, thiserror::Error)]
 #[serde(deny_unknown_fields)]
-#[error("{self:?}")]
 pub struct ErrorObject<'a> {
 	/// Code
 	code: ErrorCode,
@@ -96,6 +95,12 @@ impl<'a> ErrorObject<'a> {
 	}
 }
 
+impl fmt::Display for ErrorObject<'_> {
+	fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+		write!(f, "{}: {}", self.code(), self.message())
+	}
+}
+
 impl PartialEq for ErrorObject<'_> {
 	fn eq(&self, other: &Self) -> bool {
 		let this_raw = self.data.as_ref().map(|r| r.get());