DtoBuilder.cs 40 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212
  1. using MediaBrowser.Common.Extensions;
  2. using MediaBrowser.Controller.Entities;
  3. using MediaBrowser.Controller.Entities.Audio;
  4. using MediaBrowser.Controller.Entities.Movies;
  5. using MediaBrowser.Controller.Entities.TV;
  6. using MediaBrowser.Controller.Library;
  7. using MediaBrowser.Controller.Persistence;
  8. using MediaBrowser.Model.Drawing;
  9. using MediaBrowser.Model.Dto;
  10. using MediaBrowser.Model.Entities;
  11. using MediaBrowser.Model.Logging;
  12. using MediaBrowser.Model.Querying;
  13. using System;
  14. using System.Collections.Generic;
  15. using System.IO;
  16. using System.Linq;
  17. using System.Threading.Tasks;
  18. namespace MediaBrowser.Controller.Dto
  19. {
  20. /// <summary>
  21. /// Generates DTO's from domain entities
  22. /// </summary>
  23. public class DtoBuilder
  24. {
  25. /// <summary>
  26. /// The index folder delimeter
  27. /// </summary>
  28. const string IndexFolderDelimeter = "-index-";
  29. private readonly ILogger _logger;
  30. private readonly ILibraryManager _libraryManager;
  31. private readonly IUserDataRepository _userDataRepository;
  32. private readonly IItemRepository _itemRepo;
  33. public DtoBuilder(ILogger logger, ILibraryManager libraryManager, IUserDataRepository userDataRepository, IItemRepository itemRepo)
  34. {
  35. _logger = logger;
  36. _libraryManager = libraryManager;
  37. _userDataRepository = userDataRepository;
  38. _itemRepo = itemRepo;
  39. }
  40. /// <summary>
  41. /// Converts a BaseItem to a DTOBaseItem
  42. /// </summary>
  43. /// <param name="item">The item.</param>
  44. /// <param name="fields">The fields.</param>
  45. /// <param name="user">The user.</param>
  46. /// <returns>Task{DtoBaseItem}.</returns>
  47. /// <exception cref="System.ArgumentNullException">item</exception>
  48. public async Task<BaseItemDto> GetBaseItemDto(BaseItem item, List<ItemFields> fields, User user = null)
  49. {
  50. if (item == null)
  51. {
  52. throw new ArgumentNullException("item");
  53. }
  54. if (fields == null)
  55. {
  56. throw new ArgumentNullException("fields");
  57. }
  58. var dto = new BaseItemDto();
  59. var tasks = new List<Task>();
  60. if (fields.Contains(ItemFields.Studios))
  61. {
  62. tasks.Add(AttachStudios(dto, item));
  63. }
  64. if (fields.Contains(ItemFields.People))
  65. {
  66. tasks.Add(AttachPeople(dto, item));
  67. }
  68. if (fields.Contains(ItemFields.PrimaryImageAspectRatio))
  69. {
  70. try
  71. {
  72. await AttachPrimaryImageAspectRatio(dto, item, _logger).ConfigureAwait(false);
  73. }
  74. catch (Exception ex)
  75. {
  76. // Have to use a catch-all unfortunately because some .net image methods throw plain Exceptions
  77. _logger.ErrorException("Error generating PrimaryImageAspectRatio for {0}", ex, item.Name);
  78. }
  79. }
  80. if (user != null)
  81. {
  82. AttachUserSpecificInfo(dto, item, user, fields);
  83. }
  84. AttachBasicFields(dto, item, fields);
  85. if (fields.Contains(ItemFields.SoundtrackIds))
  86. {
  87. var series = item as Series;
  88. if (series != null)
  89. {
  90. AttachSoundtrackIds(dto, series, user);
  91. }
  92. var movie = item as Movie;
  93. if (movie != null)
  94. {
  95. AttachSoundtrackIds(dto, movie, user);
  96. }
  97. var album = item as MusicAlbum;
  98. if (album != null)
  99. {
  100. AttachSoundtrackIds(dto, album, user);
  101. }
  102. var game = item as Game;
  103. if (game != null)
  104. {
  105. AttachSoundtrackIds(dto, game, user);
  106. }
  107. }
  108. // Make sure all the tasks we kicked off have completed.
  109. if (tasks.Count > 0)
  110. {
  111. await Task.WhenAll(tasks).ConfigureAwait(false);
  112. }
  113. return dto;
  114. }
  115. private void AttachSoundtrackIds(BaseItemDto dto, Movie item, User user)
  116. {
  117. var tmdb = item.GetProviderId(MetadataProviders.Tmdb);
  118. if (string.IsNullOrEmpty(tmdb))
  119. {
  120. return;
  121. }
  122. var recursiveChildren = user == null
  123. ? _libraryManager.RootFolder.RecursiveChildren
  124. : user.RootFolder.GetRecursiveChildren(user);
  125. dto.SoundtrackIds = recursiveChildren
  126. .Where(i =>
  127. {
  128. if (!string.IsNullOrEmpty(tmdb) &&
  129. string.Equals(tmdb, i.GetProviderId(MetadataProviders.Tmdb), StringComparison.OrdinalIgnoreCase) &&
  130. i is MusicAlbum)
  131. {
  132. return true;
  133. }
  134. return false;
  135. })
  136. .Select(GetClientItemId)
  137. .ToArray();
  138. }
  139. private void AttachSoundtrackIds(BaseItemDto dto, Series item, User user)
  140. {
  141. var tvdb = item.GetProviderId(MetadataProviders.Tvdb);
  142. if (string.IsNullOrEmpty(tvdb))
  143. {
  144. return;
  145. }
  146. var recursiveChildren = user == null
  147. ? _libraryManager.RootFolder.RecursiveChildren
  148. : user.RootFolder.GetRecursiveChildren(user);
  149. dto.SoundtrackIds = recursiveChildren
  150. .Where(i =>
  151. {
  152. if (!string.IsNullOrEmpty(tvdb) &&
  153. string.Equals(tvdb, i.GetProviderId(MetadataProviders.Tvdb), StringComparison.OrdinalIgnoreCase) &&
  154. i is MusicAlbum)
  155. {
  156. return true;
  157. }
  158. return false;
  159. })
  160. .Select(GetClientItemId)
  161. .ToArray();
  162. }
  163. private void AttachSoundtrackIds(BaseItemDto dto, Game item, User user)
  164. {
  165. var gamesdb = item.GetProviderId(MetadataProviders.Gamesdb);
  166. if (string.IsNullOrEmpty(gamesdb))
  167. {
  168. return;
  169. }
  170. var recursiveChildren = user == null
  171. ? _libraryManager.RootFolder.RecursiveChildren
  172. : user.RootFolder.GetRecursiveChildren(user);
  173. dto.SoundtrackIds = recursiveChildren
  174. .Where(i =>
  175. {
  176. if (!string.IsNullOrEmpty(gamesdb) &&
  177. string.Equals(gamesdb, i.GetProviderId(MetadataProviders.Gamesdb), StringComparison.OrdinalIgnoreCase) &&
  178. i is MusicAlbum)
  179. {
  180. return true;
  181. }
  182. return false;
  183. })
  184. .Select(GetClientItemId)
  185. .ToArray();
  186. }
  187. private void AttachSoundtrackIds(BaseItemDto dto, MusicAlbum item, User user)
  188. {
  189. var tmdb = item.GetProviderId(MetadataProviders.Tmdb);
  190. var tvdb = item.GetProviderId(MetadataProviders.Tvdb);
  191. var gamesdb = item.GetProviderId(MetadataProviders.Gamesdb);
  192. if (string.IsNullOrEmpty(tmdb) && string.IsNullOrEmpty(tvdb) && string.IsNullOrEmpty(gamesdb))
  193. {
  194. return;
  195. }
  196. var recursiveChildren = user == null
  197. ? _libraryManager.RootFolder.RecursiveChildren
  198. : user.RootFolder.GetRecursiveChildren(user);
  199. dto.SoundtrackIds = recursiveChildren
  200. .Where(i =>
  201. {
  202. if (!string.IsNullOrEmpty(tmdb) &&
  203. string.Equals(tmdb, i.GetProviderId(MetadataProviders.Tmdb), StringComparison.OrdinalIgnoreCase) &&
  204. i is Movie)
  205. {
  206. return true;
  207. }
  208. if (!string.IsNullOrEmpty(tvdb) &&
  209. string.Equals(tvdb, i.GetProviderId(MetadataProviders.Tvdb), StringComparison.OrdinalIgnoreCase) &&
  210. i is Series)
  211. {
  212. return true;
  213. }
  214. if (!string.IsNullOrEmpty(gamesdb) &&
  215. string.Equals(gamesdb, i.GetProviderId(MetadataProviders.Gamesdb), StringComparison.OrdinalIgnoreCase) &&
  216. i is Game)
  217. {
  218. return true;
  219. }
  220. return false;
  221. })
  222. .Select(GetClientItemId)
  223. .ToArray();
  224. }
  225. /// <summary>
  226. /// Attaches the user specific info.
  227. /// </summary>
  228. /// <param name="dto">The dto.</param>
  229. /// <param name="item">The item.</param>
  230. /// <param name="user">The user.</param>
  231. /// <param name="fields">The fields.</param>
  232. private void AttachUserSpecificInfo(BaseItemDto dto, BaseItem item, User user, List<ItemFields> fields)
  233. {
  234. if (item.IsFolder && fields.Contains(ItemFields.DisplayPreferencesId))
  235. {
  236. dto.DisplayPreferencesId = ((Folder)item).GetDisplayPreferencesId(user.Id).ToString();
  237. }
  238. if (item.IsFolder)
  239. {
  240. if (fields.Contains(ItemFields.ItemCounts))
  241. {
  242. var folder = (Folder)item;
  243. // Skip sorting since all we want is a count
  244. dto.ChildCount = folder.GetChildren(user, true).Count();
  245. SetSpecialCounts(folder, user, dto, _userDataRepository);
  246. }
  247. }
  248. var userData = _userDataRepository.GetUserData(user.Id, item.GetUserDataKey());
  249. dto.UserData = GetUserItemDataDto(userData);
  250. if (item.IsFolder)
  251. {
  252. dto.UserData.Played = dto.PlayedPercentage.HasValue && dto.PlayedPercentage.Value >= 100;
  253. }
  254. }
  255. /// <summary>
  256. /// Attaches the primary image aspect ratio.
  257. /// </summary>
  258. /// <param name="dto">The dto.</param>
  259. /// <param name="item">The item.</param>
  260. /// <param name="logger">The _logger.</param>
  261. /// <returns>Task.</returns>
  262. internal static async Task AttachPrimaryImageAspectRatio(IItemDto dto, BaseItem item, ILogger logger)
  263. {
  264. var path = item.PrimaryImagePath;
  265. if (string.IsNullOrEmpty(path))
  266. {
  267. return;
  268. }
  269. var metaFileEntry = item.ResolveArgs.GetMetaFileByPath(path);
  270. // See if we can avoid a file system lookup by looking for the file in ResolveArgs
  271. var dateModified = metaFileEntry == null ? File.GetLastWriteTimeUtc(path) : metaFileEntry.LastWriteTimeUtc;
  272. ImageSize size;
  273. try
  274. {
  275. size = await Kernel.Instance.ImageManager.GetImageSize(path, dateModified).ConfigureAwait(false);
  276. }
  277. catch (FileNotFoundException)
  278. {
  279. logger.Error("Image file does not exist: {0}", path);
  280. return;
  281. }
  282. catch (Exception ex)
  283. {
  284. logger.ErrorException("Failed to determine primary image aspect ratio for {0}", ex, path);
  285. return;
  286. }
  287. dto.OriginalPrimaryImageAspectRatio = size.Width / size.Height;
  288. var supportedEnhancers = Kernel.Instance.ImageManager.ImageEnhancers.Where(i =>
  289. {
  290. try
  291. {
  292. return i.Supports(item, ImageType.Primary);
  293. }
  294. catch (Exception ex)
  295. {
  296. logger.ErrorException("Error in image enhancer: {0}", ex, i.GetType().Name);
  297. return false;
  298. }
  299. }).ToList();
  300. foreach (var enhancer in supportedEnhancers)
  301. {
  302. try
  303. {
  304. size = enhancer.GetEnhancedImageSize(item, ImageType.Primary, 0, size);
  305. }
  306. catch (Exception ex)
  307. {
  308. logger.ErrorException("Error in image enhancer: {0}", ex, enhancer.GetType().Name);
  309. }
  310. }
  311. dto.PrimaryImageAspectRatio = size.Width / size.Height;
  312. }
  313. /// <summary>
  314. /// Sets simple property values on a DTOBaseItem
  315. /// </summary>
  316. /// <param name="dto">The dto.</param>
  317. /// <param name="item">The item.</param>
  318. /// <param name="fields">The fields.</param>
  319. private void AttachBasicFields(BaseItemDto dto, BaseItem item, List<ItemFields> fields)
  320. {
  321. if (fields.Contains(ItemFields.DateCreated))
  322. {
  323. dto.DateCreated = item.DateCreated;
  324. }
  325. if (fields.Contains(ItemFields.OriginalRunTimeTicks))
  326. {
  327. dto.OriginalRunTimeTicks = item.OriginalRunTimeTicks;
  328. }
  329. dto.DisplayMediaType = item.DisplayMediaType;
  330. if (fields.Contains(ItemFields.MetadataSettings))
  331. {
  332. dto.LockedFields = item.LockedFields;
  333. dto.EnableInternetProviders = !item.DontFetchMeta;
  334. }
  335. if (fields.Contains(ItemFields.Budget))
  336. {
  337. dto.Budget = item.Budget;
  338. }
  339. if (fields.Contains(ItemFields.Revenue))
  340. {
  341. dto.Revenue = item.Revenue;
  342. }
  343. if (fields.Contains(ItemFields.EndDate))
  344. {
  345. dto.EndDate = item.EndDate;
  346. }
  347. if (fields.Contains(ItemFields.HomePageUrl))
  348. {
  349. dto.HomePageUrl = item.HomePageUrl;
  350. }
  351. if (fields.Contains(ItemFields.Tags))
  352. {
  353. dto.Tags = item.Tags;
  354. }
  355. if (fields.Contains(ItemFields.ProductionLocations))
  356. {
  357. dto.ProductionLocations = item.ProductionLocations;
  358. }
  359. dto.AspectRatio = item.AspectRatio;
  360. dto.BackdropImageTags = GetBackdropImageTags(item);
  361. dto.ScreenshotImageTags = GetScreenshotImageTags(item);
  362. if (fields.Contains(ItemFields.Genres))
  363. {
  364. dto.Genres = item.Genres;
  365. }
  366. dto.ImageTags = new Dictionary<ImageType, Guid>();
  367. foreach (var image in item.Images)
  368. {
  369. var type = image.Key;
  370. var tag = GetImageCacheTag(item, type, image.Value);
  371. if (tag.HasValue)
  372. {
  373. dto.ImageTags[type] = tag.Value;
  374. }
  375. }
  376. dto.Id = GetClientItemId(item);
  377. dto.IndexNumber = item.IndexNumber;
  378. dto.IsFolder = item.IsFolder;
  379. dto.Language = item.Language;
  380. dto.MediaType = item.MediaType;
  381. dto.LocationType = item.LocationType;
  382. dto.CriticRating = item.CriticRating;
  383. if (fields.Contains(ItemFields.CriticRatingSummary))
  384. {
  385. dto.CriticRatingSummary = item.CriticRatingSummary;
  386. }
  387. var localTrailerCount = item.LocalTrailerIds.Count;
  388. if (localTrailerCount > 0)
  389. {
  390. dto.LocalTrailerCount = localTrailerCount;
  391. }
  392. dto.Name = item.Name;
  393. dto.OfficialRating = item.OfficialRating;
  394. var hasOverview = fields.Contains(ItemFields.Overview);
  395. var hasHtmlOverview = fields.Contains(ItemFields.OverviewHtml);
  396. if (hasOverview || hasHtmlOverview)
  397. {
  398. var strippedOverview = string.IsNullOrEmpty(item.Overview) ? item.Overview : item.Overview.StripHtml();
  399. if (hasOverview)
  400. {
  401. dto.Overview = strippedOverview;
  402. }
  403. // Only supply the html version if there was actually html content
  404. if (hasHtmlOverview)
  405. {
  406. dto.OverviewHtml = item.Overview;
  407. }
  408. }
  409. // If there are no backdrops, indicate what parent has them in case the Ui wants to allow inheritance
  410. if (dto.BackdropImageTags.Count == 0)
  411. {
  412. var parentWithBackdrop = GetParentBackdropItem(item);
  413. if (parentWithBackdrop != null)
  414. {
  415. dto.ParentBackdropItemId = GetClientItemId(parentWithBackdrop);
  416. dto.ParentBackdropImageTags = GetBackdropImageTags(parentWithBackdrop);
  417. }
  418. }
  419. if (item.Parent != null && fields.Contains(ItemFields.ParentId))
  420. {
  421. dto.ParentId = GetClientItemId(item.Parent);
  422. }
  423. dto.ParentIndexNumber = item.ParentIndexNumber;
  424. // If there is no logo, indicate what parent has one in case the Ui wants to allow inheritance
  425. if (!dto.HasLogo)
  426. {
  427. var parentWithLogo = GetParentImageItem(item, ImageType.Logo);
  428. if (parentWithLogo != null)
  429. {
  430. dto.ParentLogoItemId = GetClientItemId(parentWithLogo);
  431. dto.ParentLogoImageTag = GetImageCacheTag(parentWithLogo, ImageType.Logo, parentWithLogo.GetImage(ImageType.Logo));
  432. }
  433. }
  434. // If there is no art, indicate what parent has one in case the Ui wants to allow inheritance
  435. if (!dto.HasArtImage)
  436. {
  437. var parentWithImage = GetParentImageItem(item, ImageType.Art);
  438. if (parentWithImage != null)
  439. {
  440. dto.ParentArtItemId = GetClientItemId(parentWithImage);
  441. dto.ParentArtImageTag = GetImageCacheTag(parentWithImage, ImageType.Art, parentWithImage.GetImage(ImageType.Art));
  442. }
  443. }
  444. if (fields.Contains(ItemFields.Path))
  445. {
  446. dto.Path = item.Path;
  447. }
  448. dto.PremiereDate = item.PremiereDate;
  449. dto.ProductionYear = item.ProductionYear;
  450. if (fields.Contains(ItemFields.ProviderIds))
  451. {
  452. dto.ProviderIds = item.ProviderIds;
  453. }
  454. dto.RunTimeTicks = item.RunTimeTicks;
  455. if (fields.Contains(ItemFields.SortName))
  456. {
  457. dto.SortName = item.SortName;
  458. }
  459. if (fields.Contains(ItemFields.CustomRating))
  460. {
  461. dto.CustomRating = item.CustomRating;
  462. }
  463. if (fields.Contains(ItemFields.Taglines))
  464. {
  465. dto.Taglines = item.Taglines;
  466. }
  467. if (fields.Contains(ItemFields.RemoteTrailers))
  468. {
  469. dto.RemoteTrailers = item.RemoteTrailers;
  470. }
  471. dto.Type = item.GetType().Name;
  472. dto.CommunityRating = item.CommunityRating;
  473. if (item.IsFolder)
  474. {
  475. var folder = (Folder)item;
  476. if (fields.Contains(ItemFields.IndexOptions))
  477. {
  478. dto.IndexOptions = folder.IndexByOptionStrings.ToArray();
  479. }
  480. }
  481. // Add audio info
  482. var audio = item as Audio;
  483. if (audio != null)
  484. {
  485. dto.Album = audio.Album;
  486. dto.AlbumArtist = audio.AlbumArtist;
  487. dto.Artists = new[] { audio.Artist };
  488. var albumParent = audio.FindParent<MusicAlbum>();
  489. if (albumParent != null)
  490. {
  491. dto.AlbumId = GetClientItemId(albumParent);
  492. var imagePath = albumParent.PrimaryImagePath;
  493. if (!string.IsNullOrEmpty(imagePath))
  494. {
  495. dto.AlbumPrimaryImageTag = GetImageCacheTag(albumParent, ImageType.Primary, imagePath);
  496. }
  497. }
  498. }
  499. var album = item as MusicAlbum;
  500. if (album != null)
  501. {
  502. var songs = album.RecursiveChildren.OfType<Audio>().ToList();
  503. dto.AlbumArtist = songs.Select(i => i.AlbumArtist).FirstOrDefault(i => !string.IsNullOrEmpty(i));
  504. dto.Artists =
  505. songs.Select(i => i.Artist ?? string.Empty)
  506. .Where(i => !string.IsNullOrEmpty(i))
  507. .Distinct(StringComparer.OrdinalIgnoreCase)
  508. .ToArray();
  509. }
  510. // Add video info
  511. var video = item as Video;
  512. if (video != null)
  513. {
  514. dto.VideoType = video.VideoType;
  515. dto.Video3DFormat = video.Video3DFormat;
  516. dto.IsoType = video.IsoType;
  517. dto.PartCount = video.AdditionalPartIds.Count + 1;
  518. if (fields.Contains(ItemFields.Chapters))
  519. {
  520. dto.Chapters = _itemRepo.GetChapters(video.Id).Select(c => GetChapterInfoDto(c, item)).ToList();
  521. }
  522. }
  523. if (fields.Contains(ItemFields.MediaStreams))
  524. {
  525. // Add VideoInfo
  526. var iHasMediaStreams = item as IHasMediaStreams;
  527. if (iHasMediaStreams != null)
  528. {
  529. dto.MediaStreams = iHasMediaStreams.MediaStreams;
  530. }
  531. }
  532. // Add MovieInfo
  533. var movie = item as Movie;
  534. if (movie != null)
  535. {
  536. var specialFeatureCount = movie.SpecialFeatureIds.Count;
  537. if (specialFeatureCount > 0)
  538. {
  539. dto.SpecialFeatureCount = specialFeatureCount;
  540. }
  541. }
  542. // Add EpisodeInfo
  543. var episode = item as Episode;
  544. if (episode != null)
  545. {
  546. dto.IndexNumberEnd = episode.IndexNumberEnd;
  547. }
  548. // Add SeriesInfo
  549. var series = item as Series;
  550. if (series != null)
  551. {
  552. dto.AirDays = series.AirDays;
  553. dto.AirTime = series.AirTime;
  554. dto.Status = series.Status;
  555. }
  556. if (episode != null)
  557. {
  558. series = item.FindParent<Series>();
  559. dto.SeriesId = GetClientItemId(series);
  560. dto.SeriesName = series.Name;
  561. }
  562. // Add SeasonInfo
  563. var season = item as Season;
  564. if (season != null)
  565. {
  566. series = item.FindParent<Series>();
  567. dto.SeriesId = GetClientItemId(series);
  568. dto.SeriesName = series.Name;
  569. }
  570. var game = item as Game;
  571. if (game != null)
  572. {
  573. SetGameProperties(dto, game);
  574. }
  575. var musicVideo = item as MusicVideo;
  576. if (musicVideo != null)
  577. {
  578. SetMusicVideoProperties(dto, musicVideo);
  579. }
  580. }
  581. private void SetMusicVideoProperties(BaseItemDto dto, MusicVideo item)
  582. {
  583. dto.Album = item.Album;
  584. dto.Artists = string.IsNullOrEmpty(item.Artist) ? new string[] { } : new[] { item.Artist };
  585. }
  586. private void SetGameProperties(BaseItemDto dto, Game item)
  587. {
  588. dto.Players = item.PlayersSupported;
  589. dto.GameSystem = item.GameSystem;
  590. }
  591. /// <summary>
  592. /// Since it can be slow to make all of these calculations independently, this method will provide a way to do them all at once
  593. /// </summary>
  594. /// <param name="folder">The folder.</param>
  595. /// <param name="user">The user.</param>
  596. /// <param name="dto">The dto.</param>
  597. /// <param name="userDataRepository">The user data repository.</param>
  598. /// <returns>Task.</returns>
  599. private static void SetSpecialCounts(Folder folder, User user, BaseItemDto dto, IUserDataRepository userDataRepository)
  600. {
  601. var rcentlyAddedItemCount = 0;
  602. var recursiveItemCount = 0;
  603. var unplayed = 0;
  604. double totalPercentPlayed = 0;
  605. // Loop through each recursive child
  606. foreach (var child in folder.GetRecursiveChildren(user, true).Where(i => !i.IsFolder).ToList())
  607. {
  608. var userdata = userDataRepository.GetUserData(user.Id, child.GetUserDataKey());
  609. recursiveItemCount++;
  610. // Check is recently added
  611. if (child.IsRecentlyAdded())
  612. {
  613. rcentlyAddedItemCount++;
  614. }
  615. var isUnplayed = true;
  616. // Incrememt totalPercentPlayed
  617. if (userdata != null)
  618. {
  619. if (userdata.Played)
  620. {
  621. totalPercentPlayed += 100;
  622. isUnplayed = false;
  623. }
  624. else if (userdata.PlaybackPositionTicks > 0 && child.RunTimeTicks.HasValue && child.RunTimeTicks.Value > 0)
  625. {
  626. double itemPercent = userdata.PlaybackPositionTicks;
  627. itemPercent /= child.RunTimeTicks.Value;
  628. totalPercentPlayed += itemPercent;
  629. }
  630. }
  631. if (isUnplayed)
  632. {
  633. unplayed++;
  634. }
  635. }
  636. dto.RecursiveItemCount = recursiveItemCount;
  637. dto.RecentlyAddedItemCount = rcentlyAddedItemCount;
  638. dto.RecursiveUnplayedItemCount = unplayed;
  639. if (recursiveItemCount > 0)
  640. {
  641. dto.PlayedPercentage = totalPercentPlayed / recursiveItemCount;
  642. }
  643. }
  644. /// <summary>
  645. /// Attaches People DTO's to a DTOBaseItem
  646. /// </summary>
  647. /// <param name="dto">The dto.</param>
  648. /// <param name="item">The item.</param>
  649. /// <returns>Task.</returns>
  650. private async Task AttachPeople(BaseItemDto dto, BaseItem item)
  651. {
  652. // Ordering by person type to ensure actors and artists are at the front.
  653. // This is taking advantage of the fact that they both begin with A
  654. // This should be improved in the future
  655. var people = item.People.OrderBy(i => i.Type).ToList();
  656. // Attach People by transforming them into BaseItemPerson (DTO)
  657. dto.People = new BaseItemPerson[people.Count];
  658. var entities = await Task.WhenAll(people.Select(p => p.Name).Distinct(StringComparer.OrdinalIgnoreCase).Select(c =>
  659. Task.Run(async () =>
  660. {
  661. try
  662. {
  663. return await _libraryManager.GetPerson(c).ConfigureAwait(false);
  664. }
  665. catch (IOException ex)
  666. {
  667. _logger.ErrorException("Error getting person {0}", ex, c);
  668. return null;
  669. }
  670. })
  671. )).ConfigureAwait(false);
  672. var dictionary = entities.Where(i => i != null).ToDictionary(i => i.Name, StringComparer.OrdinalIgnoreCase);
  673. for (var i = 0; i < people.Count; i++)
  674. {
  675. var person = people[i];
  676. var baseItemPerson = new BaseItemPerson
  677. {
  678. Name = person.Name,
  679. Role = person.Role,
  680. Type = person.Type
  681. };
  682. Person entity;
  683. if (dictionary.TryGetValue(person.Name, out entity))
  684. {
  685. var primaryImagePath = entity.PrimaryImagePath;
  686. if (!string.IsNullOrEmpty(primaryImagePath))
  687. {
  688. baseItemPerson.PrimaryImageTag = GetImageCacheTag(entity, ImageType.Primary, primaryImagePath);
  689. }
  690. }
  691. dto.People[i] = baseItemPerson;
  692. }
  693. }
  694. /// <summary>
  695. /// Attaches the studios.
  696. /// </summary>
  697. /// <param name="dto">The dto.</param>
  698. /// <param name="item">The item.</param>
  699. /// <returns>Task.</returns>
  700. private async Task AttachStudios(BaseItemDto dto, BaseItem item)
  701. {
  702. var studios = item.Studios.ToList();
  703. dto.Studios = new StudioDto[studios.Count];
  704. var entities = await Task.WhenAll(studios.Distinct(StringComparer.OrdinalIgnoreCase).Select(c =>
  705. Task.Run(async () =>
  706. {
  707. try
  708. {
  709. return await _libraryManager.GetStudio(c).ConfigureAwait(false);
  710. }
  711. catch (IOException ex)
  712. {
  713. _logger.ErrorException("Error getting studio {0}", ex, c);
  714. return null;
  715. }
  716. })
  717. )).ConfigureAwait(false);
  718. var dictionary = entities.Where(i => i != null).ToDictionary(i => i.Name, StringComparer.OrdinalIgnoreCase);
  719. for (var i = 0; i < studios.Count; i++)
  720. {
  721. var studio = studios[i];
  722. var studioDto = new StudioDto
  723. {
  724. Name = studio
  725. };
  726. Studio entity;
  727. if (dictionary.TryGetValue(studio, out entity))
  728. {
  729. var primaryImagePath = entity.PrimaryImagePath;
  730. if (!string.IsNullOrEmpty(primaryImagePath))
  731. {
  732. studioDto.PrimaryImageTag = GetImageCacheTag(entity, ImageType.Primary, primaryImagePath);
  733. }
  734. }
  735. dto.Studios[i] = studioDto;
  736. }
  737. }
  738. /// <summary>
  739. /// If an item does not any backdrops, this can be used to find the first parent that does have one
  740. /// </summary>
  741. /// <param name="item">The item.</param>
  742. /// <returns>BaseItem.</returns>
  743. private BaseItem GetParentBackdropItem(BaseItem item)
  744. {
  745. var parent = item.Parent;
  746. while (parent != null)
  747. {
  748. if (parent.BackdropImagePaths != null && parent.BackdropImagePaths.Count > 0)
  749. {
  750. return parent;
  751. }
  752. parent = parent.Parent;
  753. }
  754. return null;
  755. }
  756. /// <summary>
  757. /// If an item does not have a logo, this can be used to find the first parent that does have one
  758. /// </summary>
  759. /// <param name="item">The item.</param>
  760. /// <param name="type">The type.</param>
  761. /// <returns>BaseItem.</returns>
  762. private BaseItem GetParentImageItem(BaseItem item, ImageType type)
  763. {
  764. var parent = item.Parent;
  765. while (parent != null)
  766. {
  767. if (parent.HasImage(type))
  768. {
  769. return parent;
  770. }
  771. parent = parent.Parent;
  772. }
  773. return null;
  774. }
  775. /// <summary>
  776. /// Converts a UserItemData to a DTOUserItemData
  777. /// </summary>
  778. /// <param name="data">The data.</param>
  779. /// <returns>DtoUserItemData.</returns>
  780. /// <exception cref="System.ArgumentNullException"></exception>
  781. public static UserItemDataDto GetUserItemDataDto(UserItemData data)
  782. {
  783. if (data == null)
  784. {
  785. throw new ArgumentNullException("data");
  786. }
  787. return new UserItemDataDto
  788. {
  789. IsFavorite = data.IsFavorite,
  790. Likes = data.Likes,
  791. PlaybackPositionTicks = data.PlaybackPositionTicks,
  792. PlayCount = data.PlayCount,
  793. Rating = data.Rating,
  794. Played = data.Played,
  795. LastPlayedDate = data.LastPlayedDate
  796. };
  797. }
  798. /// <summary>
  799. /// Gets the chapter info dto.
  800. /// </summary>
  801. /// <param name="chapterInfo">The chapter info.</param>
  802. /// <param name="item">The item.</param>
  803. /// <returns>ChapterInfoDto.</returns>
  804. private ChapterInfoDto GetChapterInfoDto(ChapterInfo chapterInfo, BaseItem item)
  805. {
  806. var dto = new ChapterInfoDto
  807. {
  808. Name = chapterInfo.Name,
  809. StartPositionTicks = chapterInfo.StartPositionTicks
  810. };
  811. if (!string.IsNullOrEmpty(chapterInfo.ImagePath))
  812. {
  813. dto.ImageTag = GetImageCacheTag(item, ImageType.Chapter, chapterInfo.ImagePath);
  814. }
  815. return dto;
  816. }
  817. /// <summary>
  818. /// Converts a BaseItem to a BaseItemInfo
  819. /// </summary>
  820. /// <param name="item">The item.</param>
  821. /// <returns>BaseItemInfo.</returns>
  822. /// <exception cref="System.ArgumentNullException">item</exception>
  823. public static BaseItemInfo GetBaseItemInfo(BaseItem item)
  824. {
  825. if (item == null)
  826. {
  827. throw new ArgumentNullException("item");
  828. }
  829. var info = new BaseItemInfo
  830. {
  831. Id = GetClientItemId(item),
  832. Name = item.Name,
  833. MediaType = item.MediaType,
  834. Type = item.GetType().Name,
  835. IsFolder = item.IsFolder,
  836. RunTimeTicks = item.RunTimeTicks
  837. };
  838. var imagePath = item.PrimaryImagePath;
  839. if (!string.IsNullOrEmpty(imagePath))
  840. {
  841. try
  842. {
  843. info.PrimaryImageTag = Kernel.Instance.ImageManager.GetImageCacheTag(item, ImageType.Primary, imagePath);
  844. }
  845. catch (IOException)
  846. {
  847. }
  848. }
  849. return info;
  850. }
  851. /// <summary>
  852. /// Gets client-side Id of a server-side BaseItem
  853. /// </summary>
  854. /// <param name="item">The item.</param>
  855. /// <returns>System.String.</returns>
  856. /// <exception cref="System.ArgumentNullException">item</exception>
  857. public static string GetClientItemId(BaseItem item)
  858. {
  859. if (item == null)
  860. {
  861. throw new ArgumentNullException("item");
  862. }
  863. var indexFolder = item as IndexFolder;
  864. if (indexFolder != null)
  865. {
  866. return GetClientItemId(indexFolder.Parent) + IndexFolderDelimeter + (indexFolder.IndexName ?? string.Empty) + IndexFolderDelimeter + indexFolder.Id;
  867. }
  868. return item.Id.ToString("N");
  869. }
  870. /// <summary>
  871. /// Gets a BaseItem based upon it's client-side item id
  872. /// </summary>
  873. /// <param name="id">The id.</param>
  874. /// <param name="userManager">The user manager.</param>
  875. /// <param name="libraryManager">The library manager.</param>
  876. /// <param name="userId">The user id.</param>
  877. /// <returns>BaseItem.</returns>
  878. public static BaseItem GetItemByClientId(string id, IUserManager userManager, ILibraryManager libraryManager, Guid? userId = null)
  879. {
  880. if (string.IsNullOrEmpty(id))
  881. {
  882. throw new ArgumentNullException("id");
  883. }
  884. // If the item is an indexed folder we have to do a special routine to get it
  885. var isIndexFolder = id.IndexOf(IndexFolderDelimeter, StringComparison.OrdinalIgnoreCase) != -1;
  886. if (isIndexFolder)
  887. {
  888. if (userId.HasValue)
  889. {
  890. return GetIndexFolder(id, userId.Value, userManager, libraryManager);
  891. }
  892. }
  893. BaseItem item = null;
  894. if (userId.HasValue || !isIndexFolder)
  895. {
  896. item = libraryManager.GetItemById(new Guid(id));
  897. }
  898. // If we still don't find it, look within individual user views
  899. if (item == null && !userId.HasValue && isIndexFolder)
  900. {
  901. foreach (var user in userManager.Users)
  902. {
  903. item = GetItemByClientId(id, userManager, libraryManager, user.Id);
  904. if (item != null)
  905. {
  906. break;
  907. }
  908. }
  909. }
  910. return item;
  911. }
  912. /// <summary>
  913. /// Finds an index folder based on an Id and userId
  914. /// </summary>
  915. /// <param name="id">The id.</param>
  916. /// <param name="userId">The user id.</param>
  917. /// <param name="userManager">The user manager.</param>
  918. /// <param name="libraryManager">The library manager.</param>
  919. /// <returns>BaseItem.</returns>
  920. private static BaseItem GetIndexFolder(string id, Guid userId, IUserManager userManager, ILibraryManager libraryManager)
  921. {
  922. var user = userManager.GetUserById(userId);
  923. var stringSeparators = new[] { IndexFolderDelimeter };
  924. // Split using the delimeter
  925. var values = id.Split(stringSeparators, StringSplitOptions.None).ToList();
  926. // Get the top folder normally using the first id
  927. var folder = GetItemByClientId(values[0], userManager, libraryManager, userId) as Folder;
  928. values.RemoveAt(0);
  929. // Get indexed folders using the remaining values in the id string
  930. return GetIndexFolder(values, folder, user);
  931. }
  932. /// <summary>
  933. /// Gets indexed folders based on a list of index names and folder id's
  934. /// </summary>
  935. /// <param name="values">The values.</param>
  936. /// <param name="parentFolder">The parent folder.</param>
  937. /// <param name="user">The user.</param>
  938. /// <returns>BaseItem.</returns>
  939. private static BaseItem GetIndexFolder(List<string> values, Folder parentFolder, User user)
  940. {
  941. // The index name is first
  942. var indexBy = values[0];
  943. // The index folder id is next
  944. var indexFolderId = new Guid(values[1]);
  945. // Remove them from the lst
  946. values.RemoveRange(0, 2);
  947. // Get the IndexFolder
  948. var indexFolder = parentFolder.GetChildren(user, false, indexBy).FirstOrDefault(i => i.Id == indexFolderId) as Folder;
  949. // Nested index folder
  950. if (values.Count > 0)
  951. {
  952. return GetIndexFolder(values, indexFolder, user);
  953. }
  954. return indexFolder;
  955. }
  956. /// <summary>
  957. /// Gets the backdrop image tags.
  958. /// </summary>
  959. /// <param name="item">The item.</param>
  960. /// <returns>List{System.String}.</returns>
  961. private List<Guid> GetBackdropImageTags(BaseItem item)
  962. {
  963. return item.BackdropImagePaths
  964. .Select(p => GetImageCacheTag(item, ImageType.Backdrop, p))
  965. .Where(i => i.HasValue)
  966. .Select(i => i.Value)
  967. .ToList();
  968. }
  969. /// <summary>
  970. /// Gets the screenshot image tags.
  971. /// </summary>
  972. /// <param name="item">The item.</param>
  973. /// <returns>List{Guid}.</returns>
  974. private List<Guid> GetScreenshotImageTags(BaseItem item)
  975. {
  976. return item.ScreenshotImagePaths
  977. .Select(p => GetImageCacheTag(item, ImageType.Screenshot, p))
  978. .Where(i => i.HasValue)
  979. .Select(i => i.Value)
  980. .ToList();
  981. }
  982. private Guid? GetImageCacheTag(BaseItem item, ImageType type, string path)
  983. {
  984. try
  985. {
  986. return Kernel.Instance.ImageManager.GetImageCacheTag(item, ImageType.Screenshot, path);
  987. }
  988. catch (IOException ex)
  989. {
  990. _logger.ErrorException("Error getting {0} image info for {1}", ex, type, path);
  991. return null;
  992. }
  993. }
  994. }
  995. }