fix: some more debugging

Author: lostb1t

Makefile

@@ -33,7 +33,7 @@ run:
 	REPLEX_ENABLE_CONSOLE=0 \
 	REPLEX_CACHE_TTL=0 \
   REPLEX_HUB_RESTRICTIONS=1 \
-	RUST_LOG="info,replex=info" \
+	RUST_LOG="debug,replex=debug" \
     REPLEX_NTF_WATCHLIST_FORCE=0 \
     RUSTFLAGS=-Awarnings \
 	cargo watch -w src -x run

src/plex_client.rs

@@ -274,12 +274,14 @@ impl PlexClient {
         self,
         uuid: String,
     ) -> Option<String> {
+        //tracing::debug!(uuid = uuid, "Loading hero art from plex");
         let cache_key = format!("{}:hero_art", uuid);
 
         let cached_result: Option<Option<String>> =
             GLOBAL_CACHE.get(cache_key.as_str()).await;
 
         if cached_result.is_some() {
+            //tracing::debug!("Returning cached version");
             return cached_result.unwrap();
         }
 
@@ -307,8 +309,14 @@ impl PlexClient {
             }
         }
 
+        if image.is_none() {
+           tracing::warn!(uuid = uuid, "No hero image found on plex");
+        }
+        
         image.as_ref()?; // dont return and dont cache, let us just retry next time.
 
+        //tracing::debug!("Hero image found");
+
         let cache_expiry = crate::cache::Expiration::Month;
         let _ = GLOBAL_CACHE
             .insert(cache_key, image.clone(), cache_expiry)

src/routes.rs

@@ -133,6 +133,11 @@ pub fn route() -> Router {
                 .hoop(proxy_for_transform)
                 .get(transform_hubs_response),
         )
+        .push(
+            Router::new()
+                .path("/replex/test_proxy/<**rest>")
+                .goal(test_proxy_request),
+        )
         .push(
             Router::new()
                 .path("/replex/image/hero/<type>/<uuid>")
@@ -184,11 +189,22 @@ async fn proxy_request(
     depot: &mut Depot,
     ctrl: &mut FlowCtrl,
 ) {
-    let config: Config = Config::dynamic(req).extract().unwrap();
     let proxy = default_proxy();
     proxy.handle(req, depot, res, ctrl).await;
 }
 
+#[handler]
+async fn test_proxy_request(
+    req: &mut Request,
+    res: &mut Response,
+    depot: &mut Depot,
+    ctrl: &mut FlowCtrl,
+) {
+    dbg!("yo");
+    let proxy = test_proxy("https://webhook.site".to_string());
+    proxy.handle(req, depot, res, ctrl).await;
+}
+
 #[handler]
 async fn proxy_for_transform(
     req: &mut Request,

src/utils.rs

@@ -49,7 +49,7 @@ pub fn default_url_query_getter(
     }
 }
 
-
+// Proxy to plex instance
 pub fn default_proxy() -> Proxy<String, ReqwestClient> {
   let config: Config = Config::figment().extract().unwrap();
   let mut proxy = Proxy::new(
@@ -64,8 +64,6 @@ pub fn default_proxy() -> Proxy<String, ReqwestClient> {
   proxy
 }
 
-
-
 pub fn proxy(upstream: String) -> Proxy<String, ReqwestClient> {
   let mut proxy = Proxy::new(
     upstream,
@@ -79,6 +77,17 @@ pub fn proxy(upstream: String) -> Proxy<String, ReqwestClient> {
   proxy
 }
 
+pub fn test_proxy(upstream: String) -> Proxy<String, ReqwestClient> {
+  let mut proxy = Proxy::new(
+    upstream,
+    ReqwestClient::new(reqwest::Client::builder()
+             .build()
+             .unwrap())
+  );
+  
+  proxy
+}
+
 pub fn get_collection_id_from_child_path(path: String) -> i32 {
     let mut path = path.replace("/library/collections/", "");
     path = path.replace("/children", "");