UserLibraryService.cs 26 KB

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