UserLibraryService.cs 26 KB

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