UserLibraryService.cs 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812
  1. using MediaBrowser.Controller.Dto;
  2. using MediaBrowser.Controller.Entities;
  3. using MediaBrowser.Controller.Entities.Movies;
  4. using MediaBrowser.Controller.Entities.TV;
  5. using MediaBrowser.Controller.Library;
  6. using MediaBrowser.Controller.Session;
  7. using MediaBrowser.Model.Dto;
  8. using MediaBrowser.Model.Entities;
  9. using MediaBrowser.Model.Querying;
  10. using ServiceStack;
  11. using System;
  12. using System.Collections.Generic;
  13. using System.Globalization;
  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 trailerIds = new List<Guid>();
  434. var hasTrailers = item as IHasTrailers;
  435. if (hasTrailers != null)
  436. {
  437. trailerIds = hasTrailers.LocalTrailerIds;
  438. }
  439. var dtos = trailerIds
  440. .Select(_libraryManager.GetItemById)
  441. .OrderBy(i => i.SortName)
  442. .Select(i => _dtoService.GetBaseItemDto(i, fields, user, item));
  443. return dtos.ToList();
  444. }
  445. /// <summary>
  446. /// Gets the specified request.
  447. /// </summary>
  448. /// <param name="request">The request.</param>
  449. /// <returns>System.Object.</returns>
  450. public object Get(GetItem request)
  451. {
  452. var user = _userManager.GetUserById(request.UserId);
  453. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : _dtoService.GetItemByDtoId(request.Id, user.Id);
  454. // Get everything
  455. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  456. var result = _dtoService.GetBaseItemDto(item, fields, user);
  457. return ToOptimizedResult(result);
  458. }
  459. /// <summary>
  460. /// Gets the specified request.
  461. /// </summary>
  462. /// <param name="request">The request.</param>
  463. /// <returns>System.Object.</returns>
  464. public object Get(GetRootFolder request)
  465. {
  466. var user = _userManager.GetUserById(request.UserId);
  467. var item = user.RootFolder;
  468. // Get everything
  469. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  470. var result = _dtoService.GetBaseItemDto(item, fields, user);
  471. return ToOptimizedResult(result);
  472. }
  473. /// <summary>
  474. /// Gets the specified request.
  475. /// </summary>
  476. /// <param name="request">The request.</param>
  477. /// <returns>System.Object.</returns>
  478. public object Get(GetIntros request)
  479. {
  480. var user = _userManager.GetUserById(request.UserId);
  481. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : _dtoService.GetItemByDtoId(request.Id, user.Id);
  482. var items = _libraryManager.GetIntros(item, user);
  483. // Get everything
  484. var fields = Enum.GetNames(typeof(ItemFields))
  485. .Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true))
  486. .ToList();
  487. var dtos = items.Select(i => _dtoService.GetBaseItemDto(i, fields, user))
  488. .ToArray();
  489. var result = new ItemsResult
  490. {
  491. Items = dtos,
  492. TotalRecordCount = dtos.Length
  493. };
  494. return ToOptimizedResult(result);
  495. }
  496. /// <summary>
  497. /// Posts the specified request.
  498. /// </summary>
  499. /// <param name="request">The request.</param>
  500. public object Post(MarkFavoriteItem request)
  501. {
  502. var dto = MarkFavorite(request.UserId, request.Id, true).Result;
  503. return ToOptimizedResult(dto);
  504. }
  505. /// <summary>
  506. /// Deletes the specified request.
  507. /// </summary>
  508. /// <param name="request">The request.</param>
  509. public object Delete(UnmarkFavoriteItem request)
  510. {
  511. var dto = MarkFavorite(request.UserId, request.Id, false).Result;
  512. return ToOptimizedResult(dto);
  513. }
  514. /// <summary>
  515. /// Marks the favorite.
  516. /// </summary>
  517. /// <param name="userId">The user id.</param>
  518. /// <param name="itemId">The item id.</param>
  519. /// <param name="isFavorite">if set to <c>true</c> [is favorite].</param>
  520. /// <returns>Task{UserItemDataDto}.</returns>
  521. private async Task<UserItemDataDto> MarkFavorite(Guid userId, string itemId, bool isFavorite)
  522. {
  523. var user = _userManager.GetUserById(userId);
  524. var item = string.IsNullOrEmpty(itemId) ? user.RootFolder : _dtoService.GetItemByDtoId(itemId, user.Id);
  525. var key = item.GetUserDataKey();
  526. // Get the user data for this item
  527. var data = _userDataRepository.GetUserData(user.Id, key);
  528. // Set favorite status
  529. data.IsFavorite = isFavorite;
  530. await _userDataRepository.SaveUserData(user.Id, item, data, UserDataSaveReason.UpdateUserRating, CancellationToken.None).ConfigureAwait(false);
  531. data = _userDataRepository.GetUserData(user.Id, key);
  532. return _dtoService.GetUserItemDataDto(data);
  533. }
  534. /// <summary>
  535. /// Deletes the specified request.
  536. /// </summary>
  537. /// <param name="request">The request.</param>
  538. public object Delete(DeleteUserItemRating request)
  539. {
  540. var dto = UpdateUserItemRating(request.UserId, request.Id, null).Result;
  541. return ToOptimizedResult(dto);
  542. }
  543. /// <summary>
  544. /// Posts the specified request.
  545. /// </summary>
  546. /// <param name="request">The request.</param>
  547. public object Post(UpdateUserItemRating request)
  548. {
  549. var dto = UpdateUserItemRating(request.UserId, request.Id, request.Likes).Result;
  550. return ToOptimizedResult(dto);
  551. }
  552. /// <summary>
  553. /// Updates the user item rating.
  554. /// </summary>
  555. /// <param name="userId">The user id.</param>
  556. /// <param name="itemId">The item id.</param>
  557. /// <param name="likes">if set to <c>true</c> [likes].</param>
  558. /// <returns>Task{UserItemDataDto}.</returns>
  559. private async Task<UserItemDataDto> UpdateUserItemRating(Guid userId, string itemId, bool? likes)
  560. {
  561. var user = _userManager.GetUserById(userId);
  562. var item = string.IsNullOrEmpty(itemId) ? user.RootFolder : _dtoService.GetItemByDtoId(itemId, user.Id);
  563. var key = item.GetUserDataKey();
  564. // Get the user data for this item
  565. var data = _userDataRepository.GetUserData(user.Id, key);
  566. data.Likes = likes;
  567. await _userDataRepository.SaveUserData(user.Id, item, data, UserDataSaveReason.UpdateUserRating, CancellationToken.None).ConfigureAwait(false);
  568. data = _userDataRepository.GetUserData(user.Id, key);
  569. return _dtoService.GetUserItemDataDto(data);
  570. }
  571. /// <summary>
  572. /// Posts the specified request.
  573. /// </summary>
  574. /// <param name="request">The request.</param>
  575. public object Post(MarkPlayedItem request)
  576. {
  577. var user = _userManager.GetUserById(request.UserId);
  578. DateTime? datePlayed = null;
  579. if (!string.IsNullOrEmpty(request.DatePlayed))
  580. {
  581. datePlayed = DateTime.ParseExact(request.DatePlayed, "yyyyMMddHHmmss", CultureInfo.InvariantCulture, DateTimeStyles.AssumeUniversal);
  582. }
  583. var task = UpdatePlayedStatus(user, request.Id, true, datePlayed);
  584. return ToOptimizedResult(task.Result);
  585. }
  586. private SessionInfo GetSession()
  587. {
  588. var auth = AuthorizationRequestFilterAttribute.GetAuthorization(Request);
  589. return _sessionManager.Sessions.First(i => string.Equals(i.DeviceId, auth.DeviceId) &&
  590. string.Equals(i.Client, auth.Client) &&
  591. string.Equals(i.ApplicationVersion, auth.Version));
  592. }
  593. /// <summary>
  594. /// Posts the specified request.
  595. /// </summary>
  596. /// <param name="request">The request.</param>
  597. public void Post(OnPlaybackStart request)
  598. {
  599. var user = _userManager.GetUserById(request.UserId);
  600. var item = _dtoService.GetItemByDtoId(request.Id, user.Id);
  601. var queueableMediaTypes = (request.QueueableMediaTypes ?? string.Empty);
  602. var info = new PlaybackInfo
  603. {
  604. CanSeek = request.CanSeek,
  605. Item = item,
  606. SessionId = GetSession().Id,
  607. QueueableMediaTypes = queueableMediaTypes.Split(',').ToList()
  608. };
  609. _sessionManager.OnPlaybackStart(info);
  610. }
  611. /// <summary>
  612. /// Posts the specified request.
  613. /// </summary>
  614. /// <param name="request">The request.</param>
  615. public void Post(OnPlaybackProgress request)
  616. {
  617. var user = _userManager.GetUserById(request.UserId);
  618. var item = _dtoService.GetItemByDtoId(request.Id, user.Id);
  619. var info = new PlaybackProgressInfo
  620. {
  621. Item = item,
  622. PositionTicks = request.PositionTicks,
  623. IsMuted = request.IsMuted,
  624. IsPaused = request.IsPaused,
  625. SessionId = GetSession().Id
  626. };
  627. var task = _sessionManager.OnPlaybackProgress(info);
  628. Task.WaitAll(task);
  629. }
  630. /// <summary>
  631. /// Posts the specified request.
  632. /// </summary>
  633. /// <param name="request">The request.</param>
  634. public void Delete(OnPlaybackStopped request)
  635. {
  636. var user = _userManager.GetUserById(request.UserId);
  637. var item = _dtoService.GetItemByDtoId(request.Id, user.Id);
  638. var session = GetSession();
  639. var info = new PlaybackStopInfo
  640. {
  641. Item = item,
  642. PositionTicks = request.PositionTicks,
  643. SessionId = session.Id
  644. };
  645. var task = _sessionManager.OnPlaybackStopped(info);
  646. Task.WaitAll(task);
  647. }
  648. /// <summary>
  649. /// Deletes the specified request.
  650. /// </summary>
  651. /// <param name="request">The request.</param>
  652. public object Delete(MarkUnplayedItem request)
  653. {
  654. var user = _userManager.GetUserById(request.UserId);
  655. var task = UpdatePlayedStatus(user, request.Id, false, null);
  656. return ToOptimizedResult(task.Result);
  657. }
  658. /// <summary>
  659. /// Updates the played status.
  660. /// </summary>
  661. /// <param name="user">The user.</param>
  662. /// <param name="itemId">The item id.</param>
  663. /// <param name="wasPlayed">if set to <c>true</c> [was played].</param>
  664. /// <param name="datePlayed">The date played.</param>
  665. /// <returns>Task.</returns>
  666. private async Task<UserItemDataDto> UpdatePlayedStatus(User user, string itemId, bool wasPlayed, DateTime? datePlayed)
  667. {
  668. var item = _dtoService.GetItemByDtoId(itemId, user.Id);
  669. if (wasPlayed)
  670. {
  671. await item.MarkPlayed(user, datePlayed, _userDataRepository).ConfigureAwait(false);
  672. }
  673. else
  674. {
  675. await item.MarkUnplayed(user, _userDataRepository).ConfigureAwait(false);
  676. }
  677. return _dtoService.GetUserItemDataDto(_userDataRepository.GetUserData(user.Id, item.GetUserDataKey()));
  678. }
  679. }
  680. }