UserLibraryService.cs 27 KB

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