1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374 |
- 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
- };
- }
- }
- }
|