From 54795617329866fad87d52aa36452ac53ac899b7 Mon Sep 17 00:00:00 2001
From: syn <isaqtm@gmail.com>
Date: Sat, 9 Jan 2021 01:21:51 +0300
Subject: accept errors from telegram

---
 src/client/responder.rs | 27 +++++++++++++++------------
 1 file changed, 15 insertions(+), 12 deletions(-)

(limited to 'src/client/responder.rs')

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);
         }
     }
 }
-- 
cgit v1.2.1-18-gbd029