tgbot 0.44.0

A Telegram Bot library
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

use std::{io::Error as IoError, net::SocketAddr, sync::Arc};

use axum::Router;
use tokio::net::TcpListener;

use crate::{handler::UpdateHandler, types::Update};

/// Represents a simple webhook server for handling incoming updates from the Telegram Bot API.
#[cfg_attr(nightly, doc(cfg(feature = "webhook")))]
pub struct WebhookServer {
    router: Router,
}

impl WebhookServer {
    /// Creates a new `WebhookServer`.
    ///
    /// # Arguments
    ///
    /// * `path` - The path where the webhook server will receive incoming updates.
    /// * `handler` - The handler for processing updates.
    pub fn new<A, B>(path: A, handler: B) -> Self
    where
        A: AsRef<str>,
        B: UpdateHandler + Send + Sync + 'static,
    {
        let router = Router::new()
            .route(path.as_ref(), axum::routing::post(handle_update::<B>))
            .layer(axum::Extension(Arc::new(handler)));
        Self { router }
    }

    /// Runs the server
    ///
    /// Returns the local address that the server is bound to.
    ///
    /// # Arguments
    ///
    /// * `address` - The address to bind the server to.
    pub async fn run<T>(self, address: T) -> Result<SocketAddr, IoError>
    where
        T: Into<SocketAddr>,
    {
        let listener = TcpListener::bind(address.into()).await?;
        let result = listener.local_addr();
        axum::serve(listener, self.router).await?;
        result
    }
}

impl From<WebhookServer> for Router {
    fn from(value: WebhookServer) -> Self {
        value.router
    }
}

async fn handle_update<H>(handler: axum::Extension<Arc<H>>, axum::extract::Json(update): axum::extract::Json<Update>)
where
    H: UpdateHandler,
{
    handler.handle(update).await
}