accept errors from telegram

1 files changed, 15 insertions, 12 deletions

diff --git a/src/client/responder.rs b/src/client/responder.rs
index 6f5dd53..f501102 100644
--- a/src/client/responder.rs
+++ b/src/client/responder.rs
@@ -5,7 +5,7 @@ use crate::{raw_ptr::TdPtr, Handler};
 
 use super::{JoinStreams, SafeResponse};
 use crossbeam::channel::{Receiver, Sender};
-use log::{error, trace, warn};
+use log::{error, info, trace, warn};
 use serde_json::Value as JsonValue;
 
 /// Oneshot means it forgets any information about particular request
@@ -120,16 +120,20 @@ impl<H: Handler> OneshotResponder<H> {
         if let Some(id) = resp["@extra"].as_u64() {
             if let Some(fut) = self.wakers_map.remove(&id) {
                 let mut fut_data = fut.lock().unwrap();
-                fut_data.resp = Some(Ok(resp));
+                use crate::error::Error;
+                let err = match serde_json::from_value(resp) {
+                    Ok(tg_err) => Error::TelegramError(tg_err),
+                    Err(serde_err) => Error::Serde(serde_err),
+                };
+                fut_data.resp = Some(Err(err));
                 fut_data.waker.as_ref().map(Waker::wake_by_ref);
             } else {
-                warn!(
-                    "response received, but request was not issued by any future: {}",
-                    resp
-                );
+                warn!("response received, but request was not issued by any future");
+                info!("response was: {}", resp);
             }
         } else {
-            warn!("response has invalid @extra: {}", resp);
+            warn!("response has invalid @extra: {:?}", resp["extra"]);
+            info!("full response was: {}", resp);
         }
     }
 
@@ -140,13 +144,12 @@ impl<H: Handler> OneshotResponder<H> {
                 fut_data.resp = Some(Ok(resp));
                 fut_data.waker.as_ref().map(Waker::wake_by_ref);
             } else {
-                warn!(
-                    "response received, but request was not issued by any future: {}",
-                    resp
-                );
+                warn!("response received, but request was not issued by any future");
+                info!("response was: {}", resp);
             }
         } else {
-            warn!("response has invalid @extra: {}", resp);
+            warn!("response has invalid @extra: {:?}", resp["extra"]);
+            info!("full response was: {}", resp);
         }
     }
 }