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

use super::prelude::*;

/// 通过房号拿到直播间的信息
///
/// API 源：/xlive/web-room/v1/index/getInfoByRoom
#[derive(Debug, Deserialize, Serialize, Clone)]
pub struct InfoByRoom {
    /// 直播间信息
    pub room_info: RoomInfo,
    /// 主播有关的信息
    pub anchor_info: AnchorInfo,
}
/// [`InfoByRoom`] 的子信息，代表直播间信息
#[derive(Debug, Deserialize, Serialize, Clone)]
pub struct RoomInfo {
    /// 长房号，如 5440
    pub room_id: u64,
    /// 短房号，如 1
    pub short_id: u64,
    /// 直播间封面 url
    pub cover: String,
    /// 直播间关键帧
    pub keyframe: String,
}
/// [`InfoByRoom`] 的子信息，跟主播相关的信息
#[derive(Debug, Deserialize, Serialize, Clone)]
pub struct AnchorInfo {
    #[serde(rename = "base_info")]
    pub base: AnchorBaseInfo,
}
/// [`AnchorInfo`] 的子信息，跟主播相关的信息
#[derive(Debug, Deserialize, Serialize, Clone)]
pub struct AnchorBaseInfo {
    // 用户名
    pub uname: String,
    // 头像
    pub face: String,
    // 性别
    pub gender: String,
}

impl Request for InfoByRoom {
    type Args = u64;

    fn request(client: &Client, args: Self::Args) -> RequestResponse<Self> {
        const ROOM_INIT_URL: &str =
            "https://api.live.bilibili.com/xlive/web-room/v1/index/getInfoByRoom";

        let request = client.get(ROOM_INIT_URL).query(&[("room_id", args)]).send();

        Box::pin(async { request.await?.bili_data().await })
    }
}

#[cfg(test)]
mod tests {
    use crate::Request;
    use anyhow::*;

    #[tokio::test]
    async fn test_get_cgg_room_info() -> Result<()> {
        let client = crate::connection::new_client()?;
        // 超果果
        let info = crate::requests::InfoByRoom::request(&client, 646).await?;
        assert_eq!(info.room_info.room_id, 21133);
        assert_eq!(info.room_info.short_id, 646);

        let info = crate::requests::InfoByRoom::request(&client, 21133).await?;
        assert_eq!(info.room_info.room_id, 21133);
        assert_eq!(info.room_info.short_id, 646);

        assert_eq!(info.anchor_info.base.uname, "超果果mc");
        assert_eq!(info.anchor_info.base.gender, "男");
        Ok(())
    }

    #[tokio::test]
    async fn test_get_non_exist_room_info() -> Result<()> {
        let client = crate::connection::new_client()?;
        let info = crate::requests::InfoByRoom::request(&client, 38)
            .await
            .err()
            .unwrap();
        assert_eq!(
            info.to_string(),
            "Bilibili error: (19002000) 获取初始化数据失败"
        );
        Ok(())
    }
}