use super::super::payload::*;
use super::EventType;
use serde::{
de::{Deserialize, DeserializeSeed, Deserializer, Error as DeError, IgnoredAny},
Serialize,
};
#[derive(Clone, Debug, Eq, PartialEq, Serialize)]
pub enum DispatchEvent {
BanAdd(BanAdd),
BanRemove(BanRemove),
ChannelCreate(ChannelCreate),
ChannelDelete(ChannelDelete),
ChannelPinsUpdate(ChannelPinsUpdate),
ChannelUpdate(ChannelUpdate),
GiftCodeUpdate,
GuildCreate(Box<GuildCreate>),
GuildDelete(Box<GuildDelete>),
GuildEmojisUpdate(GuildEmojisUpdate),
GuildIntegrationsUpdate(GuildIntegrationsUpdate),
GuildUpdate(Box<GuildUpdate>),
InviteCreate(Box<InviteCreate>),
InviteDelete(InviteDelete),
MemberAdd(Box<MemberAdd>),
MemberRemove(MemberRemove),
MemberUpdate(Box<MemberUpdate>),
MemberChunk(MemberChunk),
MessageCreate(Box<MessageCreate>),
MessageDelete(MessageDelete),
MessageDeleteBulk(MessageDeleteBulk),
MessageUpdate(Box<MessageUpdate>),
PresenceUpdate(Box<PresenceUpdate>),
PresencesReplace,
ReactionAdd(Box<ReactionAdd>),
ReactionRemove(Box<ReactionRemove>),
ReactionRemoveAll(ReactionRemoveAll),
ReactionRemoveEmoji(ReactionRemoveEmoji),
Ready(Box<Ready>),
Resumed,
RoleCreate(RoleCreate),
RoleDelete(RoleDelete),
RoleUpdate(RoleUpdate),
TypingStart(Box<TypingStart>),
UnavailableGuild(UnavailableGuild),
UserUpdate(UserUpdate),
VoiceServerUpdate(VoiceServerUpdate),
VoiceStateUpdate(Box<VoiceStateUpdate>),
WebhooksUpdate(WebhooksUpdate),
}
impl DispatchEvent {
pub fn kind(&self) -> EventType {
match self {
Self::BanAdd(_) => EventType::BanAdd,
Self::BanRemove(_) => EventType::BanRemove,
Self::ChannelCreate(_) => EventType::ChannelCreate,
Self::ChannelDelete(_) => EventType::ChannelDelete,
Self::ChannelPinsUpdate(_) => EventType::ChannelPinsUpdate,
Self::ChannelUpdate(_) => EventType::ChannelUpdate,
Self::GiftCodeUpdate => EventType::GiftCodeUpdate,
Self::GuildCreate(_) => EventType::GuildCreate,
Self::GuildDelete(_) => EventType::GuildDelete,
Self::GuildEmojisUpdate(_) => EventType::GuildEmojisUpdate,
Self::GuildIntegrationsUpdate(_) => EventType::GuildIntegrationsUpdate,
Self::GuildUpdate(_) => EventType::GuildUpdate,
Self::InviteCreate(_) => EventType::InviteCreate,
Self::InviteDelete(_) => EventType::InviteDelete,
Self::MemberAdd(_) => EventType::MemberAdd,
Self::MemberRemove(_) => EventType::MemberRemove,
Self::MemberUpdate(_) => EventType::MemberUpdate,
Self::MemberChunk(_) => EventType::MemberChunk,
Self::MessageCreate(_) => EventType::MessageCreate,
Self::MessageDelete(_) => EventType::MessageDelete,
Self::MessageDeleteBulk(_) => EventType::MessageDeleteBulk,
Self::MessageUpdate(_) => EventType::MessageUpdate,
Self::PresenceUpdate(_) => EventType::PresenceUpdate,
Self::PresencesReplace => EventType::PresencesReplace,
Self::ReactionAdd(_) => EventType::ReactionAdd,
Self::ReactionRemove(_) => EventType::ReactionRemove,
Self::ReactionRemoveAll(_) => EventType::ReactionRemoveAll,
Self::ReactionRemoveEmoji(_) => EventType::ReactionRemoveEmoji,
Self::Ready(_) => EventType::Ready,
Self::Resumed => EventType::Resumed,
Self::RoleCreate(_) => EventType::RoleCreate,
Self::RoleDelete(_) => EventType::RoleDelete,
Self::RoleUpdate(_) => EventType::RoleUpdate,
Self::TypingStart(_) => EventType::TypingStart,
Self::UnavailableGuild(_) => EventType::UnavailableGuild,
Self::UserUpdate(_) => EventType::UserUpdate,
Self::VoiceServerUpdate(_) => EventType::VoiceServerUpdate,
Self::VoiceStateUpdate(_) => EventType::VoiceStateUpdate,
Self::WebhooksUpdate(_) => EventType::WebhooksUpdate,
}
}
}
#[derive(PartialEq, Eq)]
pub struct DispatchEventWithTypeDeserializer<'a>(&'a str);
impl<'a> DispatchEventWithTypeDeserializer<'a> {
pub fn new(event_name: &'a str) -> Self {
Self(event_name)
}
}
impl<'de, 'a> DeserializeSeed<'de> for DispatchEventWithTypeDeserializer<'a> {
type Value = DispatchEvent;
#[allow(clippy::too_many_lines)]
fn deserialize<D: Deserializer<'de>>(self, deserializer: D) -> Result<Self::Value, D::Error> {
Ok(match self.0 {
"CHANNEL_CREATE" => {
DispatchEvent::ChannelCreate(ChannelCreate::deserialize(deserializer)?)
}
"CHANNEL_DELETE" => {
DispatchEvent::ChannelDelete(ChannelDelete::deserialize(deserializer)?)
}
"CHANNEL_PINS_UPDATE" => {
DispatchEvent::ChannelPinsUpdate(ChannelPinsUpdate::deserialize(deserializer)?)
}
"CHANNEL_UPDATE" => {
DispatchEvent::ChannelUpdate(ChannelUpdate::deserialize(deserializer)?)
}
"GUILD_BAN_ADD" => DispatchEvent::BanAdd(BanAdd::deserialize(deserializer)?),
"GUILD_BAN_REMOVE" => DispatchEvent::BanRemove(BanRemove::deserialize(deserializer)?),
"GUILD_CREATE" => {
DispatchEvent::GuildCreate(Box::new(GuildCreate::deserialize(deserializer)?))
}
"GUILD_DELETE" => {
DispatchEvent::GuildDelete(Box::new(GuildDelete::deserialize(deserializer)?))
}
"GUILD_EMOJIS_UPDATE" => {
DispatchEvent::GuildEmojisUpdate(GuildEmojisUpdate::deserialize(deserializer)?)
}
"GUILD_INTEGRATIONS_UPDATE" => DispatchEvent::GuildIntegrationsUpdate(
GuildIntegrationsUpdate::deserialize(deserializer)?,
),
"GUILD_MEMBERS_CHUNK" => {
DispatchEvent::MemberChunk(MemberChunk::deserialize(deserializer)?)
}
"GUILD_MEMBER_ADD" => {
DispatchEvent::MemberAdd(Box::new(MemberAdd::deserialize(deserializer)?))
}
"GUILD_MEMBER_REMOVE" => {
DispatchEvent::MemberRemove(MemberRemove::deserialize(deserializer)?)
}
"GUILD_MEMBER_UPDATE" => {
DispatchEvent::MemberUpdate(Box::new(MemberUpdate::deserialize(deserializer)?))
}
"GUILD_ROLE_CREATE" => {
DispatchEvent::RoleCreate(RoleCreate::deserialize(deserializer)?)
}
"GUILD_ROLE_DELETE" => {
DispatchEvent::RoleDelete(RoleDelete::deserialize(deserializer)?)
}
"GUILD_ROLE_UPDATE" => {
DispatchEvent::RoleUpdate(RoleUpdate::deserialize(deserializer)?)
}
"GUILD_UPDATE" => {
DispatchEvent::GuildUpdate(Box::new(GuildUpdate::deserialize(deserializer)?))
}
"INVITE_CREATE" => {
DispatchEvent::InviteCreate(Box::new(InviteCreate::deserialize(deserializer)?))
}
"INVITE_DELETE" => {
DispatchEvent::InviteDelete(InviteDelete::deserialize(deserializer)?)
}
"MESSAGE_CREATE" => {
DispatchEvent::MessageCreate(Box::new(MessageCreate::deserialize(deserializer)?))
}
"MESSAGE_DELETE" => {
DispatchEvent::MessageDelete(MessageDelete::deserialize(deserializer)?)
}
"MESSAGE_DELETE_BULK" => {
DispatchEvent::MessageDeleteBulk(MessageDeleteBulk::deserialize(deserializer)?)
}
"MESSAGE_REACTION_ADD" => {
DispatchEvent::ReactionAdd(Box::new(ReactionAdd::deserialize(deserializer)?))
}
"MESSAGE_REACTION_REMOVE" => {
DispatchEvent::ReactionRemove(Box::new(ReactionRemove::deserialize(deserializer)?))
}
"MESSAGE_REACTION_REMOVE_EMOJI" => {
DispatchEvent::ReactionRemoveEmoji(ReactionRemoveEmoji::deserialize(deserializer)?)
}
"MESSAGE_REACTION_REMOVE_ALL" => {
DispatchEvent::ReactionRemoveAll(ReactionRemoveAll::deserialize(deserializer)?)
}
"MESSAGE_UPDATE" => {
DispatchEvent::MessageUpdate(Box::new(MessageUpdate::deserialize(deserializer)?))
}
"PRESENCE_UPDATE" => {
DispatchEvent::PresenceUpdate(Box::new(PresenceUpdate::deserialize(deserializer)?))
}
"PRESENCES_REPLACE" => {
deserializer.deserialize_ignored_any(IgnoredAny)?;
DispatchEvent::PresencesReplace
}
"READY" => DispatchEvent::Ready(Box::new(Ready::deserialize(deserializer)?)),
"RESUMED" => {
deserializer.deserialize_ignored_any(IgnoredAny)?;
DispatchEvent::Resumed
}
"TYPING_START" => {
DispatchEvent::TypingStart(Box::new(TypingStart::deserialize(deserializer)?))
}
"USER_UPDATE" => DispatchEvent::UserUpdate(UserUpdate::deserialize(deserializer)?),
"VOICE_SERVER_UPDATE" => {
DispatchEvent::VoiceServerUpdate(VoiceServerUpdate::deserialize(deserializer)?)
}
"VOICE_STATE_UPDATE" => DispatchEvent::VoiceStateUpdate(Box::new(
VoiceStateUpdate::deserialize(deserializer)?,
)),
"WEBHOOKS_UPDATE" => {
DispatchEvent::WebhooksUpdate(WebhooksUpdate::deserialize(deserializer)?)
}
other => return Err(DeError::unknown_variant(other, &[])),
})
}
}