tg.rs

extern crate telegram_bot;

use super::git_watcher::GitWatcher;
use telegram_bot::*;

use std::time::*;

use futures::Future;
use futures::Stream;
use futures::stream::*;

use tokio_core::reactor::Handle;
use tokio_timer::*;


pub struct TelegramGitWatcherBot{

    pub git_watcher: GitWatcher,
    pub tg_api: Api
}

impl TelegramGitWatcherBot{

    pub fn start(&self, handle: Handle) {

        let tg = self.tg_api.stream()
           .for_each(|upd| { self.log_tg(); Ok(()) })
           .map_err(|_| ());

        let timer = Timer::default()
            .interval(Duration::new(15, 0))
            .for_each(|_| { self.log_timer(); Ok(()) })
            .map_err(|_| ());

        handle.spawn(tg);
        handle.spawn(timer);
    }

    fn log_tg(&self){

        println!("telegram update!");
    }

    fn log_timer(&self){

        println!("timer tick!");
    }
}