resolve hanging thread issuse, add radio metadata

Cargo.toml

@@ -18,13 +18,14 @@ anyhow = "1.0.88"
 serde = {version = "1.0.210", features = ["derive"]}
 serde_json = "1.0.128"
 sled = "0.34.7"
-symphonia = { version = "0.5.4", features = ["all"] }
+symphonia = { path = "/home/dlj/github/Symphonia/symphonia", features = ["all"] }
 cfg-if = "1.0.0"
 tokio = { version = "1.40.0", features = ["full", "tracing"] }
 futures = { version = "0.3.30", default-features = false }
 tokio-stream = "0.1.16"
 chrono = { version = "0.4.38",  features = ["serde"]}
 uuid = { version = "1.8.0", features = ["serde", "v4"] }
+ureq = "2.10.1"
 
 [profile.release]
 opt-level = 3

Makefile.toml

@@ -143,7 +143,7 @@ script = "sudo pkill -9 rsplayer || true"
 
 [tasks.run_local]
 dependencies = ["kill_local"]
-env = { "RUST_LOG" = "rsplayer=info,rsplayer_playback=info,warp=info", "RUST_BACKTRACE" = "full", "PORT" = "8000", "TLS_PORT" = "8443", "TLS_CERT_PATH" = "self.crt", "TLS_CERT_KEY_PATH" = "self.key" }
+env = { "RUST_LOG" = "rsplayer=info,rsplayer_playback=debug,warp=info", "RUST_BACKTRACE" = "full", "PORT" = "8000", "TLS_PORT" = "8443", "TLS_CERT_PATH" = "self.crt", "TLS_CERT_KEY_PATH" = "self.key" }
 cwd = ".run"
 command = "cargo"
 args = ["run"]

rsplayer_metadata/Cargo.toml

@@ -15,6 +15,7 @@ sled.workspace = true
 symphonia.workspace = true
 chrono.workspace = true
 uuid.workspace = true
+ureq.workspace = true
 
 api_models = {path = "../rsplayer_api_models"}
 walkdir = "2.5.0"

rsplayer_metadata/src/queue_service.rs

@@ -1,8 +1,12 @@
-use std::sync::{
-    atomic::{AtomicBool, AtomicU16, Ordering},
-    Arc,
+use std::{
+    sync::{
+        atomic::{AtomicBool, AtomicU16, Ordering},
+        Arc,
+    },
+    time::Duration,
 };
 
+use log::info;
 use rand::Rng;
 use sled::{Db, IVec, Tree};
 
@@ -72,6 +76,35 @@ impl QueueService {
             if let Ok(Some(value)) = self.queue_db.get(current_key) {
                 let mut song = Song::bytes_to_song(&value).expect("Failed to parse song");
                 song.statistics = self.statistics_repository.find_by_id(song.file.as_str());
+                if song.file.starts_with("http") {
+                    let agent = ureq::AgentBuilder::new()
+                        .timeout_connect(Duration::from_secs(5))
+                        .timeout_read(Duration::from_secs(5))
+                        .timeout_write(Duration::from_secs(5))
+                        .build();
+                    let Ok(resp) = agent.get(&song.file).set("accept", "*/*").call() else {
+                        return None;
+                    };
+
+                    let status = resp.status();
+                    info!("response status code:{status} / status text:{}", resp.status_text());
+                    if status == 200 {
+
+                        resp.headers_names()
+                            .iter()
+                            .filter(|h| h.starts_with("icy-"))
+                            .for_each(|header_key| {
+                                 match header_key.as_str() {
+                                    "icy-name" => song.title = resp.header(header_key).map(|s|s.to_owned()),
+                                    "icy-description" => song.artist = resp.header(header_key).map(|s|s.to_owned()),
+                                    "icy-genre" => song.genre = resp.header(header_key).map(|s|s.to_owned()),
+                                    _ => ()
+                                 }
+                            });
+                    } else {
+                        return None
+                    }
+                }
                 return Some(song);
             }
         }

rsplayer_metadata/src/test.rs

@@ -1,3 +1,4 @@
+#[cfg(test)]
 mod queue {
     use std::sync::Arc;
 
@@ -390,6 +391,15 @@ mod metadata {
         assert_eq!(stat.liked_count, -2);
     }
 
+    #[test]
+    fn test_favorite_radio_station(){
+        let ctx = TestContext::new();
+        ctx.metadata_service.like_media_item("radio_uuid_http://radioaparat.com");
+        let favs = ctx.metadata_service.get_favorite_radio_stations();
+        assert_eq!(favs.len(), 1);
+        assert_eq!(favs.get(0).unwrap(), "http://radioaparat.com");
+    }
+
     #[test]
     fn test_increase_play_count() {
         let ctx = TestContext::new();
@@ -401,6 +411,7 @@ mod metadata {
     }
 }
 
+#[cfg(test)]
 mod playlist {
     use std::vec;
 

rsplayer_playback/Cargo.toml

@@ -19,13 +19,13 @@ tokio.workspace = true
 thread-priority = "1.1.0"
 core_affinity = "0.8.1"
 sled.workspace = true
-
+ureq.workspace = true
 # symphonia
 cpal = "0.15.3"
 # cpal = { path = "/home/dlj/github/cpal" }
 rb = "0.4.1"
 # rubato = "0.12.0"
-ureq = "2.10.1"
+
 
 
 mockall_double = "0.3.1"