1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642 |
- using System.Net;
- using System.Text;
- using MediaBrowser.Common.Extensions;
- using MediaBrowser.Common.IO;
- using MediaBrowser.Common.Net;
- using MediaBrowser.Controller.Channels;
- using MediaBrowser.Controller.Configuration;
- using MediaBrowser.Controller.Dto;
- using MediaBrowser.Controller.Entities;
- using MediaBrowser.Controller.Library;
- using MediaBrowser.Controller.Localization;
- using MediaBrowser.Controller.Providers;
- using MediaBrowser.Controller.Resolvers;
- using MediaBrowser.Model.Channels;
- using MediaBrowser.Model.Dto;
- using MediaBrowser.Model.Entities;
- using MediaBrowser.Model.Logging;
- using MediaBrowser.Model.MediaInfo;
- using MediaBrowser.Model.Net;
- using MediaBrowser.Model.Querying;
- using MediaBrowser.Model.Serialization;
- using System;
- using System.Collections.Concurrent;
- using System.Collections.Generic;
- using System.IO;
- using System.Linq;
- using System.Threading;
- using System.Threading.Tasks;
- using MediaBrowser.Server.Implementations.Library;
- namespace MediaBrowser.Server.Implementations.Channels
- {
- public class ChannelManager : IChannelManager, IDisposable
- {
- private IChannel[] _channels;
- private IChannelFactory[] _factories;
- private readonly IUserManager _userManager;
- private readonly IUserDataManager _userDataManager;
- private readonly IDtoService _dtoService;
- private readonly ILibraryManager _libraryManager;
- private readonly ILogger _logger;
- private readonly IServerConfigurationManager _config;
- private readonly IFileSystem _fileSystem;
- private readonly IJsonSerializer _jsonSerializer;
- private readonly IHttpClient _httpClient;
- private readonly ILocalizationManager _localization;
- private readonly ConcurrentDictionary<Guid, bool> _refreshedItems = new ConcurrentDictionary<Guid, bool>();
- private readonly ConcurrentDictionary<string, int> _downloadCounts = new ConcurrentDictionary<string, int>();
- private Timer _refreshTimer;
- private Timer _clearDownloadCountsTimer;
- public ChannelManager(IUserManager userManager, IDtoService dtoService, ILibraryManager libraryManager, ILogger logger, IServerConfigurationManager config, IFileSystem fileSystem, IUserDataManager userDataManager, IJsonSerializer jsonSerializer, ILocalizationManager localization, IHttpClient httpClient)
- {
- _userManager = userManager;
- _dtoService = dtoService;
- _libraryManager = libraryManager;
- _logger = logger;
- _config = config;
- _fileSystem = fileSystem;
- _userDataManager = userDataManager;
- _jsonSerializer = jsonSerializer;
- _localization = localization;
- _httpClient = httpClient;
- _refreshTimer = new Timer(s => _refreshedItems.Clear(), null, TimeSpan.FromHours(3), TimeSpan.FromHours(3));
- _clearDownloadCountsTimer = new Timer(s => _downloadCounts.Clear(), null, TimeSpan.FromHours(24), TimeSpan.FromHours(24));
- }
- private TimeSpan CacheLength
- {
- get
- {
- return TimeSpan.FromHours(6);
- }
- }
- public void AddParts(IEnumerable<IChannel> channels, IEnumerable<IChannelFactory> factories)
- {
- _channels = channels.Where(i => !(i is IFactoryChannel)).ToArray();
- _factories = factories.ToArray();
- }
- public string ChannelDownloadPath
- {
- get
- {
- var options = _config.GetChannelsConfiguration();
- if (!string.IsNullOrWhiteSpace(options.DownloadPath))
- {
- return options.DownloadPath;
- }
- return Path.Combine(_config.ApplicationPaths.ProgramDataPath, "channels");
- }
- }
- private IEnumerable<IChannel> GetAllChannels()
- {
- return _factories
- .SelectMany(i =>
- {
- try
- {
- return i.GetChannels().ToList();
- }
- catch (Exception ex)
- {
- _logger.ErrorException("Error getting channel list", ex);
- return new List<IChannel>();
- }
- })
- .Concat(_channels)
- .OrderBy(i => i.Name);
- }
- public Task<QueryResult<Channel>> GetChannelsInternal(ChannelQuery query, CancellationToken cancellationToken)
- {
- var user = string.IsNullOrWhiteSpace(query.UserId)
- ? null
- : _userManager.GetUserById(query.UserId);
- var channels = GetAllChannels()
- .Select(GetChannelEntity)
- .OrderBy(i => i.SortName)
- .ToList();
- if (query.SupportsLatestItems.HasValue)
- {
- var val = query.SupportsLatestItems.Value;
- channels = channels.Where(i => (GetChannelProvider(i) is ISupportsLatestMedia) == val)
- .ToList();
- }
- if (query.IsFavorite.HasValue)
- {
- var val = query.IsFavorite.Value;
- channels = channels.Where(i => _userDataManager.GetUserData(user.Id, i.GetUserDataKey()).IsFavorite == val)
- .ToList();
- }
- if (user != null)
- {
- channels = channels.Where(i => GetChannelProvider(i).IsEnabledFor(user.Id.ToString("N")) && i.IsVisible(user))
- .ToList();
- }
- 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();
- }
- 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
- : _userManager.GetUserById(query.UserId);
- var internalResult = await GetChannelsInternal(query, cancellationToken).ConfigureAwait(false);
- // Get everything
- var fields = Enum.GetNames(typeof(ItemFields))
- .Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true))
- .ToList();
- var returnItems = internalResult.Items.Select(i => _dtoService.GetBaseItemDto(i, fields, user))
- .ToArray();
- var result = new QueryResult<BaseItemDto>
- {
- Items = returnItems,
- TotalRecordCount = internalResult.TotalRecordCount
- };
- return result;
- }
- public async Task RefreshChannels(IProgress<double> progress, CancellationToken cancellationToken)
- {
- var allChannelsList = GetAllChannels().ToList();
- var numComplete = 0;
- foreach (var channelInfo in allChannelsList)
- {
- cancellationToken.ThrowIfCancellationRequested();
- try
- {
- var item = await GetChannel(channelInfo, cancellationToken).ConfigureAwait(false);
- _libraryManager.RegisterItem(item);
- }
- 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;
- _libraryManager.RegisterItem(item);
- }
- return item;
- }
- public async Task<IEnumerable<MediaSourceInfo>> GetChannelItemMediaSources(string id, bool includeDynamicSources, CancellationToken cancellationToken)
- {
- var item = (IChannelMediaItem)_libraryManager.GetItemById(id);
- var channel = GetChannel(item.ChannelId);
- var channelPlugin = GetChannelProvider(channel);
- var requiresCallback = channelPlugin as IRequiresMediaInfoCallback;
- IEnumerable<ChannelMediaInfo> results;
- if (requiresCallback != null && includeDynamicSources)
- {
- results = await GetChannelItemMediaSourcesInternal(requiresCallback, item.ExternalId, cancellationToken)
- .ConfigureAwait(false);
- }
- else
- {
- results = item.ChannelMediaSources;
- }
- var sources = SortMediaInfoResults(results).Select(i => GetMediaSource(item, i))
- .ToList();
- var cachedVersions = GetCachedChannelItemMediaSources(item);
- sources.InsertRange(0, cachedVersions);
- return sources.Where(IsValidMediaSource);
- }
- 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;
- }
- public IEnumerable<MediaSourceInfo> GetCachedChannelItemMediaSources(string id)
- {
- var item = (IChannelMediaItem)_libraryManager.GetItemById(id);
- return GetCachedChannelItemMediaSources(item);
- }
- public IEnumerable<MediaSourceInfo> GetCachedChannelItemMediaSources(IChannelMediaItem item)
- {
- var filenamePrefix = item.Id.ToString("N");
- var parentPath = Path.Combine(ChannelDownloadPath, item.ChannelId);
- try
- {
- var files = new DirectoryInfo(parentPath).EnumerateFiles("*", SearchOption.TopDirectoryOnly);
- if (string.Equals(item.MediaType, MediaType.Video, StringComparison.OrdinalIgnoreCase))
- {
- files = files.Where(i => _libraryManager.IsVideoFile(i.FullName));
- }
- else
- {
- files = files.Where(i => _libraryManager.IsAudioFile(i.FullName));
- }
-
- var file = files
- .FirstOrDefault(i => i.Name.StartsWith(filenamePrefix, StringComparison.OrdinalIgnoreCase));
- if (file != null)
- {
- var cachedItem = _libraryManager.ResolvePath(file);
- if (cachedItem != null)
- {
- var hasMediaSources = _libraryManager.GetItemById(cachedItem.Id) as IHasMediaSources;
- if (hasMediaSources != null)
- {
- var source = hasMediaSources.GetMediaSources(true).FirstOrDefault();
- if (source != null)
- {
- source.Type = MediaSourceType.Cache;
- return new[] { source };
- }
- }
- }
- }
- }
- catch (DirectoryNotFoundException)
- {
- }
- return new List<MediaSourceInfo>();
- }
- private MediaSourceInfo GetMediaSource(IChannelMediaItem item, ChannelMediaInfo info)
- {
- var source = info.ToMediaSource();
- source.RunTimeTicks = source.RunTimeTicks ?? item.RunTimeTicks;
- return source;
- }
- private IEnumerable<ChannelMediaInfo> SortMediaInfoResults(IEnumerable<ChannelMediaInfo> channelMediaSources)
- {
- var list = channelMediaSources.ToList();
- var options = _config.GetChannelsConfiguration();
- var width = options.PreferredStreamingWidth;
- if (width.HasValue)
- {
- var val = width.Value;
- var res = list
- .OrderBy(i => (i.Width.HasValue && i.Width.Value <= val ? 0 : 1))
- .ThenBy(i => Math.Abs((i.Width ?? 0) - val))
- .ThenByDescending(i => i.Width ?? 0)
- .ThenBy(list.IndexOf)
- .ToList();
- return res;
- }
- return list
- .OrderByDescending(i => i.Width ?? 0)
- .ThenBy(list.IndexOf);
- }
- private async Task<Channel> GetChannel(IChannel channelInfo, CancellationToken cancellationToken)
- {
- var path = Path.Combine(_config.ApplicationPaths.ItemsByNamePath, "channels", _fileSystem.GetValidFilename(channelInfo.Name));
- var fileInfo = new DirectoryInfo(path);
- var isNew = false;
- if (!fileInfo.Exists)
- {
- _logger.Debug("Creating directory {0}", path);
- Directory.CreateDirectory(path);
- fileInfo = new DirectoryInfo(path);
- if (!fileInfo.Exists)
- {
- throw new IOException("Path not created: " + path);
- }
- isNew = true;
- }
- var id = GetInternalChannelId(channelInfo.Name);
- var item = _libraryManager.GetItemById(id) as Channel;
- if (item == null)
- {
- item = new Channel
- {
- Name = channelInfo.Name,
- Id = id,
- DateCreated = _fileSystem.GetCreationTimeUtc(fileInfo),
- DateModified = _fileSystem.GetLastWriteTimeUtc(fileInfo),
- Path = path
- };
- isNew = true;
- }
- item.OfficialRating = GetOfficialRating(channelInfo.ParentalRating);
- item.Overview = channelInfo.Description;
- item.HomePageUrl = channelInfo.HomePageUrl;
- item.OriginalChannelName = channelInfo.Name;
- if (string.IsNullOrEmpty(item.Name))
- {
- item.Name = channelInfo.Name;
- }
- await item.RefreshMetadata(new MetadataRefreshOptions
- {
- ForceSave = isNew
- }, cancellationToken);
- return item;
- }
- 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)
- {
- return (Channel)_libraryManager.GetItemById(new Guid(id));
- }
- public IEnumerable<ChannelFeatures> GetAllChannelFeatures()
- {
- return GetAllChannels()
- .Select(GetChannelEntity)
- .OrderBy(i => i.SortName)
- .Select(i => GetChannelFeatures(i.Id.ToString("N")));
- }
- public ChannelFeatures GetChannelFeatures(string id)
- {
- var channel = GetChannel(id);
- var channelProvider = GetChannelProvider(channel);
- return GetChannelFeaturesDto(channel, channelProvider, channelProvider.GetChannelFeatures());
- }
- public ChannelFeatures GetChannelFeaturesDto(Channel channel,
- IChannel provider,
- InternalChannelFeatures features)
- {
- var isIndexable = provider is IIndexableChannel;
- var supportsLatest = provider is ISupportsLatestMedia;
- return new ChannelFeatures
- {
- CanFilter = !features.MaxPageSize.HasValue,
- CanSearch = provider is ISearchableChannel,
- ContentTypes = features.ContentTypes,
- DefaultSortFields = features.DefaultSortFields,
- MaxPageSize = features.MaxPageSize,
- MediaTypes = features.MediaTypes,
- SupportsSortOrderToggle = features.SupportsSortOrderToggle,
- SupportsLatestMedia = supportsLatest,
- Name = channel.Name,
- Id = channel.Id.ToString("N"),
- SupportsContentDownloading = isIndexable || supportsLatest,
- AutoRefreshLevels = features.AutoRefreshLevels
- };
- }
- private Guid GetInternalChannelId(string name)
- {
- if (string.IsNullOrWhiteSpace(name))
- {
- throw new ArgumentNullException("name");
- }
- return ("Channel " + name).GetMBId(typeof(Channel));
- }
- public async Task<QueryResult<BaseItemDto>> GetLatestChannelItems(AllChannelMediaQuery query, CancellationToken cancellationToken)
- {
- var user = string.IsNullOrWhiteSpace(query.UserId)
- ? null
- : _userManager.GetUserById(query.UserId);
- // See below about parental control
- if (user != null)
- {
- query.StartIndex = null;
- }
- var internalResult = await GetLatestChannelItemsInternal(query, cancellationToken).ConfigureAwait(false);
- // Get everything
- var fields = Enum.GetNames(typeof(ItemFields))
- .Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true))
- .ToList();
- 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))
- .Take(10)
- .ToArray();
- totalRecordCount = items.Length;
- }
- var returnItems = items.Select(i => _dtoService.GetBaseItemDto(i, fields, user))
- .ToArray();
- var result = new QueryResult<BaseItemDto>
- {
- Items = returnItems,
- TotalRecordCount = totalRecordCount
- };
- return result;
- }
- public async Task<QueryResult<BaseItem>> GetLatestChannelItemsInternal(AllChannelMediaQuery query, CancellationToken cancellationToken)
- {
- var user = string.IsNullOrWhiteSpace(query.UserId)
- ? null
- : _userManager.GetUserById(query.UserId);
- if (!string.IsNullOrWhiteSpace(query.UserId) && user == null)
- {
- throw new ArgumentException("User not found.");
- }
- 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
- {
- 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
- .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));
- }
- 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();
- await RefreshIfNeeded(internalItems, new Progress<double>(), cancellationToken).ConfigureAwait(false);
- if (query.StartIndex.HasValue)
- {
- internalItems = internalItems.Skip(query.StartIndex.Value).ToArray();
- }
- if (query.Limit.HasValue)
- {
- internalItems = internalItems.Take(query.Limit.Value).ToArray();
- }
- var returnItemArray = internalItems.ToArray();
- return new QueryResult<BaseItem>
- {
- TotalRecordCount = totalCount,
- Items = returnItemArray
- };
- }
- private async Task<IEnumerable<ChannelItemInfo>> GetLatestItems(ISupportsLatestMedia indexable, IChannel channel, string userId, CancellationToken cancellationToken)
- {
- var cacheLength = CacheLength;
- 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();
- }
- }
- public async Task<QueryResult<BaseItem>> GetAllMediaInternal(AllChannelMediaQuery query, CancellationToken cancellationToken)
- {
- 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();
- }
- var tasks = channels
- .Select(async i =>
- {
- var indexable = i as IIndexableChannel;
- if (indexable != null)
- {
- try
- {
- var result = await GetAllItems(indexable, i, new InternalAllChannelMediaQuery
- {
- UserId = query.UserId,
- ContentTypes = query.ContentTypes,
- ExtraTypes = query.ExtraTypes,
- TrailerTypes = query.TrailerTypes
- }, cancellationToken).ConfigureAwait(false);
- return new Tuple<IChannel, ChannelItemResult>(i, result);
- }
- 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
- .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);
- });
- var internalItems = await Task.WhenAll(itemTasks).ConfigureAwait(false);
- var returnItemArray = internalItems.ToArray();
- return new QueryResult<BaseItem>
- {
- TotalRecordCount = totalCount,
- Items = returnItemArray
- };
- }
- 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);
- await RefreshIfNeeded(internalResult.Items, new Progress<double>(), cancellationToken).ConfigureAwait(false);
- // Get everything
- var fields = Enum.GetNames(typeof(ItemFields))
- .Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true))
- .ToList();
- var returnItems = internalResult.Items.Select(i => _dtoService.GetBaseItemDto(i, fields, user))
- .ToArray();
- var result = new QueryResult<BaseItemDto>
- {
- Items = returnItems,
- TotalRecordCount = internalResult.TotalRecordCount
- };
- return result;
- }
- private async Task<ChannelItemResult> GetAllItems(IIndexableChannel indexable, IChannel channel, InternalAllChannelMediaQuery query, CancellationToken cancellationToken)
- {
- 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();
- }
- }
- public async Task<QueryResult<BaseItem>> GetChannelItemsInternal(ChannelItemQuery query, IProgress<double> progress, CancellationToken cancellationToken)
- {
- // Get the internal channel entity
- var channel = GetChannel(query.ChannelId);
- // Find the corresponding channel provider plugin
- var channelProvider = GetChannelProvider(channel);
- var channelInfo = channelProvider.GetChannelFeatures();
- int? providerStartIndex = null;
- int? providerLimit = null;
- if (channelInfo.MaxPageSize.HasValue)
- {
- providerStartIndex = query.StartIndex;
- if (query.Limit.HasValue && query.Limit.Value > channelInfo.MaxPageSize.Value)
- {
- throw new ArgumentException(string.Format("{0} channel only supports a maximum of {1} records at a time.", channel.Name, channelInfo.MaxPageSize.Value));
- }
- providerLimit = query.Limit;
- // This will cause some providers to fail
- if (providerLimit == 0)
- {
- providerLimit = 1;
- }
- }
- var user = string.IsNullOrWhiteSpace(query.UserId)
- ? null
- : _userManager.GetUserById(query.UserId);
- ChannelItemSortField? sortField = null;
- ChannelItemSortField parsedField;
- if (query.SortBy.Length == 1 &&
- Enum.TryParse(query.SortBy[0], true, out parsedField))
- {
- sortField = parsedField;
- }
- var sortDescending = query.SortOrder.HasValue && query.SortOrder.Value == SortOrder.Descending;
- var itemsResult = await GetChannelItems(channelProvider,
- user,
- query.FolderId,
- providerStartIndex,
- providerLimit,
- sortField,
- sortDescending,
- cancellationToken)
- .ConfigureAwait(false);
- var providerTotalRecordCount = providerLimit.HasValue ? itemsResult.TotalRecordCount : null;
- 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();
- if (providerTotalRecordCount.HasValue)
- {
- providerTotalRecordCount = providerTotalRecordCount.Value;
- }
- }
- return await GetReturnItems(internalItems, providerTotalRecordCount, user, query, progress, cancellationToken).ConfigureAwait(false);
- }
- public async Task<QueryResult<BaseItemDto>> GetChannelItems(ChannelItemQuery query, CancellationToken cancellationToken)
- {
- var user = string.IsNullOrWhiteSpace(query.UserId)
- ? null
- : _userManager.GetUserById(query.UserId);
- var internalResult = await GetChannelItemsInternal(query, new Progress<double>(), cancellationToken).ConfigureAwait(false);
- // Get everything
- var fields = Enum.GetNames(typeof(ItemFields))
- .Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true))
- .ToList();
- var returnItems = internalResult.Items.Select(i => _dtoService.GetBaseItemDto(i, fields, user))
- .ToArray();
- var result = new QueryResult<BaseItemDto>
- {
- Items = returnItems,
- TotalRecordCount = internalResult.TotalRecordCount
- };
- return result;
- }
- private readonly SemaphoreSlim _resourcePool = new SemaphoreSlim(1, 1);
- private async Task<ChannelItemResult> GetChannelItems(IChannel channel,
- User user,
- string folderId,
- int? startIndex,
- int? limit,
- ChannelItemSortField? sortField,
- bool sortDescending,
- CancellationToken cancellationToken)
- {
- var userId = user.Id.ToString("N");
- var cacheLength = CacheLength;
- var cachePath = GetChannelDataCachePath(channel, userId, folderId, sortField, sortDescending);
- try
- {
- if (!startIndex.HasValue && !limit.HasValue)
- {
- 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 (!startIndex.HasValue && !limit.HasValue)
- {
- if (_fileSystem.GetLastWriteTimeUtc(cachePath).Add(cacheLength) > DateTime.UtcNow)
- {
- return _jsonSerializer.DeserializeFromFile<ChannelItemResult>(cachePath);
- }
- }
- }
- catch (FileNotFoundException)
- {
- }
- catch (DirectoryNotFoundException)
- {
- }
- var query = new InternalChannelItemQuery
- {
- UserId = userId,
- StartIndex = startIndex,
- Limit = limit,
- SortBy = sortField,
- SortDescending = sortDescending
- };
- if (!string.IsNullOrWhiteSpace(folderId))
- {
- var categoryItem = (IChannelItem)_libraryManager.GetItemById(new Guid(folderId));
- query.FolderId = categoryItem.ExternalId;
- }
- var result = await channel.GetChannelItems(query, cancellationToken).ConfigureAwait(false);
- if (!startIndex.HasValue && !limit.HasValue)
- {
- CacheResponse(result, cachePath);
- }
- return result;
- }
- finally
- {
- _resourcePool.Release();
- }
- }
- private void CacheResponse(object result, string path)
- {
- try
- {
- Directory.CreateDirectory(Path.GetDirectoryName(path));
- _jsonSerializer.SerializeToFile(result, path);
- }
- catch (Exception ex)
- {
- _logger.ErrorException("Error writing to channel cache file: {0}", ex, path);
- }
- }
- private string GetChannelDataCachePath(IChannel channel,
- string userId,
- string folderId,
- ChannelItemSortField? sortField,
- bool sortDescending)
- {
- var channelId = GetInternalChannelId(channel.Name).ToString("N");
- var userCacheKey = string.Empty;
- var hasCacheKey = channel as IHasCacheKey;
- if (hasCacheKey != null)
- {
- userCacheKey = hasCacheKey.GetCacheKey(userId) ?? string.Empty;
- }
- var filename = string.IsNullOrWhiteSpace(folderId) ? "root" : folderId;
- filename += userCacheKey;
- var version = (channel.DataVersion ?? string.Empty).GetMD5().ToString("N");
- if (sortField.HasValue)
- {
- filename += "-sortField-" + sortField.Value;
- }
- if (sortDescending)
- {
- filename += "-sortDescending";
- }
- filename = filename.GetMD5().ToString("N");
- return Path.Combine(_config.ApplicationPaths.CachePath,
- "channels",
- channelId,
- version,
- filename + ".json");
- }
- private async Task<QueryResult<BaseItem>> GetReturnItems(IEnumerable<BaseItem> items,
- int? totalCountFromProvider,
- User user,
- ChannelItemQuery query,
- IProgress<double> progress,
- CancellationToken cancellationToken)
- {
- items = ApplyFilters(items, query.Filters, user);
- var sortBy = query.SortBy.Length == 0 ? new[] { ItemSortBy.SortName } : query.SortBy;
- items = _libraryManager.Sort(items, user, sortBy, query.SortOrder ?? SortOrder.Ascending);
- var all = items.ToList();
- var totalCount = totalCountFromProvider ?? all.Count;
- if (!totalCountFromProvider.HasValue)
- {
- if (query.StartIndex.HasValue)
- {
- all = all.Skip(query.StartIndex.Value).ToList();
- }
- if (query.Limit.HasValue)
- {
- all = all.Take(query.Limit.Value).ToList();
- }
- }
- var returnItemArray = all.ToArray();
- await RefreshIfNeeded(returnItemArray, progress, cancellationToken).ConfigureAwait(false);
- return new QueryResult<BaseItem>
- {
- Items = returnItemArray,
- TotalRecordCount = totalCount
- };
- }
- private string GetIdToHash(string externalId, string channelName)
- {
- // Increment this as needed to force new downloads
- // Incorporate Name because it's being used to convert channel entity to provider
- return externalId + (channelName ?? string.Empty) + "16";
- }
- private T GetItemById<T>(string idString, string channelName, string channnelDataVersion, out bool isNew)
- where T : BaseItem, IChannelItem, new()
- {
- var id = GetIdToHash(idString, channelName).GetMBId(typeof(T));
- T item = null;
- try
- {
- item = _libraryManager.GetItemById(id) as T;
- }
- catch (Exception ex)
- {
- _logger.ErrorException("Error retrieving channel item from database", ex);
- }
- if (item == null || !string.Equals(item.DataVersion, channnelDataVersion, StringComparison.Ordinal))
- {
- item = new T();
- isNew = true;
- }
- else
- {
- isNew = false;
- }
- item.DataVersion = channnelDataVersion;
- item.Id = id;
- return item;
- }
- private async Task<BaseItem> GetChannelItemEntity(ChannelItemInfo info, IChannel channelProvider, Guid internalChannelId, CancellationToken cancellationToken)
- {
- BaseItem item;
- bool isNew;
- if (info.Type == ChannelItemType.Folder)
- {
- item = GetItemById<ChannelFolderItem>(info.Id, channelProvider.Name, channelProvider.DataVersion, out isNew);
- }
- else if (info.MediaType == ChannelMediaType.Audio)
- {
- item = GetItemById<ChannelAudioItem>(info.Id, channelProvider.Name, channelProvider.DataVersion, out isNew);
- }
- else
- {
- item = GetItemById<ChannelVideoItem>(info.Id, channelProvider.Name, channelProvider.DataVersion, out isNew);
- }
- item.RunTimeTicks = info.RunTimeTicks;
- if (isNew)
- {
- item.Name = info.Name;
- item.Genres = info.Genres;
- item.Studios = info.Studios;
- item.CommunityRating = info.CommunityRating;
- item.Overview = info.Overview;
- item.IndexNumber = info.IndexNumber;
- item.ParentIndexNumber = info.ParentIndexNumber;
- item.People = info.People;
- item.PremiereDate = info.PremiereDate;
- item.ProductionYear = info.ProductionYear;
- item.ProviderIds = info.ProviderIds;
- item.OfficialRating = info.OfficialRating;
- item.DateCreated = info.DateCreated.HasValue ?
- info.DateCreated.Value :
- DateTime.UtcNow;
- }
- var channelItem = (IChannelItem)item;
- channelItem.OriginalImageUrl = info.ImageUrl;
- channelItem.ExternalId = info.Id;
- channelItem.ChannelId = internalChannelId.ToString("N");
- channelItem.ChannelItemType = info.Type;
- if (isNew)
- {
- channelItem.Tags = info.Tags;
- }
- var channelMediaItem = item as IChannelMediaItem;
- if (channelMediaItem != null)
- {
- channelMediaItem.ContentType = info.ContentType;
- channelMediaItem.ExtraType = info.ExtraType;
- channelMediaItem.ChannelMediaSources = info.MediaSources;
- var mediaSource = info.MediaSources.FirstOrDefault();
- item.Path = mediaSource == null ? null : mediaSource.Path;
- item.DisplayMediaType = channelMediaItem.ContentType.ToString();
- }
- if (isNew)
- {
- await _libraryManager.CreateItem(item, cancellationToken).ConfigureAwait(false);
- _libraryManager.RegisterItem(item);
- }
- return item;
- }
- private async Task RefreshIfNeeded(BaseItem[] programs, IProgress<double> progress, CancellationToken cancellationToken)
- {
- var numComplete = 0;
- var numItems = programs.Length;
- foreach (var program in programs)
- {
- await RefreshIfNeeded(program, cancellationToken).ConfigureAwait(false);
- numComplete++;
- double percent = numComplete;
- percent /= numItems;
- progress.Report(percent * 100);
- }
- }
- private async Task RefreshIfNeeded(BaseItem program, CancellationToken cancellationToken)
- {
- if (_refreshedItems.ContainsKey(program.Id))
- {
- return;
- }
- await program.RefreshMetadata(cancellationToken).ConfigureAwait(false);
- _refreshedItems.TryAdd(program.Id, true);
- }
- internal IChannel GetChannelProvider(Channel channel)
- {
- return GetAllChannels().First(i => string.Equals(i.Name, channel.OriginalChannelName, StringComparison.OrdinalIgnoreCase));
- }
- 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 =>
- {
- var userdata = _userDataManager.GetUserData(user.Id, item.GetUserDataKey());
- if (userdata == null)
- {
- return false;
- }
- var likes = userdata.Likes ?? false;
- var favorite = userdata.IsFavorite;
- return likes || favorite;
- });
- case ItemFilter.Likes:
- return items.Where(item =>
- {
- var userdata = _userDataManager.GetUserData(user.Id, item.GetUserDataKey());
- return userdata != null && userdata.Likes.HasValue && userdata.Likes.Value;
- });
- case ItemFilter.Dislikes:
- return items.Where(item =>
- {
- var userdata = _userDataManager.GetUserData(user.Id, item.GetUserDataKey());
- return userdata != null && userdata.Likes.HasValue && !userdata.Likes.Value;
- });
- case ItemFilter.IsFavorite:
- return items.Where(item =>
- {
- var userdata = _userDataManager.GetUserData(user.Id, item.GetUserDataKey());
- return userdata != null && userdata.IsFavorite;
- });
- case ItemFilter.IsResumable:
- return items.Where(item =>
- {
- var userdata = _userDataManager.GetUserData(user.Id, item.GetUserDataKey());
- 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;
- }
- public async Task<BaseItemDto> GetChannelFolder(string userId, CancellationToken cancellationToken)
- {
- var user = string.IsNullOrEmpty(userId) ? null : _userManager.GetUserById(userId);
- // Get everything
- var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
- var folder = await GetInternalChannelFolder(userId, cancellationToken).ConfigureAwait(false);
- return _dtoService.GetBaseItemDto(folder, fields, user);
- }
- public async Task<Folder> GetInternalChannelFolder(string userId, CancellationToken cancellationToken)
- {
- var name = _localization.GetLocalizedString("ViewTypeChannels");
- return await _libraryManager.GetNamedView(name, "channels", "zz_" + name, cancellationToken).ConfigureAwait(false);
- }
- public async Task DownloadChannelItem(IChannelMediaItem item, string destination,
- IProgress<double> progress, CancellationToken cancellationToken)
- {
- var itemId = item.Id.ToString("N");
- var sources = await GetChannelItemMediaSources(itemId, true, cancellationToken)
- .ConfigureAwait(false);
- var list = sources.Where(i => i.Protocol == MediaProtocol.Http).ToList();
- foreach (var source in list)
- {
- try
- {
- await TryDownloadChannelItem(source, item, destination, progress, cancellationToken).ConfigureAwait(false);
- return;
- }
- catch (HttpException ex)
- {
- if (ex.StatusCode.HasValue && ex.StatusCode.Value == HttpStatusCode.NotFound)
- {
- MarkBadMediaSource(source);
- }
- }
- }
- }
- private async Task TryDownloadChannelItem(MediaSourceInfo source,
- IChannelMediaItem item,
- string destination,
- IProgress<double> progress,
- CancellationToken cancellationToken)
- {
- var options = new HttpRequestOptions
- {
- CancellationToken = cancellationToken,
- Url = source.Path,
- Progress = new Progress<double>()
- };
- var host = new Uri(source.Path).Host.ToLower();
- var channel = GetChannel(item.ChannelId);
- var channelProvider = GetChannelProvider(channel);
- var limit = channelProvider.GetChannelFeatures().DailyDownloadLimit;
- if (!ValidateDownloadLimit(host, limit))
- {
- _logger.Error(string.Format("Download limit has been reached for {0}", channel.Name));
- throw new ChannelDownloadException(string.Format("Download limit has been reached for {0}", channel.Name));
- }
- foreach (var header in source.RequiredHttpHeaders)
- {
- options.RequestHeaders[header.Key] = header.Value;
- }
- Directory.CreateDirectory(Path.GetDirectoryName(destination));
- // 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
- };
- }
- IncrementDownloadCount(host, limit);
- 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
- {
- File.Delete(response.TempFilePath);
- throw new ApplicationException("Unexpected response type encountered: " + response.ContentType);
- }
- File.Copy(response.TempFilePath, destination, true);
- try
- {
- File.Delete(response.TempFilePath);
- }
- catch
- {
- }
- }
- private readonly ReaderWriterLockSlim _mediaSourceHistoryLock = new ReaderWriterLockSlim();
- private bool IsValidMediaSource(MediaSourceInfo source)
- {
- if (source.Protocol == MediaProtocol.Http)
- {
- return !GetBadMediaSourceHistory().Contains(source.Path, StringComparer.OrdinalIgnoreCase);
- }
- return true;
- }
- private void MarkBadMediaSource(MediaSourceInfo source)
- {
- var list = GetBadMediaSourceHistory();
- list.Add(source.Path);
- var path = GetMediaSourceHistoryPath();
- Directory.CreateDirectory(Path.GetDirectoryName(path));
- if (_mediaSourceHistoryLock.TryEnterWriteLock(TimeSpan.FromSeconds(5)))
- {
- try
- {
- File.WriteAllLines(path, list.ToArray(), Encoding.UTF8);
- }
- catch (Exception ex)
- {
- _logger.ErrorException("Error saving file", ex);
- }
- finally
- {
- _mediaSourceHistoryLock.ExitWriteLock();
- }
- }
- }
- private ConcurrentBag<string> _badMediaSources = null;
- private ConcurrentBag<string> GetBadMediaSourceHistory()
- {
- if (_badMediaSources == null)
- {
- var path = GetMediaSourceHistoryPath();
- if (_mediaSourceHistoryLock.TryEnterReadLock(TimeSpan.FromSeconds(1)))
- {
- if (_badMediaSources == null)
- {
- try
- {
- _badMediaSources = new ConcurrentBag<string>(File.ReadAllLines(path, Encoding.UTF8));
- }
- catch (IOException)
- {
- _badMediaSources = new ConcurrentBag<string>();
- }
- catch (Exception ex)
- {
- _logger.ErrorException("Error reading file", ex);
- _badMediaSources = new ConcurrentBag<string>();
- }
- finally
- {
- _mediaSourceHistoryLock.ExitReadLock();
- }
- }
- }
- }
- return _badMediaSources;
- }
- private string GetMediaSourceHistoryPath()
- {
- return Path.Combine(_config.ApplicationPaths.DataPath, "channels", "failures.txt");
- }
- private void IncrementDownloadCount(string key, int? limit)
- {
- if (!limit.HasValue)
- {
- return;
- }
- int current;
- _downloadCounts.TryGetValue(key, out current);
- current++;
- _downloadCounts.AddOrUpdate(key, current, (k, v) => current);
- }
- private bool ValidateDownloadLimit(string key, int? limit)
- {
- if (!limit.HasValue)
- {
- return true;
- }
- int current;
- _downloadCounts.TryGetValue(key, out current);
- return current < limit.Value;
- }
- public void Dispose()
- {
- if (_clearDownloadCountsTimer != null)
- {
- _clearDownloadCountsTimer.Dispose();
- _clearDownloadCountsTimer = null;
- }
- if (_refreshTimer != null)
- {
- _refreshTimer.Dispose();
- _refreshTimer = null;
- }
- }
- }
- }
|