feat: Refactor project structure and add core library

- Migrate shared components from WPF to a new Core library. - Introduce GroupInfo, M3UInfo, and ObservableViewModelBase classes. - Implement M3UParser for downloading and parsing M3U files. - Add ProgramsData for managing program lists and guides. - Create SettingsModel for application settings management. - Update project references in solution files.
2026-03-22 13:11:32 +02:00
parent 1e8e444376
commit 689450393b
10 changed files with 614 additions and 6 deletions
@@ -0,0 +1,66 @@
+using System.Reactive;
+using System.Reactive.Subjects;
+
+namespace TV_Player
+{
+    public class ProgramsData
+    {
+        private readonly ReplaySubject<List<M3UInfo>> programsSubject = new ReplaySubject<List<M3UInfo>>();
+        private readonly ReplaySubject<List<GroupInfo>> groupsSubject = new ReplaySubject<List<GroupInfo>>();
+        private readonly ReplaySubject<Unit> programGuideSubject = new ReplaySubject<Unit>();
+        public IObservable<List<M3UInfo>> AllPrograms => programsSubject;
+        public IObservable<List<GroupInfo>> GroupsInformation => groupsSubject;
+        public IObservable<Unit> ProgramGuideInfo => programGuideSubject;
+
+        private readonly string _programName;
+        public ProgramsData(string name,string playlistURL)
+        {
+            _programName = name;
+            Task.Run(() => GetPrograms(name,playlistURL));
+        }
+
+        private async Task GetPrograms(string name,string m3uLink)
+        {
+            System.Diagnostics.Debug.WriteLine($"[ProgramsData] Starting download of: {m3uLink}");
+            //string m3uLink = "http://pl.da-tv.vip/a71e77fa/835b3216/tv.m3u";
+            try
+            {
+                var result = await M3UParser.DownloadM3UFromWebAsync(m3uLink);
+                System.Diagnostics.Debug.WriteLine($"[ProgramsData] Downloaded {result.programList.Count} programs");
+
+                programsSubject.OnNext(result.programList);
+
+                var groupping = result.programList.GroupBy(item => item.GroupTitle)
+                                   .Select(group => new GroupInfo() { Name = group.Key, Count = group.Count() })
+                                   .OrderBy(g => g.Name)
+                                   .ToList();
+                System.Diagnostics.Debug.WriteLine($"[ProgramsData] Publishing {groupping.Count} groups: {string.Join(", ", groupping.Select(g => $"{g.Name}({g.Count})"))}");
+                if (groupping.Count == 0)
+                {
+                    System.Diagnostics.Debug.WriteLine("[ProgramsData] WARNING: No groups found! Check if programs have 'group-title' metadata.");
+                }
+                groupsSubject.OnNext(groupping);
+                
+                await Task.Run(() => GetProgramGuide(name, result.programGuide));
+            }
+            catch (Exception ex)
+            {
+                System.Diagnostics.Debug.WriteLine($"[ProgramsData] ERROR downloading programs: {ex.Message}");
+                throw;
+            }
+        }
+
+        public Task<ProgramGuide> GetGuideByProgram(string channelID)
+        {
+            return M3UParser.ParseEpg(_programName,channelID);
+        }
+
+        private async Task GetProgramGuide(string name, string guideLink)
+        {
+            //guideLink = "http://epg.da-tv.vip/107-light.xml";
+            await M3UParser.DownloadGuideFromWebAsync(name,guideLink);
+            programGuideSubject.OnNext(Unit.Default);
+        }
+        
+    }
+}