jellyfin-server/MediaBrowser.Server.Implementations/Channels/ChannelManager.cs

1642 lines
57 KiB
C#
Raw Normal View History

using MediaBrowser.Common.Extensions;
2014-09-30 04:47:30 +00:00
using MediaBrowser.Common.Net;
2014-03-18 01:45:41 +00:00
using MediaBrowser.Controller.Channels;
using MediaBrowser.Controller.Configuration;
using MediaBrowser.Controller.Dto;
using MediaBrowser.Controller.Entities;
using MediaBrowser.Controller.Library;
2014-06-07 19:46:24 +00:00
using MediaBrowser.Controller.Localization;
2014-03-18 01:45:41 +00:00
using MediaBrowser.Controller.Providers;
using MediaBrowser.Model.Channels;
using MediaBrowser.Model.Dto;
2014-05-03 04:20:04 +00:00
using MediaBrowser.Model.Entities;
2015-01-17 20:12:02 +00:00
using MediaBrowser.Model.Extensions;
2014-03-18 01:45:41 +00:00
using MediaBrowser.Model.Logging;
2014-09-30 04:47:30 +00:00
using MediaBrowser.Model.MediaInfo;
using MediaBrowser.Model.Net;
2014-03-18 01:45:41 +00:00
using MediaBrowser.Model.Querying;
2014-05-04 14:19:46 +00:00
using MediaBrowser.Model.Serialization;
2014-03-18 01:45:41 +00:00
using System;
2014-07-09 00:46:11 +00:00
using System.Collections.Concurrent;
2014-03-18 01:45:41 +00:00
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
2014-03-18 01:45:41 +00:00
using System.Threading;
using System.Threading.Tasks;
2015-10-04 04:23:11 +00:00
using CommonIO;
2016-03-19 05:04:38 +00:00
using MediaBrowser.Controller.Entities.Audio;
2016-03-19 15:38:05 +00:00
using MediaBrowser.Controller.Entities.Movies;
using MediaBrowser.Controller.Entities.TV;
2014-03-18 01:45:41 +00:00
namespace MediaBrowser.Server.Implementations.Channels
{
public class ChannelManager : IChannelManager
2014-03-18 01:45:41 +00:00
{
private IChannel[] _channels;
private readonly IUserManager _userManager;
2014-05-03 04:20:04 +00:00
private readonly IUserDataManager _userDataManager;
2014-03-18 01:45:41 +00:00
private readonly IDtoService _dtoService;
private readonly ILibraryManager _libraryManager;
private readonly ILogger _logger;
private readonly IServerConfigurationManager _config;
private readonly IFileSystem _fileSystem;
2014-05-04 14:19:46 +00:00
private readonly IJsonSerializer _jsonSerializer;
2014-09-30 04:47:30 +00:00
private readonly IHttpClient _httpClient;
2015-10-17 15:05:12 +00:00
private readonly IProviderManager _providerManager;
2014-03-18 01:45:41 +00:00
2014-06-07 19:46:24 +00:00
private readonly ILocalizationManager _localization;
2014-06-20 04:50:30 +00:00
private readonly ConcurrentDictionary<Guid, bool> _refreshedItems = new ConcurrentDictionary<Guid, bool>();
2015-10-17 15:05:12 +00:00
public ChannelManager(IUserManager userManager, IDtoService dtoService, ILibraryManager libraryManager, ILogger logger, IServerConfigurationManager config, IFileSystem fileSystem, IUserDataManager userDataManager, IJsonSerializer jsonSerializer, ILocalizationManager localization, IHttpClient httpClient, IProviderManager providerManager)
2014-03-18 01:45:41 +00:00
{
_userManager = userManager;
_dtoService = dtoService;
_libraryManager = libraryManager;
_logger = logger;
_config = config;
_fileSystem = fileSystem;
2014-05-03 04:20:04 +00:00
_userDataManager = userDataManager;
2014-05-04 14:19:46 +00:00
_jsonSerializer = jsonSerializer;
2014-06-07 19:46:24 +00:00
_localization = localization;
2014-09-30 04:47:30 +00:00
_httpClient = httpClient;
2015-10-17 15:05:12 +00:00
_providerManager = providerManager;
2014-03-18 01:45:41 +00:00
}
private TimeSpan CacheLength
{
get
{
2014-09-22 21:56:54 +00:00
return TimeSpan.FromHours(6);
}
}
2015-09-16 03:55:26 +00:00
public void AddParts(IEnumerable<IChannel> channels)
2014-03-18 01:45:41 +00:00
{
2015-09-16 03:55:26 +00:00
_channels = channels.ToArray();
2014-05-03 23:38:23 +00:00
}
2014-06-02 19:32:41 +00:00
public string ChannelDownloadPath
{
get
{
var options = _config.GetChannelsConfiguration();
if (!string.IsNullOrWhiteSpace(options.DownloadPath))
2014-06-02 19:32:41 +00:00
{
return options.DownloadPath;
2014-06-02 19:32:41 +00:00
}
return Path.Combine(_config.ApplicationPaths.ProgramDataPath, "channels");
}
}
2014-05-03 23:38:23 +00:00
private IEnumerable<IChannel> GetAllChannels()
{
2015-09-16 03:55:26 +00:00
return _channels
2014-05-03 23:38:23 +00:00
.OrderBy(i => i.Name);
2014-03-18 01:45:41 +00:00
}
2015-11-21 05:01:16 +00:00
public IEnumerable<Guid> GetInstalledChannelIds()
{
return GetAllChannels().Select(i => GetInternalChannelId(i.Name));
}
2014-07-30 03:31:35 +00:00
public Task<QueryResult<Channel>> GetChannelsInternal(ChannelQuery query, CancellationToken cancellationToken)
2014-03-18 01:45:41 +00:00
{
var user = string.IsNullOrWhiteSpace(query.UserId)
? null
2014-09-14 15:10:51 +00:00
: _userManager.GetUserById(query.UserId);
2014-03-18 01:45:41 +00:00
var channels = GetAllChannels()
.Select(GetChannelEntity)
.OrderBy(i => i.SortName)
.ToList();
2014-03-18 01:45:41 +00:00
2014-06-17 16:03:14 +00:00
if (query.SupportsLatestItems.HasValue)
{
var val = query.SupportsLatestItems.Value;
channels = channels.Where(i =>
{
try
{
2016-03-27 21:11:27 +00:00
return GetChannelProvider(i) is ISupportsLatestMedia == val;
}
catch
{
return false;
}
}).ToList();
2014-06-17 16:03:14 +00:00
}
2014-06-23 16:05:19 +00:00
if (query.IsFavorite.HasValue)
{
var val = query.IsFavorite.Value;
2016-04-30 22:05:13 +00:00
channels = channels.Where(i => _userDataManager.GetUserData(user, i).IsFavorite == val)
2014-06-23 16:05:19 +00:00
.ToList();
}
2014-06-17 16:03:14 +00:00
2014-03-18 01:45:41 +00:00
if (user != null)
{
2015-10-19 15:33:49 +00:00
channels = channels.Where(i =>
{
if (!i.IsVisible(user))
{
return false;
}
try
{
return GetChannelProvider(i).IsEnabledFor(user.Id.ToString("N"));
}
catch
{
return false;
}
}).ToList();
2014-03-18 01:45:41 +00:00
}
2014-05-14 18:04:26 +00:00
var all = channels;
var totalCount = all.Count;
if (query.StartIndex.HasValue)
{
all = all.Skip(query.StartIndex.Value).ToList();
}
if (query.Limit.HasValue)
{
all = all.Take(query.Limit.Value).ToList();
}
2014-05-18 19:58:42 +00:00
2014-07-30 03:31:35 +00:00
var returnItems = all.ToArray();
var result = new QueryResult<Channel>
{
Items = returnItems,
TotalRecordCount = totalCount
};
return Task.FromResult(result);
}
public async Task<QueryResult<BaseItemDto>> GetChannels(ChannelQuery query, CancellationToken cancellationToken)
{
var user = string.IsNullOrWhiteSpace(query.UserId)
? null
2014-09-14 15:10:51 +00:00
: _userManager.GetUserById(query.UserId);
2014-07-30 03:31:35 +00:00
var internalResult = await GetChannelsInternal(query, cancellationToken).ConfigureAwait(false);
2014-12-27 05:08:39 +00:00
var dtoOptions = new DtoOptions();
2014-03-18 01:45:41 +00:00
2016-06-19 06:18:29 +00:00
var returnItems = (await _dtoService.GetBaseItemDtos(internalResult.Items, dtoOptions, user).ConfigureAwait(false))
2014-03-18 01:45:41 +00:00
.ToArray();
var result = new QueryResult<BaseItemDto>
{
Items = returnItems,
2014-07-30 03:31:35 +00:00
TotalRecordCount = internalResult.TotalRecordCount
2014-03-18 01:45:41 +00:00
};
2014-07-30 03:31:35 +00:00
return result;
2014-03-18 01:45:41 +00:00
}
public async Task RefreshChannels(IProgress<double> progress, CancellationToken cancellationToken)
{
_refreshedItems.Clear();
2014-05-03 23:38:23 +00:00
var allChannelsList = GetAllChannels().ToList();
2014-03-18 01:45:41 +00:00
var numComplete = 0;
foreach (var channelInfo in allChannelsList)
{
cancellationToken.ThrowIfCancellationRequested();
try
{
2015-10-25 17:13:30 +00:00
await GetChannel(channelInfo, cancellationToken).ConfigureAwait(false);
2014-03-18 01:45:41 +00:00
}
catch (OperationCanceledException)
{
throw;
}
catch (Exception ex)
{
_logger.ErrorException("Error getting channel information for {0}", ex, channelInfo.Name);
}
numComplete++;
double percent = numComplete;
percent /= allChannelsList.Count;
progress.Report(100 * percent);
}
progress.Report(100);
}
private Channel GetChannelEntity(IChannel channel)
{
var item = GetChannel(GetInternalChannelId(channel.Name).ToString("N"));
if (item == null)
{
item = GetChannel(channel, CancellationToken.None).Result;
}
return item;
}
2016-03-19 04:22:33 +00:00
public async Task<IEnumerable<MediaSourceInfo>> GetStaticMediaSources(BaseItem item, bool includeCachedVersions, CancellationToken cancellationToken)
2014-05-18 19:58:42 +00:00
{
2016-03-19 04:22:33 +00:00
IEnumerable<ChannelMediaInfo> results = new List<ChannelMediaInfo>();
2016-03-19 15:38:05 +00:00
var video = item as Video;
2016-03-19 04:22:33 +00:00
if (video != null)
{
results = video.ChannelMediaSources;
}
2016-03-19 05:14:47 +00:00
var audio = item as Audio;
2016-03-19 04:22:33 +00:00
if (audio != null)
{
2016-03-19 05:14:47 +00:00
results = audio.ChannelMediaSources ?? new List<ChannelMediaInfo>();
2016-03-19 04:22:33 +00:00
}
2014-05-18 19:58:42 +00:00
2015-03-28 20:22:27 +00:00
var sources = SortMediaInfoResults(results)
.Select(i => GetMediaSource(item, i))
.ToList();
if (includeCachedVersions)
{
var cachedVersions = GetCachedChannelItemMediaSources(item);
sources.InsertRange(0, cachedVersions);
}
2015-07-23 05:25:55 +00:00
return sources;
2015-03-28 20:22:27 +00:00
}
2016-03-19 04:22:33 +00:00
public async Task<IEnumerable<MediaSourceInfo>> GetDynamicMediaSources(BaseItem item, CancellationToken cancellationToken)
2015-03-28 20:22:27 +00:00
{
var channel = GetChannel(item.ChannelId);
2014-05-18 22:26:06 +00:00
var channelPlugin = GetChannelProvider(channel);
2014-05-18 19:58:42 +00:00
2014-05-18 22:26:06 +00:00
var requiresCallback = channelPlugin as IRequiresMediaInfoCallback;
2014-05-18 19:58:42 +00:00
2014-06-02 19:32:41 +00:00
IEnumerable<ChannelMediaInfo> results;
2015-03-28 20:22:27 +00:00
if (requiresCallback != null)
2014-05-18 19:58:42 +00:00
{
2014-06-20 04:50:30 +00:00
results = await GetChannelItemMediaSourcesInternal(requiresCallback, item.ExternalId, cancellationToken)
2015-03-28 20:22:27 +00:00
.ConfigureAwait(false);
2014-06-02 19:32:41 +00:00
}
else
{
2015-03-28 20:22:27 +00:00
results = new List<ChannelMediaInfo>();
2014-05-18 19:58:42 +00:00
}
2015-03-28 20:22:27 +00:00
var list = SortMediaInfoResults(results)
.Select(i => GetMediaSource(item, i))
2014-06-02 19:32:41 +00:00
.ToList();
2014-06-03 02:01:30 +00:00
var cachedVersions = GetCachedChannelItemMediaSources(item);
2015-03-28 20:22:27 +00:00
list.InsertRange(0, cachedVersions);
2014-06-02 19:32:41 +00:00
2015-03-28 20:22:27 +00:00
return list;
2014-06-02 19:32:41 +00:00
}
2014-06-20 04:50:30 +00:00
private readonly ConcurrentDictionary<string, Tuple<DateTime, List<ChannelMediaInfo>>> _channelItemMediaInfo =
new ConcurrentDictionary<string, Tuple<DateTime, List<ChannelMediaInfo>>>();
private async Task<IEnumerable<ChannelMediaInfo>> GetChannelItemMediaSourcesInternal(IRequiresMediaInfoCallback channel, string id, CancellationToken cancellationToken)
{
Tuple<DateTime, List<ChannelMediaInfo>> cachedInfo;
if (_channelItemMediaInfo.TryGetValue(id, out cachedInfo))
{
if ((DateTime.UtcNow - cachedInfo.Item1).TotalMinutes < 5)
{
return cachedInfo.Item2;
}
}
var mediaInfo = await channel.GetChannelItemMediaInfo(id, cancellationToken)
.ConfigureAwait(false);
var list = mediaInfo.ToList();
var item2 = new Tuple<DateTime, List<ChannelMediaInfo>>(DateTime.UtcNow, list);
_channelItemMediaInfo.AddOrUpdate(id, item2, (key, oldValue) => item2);
return list;
}
2016-03-19 04:22:33 +00:00
private IEnumerable<MediaSourceInfo> GetCachedChannelItemMediaSources(BaseItem item)
2014-06-02 19:32:41 +00:00
{
2014-06-03 02:01:30 +00:00
var filenamePrefix = item.Id.ToString("N");
var parentPath = Path.Combine(ChannelDownloadPath, item.ChannelId);
2014-06-02 19:32:41 +00:00
try
{
2015-09-29 17:35:23 +00:00
var files = _fileSystem.GetFiles(parentPath);
2014-06-02 19:32:41 +00:00
2014-06-03 02:01:30 +00:00
if (string.Equals(item.MediaType, MediaType.Video, StringComparison.OrdinalIgnoreCase))
2014-06-02 19:32:41 +00:00
{
2014-11-16 20:44:08 +00:00
files = files.Where(i => _libraryManager.IsVideoFile(i.FullName));
2014-06-03 02:01:30 +00:00
}
else
{
2014-11-16 20:44:08 +00:00
files = files.Where(i => _libraryManager.IsAudioFile(i.FullName));
2014-06-03 02:01:30 +00:00
}
2015-04-06 03:47:01 +00:00
2014-06-03 02:01:30 +00:00
var file = files
.FirstOrDefault(i => i.Name.StartsWith(filenamePrefix, StringComparison.OrdinalIgnoreCase));
2014-06-02 19:32:41 +00:00
2014-06-03 02:01:30 +00:00
if (file != null)
{
var cachedItem = _libraryManager.ResolvePath(file);
if (cachedItem != null)
2014-06-02 19:32:41 +00:00
{
2014-06-03 02:01:30 +00:00
var hasMediaSources = _libraryManager.GetItemById(cachedItem.Id) as IHasMediaSources;
if (hasMediaSources != null)
{
var source = hasMediaSources.GetMediaSources(true).FirstOrDefault();
if (source != null)
{
return new[] { source };
}
}
2014-06-02 19:32:41 +00:00
}
}
}
catch (DirectoryNotFoundException)
{
2014-06-03 02:01:30 +00:00
2014-06-02 19:32:41 +00:00
}
2014-06-03 02:01:30 +00:00
return new List<MediaSourceInfo>();
}
2016-03-19 04:22:33 +00:00
private MediaSourceInfo GetMediaSource(BaseItem item, ChannelMediaInfo info)
2014-06-03 02:01:30 +00:00
{
2014-10-15 04:11:40 +00:00
var source = info.ToMediaSource();
2014-06-03 02:01:30 +00:00
2014-10-15 04:11:40 +00:00
source.RunTimeTicks = source.RunTimeTicks ?? item.RunTimeTicks;
2014-10-08 01:37:45 +00:00
2014-06-03 02:01:30 +00:00
return source;
2014-06-02 19:32:41 +00:00
}
private IEnumerable<ChannelMediaInfo> SortMediaInfoResults(IEnumerable<ChannelMediaInfo> channelMediaSources)
{
var list = channelMediaSources.ToList();
var options = _config.GetChannelsConfiguration();
var width = options.PreferredStreamingWidth;
2014-06-02 19:32:41 +00:00
if (width.HasValue)
{
var val = width.Value;
2014-07-11 04:27:46 +00:00
var res = list
2016-03-27 21:11:27 +00:00
.OrderBy(i => i.Width.HasValue && i.Width.Value <= val ? 0 : 1)
2014-07-11 04:27:46 +00:00
.ThenBy(i => Math.Abs((i.Width ?? 0) - val))
2014-06-02 19:32:41 +00:00
.ThenByDescending(i => i.Width ?? 0)
2014-07-11 04:27:46 +00:00
.ThenBy(list.IndexOf)
.ToList();
return res;
2014-06-02 19:32:41 +00:00
}
return list
.OrderByDescending(i => i.Width ?? 0)
.ThenBy(list.IndexOf);
2014-05-18 19:58:42 +00:00
}
2014-03-18 01:45:41 +00:00
private async Task<Channel> GetChannel(IChannel channelInfo, CancellationToken cancellationToken)
{
2015-11-21 05:01:16 +00:00
var parentFolder = await GetInternalChannelFolder(cancellationToken).ConfigureAwait(false);
var parentFolderId = parentFolder.Id;
2015-01-24 04:50:45 +00:00
var id = GetInternalChannelId(channelInfo.Name);
2016-03-19 19:32:37 +00:00
var idString = id.ToString("N");
2015-01-24 04:50:45 +00:00
var path = Channel.GetInternalMetadataPath(_config.ApplicationPaths.InternalMetadataPath, id);
2014-03-18 01:45:41 +00:00
var isNew = false;
2015-11-21 05:01:16 +00:00
var forceUpdate = false;
2014-03-18 01:45:41 +00:00
var item = _libraryManager.GetItemById(id) as Channel;
if (item == null)
{
item = new Channel
{
Name = channelInfo.Name,
Id = id,
2015-10-04 03:38:46 +00:00
DateCreated = _fileSystem.GetCreationTimeUtc(path),
2015-11-21 05:01:16 +00:00
DateModified = _fileSystem.GetLastWriteTimeUtc(path)
2014-03-18 01:45:41 +00:00
};
isNew = true;
}
2015-11-21 05:01:16 +00:00
if (!string.Equals(item.Path, path, StringComparison.OrdinalIgnoreCase))
2015-11-06 15:02:22 +00:00
{
2015-11-21 04:57:11 +00:00
isNew = true;
2015-11-02 17:25:01 +00:00
}
2015-11-21 05:01:16 +00:00
item.Path = path;
2016-03-19 19:32:37 +00:00
if (!string.Equals(item.ChannelId, idString, StringComparison.OrdinalIgnoreCase))
2015-11-21 05:01:16 +00:00
{
forceUpdate = true;
}
2016-03-19 19:32:37 +00:00
item.ChannelId = idString;
2015-11-21 05:01:16 +00:00
if (item.ParentId != parentFolderId)
{
forceUpdate = true;
}
item.ParentId = parentFolderId;
2015-09-29 17:35:23 +00:00
2014-06-07 19:46:24 +00:00
item.OfficialRating = GetOfficialRating(channelInfo.ParentalRating);
item.Overview = channelInfo.Description;
item.HomePageUrl = channelInfo.HomePageUrl;
2014-03-18 01:45:41 +00:00
2015-10-20 02:06:05 +00:00
if (string.IsNullOrWhiteSpace(item.Name))
2014-03-18 01:45:41 +00:00
{
item.Name = channelInfo.Name;
}
2015-11-21 04:57:11 +00:00
2015-11-21 05:01:16 +00:00
if (isNew)
{
await _libraryManager.CreateItem(item, cancellationToken).ConfigureAwait(false);
}
else if (forceUpdate)
{
await item.UpdateToRepository(ItemUpdateType.None, cancellationToken).ConfigureAwait(false);
}
2014-03-18 01:45:41 +00:00
2015-11-21 05:01:16 +00:00
await item.RefreshMetadata(new MetadataRefreshOptions(_fileSystem), cancellationToken);
2014-03-18 01:45:41 +00:00
return item;
}
2014-06-06 17:14:02 +00:00
private string GetOfficialRating(ChannelParentalRating rating)
{
switch (rating)
{
case ChannelParentalRating.Adult:
return "XXX";
case ChannelParentalRating.UsR:
return "R";
case ChannelParentalRating.UsPG13:
return "PG-13";
case ChannelParentalRating.UsPG:
return "PG";
default:
return null;
}
}
public Channel GetChannel(string id)
{
2016-03-19 19:32:37 +00:00
return _libraryManager.GetItemById(id) as Channel;
}
2014-06-02 19:32:41 +00:00
public IEnumerable<ChannelFeatures> GetAllChannelFeatures()
{
2016-03-20 06:46:51 +00:00
return _libraryManager.GetItemList(new InternalItemsQuery
2015-10-20 02:06:05 +00:00
{
IncludeItemTypes = new[] { typeof(Channel).Name },
SortBy = new[] { ItemSortBy.SortName }
2016-03-20 06:46:51 +00:00
}).Select(i => GetChannelFeatures(i.Id.ToString("N")));
2014-06-02 19:32:41 +00:00
}
2014-05-27 17:09:48 +00:00
public ChannelFeatures GetChannelFeatures(string id)
{
2016-03-19 19:32:37 +00:00
if (string.IsNullOrWhiteSpace(id))
{
throw new ArgumentNullException("id");
}
2014-05-27 17:09:48 +00:00
var channel = GetChannel(id);
var channelProvider = GetChannelProvider(channel);
2014-06-06 17:14:02 +00:00
return GetChannelFeaturesDto(channel, channelProvider, channelProvider.GetChannelFeatures());
2014-05-27 17:57:29 +00:00
}
2014-06-06 17:14:02 +00:00
public ChannelFeatures GetChannelFeaturesDto(Channel channel,
IChannel provider,
InternalChannelFeatures features)
2014-05-27 17:57:29 +00:00
{
2014-06-06 17:14:02 +00:00
var isIndexable = provider is IIndexableChannel;
var supportsLatest = provider is ISupportsLatestMedia;
2014-06-06 17:14:02 +00:00
2014-05-27 17:57:29 +00:00
return new ChannelFeatures
{
CanFilter = !features.MaxPageSize.HasValue,
2014-06-06 17:14:02 +00:00
CanSearch = provider is ISearchableChannel,
2014-05-27 17:57:29 +00:00
ContentTypes = features.ContentTypes,
DefaultSortFields = features.DefaultSortFields,
MaxPageSize = features.MaxPageSize,
MediaTypes = features.MediaTypes,
2014-06-02 19:32:41 +00:00
SupportsSortOrderToggle = features.SupportsSortOrderToggle,
SupportsLatestMedia = supportsLatest,
2014-06-02 19:32:41 +00:00
Name = channel.Name,
Id = channel.Id.ToString("N"),
2015-02-11 03:28:34 +00:00
SupportsContentDownloading = features.SupportsContentDownloading && (isIndexable || supportsLatest),
2014-09-28 15:27:26 +00:00
AutoRefreshLevels = features.AutoRefreshLevels
2014-05-27 17:57:29 +00:00
};
2014-05-27 17:09:48 +00:00
}
2014-03-18 01:45:41 +00:00
private Guid GetInternalChannelId(string name)
{
if (string.IsNullOrWhiteSpace(name))
{
throw new ArgumentNullException("name");
}
return _libraryManager.GetNewItemId("Channel " + name, typeof(Channel));
2014-03-18 01:45:41 +00:00
}
public async Task<QueryResult<BaseItemDto>> GetLatestChannelItems(AllChannelMediaQuery query, CancellationToken cancellationToken)
2014-09-30 04:47:30 +00:00
{
var user = string.IsNullOrWhiteSpace(query.UserId)
? null
: _userManager.GetUserById(query.UserId);
2014-12-16 05:01:57 +00:00
var limit = query.Limit;
2014-12-14 05:23:04 +00:00
// See below about parental control
if (user != null)
{
query.StartIndex = null;
2014-12-16 05:01:57 +00:00
query.Limit = null;
2014-12-14 05:23:04 +00:00
}
2014-09-30 04:47:30 +00:00
var internalResult = await GetLatestChannelItemsInternal(query, cancellationToken).ConfigureAwait(false);
2014-12-14 05:23:04 +00:00
var items = internalResult.Items;
var totalRecordCount = internalResult.TotalRecordCount;
// Supporting parental control is a hack because it has to be done after querying the remote data source
// This will get screwy if apps try to page, so limit to 10 results in an attempt to always keep them on the first page
if (user != null)
{
items = items.Where(i => i.IsVisible(user))
2014-12-16 05:01:57 +00:00
.Take(limit ?? 10)
2014-12-14 05:23:04 +00:00
.ToArray();
totalRecordCount = items.Length;
}
2014-12-27 05:08:39 +00:00
var dtoOptions = new DtoOptions();
2016-06-19 06:18:29 +00:00
var returnItems = (await _dtoService.GetBaseItemDtos(items, dtoOptions, user).ConfigureAwait(false))
2014-09-30 04:47:30 +00:00
.ToArray();
var result = new QueryResult<BaseItemDto>
{
Items = returnItems,
2014-12-14 05:23:04 +00:00
TotalRecordCount = totalRecordCount
2014-09-30 04:47:30 +00:00
};
return result;
}
public async Task<QueryResult<BaseItem>> GetLatestChannelItemsInternal(AllChannelMediaQuery query, CancellationToken cancellationToken)
{
var user = string.IsNullOrWhiteSpace(query.UserId)
? null
2014-09-14 15:10:51 +00:00
: _userManager.GetUserById(query.UserId);
2014-07-11 04:27:46 +00:00
if (!string.IsNullOrWhiteSpace(query.UserId) && user == null)
{
throw new ArgumentException("User not found.");
}
2014-07-18 00:39:07 +00:00
var channels = GetAllChannels();
if (query.ChannelIds.Length > 0)
{
// Avoid implicitly captured closure
var ids = query.ChannelIds;
channels = channels
.Where(i => ids.Contains(GetInternalChannelId(i.Name).ToString("N")))
.ToArray();
}
// Avoid implicitly captured closure
var userId = query.UserId;
var tasks = channels
.Select(async i =>
{
var indexable = i as ISupportsLatestMedia;
if (indexable != null)
{
try
{
2014-06-20 04:50:30 +00:00
var result = await GetLatestItems(indexable, i, userId, cancellationToken).ConfigureAwait(false);
var resultItems = result.ToList();
return new Tuple<IChannel, ChannelItemResult>(i, new ChannelItemResult
{
Items = resultItems,
TotalRecordCount = resultItems.Count
});
}
catch (Exception ex)
{
_logger.ErrorException("Error getting all media from {0}", ex, i.Name);
}
}
return new Tuple<IChannel, ChannelItemResult>(i, new ChannelItemResult());
});
var results = await Task.WhenAll(tasks).ConfigureAwait(false);
var totalCount = results.Length;
IEnumerable<Tuple<IChannel, ChannelItemInfo>> items = results
2014-06-18 05:16:00 +00:00
.SelectMany(i => i.Item2.Items.Select(m => new Tuple<IChannel, ChannelItemInfo>(i.Item1, m)));
if (query.ContentTypes.Length > 0)
{
// Avoid implicitly captured closure
var contentTypes = query.ContentTypes;
items = items.Where(i => contentTypes.Contains(i.Item2.ContentType));
}
2014-09-28 15:27:26 +00:00
if (query.ExtraTypes.Length > 0)
{
// Avoid implicitly captured closure
var contentTypes = query.ExtraTypes;
items = items.Where(i => contentTypes.Contains(i.Item2.ExtraType));
}
// Avoid implicitly captured closure
var token = cancellationToken;
var itemTasks = items.Select(i =>
{
var channelProvider = i.Item1;
var internalChannelId = GetInternalChannelId(channelProvider.Name);
return GetChannelItemEntity(i.Item2, channelProvider, internalChannelId, token);
});
var internalItems = await Task.WhenAll(itemTasks).ConfigureAwait(false);
internalItems = ApplyFilters(internalItems, query.Filters, user).ToArray();
2015-10-17 15:05:12 +00:00
RefreshIfNeeded(internalItems);
if (query.StartIndex.HasValue)
{
internalItems = internalItems.Skip(query.StartIndex.Value).ToArray();
}
if (query.Limit.HasValue)
{
internalItems = internalItems.Take(query.Limit.Value).ToArray();
}
2014-09-30 04:47:30 +00:00
var returnItemArray = internalItems.ToArray();
2014-09-30 04:47:30 +00:00
return new QueryResult<BaseItem>
{
TotalRecordCount = totalCount,
Items = returnItemArray
};
}
2014-06-20 04:50:30 +00:00
private async Task<IEnumerable<ChannelItemInfo>> GetLatestItems(ISupportsLatestMedia indexable, IChannel channel, string userId, CancellationToken cancellationToken)
{
2014-09-22 21:56:54 +00:00
var cacheLength = CacheLength;
2014-06-20 04:50:30 +00:00
var cachePath = GetChannelDataCachePath(channel, userId, "channelmanager-latest", null, false);
try
{
if (_fileSystem.GetLastWriteTimeUtc(cachePath).Add(cacheLength) > DateTime.UtcNow)
{
return _jsonSerializer.DeserializeFromFile<List<ChannelItemInfo>>(cachePath);
}
}
catch (FileNotFoundException)
{
}
catch (DirectoryNotFoundException)
{
}
await _resourcePool.WaitAsync(cancellationToken).ConfigureAwait(false);
try
{
try
{
if (_fileSystem.GetLastWriteTimeUtc(cachePath).Add(cacheLength) > DateTime.UtcNow)
{
return _jsonSerializer.DeserializeFromFile<List<ChannelItemInfo>>(cachePath);
}
}
catch (FileNotFoundException)
{
}
catch (DirectoryNotFoundException)
{
}
var result = await indexable.GetLatestMedia(new ChannelLatestMediaSearch
{
UserId = userId
}, cancellationToken).ConfigureAwait(false);
var resultItems = result.ToList();
CacheResponse(resultItems, cachePath);
return resultItems;
}
finally
{
_resourcePool.Release();
}
}
2014-09-22 21:56:54 +00:00
public async Task<QueryResult<BaseItem>> GetAllMediaInternal(AllChannelMediaQuery query, CancellationToken cancellationToken)
2014-06-02 19:32:41 +00:00
{
2014-07-18 00:39:07 +00:00
var channels = GetAllChannels();
2014-06-02 19:32:41 +00:00
if (query.ChannelIds.Length > 0)
{
// Avoid implicitly captured closure
var ids = query.ChannelIds;
2014-06-02 19:32:41 +00:00
channels = channels
.Where(i => ids.Contains(GetInternalChannelId(i.Name).ToString("N")))
2014-06-02 19:32:41 +00:00
.ToArray();
}
var tasks = channels
.Select(async i =>
{
2014-06-06 17:14:02 +00:00
var indexable = i as IIndexableChannel;
if (indexable != null)
2014-06-02 19:32:41 +00:00
{
2014-06-06 17:14:02 +00:00
try
2014-06-02 19:32:41 +00:00
{
2014-09-28 20:49:43 +00:00
var result = await GetAllItems(indexable, i, new InternalAllChannelMediaQuery
{
UserId = query.UserId,
ContentTypes = query.ContentTypes,
ExtraTypes = query.ExtraTypes,
TrailerTypes = query.TrailerTypes
}, cancellationToken).ConfigureAwait(false);
2014-06-02 19:32:41 +00:00
2014-06-06 17:14:02 +00:00
return new Tuple<IChannel, ChannelItemResult>(i, result);
}
catch (Exception ex)
{
_logger.ErrorException("Error getting all media from {0}", ex, i.Name);
}
2014-06-02 19:32:41 +00:00
}
return new Tuple<IChannel, ChannelItemResult>(i, new ChannelItemResult());
2014-06-02 19:32:41 +00:00
});
var results = await Task.WhenAll(tasks).ConfigureAwait(false);
var totalCount = results.Length;
IEnumerable<Tuple<IChannel, ChannelItemInfo>> items = results
.SelectMany(i => i.Item2.Items.Select(m => new Tuple<IChannel, ChannelItemInfo>(i.Item1, m)))
.OrderBy(i => i.Item2.Name);
if (query.StartIndex.HasValue)
{
items = items.Skip(query.StartIndex.Value);
}
if (query.Limit.HasValue)
{
items = items.Take(query.Limit.Value);
}
// Avoid implicitly captured closure
var token = cancellationToken;
var itemTasks = items.Select(i =>
{
var channelProvider = i.Item1;
var internalChannelId = GetInternalChannelId(channelProvider.Name);
return GetChannelItemEntity(i.Item2, channelProvider, internalChannelId, token);
2014-06-02 19:32:41 +00:00
});
var internalItems = await Task.WhenAll(itemTasks).ConfigureAwait(false);
2014-09-22 21:56:54 +00:00
var returnItemArray = internalItems.ToArray();
2014-06-02 19:32:41 +00:00
2014-09-22 21:56:54 +00:00
return new QueryResult<BaseItem>
2014-06-02 19:32:41 +00:00
{
TotalRecordCount = totalCount,
Items = returnItemArray
};
}
2014-09-28 15:27:26 +00:00
2014-09-22 21:56:54 +00:00
public async Task<QueryResult<BaseItemDto>> GetAllMedia(AllChannelMediaQuery query, CancellationToken cancellationToken)
{
var user = string.IsNullOrWhiteSpace(query.UserId)
? null
: _userManager.GetUserById(query.UserId);
var internalResult = await GetAllMediaInternal(query, cancellationToken).ConfigureAwait(false);
2015-10-17 15:05:12 +00:00
RefreshIfNeeded(internalResult.Items);
2014-09-30 04:47:30 +00:00
2014-12-27 05:08:39 +00:00
var dtoOptions = new DtoOptions();
2014-09-22 21:56:54 +00:00
2016-06-19 06:18:29 +00:00
var returnItems = (await _dtoService.GetBaseItemDtos(internalResult.Items, dtoOptions, user).ConfigureAwait(false))
2014-09-22 21:56:54 +00:00
.ToArray();
var result = new QueryResult<BaseItemDto>
{
Items = returnItems,
TotalRecordCount = internalResult.TotalRecordCount
};
return result;
}
2014-06-02 19:32:41 +00:00
2014-09-28 20:49:43 +00:00
private async Task<ChannelItemResult> GetAllItems(IIndexableChannel indexable, IChannel channel, InternalAllChannelMediaQuery query, CancellationToken cancellationToken)
2014-06-20 04:50:30 +00:00
{
2014-10-02 00:28:16 +00:00
var cacheLength = CacheLength;
var folderId = _jsonSerializer.SerializeToString(query).GetMD5().ToString("N");
var cachePath = GetChannelDataCachePath(channel, query.UserId, folderId, null, false);
try
{
if (_fileSystem.GetLastWriteTimeUtc(cachePath).Add(cacheLength) > DateTime.UtcNow)
{
return _jsonSerializer.DeserializeFromFile<ChannelItemResult>(cachePath);
}
}
catch (FileNotFoundException)
{
}
catch (DirectoryNotFoundException)
{
}
await _resourcePool.WaitAsync(cancellationToken).ConfigureAwait(false);
try
{
try
{
if (_fileSystem.GetLastWriteTimeUtc(cachePath).Add(cacheLength) > DateTime.UtcNow)
{
return _jsonSerializer.DeserializeFromFile<ChannelItemResult>(cachePath);
}
}
catch (FileNotFoundException)
{
}
catch (DirectoryNotFoundException)
{
}
var result = await indexable.GetAllMedia(query, cancellationToken).ConfigureAwait(false);
CacheResponse(result, cachePath);
return result;
}
finally
{
_resourcePool.Release();
}
2014-06-20 04:50:30 +00:00
}
2014-09-30 04:47:30 +00:00
public async Task<QueryResult<BaseItem>> GetChannelItemsInternal(ChannelItemQuery query, IProgress<double> progress, CancellationToken cancellationToken)
2014-03-18 01:45:41 +00:00
{
// Get the internal channel entity
var channel = GetChannel(query.ChannelId);
2014-03-18 01:45:41 +00:00
// Find the corresponding channel provider plugin
var channelProvider = GetChannelProvider(channel);
var channelInfo = channelProvider.GetChannelFeatures();
int? providerStartIndex = null;
int? providerLimit = null;
if (channelInfo.MaxPageSize.HasValue)
2014-05-05 00:46:52 +00:00
{
providerStartIndex = query.StartIndex;
2014-05-05 00:46:52 +00:00
2014-05-21 00:56:24 +00:00
if (query.Limit.HasValue && query.Limit.Value > channelInfo.MaxPageSize.Value)
{
2015-08-12 21:39:02 +00:00
query.Limit = Math.Min(query.Limit.Value, channelInfo.MaxPageSize.Value);
}
providerLimit = query.Limit;
2014-07-30 03:31:35 +00:00
// This will cause some providers to fail
if (providerLimit == 0)
{
providerLimit = 1;
}
}
2014-05-05 00:46:52 +00:00
var user = string.IsNullOrWhiteSpace(query.UserId)
? null
2014-09-14 15:10:51 +00:00
: _userManager.GetUserById(query.UserId);
2014-05-05 00:46:52 +00:00
2014-05-27 21:17:48 +00:00
ChannelItemSortField? sortField = null;
ChannelItemSortField parsedField;
2014-06-02 19:32:41 +00:00
if (query.SortBy.Length == 1 &&
2014-05-27 21:17:48 +00:00
Enum.TryParse(query.SortBy[0], true, out parsedField))
{
sortField = parsedField;
}
var sortDescending = query.SortOrder.HasValue && query.SortOrder.Value == SortOrder.Descending;
2014-06-02 19:32:41 +00:00
var itemsResult = await GetChannelItems(channelProvider,
user,
query.FolderId,
providerStartIndex,
providerLimit,
2014-05-27 21:17:48 +00:00
sortField,
sortDescending,
cancellationToken)
.ConfigureAwait(false);
2014-05-18 22:26:06 +00:00
var providerTotalRecordCount = providerLimit.HasValue ? itemsResult.TotalRecordCount : null;
2014-05-05 00:46:52 +00:00
var tasks = itemsResult.Items.Select(i => GetChannelItemEntity(i, channelProvider, channel.Id, cancellationToken));
var internalItems = await Task.WhenAll(tasks).ConfigureAwait(false);
if (user != null)
{
internalItems = internalItems.Where(i => i.IsVisible(user)).ToArray();
2014-03-18 01:45:41 +00:00
if (providerTotalRecordCount.HasValue)
{
providerTotalRecordCount = providerTotalRecordCount.Value;
}
}
2014-05-05 00:46:52 +00:00
2015-10-17 15:05:12 +00:00
return await GetReturnItems(internalItems, providerTotalRecordCount, user, query).ConfigureAwait(false);
2014-03-18 01:45:41 +00:00
}
2014-07-30 03:31:35 +00:00
public async Task<QueryResult<BaseItemDto>> GetChannelItems(ChannelItemQuery query, CancellationToken cancellationToken)
{
var user = string.IsNullOrWhiteSpace(query.UserId)
? null
2014-09-14 15:10:51 +00:00
: _userManager.GetUserById(query.UserId);
2014-07-30 03:31:35 +00:00
2014-09-30 04:47:30 +00:00
var internalResult = await GetChannelItemsInternal(query, new Progress<double>(), cancellationToken).ConfigureAwait(false);
2014-07-30 03:31:35 +00:00
2014-12-27 05:08:39 +00:00
var dtoOptions = new DtoOptions();
2014-07-30 03:31:35 +00:00
2016-06-19 06:18:29 +00:00
var returnItems = (await _dtoService.GetBaseItemDtos(internalResult.Items, dtoOptions, user).ConfigureAwait(false))
2014-07-30 03:31:35 +00:00
.ToArray();
var result = new QueryResult<BaseItemDto>
{
Items = returnItems,
TotalRecordCount = internalResult.TotalRecordCount
};
return result;
}
2014-05-04 14:19:46 +00:00
private readonly SemaphoreSlim _resourcePool = new SemaphoreSlim(1, 1);
2014-05-27 21:17:48 +00:00
private async Task<ChannelItemResult> GetChannelItems(IChannel channel,
User user,
string folderId,
int? startIndex,
int? limit,
ChannelItemSortField? sortField,
bool sortDescending,
CancellationToken cancellationToken)
2014-03-18 01:45:41 +00:00
{
2014-06-06 17:14:02 +00:00
var userId = user.Id.ToString("N");
var cacheLength = CacheLength;
2014-06-06 17:14:02 +00:00
var cachePath = GetChannelDataCachePath(channel, userId, folderId, sortField, sortDescending);
2014-03-18 01:45:41 +00:00
2014-05-04 14:19:46 +00:00
try
2014-03-18 01:45:41 +00:00
{
if (!startIndex.HasValue && !limit.HasValue)
2014-05-04 14:19:46 +00:00
{
2014-06-06 17:14:02 +00:00
if (_fileSystem.GetLastWriteTimeUtc(cachePath).Add(cacheLength) > DateTime.UtcNow)
{
2014-06-20 04:50:30 +00:00
return _jsonSerializer.DeserializeFromFile<ChannelItemResult>(cachePath);
}
2014-05-04 14:19:46 +00:00
}
}
catch (FileNotFoundException)
{
}
catch (DirectoryNotFoundException)
{
}
await _resourcePool.WaitAsync(cancellationToken).ConfigureAwait(false);
try
{
try
{
if (!startIndex.HasValue && !limit.HasValue)
2014-05-04 14:19:46 +00:00
{
2014-06-06 17:14:02 +00:00
if (_fileSystem.GetLastWriteTimeUtc(cachePath).Add(cacheLength) > DateTime.UtcNow)
{
2014-06-20 04:50:30 +00:00
return _jsonSerializer.DeserializeFromFile<ChannelItemResult>(cachePath);
}
2014-05-04 14:19:46 +00:00
}
}
catch (FileNotFoundException)
{
}
catch (DirectoryNotFoundException)
{
}
var query = new InternalChannelItemQuery
{
2014-06-06 17:14:02 +00:00
UserId = userId,
StartIndex = startIndex,
2014-05-27 21:17:48 +00:00
Limit = limit,
SortBy = sortField,
SortDescending = sortDescending
2014-05-04 14:19:46 +00:00
};
if (!string.IsNullOrWhiteSpace(folderId))
2014-05-18 19:58:42 +00:00
{
2016-03-19 04:05:33 +00:00
var categoryItem = _libraryManager.GetItemById(new Guid(folderId));
2014-05-18 19:58:42 +00:00
query.FolderId = categoryItem.ExternalId;
2014-05-18 19:58:42 +00:00
}
2014-05-04 14:19:46 +00:00
var result = await channel.GetChannelItems(query, cancellationToken).ConfigureAwait(false);
if (!startIndex.HasValue && !limit.HasValue)
{
CacheResponse(result, cachePath);
}
2014-05-04 14:19:46 +00:00
return result;
2014-05-04 14:19:46 +00:00
}
finally
{
_resourcePool.Release();
}
}
2014-06-20 04:50:30 +00:00
private void CacheResponse(object result, string path)
2014-05-04 14:19:46 +00:00
{
try
{
2015-09-29 17:35:23 +00:00
_fileSystem.CreateDirectory(Path.GetDirectoryName(path));
2014-05-04 14:19:46 +00:00
_jsonSerializer.SerializeToFile(result, path);
}
catch (Exception ex)
{
_logger.ErrorException("Error writing to channel cache file: {0}", ex, path);
}
}
2014-05-27 21:17:48 +00:00
private string GetChannelDataCachePath(IChannel channel,
2014-06-06 17:14:02 +00:00
string userId,
2014-05-27 21:17:48 +00:00
string folderId,
ChannelItemSortField? sortField,
bool sortDescending)
2014-05-04 14:19:46 +00:00
{
var channelId = GetInternalChannelId(channel.Name).ToString("N");
2014-03-18 01:45:41 +00:00
2014-06-06 17:14:02 +00:00
var userCacheKey = string.Empty;
var hasCacheKey = channel as IHasCacheKey;
if (hasCacheKey != null)
{
userCacheKey = hasCacheKey.GetCacheKey(userId) ?? string.Empty;
}
2014-06-07 19:46:24 +00:00
var filename = string.IsNullOrWhiteSpace(folderId) ? "root" : folderId;
filename += userCacheKey;
2014-03-18 17:05:57 +00:00
2014-06-07 19:46:24 +00:00
var version = (channel.DataVersion ?? string.Empty).GetMD5().ToString("N");
2014-05-27 21:17:48 +00:00
if (sortField.HasValue)
{
filename += "-sortField-" + sortField.Value;
}
if (sortDescending)
{
filename += "-sortDescending";
}
2014-06-07 19:46:24 +00:00
filename = filename.GetMD5().ToString("N");
2014-05-27 21:17:48 +00:00
2014-06-06 17:14:02 +00:00
return Path.Combine(_config.ApplicationPaths.CachePath,
"channels",
channelId,
version,
filename + ".json");
2014-03-18 01:45:41 +00:00
}
2014-09-30 04:47:30 +00:00
private async Task<QueryResult<BaseItem>> GetReturnItems(IEnumerable<BaseItem> items,
int? totalCountFromProvider,
User user,
2015-10-17 15:05:12 +00:00
ChannelItemQuery query)
2014-03-18 01:45:41 +00:00
{
2014-05-05 00:46:52 +00:00
items = ApplyFilters(items, query.Filters, user);
2014-05-03 04:20:04 +00:00
items = _libraryManager.Sort(items, user, query.SortBy, query.SortOrder ?? SortOrder.Ascending);
2014-03-18 01:45:41 +00:00
2014-05-05 00:46:52 +00:00
var all = items.ToList();
var totalCount = totalCountFromProvider ?? all.Count;
2014-05-03 04:20:04 +00:00
if (!totalCountFromProvider.HasValue)
2014-05-03 04:20:04 +00:00
{
if (query.StartIndex.HasValue)
{
all = all.Skip(query.StartIndex.Value).ToList();
}
if (query.Limit.HasValue)
{
all = all.Take(query.Limit.Value).ToList();
}
2014-05-03 04:20:04 +00:00
}
2014-07-30 03:31:35 +00:00
var returnItemArray = all.ToArray();
2015-10-17 15:05:12 +00:00
RefreshIfNeeded(returnItemArray);
2014-03-18 01:45:41 +00:00
2014-07-30 03:31:35 +00:00
return new QueryResult<BaseItem>
2014-03-18 01:45:41 +00:00
{
Items = returnItemArray,
2014-05-03 04:20:04 +00:00
TotalRecordCount = totalCount
2014-03-18 01:45:41 +00:00
};
}
2014-09-28 15:27:26 +00:00
private string GetIdToHash(string externalId, string channelName)
2014-03-18 01:45:41 +00:00
{
2014-05-03 04:20:04 +00:00
// Increment this as needed to force new downloads
2014-05-18 22:26:06 +00:00
// Incorporate Name because it's being used to convert channel entity to provider
2014-09-28 15:27:26 +00:00
return externalId + (channelName ?? string.Empty) + "16";
2014-05-03 04:20:04 +00:00
}
2014-03-18 17:05:57 +00:00
2014-09-28 15:27:26 +00:00
private T GetItemById<T>(string idString, string channelName, string channnelDataVersion, out bool isNew)
2016-03-19 04:05:33 +00:00
where T : BaseItem, new()
2014-05-03 04:20:04 +00:00
{
2014-09-28 15:27:26 +00:00
var id = GetIdToHash(idString, channelName).GetMBId(typeof(T));
2014-03-19 01:35:40 +00:00
2014-09-28 15:27:26 +00:00
T item = null;
2014-05-18 22:26:06 +00:00
2014-09-28 15:27:26 +00:00
try
2014-03-18 17:05:57 +00:00
{
2014-09-28 15:27:26 +00:00
item = _libraryManager.GetItemById(id) as T;
2014-03-18 17:05:57 +00:00
}
2014-09-28 15:27:26 +00:00
catch (Exception ex)
2014-03-18 17:05:57 +00:00
{
2014-09-28 15:27:26 +00:00
_logger.ErrorException("Error retrieving channel item from database", ex);
}
2014-05-03 04:20:04 +00:00
2015-10-04 18:10:50 +00:00
if (item == null || !string.Equals(item.ExternalEtag, channnelDataVersion, StringComparison.Ordinal))
2014-09-28 15:27:26 +00:00
{
item = new T();
isNew = true;
2014-03-18 17:05:57 +00:00
}
else
{
2014-09-28 15:27:26 +00:00
isNew = false;
}
2014-05-03 04:20:04 +00:00
2015-10-04 18:10:50 +00:00
item.ExternalEtag = channnelDataVersion;
2014-09-28 15:27:26 +00:00
item.Id = id;
return item;
}
2014-05-03 04:20:04 +00:00
2014-09-28 15:27:26 +00:00
private async Task<BaseItem> GetChannelItemEntity(ChannelItemInfo info, IChannel channelProvider, Guid internalChannelId, CancellationToken cancellationToken)
{
BaseItem item;
bool isNew;
2015-11-21 05:01:16 +00:00
bool forceUpdate = false;
2014-09-28 15:27:26 +00:00
if (info.Type == ChannelItemType.Folder)
{
2016-03-19 05:04:38 +00:00
if (info.FolderType == ChannelFolderType.MusicAlbum)
{
item = GetItemById<MusicAlbum>(info.Id, channelProvider.Name, channelProvider.DataVersion, out isNew);
}
2016-06-22 04:39:06 +00:00
else if (info.FolderType == ChannelFolderType.MusicArtist)
{
item = GetItemById<MusicArtist>(info.Id, channelProvider.Name, channelProvider.DataVersion, out isNew);
}
2016-03-19 05:04:38 +00:00
else if (info.FolderType == ChannelFolderType.PhotoAlbum)
{
item = GetItemById<PhotoAlbum>(info.Id, channelProvider.Name, channelProvider.DataVersion, out isNew);
}
else if (info.FolderType == ChannelFolderType.Series)
{
item = GetItemById<Series>(info.Id, channelProvider.Name, channelProvider.DataVersion, out isNew);
}
else if (info.FolderType == ChannelFolderType.Season)
{
item = GetItemById<Season>(info.Id, channelProvider.Name, channelProvider.DataVersion, out isNew);
}
2016-03-19 05:04:38 +00:00
else
{
item = GetItemById<Folder>(info.Id, channelProvider.Name, channelProvider.DataVersion, out isNew);
}
2014-09-28 15:27:26 +00:00
}
else if (info.MediaType == ChannelMediaType.Audio)
{
2016-03-19 19:32:37 +00:00
if (info.ContentType == ChannelMediaContentType.Podcast)
{
item = GetItemById<AudioPodcast>(info.Id, channelProvider.Name, channelProvider.DataVersion, out isNew);
}
else
{
item = GetItemById<Audio>(info.Id, channelProvider.Name, channelProvider.DataVersion, out isNew);
}
2014-09-28 15:27:26 +00:00
}
else
{
2016-03-19 15:38:05 +00:00
if (info.ContentType == ChannelMediaContentType.Episode)
{
item = GetItemById<Episode>(info.Id, channelProvider.Name, channelProvider.DataVersion, out isNew);
}
else if (info.ContentType == ChannelMediaContentType.Movie)
{
item = GetItemById<Movie>(info.Id, channelProvider.Name, channelProvider.DataVersion, out isNew);
}
else if (info.ContentType == ChannelMediaContentType.Trailer || info.ExtraType == ExtraType.Trailer)
{
item = GetItemById<Trailer>(info.Id, channelProvider.Name, channelProvider.DataVersion, out isNew);
}
else
{
item = GetItemById<Video>(info.Id, channelProvider.Name, channelProvider.DataVersion, out isNew);
}
2014-03-18 17:05:57 +00:00
}
item.RunTimeTicks = info.RunTimeTicks;
2014-05-03 04:20:04 +00:00
if (isNew)
{
item.Name = info.Name;
item.Genres = info.Genres;
item.Studios = info.Studios;
item.CommunityRating = info.CommunityRating;
item.Overview = info.Overview;
2014-07-08 01:41:03 +00:00
item.IndexNumber = info.IndexNumber;
item.ParentIndexNumber = info.ParentIndexNumber;
2014-05-03 04:20:04 +00:00
item.PremiereDate = info.PremiereDate;
item.ProductionYear = info.ProductionYear;
item.ProviderIds = info.ProviderIds;
2014-09-22 21:56:54 +00:00
item.OfficialRating = info.OfficialRating;
2015-10-04 18:10:50 +00:00
item.DateCreated = info.DateCreated ?? DateTime.UtcNow;
2015-11-21 05:01:16 +00:00
item.Tags = info.Tags;
2016-06-12 05:03:52 +00:00
item.HomePageUrl = info.HomePageUrl;
2014-05-03 04:20:04 +00:00
}
else if (info.Type == ChannelItemType.Folder && info.FolderType == ChannelFolderType.Container)
{
// At least update names of container folders
if (item.Name != info.Name)
{
item.Name = info.Name;
forceUpdate = true;
}
}
2014-05-03 04:20:04 +00:00
2016-06-20 17:08:13 +00:00
var hasArtists = item as IHasArtist;
if (hasArtists != null)
{
hasArtists.Artists = info.Artists;
}
var hasAlbumArtists = item as IHasAlbumArtist;
if (hasAlbumArtists != null)
{
hasAlbumArtists.AlbumArtists = info.AlbumArtists;
}
2016-03-19 19:32:37 +00:00
var trailer = item as Trailer;
if (trailer != null)
{
if (!info.TrailerTypes.SequenceEqual(trailer.TrailerTypes))
{
forceUpdate = true;
}
trailer.TrailerTypes = info.TrailerTypes;
}
2016-03-19 04:05:33 +00:00
item.ChannelId = internalChannelId.ToString("N");
2015-10-04 18:10:50 +00:00
2015-11-21 05:01:16 +00:00
if (item.ParentId != internalChannelId)
2015-11-02 17:25:01 +00:00
{
2015-11-21 05:01:16 +00:00
forceUpdate = true;
2015-11-02 17:25:01 +00:00
}
2015-11-21 05:01:16 +00:00
item.ParentId = internalChannelId;
2015-11-02 17:25:01 +00:00
2016-03-19 04:05:33 +00:00
if (!string.Equals(item.ExternalId, info.Id, StringComparison.OrdinalIgnoreCase))
2015-10-04 18:10:50 +00:00
{
2015-11-21 05:01:16 +00:00
forceUpdate = true;
2015-10-04 18:10:50 +00:00
}
2016-03-19 04:05:33 +00:00
item.ExternalId = info.Id;
2014-05-03 04:20:04 +00:00
2016-03-19 05:14:47 +00:00
var channelAudioItem = item as Audio;
2016-03-19 04:22:33 +00:00
if (channelAudioItem != null)
2014-05-03 04:20:04 +00:00
{
2016-03-19 04:22:33 +00:00
channelAudioItem.ExtraType = info.ExtraType;
channelAudioItem.ChannelMediaSources = info.MediaSources;
2014-05-18 19:58:42 +00:00
var mediaSource = info.MediaSources.FirstOrDefault();
2016-03-19 04:22:33 +00:00
item.Path = mediaSource == null ? null : mediaSource.Path;
}
2014-05-18 19:58:42 +00:00
2016-03-19 15:38:05 +00:00
var channelVideoItem = item as Video;
2016-03-19 04:22:33 +00:00
if (channelVideoItem != null)
{
channelVideoItem.ExtraType = info.ExtraType;
channelVideoItem.ChannelMediaSources = info.MediaSources;
var mediaSource = info.MediaSources.FirstOrDefault();
2014-05-18 19:58:42 +00:00
item.Path = mediaSource == null ? null : mediaSource.Path;
2014-05-03 04:20:04 +00:00
}
2015-11-02 17:32:40 +00:00
if (!string.IsNullOrWhiteSpace(info.ImageUrl) && !item.HasImage(ImageType.Primary))
2015-10-25 17:13:30 +00:00
{
item.SetImagePath(ImageType.Primary, info.ImageUrl);
}
2016-03-19 05:04:38 +00:00
if (item.SourceType != SourceType.Channel)
{
item.SourceType = SourceType.Channel;
forceUpdate = true;
}
2014-05-03 04:20:04 +00:00
if (isNew)
{
await _libraryManager.CreateItem(item, cancellationToken).ConfigureAwait(false);
2015-06-28 16:36:25 +00:00
2015-10-25 17:13:30 +00:00
if (info.People != null && info.People.Count > 0)
{
await _libraryManager.UpdatePeople(item, info.People ?? new List<PersonInfo>()).ConfigureAwait(false);
}
2014-05-03 04:20:04 +00:00
}
2015-11-21 05:01:16 +00:00
else if (forceUpdate)
{
await item.UpdateToRepository(ItemUpdateType.None, cancellationToken).ConfigureAwait(false);
}
2014-03-18 17:05:57 +00:00
return item;
2014-03-18 01:45:41 +00:00
}
2015-10-17 15:05:12 +00:00
private void RefreshIfNeeded(BaseItem[] programs)
2014-05-03 04:20:04 +00:00
{
foreach (var program in programs)
{
2015-10-17 15:05:12 +00:00
RefreshIfNeeded(program);
2014-05-03 04:20:04 +00:00
}
}
2015-10-17 15:05:12 +00:00
private void RefreshIfNeeded(BaseItem program)
2014-05-03 04:20:04 +00:00
{
if (!_refreshedItems.ContainsKey(program.Id))
2014-05-03 04:20:04 +00:00
{
_refreshedItems.TryAdd(program.Id, true);
2015-10-17 15:05:12 +00:00
_providerManager.QueueRefresh(program.Id, new MetadataRefreshOptions(_fileSystem));
2014-05-03 04:20:04 +00:00
}
}
2014-03-18 17:05:57 +00:00
internal IChannel GetChannelProvider(Channel channel)
2014-03-18 01:45:41 +00:00
{
2016-03-19 19:32:37 +00:00
if (channel == null)
{
throw new ArgumentNullException("channel");
}
2016-04-08 18:32:38 +00:00
var result = GetAllChannels()
.FirstOrDefault(i => string.Equals(GetInternalChannelId(i.Name).ToString("N"), channel.ChannelId, StringComparison.OrdinalIgnoreCase) || string.Equals(i.Name, channel.Name, StringComparison.OrdinalIgnoreCase));
if (result == null)
{
throw new ResourceNotFoundException("No channel provider found for channel " + channel.Name);
}
return result;
2014-03-18 01:45:41 +00:00
}
2014-05-03 04:20:04 +00:00
private IEnumerable<BaseItem> ApplyFilters(IEnumerable<BaseItem> items, IEnumerable<ItemFilter> filters, User user)
{
foreach (var filter in filters.OrderByDescending(f => (int)f))
{
items = ApplyFilter(items, filter, user);
}
return items;
}
private IEnumerable<BaseItem> ApplyFilter(IEnumerable<BaseItem> items, ItemFilter filter, User user)
{
// Avoid implicitly captured closure
var currentUser = user;
switch (filter)
{
case ItemFilter.IsFavoriteOrLikes:
return items.Where(item =>
{
2016-04-30 22:05:13 +00:00
var userdata = _userDataManager.GetUserData(user, item);
2014-05-03 04:20:04 +00:00
if (userdata == null)
{
return false;
}
var likes = userdata.Likes ?? false;
var favorite = userdata.IsFavorite;
return likes || favorite;
});
case ItemFilter.Likes:
return items.Where(item =>
{
2016-04-30 22:05:13 +00:00
var userdata = _userDataManager.GetUserData(user, item);
2014-05-03 04:20:04 +00:00
return userdata != null && userdata.Likes.HasValue && userdata.Likes.Value;
});
case ItemFilter.Dislikes:
return items.Where(item =>
{
2016-04-30 22:05:13 +00:00
var userdata = _userDataManager.GetUserData(user, item);
2014-05-03 04:20:04 +00:00
return userdata != null && userdata.Likes.HasValue && !userdata.Likes.Value;
});
case ItemFilter.IsFavorite:
return items.Where(item =>
{
2016-04-30 22:05:13 +00:00
var userdata = _userDataManager.GetUserData(user, item);
2014-05-03 04:20:04 +00:00
return userdata != null && userdata.IsFavorite;
});
case ItemFilter.IsResumable:
return items.Where(item =>
{
2016-04-30 22:05:13 +00:00
var userdata = _userDataManager.GetUserData(user, item);
2014-05-03 04:20:04 +00:00
return userdata != null && userdata.PlaybackPositionTicks > 0;
});
case ItemFilter.IsPlayed:
return items.Where(item => item.IsPlayed(currentUser));
case ItemFilter.IsUnplayed:
return items.Where(item => item.IsUnplayed(currentUser));
case ItemFilter.IsFolder:
return items.Where(item => item.IsFolder);
case ItemFilter.IsNotFolder:
return items.Where(item => !item.IsFolder);
}
return items;
}
2014-06-07 19:46:24 +00:00
public async Task<BaseItemDto> GetChannelFolder(string userId, CancellationToken cancellationToken)
{
2014-09-14 15:10:51 +00:00
var user = string.IsNullOrEmpty(userId) ? null : _userManager.GetUserById(userId);
2014-06-07 19:46:24 +00:00
2015-08-14 18:30:08 +00:00
var folder = await GetInternalChannelFolder(cancellationToken).ConfigureAwait(false);
2014-06-07 19:46:24 +00:00
2014-12-27 05:08:39 +00:00
return _dtoService.GetBaseItemDto(folder, new DtoOptions(), user);
2014-06-07 19:46:24 +00:00
}
2015-08-14 18:30:08 +00:00
public async Task<Folder> GetInternalChannelFolder(CancellationToken cancellationToken)
2014-06-07 19:46:24 +00:00
{
var name = _localization.GetLocalizedString("ViewTypeChannels");
2015-03-14 04:50:23 +00:00
2015-08-14 18:00:26 +00:00
return await _libraryManager.GetNamedView(name, "channels", "zz_" + name, cancellationToken).ConfigureAwait(false);
2014-06-07 19:46:24 +00:00
}
2014-06-20 04:50:30 +00:00
2016-03-19 04:22:33 +00:00
public async Task DownloadChannelItem(BaseItem item, string destination,
2014-09-30 04:47:30 +00:00
IProgress<double> progress, CancellationToken cancellationToken)
{
2015-03-28 20:22:27 +00:00
var sources = await GetDynamicMediaSources(item, cancellationToken)
2014-09-30 04:47:30 +00:00
.ConfigureAwait(false);
var list = sources.Where(i => i.Protocol == MediaProtocol.Http).ToList();
foreach (var source in list)
{
2015-07-23 05:25:55 +00:00
await TryDownloadChannelItem(source, item, destination, progress, cancellationToken).ConfigureAwait(false);
return;
2014-09-30 04:47:30 +00:00
}
}
private async Task TryDownloadChannelItem(MediaSourceInfo source,
2016-03-19 04:22:33 +00:00
BaseItem item,
2014-09-30 04:47:30 +00:00
string destination,
IProgress<double> progress,
CancellationToken cancellationToken)
{
var options = new HttpRequestOptions
{
CancellationToken = cancellationToken,
Url = source.Path,
Progress = new Progress<double>()
};
var channel = GetChannel(item.ChannelId);
var channelProvider = GetChannelProvider(channel);
2015-04-06 03:47:01 +00:00
var features = channelProvider.GetChannelFeatures();
if (!features.SupportsContentDownloading)
{
throw new ArgumentException("The channel does not support downloading.");
}
var limit = features.DailyDownloadLimit;
2014-09-30 04:47:30 +00:00
foreach (var header in source.RequiredHttpHeaders)
{
options.RequestHeaders[header.Key] = header.Value;
}
2015-09-29 17:35:23 +00:00
_fileSystem.CreateDirectory(Path.GetDirectoryName(destination));
2014-09-30 04:47:30 +00:00
// Determine output extension
var response = await _httpClient.GetTempFileResponse(options).ConfigureAwait(false);
if (response.ContentType.StartsWith("text/html"))
{
throw new HttpException("File not found")
{
StatusCode = HttpStatusCode.NotFound
};
}
if (string.Equals(item.MediaType, MediaType.Video, StringComparison.OrdinalIgnoreCase) && response.ContentType.StartsWith("video/", StringComparison.OrdinalIgnoreCase))
{
var extension = response.ContentType.Split('/')
.Last()
.Replace("quicktime", "mov", StringComparison.OrdinalIgnoreCase);
destination += "." + extension;
}
else if (string.Equals(item.MediaType, MediaType.Audio, StringComparison.OrdinalIgnoreCase) && response.ContentType.StartsWith("audio/", StringComparison.OrdinalIgnoreCase))
{
var extension = response.ContentType.Replace("audio/mpeg", "audio/mp3", StringComparison.OrdinalIgnoreCase)
.Split('/')
.Last();
destination += "." + extension;
}
else
{
_fileSystem.DeleteFile(response.TempFilePath);
2014-09-30 04:47:30 +00:00
throw new ApplicationException("Unexpected response type encountered: " + response.ContentType);
}
2015-09-29 17:35:23 +00:00
_fileSystem.CopyFile(response.TempFilePath, destination, true);
2014-09-30 04:47:30 +00:00
try
{
_fileSystem.DeleteFile(response.TempFilePath);
2014-09-30 04:47:30 +00:00
}
catch
{
}
}
2014-03-18 01:45:41 +00:00
}
2015-11-21 05:01:16 +00:00
}