euzu/tuliprox
1
0
Fork 0
mirror of https://github.com/euzu/tuliprox.git synced 2026-10-17 05:12:34 +02:00
Code Issues Packages Projects Releases 5 Wiki Activity

Some refactoring,

Browse Source 
Added input option xtream_live_stream_without_extension
This commit is contained in:
euzu
2025-01-28 13:04:58 +01:00
parent b176a116c1
commit 5cf5ae4cfd
16 changed files with 286 additions and 231 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/processing/playlist_processor.rs
+6 -4
View File
@@ -1,5 +1,8 @@
extern crate unidecode;
use crate::utils::epg_utils;
use crate::utils::m3u_utils;
use crate::utils::xtream_utils;
use crate::repository::storage::hash_string;
use async_std::sync::Mutex;
use core::cmp::Ordering;
@@ -30,7 +33,6 @@ use crate::processing::xtream_processor_series::playlist_resolve_series;
use crate::processing::xtream_processor_vod::playlist_resolve_vod;
use crate::repository::playlist_repository::persist_playlist;
use crate::utils::default_utils::default_as_default;
use crate::utils::download;
use crate::{debug_if_enabled, get_errors_notify_message, model::config, notify_err, Config};
fn is_valid(pli: &PlaylistItem, target: &ConfigTarget) -> bool {
@@ -302,11 +304,11 @@ async fn process_source(client: Arc<reqwest::Client>, cfg: Arc<Config>, source_i
if is_input_enabled(enabled_inputs, input.enabled, input.id, &user_targets) {
let start_time = Instant::now();
let (mut playlistgroups, mut error_list) = match input.input_type {
InputType::M3u => download::get_m3u_playlist(Arc::clone(&client), &cfg, input, &cfg.working_dir).await,
InputType::Xtream => download::get_xtream_playlist(Arc::clone(&client), input, &cfg.working_dir).await,
InputType::M3u => m3u_utils::get_m3u_playlist(Arc::clone(&client), &cfg, input, &cfg.working_dir).await,
InputType::Xtream => xtream_utils::get_xtream_playlist(Arc::clone(&client), input, &cfg.working_dir).await,
};
let (tvguide, mut tvguide_errors) = if error_list.is_empty() {
download::get_xmltv(Arc::clone(&client), &cfg, input, &cfg.working_dir).await
epg_utils::get_xmltv(Arc::clone(&client), &cfg, input, &cfg.working_dir).await
} else {
(None, vec![])
};