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. }
  245. /// <summary>
  246. /// Class OnPlaybackStopped
  247. /// </summary>
  248. [Route("/Users/{UserId}/PlayingItems/{Id}", "DELETE")]
  249. [Api(Description = "Reports that a user has stopped playing an item")]
  250. public class OnPlaybackStopped : IReturnVoid
  251. {
  252. /// <summary>
  253. /// Gets or sets the user id.
  254. /// </summary>
  255. /// <value>The user id.</value>
  256. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  257. public Guid UserId { get; set; }
  258. /// <summary>
  259. /// Gets or sets the id.
  260. /// </summary>
  261. /// <value>The id.</value>
  262. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  263. public string Id { get; set; }
  264. /// <summary>
  265. /// Gets or sets the position ticks.
  266. /// </summary>
  267. /// <value>The position ticks.</value>
  268. [ApiMember(Name = "PositionTicks", Description = "Optional. The position, in ticks, where playback stopped. 1 tick = 10000 ms", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "DELETE")]
  269. public long? PositionTicks { get; set; }
  270. }
  271. /// <summary>
  272. /// Class GetLocalTrailers
  273. /// </summary>
  274. [Route("/Users/{UserId}/Items/{Id}/LocalTrailers", "GET")]
  275. [Api(Description = "Gets local trailers for an item")]
  276. public class GetLocalTrailers : IReturn<List<BaseItemDto>>
  277. {
  278. /// <summary>
  279. /// Gets or sets the user id.
  280. /// </summary>
  281. /// <value>The user id.</value>
  282. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  283. public Guid UserId { get; set; }
  284. /// <summary>
  285. /// Gets or sets the id.
  286. /// </summary>
  287. /// <value>The id.</value>
  288. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  289. public string Id { get; set; }
  290. }
  291. /// <summary>
  292. /// Class GetSpecialFeatures
  293. /// </summary>
  294. [Route("/Users/{UserId}/Items/{Id}/SpecialFeatures", "GET")]
  295. [Api(Description = "Gets special features for a movie")]
  296. public class GetSpecialFeatures : IReturn<List<BaseItemDto>>
  297. {
  298. /// <summary>
  299. /// Gets or sets the user id.
  300. /// </summary>
  301. /// <value>The user id.</value>
  302. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  303. public Guid UserId { get; set; }
  304. /// <summary>
  305. /// Gets or sets the id.
  306. /// </summary>
  307. /// <value>The id.</value>
  308. [ApiMember(Name = "Id", Description = "Movie Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  309. public string Id { get; set; }
  310. }
  311. /// <summary>
  312. /// Class UserLibraryService
  313. /// </summary>
  314. public class UserLibraryService : BaseApiService
  315. {
  316. /// <summary>
  317. /// The _user manager
  318. /// </summary>
  319. private readonly IUserManager _userManager;
  320. /// <summary>
  321. /// The _user data repository
  322. /// </summary>
  323. private readonly IUserDataRepository _userDataRepository;
  324. /// <summary>
  325. /// The _library manager
  326. /// </summary>
  327. private readonly ILibraryManager _libraryManager;
  328. private readonly IItemRepository _itemRepo;
  329. private readonly ISessionManager _sessionManager;
  330. /// <summary>
  331. /// Initializes a new instance of the <see cref="UserLibraryService" /> class.
  332. /// </summary>
  333. /// <param name="userManager">The user manager.</param>
  334. /// <param name="libraryManager">The library manager.</param>
  335. /// <param name="userDataRepository">The user data repository.</param>
  336. /// <param name="itemRepo">The item repo.</param>
  337. /// <exception cref="System.ArgumentNullException">jsonSerializer</exception>
  338. public UserLibraryService(IUserManager userManager, ILibraryManager libraryManager, IUserDataRepository userDataRepository, IItemRepository itemRepo, ISessionManager sessionManager)
  339. {
  340. _userManager = userManager;
  341. _libraryManager = libraryManager;
  342. _userDataRepository = userDataRepository;
  343. _itemRepo = itemRepo;
  344. _sessionManager = sessionManager;
  345. }
  346. /// <summary>
  347. /// Gets the specified request.
  348. /// </summary>
  349. /// <param name="request">The request.</param>
  350. /// <returns>System.Object.</returns>
  351. public object Get(GetSpecialFeatures request)
  352. {
  353. var result = GetAsync(request);
  354. return ToOptimizedResult(result);
  355. }
  356. private Task<BaseItemDto[]> GetAsync(GetSpecialFeatures request)
  357. {
  358. var user = _userManager.GetUserById(request.UserId);
  359. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  360. // Get everything
  361. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  362. var movie = (Movie)item;
  363. var dtoBuilder = new DtoBuilder(Logger, _libraryManager, _userDataRepository, _itemRepo);
  364. var tasks = movie.SpecialFeatureIds
  365. .Select(_itemRepo.RetrieveItem)
  366. .OrderBy(i => i.SortName)
  367. .Select(i => dtoBuilder.GetBaseItemDto(i, fields, user, movie));
  368. return Task.WhenAll(tasks);
  369. }
  370. /// <summary>
  371. /// Gets the specified request.
  372. /// </summary>
  373. /// <param name="request">The request.</param>
  374. /// <returns>System.Object.</returns>
  375. public object Get(GetLocalTrailers request)
  376. {
  377. var result = GetAsync(request);
  378. return ToOptimizedResult(result);
  379. }
  380. private Task<BaseItemDto[]> GetAsync(GetLocalTrailers request)
  381. {
  382. var user = _userManager.GetUserById(request.UserId);
  383. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  384. // Get everything
  385. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  386. var dtoBuilder = new DtoBuilder(Logger, _libraryManager, _userDataRepository, _itemRepo);
  387. var tasks = item.LocalTrailerIds
  388. .Select(_itemRepo.RetrieveItem)
  389. .OrderBy(i => i.SortName)
  390. .Select(i => dtoBuilder.GetBaseItemDto(i, fields, user, item));
  391. return Task.WhenAll(tasks);
  392. }
  393. /// <summary>
  394. /// Gets the specified request.
  395. /// </summary>
  396. /// <param name="request">The request.</param>
  397. /// <returns>System.Object.</returns>
  398. public object Get(GetItem request)
  399. {
  400. var user = _userManager.GetUserById(request.UserId);
  401. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  402. // Get everything
  403. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  404. var dtoBuilder = new DtoBuilder(Logger, _libraryManager, _userDataRepository, _itemRepo);
  405. var result = dtoBuilder.GetBaseItemDto(item, fields, user).Result;
  406. return ToOptimizedResult(result);
  407. }
  408. /// <summary>
  409. /// Gets the specified request.
  410. /// </summary>
  411. /// <param name="request">The request.</param>
  412. /// <returns>System.Object.</returns>
  413. public object Get(GetRootFolder request)
  414. {
  415. var user = _userManager.GetUserById(request.UserId);
  416. var item = user.RootFolder;
  417. // Get everything
  418. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  419. var dtoBuilder = new DtoBuilder(Logger, _libraryManager, _userDataRepository, _itemRepo);
  420. var result = dtoBuilder.GetBaseItemDto(item, fields, user).Result;
  421. return ToOptimizedResult(result);
  422. }
  423. /// <summary>
  424. /// Gets the specified request.
  425. /// </summary>
  426. /// <param name="request">The request.</param>
  427. /// <returns>System.Object.</returns>
  428. public object Get(GetIntros request)
  429. {
  430. var user = _userManager.GetUserById(request.UserId);
  431. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  432. var result = _libraryManager.GetIntros(item, user);
  433. return ToOptimizedResult(result);
  434. }
  435. /// <summary>
  436. /// Posts the specified request.
  437. /// </summary>
  438. /// <param name="request">The request.</param>
  439. public void Post(MarkFavoriteItem request)
  440. {
  441. var user = _userManager.GetUserById(request.UserId);
  442. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  443. // Get the user data for this item
  444. var key = item.GetUserDataKey();
  445. var data = _userDataRepository.GetUserData(user.Id, key);
  446. // Set favorite status
  447. data.IsFavorite = true;
  448. var task = _userDataRepository.SaveUserData(user.Id, key, data, CancellationToken.None);
  449. Task.WaitAll(task);
  450. }
  451. /// <summary>
  452. /// Deletes the specified request.
  453. /// </summary>
  454. /// <param name="request">The request.</param>
  455. public void Delete(UnmarkFavoriteItem request)
  456. {
  457. var user = _userManager.GetUserById(request.UserId);
  458. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.Id, _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 = false;
  464. var task = _userDataRepository.SaveUserData(user.Id, key, data, CancellationToken.None);
  465. Task.WaitAll(task);
  466. }
  467. /// <summary>
  468. /// Deletes the specified request.
  469. /// </summary>
  470. /// <param name="request">The request.</param>
  471. public void Delete(DeleteUserItemRating request)
  472. {
  473. var user = _userManager.GetUserById(request.UserId);
  474. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  475. var key = item.GetUserDataKey();
  476. // Get the user data for this item
  477. var data = _userDataRepository.GetUserData(user.Id, key);
  478. data.Rating = null;
  479. var task = _userDataRepository.SaveUserData(user.Id, key, data, CancellationToken.None);
  480. Task.WaitAll(task);
  481. }
  482. /// <summary>
  483. /// Posts the specified request.
  484. /// </summary>
  485. /// <param name="request">The request.</param>
  486. public void Post(UpdateUserItemRating request)
  487. {
  488. var user = _userManager.GetUserById(request.UserId);
  489. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.Id, _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 = request.Likes;
  494. var task = _userDataRepository.SaveUserData(user.Id, key, data, CancellationToken.None);
  495. Task.WaitAll(task);
  496. }
  497. /// <summary>
  498. /// Posts the specified request.
  499. /// </summary>
  500. /// <param name="request">The request.</param>
  501. public void Post(MarkPlayedItem request)
  502. {
  503. var user = _userManager.GetUserById(request.UserId);
  504. var task = UpdatePlayedStatus(user, request.Id, true);
  505. Task.WaitAll(task);
  506. }
  507. private SessionInfo GetSession()
  508. {
  509. var auth = RequestFilterAttribute.GetAuthorization(RequestContext);
  510. string deviceId;
  511. string client;
  512. string version;
  513. auth.TryGetValue("DeviceId", out deviceId);
  514. auth.TryGetValue("Client", out client);
  515. auth.TryGetValue("Version", out version);
  516. return _sessionManager.Sessions.First(i => string.Equals(i.DeviceId, deviceId) &&
  517. string.Equals(i.Client, client) &&
  518. string.Equals(i.ApplicationVersion, version));
  519. }
  520. /// <summary>
  521. /// Posts the specified request.
  522. /// </summary>
  523. /// <param name="request">The request.</param>
  524. public void Post(OnPlaybackStart request)
  525. {
  526. var user = _userManager.GetUserById(request.UserId);
  527. var item = DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  528. _sessionManager.OnPlaybackStart(item, GetSession().Id);
  529. }
  530. /// <summary>
  531. /// Posts the specified request.
  532. /// </summary>
  533. /// <param name="request">The request.</param>
  534. public void Post(OnPlaybackProgress request)
  535. {
  536. var user = _userManager.GetUserById(request.UserId);
  537. var item = DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  538. var task = _sessionManager.OnPlaybackProgress(item, request.PositionTicks, request.IsPaused, GetSession().Id);
  539. Task.WaitAll(task);
  540. }
  541. /// <summary>
  542. /// Posts the specified request.
  543. /// </summary>
  544. /// <param name="request">The request.</param>
  545. public void Delete(OnPlaybackStopped request)
  546. {
  547. var user = _userManager.GetUserById(request.UserId);
  548. var item = DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  549. var task = _sessionManager.OnPlaybackStopped(item, request.PositionTicks, GetSession().Id);
  550. Task.WaitAll(task);
  551. }
  552. /// <summary>
  553. /// Deletes the specified request.
  554. /// </summary>
  555. /// <param name="request">The request.</param>
  556. public void Delete(MarkUnplayedItem request)
  557. {
  558. var user = _userManager.GetUserById(request.UserId);
  559. var task = UpdatePlayedStatus(user, request.Id, false);
  560. Task.WaitAll(task);
  561. }
  562. /// <summary>
  563. /// Updates the played status.
  564. /// </summary>
  565. /// <param name="user">The user.</param>
  566. /// <param name="itemId">The item id.</param>
  567. /// <param name="wasPlayed">if set to <c>true</c> [was played].</param>
  568. /// <returns>Task.</returns>
  569. private Task UpdatePlayedStatus(User user, string itemId, bool wasPlayed)
  570. {
  571. var item = DtoBuilder.GetItemByClientId(itemId, _userManager, _libraryManager, user.Id);
  572. return item.SetPlayedStatus(user, wasPlayed, _userDataRepository);
  573. }
  574. }
  575. }