maxbot 0.1.0

Автоматизация работы с чат-ботами MAX
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

//! Управление подписками (webhook).

use crate::client::MaxClient;
use crate::error::Result;
use crate::types::Subscription;

impl MaxClient {
    /// Получить список всех подписок бота.
    pub async fn get_subscriptions(&self) -> Result<Vec<Subscription>> {
        self.request_with_rate_limit(reqwest::Method::GET, "/subscriptions", &[], None)
            .await
    }

    /// Создать новую подписку (установить webhook).
    ///
    /// # Arguments
    /// * `url` - HTTPS URL, на который будут приходить обновления.
    /// * `update_types` - список типов обновлений, например `["message_created", "message_callback"]`.
    /// * `secret` - опциональный секретный ключ для проверки заголовка `X-Max-Bot-Api-Secret`.
    pub async fn create_subscription(
        &self,
        url: &str,
        update_types: Vec<String>,
        secret: Option<&str>,
    ) -> Result<()> {
        let mut body = serde_json::json!({
            "url": url,
            "update_types": update_types,
        });
        if let Some(s) = secret {
            body["secret"] = s.into();
        }
        let resp: serde_json::Value = self
            .request_with_rate_limit(reqwest::Method::POST, "/subscriptions", &[], Some(body))
            .await?;
        // API MAX возвращает {"success": true, "message": "..."}
        if !resp["success"].as_bool().unwrap_or(false) {
            let msg = resp["message"].as_str().unwrap_or("unknown error");
            return Err(crate::error::Error::Api {
                code: 400,
                message: msg.to_string(),
            });
        }
        Ok(())
    }

    /// Удалить подписку (отключить webhook).
    pub async fn delete_subscription(&self, url: &str) -> Result<()> {
        let resp: serde_json::Value = self
            .request_with_rate_limit(
                reqwest::Method::DELETE,
                "/subscriptions",
                &[("url", url.to_string())],
                None,
            )
            .await?;
        if !resp["success"].as_bool().unwrap_or(false) {
            let msg = resp["message"].as_str().unwrap_or("unknown error");
            return Err(crate::error::Error::Api {
                code: 400,
                message: msg.to_string(),
            });
        }
        Ok(())
    }
}