LiveTvManager.cs 92 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515
  1. using MediaBrowser.Common.Configuration;
  2. using MediaBrowser.Common.Extensions;
  3. using MediaBrowser.Common.Progress;
  4. using MediaBrowser.Controller.Configuration;
  5. using MediaBrowser.Controller.Drawing;
  6. using MediaBrowser.Controller.Dto;
  7. using MediaBrowser.Controller.Entities;
  8. using MediaBrowser.Controller.Library;
  9. using MediaBrowser.Controller.LiveTv;
  10. using MediaBrowser.Controller.Persistence;
  11. using MediaBrowser.Controller.Providers;
  12. using MediaBrowser.Controller.Sorting;
  13. using MediaBrowser.Model.Dto;
  14. using MediaBrowser.Model.Entities;
  15. using MediaBrowser.Model.LiveTv;
  16. using Microsoft.Extensions.Logging;
  17. using MediaBrowser.Model.Querying;
  18. using MediaBrowser.Model.Serialization;
  19. using System;
  20. using System.Collections.Generic;
  21. using System.Linq;
  22. using System.Threading;
  23. using System.Threading.Tasks;
  24. using MediaBrowser.Model.IO;
  25. using MediaBrowser.Common.Security;
  26. using MediaBrowser.Controller.Entities.Movies;
  27. using MediaBrowser.Controller.Entities.TV;
  28. using MediaBrowser.Model.Events;
  29. using MediaBrowser.Model.Extensions;
  30. using MediaBrowser.Model.Globalization;
  31. using MediaBrowser.Model.Tasks;
  32. using Emby.Server.Implementations.LiveTv.Listings;
  33. using MediaBrowser.Controller.Channels;
  34. using Emby.Server.Implementations.Library;
  35. using MediaBrowser.Controller;
  36. using MediaBrowser.Common.Net;
  37. namespace Emby.Server.Implementations.LiveTv
  38. {
  39. /// <summary>
  40. /// Class LiveTvManager
  41. /// </summary>
  42. public class LiveTvManager : ILiveTvManager, IDisposable
  43. {
  44. private readonly IServerConfigurationManager _config;
  45. private readonly ILogger _logger;
  46. private readonly IItemRepository _itemRepo;
  47. private readonly IUserManager _userManager;
  48. private readonly IUserDataManager _userDataManager;
  49. private readonly ILibraryManager _libraryManager;
  50. private readonly ITaskManager _taskManager;
  51. private readonly IJsonSerializer _jsonSerializer;
  52. private readonly IProviderManager _providerManager;
  53. private readonly ISecurityManager _security;
  54. private readonly Func<IChannelManager> _channelManager;
  55. private readonly IDtoService _dtoService;
  56. private readonly ILocalizationManager _localization;
  57. private readonly LiveTvDtoService _tvDtoService;
  58. private ILiveTvService[] _services = new ILiveTvService[] { };
  59. private ITunerHost[] _tunerHosts = Array.Empty<ITunerHost>();
  60. private IListingsProvider[] _listingProviders = Array.Empty<IListingsProvider>();
  61. private readonly IFileSystem _fileSystem;
  62. public event EventHandler<GenericEventArgs<TimerEventInfo>> SeriesTimerCancelled;
  63. public event EventHandler<GenericEventArgs<TimerEventInfo>> TimerCancelled;
  64. public event EventHandler<GenericEventArgs<TimerEventInfo>> TimerCreated;
  65. public event EventHandler<GenericEventArgs<TimerEventInfo>> SeriesTimerCreated;
  66. public string GetEmbyTvActiveRecordingPath(string id)
  67. {
  68. return EmbyTV.EmbyTV.Current.GetActiveRecordingPath(id);
  69. }
  70. private IServerApplicationHost _appHost;
  71. private IHttpClient _httpClient;
  72. public LiveTvManager(IServerApplicationHost appHost, IHttpClient httpClient, IServerConfigurationManager config, ILogger logger, IItemRepository itemRepo, IImageProcessor imageProcessor, IUserDataManager userDataManager, IDtoService dtoService, IUserManager userManager, ILibraryManager libraryManager, ITaskManager taskManager, ILocalizationManager localization, IJsonSerializer jsonSerializer, IProviderManager providerManager, IFileSystem fileSystem, ISecurityManager security, Func<IChannelManager> channelManager)
  73. {
  74. _appHost = appHost;
  75. _config = config;
  76. _logger = logger;
  77. _itemRepo = itemRepo;
  78. _userManager = userManager;
  79. _libraryManager = libraryManager;
  80. _taskManager = taskManager;
  81. _localization = localization;
  82. _jsonSerializer = jsonSerializer;
  83. _providerManager = providerManager;
  84. _fileSystem = fileSystem;
  85. _security = security;
  86. _dtoService = dtoService;
  87. _userDataManager = userDataManager;
  88. _channelManager = channelManager;
  89. _httpClient = httpClient;
  90. _tvDtoService = new LiveTvDtoService(dtoService, imageProcessor, logger, appHost, _libraryManager);
  91. }
  92. /// <summary>
  93. /// Gets the services.
  94. /// </summary>
  95. /// <value>The services.</value>
  96. public IReadOnlyList<ILiveTvService> Services => _services;
  97. private LiveTvOptions GetConfiguration()
  98. {
  99. return _config.GetConfiguration<LiveTvOptions>("livetv");
  100. }
  101. /// <summary>
  102. /// Adds the parts.
  103. /// </summary>
  104. /// <param name="services">The services.</param>
  105. /// <param name="tunerHosts">The tuner hosts.</param>
  106. /// <param name="listingProviders">The listing providers.</param>
  107. public void AddParts(IEnumerable<ILiveTvService> services, IEnumerable<ITunerHost> tunerHosts, IEnumerable<IListingsProvider> listingProviders)
  108. {
  109. _services = services.ToArray();
  110. _tunerHosts = tunerHosts.Where(i => i.IsSupported).ToArray();
  111. _listingProviders = listingProviders.ToArray();
  112. foreach (var service in _services)
  113. {
  114. service.DataSourceChanged += service_DataSourceChanged;
  115. if (service is EmbyTV.EmbyTV embyTv)
  116. {
  117. embyTv.TimerCreated += EmbyTv_TimerCreated;
  118. embyTv.TimerCancelled += EmbyTv_TimerCancelled;
  119. }
  120. }
  121. }
  122. private void EmbyTv_TimerCancelled(object sender, GenericEventArgs<string> e)
  123. {
  124. var timerId = e.Argument;
  125. TimerCancelled?.Invoke(this, new GenericEventArgs<TimerEventInfo>
  126. {
  127. Argument = new TimerEventInfo
  128. {
  129. Id = timerId
  130. }
  131. });
  132. }
  133. private void EmbyTv_TimerCreated(object sender, GenericEventArgs<TimerInfo> e)
  134. {
  135. var timer = e.Argument;
  136. var service = sender as ILiveTvService;
  137. TimerCreated?.Invoke(this, new GenericEventArgs<TimerEventInfo>
  138. {
  139. Argument = new TimerEventInfo
  140. {
  141. ProgramId = _tvDtoService.GetInternalProgramId(timer.ProgramId),
  142. Id = timer.Id
  143. }
  144. });
  145. }
  146. public ITunerHost[] TunerHosts => _tunerHosts;
  147. public IListingsProvider[] ListingProviders => _listingProviders;
  148. public List<NameIdPair> GetTunerHostTypes()
  149. {
  150. return _tunerHosts.OrderBy(i => i.Name).Select(i => new NameIdPair
  151. {
  152. Name = i.Name,
  153. Id = i.Type
  154. }).ToList();
  155. }
  156. public Task<List<TunerHostInfo>> DiscoverTuners(bool newDevicesOnly, CancellationToken cancellationToken)
  157. {
  158. return EmbyTV.EmbyTV.Current.DiscoverTuners(newDevicesOnly, cancellationToken);
  159. }
  160. void service_DataSourceChanged(object sender, EventArgs e)
  161. {
  162. if (!_isDisposed)
  163. {
  164. _taskManager.CancelIfRunningAndQueue<RefreshChannelsScheduledTask>();
  165. }
  166. }
  167. public QueryResult<BaseItem> GetInternalChannels(LiveTvChannelQuery query, DtoOptions dtoOptions, CancellationToken cancellationToken)
  168. {
  169. var user = query.UserId.Equals(Guid.Empty) ? null : _userManager.GetUserById(query.UserId);
  170. var topFolder = GetInternalLiveTvFolder(cancellationToken);
  171. var internalQuery = new InternalItemsQuery(user)
  172. {
  173. IsMovie = query.IsMovie,
  174. IsNews = query.IsNews,
  175. IsKids = query.IsKids,
  176. IsSports = query.IsSports,
  177. IsSeries = query.IsSeries,
  178. IncludeItemTypes = new[] { typeof(LiveTvChannel).Name },
  179. TopParentIds = new[] { topFolder.Id },
  180. IsFavorite = query.IsFavorite,
  181. IsLiked = query.IsLiked,
  182. StartIndex = query.StartIndex,
  183. Limit = query.Limit,
  184. DtoOptions = dtoOptions
  185. };
  186. var orderBy = internalQuery.OrderBy.ToList();
  187. orderBy.AddRange(query.SortBy.Select(i => new ValueTuple<string, SortOrder>(i, query.SortOrder ?? SortOrder.Ascending)));
  188. if (query.EnableFavoriteSorting)
  189. {
  190. orderBy.Insert(0, new ValueTuple<string, SortOrder>(ItemSortBy.IsFavoriteOrLiked, SortOrder.Descending));
  191. }
  192. if (!internalQuery.OrderBy.Any(i => string.Equals(i.Item1, ItemSortBy.SortName, StringComparison.OrdinalIgnoreCase)))
  193. {
  194. orderBy.Add(new ValueTuple<string, SortOrder>(ItemSortBy.SortName, SortOrder.Ascending));
  195. }
  196. internalQuery.OrderBy = orderBy.ToArray();
  197. return _libraryManager.GetItemsResult(internalQuery);
  198. }
  199. public async Task<Tuple<MediaSourceInfo, ILiveStream>> GetChannelStream(string id, string mediaSourceId, List<ILiveStream> currentLiveStreams, CancellationToken cancellationToken)
  200. {
  201. if (string.Equals(id, mediaSourceId, StringComparison.OrdinalIgnoreCase))
  202. {
  203. mediaSourceId = null;
  204. }
  205. var channel = (LiveTvChannel)_libraryManager.GetItemById(id);
  206. bool isVideo = channel.ChannelType == ChannelType.TV;
  207. ILiveTvService service = GetService(channel);
  208. _logger.LogInformation("Opening channel stream from {0}, external channel Id: {1}", service.Name, channel.ExternalId);
  209. MediaSourceInfo info;
  210. ILiveStream liveStream;
  211. if (service is ISupportsDirectStreamProvider supportsManagedStream)
  212. {
  213. liveStream = await supportsManagedStream.GetChannelStreamWithDirectStreamProvider(channel.ExternalId, mediaSourceId, currentLiveStreams, cancellationToken).ConfigureAwait(false);
  214. info = liveStream.MediaSource;
  215. }
  216. else
  217. {
  218. info = await service.GetChannelStream(channel.ExternalId, mediaSourceId, cancellationToken).ConfigureAwait(false);
  219. var openedId = info.Id;
  220. Func<Task> closeFn = () => service.CloseLiveStream(openedId, CancellationToken.None);
  221. liveStream = new ExclusiveLiveStream(info, closeFn);
  222. var startTime = DateTime.UtcNow;
  223. await liveStream.Open(cancellationToken).ConfigureAwait(false);
  224. var endTime = DateTime.UtcNow;
  225. _logger.LogInformation("Live stream opened after {0}ms", (endTime - startTime).TotalMilliseconds);
  226. }
  227. info.RequiresClosing = true;
  228. var idPrefix = service.GetType().FullName.GetMD5().ToString("N") + "_";
  229. info.LiveStreamId = idPrefix + info.Id;
  230. Normalize(info, service, isVideo);
  231. return new Tuple<MediaSourceInfo, ILiveStream>(info, liveStream);
  232. }
  233. public async Task<IEnumerable<MediaSourceInfo>> GetChannelMediaSources(BaseItem item, CancellationToken cancellationToken)
  234. {
  235. var baseItem = (LiveTvChannel)item;
  236. var service = GetService(baseItem);
  237. var sources = await service.GetChannelStreamMediaSources(baseItem.ExternalId, cancellationToken).ConfigureAwait(false);
  238. if (sources.Count == 0)
  239. {
  240. throw new NotImplementedException();
  241. }
  242. foreach (var source in sources)
  243. {
  244. Normalize(source, service, baseItem.ChannelType == ChannelType.TV);
  245. }
  246. return sources;
  247. }
  248. private ILiveTvService GetService(LiveTvChannel item)
  249. {
  250. var name = item.ServiceName;
  251. return GetService(name);
  252. }
  253. private ILiveTvService GetService(LiveTvProgram item)
  254. {
  255. var channel = _libraryManager.GetItemById(item.ChannelId) as LiveTvChannel;
  256. return GetService(channel);
  257. }
  258. private ILiveTvService GetService(string name)
  259. {
  260. return _services.FirstOrDefault(i => string.Equals(i.Name, name, StringComparison.OrdinalIgnoreCase));
  261. }
  262. private static void Normalize(MediaSourceInfo mediaSource, ILiveTvService service, bool isVideo)
  263. {
  264. // Not all of the plugins are setting this
  265. mediaSource.IsInfiniteStream = true;
  266. if (mediaSource.MediaStreams.Count == 0)
  267. {
  268. if (isVideo)
  269. {
  270. mediaSource.MediaStreams.AddRange(new List<MediaStream>
  271. {
  272. new MediaStream
  273. {
  274. Type = MediaStreamType.Video,
  275. // Set the index to -1 because we don't know the exact index of the video stream within the container
  276. Index = -1,
  277. // Set to true if unknown to enable deinterlacing
  278. IsInterlaced = true
  279. },
  280. new MediaStream
  281. {
  282. Type = MediaStreamType.Audio,
  283. // Set the index to -1 because we don't know the exact index of the audio stream within the container
  284. Index = -1
  285. }
  286. });
  287. }
  288. else
  289. {
  290. mediaSource.MediaStreams.AddRange(new List<MediaStream>
  291. {
  292. new MediaStream
  293. {
  294. Type = MediaStreamType.Audio,
  295. // Set the index to -1 because we don't know the exact index of the audio stream within the container
  296. Index = -1
  297. }
  298. });
  299. }
  300. }
  301. // Clean some bad data coming from providers
  302. foreach (var stream in mediaSource.MediaStreams)
  303. {
  304. if (stream.BitRate.HasValue && stream.BitRate <= 0)
  305. {
  306. stream.BitRate = null;
  307. }
  308. if (stream.Channels.HasValue && stream.Channels <= 0)
  309. {
  310. stream.Channels = null;
  311. }
  312. if (stream.AverageFrameRate.HasValue && stream.AverageFrameRate <= 0)
  313. {
  314. stream.AverageFrameRate = null;
  315. }
  316. if (stream.RealFrameRate.HasValue && stream.RealFrameRate <= 0)
  317. {
  318. stream.RealFrameRate = null;
  319. }
  320. if (stream.Width.HasValue && stream.Width <= 0)
  321. {
  322. stream.Width = null;
  323. }
  324. if (stream.Height.HasValue && stream.Height <= 0)
  325. {
  326. stream.Height = null;
  327. }
  328. if (stream.SampleRate.HasValue && stream.SampleRate <= 0)
  329. {
  330. stream.SampleRate = null;
  331. }
  332. if (stream.Level.HasValue && stream.Level <= 0)
  333. {
  334. stream.Level = null;
  335. }
  336. }
  337. var indexes = mediaSource.MediaStreams.Select(i => i.Index).Distinct().ToList();
  338. // If there are duplicate stream indexes, set them all to unknown
  339. if (indexes.Count != mediaSource.MediaStreams.Count)
  340. {
  341. foreach (var stream in mediaSource.MediaStreams)
  342. {
  343. stream.Index = -1;
  344. }
  345. }
  346. // Set the total bitrate if not already supplied
  347. mediaSource.InferTotalBitrate();
  348. if (!(service is EmbyTV.EmbyTV))
  349. {
  350. // We can't trust that we'll be able to direct stream it through emby server, no matter what the provider says
  351. //mediaSource.SupportsDirectPlay = false;
  352. //mediaSource.SupportsDirectStream = false;
  353. mediaSource.SupportsTranscoding = true;
  354. foreach (var stream in mediaSource.MediaStreams)
  355. {
  356. if (stream.Type == MediaStreamType.Video && string.IsNullOrWhiteSpace(stream.NalLengthSize))
  357. {
  358. stream.NalLengthSize = "0";
  359. }
  360. if (stream.Type == MediaStreamType.Video)
  361. {
  362. stream.IsInterlaced = true;
  363. }
  364. }
  365. }
  366. }
  367. private const string ExternalServiceTag = "ExternalServiceId";
  368. private LiveTvChannel GetChannel(ChannelInfo channelInfo, string serviceName, BaseItem parentFolder, CancellationToken cancellationToken)
  369. {
  370. var parentFolderId = parentFolder.Id;
  371. var isNew = false;
  372. var forceUpdate = false;
  373. var id = _tvDtoService.GetInternalChannelId(serviceName, channelInfo.Id);
  374. var item = _libraryManager.GetItemById(id) as LiveTvChannel;
  375. if (item == null)
  376. {
  377. item = new LiveTvChannel
  378. {
  379. Name = channelInfo.Name,
  380. Id = id,
  381. DateCreated = DateTime.UtcNow
  382. };
  383. isNew = true;
  384. }
  385. if (channelInfo.Tags != null)
  386. {
  387. if (!channelInfo.Tags.SequenceEqual(item.Tags, StringComparer.OrdinalIgnoreCase))
  388. {
  389. isNew = true;
  390. }
  391. item.Tags = channelInfo.Tags;
  392. }
  393. if (!item.ParentId.Equals(parentFolderId))
  394. {
  395. isNew = true;
  396. }
  397. item.ParentId = parentFolderId;
  398. item.ChannelType = channelInfo.ChannelType;
  399. item.ServiceName = serviceName;
  400. if (!string.Equals(item.GetProviderId(ExternalServiceTag), serviceName, StringComparison.OrdinalIgnoreCase))
  401. {
  402. forceUpdate = true;
  403. }
  404. item.SetProviderId(ExternalServiceTag, serviceName);
  405. if (!string.Equals(channelInfo.Id, item.ExternalId, StringComparison.Ordinal))
  406. {
  407. forceUpdate = true;
  408. }
  409. item.ExternalId = channelInfo.Id;
  410. if (!string.Equals(channelInfo.Number, item.Number, StringComparison.Ordinal))
  411. {
  412. forceUpdate = true;
  413. }
  414. item.Number = channelInfo.Number;
  415. if (!string.Equals(channelInfo.Name, item.Name, StringComparison.Ordinal))
  416. {
  417. forceUpdate = true;
  418. }
  419. item.Name = channelInfo.Name;
  420. if (!item.HasImage(ImageType.Primary))
  421. {
  422. if (!string.IsNullOrWhiteSpace(channelInfo.ImagePath))
  423. {
  424. item.SetImagePath(ImageType.Primary, channelInfo.ImagePath);
  425. forceUpdate = true;
  426. }
  427. else if (!string.IsNullOrWhiteSpace(channelInfo.ImageUrl))
  428. {
  429. item.SetImagePath(ImageType.Primary, channelInfo.ImageUrl);
  430. forceUpdate = true;
  431. }
  432. }
  433. if (isNew)
  434. {
  435. _libraryManager.CreateItem(item, parentFolder);
  436. }
  437. else if (forceUpdate)
  438. {
  439. _libraryManager.UpdateItem(item, parentFolder, ItemUpdateType.MetadataImport, cancellationToken);
  440. }
  441. return item;
  442. }
  443. private const string EtagKey = "ProgramEtag";
  444. private Tuple<LiveTvProgram, bool, bool> GetProgram(ProgramInfo info, Dictionary<Guid, LiveTvProgram> allExistingPrograms, LiveTvChannel channel, ChannelType channelType, string serviceName, CancellationToken cancellationToken)
  445. {
  446. var id = _tvDtoService.GetInternalProgramId(info.Id);
  447. var isNew = false;
  448. var forceUpdate = false;
  449. LiveTvProgram item;
  450. if (!allExistingPrograms.TryGetValue(id, out item))
  451. {
  452. isNew = true;
  453. item = new LiveTvProgram
  454. {
  455. Name = info.Name,
  456. Id = id,
  457. DateCreated = DateTime.UtcNow,
  458. DateModified = DateTime.UtcNow
  459. };
  460. if (!string.IsNullOrEmpty(info.Etag))
  461. {
  462. item.SetProviderId(EtagKey, info.Etag);
  463. }
  464. }
  465. if (!string.Equals(info.ShowId, item.ShowId, StringComparison.OrdinalIgnoreCase))
  466. {
  467. item.ShowId = info.ShowId;
  468. forceUpdate = true;
  469. }
  470. var seriesId = info.SeriesId;
  471. if (!item.ParentId.Equals(channel.Id))
  472. {
  473. forceUpdate = true;
  474. }
  475. item.ParentId = channel.Id;
  476. //item.ChannelType = channelType;
  477. item.Audio = info.Audio;
  478. item.ChannelId = channel.Id;
  479. item.CommunityRating = item.CommunityRating ?? info.CommunityRating;
  480. if ((item.CommunityRating ?? 0).Equals(0))
  481. {
  482. item.CommunityRating = null;
  483. }
  484. item.EpisodeTitle = info.EpisodeTitle;
  485. item.ExternalId = info.Id;
  486. if (!string.IsNullOrWhiteSpace(seriesId) && !string.Equals(item.ExternalSeriesId, seriesId, StringComparison.Ordinal))
  487. {
  488. forceUpdate = true;
  489. }
  490. item.ExternalSeriesId = seriesId;
  491. var isSeries = info.IsSeries || !string.IsNullOrEmpty(info.EpisodeTitle);
  492. if (isSeries || !string.IsNullOrEmpty(info.EpisodeTitle))
  493. {
  494. item.SeriesName = info.Name;
  495. }
  496. var tags = new List<string>();
  497. if (info.IsLive)
  498. {
  499. tags.Add("Live");
  500. }
  501. if (info.IsPremiere)
  502. {
  503. tags.Add("Premiere");
  504. }
  505. if (info.IsNews)
  506. {
  507. tags.Add("News");
  508. }
  509. if (info.IsSports)
  510. {
  511. tags.Add("Sports");
  512. }
  513. if (info.IsKids)
  514. {
  515. tags.Add("Kids");
  516. }
  517. if (info.IsRepeat)
  518. {
  519. tags.Add("Repeat");
  520. }
  521. if (info.IsMovie)
  522. {
  523. tags.Add("Movie");
  524. }
  525. if (isSeries)
  526. {
  527. tags.Add("Series");
  528. }
  529. item.Tags = tags.ToArray();
  530. item.Genres = info.Genres.ToArray();
  531. if (info.IsHD ?? false)
  532. {
  533. item.Width = 1280;
  534. item.Height = 720;
  535. }
  536. item.IsMovie = info.IsMovie;
  537. item.IsRepeat = info.IsRepeat;
  538. if (item.IsSeries != isSeries)
  539. {
  540. forceUpdate = true;
  541. }
  542. item.IsSeries = isSeries;
  543. item.Name = info.Name;
  544. item.OfficialRating = item.OfficialRating ?? info.OfficialRating;
  545. item.Overview = item.Overview ?? info.Overview;
  546. item.RunTimeTicks = (info.EndDate - info.StartDate).Ticks;
  547. item.ProviderIds = info.ProviderIds;
  548. foreach (var providerId in info.SeriesProviderIds)
  549. {
  550. info.ProviderIds["Series" + providerId.Key] = providerId.Value;
  551. }
  552. if (item.StartDate != info.StartDate)
  553. {
  554. forceUpdate = true;
  555. }
  556. item.StartDate = info.StartDate;
  557. if (item.EndDate != info.EndDate)
  558. {
  559. forceUpdate = true;
  560. }
  561. item.EndDate = info.EndDate;
  562. item.ProductionYear = info.ProductionYear;
  563. if (!isSeries || info.IsRepeat)
  564. {
  565. item.PremiereDate = info.OriginalAirDate;
  566. }
  567. item.IndexNumber = info.EpisodeNumber;
  568. item.ParentIndexNumber = info.SeasonNumber;
  569. if (!item.HasImage(ImageType.Primary))
  570. {
  571. if (!string.IsNullOrWhiteSpace(info.ImagePath))
  572. {
  573. item.SetImage(new ItemImageInfo
  574. {
  575. Path = info.ImagePath,
  576. Type = ImageType.Primary
  577. }, 0);
  578. }
  579. else if (!string.IsNullOrWhiteSpace(info.ImageUrl))
  580. {
  581. item.SetImage(new ItemImageInfo
  582. {
  583. Path = info.ImageUrl,
  584. Type = ImageType.Primary
  585. }, 0);
  586. }
  587. }
  588. if (!item.HasImage(ImageType.Thumb))
  589. {
  590. if (!string.IsNullOrWhiteSpace(info.ThumbImageUrl))
  591. {
  592. item.SetImage(new ItemImageInfo
  593. {
  594. Path = info.ThumbImageUrl,
  595. Type = ImageType.Thumb
  596. }, 0);
  597. }
  598. }
  599. if (!item.HasImage(ImageType.Logo))
  600. {
  601. if (!string.IsNullOrWhiteSpace(info.LogoImageUrl))
  602. {
  603. item.SetImage(new ItemImageInfo
  604. {
  605. Path = info.LogoImageUrl,
  606. Type = ImageType.Logo
  607. }, 0);
  608. }
  609. }
  610. if (!item.HasImage(ImageType.Backdrop))
  611. {
  612. if (!string.IsNullOrWhiteSpace(info.BackdropImageUrl))
  613. {
  614. item.SetImage(new ItemImageInfo
  615. {
  616. Path = info.BackdropImageUrl,
  617. Type = ImageType.Backdrop
  618. }, 0);
  619. }
  620. }
  621. var isUpdated = false;
  622. if (isNew)
  623. {
  624. }
  625. else if (forceUpdate || string.IsNullOrWhiteSpace(info.Etag))
  626. {
  627. isUpdated = true;
  628. }
  629. else
  630. {
  631. var etag = info.Etag;
  632. if (!string.Equals(etag, item.GetProviderId(EtagKey), StringComparison.OrdinalIgnoreCase))
  633. {
  634. item.SetProviderId(EtagKey, etag);
  635. isUpdated = true;
  636. }
  637. }
  638. if (isNew || isUpdated)
  639. {
  640. item.OnMetadataChanged();
  641. }
  642. return new Tuple<LiveTvProgram, bool, bool>(item, isNew, isUpdated);
  643. }
  644. public async Task<BaseItemDto> GetProgram(string id, CancellationToken cancellationToken, User user = null)
  645. {
  646. var program = _libraryManager.GetItemById(id);
  647. var dto = _dtoService.GetBaseItemDto(program, new DtoOptions(), user);
  648. var list = new List<Tuple<BaseItemDto, string, string>>() {
  649. new Tuple<BaseItemDto, string, string>(dto, program.ExternalId, program.ExternalSeriesId)
  650. };
  651. await AddRecordingInfo(list, cancellationToken).ConfigureAwait(false);
  652. return dto;
  653. }
  654. public async Task<QueryResult<BaseItemDto>> GetPrograms(InternalItemsQuery query, DtoOptions options, CancellationToken cancellationToken)
  655. {
  656. var user = query.User;
  657. var topFolder = GetInternalLiveTvFolder(cancellationToken);
  658. if (query.OrderBy.Length == 0)
  659. {
  660. if (query.IsAiring ?? false)
  661. {
  662. // Unless something else was specified, order by start date to take advantage of a specialized index
  663. query.OrderBy = new ValueTuple<string, SortOrder>[]
  664. {
  665. new ValueTuple<string, SortOrder>(ItemSortBy.StartDate, SortOrder.Ascending)
  666. };
  667. }
  668. else
  669. {
  670. // Unless something else was specified, order by start date to take advantage of a specialized index
  671. query.OrderBy = new ValueTuple<string, SortOrder>[]
  672. {
  673. new ValueTuple<string, SortOrder>(ItemSortBy.StartDate, SortOrder.Ascending)
  674. };
  675. }
  676. }
  677. RemoveFields(options);
  678. var internalQuery = new InternalItemsQuery(user)
  679. {
  680. IncludeItemTypes = new[] { typeof(LiveTvProgram).Name },
  681. MinEndDate = query.MinEndDate,
  682. MinStartDate = query.MinStartDate,
  683. MaxEndDate = query.MaxEndDate,
  684. MaxStartDate = query.MaxStartDate,
  685. ChannelIds = query.ChannelIds,
  686. IsMovie = query.IsMovie,
  687. IsSeries = query.IsSeries,
  688. IsSports = query.IsSports,
  689. IsKids = query.IsKids,
  690. IsNews = query.IsNews,
  691. Genres = query.Genres,
  692. GenreIds = query.GenreIds,
  693. StartIndex = query.StartIndex,
  694. Limit = query.Limit,
  695. OrderBy = query.OrderBy,
  696. EnableTotalRecordCount = query.EnableTotalRecordCount,
  697. TopParentIds = new[] { topFolder.Id },
  698. Name = query.Name,
  699. DtoOptions = options,
  700. HasAired = query.HasAired,
  701. IsAiring = query.IsAiring
  702. };
  703. if (!string.IsNullOrWhiteSpace(query.SeriesTimerId))
  704. {
  705. var seriesTimers = await GetSeriesTimersInternal(new SeriesTimerQuery { }, cancellationToken).ConfigureAwait(false);
  706. var seriesTimer = seriesTimers.Items.FirstOrDefault(i => string.Equals(_tvDtoService.GetInternalSeriesTimerId(i.Id).ToString("N"), query.SeriesTimerId, StringComparison.OrdinalIgnoreCase));
  707. if (seriesTimer != null)
  708. {
  709. internalQuery.ExternalSeriesId = seriesTimer.SeriesId;
  710. if (string.IsNullOrWhiteSpace(seriesTimer.SeriesId))
  711. {
  712. // Better to return nothing than every program in the database
  713. return new QueryResult<BaseItemDto>();
  714. }
  715. }
  716. else
  717. {
  718. // Better to return nothing than every program in the database
  719. return new QueryResult<BaseItemDto>();
  720. }
  721. }
  722. var queryResult = _libraryManager.QueryItems(internalQuery);
  723. var returnArray = _dtoService.GetBaseItemDtos(queryResult.Items, options, user);
  724. var result = new QueryResult<BaseItemDto>
  725. {
  726. Items = returnArray,
  727. TotalRecordCount = queryResult.TotalRecordCount
  728. };
  729. return result;
  730. }
  731. public QueryResult<BaseItem> GetRecommendedProgramsInternal(InternalItemsQuery query, DtoOptions options, CancellationToken cancellationToken)
  732. {
  733. var user = query.User;
  734. var topFolder = GetInternalLiveTvFolder(cancellationToken);
  735. var internalQuery = new InternalItemsQuery(user)
  736. {
  737. IncludeItemTypes = new[] { typeof(LiveTvProgram).Name },
  738. IsAiring = query.IsAiring,
  739. HasAired = query.HasAired,
  740. IsNews = query.IsNews,
  741. IsMovie = query.IsMovie,
  742. IsSeries = query.IsSeries,
  743. IsSports = query.IsSports,
  744. IsKids = query.IsKids,
  745. EnableTotalRecordCount = query.EnableTotalRecordCount,
  746. OrderBy = new[] { new ValueTuple<string, SortOrder>(ItemSortBy.StartDate, SortOrder.Ascending) },
  747. TopParentIds = new[] { topFolder.Id },
  748. DtoOptions = options,
  749. GenreIds = query.GenreIds
  750. };
  751. if (query.Limit.HasValue)
  752. {
  753. internalQuery.Limit = Math.Max(query.Limit.Value * 4, 200);
  754. }
  755. var programList = _libraryManager.QueryItems(internalQuery).Items;
  756. var totalCount = programList.Length;
  757. IOrderedEnumerable<LiveTvProgram> orderedPrograms = programList.Cast<LiveTvProgram>().OrderBy(i => i.StartDate.Date);
  758. if (query.IsAiring ?? false)
  759. {
  760. orderedPrograms = orderedPrograms
  761. .ThenByDescending(i => GetRecommendationScore(i, user, true));
  762. }
  763. IEnumerable<BaseItem> programs = orderedPrograms;
  764. if (query.Limit.HasValue)
  765. {
  766. programs = programs.Take(query.Limit.Value);
  767. }
  768. return new QueryResult<BaseItem>
  769. {
  770. Items = programs.ToArray(),
  771. TotalRecordCount = totalCount
  772. };
  773. }
  774. public QueryResult<BaseItemDto> GetRecommendedPrograms(InternalItemsQuery query, DtoOptions options, CancellationToken cancellationToken)
  775. {
  776. if (!(query.IsAiring ?? false))
  777. {
  778. return GetPrograms(query, options, cancellationToken).Result;
  779. }
  780. RemoveFields(options);
  781. var internalResult = GetRecommendedProgramsInternal(query, options, cancellationToken);
  782. return new QueryResult<BaseItemDto>
  783. {
  784. Items = _dtoService.GetBaseItemDtos(internalResult.Items, options, query.User),
  785. TotalRecordCount = internalResult.TotalRecordCount
  786. };
  787. }
  788. private int GetRecommendationScore(LiveTvProgram program, User user, bool factorChannelWatchCount)
  789. {
  790. var score = 0;
  791. if (program.IsLive)
  792. {
  793. score++;
  794. }
  795. if (program.IsSeries && !program.IsRepeat)
  796. {
  797. score++;
  798. }
  799. var channel = _libraryManager.GetItemById(program.ChannelId);
  800. if (channel == null)
  801. {
  802. return score;
  803. }
  804. var channelUserdata = _userDataManager.GetUserData(user, channel);
  805. if (channelUserdata.Likes.HasValue)
  806. {
  807. score += channelUserdata.Likes.Value ? 2 : -2;
  808. }
  809. if (channelUserdata.IsFavorite)
  810. {
  811. score += 3;
  812. }
  813. if (factorChannelWatchCount)
  814. {
  815. score += channelUserdata.PlayCount;
  816. }
  817. return score;
  818. }
  819. private async Task AddRecordingInfo(IEnumerable<Tuple<BaseItemDto, string, string>> programs, CancellationToken cancellationToken)
  820. {
  821. var timers = new Dictionary<string, List<TimerInfo>>();
  822. var seriesTimers = new Dictionary<string, List<SeriesTimerInfo>>();
  823. TimerInfo[] timerList = null;
  824. SeriesTimerInfo[] seriesTimerList = null;
  825. foreach (var programTuple in programs)
  826. {
  827. var program = programTuple.Item1;
  828. var externalProgramId = programTuple.Item2;
  829. string externalSeriesId = programTuple.Item3;
  830. if (timerList == null)
  831. {
  832. timerList = (await GetTimersInternal(new TimerQuery(), cancellationToken).ConfigureAwait(false)).Items;
  833. }
  834. var timer = timerList.FirstOrDefault(i => string.Equals(i.ProgramId, externalProgramId, StringComparison.OrdinalIgnoreCase));
  835. var foundSeriesTimer = false;
  836. if (timer != null)
  837. {
  838. if (timer.Status != RecordingStatus.Cancelled && timer.Status != RecordingStatus.Error)
  839. {
  840. program.TimerId = _tvDtoService.GetInternalTimerId(timer.Id);
  841. program.Status = timer.Status.ToString();
  842. }
  843. if (!string.IsNullOrEmpty(timer.SeriesTimerId))
  844. {
  845. program.SeriesTimerId = _tvDtoService.GetInternalSeriesTimerId(timer.SeriesTimerId)
  846. .ToString("N");
  847. foundSeriesTimer = true;
  848. }
  849. }
  850. if (foundSeriesTimer || string.IsNullOrWhiteSpace(externalSeriesId))
  851. {
  852. continue;
  853. }
  854. if (seriesTimerList == null)
  855. {
  856. seriesTimerList = (await GetSeriesTimersInternal(new SeriesTimerQuery(), cancellationToken).ConfigureAwait(false)).Items;
  857. }
  858. var seriesTimer = seriesTimerList.FirstOrDefault(i => string.Equals(i.SeriesId, externalSeriesId, StringComparison.OrdinalIgnoreCase));
  859. if (seriesTimer != null)
  860. {
  861. program.SeriesTimerId = _tvDtoService.GetInternalSeriesTimerId(seriesTimer.Id)
  862. .ToString("N");
  863. }
  864. }
  865. }
  866. internal Task RefreshChannels(IProgress<double> progress, CancellationToken cancellationToken)
  867. {
  868. return RefreshChannelsInternal(progress, cancellationToken);
  869. }
  870. private async Task RefreshChannelsInternal(IProgress<double> progress, CancellationToken cancellationToken)
  871. {
  872. await EmbyTV.EmbyTV.Current.CreateRecordingFolders().ConfigureAwait(false);
  873. await EmbyTV.EmbyTV.Current.ScanForTunerDeviceChanges(cancellationToken).ConfigureAwait(false);
  874. var numComplete = 0;
  875. double progressPerService = _services.Length == 0
  876. ? 0
  877. : 1.0 / _services.Length;
  878. var newChannelIdList = new List<Guid>();
  879. var newProgramIdList = new List<Guid>();
  880. var cleanDatabase = true;
  881. foreach (var service in _services)
  882. {
  883. cancellationToken.ThrowIfCancellationRequested();
  884. _logger.LogDebug("Refreshing guide from {name}", service.Name);
  885. try
  886. {
  887. var innerProgress = new ActionableProgress<double>();
  888. innerProgress.RegisterAction(p => progress.Report(p * progressPerService));
  889. var idList = await RefreshChannelsInternal(service, innerProgress, cancellationToken).ConfigureAwait(false);
  890. newChannelIdList.AddRange(idList.Item1);
  891. newProgramIdList.AddRange(idList.Item2);
  892. }
  893. catch (OperationCanceledException)
  894. {
  895. throw;
  896. }
  897. catch (Exception ex)
  898. {
  899. cleanDatabase = false;
  900. _logger.LogError(ex, "Error refreshing channels for service");
  901. }
  902. numComplete++;
  903. double percent = numComplete;
  904. percent /= _services.Length;
  905. progress.Report(100 * percent);
  906. }
  907. if (cleanDatabase)
  908. {
  909. CleanDatabaseInternal(newChannelIdList.ToArray(), new[] { typeof(LiveTvChannel).Name }, progress, cancellationToken);
  910. CleanDatabaseInternal(newProgramIdList.ToArray(), new[] { typeof(LiveTvProgram).Name }, progress, cancellationToken);
  911. }
  912. var coreService = _services.OfType<EmbyTV.EmbyTV>().FirstOrDefault();
  913. if (coreService != null)
  914. {
  915. await coreService.RefreshSeriesTimers(cancellationToken, new SimpleProgress<double>()).ConfigureAwait(false);
  916. await coreService.RefreshTimers(cancellationToken, new SimpleProgress<double>()).ConfigureAwait(false);
  917. }
  918. // Load these now which will prefetch metadata
  919. var dtoOptions = new DtoOptions();
  920. var fields = dtoOptions.Fields.ToList();
  921. fields.Remove(ItemFields.BasicSyncInfo);
  922. dtoOptions.Fields = fields.ToArray();
  923. progress.Report(100);
  924. }
  925. private async Task<Tuple<List<Guid>, List<Guid>>> RefreshChannelsInternal(ILiveTvService service, IProgress<double> progress, CancellationToken cancellationToken)
  926. {
  927. progress.Report(10);
  928. var allChannelsList = (await service.GetChannelsAsync(cancellationToken).ConfigureAwait(false))
  929. .Select(i => new Tuple<string, ChannelInfo>(service.Name, i))
  930. .ToList();
  931. var list = new List<LiveTvChannel>();
  932. var numComplete = 0;
  933. var parentFolder = GetInternalLiveTvFolder(cancellationToken);
  934. foreach (var channelInfo in allChannelsList)
  935. {
  936. cancellationToken.ThrowIfCancellationRequested();
  937. try
  938. {
  939. var item = GetChannel(channelInfo.Item2, channelInfo.Item1, parentFolder, cancellationToken);
  940. list.Add(item);
  941. }
  942. catch (OperationCanceledException)
  943. {
  944. throw;
  945. }
  946. catch (Exception ex)
  947. {
  948. _logger.LogError(ex, "Error getting channel information for {name}", channelInfo.Item2.Name);
  949. }
  950. numComplete++;
  951. double percent = numComplete;
  952. percent /= allChannelsList.Count;
  953. progress.Report(5 * percent + 10);
  954. }
  955. progress.Report(15);
  956. numComplete = 0;
  957. var programs = new List<Guid>();
  958. var channels = new List<Guid>();
  959. var guideDays = GetGuideDays();
  960. _logger.LogInformation("Refreshing guide with {0} days of guide data", guideDays);
  961. cancellationToken.ThrowIfCancellationRequested();
  962. foreach (var currentChannel in list)
  963. {
  964. channels.Add(currentChannel.Id);
  965. cancellationToken.ThrowIfCancellationRequested();
  966. try
  967. {
  968. var start = DateTime.UtcNow.AddHours(-1);
  969. var end = start.AddDays(guideDays);
  970. var isMovie = false;
  971. var isSports = false;
  972. var isNews = false;
  973. var isKids = false;
  974. var iSSeries = false;
  975. var channelPrograms = (await service.GetProgramsAsync(currentChannel.ExternalId, start, end, cancellationToken).ConfigureAwait(false)).ToList();
  976. var existingPrograms = _libraryManager.GetItemList(new InternalItemsQuery
  977. {
  978. IncludeItemTypes = new string[] { typeof(LiveTvProgram).Name },
  979. ChannelIds = new Guid[] { currentChannel.Id },
  980. DtoOptions = new DtoOptions(true)
  981. }).Cast<LiveTvProgram>().ToDictionary(i => i.Id);
  982. var newPrograms = new List<LiveTvProgram>();
  983. var updatedPrograms = new List<BaseItem>();
  984. foreach (var program in channelPrograms)
  985. {
  986. var programTuple = GetProgram(program, existingPrograms, currentChannel, currentChannel.ChannelType, service.Name, cancellationToken);
  987. var programItem = programTuple.Item1;
  988. if (programTuple.Item2)
  989. {
  990. newPrograms.Add(programItem);
  991. }
  992. else if (programTuple.Item3)
  993. {
  994. updatedPrograms.Add(programItem);
  995. }
  996. programs.Add(programItem.Id);
  997. isMovie |= program.IsMovie;
  998. iSSeries |= program.IsSeries;
  999. isSports |= program.IsSports;
  1000. isNews |= program.IsNews;
  1001. isKids |= program.IsKids;
  1002. }
  1003. _logger.LogDebug("Channel {0} has {1} new programs and {2} updated programs", currentChannel.Name, newPrograms.Count, updatedPrograms.Count);
  1004. if (newPrograms.Count > 0)
  1005. {
  1006. _libraryManager.CreateItems(newPrograms, null, cancellationToken);
  1007. }
  1008. if (updatedPrograms.Count > 0)
  1009. {
  1010. _libraryManager.UpdateItems(updatedPrograms, currentChannel, ItemUpdateType.MetadataImport, cancellationToken);
  1011. }
  1012. currentChannel.IsMovie = isMovie;
  1013. currentChannel.IsNews = isNews;
  1014. currentChannel.IsSports = isSports;
  1015. currentChannel.IsSeries = iSSeries;
  1016. if (isKids)
  1017. {
  1018. currentChannel.AddTag("Kids");
  1019. }
  1020. //currentChannel.UpdateToRepository(ItemUpdateType.MetadataImport, cancellationToken);
  1021. await currentChannel.RefreshMetadata(new MetadataRefreshOptions(new DirectoryService(_logger, _fileSystem))
  1022. {
  1023. ForceSave = true
  1024. }, cancellationToken).ConfigureAwait(false);
  1025. }
  1026. catch (OperationCanceledException)
  1027. {
  1028. throw;
  1029. }
  1030. catch (Exception ex)
  1031. {
  1032. _logger.LogError(ex, "Error getting programs for channel {name}", currentChannel.Name);
  1033. }
  1034. numComplete++;
  1035. double percent = numComplete / (double) allChannelsList.Count;
  1036. progress.Report(85 * percent + 15);
  1037. }
  1038. progress.Report(100);
  1039. return new Tuple<List<Guid>, List<Guid>>(channels, programs);
  1040. }
  1041. private void CleanDatabaseInternal(Guid[] currentIdList, string[] validTypes, IProgress<double> progress, CancellationToken cancellationToken)
  1042. {
  1043. var list = _itemRepo.GetItemIdsList(new InternalItemsQuery
  1044. {
  1045. IncludeItemTypes = validTypes,
  1046. DtoOptions = new DtoOptions(false)
  1047. });
  1048. var numComplete = 0;
  1049. foreach (var itemId in list)
  1050. {
  1051. cancellationToken.ThrowIfCancellationRequested();
  1052. if (itemId.Equals(Guid.Empty))
  1053. {
  1054. // Somehow some invalid data got into the db. It probably predates the boundary checking
  1055. continue;
  1056. }
  1057. if (!currentIdList.Contains(itemId))
  1058. {
  1059. var item = _libraryManager.GetItemById(itemId);
  1060. if (item != null)
  1061. {
  1062. _libraryManager.DeleteItem(item, new DeleteOptions
  1063. {
  1064. DeleteFileLocation = false,
  1065. DeleteFromExternalProvider = false
  1066. }, false);
  1067. }
  1068. }
  1069. numComplete++;
  1070. double percent = numComplete / (double) list.Count;
  1071. progress.Report(100 * percent);
  1072. }
  1073. }
  1074. private const int MaxGuideDays = 14;
  1075. private double GetGuideDays()
  1076. {
  1077. var config = GetConfiguration();
  1078. if (config.GuideDays.HasValue)
  1079. {
  1080. return Math.Max(1, Math.Min(config.GuideDays.Value, MaxGuideDays));
  1081. }
  1082. return 7;
  1083. }
  1084. private QueryResult<BaseItem> GetEmbyRecordings(RecordingQuery query, DtoOptions dtoOptions, User user)
  1085. {
  1086. if (user == null)
  1087. {
  1088. return new QueryResult<BaseItem>();
  1089. }
  1090. var folderIds = GetRecordingFolders(user, true)
  1091. .Select(i => i.Id)
  1092. .ToList();
  1093. var excludeItemTypes = new List<string>();
  1094. if (folderIds.Count == 0)
  1095. {
  1096. return new QueryResult<BaseItem>();
  1097. }
  1098. var includeItemTypes = new List<string>();
  1099. var genres = new List<string>();
  1100. if (query.IsMovie.HasValue)
  1101. {
  1102. if (query.IsMovie.Value)
  1103. {
  1104. includeItemTypes.Add(typeof(Movie).Name);
  1105. }
  1106. else
  1107. {
  1108. excludeItemTypes.Add(typeof(Movie).Name);
  1109. }
  1110. }
  1111. if (query.IsSeries.HasValue)
  1112. {
  1113. if (query.IsSeries.Value)
  1114. {
  1115. includeItemTypes.Add(typeof(Episode).Name);
  1116. }
  1117. else
  1118. {
  1119. excludeItemTypes.Add(typeof(Episode).Name);
  1120. }
  1121. }
  1122. if (query.IsSports ?? false)
  1123. {
  1124. genres.Add("Sports");
  1125. }
  1126. if (query.IsKids ?? false)
  1127. {
  1128. genres.Add("Kids");
  1129. genres.Add("Children");
  1130. genres.Add("Family");
  1131. }
  1132. var limit = query.Limit;
  1133. if (query.IsInProgress ?? false)
  1134. {
  1135. // limit = (query.Limit ?? 10) * 2;
  1136. limit = null;
  1137. //var allActivePaths = EmbyTV.EmbyTV.Current.GetAllActiveRecordings().Select(i => i.Path).ToArray();
  1138. //var items = allActivePaths.Select(i => _libraryManager.FindByPath(i, false)).Where(i => i != null).ToArray();
  1139. //return new QueryResult<BaseItem>
  1140. //{
  1141. // Items = items,
  1142. // TotalRecordCount = items.Length
  1143. //};
  1144. dtoOptions.Fields = dtoOptions.Fields.Concat(new[] { ItemFields.Tags }).Distinct().ToArray();
  1145. }
  1146. var result = _libraryManager.GetItemsResult(new InternalItemsQuery(user)
  1147. {
  1148. MediaTypes = new[] { MediaType.Video },
  1149. Recursive = true,
  1150. AncestorIds = folderIds.ToArray(),
  1151. IsFolder = false,
  1152. IsVirtualItem = false,
  1153. Limit = limit,
  1154. StartIndex = query.StartIndex,
  1155. OrderBy = new[] { new ValueTuple<string, SortOrder>(ItemSortBy.DateCreated, SortOrder.Descending) },
  1156. EnableTotalRecordCount = query.EnableTotalRecordCount,
  1157. IncludeItemTypes = includeItemTypes.ToArray(),
  1158. ExcludeItemTypes = excludeItemTypes.ToArray(),
  1159. Genres = genres.ToArray(),
  1160. DtoOptions = dtoOptions
  1161. });
  1162. if (query.IsInProgress ?? false)
  1163. {
  1164. //TODO Fix The co-variant conversion between Video[] and BaseItem[], this can generate runtime issues.
  1165. result.Items = result
  1166. .Items
  1167. .OfType<Video>()
  1168. .Where(i => !i.IsCompleteMedia)
  1169. .ToArray();
  1170. result.TotalRecordCount = result.Items.Length;
  1171. }
  1172. return result;
  1173. }
  1174. public Task AddInfoToProgramDto(List<Tuple<BaseItem, BaseItemDto>> tuples, ItemFields[] fields, User user = null)
  1175. {
  1176. var programTuples = new List<Tuple<BaseItemDto, string, string>>();
  1177. var hasChannelImage = fields.Contains(ItemFields.ChannelImage);
  1178. var hasChannelInfo = fields.Contains(ItemFields.ChannelInfo);
  1179. foreach (var tuple in tuples)
  1180. {
  1181. var program = (LiveTvProgram)tuple.Item1;
  1182. var dto = tuple.Item2;
  1183. dto.StartDate = program.StartDate;
  1184. dto.EpisodeTitle = program.EpisodeTitle;
  1185. dto.IsRepeat |= program.IsRepeat;
  1186. dto.IsMovie |= program.IsMovie;
  1187. dto.IsSeries |= program.IsSeries;
  1188. dto.IsSports |= program.IsSports;
  1189. dto.IsLive |= program.IsLive;
  1190. dto.IsNews |= program.IsNews;
  1191. dto.IsKids |= program.IsKids;
  1192. dto.IsPremiere |= program.IsPremiere;
  1193. if (hasChannelInfo || hasChannelImage)
  1194. {
  1195. var channel = _libraryManager.GetItemById(program.ChannelId);
  1196. if (channel is LiveTvChannel liveChannel)
  1197. {
  1198. dto.ChannelName = liveChannel.Name;
  1199. dto.MediaType = liveChannel.MediaType;
  1200. dto.ChannelNumber = liveChannel.Number;
  1201. if (hasChannelImage && liveChannel.HasImage(ImageType.Primary))
  1202. {
  1203. dto.ChannelPrimaryImageTag = _tvDtoService.GetImageTag(liveChannel);
  1204. }
  1205. }
  1206. }
  1207. programTuples.Add(new Tuple<BaseItemDto, string, string>(dto, program.ExternalId, program.ExternalSeriesId));
  1208. }
  1209. return AddRecordingInfo(programTuples, CancellationToken.None);
  1210. }
  1211. public ActiveRecordingInfo GetActiveRecordingInfo(string path)
  1212. {
  1213. return EmbyTV.EmbyTV.Current.GetActiveRecordingInfo(path);
  1214. }
  1215. public void AddInfoToRecordingDto(BaseItem item, BaseItemDto dto, ActiveRecordingInfo activeRecordingInfo, User user = null)
  1216. {
  1217. var service = EmbyTV.EmbyTV.Current;
  1218. var info = activeRecordingInfo.Timer;
  1219. var channel = string.IsNullOrWhiteSpace(info.ChannelId) ? null : _libraryManager.GetItemById(_tvDtoService.GetInternalChannelId(service.Name, info.ChannelId));
  1220. dto.SeriesTimerId = string.IsNullOrEmpty(info.SeriesTimerId)
  1221. ? null
  1222. : _tvDtoService.GetInternalSeriesTimerId(info.SeriesTimerId).ToString("N");
  1223. dto.TimerId = string.IsNullOrEmpty(info.Id)
  1224. ? null
  1225. : _tvDtoService.GetInternalTimerId(info.Id);
  1226. var startDate = info.StartDate;
  1227. var endDate = info.EndDate;
  1228. dto.StartDate = startDate;
  1229. dto.EndDate = endDate;
  1230. dto.Status = info.Status.ToString();
  1231. dto.IsRepeat = info.IsRepeat;
  1232. dto.EpisodeTitle = info.EpisodeTitle;
  1233. dto.IsMovie = info.IsMovie;
  1234. dto.IsSeries = info.IsSeries;
  1235. dto.IsSports = info.IsSports;
  1236. dto.IsLive = info.IsLive;
  1237. dto.IsNews = info.IsNews;
  1238. dto.IsKids = info.IsKids;
  1239. dto.IsPremiere = info.IsPremiere;
  1240. if (info.Status == RecordingStatus.InProgress)
  1241. {
  1242. startDate = info.StartDate.AddSeconds(0 - info.PrePaddingSeconds);
  1243. endDate = info.EndDate.AddSeconds(info.PostPaddingSeconds);
  1244. var now = DateTime.UtcNow.Ticks;
  1245. var start = startDate.Ticks;
  1246. var end = endDate.Ticks;
  1247. var pct = now - start;
  1248. pct /= end;
  1249. pct *= 100;
  1250. dto.CompletionPercentage = pct;
  1251. }
  1252. if (channel != null)
  1253. {
  1254. dto.ChannelName = channel.Name;
  1255. if (channel.HasImage(ImageType.Primary))
  1256. {
  1257. dto.ChannelPrimaryImageTag = _tvDtoService.GetImageTag(channel);
  1258. }
  1259. }
  1260. }
  1261. public QueryResult<BaseItemDto> GetRecordings(RecordingQuery query, DtoOptions options)
  1262. {
  1263. var user = query.UserId.Equals(Guid.Empty) ? null : _userManager.GetUserById(query.UserId);
  1264. RemoveFields(options);
  1265. var internalResult = GetEmbyRecordings(query, options, user);
  1266. var returnArray = _dtoService.GetBaseItemDtos(internalResult.Items, options, user);
  1267. return new QueryResult<BaseItemDto>
  1268. {
  1269. Items = returnArray,
  1270. TotalRecordCount = internalResult.TotalRecordCount
  1271. };
  1272. }
  1273. private async Task<QueryResult<TimerInfo>> GetTimersInternal(TimerQuery query, CancellationToken cancellationToken)
  1274. {
  1275. var tasks = _services.Select(async i =>
  1276. {
  1277. try
  1278. {
  1279. var recs = await i.GetTimersAsync(cancellationToken).ConfigureAwait(false);
  1280. return recs.Select(r => new Tuple<TimerInfo, ILiveTvService>(r, i));
  1281. }
  1282. catch (Exception ex)
  1283. {
  1284. _logger.LogError(ex, "Error getting recordings");
  1285. return new List<Tuple<TimerInfo, ILiveTvService>>();
  1286. }
  1287. });
  1288. var results = await Task.WhenAll(tasks).ConfigureAwait(false);
  1289. var timers = results.SelectMany(i => i.ToList());
  1290. if (query.IsActive.HasValue)
  1291. {
  1292. if (query.IsActive.Value)
  1293. {
  1294. timers = timers.Where(i => i.Item1.Status == RecordingStatus.InProgress);
  1295. }
  1296. else
  1297. {
  1298. timers = timers.Where(i => i.Item1.Status != RecordingStatus.InProgress);
  1299. }
  1300. }
  1301. if (query.IsScheduled.HasValue)
  1302. {
  1303. if (query.IsScheduled.Value)
  1304. {
  1305. timers = timers.Where(i => i.Item1.Status == RecordingStatus.New);
  1306. }
  1307. else
  1308. {
  1309. timers = timers.Where(i => i.Item1.Status != RecordingStatus.New);
  1310. }
  1311. }
  1312. if (!string.IsNullOrEmpty(query.ChannelId))
  1313. {
  1314. var guid = new Guid(query.ChannelId);
  1315. timers = timers.Where(i => guid == _tvDtoService.GetInternalChannelId(i.Item2.Name, i.Item1.ChannelId));
  1316. }
  1317. if (!string.IsNullOrEmpty(query.SeriesTimerId))
  1318. {
  1319. var guid = new Guid(query.SeriesTimerId);
  1320. timers = timers
  1321. .Where(i => _tvDtoService.GetInternalSeriesTimerId(i.Item1.SeriesTimerId) == guid);
  1322. }
  1323. if (!string.IsNullOrEmpty(query.Id))
  1324. {
  1325. var guid = new Guid(query.Id);
  1326. timers = timers
  1327. .Where(i => string.Equals(_tvDtoService.GetInternalTimerId(i.Item1.Id), query.Id, StringComparison.OrdinalIgnoreCase));
  1328. }
  1329. var returnArray = timers
  1330. .Select(i => i.Item1)
  1331. .OrderBy(i => i.StartDate)
  1332. .ToArray();
  1333. return new QueryResult<TimerInfo>
  1334. {
  1335. Items = returnArray,
  1336. TotalRecordCount = returnArray.Length
  1337. };
  1338. }
  1339. public async Task<QueryResult<TimerInfoDto>> GetTimers(TimerQuery query, CancellationToken cancellationToken)
  1340. {
  1341. var tasks = _services.Select(async i =>
  1342. {
  1343. try
  1344. {
  1345. var recs = await i.GetTimersAsync(cancellationToken).ConfigureAwait(false);
  1346. return recs.Select(r => new Tuple<TimerInfo, ILiveTvService>(r, i));
  1347. }
  1348. catch (Exception ex)
  1349. {
  1350. _logger.LogError(ex, "Error getting recordings");
  1351. return new List<Tuple<TimerInfo, ILiveTvService>>();
  1352. }
  1353. });
  1354. var results = await Task.WhenAll(tasks).ConfigureAwait(false);
  1355. var timers = results.SelectMany(i => i.ToList());
  1356. if (query.IsActive.HasValue)
  1357. {
  1358. if (query.IsActive.Value)
  1359. {
  1360. timers = timers.Where(i => i.Item1.Status == RecordingStatus.InProgress);
  1361. }
  1362. else
  1363. {
  1364. timers = timers.Where(i => i.Item1.Status != RecordingStatus.InProgress);
  1365. }
  1366. }
  1367. if (query.IsScheduled.HasValue)
  1368. {
  1369. if (query.IsScheduled.Value)
  1370. {
  1371. timers = timers.Where(i => i.Item1.Status == RecordingStatus.New);
  1372. }
  1373. else
  1374. {
  1375. timers = timers.Where(i => i.Item1.Status != RecordingStatus.New);
  1376. }
  1377. }
  1378. if (!string.IsNullOrEmpty(query.ChannelId))
  1379. {
  1380. var guid = new Guid(query.ChannelId);
  1381. timers = timers.Where(i => guid == _tvDtoService.GetInternalChannelId(i.Item2.Name, i.Item1.ChannelId));
  1382. }
  1383. if (!string.IsNullOrEmpty(query.SeriesTimerId))
  1384. {
  1385. var guid = new Guid(query.SeriesTimerId);
  1386. timers = timers
  1387. .Where(i => _tvDtoService.GetInternalSeriesTimerId(i.Item1.SeriesTimerId) == guid);
  1388. }
  1389. if (!string.IsNullOrEmpty(query.Id))
  1390. {
  1391. timers = timers
  1392. .Where(i => string.Equals(_tvDtoService.GetInternalTimerId(i.Item1.Id), query.Id, StringComparison.OrdinalIgnoreCase));
  1393. }
  1394. var returnList = new List<TimerInfoDto>();
  1395. foreach (var i in timers)
  1396. {
  1397. var program = string.IsNullOrEmpty(i.Item1.ProgramId) ?
  1398. null :
  1399. _libraryManager.GetItemById(_tvDtoService.GetInternalProgramId(i.Item1.ProgramId)) as LiveTvProgram;
  1400. var channel = string.IsNullOrEmpty(i.Item1.ChannelId) ? null : _libraryManager.GetItemById(_tvDtoService.GetInternalChannelId(i.Item2.Name, i.Item1.ChannelId));
  1401. returnList.Add(_tvDtoService.GetTimerInfoDto(i.Item1, i.Item2, program, channel));
  1402. }
  1403. var returnArray = returnList
  1404. .OrderBy(i => i.StartDate)
  1405. .ToArray();
  1406. return new QueryResult<TimerInfoDto>
  1407. {
  1408. Items = returnArray,
  1409. TotalRecordCount = returnArray.Length
  1410. };
  1411. }
  1412. public async Task CancelTimer(string id)
  1413. {
  1414. var timer = await GetTimer(id, CancellationToken.None).ConfigureAwait(false);
  1415. if (timer == null)
  1416. {
  1417. throw new ResourceNotFoundException(string.Format("Timer with Id {0} not found", id));
  1418. }
  1419. var service = GetService(timer.ServiceName);
  1420. await service.CancelTimerAsync(timer.ExternalId, CancellationToken.None).ConfigureAwait(false);
  1421. if (!(service is EmbyTV.EmbyTV))
  1422. {
  1423. TimerCancelled?.Invoke(this, new GenericEventArgs<TimerEventInfo>
  1424. {
  1425. Argument = new TimerEventInfo
  1426. {
  1427. Id = id
  1428. }
  1429. });
  1430. }
  1431. }
  1432. public async Task CancelSeriesTimer(string id)
  1433. {
  1434. var timer = await GetSeriesTimer(id, CancellationToken.None).ConfigureAwait(false);
  1435. if (timer == null)
  1436. {
  1437. throw new ResourceNotFoundException(string.Format("SeriesTimer with Id {0} not found", id));
  1438. }
  1439. var service = GetService(timer.ServiceName);
  1440. await service.CancelSeriesTimerAsync(timer.ExternalId, CancellationToken.None).ConfigureAwait(false);
  1441. SeriesTimerCancelled?.Invoke(this, new GenericEventArgs<TimerEventInfo>
  1442. {
  1443. Argument = new TimerEventInfo
  1444. {
  1445. Id = id
  1446. }
  1447. });
  1448. }
  1449. public async Task<TimerInfoDto> GetTimer(string id, CancellationToken cancellationToken)
  1450. {
  1451. var results = await GetTimers(new TimerQuery
  1452. {
  1453. Id = id
  1454. }, cancellationToken).ConfigureAwait(false);
  1455. return results.Items.FirstOrDefault(i => string.Equals(i.Id, id, StringComparison.OrdinalIgnoreCase));
  1456. }
  1457. public async Task<SeriesTimerInfoDto> GetSeriesTimer(string id, CancellationToken cancellationToken)
  1458. {
  1459. var results = await GetSeriesTimers(new SeriesTimerQuery(), cancellationToken).ConfigureAwait(false);
  1460. return results.Items.FirstOrDefault(i => string.Equals(i.Id, id, StringComparison.OrdinalIgnoreCase));
  1461. }
  1462. private async Task<QueryResult<SeriesTimerInfo>> GetSeriesTimersInternal(SeriesTimerQuery query, CancellationToken cancellationToken)
  1463. {
  1464. var tasks = _services.Select(async i =>
  1465. {
  1466. try
  1467. {
  1468. var recs = await i.GetSeriesTimersAsync(cancellationToken).ConfigureAwait(false);
  1469. return recs.Select(r =>
  1470. {
  1471. r.ServiceName = i.Name;
  1472. return new Tuple<SeriesTimerInfo, ILiveTvService>(r, i);
  1473. });
  1474. }
  1475. catch (Exception ex)
  1476. {
  1477. _logger.LogError(ex, "Error getting recordings");
  1478. return new List<Tuple<SeriesTimerInfo, ILiveTvService>>();
  1479. }
  1480. });
  1481. var results = await Task.WhenAll(tasks).ConfigureAwait(false);
  1482. var timers = results.SelectMany(i => i.ToList());
  1483. if (string.Equals(query.SortBy, "Priority", StringComparison.OrdinalIgnoreCase))
  1484. {
  1485. timers = query.SortOrder == SortOrder.Descending ?
  1486. timers.OrderBy(i => i.Item1.Priority).ThenByStringDescending(i => i.Item1.Name) :
  1487. timers.OrderByDescending(i => i.Item1.Priority).ThenByString(i => i.Item1.Name);
  1488. }
  1489. else
  1490. {
  1491. timers = query.SortOrder == SortOrder.Descending ?
  1492. timers.OrderByStringDescending(i => i.Item1.Name) :
  1493. timers.OrderByString(i => i.Item1.Name);
  1494. }
  1495. var returnArray = timers
  1496. .Select(i =>
  1497. {
  1498. return i.Item1;
  1499. })
  1500. .ToArray();
  1501. return new QueryResult<SeriesTimerInfo>
  1502. {
  1503. Items = returnArray,
  1504. TotalRecordCount = returnArray.Length
  1505. };
  1506. }
  1507. public async Task<QueryResult<SeriesTimerInfoDto>> GetSeriesTimers(SeriesTimerQuery query, CancellationToken cancellationToken)
  1508. {
  1509. var tasks = _services.Select(async i =>
  1510. {
  1511. try
  1512. {
  1513. var recs = await i.GetSeriesTimersAsync(cancellationToken).ConfigureAwait(false);
  1514. return recs.Select(r => new Tuple<SeriesTimerInfo, ILiveTvService>(r, i));
  1515. }
  1516. catch (Exception ex)
  1517. {
  1518. _logger.LogError(ex, "Error getting recordings");
  1519. return new List<Tuple<SeriesTimerInfo, ILiveTvService>>();
  1520. }
  1521. });
  1522. var results = await Task.WhenAll(tasks).ConfigureAwait(false);
  1523. var timers = results.SelectMany(i => i.ToList());
  1524. if (string.Equals(query.SortBy, "Priority", StringComparison.OrdinalIgnoreCase))
  1525. {
  1526. timers = query.SortOrder == SortOrder.Descending ?
  1527. timers.OrderBy(i => i.Item1.Priority).ThenByStringDescending(i => i.Item1.Name) :
  1528. timers.OrderByDescending(i => i.Item1.Priority).ThenByString(i => i.Item1.Name);
  1529. }
  1530. else
  1531. {
  1532. timers = query.SortOrder == SortOrder.Descending ?
  1533. timers.OrderByStringDescending(i => i.Item1.Name) :
  1534. timers.OrderByString(i => i.Item1.Name);
  1535. }
  1536. var returnArray = timers
  1537. .Select(i =>
  1538. {
  1539. string channelName = null;
  1540. if (!string.IsNullOrEmpty(i.Item1.ChannelId))
  1541. {
  1542. var internalChannelId = _tvDtoService.GetInternalChannelId(i.Item2.Name, i.Item1.ChannelId);
  1543. var channel = _libraryManager.GetItemById(internalChannelId);
  1544. channelName = channel == null ? null : channel.Name;
  1545. }
  1546. return _tvDtoService.GetSeriesTimerInfoDto(i.Item1, i.Item2, channelName);
  1547. })
  1548. .ToArray();
  1549. return new QueryResult<SeriesTimerInfoDto>
  1550. {
  1551. Items = returnArray,
  1552. TotalRecordCount = returnArray.Length
  1553. };
  1554. }
  1555. public BaseItem GetLiveTvChannel(TimerInfo timer, ILiveTvService service)
  1556. {
  1557. var internalChannelId = _tvDtoService.GetInternalChannelId(service.Name, timer.ChannelId);
  1558. return _libraryManager.GetItemById(internalChannelId);
  1559. }
  1560. public void AddChannelInfo(List<Tuple<BaseItemDto, LiveTvChannel>> tuples, DtoOptions options, User user)
  1561. {
  1562. var now = DateTime.UtcNow;
  1563. var channelIds = tuples.Select(i => i.Item2.Id).Distinct().ToArray();
  1564. var programs = options.AddCurrentProgram ? _libraryManager.GetItemList(new InternalItemsQuery(user)
  1565. {
  1566. IncludeItemTypes = new[] { typeof(LiveTvProgram).Name },
  1567. ChannelIds = channelIds,
  1568. MaxStartDate = now,
  1569. MinEndDate = now,
  1570. Limit = channelIds.Length,
  1571. OrderBy = new[] { new ValueTuple<string, SortOrder>(ItemSortBy.StartDate, SortOrder.Ascending) },
  1572. TopParentIds = new[] { GetInternalLiveTvFolder(CancellationToken.None).Id },
  1573. DtoOptions = options
  1574. }) : new List<BaseItem>();
  1575. RemoveFields(options);
  1576. var currentProgramsList = new List<BaseItem>();
  1577. var currentChannelsDict = new Dictionary<Guid, BaseItemDto>();
  1578. var addCurrentProgram = options.AddCurrentProgram;
  1579. foreach (var tuple in tuples)
  1580. {
  1581. var dto = tuple.Item1;
  1582. var channel = tuple.Item2;
  1583. dto.Number = channel.Number;
  1584. dto.ChannelNumber = channel.Number;
  1585. dto.ChannelType = channel.ChannelType;
  1586. currentChannelsDict[dto.Id] = dto;
  1587. if (addCurrentProgram)
  1588. {
  1589. var currentProgram = programs.FirstOrDefault(i => channel.Id.Equals(i.ChannelId));
  1590. if (currentProgram != null)
  1591. {
  1592. currentProgramsList.Add(currentProgram);
  1593. }
  1594. }
  1595. }
  1596. if (addCurrentProgram)
  1597. {
  1598. var currentProgramDtos = _dtoService.GetBaseItemDtos(currentProgramsList, options, user);
  1599. foreach (var programDto in currentProgramDtos)
  1600. {
  1601. BaseItemDto channelDto;
  1602. if (currentChannelsDict.TryGetValue(programDto.ChannelId, out channelDto))
  1603. {
  1604. channelDto.CurrentProgram = programDto;
  1605. }
  1606. }
  1607. }
  1608. }
  1609. private async Task<Tuple<SeriesTimerInfo, ILiveTvService>> GetNewTimerDefaultsInternal(CancellationToken cancellationToken, LiveTvProgram program = null)
  1610. {
  1611. ILiveTvService service = null;
  1612. ProgramInfo programInfo = null;
  1613. if(program != null)
  1614. {
  1615. service = GetService(program);
  1616. var channel = _libraryManager.GetItemById(program.ChannelId);
  1617. programInfo = new ProgramInfo
  1618. {
  1619. Audio = program.Audio,
  1620. ChannelId = channel.ExternalId,
  1621. CommunityRating = program.CommunityRating,
  1622. EndDate = program.EndDate ?? DateTime.MinValue,
  1623. EpisodeTitle = program.EpisodeTitle,
  1624. Genres = program.Genres.ToList(),
  1625. Id = program.ExternalId,
  1626. IsHD = program.IsHD,
  1627. IsKids = program.IsKids,
  1628. IsLive = program.IsLive,
  1629. IsMovie = program.IsMovie,
  1630. IsNews = program.IsNews,
  1631. IsPremiere = program.IsPremiere,
  1632. IsRepeat = program.IsRepeat,
  1633. IsSeries = program.IsSeries,
  1634. IsSports = program.IsSports,
  1635. OriginalAirDate = program.PremiereDate,
  1636. Overview = program.Overview,
  1637. StartDate = program.StartDate,
  1638. //ImagePath = program.ExternalImagePath,
  1639. Name = program.Name,
  1640. OfficialRating = program.OfficialRating
  1641. };
  1642. }
  1643. if (service == null)
  1644. {
  1645. service = _services.First();
  1646. }
  1647. var info = await service.GetNewTimerDefaultsAsync(cancellationToken, programInfo).ConfigureAwait(false);
  1648. info.RecordAnyTime = true;
  1649. info.Days = new List<DayOfWeek>
  1650. {
  1651. DayOfWeek.Sunday,
  1652. DayOfWeek.Monday,
  1653. DayOfWeek.Tuesday,
  1654. DayOfWeek.Wednesday,
  1655. DayOfWeek.Thursday,
  1656. DayOfWeek.Friday,
  1657. DayOfWeek.Saturday
  1658. };
  1659. info.Id = null;
  1660. return new Tuple<SeriesTimerInfo, ILiveTvService>(info, service);
  1661. }
  1662. public async Task<SeriesTimerInfoDto> GetNewTimerDefaults(CancellationToken cancellationToken)
  1663. {
  1664. var info = await GetNewTimerDefaultsInternal(cancellationToken).ConfigureAwait(false);
  1665. var obj = _tvDtoService.GetSeriesTimerInfoDto(info.Item1, info.Item2, null);
  1666. return obj;
  1667. }
  1668. public async Task<SeriesTimerInfoDto> GetNewTimerDefaults(string programId, CancellationToken cancellationToken)
  1669. {
  1670. var program = (LiveTvProgram)_libraryManager.GetItemById(programId);
  1671. var programDto = await GetProgram(programId, cancellationToken).ConfigureAwait(false);
  1672. var defaults = await GetNewTimerDefaultsInternal(cancellationToken, program).ConfigureAwait(false);
  1673. var info = _tvDtoService.GetSeriesTimerInfoDto(defaults.Item1, defaults.Item2, null);
  1674. info.Days = defaults.Item1.Days.ToArray();
  1675. info.DayPattern = _tvDtoService.GetDayPattern(info.Days);
  1676. info.Name = program.Name;
  1677. info.ChannelId = programDto.ChannelId;
  1678. info.ChannelName = programDto.ChannelName;
  1679. info.StartDate = program.StartDate;
  1680. info.Name = program.Name;
  1681. info.Overview = program.Overview;
  1682. info.ProgramId = programDto.Id.ToString("N");
  1683. info.ExternalProgramId = program.ExternalId;
  1684. if (program.EndDate.HasValue)
  1685. {
  1686. info.EndDate = program.EndDate.Value;
  1687. }
  1688. return info;
  1689. }
  1690. public async Task CreateTimer(TimerInfoDto timer, CancellationToken cancellationToken)
  1691. {
  1692. var service = GetService(timer.ServiceName);
  1693. var info = await _tvDtoService.GetTimerInfo(timer, true, this, cancellationToken).ConfigureAwait(false);
  1694. // Set priority from default values
  1695. var defaultValues = await service.GetNewTimerDefaultsAsync(cancellationToken).ConfigureAwait(false);
  1696. info.Priority = defaultValues.Priority;
  1697. string newTimerId = null;
  1698. if (service is ISupportsNewTimerIds supportsNewTimerIds)
  1699. {
  1700. newTimerId = await supportsNewTimerIds.CreateTimer(info, cancellationToken).ConfigureAwait(false);
  1701. newTimerId = _tvDtoService.GetInternalTimerId(newTimerId);
  1702. }
  1703. else
  1704. {
  1705. await service.CreateTimerAsync(info, cancellationToken).ConfigureAwait(false);
  1706. }
  1707. _logger.LogInformation("New recording scheduled");
  1708. if (!(service is EmbyTV.EmbyTV))
  1709. {
  1710. TimerCreated?.Invoke(this, new GenericEventArgs<TimerEventInfo>
  1711. {
  1712. Argument = new TimerEventInfo
  1713. {
  1714. ProgramId = _tvDtoService.GetInternalProgramId(info.ProgramId),
  1715. Id = newTimerId
  1716. }
  1717. });
  1718. }
  1719. }
  1720. public async Task CreateSeriesTimer(SeriesTimerInfoDto timer, CancellationToken cancellationToken)
  1721. {
  1722. var registration = await GetRegistrationInfo("seriesrecordings").ConfigureAwait(false);
  1723. if (!registration.IsValid)
  1724. {
  1725. _logger.LogInformation("Creating series recordings requires an active Emby Premiere subscription.");
  1726. return;
  1727. }
  1728. var service = GetService(timer.ServiceName);
  1729. var info = await _tvDtoService.GetSeriesTimerInfo(timer, true, this, cancellationToken).ConfigureAwait(false);
  1730. // Set priority from default values
  1731. var defaultValues = await service.GetNewTimerDefaultsAsync(cancellationToken).ConfigureAwait(false);
  1732. info.Priority = defaultValues.Priority;
  1733. string newTimerId = null;
  1734. if (service is ISupportsNewTimerIds supportsNewTimerIds)
  1735. {
  1736. newTimerId = await supportsNewTimerIds.CreateSeriesTimer(info, cancellationToken).ConfigureAwait(false);
  1737. newTimerId = _tvDtoService.GetInternalSeriesTimerId(newTimerId).ToString("N");
  1738. }
  1739. else
  1740. {
  1741. await service.CreateSeriesTimerAsync(info, cancellationToken).ConfigureAwait(false);
  1742. }
  1743. SeriesTimerCreated?.Invoke(this, new GenericEventArgs<TimerEventInfo>
  1744. {
  1745. Argument = new TimerEventInfo
  1746. {
  1747. ProgramId = _tvDtoService.GetInternalProgramId(info.ProgramId),
  1748. Id = newTimerId
  1749. }
  1750. });
  1751. }
  1752. public async Task UpdateTimer(TimerInfoDto timer, CancellationToken cancellationToken)
  1753. {
  1754. var info = await _tvDtoService.GetTimerInfo(timer, false, this, cancellationToken).ConfigureAwait(false);
  1755. var service = GetService(timer.ServiceName);
  1756. await service.UpdateTimerAsync(info, cancellationToken).ConfigureAwait(false);
  1757. }
  1758. public async Task UpdateSeriesTimer(SeriesTimerInfoDto timer, CancellationToken cancellationToken)
  1759. {
  1760. var info = await _tvDtoService.GetSeriesTimerInfo(timer, false, this, cancellationToken).ConfigureAwait(false);
  1761. var service = GetService(timer.ServiceName);
  1762. await service.UpdateSeriesTimerAsync(info, cancellationToken).ConfigureAwait(false);
  1763. }
  1764. public GuideInfo GetGuideInfo()
  1765. {
  1766. var startDate = DateTime.UtcNow;
  1767. var endDate = startDate.AddDays(GetGuideDays());
  1768. return new GuideInfo
  1769. {
  1770. StartDate = startDate,
  1771. EndDate = endDate
  1772. };
  1773. }
  1774. /// <summary>
  1775. /// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
  1776. /// </summary>
  1777. public void Dispose()
  1778. {
  1779. Dispose(true);
  1780. }
  1781. private bool _isDisposed = false;
  1782. /// <summary>
  1783. /// Releases unmanaged and - optionally - managed resources.
  1784. /// </summary>
  1785. /// <param name="dispose"><c>true</c> to release both managed and unmanaged resources; <c>false</c> to release only unmanaged resources.</param>
  1786. protected virtual void Dispose(bool dispose)
  1787. {
  1788. if (dispose)
  1789. {
  1790. _isDisposed = true;
  1791. }
  1792. }
  1793. private LiveTvServiceInfo[] GetServiceInfos()
  1794. {
  1795. return Services.Select(GetServiceInfo).ToArray();
  1796. }
  1797. private static LiveTvServiceInfo GetServiceInfo(ILiveTvService service)
  1798. {
  1799. return new LiveTvServiceInfo
  1800. {
  1801. Name = service.Name
  1802. };
  1803. }
  1804. public LiveTvInfo GetLiveTvInfo(CancellationToken cancellationToken)
  1805. {
  1806. var services = GetServiceInfos();
  1807. var info = new LiveTvInfo
  1808. {
  1809. Services = services,
  1810. IsEnabled = services.Length > 0
  1811. };
  1812. info.EnabledUsers = _userManager.Users
  1813. .Where(IsLiveTvEnabled)
  1814. .Select(i => i.Id.ToString("N"))
  1815. .ToArray();
  1816. return info;
  1817. }
  1818. private bool IsLiveTvEnabled(User user)
  1819. {
  1820. return user.Policy.EnableLiveTvAccess && (Services.Count > 1 || GetConfiguration().TunerHosts.Length > 0);
  1821. }
  1822. public IEnumerable<User> GetEnabledUsers()
  1823. {
  1824. return _userManager.Users
  1825. .Where(IsLiveTvEnabled);
  1826. }
  1827. /// <summary>
  1828. /// Resets the tuner.
  1829. /// </summary>
  1830. /// <param name="id">The identifier.</param>
  1831. /// <param name="cancellationToken">The cancellation token.</param>
  1832. /// <returns>Task.</returns>
  1833. public Task ResetTuner(string id, CancellationToken cancellationToken)
  1834. {
  1835. var parts = id.Split(new[] { '_' }, 2);
  1836. var service = _services.FirstOrDefault(i => string.Equals(i.GetType().FullName.GetMD5().ToString("N"), parts[0], StringComparison.OrdinalIgnoreCase));
  1837. if (service == null)
  1838. {
  1839. throw new ArgumentException("Service not found.");
  1840. }
  1841. return service.ResetTuner(parts[1], cancellationToken);
  1842. }
  1843. private static void RemoveFields(DtoOptions options)
  1844. {
  1845. var fields = options.Fields.ToList();
  1846. fields.Remove(ItemFields.CanDelete);
  1847. fields.Remove(ItemFields.CanDownload);
  1848. fields.Remove(ItemFields.DisplayPreferencesId);
  1849. fields.Remove(ItemFields.Etag);
  1850. options.Fields = fields.ToArray();
  1851. }
  1852. public Folder GetInternalLiveTvFolder(CancellationToken cancellationToken)
  1853. {
  1854. var name = _localization.GetLocalizedString("HeaderLiveTV");
  1855. return _libraryManager.GetNamedView(name, CollectionType.LiveTv, name);
  1856. }
  1857. public async Task<TunerHostInfo> SaveTunerHost(TunerHostInfo info, bool dataSourceChanged = true)
  1858. {
  1859. info = _jsonSerializer.DeserializeFromString<TunerHostInfo>(_jsonSerializer.SerializeToString(info));
  1860. var provider = _tunerHosts.FirstOrDefault(i => string.Equals(info.Type, i.Type, StringComparison.OrdinalIgnoreCase));
  1861. if (provider == null)
  1862. {
  1863. throw new ResourceNotFoundException();
  1864. }
  1865. if (provider is IConfigurableTunerHost configurable)
  1866. {
  1867. await configurable.Validate(info).ConfigureAwait(false);
  1868. }
  1869. var config = GetConfiguration();
  1870. var list = config.TunerHosts.ToList();
  1871. var index = list.FindIndex(i => string.Equals(i.Id, info.Id, StringComparison.OrdinalIgnoreCase));
  1872. if (index == -1 || string.IsNullOrWhiteSpace(info.Id))
  1873. {
  1874. info.Id = Guid.NewGuid().ToString("N");
  1875. list.Add(info);
  1876. config.TunerHosts = list.ToArray();
  1877. }
  1878. else
  1879. {
  1880. config.TunerHosts[index] = info;
  1881. }
  1882. _config.SaveConfiguration("livetv", config);
  1883. if (dataSourceChanged)
  1884. {
  1885. _taskManager.CancelIfRunningAndQueue<RefreshChannelsScheduledTask>();
  1886. }
  1887. return info;
  1888. }
  1889. public async Task<ListingsProviderInfo> SaveListingProvider(ListingsProviderInfo info, bool validateLogin, bool validateListings)
  1890. {
  1891. // Hack to make the object a pure ListingsProviderInfo instead of an AddListingProvider
  1892. // ServerConfiguration.SaveConfiguration crashes during xml serialization for AddListingProvider
  1893. info = _jsonSerializer.DeserializeFromString<ListingsProviderInfo>(_jsonSerializer.SerializeToString(info));
  1894. IListingsProvider provider = _listingProviders.FirstOrDefault(i => string.Equals(info.Type, i.Type, StringComparison.OrdinalIgnoreCase));
  1895. if (provider == null)
  1896. {
  1897. throw new ResourceNotFoundException(
  1898. string.Format("Couldn't find provider of type: '{0}'", info.Type)
  1899. );
  1900. }
  1901. await provider.Validate(info, validateLogin, validateListings).ConfigureAwait(false);
  1902. LiveTvOptions config = GetConfiguration();
  1903. List<ListingsProviderInfo> list = config.ListingProviders.ToList();
  1904. int index = list.FindIndex(i => string.Equals(i.Id, info.Id, StringComparison.OrdinalIgnoreCase));
  1905. if (index == -1 || string.IsNullOrWhiteSpace(info.Id))
  1906. {
  1907. info.Id = Guid.NewGuid().ToString("N");
  1908. list.Add(info);
  1909. config.ListingProviders = list.ToArray();
  1910. }
  1911. else
  1912. {
  1913. config.ListingProviders[index] = info;
  1914. }
  1915. _config.SaveConfiguration("livetv", config);
  1916. _taskManager.CancelIfRunningAndQueue<RefreshChannelsScheduledTask>();
  1917. return info;
  1918. }
  1919. public void DeleteListingsProvider(string id)
  1920. {
  1921. var config = GetConfiguration();
  1922. config.ListingProviders = config.ListingProviders.Where(i => !string.Equals(id, i.Id, StringComparison.OrdinalIgnoreCase)).ToArray();
  1923. _config.SaveConfiguration("livetv", config);
  1924. _taskManager.CancelIfRunningAndQueue<RefreshChannelsScheduledTask>();
  1925. }
  1926. public async Task<TunerChannelMapping> SetChannelMapping(string providerId, string tunerChannelId, string providerChannelId)
  1927. {
  1928. var config = GetConfiguration();
  1929. var listingsProviderInfo = config.ListingProviders.First(i => string.Equals(providerId, i.Id, StringComparison.OrdinalIgnoreCase));
  1930. listingsProviderInfo.ChannelMappings = listingsProviderInfo.ChannelMappings.Where(i => !string.Equals(i.Name, tunerChannelId, StringComparison.OrdinalIgnoreCase)).ToArray();
  1931. if (!string.Equals(tunerChannelId, providerChannelId, StringComparison.OrdinalIgnoreCase))
  1932. {
  1933. var list = listingsProviderInfo.ChannelMappings.ToList();
  1934. list.Add(new NameValuePair
  1935. {
  1936. Name = tunerChannelId,
  1937. Value = providerChannelId
  1938. });
  1939. listingsProviderInfo.ChannelMappings = list.ToArray();
  1940. }
  1941. _config.SaveConfiguration("livetv", config);
  1942. var tunerChannels = await GetChannelsForListingsProvider(providerId, CancellationToken.None)
  1943. .ConfigureAwait(false);
  1944. var providerChannels = await GetChannelsFromListingsProviderData(providerId, CancellationToken.None)
  1945. .ConfigureAwait(false);
  1946. var mappings = listingsProviderInfo.ChannelMappings;
  1947. var tunerChannelMappings =
  1948. tunerChannels.Select(i => GetTunerChannelMapping(i, mappings, providerChannels)).ToList();
  1949. _taskManager.CancelIfRunningAndQueue<RefreshChannelsScheduledTask>();
  1950. return tunerChannelMappings.First(i => string.Equals(i.Id, tunerChannelId, StringComparison.OrdinalIgnoreCase));
  1951. }
  1952. public TunerChannelMapping GetTunerChannelMapping(ChannelInfo tunerChannel, NameValuePair[] mappings, List<ChannelInfo> epgChannels)
  1953. {
  1954. var result = new TunerChannelMapping
  1955. {
  1956. Name = tunerChannel.Name,
  1957. Id = tunerChannel.Id
  1958. };
  1959. if (!string.IsNullOrWhiteSpace(tunerChannel.Number))
  1960. {
  1961. result.Name = tunerChannel.Number + " " + result.Name;
  1962. }
  1963. var providerChannel = EmbyTV.EmbyTV.Current.GetEpgChannelFromTunerChannel(mappings, tunerChannel, epgChannels);
  1964. if (providerChannel != null)
  1965. {
  1966. result.ProviderChannelName = providerChannel.Name;
  1967. result.ProviderChannelId = providerChannel.Id;
  1968. }
  1969. return result;
  1970. }
  1971. public Task<List<NameIdPair>> GetLineups(string providerType, string providerId, string country, string location)
  1972. {
  1973. var config = GetConfiguration();
  1974. if (string.IsNullOrWhiteSpace(providerId))
  1975. {
  1976. var provider = _listingProviders.FirstOrDefault(i => string.Equals(providerType, i.Type, StringComparison.OrdinalIgnoreCase));
  1977. if (provider == null)
  1978. {
  1979. throw new ResourceNotFoundException();
  1980. }
  1981. return provider.GetLineups(null, country, location);
  1982. }
  1983. else
  1984. {
  1985. var info = config.ListingProviders.FirstOrDefault(i => string.Equals(i.Id, providerId, StringComparison.OrdinalIgnoreCase));
  1986. var provider = _listingProviders.FirstOrDefault(i => string.Equals(info.Type, i.Type, StringComparison.OrdinalIgnoreCase));
  1987. if (provider == null)
  1988. {
  1989. throw new ResourceNotFoundException();
  1990. }
  1991. return provider.GetLineups(info, country, location);
  1992. }
  1993. }
  1994. public Task<MBRegistrationRecord> GetRegistrationInfo(string feature)
  1995. {
  1996. if (string.Equals(feature, "seriesrecordings", StringComparison.OrdinalIgnoreCase))
  1997. {
  1998. feature = "embytvseriesrecordings";
  1999. }
  2000. if (string.Equals(feature, "dvr-l", StringComparison.OrdinalIgnoreCase))
  2001. {
  2002. var config = GetConfiguration();
  2003. if (config.TunerHosts.Length > 0 &&
  2004. config.ListingProviders.Count(i => (i.EnableAllTuners || i.EnabledTuners.Length > 0) && string.Equals(i.Type, SchedulesDirect.TypeName, StringComparison.OrdinalIgnoreCase)) > 0)
  2005. {
  2006. return Task.FromResult(new MBRegistrationRecord
  2007. {
  2008. IsRegistered = true,
  2009. IsValid = true
  2010. });
  2011. }
  2012. }
  2013. return _security.GetRegistrationStatus(feature);
  2014. }
  2015. public Task<List<ChannelInfo>> GetChannelsForListingsProvider(string id, CancellationToken cancellationToken)
  2016. {
  2017. var info = GetConfiguration().ListingProviders.First(i => string.Equals(i.Id, id, StringComparison.OrdinalIgnoreCase));
  2018. return EmbyTV.EmbyTV.Current.GetChannelsForListingsProvider(info, cancellationToken);
  2019. }
  2020. public Task<List<ChannelInfo>> GetChannelsFromListingsProviderData(string id, CancellationToken cancellationToken)
  2021. {
  2022. var info = GetConfiguration().ListingProviders.First(i => string.Equals(i.Id, id, StringComparison.OrdinalIgnoreCase));
  2023. var provider = _listingProviders.First(i => string.Equals(i.Type, info.Type, StringComparison.OrdinalIgnoreCase));
  2024. return provider.GetChannels(info, cancellationToken);
  2025. }
  2026. public Guid GetInternalChannelId(string serviceName, string externalId)
  2027. {
  2028. return _tvDtoService.GetInternalChannelId(serviceName, externalId);
  2029. }
  2030. public Guid GetInternalProgramId(string externalId)
  2031. {
  2032. return _tvDtoService.GetInternalProgramId(externalId);
  2033. }
  2034. public List<BaseItem> GetRecordingFolders(User user)
  2035. {
  2036. return GetRecordingFolders(user, false);
  2037. }
  2038. private List<BaseItem> GetRecordingFolders(User user, bool refreshChannels)
  2039. {
  2040. var folders = EmbyTV.EmbyTV.Current.GetRecordingFolders()
  2041. .SelectMany(i => i.Locations)
  2042. .Distinct(StringComparer.OrdinalIgnoreCase)
  2043. .Select(i => _libraryManager.FindByPath(i, true))
  2044. .Where(i => i != null)
  2045. .Where(i => i.IsVisibleStandalone(user))
  2046. .SelectMany(i => _libraryManager.GetCollectionFolders(i))
  2047. .DistinctBy(i => i.Id)
  2048. .OrderBy(i => i.SortName)
  2049. .ToList();
  2050. folders.AddRange(_channelManager().GetChannelsInternal(new MediaBrowser.Model.Channels.ChannelQuery
  2051. {
  2052. UserId = user.Id,
  2053. IsRecordingsFolder = true,
  2054. RefreshLatestChannelItems = refreshChannels
  2055. }).Items);
  2056. return folders.Cast<BaseItem>().ToList();
  2057. }
  2058. }
  2059. }