fix: test

Author: lostb1t

src/models.rs

@@ -193,6 +193,8 @@ pub struct PlexContext {
     // host of the proxy server
     #[salvo(extract(rename = "host"))]
     pub host: Option<String>,
+    // #[salvo(extract(rename = "scheme"))]
+    // pub scheme: Option<String>,
     // photo transcode
     pub size: Option<String>,
     pub width: Option<i32>,

src/routes.rs

@@ -323,7 +323,6 @@ async fn ntf_watchlist_force(
     // use memory_stats::memory_stats;
     // dbg!(memory_stats().unwrap().physical_mem / 1024 / 1000);
     let params: PlexContext = req.extract().await.unwrap();
-    dbg!(&req);
     if params.clone().token.is_some() {
         tokio::spawn(async move {
             let url = format!("https://notifications.plex.tv/api/v1/notifications/settings?X-Plex-Token={}", params.clone().token.unwrap());

src/transform.rs

@@ -797,12 +797,19 @@ impl Transform for MediaStyleTransform {
             if guid.starts_with("plex://episode") && item.parent_guid.is_some() {    
                 guid = item.parent_guid.clone().unwrap();
             }
-            guid = guid
-                .replace("plex://", "");
+            guid = guid.replace("plex://", "");
 
             //let cover_art = item.get_hero_art(plex_client).await;
-            let cover_art = Some(format!("http://{}/image/hero/{}/{}", 
-                options.host.clone().unwrap(), 
+            let cover_art = Some(format!("{}://{}/image/hero/{}/{}", 
+                match options.forwarded_proto {
+                    Some(v) => v,
+                    None => "http".to_string()
+                },
+                match options.forwarded_host {
+                    Some(v) => v,
+                    None => options.host.clone().unwrap()
+                },
+                // options.host.clone().unwrap(), 
                 guid,
                 options.token.clone().unwrap()
             ));