ataraxia 0.1.0

A Rust Wrapper for the Revolt 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
73
74
75
76
77
78
79
80
81
82
83
84
85
86

use reqwest::Client;





pub static API_BASE_URL: &str = "https://api.revolt.chat";


#[derive(Clone)]
pub struct Http;/* T> where T: Service<Request> {
} */


/* struct RateLimiter<T> where T: Service<Request> {
    service: tower::limit::RateLimit<tower::util::ServiceFn<T>>
} */

impl Http
{

    /// Instantiates a new Http Client
    /// 
/*     pub async fn new() {
        let client = reqwest::Client::new();
        let mut svc = tower::ServiceBuilder::new()
            .rate_limit(100, Duration::new(10, 0)) // 100 requests every 10 seconds
            .service(tower::service_fn(move |req| client.execute(req)));
/*         let mut http_ratelimiter = RateLimiter { service: svc };
 */
        let mut req = Request::new(Method::POST, Url::parse("http://httpbin.org/post")?);
        *req.body_mut() = Some(Body::from("the exact body that is sent"));

/*         let b = http_ratelimiter.service.ready().await?.call(req).await?;
 */
        let res = svc.ready().await?.call(req).await;

    
    } */

    /// Sends a POST request to the revolt api
    /// ```rs
    /// let a = Http::new();
    /// let b = a.post("channel/abc/messages", "my_bot_token", {"content": "Hello World!"}).await;
    /// ```
    pub async fn post(destination: &str, token: &str, body: serde_json::Value) -> Result<(), reqwest::Error> {
        let client = Client::new();
        let res = client.post(format!("{}/{}", API_BASE_URL, destination))
        .header("x-bot-token", format!("{token}", token = token))
        .header("content-type", "application/json")
        .body(body.to_string())
        .send()
        .await;

        res.map(|_| ())
    }

    /// Sends a GET request to the revolt api
    /// ```rs
    /// let a = Http::new();
    /// let b = a.get("channel/abc/messages", "my_bot_token").await;
    /// ```
    /// 
    pub async fn get(destination: &str, token: &str) -> Result<(), reqwest::Error> {
        let client = Client::new();
        let res = client.get(format!("{}/{}", API_BASE_URL, destination))
        .header("x-bot-token", format!("{token}", token = token))
        .send()
        .await;

        res.map(|_| ())
    }

    /// Sends a DELETE request to the revolt api
    pub async fn delete(destination: &str, token: &str, body: serde_json::Value) -> Result<(), reqwest::Error> {
        let client = Client::new();
        let res = client.delete(format!("{}/{}", API_BASE_URL, destination))
        .header("x-bot-token", format!("{token}", token = token))
        .header("content-type", "application/json")
        .body(body.to_string())
        .send()
        .await;

        res.map(|_| ())
    }
}