bililive 0.1.2

A simple stream-based bilibili live client library.
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

use serde::Deserialize;
use url::Url;

#[derive(Clone, Eq, PartialEq, Deserialize, Hash)]
pub struct Resp<T> {
    data: T,
}

impl Resp<ConfQueryInner> {
    pub fn token(&self) -> &str {
        &self.data.token
    }
    pub fn servers(&self) -> Vec<String> {
        self.data
            .host_server_list
            .iter()
            .map(|server| format!("wss://{}:{}/sub", server.host, server.wss_port))
            .collect()
    }
}

impl Resp<RoomQueryInner> {
    pub fn room_id(&self) -> Option<u64> {
        let url = &self.data.url;
        if url.host_str()? != "live.bilibili.com" {
            return None;
        }
        url.path_segments()
            .into_iter()
            .flatten()
            .last()
            .and_then(|id| id.parse().ok())
    }
}

#[derive(Clone, Eq, PartialEq, Deserialize, Hash)]
pub struct RoomQueryInner {
    url: Url,
}

#[derive(Clone, Eq, PartialEq, Deserialize, Hash)]
pub struct ConfQueryInner {
    token: String,
    host_server_list: Vec<WSServer>,
}

#[derive(Clone, Eq, PartialEq, Deserialize, Hash)]
struct WSServer {
    host: String,
    wss_port: u16,
}