actix-telegram 0.0.5

telegram bot api lib based on actix
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

use super::TelegramApi;
use crate::application::UpdateHandler;
use crate::types::Update;
use actix::{Actor, Addr, Context, Handler, Message};

pub struct TelegramWorker<H>
where
    H: UpdateHandler + 'static,
{
    apps: H,
    telegram_api: Addr<TelegramApi>,
}

impl<H> TelegramWorker<H>
where
    H: UpdateHandler + 'static,
{
    pub(crate) fn new(telegram_api: Addr<TelegramApi>, apps: H) -> Self {
        Self { apps, telegram_api }
    }
}

impl<H> Actor for TelegramWorker<H>
where
    H: UpdateHandler + 'static,
{
    type Context = Context<Self>;

    fn started(&mut self, _ctx: &mut Context<Self>) {
        debug!("TelegramWorker is alive");
    }

    fn stopped(&mut self, _ctx: &mut Context<Self>) {
        debug!("TelegramWorker is stopped");
    }
}

impl<H> Handler<Update> for TelegramWorker<H>
where
    H: UpdateHandler + 'static,
{
    type Result = Result<(), ()>;

    fn handle(&mut self, msg: Update, _ctx: &mut Context<Self>) -> Self::Result {
        debug!("TelegramWorker.Update received {:?}", msg);
        if self.apps.handle(msg, &self.telegram_api).is_some() {
            debug!("update is not handled");
            Err(())
        } else {
            Ok(())
        }
    }
}

impl Message for Update {
    type Result = Result<(), ()>;
}