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

Fixed category creation during xtream playlist save

Browse Source
This commit is contained in:
euzu
2026-01-04 14:55:19 +01:00
parent c5ecc152e4
commit 5bb32ebc72
5 changed files with 99 additions and 52 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/src/processing/processor/playlist.rs
+2 -2
View File
@@ -567,7 +567,7 @@ fn execute_pipe<'a>(target: &ConfigTarget, pipe: &ProcessingPipe, fpl: &FetchedP
};
if target.options.as_ref().is_some_and(|opt| opt.remove_duplicates) {
for group in &mut new_fpl.playlist_groups {
// `HashSet::insert` returns true for first insert, otherweise false
// `HashSet::insert` returns true for first insert, otherwise false
group.channels.retain(|item| duplicates.insert(duplicate_hash(item)));
}
}
@@ -614,7 +614,6 @@ async fn process_playlist_for_target(app_config: &Arc<AppConfig>,
event_manager: Option<Arc<EventManager>>,
playlist_state: Option<&Arc<PlaylistStorageState>>,
) -> Result<(), Vec<TuliproxError>> {
let pipe = get_processing_pipe(target);
debug_if_enabled!("Processing order is {}", &target.processing_order);
let mut duplicates: HashSet<UUIDType> = HashSet::new();
@@ -623,6 +622,7 @@ async fn process_playlist_for_target(app_config: &Arc<AppConfig>,
debug!("Executing processing pipes");
let broadcast_step = create_broadcast_callback(event_manager.as_ref());
let pipe = get_processing_pipe(target);
let mut step = StepMeasure::new(&target.name, broadcast_step);
for provider_fpl in playlists.iter_mut() {
step.broadcast("Executing transformations on '{}' playlist", &target.name);