astrid-telegram 0.1.0

Telegram bot frontend for the Astrid agent runtime
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84

//! Error types for the Telegram bot.

use thiserror::Error;

/// Errors produced by the Telegram bot.
#[derive(Debug, Error)]
pub enum TelegramBotError {
    /// Daemon connection failed.
    #[error("daemon connection failed: {0}")]
    DaemonConnection(String),

    /// Daemon RPC call failed.
    #[error("daemon RPC error: {0}")]
    DaemonRpc(String),

    /// Session not found for the given chat.
    #[error("no session for chat {0}")]
    #[allow(dead_code)]
    NoSession(i64),

    /// A turn is already in progress for this chat.
    #[error("turn already in progress for chat {0}")]
    #[allow(dead_code)]
    TurnInProgress(i64),

    /// Telegram API error.
    #[error("telegram API error: {0}")]
    #[allow(dead_code)]
    Telegram(String),

    /// Configuration error.
    #[error("configuration error: {0}")]
    Config(String),
}

/// Convenience alias.
pub type TelegramResult<T> = Result<T, TelegramBotError>;

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn error_display_daemon_connection() {
        let err = TelegramBotError::DaemonConnection("refused".to_string());
        assert_eq!(err.to_string(), "daemon connection failed: refused");
    }

    #[test]
    fn error_display_daemon_rpc() {
        let err = TelegramBotError::DaemonRpc("timeout".to_string());
        assert_eq!(err.to_string(), "daemon RPC error: timeout");
    }

    #[test]
    fn error_display_no_session() {
        let err = TelegramBotError::NoSession(42);
        assert_eq!(err.to_string(), "no session for chat 42");
    }

    #[test]
    fn error_display_turn_in_progress() {
        let err = TelegramBotError::TurnInProgress(99);
        assert_eq!(err.to_string(), "turn already in progress for chat 99");
    }

    #[test]
    fn error_display_telegram() {
        let err = TelegramBotError::Telegram("rate limited".to_string());
        assert_eq!(err.to_string(), "telegram API error: rate limited");
    }

    #[test]
    fn error_display_config() {
        let err = TelegramBotError::Config("missing token".to_string());
        assert_eq!(err.to_string(), "configuration error: missing token");
    }

    #[test]
    fn error_is_send_and_sync() {
        fn assert_send_sync<T: Send + Sync>() {}
        assert_send_sync::<TelegramBotError>();
    }
}