twitch_highway 0.5.2

Twitch 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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115

mod builder;
mod response;
mod types;

pub use builder::{GetConduitShards, ShardUpdate, TransportConfig, UpdateConduitShards};
pub use response::{
    ConduitResponse, GetConduitShardsResponse, UpdateConduitShardsResponse, UpdateShardError,
};
pub use types::{Conduit, ConduitShard, Transport};

use types::{CreateConduitsBody, UpdateConduitsBody};

use std::future::Future;

use crate::{
    Client, Error,
    types::{
        ConduitId,
        constants::{CONDUITS, EVENTSUB, ID},
    },
};

pub trait ConduitsAPI {
    /// See <https://dev.twitch.tv/docs/api/reference/#get-conduits>
    fn get_conduits(&self) -> impl Future<Output = Result<ConduitResponse, Error>> + Send;

    /// See <https://dev.twitch.tv/docs/api/reference/#create-conduits>
    fn create_conduits(
        &self,
        shard_count: u64,
    ) -> impl Future<Output = Result<ConduitResponse, Error>> + Send;

    /// See <https://dev.twitch.tv/docs/api/reference/#update-conduits>
    fn update_conduits(
        &self,
        conduit_id: &ConduitId,
        shard_count: u64,
    ) -> impl Future<Output = Result<ConduitResponse, Error>> + Send;

    /// See <https://dev.twitch.tv/docs/api/reference/#delete-conduit>
    fn delete_conduits(
        &self,
        conduit_id: &ConduitId,
    ) -> impl Future<Output = Result<(), Error>> + Send;

    /// See <https://dev.twitch.tv/docs/api/reference/#get-conduit-shards>
    fn get_conduit_shards<'a>(&'a self, conduit_id: &'a ConduitId) -> GetConduitShards<'a>;

    /// See <https://dev.twitch.tv/docs/api/reference/#update-conduit-shards>
    fn update_conduit_shards<'a>(&'a self, conduit_id: ConduitId) -> UpdateConduitShards<'a>;
}

impl ConduitsAPI for Client {
    async fn get_conduits(&self) -> Result<ConduitResponse, Error> {
        let mut url = self.base_url();

        url.path_segments_mut()
            .unwrap()
            .extend([EVENTSUB, CONDUITS]);

        self.json(self.http_client().get(url)).await
    }

    async fn create_conduits(&self, shard_count: u64) -> Result<ConduitResponse, Error> {
        let mut url = self.base_url();

        url.path_segments_mut()
            .unwrap()
            .extend([EVENTSUB, CONDUITS]);

        let req = self
            .http_client()
            .post(url)
            .json(&CreateConduitsBody { shard_count });
        self.json(req).await
    }

    async fn update_conduits(
        &self,
        conduit_id: &ConduitId,
        shard_count: u64,
    ) -> Result<ConduitResponse, Error> {
        let mut url = self.base_url();

        url.path_segments_mut()
            .unwrap()
            .extend([EVENTSUB, CONDUITS]);

        let req = self.http_client().patch(url).json(&UpdateConduitsBody {
            conduit_id,
            shard_count,
        });
        self.json(req).await
    }

    async fn delete_conduits(&self, conduit_id: &ConduitId) -> Result<(), Error> {
        let mut url = self.base_url();

        url.path_segments_mut()
            .unwrap()
            .extend([EVENTSUB, CONDUITS]);

        url.query_pairs_mut().append_pair(ID, conduit_id);

        self.no_content(self.http_client().delete(url)).await
    }

    fn get_conduit_shards<'a>(&'a self, conduit_id: &'a ConduitId) -> GetConduitShards<'a> {
        GetConduitShards::new(self, conduit_id)
    }

    fn update_conduit_shards<'a>(&'a self, conduit_id: ConduitId) -> UpdateConduitShards<'a> {
        UpdateConduitShards::new(self, conduit_id)
    }
}