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
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

use serde::{Deserialize, Serialize};

use crate::config::{
    backend::{
        Backend, BackendNode, direct::DirectLink, disk::Disk,
        openlist::OpenList,
    },
    frontend::Frontend,
    general::{Emby, General, Log, UserAgent},
    http2::Http2,
};

#[derive(Clone, Debug, Deserialize, Serialize, Default)]
pub struct PathRewriteConfig {
    #[serde(default)]
    pub enable: bool,
    #[serde(default)]
    pub pattern: String,
    #[serde(default)]
    pub replacement: String,
}

impl PathRewriteConfig {
    pub fn is_need_rewrite(&self, path: &str) -> bool {
        if path.is_empty() || !self.enable {
            return false;
        }
        !self.pattern.is_empty() && !self.replacement.is_empty()
    }
}

#[derive(Clone, Debug, Default, Deserialize, Serialize)]
pub struct AntiReverseProxyConfig {
    #[serde(default)]
    pub enable: bool,
    #[serde(default, rename = "host")]
    pub trusted_host: String,
}

impl AntiReverseProxyConfig {
    #[inline]
    pub fn is_need_anti(&self, host: &str) -> bool {
        if !self.enable || self.trusted_host.is_empty() {
            return false;
        }

        fn extract_valid_host(url: &str) -> Option<&str> {
            let cleaned = url
                .trim_start_matches("http://")
                .trim_start_matches("https://");

            cleaned
                .split(['/', ':'])
                .next()
                .filter(|&s| !s.is_empty())
                .map(|s| s.trim_end_matches('/'))
        }

        match (
            extract_valid_host(host),
            extract_valid_host(&self.trusted_host),
        ) {
            (Some(request_host), Some(trusted_host)) => {
                !request_host.eq_ignore_ascii_case(trusted_host)
            }
            _ => false,
        }
    }
}

#[derive(Clone, Debug, Deserialize, Serialize, Default)]
pub struct FallbackConfig {
    #[serde(default)]
    pub video_missing_path: String,
}

#[derive(Clone, Deserialize, Serialize)]
pub struct RawConfig {
    #[serde(rename = "General")]
    pub general: General,
    #[serde(rename = "Log")]
    pub log: Log,
    #[serde(rename = "Emby")]
    pub emby: Emby,
    #[serde(rename = "UserAgent")]
    pub user_agent: UserAgent,
    #[serde(rename = "Http2")]
    pub http2: Option<Http2>,
    #[serde(rename = "Frontend")]
    pub frontend: Option<Frontend>,
    #[serde(rename = "Backend")]
    pub backend: Option<Backend>,
    #[serde(rename = "BackendNode")]
    pub backend_nodes: Option<Vec<BackendNode>>,
    #[serde(rename = "Disk")]
    pub disk: Option<Disk>,
    #[serde(rename = "OpenList")]
    pub open_list: Option<OpenList>,
    #[serde(rename = "DirectLink")]
    pub direct_link: Option<DirectLink>,
    #[serde(rename = "Fallback", default)]
    pub fallback: FallbackConfig,
}