chore: log invalid json body

Author: SSebo

src/evaluate.rs

@@ -496,7 +496,8 @@ fn validate_toggle(_toggle: &Toggle) -> Result<(), FPError> {
 
 #[allow(dead_code)]
 pub fn load_json(json_str: &str) -> Result<Repository, FPError> {
-    let repo = serde_json::from_str::<Repository>(json_str).map_err(FPError::JsonError);
+    let repo = serde_json::from_str::<Repository>(json_str)
+        .map_err(|e| FPError::JsonError(json_str.to_owned(), e));
     if let Ok(repo) = &repo {
         for t in repo.toggles.values() {
             validate_toggle(t)?
@@ -1116,7 +1117,8 @@ mod condition_tests {
         }
         "#;
 
-        let segment = serde_json::from_str::<Condition>(json_str).map_err(FPError::JsonError);
+        let segment = serde_json::from_str::<Condition>(json_str)
+            .map_err(|e| FPError::JsonError(json_str.to_owned(), e));
         assert!(segment.is_ok())
     }
 

src/feature_probe.rs

@@ -350,7 +350,8 @@ mod server_sdk_contract_tests {
 
     #[allow(dead_code)]
     pub(crate) fn load_tests_json(json_str: &str) -> Result<Tests, FPError> {
-        serde_json::from_str::<Tests>(json_str).map_err(FPError::JsonError)
+        serde_json::from_str::<Tests>(json_str)
+            .map_err(|e| FPError::JsonError(json_str.to_owned(), e))
     }
 
     #[derive(Serialize, Deserialize, Debug, Default, PartialEq)]

src/lib.rs

@@ -35,8 +35,8 @@ pub struct FPDetail<T: Default + Debug> {
 #[non_exhaustive]
 #[derive(Debug, Error)]
 pub enum FPError {
-    #[error("invalid json: {0}")]
-    JsonError(#[from] serde_json::Error),
+    #[error("invalid json: {0} error: {1}")]
+    JsonError(String, serde_json::Error),
     #[error("invalid url: {0}")]
     UrlError(String),
     #[error("http error: {0}")]

src/sync.rs

@@ -176,7 +176,7 @@ impl Inner {
             Ok(resp) => match resp.text().await {
                 Err(e) => Err(FPError::HttpError(e.to_string())),
                 Ok(body) => match serde_json::from_str::<Repository>(&body) {
-                    Err(e) => Err(FPError::JsonError(e)),
+                    Err(e) => Err(FPError::JsonError(body, e)),
                     Ok(r) => {
                         // TODO: validate repo
                         // TODO: diff change, notify subscriber
@@ -216,7 +216,7 @@ impl Inner {
                 Err(e) => Err(FPError::HttpError(e.to_string())),
                 Ok(body) => {
                     match serde_json::from_str::<Repository>(&body) {
-                        Err(e) => Err(FPError::JsonError(e)),
+                        Err(e) => Err(FPError::JsonError(body, e)),
                         Ok(r) => {
                             // TODO: validate repo
                             debug!("sync success {:?}", r);