diff options
Diffstat (limited to 'src/discord.rs')
| -rw-r--r-- | src/discord.rs | 68 |
1 files changed, 36 insertions, 32 deletions
diff --git a/src/discord.rs b/src/discord.rs index 0cca552..e0119a4 100644 --- a/src/discord.rs +++ b/src/discord.rs @@ -2,8 +2,7 @@ use crate::agenda::{parse_message, AgendaPoint, Emoji}; use discord::{ model::{ChannelId, Event, PossibleServer, ReactionEmoji, UserId}, - Discord, - Error, + Discord, Error, }; use futures::join; use std::{ @@ -66,26 +65,25 @@ fn receive_events(handler: &mut Handler) { Ok(Event::ServerCreate(server)) => { if let PossibleServer::Online(server) = server { if handler.channel.is_none() { - println!("Discord channels in {}: {:#?}", - server.name, - server - .channels - .iter() - .map(|channel| - format!("{}: {} ({:?})", - channel.name, - channel.id, - channel.kind)) - .collect::<Vec<_>>()); + println!( + "Discord channels in {}: {:#?}", + server.name, + server + .channels + .iter() + .map(|channel| format!( + "{}: {} ({:?})", + channel.name, channel.id, channel.kind + )) + .collect::<Vec<_>>() + ); } for member in server.members { if let Some(nick) = member.nick { handler.display_names.insert(member.user.id, nick); } } - - } - else if let PossibleServer::Offline(server) = server { + } else if let PossibleServer::Offline(server) = server { if handler.channel.is_none() { println!("Server {} is offline", server); } @@ -97,7 +95,9 @@ fn receive_events(handler: &mut Handler) { if channel == message.channel_id { match parse_message( &message.content, - if let Some(display_name) = handler.display_names.get(&message.author.id) { + if let Some(display_name) = + handler.display_names.get(&message.author.id) + { display_name } else { println!("Missing display name for '{}' (see 'Discord display names' in the readme)", @@ -105,20 +105,26 @@ fn receive_events(handler: &mut Handler) { &message.author.name }, |s: String| { - handler.client + handler + .client .lock() .unwrap() .send_message(channel, &s, "", false) .unwrap(); }, - &handler.sender + &handler.sender, ) { Some(Emoji::Ok) => { - handler.client.lock().unwrap().add_reaction( - channel, - message.id, - ReactionEmoji::Unicode("👍".to_string()) - ).unwrap(); + handler + .client + .lock() + .unwrap() + .add_reaction( + channel, + message.id, + ReactionEmoji::Unicode("👍".to_string()), + ) + .unwrap(); } _ => {} } @@ -140,18 +146,16 @@ fn receive_events(handler: &mut Handler) { async fn receive_from_slack( mut receiver: mpsc::UnboundedReceiver<AgendaPoint>, client: Arc<Mutex<discord::Discord>>, - channel: Option<ChannelId> + channel: Option<ChannelId>, ) { if let Some(channel) = channel { while let Some(point) = receiver.recv().await { println!("Discord received '{}'", point); - client.lock().unwrap().send_message( - channel, - &point.to_add_message(), - "", - false - ).unwrap(); + client + .lock() + .unwrap() + .send_message(channel, &point.to_add_message(), "", false) + .unwrap(); } } - } |
