diff options
| author | Mishio595 <[email protected]> | 2018-07-24 17:19:22 -0600 |
|---|---|---|
| committer | Mishio595 <[email protected]> | 2018-07-24 17:19:22 -0600 |
| commit | cd3c3ececb24a7da4a4c99543cac5127f092a10a (patch) | |
| tree | ad20f6506579f47c64b8b5e06325cdd1c8f30f57 /src/client | |
| parent | Fallback to default-command if passed sub-command is wrong (diff) | |
| download | serenity-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.rs | 16 | ||||
| -rw-r--r-- | src/client/event_handler.rs | 7 |
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>) {} |