embystream 0.0.36

Another Emby streaming application (frontend/backend separation) written in 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

use crate::oauthutil::OAuthToken;
use serde::{Deserialize, Serialize};

/// Sub-table `[BackendNode.GoogleDrive]`.
#[derive(Clone, Debug, Default, Deserialize, Serialize)]
pub struct GoogleDriveConfig {
    /// Stable node identifier used for token/cache keys.
    #[serde(default)]
    pub node_uuid: String,
    /// OAuth client ID used when refreshing access tokens.
    #[serde(default)]
    pub client_id: String,
    /// OAuth client secret used when refreshing access tokens.
    #[serde(default)]
    pub client_secret: String,
    /// Preferred shared drive ID; takes precedence over `drive_name`.
    #[serde(default)]
    pub drive_id: String,
    /// Shared drive name fallback when `drive_id` is absent.
    #[serde(default)]
    pub drive_name: String,
    /// Persisted OAuth access token; may be refreshed at runtime.
    #[serde(default)]
    pub access_token: String,
    /// OAuth refresh token used to renew `access_token`.
    #[serde(default)]
    pub refresh_token: String,
    /// Preferred persisted OAuth token blob.
    #[serde(default)]
    pub token: Option<OAuthToken>,
}

impl GoogleDriveConfig {
    pub fn effective_token(&self) -> Option<OAuthToken> {
        if let Some(token) = self.token.as_ref().filter(|token| {
            token.has_access_token() || token.has_refresh_token()
        }) {
            return Some(token.clone());
        }

        if self.access_token.trim().is_empty()
            && self.refresh_token.trim().is_empty()
        {
            return None;
        }

        Some(OAuthToken {
            access_token: self.access_token.trim().to_string(),
            refresh_token: self.refresh_token.trim().to_string(),
            token_type: "Bearer".to_string(),
            expiry: None,
        })
    }

    pub fn effective_refresh_token(&self) -> Option<String> {
        self.effective_token()
            .map(|token| token.refresh_token.trim().to_string())
            .filter(|token| !token.is_empty())
    }

    pub fn apply_token(&mut self, token: OAuthToken) {
        self.access_token = token.access_token.clone();
        self.refresh_token = token.refresh_token.clone();
        self.token = Some(token);
    }
}