Enhancement: Clean up orphaned programs for unmapped EPG entries

CHANGELOG.md

@@ -13,7 +13,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Changed
 
-- **Performance**: EPG program parsing optimized for sources with many channels but only a fraction mapped. Now parses XML file once per source instead of once per channel, dramatically reducing I/O and CPU overhead. For sources with 10,000 channels and 100 mapped, this results in ~99x fewer file opens and ~100x fewer full file scans.
+- **Performance**: EPG program parsing optimized for sources with many channels but only a fraction mapped. Now parses XML file once per source instead of once per channel, dramatically reducing I/O and CPU overhead. For sources with 10,000 channels and 100 mapped, this results in ~99x fewer file opens and ~100x fewer full file scans. Orphaned programs for unmapped channels are also cleaned up during refresh to prevent database bloat.
 - IPv6 access now allowed by default with all IPv6 CIDRs accepted - Thanks [@adrianmace](https://github.com/adrianmace)
 - nginx.conf updated to bind to both IPv4 and IPv6 ports - Thanks [@jordandalley](https://github.com/jordandalley)
 

apps/epg/tasks.py

@@ -1502,6 +1502,17 @@ def parse_programs_for_source(epg_source, tvg_id=None):
         deleted_count = ProgramData.objects.filter(epg_id__in=mapped_epg_ids).delete()[0]
         logger.info(f"Deleted {deleted_count} existing programs")
 
+        # Clean up orphaned programs for unmapped EPG entries
+        # These accumulate if a channel is unmapped after being mapped
+        unmapped_epg_ids = EPGData.objects.filter(
+            epg_source=epg_source
+        ).exclude(id__in=mapped_epg_ids).values_list('id', flat=True)
+
+        if unmapped_epg_ids:
+            orphaned_count = ProgramData.objects.filter(epg_id__in=unmapped_epg_ids).delete()[0]
+            if orphaned_count > 0:
+                logger.info(f"Cleaned up {orphaned_count} orphaned programs for {len(unmapped_epg_ids)} unmapped EPG entries")
+
         # SINGLE PASS PARSING: Parse the XML file once and process all mapped channels
         programs_to_create = []
         programs_by_channel = {tvg_id: 0 for tvg_id in mapped_tvg_ids}  # Track count per channel