diff options
Diffstat (limited to 'Emby.Server.Implementations')
4 files changed, 258 insertions, 0 deletions
diff --git a/Emby.Server.Implementations/Emby.Server.Implementations.csproj b/Emby.Server.Implementations/Emby.Server.Implementations.csproj index 7829193c5..322b6773f 100644 --- a/Emby.Server.Implementations/Emby.Server.Implementations.csproj +++ b/Emby.Server.Implementations/Emby.Server.Implementations.csproj @@ -109,6 +109,9 @@ <Compile Include="Library\Validators\StudiosPostScanTask.cs" /> <Compile Include="Library\Validators\StudiosValidator.cs" /> <Compile Include="Library\Validators\YearsPostScanTask.cs" /> + <Compile Include="LiveTv\ChannelImageProvider.cs" /> + <Compile Include="LiveTv\ProgramImageProvider.cs" /> + <Compile Include="LiveTv\RecordingImageProvider.cs" /> <Compile Include="Logging\PatternsLogger.cs" /> <Compile Include="MediaEncoder\EncodingManager.cs" /> <Compile Include="News\NewsEntryPoint.cs" /> diff --git a/Emby.Server.Implementations/LiveTv/ChannelImageProvider.cs b/Emby.Server.Implementations/LiveTv/ChannelImageProvider.cs new file mode 100644 index 000000000..95cefd999 --- /dev/null +++ b/Emby.Server.Implementations/LiveTv/ChannelImageProvider.cs @@ -0,0 +1,85 @@ +using MediaBrowser.Common; +using MediaBrowser.Common.Net; +using MediaBrowser.Controller.Entities; +using MediaBrowser.Controller.LiveTv; +using MediaBrowser.Controller.Providers; +using MediaBrowser.Model.Entities; +using MediaBrowser.Model.Logging; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Threading; +using System.Threading.Tasks; + +namespace Emby.Server.Implementations.LiveTv +{ + public class ChannelImageProvider : IDynamicImageProvider, IHasItemChangeMonitor + { + private readonly ILiveTvManager _liveTvManager; + private readonly IHttpClient _httpClient; + private readonly ILogger _logger; + private readonly IApplicationHost _appHost; + + public ChannelImageProvider(ILiveTvManager liveTvManager, IHttpClient httpClient, ILogger logger, IApplicationHost appHost) + { + _liveTvManager = liveTvManager; + _httpClient = httpClient; + _logger = logger; + _appHost = appHost; + } + + public IEnumerable<ImageType> GetSupportedImages(IHasImages item) + { + return new[] { ImageType.Primary }; + } + + public async Task<DynamicImageResponse> GetImage(IHasImages item, ImageType type, CancellationToken cancellationToken) + { + var liveTvItem = (LiveTvChannel)item; + + var imageResponse = new DynamicImageResponse(); + + var service = _liveTvManager.Services.FirstOrDefault(i => string.Equals(i.Name, liveTvItem.ServiceName, StringComparison.OrdinalIgnoreCase)); + + if (service != null && !item.HasImage(ImageType.Primary)) + { + try + { + var response = await service.GetChannelImageAsync(liveTvItem.ExternalId, cancellationToken).ConfigureAwait(false); + + if (response != null) + { + imageResponse.HasImage = true; + imageResponse.Stream = response.Stream; + imageResponse.Format = response.Format; + } + } + catch (NotImplementedException) + { + } + } + + return imageResponse; + } + + public string Name + { + get { return "Live TV Service Provider"; } + } + + public bool Supports(IHasImages item) + { + return item is LiveTvChannel; + } + + public int Order + { + get { return 0; } + } + + public bool HasChanged(IHasMetadata item, IDirectoryService directoryService) + { + return GetSupportedImages(item).Any(i => !item.HasImage(i)); + } + } +} diff --git a/Emby.Server.Implementations/LiveTv/ProgramImageProvider.cs b/Emby.Server.Implementations/LiveTv/ProgramImageProvider.cs new file mode 100644 index 000000000..f5d298af4 --- /dev/null +++ b/Emby.Server.Implementations/LiveTv/ProgramImageProvider.cs @@ -0,0 +1,88 @@ +using MediaBrowser.Controller.Entities; +using MediaBrowser.Controller.LiveTv; +using MediaBrowser.Controller.Providers; +using MediaBrowser.Model.Entities; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Threading; +using System.Threading.Tasks; + +namespace Emby.Server.Implementations.LiveTv +{ + public class ProgramImageProvider : IDynamicImageProvider, IHasItemChangeMonitor, IHasOrder + { + private readonly ILiveTvManager _liveTvManager; + + public ProgramImageProvider(ILiveTvManager liveTvManager) + { + _liveTvManager = liveTvManager; + } + + public IEnumerable<ImageType> GetSupportedImages(IHasImages item) + { + return new[] { ImageType.Primary }; + } + + public async Task<DynamicImageResponse> GetImage(IHasImages item, ImageType type, CancellationToken cancellationToken) + { + var liveTvItem = (LiveTvProgram)item; + + var imageResponse = new DynamicImageResponse(); + + var service = _liveTvManager.Services.FirstOrDefault(i => string.Equals(i.Name, liveTvItem.ServiceName, StringComparison.OrdinalIgnoreCase)); + + if (service != null) + { + try + { + var channel = _liveTvManager.GetInternalChannel(liveTvItem.ChannelId); + + var response = await service.GetProgramImageAsync(liveTvItem.ExternalId, channel.ExternalId, cancellationToken).ConfigureAwait(false); + + if (response != null) + { + imageResponse.HasImage = true; + imageResponse.Stream = response.Stream; + imageResponse.Format = response.Format; + } + } + catch (NotImplementedException) + { + } + } + + return imageResponse; + } + + public string Name + { + get { return "Live TV Service Provider"; } + } + + public bool Supports(IHasImages item) + { + return item is LiveTvProgram; + } + + public int Order + { + get + { + // Let the better providers run first + return 100; + } + } + + public bool HasChanged(IHasMetadata item, IDirectoryService directoryService) + { + var liveTvItem = item as LiveTvProgram; + + if (liveTvItem != null) + { + return !liveTvItem.HasImage(ImageType.Primary); + } + return false; + } + } +} diff --git a/Emby.Server.Implementations/LiveTv/RecordingImageProvider.cs b/Emby.Server.Implementations/LiveTv/RecordingImageProvider.cs new file mode 100644 index 000000000..47663bdbc --- /dev/null +++ b/Emby.Server.Implementations/LiveTv/RecordingImageProvider.cs @@ -0,0 +1,82 @@ +using MediaBrowser.Controller.Entities; +using MediaBrowser.Controller.LiveTv; +using MediaBrowser.Controller.Providers; +using MediaBrowser.Model.Entities; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Threading; +using System.Threading.Tasks; + +namespace Emby.Server.Implementations.LiveTv +{ + public class RecordingImageProvider : IDynamicImageProvider, IHasItemChangeMonitor + { + private readonly ILiveTvManager _liveTvManager; + + public RecordingImageProvider(ILiveTvManager liveTvManager) + { + _liveTvManager = liveTvManager; + } + + public IEnumerable<ImageType> GetSupportedImages(IHasImages item) + { + return new[] { ImageType.Primary }; + } + + public async Task<DynamicImageResponse> GetImage(IHasImages item, ImageType type, CancellationToken cancellationToken) + { + var liveTvItem = (ILiveTvRecording)item; + + var imageResponse = new DynamicImageResponse(); + + var service = _liveTvManager.Services.FirstOrDefault(i => string.Equals(i.Name, liveTvItem.ServiceName, StringComparison.OrdinalIgnoreCase)); + + if (service != null) + { + try + { + var response = await service.GetRecordingImageAsync(liveTvItem.ExternalId, cancellationToken).ConfigureAwait(false); + + if (response != null) + { + imageResponse.HasImage = true; + imageResponse.Stream = response.Stream; + imageResponse.Format = response.Format; + } + } + catch (NotImplementedException) + { + } + } + + return imageResponse; + } + + public string Name + { + get { return "Live TV Service Provider"; } + } + + public bool Supports(IHasImages item) + { + return item is ILiveTvRecording; + } + + public int Order + { + get { return 0; } + } + + public bool HasChanged(IHasMetadata item, IDirectoryService directoryService) + { + var liveTvItem = item as ILiveTvRecording; + + if (liveTvItem != null) + { + return !liveTvItem.HasImage(ImageType.Primary); + } + return false; + } + } +} |