OpenSource/teloxide
OpenSource/teloxide
1
0
Fork 0
mirror of https://github.com/teloxide/teloxide.git synced 2025-03-24 23:57:38 +01:00
Code Issues Projects Releases Packages Wiki Activity

Trace previous state on update

Browse source
This commit is contained in:
ivan770 2020-11-18 09:56:57 +02:00
parent 5830ba2b32
commit f86217b0f9
No known key found for this signature in database
GPG key ID: D8C4BD5AE4D9CC4D
1 changed files with 10 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
src/dispatching/dialogue/storage/trace_storage.rs
View file

@ -1,9 +1,9 @@
use std::{fmt::Debug, sync::Arc}; use std::{fmt::Debug, marker::{Send, Sync}, sync::Arc};
use futures::future::BoxFuture; use futures::future::BoxFuture;
use log::trace; use log::trace;
use super::Storage; use crate::dispatching::dialogue::Storage;
/// Storage wrapper for logging purposes /// Storage wrapper for logging purposes
/// ///
@ -26,7 +26,7 @@ impl<S> TraceStorage<S> {
impl<S, D> Storage<D> for TraceStorage<S> impl<S, D> Storage<D> for TraceStorage<S>
where where
D: Debug, D: Debug,
S: Storage<D>, S: Storage<D> + Send + Sync + 'static,
{ {
type Error = <S as Storage<D>>::Error; type Error = <S as Storage<D>>::Error;
@ -49,7 +49,12 @@ where
where where
D: Send + 'static, D: Send + 'static,
{ {
trace!("Updating dialogue with {}: {:#?}", chat_id, dialogue); Box::pin(async move {
<S as Storage<D>>::update_dialogue(self.inner.clone(), chat_id, dialogue) trace!("Updating dialogue with {}: {:#?}", chat_id, dialogue);
let from =
<S as Storage<D>>::update_dialogue(self.inner.clone(), chat_id, dialogue).await?;
trace!("Updated dialogue with {}, previous state: {:#?}", chat_id, from);
Ok(from)
})
} }
} }