diff --git a/backend/src/processing/processor/stream_probe.rs b/backend/src/processing/processor/stream_probe.rs index b00bfc93f..380503910 100644 --- a/backend/src/processing/processor/stream_probe.rs +++ b/backend/src/processing/processor/stream_probe.rs @@ -105,7 +105,7 @@ pub async fn update_generic_stream_metadata( return Err(TuliproxError::Probe(format!("Skipping probe for generic stream {unique_id} due to connection limits"))); } - let probe_url = stream_url.to_string(); + let probe_url = input.resolve_url(stream_url)?.into_owned(); let config = app_config.config.load(); let metadata_update = config.metadata_update.clone().unwrap_or_default(); let ffprobe_timeout = metadata_update.ffprobe.timeout.unwrap_or(60); diff --git a/backend/src/processing/processor/xtream.rs b/backend/src/processing/processor/xtream.rs index 8c156380c..ac78df2fb 100644 --- a/backend/src/processing/processor/xtream.rs +++ b/backend/src/processing/processor/xtream.rs @@ -116,6 +116,7 @@ pub async fn update_live_stream_metadata( &temp_stream_prop, use_prefix, no_ext ); + let probe_url_cow = input.resolve_url(&stream_url)?; let config = app_config.config.load(); let metadata_update = config.metadata_update.clone().unwrap_or_default(); let ffprobe_timeout = metadata_update.ffprobe.timeout.unwrap_or(60); @@ -134,7 +135,7 @@ pub async fn update_live_stream_metadata( let mut success = false; let mut not_found = false; match FfmpegExecutor::new().probe_url( - &stream_url, + probe_url_cow.as_ref(), user_agent.as_deref(), analyze_duration, probe_size,