diff options
| author | Zeyla Hellyer <[email protected]> | 2017-08-18 16:14:32 -0700 |
|---|---|---|
| committer | Zeyla Hellyer <[email protected]> | 2017-08-18 17:52:53 -0700 |
| commit | e4113570967a1fb13539efbfa2cf7285b19d95ba (patch) | |
| tree | 06bb020fcfaa5f8323454dfb525272314a900186 /src/cache | |
| parent | Move Clippy lints to a cfg_attr (diff) | |
| download | serenity-e4113570967a1fb13539efbfa2cf7285b19d95ba.tar.xz serenity-e4113570967a1fb13539efbfa2cf7285b19d95ba.zip | |
Apply rustfmt
Diffstat (limited to 'src/cache')
| -rw-r--r-- | src/cache/cache_events_impl.rs | 159 | ||||
| -rw-r--r-- | src/cache/mod.rs | 6 |
2 files changed, 73 insertions, 92 deletions
diff --git a/src/cache/cache_events_impl.rs b/src/cache/cache_events_impl.rs index 7424add..cbf0e77 100644 --- a/src/cache/cache_events_impl.rs +++ b/src/cache/cache_events_impl.rs @@ -7,51 +7,39 @@ use model::*; use model::event::*; pub(crate) trait CacheEventsImpl { - fn update_with_channel_create(&mut self, - event: &ChannelCreateEvent) - -> Option<Channel>; + fn update_with_channel_create(&mut self, event: &ChannelCreateEvent) -> Option<Channel>; fn update_with_channel_delete(&mut self, event: &ChannelDeleteEvent); fn update_with_channel_pins_update(&mut self, event: &ChannelPinsUpdateEvent); - fn update_with_channel_recipient_add(&mut self, - event: &mut ChannelRecipientAddEvent); + fn update_with_channel_recipient_add(&mut self, event: &mut ChannelRecipientAddEvent); - fn update_with_channel_recipient_remove(&mut self, - event: &ChannelRecipientRemoveEvent); + fn update_with_channel_recipient_remove(&mut self, event: &ChannelRecipientRemoveEvent); fn update_with_channel_update(&mut self, event: &ChannelUpdateEvent); fn update_with_guild_create(&mut self, event: &GuildCreateEvent); - fn update_with_guild_delete(&mut self, - event: &GuildDeleteEvent) - -> Option<Arc<RwLock<Guild>>>; + fn update_with_guild_delete(&mut self, event: &GuildDeleteEvent) -> Option<Arc<RwLock<Guild>>>; fn update_with_guild_emojis_update(&mut self, event: &GuildEmojisUpdateEvent); fn update_with_guild_member_add(&mut self, event: &mut GuildMemberAddEvent); - fn update_with_guild_member_remove(&mut self, - event: &GuildMemberRemoveEvent) - -> Option<Member>; + fn update_with_guild_member_remove(&mut self, event: &GuildMemberRemoveEvent) + -> Option<Member>; - fn update_with_guild_member_update(&mut self, - event: &GuildMemberUpdateEvent) - -> Option<Member>; + fn update_with_guild_member_update(&mut self, event: &GuildMemberUpdateEvent) + -> Option<Member>; fn update_with_guild_members_chunk(&mut self, event: &GuildMembersChunkEvent); fn update_with_guild_role_create(&mut self, event: &GuildRoleCreateEvent); - fn update_with_guild_role_delete(&mut self, - event: &GuildRoleDeleteEvent) - -> Option<Role>; + fn update_with_guild_role_delete(&mut self, event: &GuildRoleDeleteEvent) -> Option<Role>; - fn update_with_guild_role_update(&mut self, - event: &GuildRoleUpdateEvent) - -> Option<Role>; + fn update_with_guild_role_update(&mut self, event: &GuildRoleUpdateEvent) -> Option<Role>; fn update_with_guild_unavailable(&mut self, event: &GuildUnavailableEvent); @@ -69,9 +57,7 @@ pub(crate) trait CacheEventsImpl { } impl CacheEventsImpl for super::Cache { - fn update_with_channel_create(&mut self, - event: &ChannelCreateEvent) - -> Option<Channel> { + fn update_with_channel_create(&mut self, event: &ChannelCreateEvent) -> Option<Channel> { match event.channel { Channel::Group(ref group) => { let group = group.clone(); @@ -104,11 +90,10 @@ impl CacheEventsImpl for super::Cache { self.guilds .get_mut(&guild_id) .and_then(|guild| { - guild - .write() - .unwrap() - .channels - .insert(channel_id, channel.clone()) + guild.write().unwrap().channels.insert( + channel_id, + channel.clone(), + ) }) .map(Channel::Guild) }, @@ -131,8 +116,10 @@ impl CacheEventsImpl for super::Cache { channel_writer.recipient = self.users[&user_id].clone(); - let ch = self.private_channels - .insert(channel_writer.id, channel.clone()); + let ch = self.private_channels.insert( + channel_writer.id, + channel.clone(), + ); ch.map(Channel::Private) }, } @@ -141,9 +128,11 @@ impl CacheEventsImpl for super::Cache { fn update_with_channel_delete(&mut self, event: &ChannelDeleteEvent) { let channel = match event.channel { Channel::Guild(ref channel) => channel, - // We ignore these two due to the fact that the delete event for dms/groups will _not_ fire + // We ignore these two due to the fact that the delete event for dms/groups + // will _not_ fire // anymore. - Channel::Private(_) | Channel::Group(_) => unreachable!(), + Channel::Private(_) | + Channel::Group(_) => unreachable!(), }; let (channel_id, guild_id) = { @@ -154,9 +143,9 @@ impl CacheEventsImpl for super::Cache { self.channels.remove(&channel_id); - self.guilds - .get_mut(&guild_id) - .and_then(|guild| guild.write().unwrap().channels.remove(&channel_id)); + self.guilds.get_mut(&guild_id).and_then(|guild| { + guild.write().unwrap().channels.remove(&channel_id) + }); } #[allow(dead_code)] @@ -180,22 +169,19 @@ impl CacheEventsImpl for super::Cache { } } - fn update_with_channel_recipient_add(&mut self, - event: &mut ChannelRecipientAddEvent) { + fn update_with_channel_recipient_add(&mut self, event: &mut ChannelRecipientAddEvent) { self.update_user_entry(&event.user); let user = self.users[&event.user.id].clone(); self.groups.get_mut(&event.channel_id).map(|group| { - group - .write() - .unwrap() - .recipients - .insert(event.user.id, user); + group.write().unwrap().recipients.insert( + event.user.id, + user, + ); }); } - fn update_with_channel_recipient_remove(&mut self, - event: &ChannelRecipientRemoveEvent) { + fn update_with_channel_recipient_remove(&mut self, event: &ChannelRecipientRemoveEvent) { self.groups.get_mut(&event.channel_id).map(|group| { group.write().unwrap().recipients.remove(&event.user.id) }); @@ -238,11 +224,10 @@ impl CacheEventsImpl for super::Cache { self.channels.insert(channel_id, channel.clone()); self.guilds.get_mut(&guild_id).map(|guild| { - guild - .write() - .unwrap() - .channels - .insert(channel_id, channel.clone()) + guild.write().unwrap().channels.insert( + channel_id, + channel.clone(), + ) }); }, Channel::Private(ref channel) => { @@ -266,13 +251,13 @@ impl CacheEventsImpl for super::Cache { } self.channels.extend(guild.channels.clone()); - self.guilds - .insert(event.guild.id, Arc::new(RwLock::new(guild))); + self.guilds.insert( + event.guild.id, + Arc::new(RwLock::new(guild)), + ); } - fn update_with_guild_delete(&mut self, - event: &GuildDeleteEvent) - -> Option<Arc<RwLock<Guild>>> { + fn update_with_guild_delete(&mut self, event: &GuildDeleteEvent) -> Option<Arc<RwLock<Guild>>> { // Remove channel entries for the guild if the guild is found. self.guilds.remove(&event.guild.id).map(|guild| { for channel_id in guild.read().unwrap().channels.keys() { @@ -305,8 +290,8 @@ impl CacheEventsImpl for super::Cache { } fn update_with_guild_member_remove(&mut self, - event: &GuildMemberRemoveEvent) - -> Option<Member> { + event: &GuildMemberRemoveEvent) + -> Option<Member> { self.guilds.get_mut(&event.guild_id).and_then(|guild| { let mut guild = guild.write().unwrap(); @@ -316,8 +301,8 @@ impl CacheEventsImpl for super::Cache { } fn update_with_guild_member_update(&mut self, - event: &GuildMemberUpdateEvent) - -> Option<Member> { + event: &GuildMemberUpdateEvent) + -> Option<Member> { self.update_user_entry(&event.user); if let Some(guild) = self.guilds.get_mut(&event.guild_id) { @@ -372,32 +357,24 @@ impl CacheEventsImpl for super::Cache { fn update_with_guild_role_create(&mut self, event: &GuildRoleCreateEvent) { self.guilds.get_mut(&event.guild_id).map(|guild| { - guild - .write() - .unwrap() - .roles - .insert(event.role.id, event.role.clone()) + guild.write().unwrap().roles.insert( + event.role.id, + event.role.clone(), + ) }); } - fn update_with_guild_role_delete(&mut self, - event: &GuildRoleDeleteEvent) - -> Option<Role> { - self.guilds - .get_mut(&event.guild_id) - .and_then(|guild| guild.write().unwrap().roles.remove(&event.role_id)) + fn update_with_guild_role_delete(&mut self, event: &GuildRoleDeleteEvent) -> Option<Role> { + self.guilds.get_mut(&event.guild_id).and_then(|guild| { + guild.write().unwrap().roles.remove(&event.role_id) + }) } - fn update_with_guild_role_update(&mut self, - event: &GuildRoleUpdateEvent) - -> Option<Role> { + fn update_with_guild_role_update(&mut self, event: &GuildRoleUpdateEvent) -> Option<Role> { self.guilds.get_mut(&event.guild_id).and_then(|guild| { - guild - .write() - .unwrap() - .roles - .get_mut(&event.role.id) - .map(|role| mem::replace(role, event.role.clone())) + guild.write().unwrap().roles.get_mut(&event.role.id).map( + |role| mem::replace(role, event.role.clone()), + ) }) } @@ -449,16 +426,19 @@ impl CacheEventsImpl for super::Cache { if event.presence.status == OnlineStatus::Offline { guild.presences.remove(&event.presence.user_id); } else { - guild - .presences - .insert(event.presence.user_id, event.presence.clone()); + guild.presences.insert( + event.presence.user_id, + event.presence.clone(), + ); } } } else if event.presence.status == OnlineStatus::Offline { self.presences.remove(&event.presence.user_id); } else { - self.presences - .insert(event.presence.user_id, event.presence.clone()); + self.presences.insert( + event.presence.user_id, + event.presence.clone(), + ); } } @@ -516,9 +496,10 @@ impl CacheEventsImpl for super::Cache { } } - guild - .voice_states - .insert(event.voice_state.user_id, event.voice_state.clone()); + guild.voice_states.insert( + event.voice_state.user_id, + event.voice_state.clone(), + ); } else { // Remove the user from the voice state list guild.voice_states.remove(&event.voice_state.user_id); @@ -528,4 +509,4 @@ impl CacheEventsImpl for super::Cache { return; } } -}
\ No newline at end of file +} diff --git a/src/cache/mod.rs b/src/cache/mod.rs index 19089ee..68a78a7 100644 --- a/src/cache/mod.rs +++ b/src/cache/mod.rs @@ -553,9 +553,9 @@ impl Cache { /// ``` pub fn role<G, R>(&self, guild_id: G, role_id: R) -> Option<Role> where G: Into<GuildId>, R: Into<RoleId> { - self.guilds - .get(&guild_id.into()) - .and_then(|g| g.read().unwrap().roles.get(&role_id.into()).cloned()) + self.guilds.get(&guild_id.into()).and_then(|g| { + g.read().unwrap().roles.get(&role_id.into()).cloned() + }) } /// Retrieves a `User` from the cache's [`users`] map, if it exists. |