feat: use serde_path_to_error

Author: joe-p

Cargo.lock

@@ -100,7 +100,7 @@ pub async fn {{ operation.rust_function_name }}(
         match content_type {
             ContentType::Json => {
                 let content = resp.text().await?;
-                serde_json::from_str(&content).map_err(Error::from)
+                serde_path_to_error::deserialize(&mut serde_json::Deserializer::from_str(&content)).map_err(Error::from)
             },
             ContentType::Text => Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `{{ get_success_response_type(operation) }}`"))),
             ContentType::Unsupported(unknown_type) => Err(Error::from(serde_json::Error::custom(format!("Received `{unknown_type}` content type response that cannot be converted to `{{ get_success_response_type(operation) }}`")))),

api/oas_generator/rust_oas_generator/templates/apis/api.rs.j2

@@ -208,9 +208,9 @@ pub async fn {{ operation.rust_function_name }}(
         .unwrap_or("application/json");
 
     match ContentType::from(content_type) {
-        ContentType::Json => serde_json::from_slice(&response.body).map_err(|e| Error::Serde { message: e.to_string() }),
+        ContentType::Json => serde_path_to_error::deserialize(&mut serde_json::Deserializer::from_slice(&response.body)).map_err(|e| Error::Serde { message: e.to_string() }),
         {% if operation.supports_msgpack %}
-        ContentType::MsgPack => rmp_serde::from_slice(&response.body).map_err(|e| Error::Serde { message: e.to_string() }),
+        ContentType::MsgPack => serde_path_to_error::deserialize(&mut rmp_serde::Deserializer::new(std::io::Cursor::new(&response.body))).map_err(|e| Error::Serde { message: e.to_string() }),
         {% else %}
         ContentType::MsgPack => Err(Error::Serde { message: "MsgPack not supported".to_string() }),
         {% endif %}

api/oas_generator/rust_oas_generator/templates/apis/endpoint.rs.j2

@@ -20,6 +20,7 @@ serde_with = { version = "^3.8", default-features = false, features = [
   "macros",
 ] }
 serde_json = "^1.0"
+serde_path_to_error = "^0.1"
 serde_repr = "^0.1"
 serde_bytes = "^0.11"
 

api/oas_generator/rust_oas_generator/templates/base/Cargo.toml.j2

@@ -20,6 +20,7 @@ serde_with = { version = "^3.8", default-features = false, features = [
   "macros",
 ] }
 serde_json = "^1.0"
+serde_path_to_error = "^0.1"
 serde_repr = "^0.1"
 serde_bytes = "^0.11"
 

crates/algod_client/Cargo.toml

@@ -69,7 +69,10 @@ pub async fn abort_catchup(
         .unwrap_or("application/json");
 
     match ContentType::from(content_type) {
-        ContentType::Json => serde_json::from_slice(&response.body).map_err(|e| Error::Serde {
+        ContentType::Json => serde_path_to_error::deserialize(
+            &mut serde_json::Deserializer::from_slice(&response.body),
+        )
+        .map_err(|e| Error::Serde {
             message: e.to_string(),
         }),
         ContentType::MsgPack => Err(Error::Serde {

crates/algod_client/src/apis/abort_catchup.rs

@@ -85,10 +85,16 @@ pub async fn account_application_information(
         .unwrap_or("application/json");
 
     match ContentType::from(content_type) {
-        ContentType::Json => serde_json::from_slice(&response.body).map_err(|e| Error::Serde {
+        ContentType::Json => serde_path_to_error::deserialize(
+            &mut serde_json::Deserializer::from_slice(&response.body),
+        )
+        .map_err(|e| Error::Serde {
             message: e.to_string(),
         }),
-        ContentType::MsgPack => rmp_serde::from_slice(&response.body).map_err(|e| Error::Serde {
+        ContentType::MsgPack => serde_path_to_error::deserialize(
+            &mut rmp_serde::Deserializer::new(std::io::Cursor::new(&response.body)),
+        )
+        .map_err(|e| Error::Serde {
             message: e.to_string(),
         }),
         ContentType::Text => {

crates/algod_client/src/apis/account_application_information.rs

@@ -72,7 +72,10 @@ pub async fn account_asset_information(
         .unwrap_or("application/json");
 
     match ContentType::from(content_type) {
-        ContentType::Json => serde_json::from_slice(&response.body).map_err(|e| Error::Serde {
+        ContentType::Json => serde_path_to_error::deserialize(
+            &mut serde_json::Deserializer::from_slice(&response.body),
+        )
+        .map_err(|e| Error::Serde {
             message: e.to_string(),
         }),
         ContentType::MsgPack => Err(Error::Serde {

crates/algod_client/src/apis/account_asset_information.rs

@@ -79,7 +79,10 @@ pub async fn account_assets_information(
         .unwrap_or("application/json");
 
     match ContentType::from(content_type) {
-        ContentType::Json => serde_json::from_slice(&response.body).map_err(|e| Error::Serde {
+        ContentType::Json => serde_path_to_error::deserialize(
+            &mut serde_json::Deserializer::from_slice(&response.body),
+        )
+        .map_err(|e| Error::Serde {
             message: e.to_string(),
         }),
         ContentType::MsgPack => Err(Error::Serde {

crates/algod_client/src/apis/account_assets_information.rs

@@ -75,7 +75,10 @@ pub async fn account_information(
         .unwrap_or("application/json");
 
     match ContentType::from(content_type) {
-        ContentType::Json => serde_json::from_slice(&response.body).map_err(|e| Error::Serde {
+        ContentType::Json => serde_path_to_error::deserialize(
+            &mut serde_json::Deserializer::from_slice(&response.body),
+        )
+        .map_err(|e| Error::Serde {
             message: e.to_string(),
         }),
         ContentType::MsgPack => Err(Error::Serde {