bpi-rs 0.1.3

Bilibili API client library for Rust
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
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140

use serde::{ Deserialize, Serialize };

use crate::{ BilibiliRequest, BpiClient, BpiError, BpiResponse };

#[derive(Debug, Serialize, Clone, Deserialize)]
pub struct SilentUserInfo {
    /// 禁言者uid
    pub tuid: i64,
    /// 禁言者昵称
    pub tname: String,
    /// 发起者uid
    pub uid: i64,
    /// 发起者昵称
    pub name: String,
    /// 禁言时间
    pub ctime: String,
    /// 禁言记录Id
    pub id: i64,
    /// 不明
    pub is_anchor: i32,
    /// 禁言者头像
    pub face: String,
    /// 发起者权限
    pub admin_level: i32,
}

#[derive(Debug, Serialize, Clone, Deserialize)]
pub struct SilentUserListData {
    /// 禁言列表
    pub data: Vec<SilentUserInfo>,
    /// 禁言观众数量
    pub total: i32,
    /// 页码总数量
    pub total_page: i32,
}

impl BpiClient {
    /// 禁言观众
    /// tuid: 用户uid
    /// hour: -1永久 0本场直播
    pub async fn live_add_silent_user(
        &self,
        room_id: i64,
        tuid: i64,
        hour: i32
    ) -> Result<BpiResponse<serde_json::Value>, BpiError> {
        let csrf = self.csrf()?;

        let block_type = if hour == 0 {"2".to_string()} else {"1".to_string()};
        
        let form = vec![
            ("room_id", room_id.to_string()),
            ("tuid", tuid.to_string()),
            ("mobile_app", "web".to_string()),
            ("type", block_type),
            ("hour", hour.to_string()),
            ("csrf_token", csrf.clone()),
            ("csrf", csrf)
        ];

        // if let Some(msg) = msg {
        //     form.push(("msg", msg.to_string()));
        // }

        self
            .post("https://api.live.bilibili.com/xlive/web-ucenter/v1/banned/AddSilentUser")
            .form(&form)
            .send_bpi("禁言观众").await
    }

    /// 查询直播间禁言列表
    ///
    pub async fn live_list_silent_users(
        &self,
        room_id: i64,
        ps: i32
    ) -> Result<BpiResponse<SilentUserListData>, BpiError> {
        let csrf = self.csrf()?;

        let form = vec![
            ("room_id", room_id.to_string()),
            ("ps", ps.to_string()),
            ("csrf_token", csrf.clone()),
            ("csrf", csrf)
        ];

        self
            .post("https://api.live.bilibili.com/xlive/web-ucenter/v1/banned/GetSilentUserList")
            .form(&form)
            .send_bpi("查询直播间禁言列表").await
    }

    /// 解除禁言
    ///
    pub async fn live_del_block_user(
        &self,
        roomid: i64,
        id: i64
    ) -> Result<BpiResponse<serde_json::Value>, BpiError> {
        let csrf = self.csrf()?;

        let form = vec![
            ("room_id", roomid.to_string()),
            ("tuid", id.to_string()),
            ("csrf_token", csrf.clone()),
            ("csrf", csrf)
        ];

        self
            .post("https://api.live.bilibili.com/xlive/web-ucenter/v1/banned/DelSilentUser")
            .form(&form)
            .send_bpi("解除禁言").await
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[tokio::test]
    async fn test_get_silent_user_list() {
        let bpi = BpiClient::new();
        let resp = bpi.live_list_silent_users(3818081, 1).await.unwrap();
        tracing::info!("{:?}", resp);
    }

    #[tokio::test]
    async fn test_add_silent_user() {
        let bpi = BpiClient::new();
        let resp = bpi.live_add_silent_user(3818081, 316183842, 0).await.unwrap();
        tracing::info!("{:?}", resp);
    }

    #[tokio::test]
    async fn test_del_silent_user_list() {
        let bpi = BpiClient::new();
        let resp = bpi.live_del_block_user(3818081, 316183842).await.unwrap();
        tracing::info!("{:?}", resp);
    }
}