UserLibraryService.cs 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804
  1. using System.Globalization;
  2. using MediaBrowser.Controller.Dto;
  3. using MediaBrowser.Controller.Entities;
  4. using MediaBrowser.Controller.Entities.Movies;
  5. using MediaBrowser.Controller.Entities.TV;
  6. using MediaBrowser.Controller.Library;
  7. using MediaBrowser.Controller.Session;
  8. using MediaBrowser.Model.Dto;
  9. using MediaBrowser.Model.Entities;
  10. using MediaBrowser.Model.Querying;
  11. using ServiceStack.ServiceHost;
  12. using System;
  13. using System.Collections.Generic;
  14. using System.Linq;
  15. using System.Threading;
  16. using System.Threading.Tasks;
  17. namespace MediaBrowser.Api.UserLibrary
  18. {
  19. /// <summary>
  20. /// Class GetItem
  21. /// </summary>
  22. [Route("/Users/{UserId}/Items/{Id}", "GET")]
  23. [Api(Description = "Gets an item from a user's library")]
  24. public class GetItem : IReturn<BaseItemDto>
  25. {
  26. /// <summary>
  27. /// Gets or sets the user id.
  28. /// </summary>
  29. /// <value>The user id.</value>
  30. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  31. public Guid UserId { get; set; }
  32. /// <summary>
  33. /// Gets or sets the id.
  34. /// </summary>
  35. /// <value>The id.</value>
  36. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  37. public string Id { get; set; }
  38. }
  39. /// <summary>
  40. /// Class GetItem
  41. /// </summary>
  42. [Route("/Users/{UserId}/Items/Root", "GET")]
  43. [Api(Description = "Gets the root folder from a user's library")]
  44. public class GetRootFolder : IReturn<BaseItemDto>
  45. {
  46. /// <summary>
  47. /// Gets or sets the user id.
  48. /// </summary>
  49. /// <value>The user id.</value>
  50. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  51. public Guid UserId { get; set; }
  52. }
  53. /// <summary>
  54. /// Class GetIntros
  55. /// </summary>
  56. [Route("/Users/{UserId}/Items/{Id}/Intros", "GET")]
  57. [Api(("Gets intros to play before the main media item plays"))]
  58. public class GetIntros : IReturn<ItemsResult>
  59. {
  60. /// <summary>
  61. /// Gets or sets the user id.
  62. /// </summary>
  63. /// <value>The user id.</value>
  64. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  65. public Guid UserId { get; set; }
  66. /// <summary>
  67. /// Gets or sets the item id.
  68. /// </summary>
  69. /// <value>The item id.</value>
  70. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  71. public string Id { get; set; }
  72. }
  73. /// <summary>
  74. /// Class MarkFavoriteItem
  75. /// </summary>
  76. [Route("/Users/{UserId}/FavoriteItems/{Id}", "POST")]
  77. [Api(Description = "Marks an item as a favorite")]
  78. public class MarkFavoriteItem : IReturn<UserItemDataDto>
  79. {
  80. /// <summary>
  81. /// Gets or sets the user id.
  82. /// </summary>
  83. /// <value>The user id.</value>
  84. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  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 = "POST")]
  91. public string Id { get; set; }
  92. }
  93. /// <summary>
  94. /// Class UnmarkFavoriteItem
  95. /// </summary>
  96. [Route("/Users/{UserId}/FavoriteItems/{Id}", "DELETE")]
  97. [Api(Description = "Unmarks an item as a favorite")]
  98. public class UnmarkFavoriteItem : IReturn<UserItemDataDto>
  99. {
  100. /// <summary>
  101. /// Gets or sets the user id.
  102. /// </summary>
  103. /// <value>The user id.</value>
  104. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  105. public Guid UserId { get; set; }
  106. /// <summary>
  107. /// Gets or sets the id.
  108. /// </summary>
  109. /// <value>The id.</value>
  110. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  111. public string Id { get; set; }
  112. }
  113. /// <summary>
  114. /// Class ClearUserItemRating
  115. /// </summary>
  116. [Route("/Users/{UserId}/Items/{Id}/Rating", "DELETE")]
  117. [Api(Description = "Deletes a user's saved personal rating for an item")]
  118. public class DeleteUserItemRating : IReturn<UserItemDataDto>
  119. {
  120. /// <summary>
  121. /// Gets or sets the user id.
  122. /// </summary>
  123. /// <value>The user id.</value>
  124. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  125. public Guid UserId { get; set; }
  126. /// <summary>
  127. /// Gets or sets the id.
  128. /// </summary>
  129. /// <value>The id.</value>
  130. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  131. public string Id { get; set; }
  132. }
  133. /// <summary>
  134. /// Class UpdateUserItemRating
  135. /// </summary>
  136. [Route("/Users/{UserId}/Items/{Id}/Rating", "POST")]
  137. [Api(Description = "Updates a user's rating for an item")]
  138. public class UpdateUserItemRating : IReturn<UserItemDataDto>
  139. {
  140. /// <summary>
  141. /// Gets or sets the user id.
  142. /// </summary>
  143. /// <value>The user id.</value>
  144. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  145. public Guid UserId { get; set; }
  146. /// <summary>
  147. /// Gets or sets the id.
  148. /// </summary>
  149. /// <value>The id.</value>
  150. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  151. public string Id { get; set; }
  152. /// <summary>
  153. /// Gets or sets a value indicating whether this <see cref="UpdateUserItemRating" /> is likes.
  154. /// </summary>
  155. /// <value><c>true</c> if likes; otherwise, <c>false</c>.</value>
  156. [ApiMember(Name = "Likes", Description = "Whether the user likes the item or not. true/false", IsRequired = true, DataType = "boolean", ParameterType = "query", Verb = "POST")]
  157. public bool Likes { get; set; }
  158. }
  159. /// <summary>
  160. /// Class MarkPlayedItem
  161. /// </summary>
  162. [Route("/Users/{UserId}/PlayedItems/{Id}", "POST")]
  163. [Api(Description = "Marks an item as played")]
  164. public class MarkPlayedItem : IReturn<UserItemDataDto>
  165. {
  166. /// <summary>
  167. /// Gets or sets the user id.
  168. /// </summary>
  169. /// <value>The user id.</value>
  170. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  171. public Guid UserId { get; set; }
  172. [ApiMember(Name = "DatePlayed", Description = "The date the item was played (if any). Format = yyyyMMddHHmmss", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "POST")]
  173. public string DatePlayed { get; set; }
  174. /// <summary>
  175. /// Gets or sets the id.
  176. /// </summary>
  177. /// <value>The id.</value>
  178. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  179. public string Id { get; set; }
  180. }
  181. /// <summary>
  182. /// Class MarkUnplayedItem
  183. /// </summary>
  184. [Route("/Users/{UserId}/PlayedItems/{Id}", "DELETE")]
  185. [Api(Description = "Marks an item as unplayed")]
  186. public class MarkUnplayedItem : IReturn<UserItemDataDto>
  187. {
  188. /// <summary>
  189. /// Gets or sets the user id.
  190. /// </summary>
  191. /// <value>The user id.</value>
  192. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  193. public Guid UserId { get; set; }
  194. /// <summary>
  195. /// Gets or sets the id.
  196. /// </summary>
  197. /// <value>The id.</value>
  198. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  199. public string Id { get; set; }
  200. }
  201. /// <summary>
  202. /// Class OnPlaybackStart
  203. /// </summary>
  204. [Route("/Users/{UserId}/PlayingItems/{Id}", "POST")]
  205. [Api(Description = "Reports that a user has begun playing an item")]
  206. public class OnPlaybackStart : IReturnVoid
  207. {
  208. /// <summary>
  209. /// Gets or sets the user id.
  210. /// </summary>
  211. /// <value>The user id.</value>
  212. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  213. public Guid UserId { get; set; }
  214. /// <summary>
  215. /// Gets or sets the id.
  216. /// </summary>
  217. /// <value>The id.</value>
  218. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  219. public string Id { get; set; }
  220. /// <summary>
  221. /// Gets or sets a value indicating whether this <see cref="UpdateUserItemRating" /> is likes.
  222. /// </summary>
  223. /// <value><c>true</c> if likes; otherwise, <c>false</c>.</value>
  224. [ApiMember(Name = "CanSeek", Description = "Indicates if the client can seek", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "POST")]
  225. public bool CanSeek { get; set; }
  226. /// <summary>
  227. /// Gets or sets the id.
  228. /// </summary>
  229. /// <value>The id.</value>
  230. [ApiMember(Name = "QueueableMediaTypes", Description = "A list of media types that can be queued from this item, comma delimited. Audio,Video,Book,Game", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "POST", AllowMultiple = true)]
  231. public string QueueableMediaTypes { get; set; }
  232. }
  233. /// <summary>
  234. /// Class OnPlaybackProgress
  235. /// </summary>
  236. [Route("/Users/{UserId}/PlayingItems/{Id}/Progress", "POST")]
  237. [Api(Description = "Reports a user's playback progress")]
  238. public class OnPlaybackProgress : IReturnVoid
  239. {
  240. /// <summary>
  241. /// Gets or sets the user id.
  242. /// </summary>
  243. /// <value>The user id.</value>
  244. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  245. public Guid UserId { get; set; }
  246. /// <summary>
  247. /// Gets or sets the id.
  248. /// </summary>
  249. /// <value>The id.</value>
  250. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  251. public string Id { get; set; }
  252. /// <summary>
  253. /// Gets or sets the position ticks.
  254. /// </summary>
  255. /// <value>The position ticks.</value>
  256. [ApiMember(Name = "PositionTicks", Description = "Optional. The current position, in ticks. 1 tick = 10000 ms", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "POST")]
  257. public long? PositionTicks { get; set; }
  258. [ApiMember(Name = "IsPaused", Description = "Indicates if the player is paused.", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "POST")]
  259. public bool IsPaused { get; set; }
  260. [ApiMember(Name = "IsMuted", Description = "Indicates if the player is muted.", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "POST")]
  261. public bool IsMuted { get; set; }
  262. }
  263. /// <summary>
  264. /// Class OnPlaybackStopped
  265. /// </summary>
  266. [Route("/Users/{UserId}/PlayingItems/{Id}", "DELETE")]
  267. [Api(Description = "Reports that a user has stopped playing an item")]
  268. public class OnPlaybackStopped : IReturnVoid
  269. {
  270. /// <summary>
  271. /// Gets or sets the user id.
  272. /// </summary>
  273. /// <value>The user id.</value>
  274. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  275. public Guid UserId { get; set; }
  276. /// <summary>
  277. /// Gets or sets the id.
  278. /// </summary>
  279. /// <value>The id.</value>
  280. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  281. public string Id { get; set; }
  282. /// <summary>
  283. /// Gets or sets the position ticks.
  284. /// </summary>
  285. /// <value>The position ticks.</value>
  286. [ApiMember(Name = "PositionTicks", Description = "Optional. The position, in ticks, where playback stopped. 1 tick = 10000 ms", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "DELETE")]
  287. public long? PositionTicks { get; set; }
  288. }
  289. /// <summary>
  290. /// Class GetLocalTrailers
  291. /// </summary>
  292. [Route("/Users/{UserId}/Items/{Id}/LocalTrailers", "GET")]
  293. [Api(Description = "Gets local trailers for an item")]
  294. public class GetLocalTrailers : IReturn<List<BaseItemDto>>
  295. {
  296. /// <summary>
  297. /// Gets or sets the user id.
  298. /// </summary>
  299. /// <value>The user id.</value>
  300. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  301. public Guid UserId { get; set; }
  302. /// <summary>
  303. /// Gets or sets the id.
  304. /// </summary>
  305. /// <value>The id.</value>
  306. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  307. public string Id { get; set; }
  308. }
  309. /// <summary>
  310. /// Class GetSpecialFeatures
  311. /// </summary>
  312. [Route("/Users/{UserId}/Items/{Id}/SpecialFeatures", "GET")]
  313. [Api(Description = "Gets special features for an item")]
  314. public class GetSpecialFeatures : IReturn<List<BaseItemDto>>
  315. {
  316. /// <summary>
  317. /// Gets or sets the user id.
  318. /// </summary>
  319. /// <value>The user id.</value>
  320. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  321. public Guid UserId { get; set; }
  322. /// <summary>
  323. /// Gets or sets the id.
  324. /// </summary>
  325. /// <value>The id.</value>
  326. [ApiMember(Name = "Id", Description = "Movie Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  327. public string Id { get; set; }
  328. }
  329. /// <summary>
  330. /// Class UserLibraryService
  331. /// </summary>
  332. public class UserLibraryService : BaseApiService
  333. {
  334. /// <summary>
  335. /// The _user manager
  336. /// </summary>
  337. private readonly IUserManager _userManager;
  338. /// <summary>
  339. /// The _user data repository
  340. /// </summary>
  341. private readonly IUserDataManager _userDataRepository;
  342. /// <summary>
  343. /// The _library manager
  344. /// </summary>
  345. private readonly ILibraryManager _libraryManager;
  346. private readonly ISessionManager _sessionManager;
  347. private readonly IDtoService _dtoService;
  348. /// <summary>
  349. /// Initializes a new instance of the <see cref="UserLibraryService" /> class.
  350. /// </summary>
  351. /// <param name="userManager">The user manager.</param>
  352. /// <param name="libraryManager">The library manager.</param>
  353. /// <param name="userDataRepository">The user data repository.</param>
  354. /// <param name="sessionManager">The session manager.</param>
  355. /// <param name="dtoService">The dto service.</param>
  356. /// <exception cref="System.ArgumentNullException">jsonSerializer</exception>
  357. public UserLibraryService(IUserManager userManager, ILibraryManager libraryManager, IUserDataManager userDataRepository, ISessionManager sessionManager, IDtoService dtoService)
  358. {
  359. _userManager = userManager;
  360. _libraryManager = libraryManager;
  361. _userDataRepository = userDataRepository;
  362. _sessionManager = sessionManager;
  363. _dtoService = dtoService;
  364. }
  365. /// <summary>
  366. /// Gets the specified request.
  367. /// </summary>
  368. /// <param name="request">The request.</param>
  369. /// <returns>System.Object.</returns>
  370. public object Get(GetSpecialFeatures request)
  371. {
  372. var result = GetAsync(request);
  373. return ToOptimizedResult(result);
  374. }
  375. private List<BaseItemDto> GetAsync(GetSpecialFeatures request)
  376. {
  377. var user = _userManager.GetUserById(request.UserId);
  378. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : _dtoService.GetItemByDtoId(request.Id, user.Id);
  379. // Get everything
  380. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  381. var movie = item as Movie;
  382. // Get them from the db
  383. if (movie != null)
  384. {
  385. // Avoid implicitly captured closure
  386. var movie1 = movie;
  387. var dtos = movie.SpecialFeatureIds
  388. .Select(_libraryManager.GetItemById)
  389. .OrderBy(i => i.SortName)
  390. .Select(i => _dtoService.GetBaseItemDto(i, fields, user, movie1));
  391. return dtos.ToList();
  392. }
  393. var series = item as Series;
  394. // Get them from the child tree
  395. if (series != null)
  396. {
  397. var dtos = series
  398. .GetRecursiveChildren(i => i is Episode && i.ParentIndexNumber.HasValue && i.ParentIndexNumber.Value == 0)
  399. .OrderBy(i =>
  400. {
  401. if (i.PremiereDate.HasValue)
  402. {
  403. return i.PremiereDate.Value;
  404. }
  405. if (i.ProductionYear.HasValue)
  406. {
  407. return new DateTime(i.ProductionYear.Value, 1, 1, 0, 0, 0, DateTimeKind.Utc);
  408. }
  409. return DateTime.MinValue;
  410. })
  411. .ThenBy(i => i.SortName)
  412. .Select(i => _dtoService.GetBaseItemDto(i, fields, user));
  413. return dtos.ToList();
  414. }
  415. throw new ArgumentException("The item does not support special features");
  416. }
  417. /// <summary>
  418. /// Gets the specified request.
  419. /// </summary>
  420. /// <param name="request">The request.</param>
  421. /// <returns>System.Object.</returns>
  422. public object Get(GetLocalTrailers request)
  423. {
  424. var result = GetAsync(request);
  425. return ToOptimizedResult(result);
  426. }
  427. private List<BaseItemDto> GetAsync(GetLocalTrailers request)
  428. {
  429. var user = _userManager.GetUserById(request.UserId);
  430. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : _dtoService.GetItemByDtoId(request.Id, user.Id);
  431. // Get everything
  432. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  433. var dtos = item.LocalTrailerIds
  434. .Select(_libraryManager.GetItemById)
  435. .OrderBy(i => i.SortName)
  436. .Select(i => _dtoService.GetBaseItemDto(i, fields, user, item));
  437. return dtos.ToList();
  438. }
  439. /// <summary>
  440. /// Gets the specified request.
  441. /// </summary>
  442. /// <param name="request">The request.</param>
  443. /// <returns>System.Object.</returns>
  444. public object Get(GetItem request)
  445. {
  446. var user = _userManager.GetUserById(request.UserId);
  447. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : _dtoService.GetItemByDtoId(request.Id, user.Id);
  448. // Get everything
  449. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  450. var result = _dtoService.GetBaseItemDto(item, fields, user);
  451. return ToOptimizedResult(result);
  452. }
  453. /// <summary>
  454. /// Gets the specified request.
  455. /// </summary>
  456. /// <param name="request">The request.</param>
  457. /// <returns>System.Object.</returns>
  458. public object Get(GetRootFolder request)
  459. {
  460. var user = _userManager.GetUserById(request.UserId);
  461. var item = user.RootFolder;
  462. // Get everything
  463. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  464. var result = _dtoService.GetBaseItemDto(item, fields, user);
  465. return ToOptimizedResult(result);
  466. }
  467. /// <summary>
  468. /// Gets the specified request.
  469. /// </summary>
  470. /// <param name="request">The request.</param>
  471. /// <returns>System.Object.</returns>
  472. public object Get(GetIntros request)
  473. {
  474. var user = _userManager.GetUserById(request.UserId);
  475. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : _dtoService.GetItemByDtoId(request.Id, user.Id);
  476. var items = _libraryManager.GetIntros(item, user);
  477. // Get everything
  478. var fields = Enum.GetNames(typeof(ItemFields))
  479. .Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true))
  480. .ToList();
  481. var dtos = items.Select(i => _dtoService.GetBaseItemDto(i, fields, user))
  482. .ToArray();
  483. var result = new ItemsResult
  484. {
  485. Items = dtos,
  486. TotalRecordCount = dtos.Length
  487. };
  488. return ToOptimizedResult(result);
  489. }
  490. /// <summary>
  491. /// Posts the specified request.
  492. /// </summary>
  493. /// <param name="request">The request.</param>
  494. public object Post(MarkFavoriteItem request)
  495. {
  496. var dto = MarkFavorite(request.UserId, request.Id, true).Result;
  497. return ToOptimizedResult(dto);
  498. }
  499. /// <summary>
  500. /// Deletes the specified request.
  501. /// </summary>
  502. /// <param name="request">The request.</param>
  503. public object Delete(UnmarkFavoriteItem request)
  504. {
  505. var dto = MarkFavorite(request.UserId, request.Id, false).Result;
  506. return ToOptimizedResult(dto);
  507. }
  508. /// <summary>
  509. /// Marks the favorite.
  510. /// </summary>
  511. /// <param name="userId">The user id.</param>
  512. /// <param name="itemId">The item id.</param>
  513. /// <param name="isFavorite">if set to <c>true</c> [is favorite].</param>
  514. /// <returns>Task{UserItemDataDto}.</returns>
  515. private async Task<UserItemDataDto> MarkFavorite(Guid userId, string itemId, bool isFavorite)
  516. {
  517. var user = _userManager.GetUserById(userId);
  518. var item = string.IsNullOrEmpty(itemId) ? user.RootFolder : _dtoService.GetItemByDtoId(itemId, user.Id);
  519. var key = item.GetUserDataKey();
  520. // Get the user data for this item
  521. var data = _userDataRepository.GetUserData(user.Id, key);
  522. // Set favorite status
  523. data.IsFavorite = isFavorite;
  524. await _userDataRepository.SaveUserData(user.Id, item, data, UserDataSaveReason.UpdateUserRating, CancellationToken.None).ConfigureAwait(false);
  525. data = _userDataRepository.GetUserData(user.Id, key);
  526. return _dtoService.GetUserItemDataDto(data);
  527. }
  528. /// <summary>
  529. /// Deletes the specified request.
  530. /// </summary>
  531. /// <param name="request">The request.</param>
  532. public object Delete(DeleteUserItemRating request)
  533. {
  534. var dto = UpdateUserItemRating(request.UserId, request.Id, null).Result;
  535. return ToOptimizedResult(dto);
  536. }
  537. /// <summary>
  538. /// Posts the specified request.
  539. /// </summary>
  540. /// <param name="request">The request.</param>
  541. public object Post(UpdateUserItemRating request)
  542. {
  543. var dto = UpdateUserItemRating(request.UserId, request.Id, request.Likes).Result;
  544. return ToOptimizedResult(dto);
  545. }
  546. /// <summary>
  547. /// Updates the user item rating.
  548. /// </summary>
  549. /// <param name="userId">The user id.</param>
  550. /// <param name="itemId">The item id.</param>
  551. /// <param name="likes">if set to <c>true</c> [likes].</param>
  552. /// <returns>Task{UserItemDataDto}.</returns>
  553. private async Task<UserItemDataDto> UpdateUserItemRating(Guid userId, string itemId, bool? likes)
  554. {
  555. var user = _userManager.GetUserById(userId);
  556. var item = string.IsNullOrEmpty(itemId) ? user.RootFolder : _dtoService.GetItemByDtoId(itemId, user.Id);
  557. var key = item.GetUserDataKey();
  558. // Get the user data for this item
  559. var data = _userDataRepository.GetUserData(user.Id, key);
  560. data.Likes = likes;
  561. await _userDataRepository.SaveUserData(user.Id, item, data, UserDataSaveReason.UpdateUserRating, CancellationToken.None).ConfigureAwait(false);
  562. data = _userDataRepository.GetUserData(user.Id, key);
  563. return _dtoService.GetUserItemDataDto(data);
  564. }
  565. /// <summary>
  566. /// Posts the specified request.
  567. /// </summary>
  568. /// <param name="request">The request.</param>
  569. public object Post(MarkPlayedItem request)
  570. {
  571. var user = _userManager.GetUserById(request.UserId);
  572. DateTime? datePlayed = null;
  573. if (!string.IsNullOrEmpty(request.DatePlayed))
  574. {
  575. datePlayed = DateTime.ParseExact(request.DatePlayed, "yyyyMMddHHmmss", CultureInfo.InvariantCulture, DateTimeStyles.AssumeUniversal);
  576. }
  577. var task = UpdatePlayedStatus(user, request.Id, true, datePlayed);
  578. return ToOptimizedResult(task.Result);
  579. }
  580. private SessionInfo GetSession()
  581. {
  582. var auth = AuthorizationRequestFilterAttribute.GetAuthorization(RequestContext);
  583. return _sessionManager.Sessions.First(i => string.Equals(i.DeviceId, auth.DeviceId) &&
  584. string.Equals(i.Client, auth.Client) &&
  585. string.Equals(i.ApplicationVersion, auth.Version));
  586. }
  587. /// <summary>
  588. /// Posts the specified request.
  589. /// </summary>
  590. /// <param name="request">The request.</param>
  591. public void Post(OnPlaybackStart request)
  592. {
  593. var user = _userManager.GetUserById(request.UserId);
  594. var item = _dtoService.GetItemByDtoId(request.Id, user.Id);
  595. var queueableMediaTypes = (request.QueueableMediaTypes ?? string.Empty);
  596. var info = new PlaybackInfo
  597. {
  598. CanSeek = request.CanSeek,
  599. Item = item,
  600. SessionId = GetSession().Id,
  601. QueueableMediaTypes = queueableMediaTypes.Split(',').ToList()
  602. };
  603. _sessionManager.OnPlaybackStart(info);
  604. }
  605. /// <summary>
  606. /// Posts the specified request.
  607. /// </summary>
  608. /// <param name="request">The request.</param>
  609. public void Post(OnPlaybackProgress request)
  610. {
  611. var user = _userManager.GetUserById(request.UserId);
  612. var item = _dtoService.GetItemByDtoId(request.Id, user.Id);
  613. var info = new PlaybackProgressInfo
  614. {
  615. Item = item,
  616. PositionTicks = request.PositionTicks,
  617. IsMuted = request.IsMuted,
  618. IsPaused = request.IsPaused,
  619. SessionId = GetSession().Id
  620. };
  621. var task = _sessionManager.OnPlaybackProgress(info);
  622. Task.WaitAll(task);
  623. }
  624. /// <summary>
  625. /// Posts the specified request.
  626. /// </summary>
  627. /// <param name="request">The request.</param>
  628. public void Delete(OnPlaybackStopped request)
  629. {
  630. var user = _userManager.GetUserById(request.UserId);
  631. var item = _dtoService.GetItemByDtoId(request.Id, user.Id);
  632. var session = GetSession();
  633. var info = new PlaybackStopInfo
  634. {
  635. Item = item,
  636. PositionTicks = request.PositionTicks,
  637. SessionId = session.Id
  638. };
  639. var task = _sessionManager.OnPlaybackStopped(info);
  640. Task.WaitAll(task);
  641. }
  642. /// <summary>
  643. /// Deletes the specified request.
  644. /// </summary>
  645. /// <param name="request">The request.</param>
  646. public object Delete(MarkUnplayedItem request)
  647. {
  648. var user = _userManager.GetUserById(request.UserId);
  649. var task = UpdatePlayedStatus(user, request.Id, false, null);
  650. return ToOptimizedResult(task.Result);
  651. }
  652. /// <summary>
  653. /// Updates the played status.
  654. /// </summary>
  655. /// <param name="user">The user.</param>
  656. /// <param name="itemId">The item id.</param>
  657. /// <param name="wasPlayed">if set to <c>true</c> [was played].</param>
  658. /// <param name="datePlayed">The date played.</param>
  659. /// <returns>Task.</returns>
  660. private async Task<UserItemDataDto> UpdatePlayedStatus(User user, string itemId, bool wasPlayed, DateTime? datePlayed)
  661. {
  662. var item = _dtoService.GetItemByDtoId(itemId, user.Id);
  663. if (wasPlayed)
  664. {
  665. await item.MarkPlayed(user, datePlayed, _userDataRepository).ConfigureAwait(false);
  666. }
  667. else
  668. {
  669. await item.MarkUnplayed(user, _userDataRepository).ConfigureAwait(false);
  670. }
  671. return _dtoService.GetUserItemDataDto(_userDataRepository.GetUserData(user.Id, item.GetUserDataKey()));
  672. }
  673. }
  674. }