stoat-rs 0.2.5

Stoat API Wrapper
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

use async_trait::async_trait;
use stoat_models::v0::Webhook;

use crate::{
    Error, HttpClient, Result,
    builders::{EditWebhookBuilder, ExecuteWebhookBuilder},
};

#[async_trait]
pub trait WebhookExt: Sized {
    async fn from_token(
        http: impl AsRef<HttpClient> + Send,
        webhook_id: &str,
        token: &str,
    ) -> Result<Self>;
    async fn from_url(http: impl AsRef<HttpClient> + Send, url: &str) -> Result<Self>;
    async fn delete(&self, http: impl AsRef<HttpClient> + Send) -> Result<()>;
    fn edit(&self, http: impl AsRef<HttpClient>) -> EditWebhookBuilder;
    fn execute(&self, http: impl AsRef<HttpClient>) -> ExecuteWebhookBuilder;
}

#[async_trait]
impl WebhookExt for Webhook {
    async fn from_token(
        http: impl AsRef<HttpClient> + Send,
        webhook_id: &str,
        token: &str,
    ) -> Result<Self> {
        http.as_ref().fetch_webhook_token(webhook_id, token).await
    }

    async fn from_url(http: impl AsRef<HttpClient> + Send, url: &str) -> Result<Self> {
        let mut components = url.split('/').rev();
        let token = components.next().ok_or(Error::InvalidUrl)?;
        let id = components.next().ok_or(Error::InvalidUrl)?;

        Self::from_token(http, id, token).await
    }

    async fn delete(&self, http: impl AsRef<HttpClient> + Send) -> Result<()> {
        if let Some(token) = &self.token {
            http.as_ref().delete_webhook_token(&self.id, token).await
        } else {
            http.as_ref().delete_webhook(&self.id).await
        }
    }

    fn edit(&self, http: impl AsRef<HttpClient>) -> EditWebhookBuilder {
        EditWebhookBuilder::new(http.as_ref().clone(), self.id.clone(), self.token.clone())
    }

    fn execute(&self, http: impl AsRef<HttpClient>) -> ExecuteWebhookBuilder {
        ExecuteWebhookBuilder::new(
            http.as_ref().clone(),
            self.id.clone(),
            self.token.clone().expect("Webhook missing token."),
        )
    }
}