twetch-sdk 0.0.1

rust twetch sdk with wasm builds
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
87
88
89

use anyhow::Result;
use serde_json::{json, Value};

pub struct Api {
    pub token: String,
}

impl Api {
    pub fn client(&self) -> reqwest::RequestBuilder {
        let client = reqwest::Client::new();
        client
            .post(format!("https://gw.twetch.app"))
            .header("Authorization", format!("Bearer {}", self.token))
    }

    pub async fn graphql(&self, query: String, variables: Option<Value>) -> Result<Value> {
        let payload = json!({
            "operationName": null,
            "variables": variables,
            "query": query
        });

        println!("api payload {:?}", payload);

        let res = self
            .client()
            .json(&payload)
            .send()
            .await?
            .json::<Value>()
            .await?;

        println!("res {:?}", res);

        let data = res.get("data").unwrap().clone();

        println!("data {:?}", data);

        Ok(data)
    }

    pub async fn create_message(&self, payload: Value) -> Result<Value> {
        let query = format!(
            "mutation createMessage($payload: MessageInput!) {{ createMessage(input: {{ message: $payload }}) {{ messageEdge {{ node {{ id }} }} }} }}",
        );

        let res = self
            .graphql(query, Some(payload))
            .await?
            .get("createMessage")
            .unwrap()
            .clone();
        Ok(res)
    }

    pub async fn create_conversation(&self, payload: String) -> Result<Value> {
        let query = format!(
            "mutation createConversation($payload: String!) {{ createConversation(input: {{ payload: $payload }}) {{ id }} }}",
        );

        let res = self
            .graphql(
                query,
                Some(json!({ "payload": serde_json::to_value(payload).unwrap() })),
            )
            .await?
            .get("createConversation")
            .unwrap()
            .clone();
        Ok(res)
    }

    pub async fn list_pubkeys(&self, user_ids: Vec<String>) -> Result<Value> {
        let user_ids_string = serde_json::to_value(user_ids).unwrap().to_string();
        let query = format!(
            "query ListPubkeys {{ allUsers(filter: {{ id: {{ in: {} }} }}) {{ nodes {{ publicKey }} }} }} ",
            user_ids_string
        );
        let res = self
            .graphql(query, None)
            .await?
            .get("allUsers")
            .unwrap()
            .get("nodes")
            .unwrap()
            .clone();
        Ok(res)
    }
}