aboutsummaryrefslogtreecommitdiff
path: root/src/client
diff options
context:
space:
mode:
authorMishio595 <[email protected]>2018-07-24 17:19:22 -0600
committerMishio595 <[email protected]>2018-07-24 17:19:22 -0600
commitcd3c3ececb24a7da4a4c99543cac5127f092a10a (patch)
treead20f6506579f47c64b8b5e06325cdd1c8f30f57 /src/client
parentFallback to default-command if passed sub-command is wrong (diff)
downloadserenity-cd3c3ececb24a7da4a4c99543cac5127f092a10a.tar.xz
serenity-cd3c3ececb24a7da4a4c99543cac5127f092a10a.zip
EventHandler::message_update with cache feature sends old message if available
Diffstat (limited to 'src/client')
-rw-r--r--src/client/dispatch.rs16
-rw-r--r--src/client/event_handler.rs7
2 files changed, 21 insertions, 2 deletions
diff --git a/src/client/dispatch.rs b/src/client/dispatch.rs
index 04bd8c9..dd5b4fe 100644
--- a/src/client/dispatch.rs
+++ b/src/client/dispatch.rs
@@ -510,13 +510,25 @@ fn handle_event<H: EventHandler + Send + Sync + 'static>(
});
},
DispatchEvent::Model(Event::MessageUpdate(mut event)) => {
- update!(event);
+ let _before = update!(event);
+
+ let _after: Option<Message> = feature_cache! {{
+ CACHE.read().message(event.channel_id, event.id)
+ } else {
+ None
+ }};
let context = context(data, runner_tx, shard_id);
let event_handler = Arc::clone(event_handler);
threadpool.execute(move || {
- event_handler.message_update(context, event);
+ feature_cache! {{
+ if let Some(after) = _after {
+ event_handler.message_update(context, _before, after);
+ }
+ } else {
+ event_handler.message_update(context, event);
+ }}
});
},
DispatchEvent::Model(Event::PresencesReplace(mut event)) => {
diff --git a/src/client/event_handler.rs b/src/client/event_handler.rs
index 32fdaa1..8100532 100644
--- a/src/client/event_handler.rs
+++ b/src/client/event_handler.rs
@@ -230,6 +230,13 @@ pub trait EventHandler {
/// Dispatched when a message is updated.
///
/// Provides the new data of the message.
+ #[cfg(feature = "cache")]
+ fn message_update(&self, _ctx: Context, _old_if_available: Option<Message>, _new: Message) {}
+
+ /// Dispatched when a message is updated.
+ ///
+ /// Provides the new data of the message.
+ #[cfg(not(feature = "cache"))]
fn message_update(&self, _ctx: Context, _new_data: MessageUpdateEvent) {}
fn presence_replace(&self, _ctx: Context, _: Vec<Presence>) {}