DtoBuilder.cs 40 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209
  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. dto.EndDate = item.EndDate;
  344. if (fields.Contains(ItemFields.HomePageUrl))
  345. {
  346. dto.HomePageUrl = item.HomePageUrl;
  347. }
  348. if (fields.Contains(ItemFields.Tags))
  349. {
  350. dto.Tags = item.Tags;
  351. }
  352. if (fields.Contains(ItemFields.ProductionLocations))
  353. {
  354. dto.ProductionLocations = item.ProductionLocations;
  355. }
  356. dto.AspectRatio = item.AspectRatio;
  357. dto.BackdropImageTags = GetBackdropImageTags(item);
  358. dto.ScreenshotImageTags = GetScreenshotImageTags(item);
  359. if (fields.Contains(ItemFields.Genres))
  360. {
  361. dto.Genres = item.Genres;
  362. }
  363. dto.ImageTags = new Dictionary<ImageType, Guid>();
  364. foreach (var image in item.Images)
  365. {
  366. var type = image.Key;
  367. var tag = GetImageCacheTag(item, type, image.Value);
  368. if (tag.HasValue)
  369. {
  370. dto.ImageTags[type] = tag.Value;
  371. }
  372. }
  373. dto.Id = GetClientItemId(item);
  374. dto.IndexNumber = item.IndexNumber;
  375. dto.IsFolder = item.IsFolder;
  376. dto.Language = item.Language;
  377. dto.MediaType = item.MediaType;
  378. dto.LocationType = item.LocationType;
  379. dto.CriticRating = item.CriticRating;
  380. if (fields.Contains(ItemFields.CriticRatingSummary))
  381. {
  382. dto.CriticRatingSummary = item.CriticRatingSummary;
  383. }
  384. var localTrailerCount = item.LocalTrailerIds.Count;
  385. if (localTrailerCount > 0)
  386. {
  387. dto.LocalTrailerCount = localTrailerCount;
  388. }
  389. dto.Name = item.Name;
  390. dto.OfficialRating = item.OfficialRating;
  391. var hasOverview = fields.Contains(ItemFields.Overview);
  392. var hasHtmlOverview = fields.Contains(ItemFields.OverviewHtml);
  393. if (hasOverview || hasHtmlOverview)
  394. {
  395. var strippedOverview = string.IsNullOrEmpty(item.Overview) ? item.Overview : item.Overview.StripHtml();
  396. if (hasOverview)
  397. {
  398. dto.Overview = strippedOverview;
  399. }
  400. // Only supply the html version if there was actually html content
  401. if (hasHtmlOverview)
  402. {
  403. dto.OverviewHtml = item.Overview;
  404. }
  405. }
  406. // If there are no backdrops, indicate what parent has them in case the Ui wants to allow inheritance
  407. if (dto.BackdropImageTags.Count == 0)
  408. {
  409. var parentWithBackdrop = GetParentBackdropItem(item);
  410. if (parentWithBackdrop != null)
  411. {
  412. dto.ParentBackdropItemId = GetClientItemId(parentWithBackdrop);
  413. dto.ParentBackdropImageTags = GetBackdropImageTags(parentWithBackdrop);
  414. }
  415. }
  416. if (item.Parent != null && fields.Contains(ItemFields.ParentId))
  417. {
  418. dto.ParentId = GetClientItemId(item.Parent);
  419. }
  420. dto.ParentIndexNumber = item.ParentIndexNumber;
  421. // If there is no logo, indicate what parent has one in case the Ui wants to allow inheritance
  422. if (!dto.HasLogo)
  423. {
  424. var parentWithLogo = GetParentImageItem(item, ImageType.Logo);
  425. if (parentWithLogo != null)
  426. {
  427. dto.ParentLogoItemId = GetClientItemId(parentWithLogo);
  428. dto.ParentLogoImageTag = GetImageCacheTag(parentWithLogo, ImageType.Logo, parentWithLogo.GetImage(ImageType.Logo));
  429. }
  430. }
  431. // If there is no art, indicate what parent has one in case the Ui wants to allow inheritance
  432. if (!dto.HasArtImage)
  433. {
  434. var parentWithImage = GetParentImageItem(item, ImageType.Art);
  435. if (parentWithImage != null)
  436. {
  437. dto.ParentArtItemId = GetClientItemId(parentWithImage);
  438. dto.ParentArtImageTag = GetImageCacheTag(parentWithImage, ImageType.Art, parentWithImage.GetImage(ImageType.Art));
  439. }
  440. }
  441. if (fields.Contains(ItemFields.Path))
  442. {
  443. dto.Path = item.Path;
  444. }
  445. dto.PremiereDate = item.PremiereDate;
  446. dto.ProductionYear = item.ProductionYear;
  447. if (fields.Contains(ItemFields.ProviderIds))
  448. {
  449. dto.ProviderIds = item.ProviderIds;
  450. }
  451. dto.RunTimeTicks = item.RunTimeTicks;
  452. if (fields.Contains(ItemFields.SortName))
  453. {
  454. dto.SortName = item.SortName;
  455. }
  456. if (fields.Contains(ItemFields.CustomRating))
  457. {
  458. dto.CustomRating = item.CustomRating;
  459. }
  460. if (fields.Contains(ItemFields.Taglines))
  461. {
  462. dto.Taglines = item.Taglines;
  463. }
  464. if (fields.Contains(ItemFields.RemoteTrailers))
  465. {
  466. dto.RemoteTrailers = item.RemoteTrailers;
  467. }
  468. dto.Type = item.GetType().Name;
  469. dto.CommunityRating = item.CommunityRating;
  470. if (item.IsFolder)
  471. {
  472. var folder = (Folder)item;
  473. if (fields.Contains(ItemFields.IndexOptions))
  474. {
  475. dto.IndexOptions = folder.IndexByOptionStrings.ToArray();
  476. }
  477. }
  478. // Add audio info
  479. var audio = item as Audio;
  480. if (audio != null)
  481. {
  482. dto.Album = audio.Album;
  483. dto.AlbumArtist = audio.AlbumArtist;
  484. dto.Artists = new[] { audio.Artist };
  485. var albumParent = audio.FindParent<MusicAlbum>();
  486. if (albumParent != null)
  487. {
  488. dto.AlbumId = GetClientItemId(albumParent);
  489. var imagePath = albumParent.PrimaryImagePath;
  490. if (!string.IsNullOrEmpty(imagePath))
  491. {
  492. dto.AlbumPrimaryImageTag = GetImageCacheTag(albumParent, ImageType.Primary, imagePath);
  493. }
  494. }
  495. }
  496. var album = item as MusicAlbum;
  497. if (album != null)
  498. {
  499. var songs = album.RecursiveChildren.OfType<Audio>().ToList();
  500. dto.AlbumArtist = songs.Select(i => i.AlbumArtist).FirstOrDefault(i => !string.IsNullOrEmpty(i));
  501. dto.Artists =
  502. songs.Select(i => i.Artist ?? string.Empty)
  503. .Where(i => !string.IsNullOrEmpty(i))
  504. .Distinct(StringComparer.OrdinalIgnoreCase)
  505. .ToArray();
  506. }
  507. // Add video info
  508. var video = item as Video;
  509. if (video != null)
  510. {
  511. dto.VideoType = video.VideoType;
  512. dto.Video3DFormat = video.Video3DFormat;
  513. dto.IsoType = video.IsoType;
  514. dto.PartCount = video.AdditionalPartIds.Count + 1;
  515. if (fields.Contains(ItemFields.Chapters))
  516. {
  517. dto.Chapters = _itemRepo.GetChapters(video.Id).Select(c => GetChapterInfoDto(c, item)).ToList();
  518. }
  519. }
  520. if (fields.Contains(ItemFields.MediaStreams))
  521. {
  522. // Add VideoInfo
  523. var iHasMediaStreams = item as IHasMediaStreams;
  524. if (iHasMediaStreams != null)
  525. {
  526. dto.MediaStreams = iHasMediaStreams.MediaStreams;
  527. }
  528. }
  529. // Add MovieInfo
  530. var movie = item as Movie;
  531. if (movie != null)
  532. {
  533. var specialFeatureCount = movie.SpecialFeatureIds.Count;
  534. if (specialFeatureCount > 0)
  535. {
  536. dto.SpecialFeatureCount = specialFeatureCount;
  537. }
  538. }
  539. // Add EpisodeInfo
  540. var episode = item as Episode;
  541. if (episode != null)
  542. {
  543. dto.IndexNumberEnd = episode.IndexNumberEnd;
  544. }
  545. // Add SeriesInfo
  546. var series = item as Series;
  547. if (series != null)
  548. {
  549. dto.AirDays = series.AirDays;
  550. dto.AirTime = series.AirTime;
  551. dto.Status = series.Status;
  552. }
  553. if (episode != null)
  554. {
  555. series = item.FindParent<Series>();
  556. dto.SeriesId = GetClientItemId(series);
  557. dto.SeriesName = series.Name;
  558. }
  559. // Add SeasonInfo
  560. var season = item as Season;
  561. if (season != null)
  562. {
  563. series = item.FindParent<Series>();
  564. dto.SeriesId = GetClientItemId(series);
  565. dto.SeriesName = series.Name;
  566. }
  567. var game = item as Game;
  568. if (game != null)
  569. {
  570. SetGameProperties(dto, game);
  571. }
  572. var musicVideo = item as MusicVideo;
  573. if (musicVideo != null)
  574. {
  575. SetMusicVideoProperties(dto, musicVideo);
  576. }
  577. }
  578. private void SetMusicVideoProperties(BaseItemDto dto, MusicVideo item)
  579. {
  580. dto.Album = item.Album;
  581. dto.Artists = string.IsNullOrEmpty(item.Artist) ? new string[] { } : new[] { item.Artist };
  582. }
  583. private void SetGameProperties(BaseItemDto dto, Game item)
  584. {
  585. dto.Players = item.PlayersSupported;
  586. dto.GameSystem = item.GameSystem;
  587. }
  588. /// <summary>
  589. /// Since it can be slow to make all of these calculations independently, this method will provide a way to do them all at once
  590. /// </summary>
  591. /// <param name="folder">The folder.</param>
  592. /// <param name="user">The user.</param>
  593. /// <param name="dto">The dto.</param>
  594. /// <param name="userDataRepository">The user data repository.</param>
  595. /// <returns>Task.</returns>
  596. private static void SetSpecialCounts(Folder folder, User user, BaseItemDto dto, IUserDataRepository userDataRepository)
  597. {
  598. var rcentlyAddedItemCount = 0;
  599. var recursiveItemCount = 0;
  600. var unplayed = 0;
  601. double totalPercentPlayed = 0;
  602. // Loop through each recursive child
  603. foreach (var child in folder.GetRecursiveChildren(user, true).Where(i => !i.IsFolder).ToList())
  604. {
  605. var userdata = userDataRepository.GetUserData(user.Id, child.GetUserDataKey());
  606. recursiveItemCount++;
  607. // Check is recently added
  608. if (child.IsRecentlyAdded())
  609. {
  610. rcentlyAddedItemCount++;
  611. }
  612. var isUnplayed = true;
  613. // Incrememt totalPercentPlayed
  614. if (userdata != null)
  615. {
  616. if (userdata.Played)
  617. {
  618. totalPercentPlayed += 100;
  619. isUnplayed = false;
  620. }
  621. else if (userdata.PlaybackPositionTicks > 0 && child.RunTimeTicks.HasValue && child.RunTimeTicks.Value > 0)
  622. {
  623. double itemPercent = userdata.PlaybackPositionTicks;
  624. itemPercent /= child.RunTimeTicks.Value;
  625. totalPercentPlayed += itemPercent;
  626. }
  627. }
  628. if (isUnplayed)
  629. {
  630. unplayed++;
  631. }
  632. }
  633. dto.RecursiveItemCount = recursiveItemCount;
  634. dto.RecentlyAddedItemCount = rcentlyAddedItemCount;
  635. dto.RecursiveUnplayedItemCount = unplayed;
  636. if (recursiveItemCount > 0)
  637. {
  638. dto.PlayedPercentage = totalPercentPlayed / recursiveItemCount;
  639. }
  640. }
  641. /// <summary>
  642. /// Attaches People DTO's to a DTOBaseItem
  643. /// </summary>
  644. /// <param name="dto">The dto.</param>
  645. /// <param name="item">The item.</param>
  646. /// <returns>Task.</returns>
  647. private async Task AttachPeople(BaseItemDto dto, BaseItem item)
  648. {
  649. // Ordering by person type to ensure actors and artists are at the front.
  650. // This is taking advantage of the fact that they both begin with A
  651. // This should be improved in the future
  652. var people = item.People.OrderBy(i => i.Type).ToList();
  653. // Attach People by transforming them into BaseItemPerson (DTO)
  654. dto.People = new BaseItemPerson[people.Count];
  655. var entities = await Task.WhenAll(people.Select(p => p.Name).Distinct(StringComparer.OrdinalIgnoreCase).Select(c =>
  656. Task.Run(async () =>
  657. {
  658. try
  659. {
  660. return await _libraryManager.GetPerson(c).ConfigureAwait(false);
  661. }
  662. catch (IOException ex)
  663. {
  664. _logger.ErrorException("Error getting person {0}", ex, c);
  665. return null;
  666. }
  667. })
  668. )).ConfigureAwait(false);
  669. var dictionary = entities.Where(i => i != null).ToDictionary(i => i.Name, StringComparer.OrdinalIgnoreCase);
  670. for (var i = 0; i < people.Count; i++)
  671. {
  672. var person = people[i];
  673. var baseItemPerson = new BaseItemPerson
  674. {
  675. Name = person.Name,
  676. Role = person.Role,
  677. Type = person.Type
  678. };
  679. Person entity;
  680. if (dictionary.TryGetValue(person.Name, out entity))
  681. {
  682. var primaryImagePath = entity.PrimaryImagePath;
  683. if (!string.IsNullOrEmpty(primaryImagePath))
  684. {
  685. baseItemPerson.PrimaryImageTag = GetImageCacheTag(entity, ImageType.Primary, primaryImagePath);
  686. }
  687. }
  688. dto.People[i] = baseItemPerson;
  689. }
  690. }
  691. /// <summary>
  692. /// Attaches the studios.
  693. /// </summary>
  694. /// <param name="dto">The dto.</param>
  695. /// <param name="item">The item.</param>
  696. /// <returns>Task.</returns>
  697. private async Task AttachStudios(BaseItemDto dto, BaseItem item)
  698. {
  699. var studios = item.Studios.ToList();
  700. dto.Studios = new StudioDto[studios.Count];
  701. var entities = await Task.WhenAll(studios.Distinct(StringComparer.OrdinalIgnoreCase).Select(c =>
  702. Task.Run(async () =>
  703. {
  704. try
  705. {
  706. return await _libraryManager.GetStudio(c).ConfigureAwait(false);
  707. }
  708. catch (IOException ex)
  709. {
  710. _logger.ErrorException("Error getting studio {0}", ex, c);
  711. return null;
  712. }
  713. })
  714. )).ConfigureAwait(false);
  715. var dictionary = entities.Where(i => i != null).ToDictionary(i => i.Name, StringComparer.OrdinalIgnoreCase);
  716. for (var i = 0; i < studios.Count; i++)
  717. {
  718. var studio = studios[i];
  719. var studioDto = new StudioDto
  720. {
  721. Name = studio
  722. };
  723. Studio entity;
  724. if (dictionary.TryGetValue(studio, out entity))
  725. {
  726. var primaryImagePath = entity.PrimaryImagePath;
  727. if (!string.IsNullOrEmpty(primaryImagePath))
  728. {
  729. studioDto.PrimaryImageTag = GetImageCacheTag(entity, ImageType.Primary, primaryImagePath);
  730. }
  731. }
  732. dto.Studios[i] = studioDto;
  733. }
  734. }
  735. /// <summary>
  736. /// If an item does not any backdrops, this can be used to find the first parent that does have one
  737. /// </summary>
  738. /// <param name="item">The item.</param>
  739. /// <returns>BaseItem.</returns>
  740. private BaseItem GetParentBackdropItem(BaseItem item)
  741. {
  742. var parent = item.Parent;
  743. while (parent != null)
  744. {
  745. if (parent.BackdropImagePaths != null && parent.BackdropImagePaths.Count > 0)
  746. {
  747. return parent;
  748. }
  749. parent = parent.Parent;
  750. }
  751. return null;
  752. }
  753. /// <summary>
  754. /// If an item does not have a logo, this can be used to find the first parent that does have one
  755. /// </summary>
  756. /// <param name="item">The item.</param>
  757. /// <param name="type">The type.</param>
  758. /// <returns>BaseItem.</returns>
  759. private BaseItem GetParentImageItem(BaseItem item, ImageType type)
  760. {
  761. var parent = item.Parent;
  762. while (parent != null)
  763. {
  764. if (parent.HasImage(type))
  765. {
  766. return parent;
  767. }
  768. parent = parent.Parent;
  769. }
  770. return null;
  771. }
  772. /// <summary>
  773. /// Converts a UserItemData to a DTOUserItemData
  774. /// </summary>
  775. /// <param name="data">The data.</param>
  776. /// <returns>DtoUserItemData.</returns>
  777. /// <exception cref="System.ArgumentNullException"></exception>
  778. public static UserItemDataDto GetUserItemDataDto(UserItemData data)
  779. {
  780. if (data == null)
  781. {
  782. throw new ArgumentNullException("data");
  783. }
  784. return new UserItemDataDto
  785. {
  786. IsFavorite = data.IsFavorite,
  787. Likes = data.Likes,
  788. PlaybackPositionTicks = data.PlaybackPositionTicks,
  789. PlayCount = data.PlayCount,
  790. Rating = data.Rating,
  791. Played = data.Played,
  792. LastPlayedDate = data.LastPlayedDate
  793. };
  794. }
  795. /// <summary>
  796. /// Gets the chapter info dto.
  797. /// </summary>
  798. /// <param name="chapterInfo">The chapter info.</param>
  799. /// <param name="item">The item.</param>
  800. /// <returns>ChapterInfoDto.</returns>
  801. private ChapterInfoDto GetChapterInfoDto(ChapterInfo chapterInfo, BaseItem item)
  802. {
  803. var dto = new ChapterInfoDto
  804. {
  805. Name = chapterInfo.Name,
  806. StartPositionTicks = chapterInfo.StartPositionTicks
  807. };
  808. if (!string.IsNullOrEmpty(chapterInfo.ImagePath))
  809. {
  810. dto.ImageTag = GetImageCacheTag(item, ImageType.Chapter, chapterInfo.ImagePath);
  811. }
  812. return dto;
  813. }
  814. /// <summary>
  815. /// Converts a BaseItem to a BaseItemInfo
  816. /// </summary>
  817. /// <param name="item">The item.</param>
  818. /// <returns>BaseItemInfo.</returns>
  819. /// <exception cref="System.ArgumentNullException">item</exception>
  820. public static BaseItemInfo GetBaseItemInfo(BaseItem item)
  821. {
  822. if (item == null)
  823. {
  824. throw new ArgumentNullException("item");
  825. }
  826. var info = new BaseItemInfo
  827. {
  828. Id = GetClientItemId(item),
  829. Name = item.Name,
  830. MediaType = item.MediaType,
  831. Type = item.GetType().Name,
  832. IsFolder = item.IsFolder,
  833. RunTimeTicks = item.RunTimeTicks
  834. };
  835. var imagePath = item.PrimaryImagePath;
  836. if (!string.IsNullOrEmpty(imagePath))
  837. {
  838. try
  839. {
  840. info.PrimaryImageTag = Kernel.Instance.ImageManager.GetImageCacheTag(item, ImageType.Primary, imagePath);
  841. }
  842. catch (IOException)
  843. {
  844. }
  845. }
  846. return info;
  847. }
  848. /// <summary>
  849. /// Gets client-side Id of a server-side BaseItem
  850. /// </summary>
  851. /// <param name="item">The item.</param>
  852. /// <returns>System.String.</returns>
  853. /// <exception cref="System.ArgumentNullException">item</exception>
  854. public static string GetClientItemId(BaseItem item)
  855. {
  856. if (item == null)
  857. {
  858. throw new ArgumentNullException("item");
  859. }
  860. var indexFolder = item as IndexFolder;
  861. if (indexFolder != null)
  862. {
  863. return GetClientItemId(indexFolder.Parent) + IndexFolderDelimeter + (indexFolder.IndexName ?? string.Empty) + IndexFolderDelimeter + indexFolder.Id;
  864. }
  865. return item.Id.ToString("N");
  866. }
  867. /// <summary>
  868. /// Gets a BaseItem based upon it's client-side item id
  869. /// </summary>
  870. /// <param name="id">The id.</param>
  871. /// <param name="userManager">The user manager.</param>
  872. /// <param name="libraryManager">The library manager.</param>
  873. /// <param name="userId">The user id.</param>
  874. /// <returns>BaseItem.</returns>
  875. public static BaseItem GetItemByClientId(string id, IUserManager userManager, ILibraryManager libraryManager, Guid? userId = null)
  876. {
  877. if (string.IsNullOrEmpty(id))
  878. {
  879. throw new ArgumentNullException("id");
  880. }
  881. // If the item is an indexed folder we have to do a special routine to get it
  882. var isIndexFolder = id.IndexOf(IndexFolderDelimeter, StringComparison.OrdinalIgnoreCase) != -1;
  883. if (isIndexFolder)
  884. {
  885. if (userId.HasValue)
  886. {
  887. return GetIndexFolder(id, userId.Value, userManager, libraryManager);
  888. }
  889. }
  890. BaseItem item = null;
  891. if (userId.HasValue || !isIndexFolder)
  892. {
  893. item = libraryManager.GetItemById(new Guid(id));
  894. }
  895. // If we still don't find it, look within individual user views
  896. if (item == null && !userId.HasValue && isIndexFolder)
  897. {
  898. foreach (var user in userManager.Users)
  899. {
  900. item = GetItemByClientId(id, userManager, libraryManager, user.Id);
  901. if (item != null)
  902. {
  903. break;
  904. }
  905. }
  906. }
  907. return item;
  908. }
  909. /// <summary>
  910. /// Finds an index folder based on an Id and userId
  911. /// </summary>
  912. /// <param name="id">The id.</param>
  913. /// <param name="userId">The user id.</param>
  914. /// <param name="userManager">The user manager.</param>
  915. /// <param name="libraryManager">The library manager.</param>
  916. /// <returns>BaseItem.</returns>
  917. private static BaseItem GetIndexFolder(string id, Guid userId, IUserManager userManager, ILibraryManager libraryManager)
  918. {
  919. var user = userManager.GetUserById(userId);
  920. var stringSeparators = new[] { IndexFolderDelimeter };
  921. // Split using the delimeter
  922. var values = id.Split(stringSeparators, StringSplitOptions.None).ToList();
  923. // Get the top folder normally using the first id
  924. var folder = GetItemByClientId(values[0], userManager, libraryManager, userId) as Folder;
  925. values.RemoveAt(0);
  926. // Get indexed folders using the remaining values in the id string
  927. return GetIndexFolder(values, folder, user);
  928. }
  929. /// <summary>
  930. /// Gets indexed folders based on a list of index names and folder id's
  931. /// </summary>
  932. /// <param name="values">The values.</param>
  933. /// <param name="parentFolder">The parent folder.</param>
  934. /// <param name="user">The user.</param>
  935. /// <returns>BaseItem.</returns>
  936. private static BaseItem GetIndexFolder(List<string> values, Folder parentFolder, User user)
  937. {
  938. // The index name is first
  939. var indexBy = values[0];
  940. // The index folder id is next
  941. var indexFolderId = new Guid(values[1]);
  942. // Remove them from the lst
  943. values.RemoveRange(0, 2);
  944. // Get the IndexFolder
  945. var indexFolder = parentFolder.GetChildren(user, false, indexBy).FirstOrDefault(i => i.Id == indexFolderId) as Folder;
  946. // Nested index folder
  947. if (values.Count > 0)
  948. {
  949. return GetIndexFolder(values, indexFolder, user);
  950. }
  951. return indexFolder;
  952. }
  953. /// <summary>
  954. /// Gets the backdrop image tags.
  955. /// </summary>
  956. /// <param name="item">The item.</param>
  957. /// <returns>List{System.String}.</returns>
  958. private List<Guid> GetBackdropImageTags(BaseItem item)
  959. {
  960. return item.BackdropImagePaths
  961. .Select(p => GetImageCacheTag(item, ImageType.Backdrop, p))
  962. .Where(i => i.HasValue)
  963. .Select(i => i.Value)
  964. .ToList();
  965. }
  966. /// <summary>
  967. /// Gets the screenshot image tags.
  968. /// </summary>
  969. /// <param name="item">The item.</param>
  970. /// <returns>List{Guid}.</returns>
  971. private List<Guid> GetScreenshotImageTags(BaseItem item)
  972. {
  973. return item.ScreenshotImagePaths
  974. .Select(p => GetImageCacheTag(item, ImageType.Screenshot, p))
  975. .Where(i => i.HasValue)
  976. .Select(i => i.Value)
  977. .ToList();
  978. }
  979. private Guid? GetImageCacheTag(BaseItem item, ImageType type, string path)
  980. {
  981. try
  982. {
  983. return Kernel.Instance.ImageManager.GetImageCacheTag(item, ImageType.Screenshot, path);
  984. }
  985. catch (IOException ex)
  986. {
  987. _logger.ErrorException("Error getting {0} image info for {1}", ex, type, path);
  988. return null;
  989. }
  990. }
  991. }
  992. }