botrs 0.13.0

A Rust QQ Bot framework based on QQ Guild Bot API
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

use super::{BotApi, resource};
use crate::error::Result;
use crate::models::webhook::{
    HttpIdentity, HttpReady, HttpSession, WebhookValidationRequest, WebhookValidationResponse,
};
use std::collections::HashMap;
use tracing::debug;

impl BotApi {
    /// Creates a new HTTP webhook session.
    pub async fn create_session(&self, identity: &HttpIdentity) -> Result<HttpReady> {
        debug!("Creating HTTP webhook session");
        let response = self
            .http
            .post(
                self.token(),
                resource::WEBHOOK_SESSIONS,
                None::<&()>,
                Some(identity),
            )
            .await?;
        Self::decode_json(response)
    }

    /// Checks HTTP webhook session health.
    pub async fn check_sessions(&self) -> Result<Vec<HttpSession>> {
        debug!("Checking HTTP webhook sessions");
        let mut params = HashMap::new();
        params.insert("action", "check");
        let response = self
            .http
            .patch(
                self.token(),
                resource::WEBHOOK_SESSIONS,
                Some(&params),
                None::<&()>,
            )
            .await?;
        Self::decode_json(response)
    }

    /// Lists active HTTP webhook sessions.
    pub async fn session_list(&self) -> Result<Vec<HttpSession>> {
        debug!("Listing HTTP webhook sessions");
        let response = self
            .http
            .get(self.token(), resource::WEBHOOK_SESSIONS, None::<&()>)
            .await?;
        Self::decode_json(response)
    }

    /// Removes an HTTP webhook session.
    pub async fn remove_session(&self, session_id: &str) -> Result<()> {
        debug!("Removing HTTP webhook session {}", session_id);
        let path = resource::webhook_session(session_id);
        self.http.delete(self.token(), &path, None::<&()>).await?;
        Ok(())
    }

    /// Builds a webhook validation response from a request and signature.
    pub fn webhook_validation_response(
        request: &WebhookValidationRequest,
        signature: impl Into<String>,
        data_version: impl Into<String>,
    ) -> WebhookValidationResponse {
        WebhookValidationResponse {
            plain_token: request.plain_token.clone(),
            signature: signature.into(),
            data_version: data_version.into(),
        }
    }
}