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
62
63
64
65

#![allow(missing_docs)]
use std::sync::Arc;

use reqwest::{Client, StatusCode};
use tgbot::{
    handler::{UpdateHandler, WebhookServer},
    types::Update,
};
use tokio::sync::Mutex;

#[derive(Clone)]
struct Handler {
    updates: Arc<Mutex<Vec<Update>>>,
}

impl UpdateHandler for Handler {
    async fn handle(&self, update: Update) {
        let mut updates = self.updates.lock().await;
        updates.push(update);
    }
}

#[tokio::test]
async fn webhook() {
    let updates = Arc::new(Mutex::new(Vec::new()));
    let webhook_server = WebhookServer::new(
        "/",
        Handler {
            updates: updates.clone(),
        },
    );
    tokio::spawn(async move {
        webhook_server.run(([127, 0, 0, 1], 8080)).await.unwrap();
    });
    let client = Client::new();
    let response = client
        .post("http://localhost:8080/")
        .json(&serde_json::json!({
            "update_id":10000,
            "message":{
                "date":1441645532,
                "chat":{
                    "last_name":"Test Lastname",
                    "id":1111111,
                    "first_name":"Test",
                    "username":"Test",
                    "type": "private"
                },
                "message_id":1365,
                "from":{
                    "last_name":"Test Lastname",
                    "id":1111111,
                    "first_name":"Test",
                    "username":"Test",
                    "is_bot": false
                },
                "text":"/start"
            }
        }))
        .send()
        .await
        .unwrap();
    assert_eq!(response.status(), StatusCode::OK);
    assert!(!updates.lock().await.is_empty())
}