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

implemented xtream series to m3u playlist.

Browse Source
This commit is contained in:
euzu
2023-12-11 11:15:06 +01:00
parent 1c8abcb01a
commit f7af09a350
6 changed files with 58 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/processing/playlist_processor.rs
+20 -12
View File
@@ -426,22 +426,30 @@ pub(crate) async fn process_playlist<'a>(playlists: &mut [FetchedPlaylist<'a>],
new_fpl.playlist = v;
}
}
let resolve_series =
let (resolve_series, resolve_series_delay) =
if let Some(options) = &target.options {
options.xtream_resolve_series && fpl.input.input_type == InputType::Xtream && target.has_output(&TargetType::M3u)
(options.xtream_resolve_series && fpl.input.input_type == InputType::Xtream && target.has_output(&TargetType::M3u),
options.xtream_resolve_series_delay)
} else {
false
(false, 0)
};
if resolve_series {
get_xtream_playlist_series(fpl, errors).await;
// the original list has now resolved the series info items.
// wee need to pipe them an put them into
// TODO
//for plg in fpl.playlist {
// 1. extract series playlistitems per group
// 2. run processing pipe
// 3. assign results to the new_fpl groups.
//}
let mut series_playlist = get_xtream_playlist_series(fpl, errors, resolve_series_delay).await;
// original content saved into original list
for plg in &series_playlist {
fpl.update_playlist(plg);
}
// run processing pipe over new items
for f in &pipe {
let r = f(&mut series_playlist, target);
if let Some(v) = r {
series_playlist = v;
}
}
// assign new items to the new playlist
for plg in &series_playlist {
new_fpl.update_playlist(plg);
}
}
// stats