Spaces:
Running
Running
Upload main.rs
Browse files- src/main.rs +8 -21
src/main.rs
CHANGED
|
@@ -134,8 +134,13 @@ async fn api_client_for_arl(state: &AppState, arl: Option<String>) -> Arc<Mutex<
|
|
| 134 |
c
|
| 135 |
}
|
| 136 |
|
| 137 |
-
fn extract_media_url_and_format(
|
| 138 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 139 |
let Some(data_arr) = data else {
|
| 140 |
return (String::new(), String::new(), 0);
|
| 141 |
};
|
|
@@ -394,25 +399,7 @@ async fn media_url_for_track(
|
|
| 394 |
}
|
| 395 |
|
| 396 |
fn upstream_bases() -> Vec<String> {
|
| 397 |
-
|
| 398 |
-
|
| 399 |
-
let env = std::env::var("DZMEDIA_UPSTREAM").ok().unwrap_or_default();
|
| 400 |
-
let env = env.trim();
|
| 401 |
-
if env == "-" {
|
| 402 |
-
return out;
|
| 403 |
-
}
|
| 404 |
-
|
| 405 |
-
if !env.is_empty() {
|
| 406 |
-
for part in env.split(',') {
|
| 407 |
-
let s = part.trim();
|
| 408 |
-
if s.is_empty() {
|
| 409 |
-
continue;
|
| 410 |
-
}
|
| 411 |
-
out.push(s.trim_end_matches('/').to_string());
|
| 412 |
-
}
|
| 413 |
-
}
|
| 414 |
-
|
| 415 |
-
out
|
| 416 |
}
|
| 417 |
|
| 418 |
fn upstream_get_url_endpoint(base: &str) -> String {
|
|
|
|
| 134 |
c
|
| 135 |
}
|
| 136 |
|
| 137 |
+
fn extract_media_url_and_format(json: &serde_json::Value, formats: &Vec<&str>) -> (String, String, usize) {
|
| 138 |
+
use std::io::Write;
|
| 139 |
+
let mut log_file = std::fs::OpenOptions::new().create(true).append(true).open("debug_dzmedia.log").unwrap();
|
| 140 |
+
let _ = writeln!(log_file, "--- MEDIA JSON RESPONSE ---");
|
| 141 |
+
let _ = writeln!(log_file, "{}", serde_json::to_string_pretty(json).unwrap_or_default());
|
| 142 |
+
|
| 143 |
+
let data = json.get("data").and_then(|v| v.as_array());
|
| 144 |
let Some(data_arr) = data else {
|
| 145 |
return (String::new(), String::new(), 0);
|
| 146 |
};
|
|
|
|
| 399 |
}
|
| 400 |
|
| 401 |
fn upstream_bases() -> Vec<String> {
|
| 402 |
+
Vec::new()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 403 |
}
|
| 404 |
|
| 405 |
fn upstream_get_url_endpoint(base: &str) -> String {
|