tenquestionmarks/src/modules/stdin.rs

use std::io;

use modules::Module;
use toml::Table;

use User;
use MessageSender;

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

pub struct StdinModule {}

pub struct StdinMessageSender {
    name: String
}

impl MessageSender for StdinMessageSender {
    fn send_message (&self, message: &str) {
        debug!("Send message to stdout: {:?}", message);
        println!("{}: {}", self.name, message);
    }
}

impl StdinModule {
    pub fn new (configuration: &Table) -> Box<Module> {
        Box::new(StdinModule {})
    }
}

impl Module for StdinModule {
    fn produce_events<'a>(&'a self, sender: Sender<Event>) {
        let user = User {
            name: String::from("Dave"),
            sender: Arc::new(StdinMessageSender {
                name: String::from("Dave")
            })
        };

        loop {
            let mut input = String::new();
            match io::stdin().read_line(&mut input) {
                Ok(n) => {
                    let message = Event::Message { sender: user.clone(), content: input, channel: None };
                    match sender.send(message) {
                        Err(err) => error!("Error sending message event: {:?}", err),
                        Ok(_) => {}
                    }
                }
                Err(error) => error!("error: {}", error),
            }
        }
    }
}