1 files changed, 74 insertions, 0 deletions
diff --git a/MediaBrowser.Api/LiveTv/LiveTvService.cs b/MediaBrowser.Api/LiveTv/LiveTvService.cs
new file mode 100644
index 000000000..a7a709aee
--- /dev/null
+++ b/MediaBrowser.Api/LiveTv/LiveTvService.cs
@@ -0,0 +1,74 @@
+using MediaBrowser.Controller.LiveTv;
+using MediaBrowser.Model.LiveTv;
+using ServiceStack.ServiceHost;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace MediaBrowser.Api.LiveTv
+{
+    [Route("/LiveTv/Services", "GET")]
+    [Api(Description = "Gets available live tv services.")]
+    public class GetServices : IReturn<List<LiveTvServiceInfo>>
+    {
+    }
+
+    [Route("/LiveTv/Channels", "GET")]
+    [Api(Description = "Gets available live tv channels.")]
+    public class GetChannels : IReturn<List<ChannelInfoDto>>
+    {
+        // Add filter by service if needed, and/or other filters
+    }
+    
+    public class LiveTvService : BaseApiService
+    {
+        private readonly ILiveTvManager _liveTvManager;
+
+        public LiveTvService(ILiveTvManager liveTvManager)
+        {
+            _liveTvManager = liveTvManager;
+        }
+
+        public object Get(GetServices request)
+        {
+            var services = _liveTvManager.Services;
+
+            var result = services.Select(GetServiceInfo)
+                .ToList();
+
+            return ToOptimizedResult(result);
+        }
+
+        public object Get(GetChannels request)
+        {
+            var services = _liveTvManager.Services;
+
+            var result = services.Select(GetServiceInfo)
+                .ToList();
+
+            return ToOptimizedResult(result);
+        }
+
+        public async Task<IEnumerable<ChannelInfoDto>> GetChannelsAsync(GetChannels request)
+        {
+            var services = _liveTvManager.Services;
+
+            var channelTasks = services.Select(i => i.GetChannelsAsync(CancellationToken.None));
+
+            var channelLists = await Task.WhenAll(channelTasks).ConfigureAwait(false);
+
+            // Aggregate all channels from all services
+            return channelLists.SelectMany(i => i)
+                .Select(_liveTvManager.GetChannelInfoDto);
+        }
+        
+        private LiveTvServiceInfo GetServiceInfo(ILiveTvService service)
+        {
+            return new LiveTvServiceInfo
+            {
+                Name = service.Name
+            };
+        }
+    }
+}