UserLibraryService.cs 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727
  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. /// <summary>
  172. /// Gets or sets the id.
  173. /// </summary>
  174. /// <value>The id.</value>
  175. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  176. public string Id { get; set; }
  177. }
  178. /// <summary>
  179. /// Class MarkUnplayedItem
  180. /// </summary>
  181. [Route("/Users/{UserId}/PlayedItems/{Id}", "DELETE")]
  182. [Api(Description = "Marks an item as unplayed")]
  183. public class MarkUnplayedItem : IReturn<UserItemDataDto>
  184. {
  185. /// <summary>
  186. /// Gets or sets the user id.
  187. /// </summary>
  188. /// <value>The user id.</value>
  189. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  190. public Guid UserId { get; set; }
  191. /// <summary>
  192. /// Gets or sets the id.
  193. /// </summary>
  194. /// <value>The id.</value>
  195. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  196. public string Id { get; set; }
  197. }
  198. /// <summary>
  199. /// Class OnPlaybackStart
  200. /// </summary>
  201. [Route("/Users/{UserId}/PlayingItems/{Id}", "POST")]
  202. [Api(Description = "Reports that a user has begun playing an item")]
  203. public class OnPlaybackStart : IReturnVoid
  204. {
  205. /// <summary>
  206. /// Gets or sets the user id.
  207. /// </summary>
  208. /// <value>The user id.</value>
  209. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  210. public Guid UserId { get; set; }
  211. /// <summary>
  212. /// Gets or sets the id.
  213. /// </summary>
  214. /// <value>The id.</value>
  215. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  216. public string Id { get; set; }
  217. }
  218. /// <summary>
  219. /// Class OnPlaybackProgress
  220. /// </summary>
  221. [Route("/Users/{UserId}/PlayingItems/{Id}/Progress", "POST")]
  222. [Api(Description = "Reports a user's playback progress")]
  223. public class OnPlaybackProgress : IReturnVoid
  224. {
  225. /// <summary>
  226. /// Gets or sets the user id.
  227. /// </summary>
  228. /// <value>The user id.</value>
  229. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  230. public Guid UserId { get; set; }
  231. /// <summary>
  232. /// Gets or sets the id.
  233. /// </summary>
  234. /// <value>The id.</value>
  235. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  236. public string Id { get; set; }
  237. /// <summary>
  238. /// Gets or sets the position ticks.
  239. /// </summary>
  240. /// <value>The position ticks.</value>
  241. [ApiMember(Name = "PositionTicks", Description = "Optional. The current position, in ticks. 1 tick = 10000 ms", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "POST")]
  242. public long? PositionTicks { get; set; }
  243. [ApiMember(Name = "IsPaused", Description = "Indicates if the player is paused.", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "POST")]
  244. public bool IsPaused { get; set; }
  245. [ApiMember(Name = "IsMuted", Description = "Indicates if the player is muted.", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "POST")]
  246. public bool IsMuted { get; set; }
  247. }
  248. /// <summary>
  249. /// Class OnPlaybackStopped
  250. /// </summary>
  251. [Route("/Users/{UserId}/PlayingItems/{Id}", "DELETE")]
  252. [Api(Description = "Reports that a user has stopped playing an item")]
  253. public class OnPlaybackStopped : IReturnVoid
  254. {
  255. /// <summary>
  256. /// Gets or sets the user id.
  257. /// </summary>
  258. /// <value>The user id.</value>
  259. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  260. public Guid UserId { get; set; }
  261. /// <summary>
  262. /// Gets or sets the id.
  263. /// </summary>
  264. /// <value>The id.</value>
  265. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  266. public string Id { get; set; }
  267. /// <summary>
  268. /// Gets or sets the position ticks.
  269. /// </summary>
  270. /// <value>The position ticks.</value>
  271. [ApiMember(Name = "PositionTicks", Description = "Optional. The position, in ticks, where playback stopped. 1 tick = 10000 ms", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "DELETE")]
  272. public long? PositionTicks { get; set; }
  273. }
  274. /// <summary>
  275. /// Class GetLocalTrailers
  276. /// </summary>
  277. [Route("/Users/{UserId}/Items/{Id}/LocalTrailers", "GET")]
  278. [Api(Description = "Gets local trailers for an item")]
  279. public class GetLocalTrailers : IReturn<List<BaseItemDto>>
  280. {
  281. /// <summary>
  282. /// Gets or sets the user id.
  283. /// </summary>
  284. /// <value>The user id.</value>
  285. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  286. public Guid UserId { get; set; }
  287. /// <summary>
  288. /// Gets or sets the id.
  289. /// </summary>
  290. /// <value>The id.</value>
  291. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  292. public string Id { get; set; }
  293. }
  294. /// <summary>
  295. /// Class GetSpecialFeatures
  296. /// </summary>
  297. [Route("/Users/{UserId}/Items/{Id}/SpecialFeatures", "GET")]
  298. [Api(Description = "Gets special features for an item")]
  299. public class GetSpecialFeatures : IReturn<List<BaseItemDto>>
  300. {
  301. /// <summary>
  302. /// Gets or sets the user id.
  303. /// </summary>
  304. /// <value>The user id.</value>
  305. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  306. public Guid UserId { get; set; }
  307. /// <summary>
  308. /// Gets or sets the id.
  309. /// </summary>
  310. /// <value>The id.</value>
  311. [ApiMember(Name = "Id", Description = "Movie Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  312. public string Id { get; set; }
  313. }
  314. /// <summary>
  315. /// Class UserLibraryService
  316. /// </summary>
  317. public class UserLibraryService : BaseApiService
  318. {
  319. /// <summary>
  320. /// The _user manager
  321. /// </summary>
  322. private readonly IUserManager _userManager;
  323. /// <summary>
  324. /// The _user data repository
  325. /// </summary>
  326. private readonly IUserDataRepository _userDataRepository;
  327. /// <summary>
  328. /// The _library manager
  329. /// </summary>
  330. private readonly ILibraryManager _libraryManager;
  331. private readonly IItemRepository _itemRepo;
  332. private readonly ISessionManager _sessionManager;
  333. private readonly IDtoService _dtoService;
  334. /// <summary>
  335. /// Initializes a new instance of the <see cref="UserLibraryService" /> class.
  336. /// </summary>
  337. /// <param name="userManager">The user manager.</param>
  338. /// <param name="libraryManager">The library manager.</param>
  339. /// <param name="userDataRepository">The user data repository.</param>
  340. /// <param name="itemRepo">The item repo.</param>
  341. /// <exception cref="System.ArgumentNullException">jsonSerializer</exception>
  342. public UserLibraryService(IUserManager userManager, ILibraryManager libraryManager, IUserDataRepository userDataRepository, IItemRepository itemRepo, ISessionManager sessionManager, IDtoService dtoService)
  343. {
  344. _userManager = userManager;
  345. _libraryManager = libraryManager;
  346. _userDataRepository = userDataRepository;
  347. _itemRepo = itemRepo;
  348. _sessionManager = sessionManager;
  349. _dtoService = dtoService;
  350. }
  351. /// <summary>
  352. /// Gets the specified request.
  353. /// </summary>
  354. /// <param name="request">The request.</param>
  355. /// <returns>System.Object.</returns>
  356. public object Get(GetSpecialFeatures request)
  357. {
  358. var result = GetAsync(request);
  359. return ToOptimizedResult(result);
  360. }
  361. private List<BaseItemDto> GetAsync(GetSpecialFeatures request)
  362. {
  363. var user = _userManager.GetUserById(request.UserId);
  364. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : _dtoService.GetItemByDtoId(request.Id, user.Id);
  365. // Get everything
  366. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  367. var movie = item as Movie;
  368. // Get them from the db
  369. if (movie != null)
  370. {
  371. // Avoid implicitly captured closure
  372. var movie1 = movie;
  373. var dtos = movie.SpecialFeatureIds
  374. .Select(_itemRepo.RetrieveItem)
  375. .OrderBy(i => i.SortName)
  376. .Select(i => _dtoService.GetBaseItemDto(i, fields, user, movie1));
  377. return dtos.ToList();
  378. }
  379. var series = item as Series;
  380. // Get them from the child tree
  381. if (series != null)
  382. {
  383. var dtos = series
  384. .RecursiveChildren
  385. .OfType<Episode>()
  386. .Where(i => i.ParentIndexNumber.HasValue && i.ParentIndexNumber.Value == 0)
  387. .OrderBy(i =>
  388. {
  389. if (i.PremiereDate.HasValue)
  390. {
  391. return i.PremiereDate.Value;
  392. }
  393. if (i.ProductionYear.HasValue)
  394. {
  395. return new DateTime(i.ProductionYear.Value, 1, 1, 0, 0, 0, DateTimeKind.Utc);
  396. }
  397. return DateTime.MinValue;
  398. })
  399. .ThenBy(i => i.SortName)
  400. .Select(i => _dtoService.GetBaseItemDto(i, fields, user));
  401. return dtos.ToList();
  402. }
  403. throw new ArgumentException("The item does not support special features");
  404. }
  405. /// <summary>
  406. /// Gets the specified request.
  407. /// </summary>
  408. /// <param name="request">The request.</param>
  409. /// <returns>System.Object.</returns>
  410. public object Get(GetLocalTrailers request)
  411. {
  412. var result = GetAsync(request);
  413. return ToOptimizedResult(result);
  414. }
  415. private List<BaseItemDto> GetAsync(GetLocalTrailers request)
  416. {
  417. var user = _userManager.GetUserById(request.UserId);
  418. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : _dtoService.GetItemByDtoId(request.Id, user.Id);
  419. // Get everything
  420. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  421. var dtos = item.LocalTrailerIds
  422. .Select(_itemRepo.RetrieveItem)
  423. .OrderBy(i => i.SortName)
  424. .Select(i => _dtoService.GetBaseItemDto(i, fields, user, item));
  425. return dtos.ToList();
  426. }
  427. /// <summary>
  428. /// Gets the specified request.
  429. /// </summary>
  430. /// <param name="request">The request.</param>
  431. /// <returns>System.Object.</returns>
  432. public object Get(GetItem request)
  433. {
  434. var user = _userManager.GetUserById(request.UserId);
  435. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : _dtoService.GetItemByDtoId(request.Id, user.Id);
  436. // Get everything
  437. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  438. var result = _dtoService.GetBaseItemDto(item, fields, user);
  439. return ToOptimizedResult(result);
  440. }
  441. /// <summary>
  442. /// Gets the specified request.
  443. /// </summary>
  444. /// <param name="request">The request.</param>
  445. /// <returns>System.Object.</returns>
  446. public object Get(GetRootFolder request)
  447. {
  448. var user = _userManager.GetUserById(request.UserId);
  449. var item = user.RootFolder;
  450. // Get everything
  451. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  452. var result = _dtoService.GetBaseItemDto(item, fields, user);
  453. return ToOptimizedResult(result);
  454. }
  455. /// <summary>
  456. /// Gets the specified request.
  457. /// </summary>
  458. /// <param name="request">The request.</param>
  459. /// <returns>System.Object.</returns>
  460. public object Get(GetIntros request)
  461. {
  462. var user = _userManager.GetUserById(request.UserId);
  463. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : _dtoService.GetItemByDtoId(request.Id, user.Id);
  464. var result = _libraryManager.GetIntros(item, user);
  465. return ToOptimizedResult(result);
  466. }
  467. /// <summary>
  468. /// Posts the specified request.
  469. /// </summary>
  470. /// <param name="request">The request.</param>
  471. public object Post(MarkFavoriteItem request)
  472. {
  473. var dto = MarkFavorite(request.UserId, request.Id, true).Result;
  474. return ToOptimizedResult(dto);
  475. }
  476. /// <summary>
  477. /// Deletes the specified request.
  478. /// </summary>
  479. /// <param name="request">The request.</param>
  480. public object Delete(UnmarkFavoriteItem request)
  481. {
  482. var dto = MarkFavorite(request.UserId, request.Id, false).Result;
  483. return ToOptimizedResult(dto);
  484. }
  485. private async Task<UserItemDataDto> MarkFavorite(Guid userId, string itemId, bool isFavorite)
  486. {
  487. var user = _userManager.GetUserById(userId);
  488. var item = string.IsNullOrEmpty(itemId) ? user.RootFolder : _dtoService.GetItemByDtoId(itemId, user.Id);
  489. var key = item.GetUserDataKey();
  490. // Get the user data for this item
  491. var data = _userDataRepository.GetUserData(user.Id, key);
  492. // Set favorite status
  493. data.IsFavorite = isFavorite;
  494. await _userDataRepository.SaveUserData(user.Id, key, data, CancellationToken.None).ConfigureAwait(false);
  495. data = _userDataRepository.GetUserData(user.Id, key);
  496. return _dtoService.GetUserItemDataDto(data);
  497. }
  498. /// <summary>
  499. /// Deletes the specified request.
  500. /// </summary>
  501. /// <param name="request">The request.</param>
  502. public object Delete(DeleteUserItemRating request)
  503. {
  504. var dto = UpdateUserItemRating(request.UserId, request.Id, null).Result;
  505. return ToOptimizedResult(dto);
  506. }
  507. /// <summary>
  508. /// Posts the specified request.
  509. /// </summary>
  510. /// <param name="request">The request.</param>
  511. public object Post(UpdateUserItemRating request)
  512. {
  513. var dto = UpdateUserItemRating(request.UserId, request.Id, request.Likes).Result;
  514. return ToOptimizedResult(dto);
  515. }
  516. private async Task<UserItemDataDto> UpdateUserItemRating(Guid userId, string itemId, bool? likes)
  517. {
  518. var user = _userManager.GetUserById(userId);
  519. var item = string.IsNullOrEmpty(itemId) ? user.RootFolder : _dtoService.GetItemByDtoId(itemId, user.Id);
  520. var key = item.GetUserDataKey();
  521. // Get the user data for this item
  522. var data = _userDataRepository.GetUserData(user.Id, key);
  523. data.Likes = likes;
  524. await _userDataRepository.SaveUserData(user.Id, key, data, CancellationToken.None).ConfigureAwait(false);
  525. data = _userDataRepository.GetUserData(user.Id, key);
  526. return _dtoService.GetUserItemDataDto(data);
  527. }
  528. /// <summary>
  529. /// Posts the specified request.
  530. /// </summary>
  531. /// <param name="request">The request.</param>
  532. public object Post(MarkPlayedItem request)
  533. {
  534. var user = _userManager.GetUserById(request.UserId);
  535. var task = UpdatePlayedStatus(user, request.Id, true);
  536. return ToOptimizedResult(task.Result);
  537. }
  538. private SessionInfo GetSession()
  539. {
  540. var auth = RequestFilterAttribute.GetAuthorization(RequestContext);
  541. string deviceId;
  542. string client;
  543. string version;
  544. auth.TryGetValue("DeviceId", out deviceId);
  545. auth.TryGetValue("Client", out client);
  546. auth.TryGetValue("Version", out version);
  547. return _sessionManager.Sessions.First(i => string.Equals(i.DeviceId, deviceId) &&
  548. string.Equals(i.Client, client) &&
  549. string.Equals(i.ApplicationVersion, version));
  550. }
  551. /// <summary>
  552. /// Posts the specified request.
  553. /// </summary>
  554. /// <param name="request">The request.</param>
  555. public void Post(OnPlaybackStart request)
  556. {
  557. var user = _userManager.GetUserById(request.UserId);
  558. var item = _dtoService.GetItemByDtoId(request.Id, user.Id);
  559. _sessionManager.OnPlaybackStart(item, GetSession().Id);
  560. }
  561. /// <summary>
  562. /// Posts the specified request.
  563. /// </summary>
  564. /// <param name="request">The request.</param>
  565. public void Post(OnPlaybackProgress request)
  566. {
  567. var user = _userManager.GetUserById(request.UserId);
  568. var item = _dtoService.GetItemByDtoId(request.Id, user.Id);
  569. var task = _sessionManager.OnPlaybackProgress(item, request.PositionTicks, request.IsPaused, request.IsMuted, GetSession().Id);
  570. Task.WaitAll(task);
  571. }
  572. /// <summary>
  573. /// Posts the specified request.
  574. /// </summary>
  575. /// <param name="request">The request.</param>
  576. public void Delete(OnPlaybackStopped request)
  577. {
  578. var user = _userManager.GetUserById(request.UserId);
  579. var item = _dtoService.GetItemByDtoId(request.Id, user.Id);
  580. var task = _sessionManager.OnPlaybackStopped(item, request.PositionTicks, GetSession().Id);
  581. Task.WaitAll(task);
  582. }
  583. /// <summary>
  584. /// Deletes the specified request.
  585. /// </summary>
  586. /// <param name="request">The request.</param>
  587. public object Delete(MarkUnplayedItem request)
  588. {
  589. var user = _userManager.GetUserById(request.UserId);
  590. var task = UpdatePlayedStatus(user, request.Id, false);
  591. return ToOptimizedResult(task.Result);
  592. }
  593. /// <summary>
  594. /// Updates the played status.
  595. /// </summary>
  596. /// <param name="user">The user.</param>
  597. /// <param name="itemId">The item id.</param>
  598. /// <param name="wasPlayed">if set to <c>true</c> [was played].</param>
  599. /// <returns>Task.</returns>
  600. private async Task<UserItemDataDto> UpdatePlayedStatus(User user, string itemId, bool wasPlayed)
  601. {
  602. var item = _dtoService.GetItemByDtoId(itemId, user.Id);
  603. await item.SetPlayedStatus(user, wasPlayed, _userDataRepository).ConfigureAwait(false);
  604. return _dtoService.GetUserItemDataDto(_userDataRepository.GetUserData(user.Id, item.GetUserDataKey()));
  605. }
  606. }
  607. }