teloxide_tests 0.4.0

Test suite for teloxide bots
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

use std::sync::Mutex;

use actix_web::{web, Responder};
use serde::Deserialize;

use super::BodyChatId;
use crate::{
    server::{
        routes::{delete_message::DeleteMessageBody, make_telegram_result},
        DeletedMessage,
    },
    state::State,
};

#[derive(Debug, Deserialize, Clone)]
pub struct DeleteMessagesBody {
    pub chat_id: BodyChatId,
    pub message_ids: Vec<i32>,
}

pub async fn delete_messages(
    state: web::Data<Mutex<State>>,
    body: web::Json<DeleteMessagesBody>,
) -> impl Responder {
    let mut lock = state.lock().unwrap();
    let bot_request = body.into_inner();
    // deleteMessages skips messages that are not found, no error is returned.
    let mut deleted_messages = lock
        .messages
        .delete_messages(&bot_request.message_ids)
        .into_iter()
        .map(|m| DeletedMessage {
            message: m.clone(),
            bot_request: DeleteMessageBody {
                chat_id: bot_request.chat_id.clone(),
                message_id: m.id.0,
            },
        })
        .collect();

    lock.responses
        .deleted_messages
        .append(&mut deleted_messages);

    make_telegram_result(true)
}