LibraryService.cs 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788
  1. using MediaBrowser.Common.Extensions;
  2. using MediaBrowser.Controller.Dto;
  3. using MediaBrowser.Controller.Entities;
  4. using MediaBrowser.Controller.Entities.Audio;
  5. using MediaBrowser.Controller.Entities.Movies;
  6. using MediaBrowser.Controller.Entities.TV;
  7. using MediaBrowser.Controller.Library;
  8. using MediaBrowser.Controller.Persistence;
  9. using MediaBrowser.Model.Dto;
  10. using MediaBrowser.Model.Entities;
  11. using MediaBrowser.Model.Querying;
  12. using ServiceStack;
  13. using System;
  14. using System.Collections;
  15. using System.Collections.Generic;
  16. using System.Globalization;
  17. using System.IO;
  18. using System.Linq;
  19. using System.Threading;
  20. using System.Threading.Tasks;
  21. namespace MediaBrowser.Api.Library
  22. {
  23. [Route("/Items/{Id}/File", "GET")]
  24. [Api(Description = "Gets the original file of an item")]
  25. public class GetFile
  26. {
  27. /// <summary>
  28. /// Gets or sets the id.
  29. /// </summary>
  30. /// <value>The id.</value>
  31. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  32. public string Id { get; set; }
  33. }
  34. [Route("/Videos/{Id}/Subtitle/{Index}", "GET")]
  35. [Api(Description = "Gets an external subtitle file")]
  36. public class GetSubtitle
  37. {
  38. /// <summary>
  39. /// Gets or sets the id.
  40. /// </summary>
  41. /// <value>The id.</value>
  42. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  43. public string Id { get; set; }
  44. [ApiMember(Name = "Index", Description = "The subtitle stream index", IsRequired = true, DataType = "int", ParameterType = "path", Verb = "GET")]
  45. public int Index { get; set; }
  46. }
  47. /// <summary>
  48. /// Class GetCriticReviews
  49. /// </summary>
  50. [Route("/Items/{Id}/CriticReviews", "GET")]
  51. [Api(Description = "Gets critic reviews for an item")]
  52. public class GetCriticReviews : IReturn<QueryResult<ItemReview>>
  53. {
  54. /// <summary>
  55. /// Gets or sets the id.
  56. /// </summary>
  57. /// <value>The id.</value>
  58. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  59. public string Id { get; set; }
  60. /// <summary>
  61. /// Skips over a given number of items within the results. Use for paging.
  62. /// </summary>
  63. /// <value>The start index.</value>
  64. [ApiMember(Name = "StartIndex", Description = "Optional. The record index to start at. All items with a lower index will be dropped from the results.", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
  65. public int? StartIndex { get; set; }
  66. /// <summary>
  67. /// The maximum number of items to return
  68. /// </summary>
  69. /// <value>The limit.</value>
  70. [ApiMember(Name = "Limit", Description = "Optional. The maximum number of records to return", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
  71. public int? Limit { get; set; }
  72. }
  73. /// <summary>
  74. /// Class GetThemeSongs
  75. /// </summary>
  76. [Route("/Items/{Id}/ThemeSongs", "GET")]
  77. [Api(Description = "Gets theme songs for an item")]
  78. public class GetThemeSongs : IReturn<ThemeMediaResult>
  79. {
  80. /// <summary>
  81. /// Gets or sets the user id.
  82. /// </summary>
  83. /// <value>The user id.</value>
  84. [ApiMember(Name = "UserId", Description = "Optional. Filter by user id, and attach user data", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  85. public Guid? UserId { get; set; }
  86. /// <summary>
  87. /// Gets or sets the id.
  88. /// </summary>
  89. /// <value>The id.</value>
  90. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  91. public string Id { get; set; }
  92. [ApiMember(Name = "InheritFromParent", Description = "Determines whether or not parent items should be searched for theme media.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  93. public bool InheritFromParent { get; set; }
  94. }
  95. /// <summary>
  96. /// Class GetThemeVideos
  97. /// </summary>
  98. [Route("/Items/{Id}/ThemeVideos", "GET")]
  99. [Api(Description = "Gets theme videos for an item")]
  100. public class GetThemeVideos : IReturn<ThemeMediaResult>
  101. {
  102. /// <summary>
  103. /// Gets or sets the user id.
  104. /// </summary>
  105. /// <value>The user id.</value>
  106. [ApiMember(Name = "UserId", Description = "Optional. Filter by user id, and attach user data", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  107. public Guid? UserId { get; set; }
  108. /// <summary>
  109. /// Gets or sets the id.
  110. /// </summary>
  111. /// <value>The id.</value>
  112. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  113. public string Id { get; set; }
  114. [ApiMember(Name = "InheritFromParent", Description = "Determines whether or not parent items should be searched for theme media.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  115. public bool InheritFromParent { get; set; }
  116. }
  117. /// <summary>
  118. /// Class GetThemeVideos
  119. /// </summary>
  120. [Route("/Items/{Id}/ThemeMedia", "GET")]
  121. [Api(Description = "Gets theme videos and songs for an item")]
  122. public class GetThemeMedia : IReturn<AllThemeMediaResult>
  123. {
  124. /// <summary>
  125. /// Gets or sets the user id.
  126. /// </summary>
  127. /// <value>The user id.</value>
  128. [ApiMember(Name = "UserId", Description = "Optional. Filter by user id, and attach user data", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  129. public Guid? UserId { get; set; }
  130. /// <summary>
  131. /// Gets or sets the id.
  132. /// </summary>
  133. /// <value>The id.</value>
  134. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  135. public string Id { get; set; }
  136. [ApiMember(Name = "InheritFromParent", Description = "Determines whether or not parent items should be searched for theme media.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  137. public bool InheritFromParent { get; set; }
  138. }
  139. [Route("/Library/Refresh", "POST")]
  140. [Api(Description = "Starts a library scan")]
  141. public class RefreshLibrary : IReturnVoid
  142. {
  143. }
  144. [Route("/Items/{Id}", "DELETE")]
  145. [Api(Description = "Deletes an item from the library and file system")]
  146. public class DeleteItem : IReturnVoid
  147. {
  148. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  149. public string Id { get; set; }
  150. }
  151. [Route("/Items/Counts", "GET")]
  152. [Api(Description = "Gets counts of various item types")]
  153. public class GetItemCounts : IReturn<ItemCounts>
  154. {
  155. [ApiMember(Name = "UserId", Description = "Optional. Get counts from a specific user's library.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  156. public Guid? UserId { get; set; }
  157. [ApiMember(Name = "IsFavorite", Description = "Optional. Get counts of favorite items", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
  158. public bool? IsFavorite { get; set; }
  159. }
  160. [Route("/Items/{Id}/Ancestors", "GET")]
  161. [Api(Description = "Gets all parents of an item")]
  162. public class GetAncestors : IReturn<BaseItemDto[]>
  163. {
  164. /// <summary>
  165. /// Gets or sets the user id.
  166. /// </summary>
  167. /// <value>The user id.</value>
  168. [ApiMember(Name = "UserId", Description = "Optional. Filter by user id, and attach user data", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  169. public Guid? UserId { get; set; }
  170. /// <summary>
  171. /// Gets or sets the id.
  172. /// </summary>
  173. /// <value>The id.</value>
  174. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  175. public string Id { get; set; }
  176. }
  177. [Route("/Items/YearIndex", "GET")]
  178. [Api(Description = "Gets a year index based on an item query.")]
  179. public class GetYearIndex : IReturn<List<ItemIndex>>
  180. {
  181. /// <summary>
  182. /// Gets or sets the user id.
  183. /// </summary>
  184. /// <value>The user id.</value>
  185. [ApiMember(Name = "UserId", Description = "Optional. Filter by user id, and attach user data", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  186. public Guid? UserId { get; set; }
  187. [ApiMember(Name = "IncludeItemTypes", Description = "Optional. If specified, results will be filtered based on item type. This allows multiple, comma delimeted.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
  188. public string IncludeItemTypes { get; set; }
  189. }
  190. /// <summary>
  191. /// Class GetPhyscialPaths
  192. /// </summary>
  193. [Route("/Library/PhysicalPaths", "GET")]
  194. [Api(Description = "Gets a list of physical paths from virtual folders")]
  195. public class GetPhyscialPaths : IReturn<List<string>>
  196. {
  197. }
  198. [Route("/Library/MediaFolders", "GET")]
  199. [Api(Description = "Gets all user media folders.")]
  200. public class GetMediaFolders : IReturn<ItemsResult>
  201. {
  202. }
  203. /// <summary>
  204. /// Class LibraryService
  205. /// </summary>
  206. public class LibraryService : BaseApiService
  207. {
  208. /// <summary>
  209. /// The _item repo
  210. /// </summary>
  211. private readonly IItemRepository _itemRepo;
  212. private readonly ILibraryManager _libraryManager;
  213. private readonly IUserManager _userManager;
  214. private readonly IUserDataManager _userDataManager;
  215. private readonly IDtoService _dtoService;
  216. /// <summary>
  217. /// Initializes a new instance of the <see cref="LibraryService" /> class.
  218. /// </summary>
  219. public LibraryService(IItemRepository itemRepo, ILibraryManager libraryManager, IUserManager userManager,
  220. IDtoService dtoService, IUserDataManager userDataManager)
  221. {
  222. _itemRepo = itemRepo;
  223. _libraryManager = libraryManager;
  224. _userManager = userManager;
  225. _dtoService = dtoService;
  226. _userDataManager = userDataManager;
  227. }
  228. public object Get(GetMediaFolders request)
  229. {
  230. var items = _libraryManager.GetUserRootFolder().Children.OrderBy(i => i.SortName).ToList();
  231. // Get everything
  232. var fields = Enum.GetNames(typeof(ItemFields))
  233. .Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true))
  234. .ToList();
  235. var result = new ItemsResult
  236. {
  237. TotalRecordCount = items.Count,
  238. Items = items.Select(i => _dtoService.GetBaseItemDto(i, fields)).ToArray()
  239. };
  240. return ToOptimizedResult(result);
  241. }
  242. public object Get(GetFile request)
  243. {
  244. var item = _dtoService.GetItemByDtoId(request.Id);
  245. var locationType = item.LocationType;
  246. if (locationType == LocationType.Remote || locationType == LocationType.Virtual)
  247. {
  248. throw new ArgumentException("This command cannot be used for remote or virtual items.");
  249. }
  250. if (Directory.Exists(item.Path))
  251. {
  252. throw new ArgumentException("This command cannot be used for directories.");
  253. }
  254. return ToStaticFileResult(item.Path);
  255. }
  256. public object Get(GetSubtitle request)
  257. {
  258. var subtitleStream = _itemRepo.GetMediaStreams(new MediaStreamQuery
  259. {
  260. Index = request.Index,
  261. ItemId = new Guid(request.Id),
  262. Type = MediaStreamType.Subtitle
  263. }).FirstOrDefault();
  264. if (subtitleStream == null)
  265. {
  266. throw new ResourceNotFoundException();
  267. }
  268. return ToStaticFileResult(subtitleStream.Path);
  269. }
  270. /// <summary>
  271. /// Gets the specified request.
  272. /// </summary>
  273. /// <param name="request">The request.</param>
  274. /// <returns>System.Object.</returns>
  275. public object Get(GetPhyscialPaths request)
  276. {
  277. var result = _libraryManager.RootFolder.Children
  278. .SelectMany(c => c.PhysicalLocations)
  279. .ToList();
  280. return ToOptimizedSerializedResultUsingCache(result);
  281. }
  282. /// <summary>
  283. /// Gets the specified request.
  284. /// </summary>
  285. /// <param name="request">The request.</param>
  286. /// <returns>System.Object.</returns>
  287. public object Get(GetAncestors request)
  288. {
  289. var result = GetAncestors(request);
  290. return ToOptimizedSerializedResultUsingCache(result);
  291. }
  292. /// <summary>
  293. /// Gets the ancestors.
  294. /// </summary>
  295. /// <param name="request">The request.</param>
  296. /// <returns>Task{BaseItemDto[]}.</returns>
  297. public List<BaseItemDto> GetAncestors(GetAncestors request)
  298. {
  299. var item = _dtoService.GetItemByDtoId(request.Id);
  300. var baseItemDtos = new List<BaseItemDto>();
  301. var user = request.UserId.HasValue ? _userManager.GetUserById(request.UserId.Value) : null;
  302. // Get everything
  303. var fields = Enum.GetNames(typeof(ItemFields))
  304. .Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true))
  305. .ToList();
  306. BaseItem parent = item.Parent;
  307. while (parent != null)
  308. {
  309. if (user != null)
  310. {
  311. parent = TranslateParentItem(parent, user);
  312. }
  313. baseItemDtos.Add(_dtoService.GetBaseItemDto(parent, fields, user));
  314. parent = parent.Parent;
  315. }
  316. return baseItemDtos.ToList();
  317. }
  318. private BaseItem TranslateParentItem(BaseItem item, User user)
  319. {
  320. if (item.Parent is AggregateFolder)
  321. {
  322. return user.RootFolder.GetChildren(user, true).FirstOrDefault(i => i.PhysicalLocations.Contains(item.Path));
  323. }
  324. return item;
  325. }
  326. /// <summary>
  327. /// Gets the specified request.
  328. /// </summary>
  329. /// <param name="request">The request.</param>
  330. /// <returns>System.Object.</returns>
  331. public object Get(GetCriticReviews request)
  332. {
  333. var result = GetCriticReviews(request);
  334. return ToOptimizedSerializedResultUsingCache(result);
  335. }
  336. /// <summary>
  337. /// Gets the specified request.
  338. /// </summary>
  339. /// <param name="request">The request.</param>
  340. /// <returns>System.Object.</returns>
  341. public object Get(GetItemCounts request)
  342. {
  343. var items = GetAllLibraryItems(request.UserId, _userManager, _libraryManager)
  344. .Where(i => i.LocationType != LocationType.Virtual)
  345. .ToList();
  346. var filteredItems = request.UserId.HasValue ? FilterItems(items, request, request.UserId.Value).ToList() : items;
  347. var albums = filteredItems.OfType<MusicAlbum>().ToList();
  348. var episodes = filteredItems.OfType<Episode>().ToList();
  349. var games = filteredItems.OfType<Game>().ToList();
  350. var movies = filteredItems.OfType<Movie>().ToList();
  351. var musicVideos = filteredItems.OfType<MusicVideo>().ToList();
  352. var adultVideos = filteredItems.OfType<AdultVideo>().ToList();
  353. var boxsets = filteredItems.OfType<BoxSet>().ToList();
  354. var books = filteredItems.OfType<Book>().ToList();
  355. var songs = filteredItems.OfType<Audio>().ToList();
  356. var series = filteredItems.OfType<Series>().ToList();
  357. var counts = new ItemCounts
  358. {
  359. AlbumCount = albums.Count,
  360. EpisodeCount = episodes.Count,
  361. GameCount = games.Count,
  362. GameSystemCount = filteredItems.OfType<GameSystem>().Count(),
  363. MovieCount = movies.Count,
  364. SeriesCount = series.Count,
  365. SongCount = songs.Count,
  366. TrailerCount = filteredItems.OfType<Trailer>().Count(),
  367. MusicVideoCount = musicVideos.Count,
  368. AdultVideoCount = adultVideos.Count,
  369. BoxSetCount = boxsets.Count,
  370. BookCount = books.Count,
  371. UniqueTypes = items.Select(i => i.GetClientTypeName()).Distinct().ToList()
  372. };
  373. return ToOptimizedSerializedResultUsingCache(counts);
  374. }
  375. private IEnumerable<T> FilterItems<T>(IEnumerable<T> items, GetItemCounts request, Guid userId)
  376. where T : BaseItem
  377. {
  378. if (request.IsFavorite.HasValue)
  379. {
  380. var val = request.IsFavorite.Value;
  381. items = items.Where(i => _userDataManager.GetUserData(userId, i.GetUserDataKey()).IsFavorite == val);
  382. }
  383. return items;
  384. }
  385. /// <summary>
  386. /// Posts the specified request.
  387. /// </summary>
  388. /// <param name="request">The request.</param>
  389. public async void Post(RefreshLibrary request)
  390. {
  391. try
  392. {
  393. await _libraryManager.ValidateMediaLibrary(new Progress<double>(), CancellationToken.None)
  394. .ConfigureAwait(false);
  395. }
  396. catch (Exception ex)
  397. {
  398. Logger.ErrorException("Error refreshing library", ex);
  399. }
  400. }
  401. /// <summary>
  402. /// Deletes the specified request.
  403. /// </summary>
  404. /// <param name="request">The request.</param>
  405. public void Delete(DeleteItem request)
  406. {
  407. var task = DeleteItem(request);
  408. Task.WaitAll(task);
  409. }
  410. private Task DeleteItem(DeleteItem request)
  411. {
  412. var item = _dtoService.GetItemByDtoId(request.Id);
  413. return _libraryManager.DeleteItem(item);
  414. }
  415. /// <summary>
  416. /// Gets the critic reviews async.
  417. /// </summary>
  418. /// <param name="request">The request.</param>
  419. /// <returns>Task{ItemReviewsResult}.</returns>
  420. private QueryResult<ItemReview> GetCriticReviews(GetCriticReviews request)
  421. {
  422. var reviews = _itemRepo.GetCriticReviews(new Guid(request.Id));
  423. var reviewsArray = reviews.ToArray();
  424. var result = new QueryResult<ItemReview>
  425. {
  426. TotalRecordCount = reviewsArray.Length
  427. };
  428. if (request.StartIndex.HasValue)
  429. {
  430. reviewsArray = reviewsArray.Skip(request.StartIndex.Value).ToArray();
  431. }
  432. if (request.Limit.HasValue)
  433. {
  434. reviewsArray = reviewsArray.Take(request.Limit.Value).ToArray();
  435. }
  436. result.Items = reviewsArray;
  437. return result;
  438. }
  439. public object Get(GetThemeMedia request)
  440. {
  441. var themeSongs = GetThemeSongs(new GetThemeSongs
  442. {
  443. InheritFromParent = request.InheritFromParent,
  444. Id = request.Id,
  445. UserId = request.UserId
  446. });
  447. var themeVideos = GetThemeVideos(new GetThemeVideos
  448. {
  449. InheritFromParent = request.InheritFromParent,
  450. Id = request.Id,
  451. UserId = request.UserId
  452. });
  453. return ToOptimizedSerializedResultUsingCache(new AllThemeMediaResult
  454. {
  455. ThemeSongsResult = themeSongs,
  456. ThemeVideosResult = themeVideos,
  457. SoundtrackSongsResult = GetSoundtrackSongs(request.Id, request.UserId, request.InheritFromParent)
  458. });
  459. }
  460. /// <summary>
  461. /// Gets the specified request.
  462. /// </summary>
  463. /// <param name="request">The request.</param>
  464. /// <returns>System.Object.</returns>
  465. public object Get(GetThemeSongs request)
  466. {
  467. var result = GetThemeSongs(request);
  468. return ToOptimizedSerializedResultUsingCache(result);
  469. }
  470. private ThemeMediaResult GetThemeSongs(GetThemeSongs request)
  471. {
  472. var user = request.UserId.HasValue ? _userManager.GetUserById(request.UserId.Value) : null;
  473. var item = string.IsNullOrEmpty(request.Id)
  474. ? (request.UserId.HasValue
  475. ? user.RootFolder
  476. : (Folder)_libraryManager.RootFolder)
  477. : _dtoService.GetItemByDtoId(request.Id, request.UserId);
  478. var originalItem = item;
  479. while (GetThemeSongIds(item).Count == 0 && request.InheritFromParent && item.Parent != null)
  480. {
  481. item = item.Parent;
  482. }
  483. // Get everything
  484. var fields = Enum.GetNames(typeof(ItemFields))
  485. .Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true))
  486. .ToList();
  487. var themeSongIds = GetThemeSongIds(item);
  488. if (themeSongIds.Count == 0 && request.InheritFromParent)
  489. {
  490. var album = originalItem as MusicAlbum;
  491. if (album != null)
  492. {
  493. var linkedItemWithThemes = album.SoundtrackIds
  494. .Select(i => _libraryManager.GetItemById(i))
  495. .FirstOrDefault(i => GetThemeSongIds(i).Count > 0);
  496. if (linkedItemWithThemes != null)
  497. {
  498. themeSongIds = GetThemeSongIds(linkedItemWithThemes);
  499. item = linkedItemWithThemes;
  500. }
  501. }
  502. }
  503. var dtos = themeSongIds.Select(_libraryManager.GetItemById)
  504. .OrderBy(i => i.SortName)
  505. .Select(i => _dtoService.GetBaseItemDto(i, fields, user, item));
  506. var items = dtos.ToArray();
  507. return new ThemeMediaResult
  508. {
  509. Items = items,
  510. TotalRecordCount = items.Length,
  511. OwnerId = _dtoService.GetDtoId(item)
  512. };
  513. }
  514. /// <summary>
  515. /// Gets the specified request.
  516. /// </summary>
  517. /// <param name="request">The request.</param>
  518. /// <returns>System.Object.</returns>
  519. public object Get(GetThemeVideos request)
  520. {
  521. var result = GetThemeVideos(request);
  522. return ToOptimizedSerializedResultUsingCache(result);
  523. }
  524. public ThemeMediaResult GetThemeVideos(GetThemeVideos request)
  525. {
  526. var user = request.UserId.HasValue ? _userManager.GetUserById(request.UserId.Value) : null;
  527. var item = string.IsNullOrEmpty(request.Id)
  528. ? (request.UserId.HasValue
  529. ? user.RootFolder
  530. : (Folder)_libraryManager.RootFolder)
  531. : _dtoService.GetItemByDtoId(request.Id, request.UserId);
  532. var originalItem = item;
  533. while (GetThemeVideoIds(item).Count == 0 && request.InheritFromParent && item.Parent != null)
  534. {
  535. item = item.Parent;
  536. }
  537. // Get everything
  538. var fields = Enum.GetNames(typeof(ItemFields))
  539. .Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true))
  540. .ToList();
  541. var themeVideoIds = GetThemeVideoIds(item);
  542. if (themeVideoIds.Count == 0 && request.InheritFromParent)
  543. {
  544. var album = originalItem as MusicAlbum;
  545. if (album == null)
  546. {
  547. album = originalItem.Parents.OfType<MusicAlbum>().FirstOrDefault();
  548. }
  549. if (album != null)
  550. {
  551. var linkedItemWithThemes = album.SoundtrackIds
  552. .Select(i => _libraryManager.GetItemById(i))
  553. .FirstOrDefault(i => GetThemeVideoIds(i).Count > 0);
  554. if (linkedItemWithThemes != null)
  555. {
  556. themeVideoIds = GetThemeVideoIds(linkedItemWithThemes);
  557. item = linkedItemWithThemes;
  558. }
  559. }
  560. }
  561. var dtos = themeVideoIds.Select(_libraryManager.GetItemById)
  562. .OrderBy(i => i.SortName)
  563. .Select(i => _dtoService.GetBaseItemDto(i, fields, user, item));
  564. var items = dtos.ToArray();
  565. return new ThemeMediaResult
  566. {
  567. Items = items,
  568. TotalRecordCount = items.Length,
  569. OwnerId = _dtoService.GetDtoId(item)
  570. };
  571. }
  572. private List<Guid> GetThemeVideoIds(BaseItem item)
  573. {
  574. var i = item as IHasThemeMedia;
  575. if (i != null)
  576. {
  577. return i.ThemeVideoIds;
  578. }
  579. return new List<Guid>();
  580. }
  581. private List<Guid> GetThemeSongIds(BaseItem item)
  582. {
  583. var i = item as IHasThemeMedia;
  584. if (i != null)
  585. {
  586. return i.ThemeSongIds;
  587. }
  588. return new List<Guid>();
  589. }
  590. private readonly CultureInfo _usCulture = new CultureInfo("en-US");
  591. public object Get(GetYearIndex request)
  592. {
  593. IEnumerable<BaseItem> items = GetAllLibraryItems(request.UserId, _userManager, _libraryManager);
  594. if (!string.IsNullOrEmpty(request.IncludeItemTypes))
  595. {
  596. var vals = request.IncludeItemTypes.Split(',');
  597. items = items.Where(f => vals.Contains(f.GetType().Name, StringComparer.OrdinalIgnoreCase));
  598. }
  599. var lookup = items
  600. .ToLookup(i => i.ProductionYear ?? -1)
  601. .OrderBy(i => i.Key)
  602. .Select(i => new ItemIndex
  603. {
  604. ItemCount = i.Count(),
  605. Name = i.Key == -1 ? string.Empty : i.Key.ToString(_usCulture)
  606. })
  607. .ToList();
  608. return ToOptimizedSerializedResultUsingCache(lookup);
  609. }
  610. public ThemeMediaResult GetSoundtrackSongs(string id, Guid? userId, bool inheritFromParent)
  611. {
  612. var user = userId.HasValue ? _userManager.GetUserById(userId.Value) : null;
  613. var item = string.IsNullOrEmpty(id)
  614. ? (userId.HasValue
  615. ? user.RootFolder
  616. : (Folder)_libraryManager.RootFolder)
  617. : _dtoService.GetItemByDtoId(id, userId);
  618. // Get everything
  619. var fields = Enum.GetNames(typeof(ItemFields))
  620. .Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true))
  621. .ToList();
  622. var dtos = GetSoundtrackSongIds(item, inheritFromParent)
  623. .Select(_libraryManager.GetItemById)
  624. .OfType<MusicAlbum>()
  625. .SelectMany(i => i.RecursiveChildren)
  626. .OfType<Audio>()
  627. .OrderBy(i => i.SortName)
  628. .Select(i => _dtoService.GetBaseItemDto(i, fields, user, item));
  629. var items = dtos.ToArray();
  630. return new ThemeMediaResult
  631. {
  632. Items = items,
  633. TotalRecordCount = items.Length,
  634. OwnerId = _dtoService.GetDtoId(item)
  635. };
  636. }
  637. private IEnumerable<Guid> GetSoundtrackSongIds(BaseItem item, bool inherit)
  638. {
  639. var hasSoundtracks = item as IHasSoundtracks;
  640. if (hasSoundtracks != null)
  641. {
  642. return hasSoundtracks.SoundtrackIds;
  643. }
  644. if (!inherit)
  645. {
  646. return null;
  647. }
  648. hasSoundtracks = item.Parents.OfType<IHasSoundtracks>().FirstOrDefault();
  649. return hasSoundtracks != null ? hasSoundtracks.SoundtrackIds : new List<Guid>();
  650. }
  651. }
  652. }