tenquestionmarks/src/plugins/discord.rs

use discord;
use discord::Discord;
use discord::model::Event;

use plugins::Plugin;
use toml::Table;

use event;
use std::sync::mpsc::Sender;

use User;
use Channel;

use std::collections::BTreeMap;

pub struct DiscordPlugin {
    token: String
}

impl DiscordPlugin {
    pub fn new (configuration: &Table) -> Box<Plugin> {
        let token = configuration.get("token")
                                 .and_then(|value| value.as_str())
                                 .unwrap_or("");

        Box::new(DiscordPlugin {
            token: String::from(token)
        })
    }
}

impl Plugin for DiscordPlugin {
    fn produce_events<'a>(&'a self, sender: Sender<event::Event>) {
        let discord = Discord::from_bot_token(&self.token[..]).expect("Login failed");
        let (mut connection, _) = discord.connect().expect("Connection failed");
        loop {
            match connection.recv_event() {
                Ok(Event::MessageCreate(message)) => {
                    let author = User {
                        name: message.author.name,
                        send_function: &(|user: &User, message: &str| {
                            println!("Send to {:?}: {:?}", user.name, message);
                        })
                    };

                    let channel = Channel {
                        name: String::from("channel"),
                        description: String::from(""),
                        topic: String::from(""),
                        send_function: &(|channel: &Channel, message: &str| {
                            println!("Send to {:?}: {:?}", channel.name, message);
                        })
                    };

                    sender.send(event::Event::Message { sender: author, content: message.content, channel: Option::Some(channel) });
                }
    			Ok(_) => {}
    			Err(discord::Error::Closed(code, body)) => {
	                println!("Gateway closed on us with code {:?}: {}", code, body);
    				break
    			}
    			Err(err) => println!("Receive error: {:?}", err)
            }
        }
    }
}