botkit-telegram 0.2.0

Telegram implementation for botkit
Documentation 
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
58
59
60
61
62
63

use std::time::Duration;

use botkit_core::BotError;
use botkit_core::action::{ChatAction, ChatActionFutureBounds, ChatActionSender};

use crate::client::TelegramClient;

/// Telegram chat action sender
///
/// Sends chat actions to Telegram with appropriate action strings.
#[derive(Clone)]
pub struct TelegramActionSender {
    client: TelegramClient,
    chat_id: i64,
    /// Forum topic to scope the action to, when the chat has topics.
    thread_id: Option<i64>,
}

impl TelegramActionSender {
    /// Create a new Telegram action sender
    pub fn new(client: TelegramClient, chat_id: i64, thread_id: Option<i64>) -> Self {
        Self {
            client,
            chat_id,
            thread_id,
        }
    }

    /// Map unified ChatAction to Telegram API action string
    fn action_string(action: ChatAction) -> &'static str {
        match action {
            ChatAction::Typing => "typing",
            ChatAction::UploadPhoto => "upload_photo",
            ChatAction::RecordVideo => "record_video",
            ChatAction::UploadVideo => "upload_video",
            ChatAction::RecordVoice => "record_voice",
            ChatAction::UploadVoice => "upload_voice",
            ChatAction::UploadDocument => "upload_document",
            ChatAction::ChooseSticker => "choose_sticker",
            ChatAction::FindLocation => "find_location",
            ChatAction::RecordVideoNote => "record_video_note",
            ChatAction::UploadVideoNote => "upload_video_note",
        }
    }
}

impl ChatActionSender for TelegramActionSender {
    fn send_action(
        &self,
        action: ChatAction,
    ) -> impl ChatActionFutureBounds<Output = Result<(), BotError>> + '_ {
        async move {
            self.client
                .send_chat_action(self.chat_id, Self::action_string(action), self.thread_id)
                .await
        }
    }

    fn action_expiry(&self) -> Duration {
        // Telegram typing expires after 5 seconds
        Duration::from_secs(5)
    }
}