amagi 0.1.1

Rust SDK, CLI, and Web API service skeleton for multi-platform social web adapters.
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

use serde_json::Value;

use crate::error::AppError;

use super::super::types::{
    BilibiliLoginQrcode, BilibiliLoginStatus, BilibiliQrcodeStatus, BilibiliQrcodeStatusData,
};
use super::{
    BilibiliFetcher,
    helper::{ensure_bilibili_success, flatten_headers},
    requests,
};

impl BilibiliFetcher {
    /// Fetch the current Bilibili login status payload.
    ///
    /// # Errors
    ///
    /// Returns an error when the upstream request fails or the response body
    /// contains a non-zero Bilibili API status code.
    #[doc(alias = "fetchLoginStatus")]
    pub async fn fetch_login_status(&self) -> Result<BilibiliLoginStatus, AppError> {
        self.fetch_json(&requests::login_status(self.api_base_url.as_ref())?)
            .await
    }

    /// Request a new Bilibili login QR code.
    ///
    /// # Errors
    ///
    /// Returns an error when the upstream request fails or the response body
    /// contains a non-zero Bilibili API status code.
    #[doc(alias = "requestLoginQrcode")]
    #[doc(alias = "fetchLoginQrcode")]
    pub async fn request_login_qrcode(&self) -> Result<BilibiliLoginQrcode, AppError> {
        self.fetch_json(&requests::login_qrcode(self.passport_base_url.as_ref())?)
            .await
    }

    /// Poll the status of one Bilibili login QR code.
    ///
    /// # Errors
    ///
    /// Returns an error when the upstream request fails or the response body
    /// contains a non-zero Bilibili API status code.
    #[doc(alias = "checkQrcodeStatus")]
    #[doc(alias = "fetchQrcodeStatus")]
    pub async fn check_qrcode_status(
        &self,
        qrcode_key: &str,
    ) -> Result<BilibiliQrcodeStatus, AppError> {
        let url = requests::qrcode_status(self.passport_base_url.as_ref(), qrcode_key)?;
        let (headers, body) = self.send_text_request_with_headers(&url, None).await?;
        let value: Value = serde_json::from_str(&body)?;
        ensure_bilibili_success(&url, &value)?;

        Ok(BilibiliQrcodeStatus {
            code: 0,
            message: value
                .get("message")
                .or_else(|| value.get("msg"))
                .and_then(Value::as_str)
                .unwrap_or("0")
                .to_owned(),
            data: BilibiliQrcodeStatusData {
                data: value.get("data").cloned().unwrap_or(Value::Null),
                headers: flatten_headers(&headers),
            },
            upstream_payload: value.get("data").cloned().unwrap_or(Value::Null),
        })
    }
}