UserLibraryService.cs 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763
  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. /// <summary>
  197. /// Class OnPlaybackStart
  198. /// </summary>
  199. [Route("/Users/{UserId}/PlayingItems/{Id}", "POST")]
  200. [Api(Description = "Reports that a user has begun playing an item")]
  201. public class OnPlaybackStart : IReturnVoid
  202. {
  203. /// <summary>
  204. /// Gets or sets the user id.
  205. /// </summary>
  206. /// <value>The user id.</value>
  207. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  208. public Guid UserId { get; set; }
  209. /// <summary>
  210. /// Gets or sets the id.
  211. /// </summary>
  212. /// <value>The id.</value>
  213. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  214. public string Id { get; set; }
  215. }
  216. /// <summary>
  217. /// Class OnPlaybackProgress
  218. /// </summary>
  219. [Route("/Users/{UserId}/PlayingItems/{Id}/Progress", "POST")]
  220. [Api(Description = "Reports a user's playback progress")]
  221. public class OnPlaybackProgress : IReturnVoid
  222. {
  223. /// <summary>
  224. /// Gets or sets the user id.
  225. /// </summary>
  226. /// <value>The user id.</value>
  227. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  228. public Guid UserId { get; set; }
  229. /// <summary>
  230. /// Gets or sets the id.
  231. /// </summary>
  232. /// <value>The id.</value>
  233. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  234. public string Id { get; set; }
  235. /// <summary>
  236. /// Gets or sets the position ticks.
  237. /// </summary>
  238. /// <value>The position ticks.</value>
  239. [ApiMember(Name = "PositionTicks", Description = "Optional. The current position, in ticks. 1 tick = 10000 ms", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "POST")]
  240. public long? PositionTicks { get; set; }
  241. }
  242. /// <summary>
  243. /// Class OnPlaybackStopped
  244. /// </summary>
  245. [Route("/Users/{UserId}/PlayingItems/{Id}", "DELETE")]
  246. [Api(Description = "Reports that a user has stopped playing an item")]
  247. public class OnPlaybackStopped : IReturnVoid
  248. {
  249. /// <summary>
  250. /// Gets or sets the user id.
  251. /// </summary>
  252. /// <value>The user id.</value>
  253. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  254. public Guid UserId { get; set; }
  255. /// <summary>
  256. /// Gets or sets the id.
  257. /// </summary>
  258. /// <value>The id.</value>
  259. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  260. public string Id { get; set; }
  261. /// <summary>
  262. /// Gets or sets the position ticks.
  263. /// </summary>
  264. /// <value>The position ticks.</value>
  265. [ApiMember(Name = "PositionTicks", Description = "Optional. The position, in ticks, where playback stopped. 1 tick = 10000 ms", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "DELETE")]
  266. public long? PositionTicks { get; set; }
  267. }
  268. /// <summary>
  269. /// Class GetLocalTrailers
  270. /// </summary>
  271. [Route("/Users/{UserId}/Items/{Id}/LocalTrailers", "GET")]
  272. [Api(Description = "Gets local trailers for an item")]
  273. public class GetLocalTrailers : IReturn<List<BaseItemDto>>
  274. {
  275. /// <summary>
  276. /// Gets or sets the user id.
  277. /// </summary>
  278. /// <value>The user id.</value>
  279. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  280. public Guid UserId { get; set; }
  281. /// <summary>
  282. /// Gets or sets the id.
  283. /// </summary>
  284. /// <value>The id.</value>
  285. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  286. public string Id { get; set; }
  287. }
  288. /// <summary>
  289. /// Class GetThemeSongs
  290. /// </summary>
  291. [Route("/Users/{UserId}/Items/{Id}/ThemeSongs", "GET")]
  292. [Api(Description = "Gets theme songs for an item")]
  293. public class GetThemeSongs : IReturn<ThemeSongsResult>
  294. {
  295. /// <summary>
  296. /// Gets or sets the user id.
  297. /// </summary>
  298. /// <value>The user id.</value>
  299. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  300. public Guid UserId { get; set; }
  301. /// <summary>
  302. /// Gets or sets the id.
  303. /// </summary>
  304. /// <value>The id.</value>
  305. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  306. public string Id { get; set; }
  307. }
  308. /// <summary>
  309. /// Class GetThemeVideos
  310. /// </summary>
  311. [Route("/Users/{UserId}/Items/{Id}/ThemeVideos", "GET")]
  312. [Api(Description = "Gets video backdrops for an item")]
  313. public class GetThemeVideos : IReturn<ThemeVideosResult>
  314. {
  315. /// <summary>
  316. /// Gets or sets the user id.
  317. /// </summary>
  318. /// <value>The user id.</value>
  319. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  320. public Guid UserId { get; set; }
  321. /// <summary>
  322. /// Gets or sets the id.
  323. /// </summary>
  324. /// <value>The id.</value>
  325. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  326. public string Id { get; set; }
  327. }
  328. /// <summary>
  329. /// Class GetSpecialFeatures
  330. /// </summary>
  331. [Route("/Users/{UserId}/Items/{Id}/SpecialFeatures", "GET")]
  332. [Api(Description = "Gets special features for a movie")]
  333. public class GetSpecialFeatures : IReturn<List<BaseItemDto>>
  334. {
  335. /// <summary>
  336. /// Gets or sets the user id.
  337. /// </summary>
  338. /// <value>The user id.</value>
  339. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  340. public Guid UserId { get; set; }
  341. /// <summary>
  342. /// Gets or sets the id.
  343. /// </summary>
  344. /// <value>The id.</value>
  345. [ApiMember(Name = "Id", Description = "Movie Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  346. public string Id { get; set; }
  347. }
  348. /// <summary>
  349. /// Class UserLibraryService
  350. /// </summary>
  351. public class UserLibraryService : BaseApiService
  352. {
  353. /// <summary>
  354. /// The _user manager
  355. /// </summary>
  356. private readonly IUserManager _userManager;
  357. /// <summary>
  358. /// The _user data repository
  359. /// </summary>
  360. private readonly IUserDataRepository _userDataRepository;
  361. /// <summary>
  362. /// The _library manager
  363. /// </summary>
  364. private readonly ILibraryManager _libraryManager;
  365. /// <summary>
  366. /// Initializes a new instance of the <see cref="UserLibraryService" /> class.
  367. /// </summary>
  368. /// <param name="userManager">The user manager.</param>
  369. /// <param name="libraryManager">The library manager.</param>
  370. /// <param name="userDataRepository">The user data repository.</param>
  371. /// <exception cref="System.ArgumentNullException">jsonSerializer</exception>
  372. public UserLibraryService(IUserManager userManager, ILibraryManager libraryManager, IUserDataRepository userDataRepository)
  373. : base()
  374. {
  375. _userManager = userManager;
  376. _libraryManager = libraryManager;
  377. _userDataRepository = userDataRepository;
  378. }
  379. /// <summary>
  380. /// Gets the specified request.
  381. /// </summary>
  382. /// <param name="request">The request.</param>
  383. /// <returns>System.Object.</returns>
  384. public object Get(GetSpecialFeatures request)
  385. {
  386. var user = _userManager.GetUserById(request.UserId);
  387. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  388. // Get everything
  389. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  390. var movie = (Movie)item;
  391. var dtoBuilder = new DtoBuilder(Logger, _libraryManager, _userDataRepository);
  392. var items = movie.SpecialFeatures.Select(i => dtoBuilder.GetBaseItemDto(i, user, fields)).AsParallel().Select(t => t.Result).ToList();
  393. return ToOptimizedResult(items);
  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(GetLocalTrailers 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);
  407. var items = item.LocalTrailers.Select(i => dtoBuilder.GetBaseItemDto(i, user, fields)).AsParallel().Select(t => t.Result).ToList();
  408. return ToOptimizedResult(items);
  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(GetThemeSongs request)
  416. {
  417. var user = _userManager.GetUserById(request.UserId);
  418. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  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);
  422. var items = item.ThemeSongs.Select(i => dtoBuilder.GetBaseItemDto(i, user, fields)).AsParallel().Select(t => t.Result).ToArray();
  423. var result = new ThemeSongsResult
  424. {
  425. Items = items,
  426. TotalRecordCount = items.Length,
  427. OwnerId = DtoBuilder.GetClientItemId(item)
  428. };
  429. return ToOptimizedResult(result);
  430. }
  431. /// <summary>
  432. /// Gets the specified request.
  433. /// </summary>
  434. /// <param name="request">The request.</param>
  435. /// <returns>System.Object.</returns>
  436. public object Get(GetThemeVideos request)
  437. {
  438. var user = _userManager.GetUserById(request.UserId);
  439. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  440. // Get everything
  441. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  442. var dtoBuilder = new DtoBuilder(Logger, _libraryManager, _userDataRepository);
  443. var items = item.ThemeVideos.Select(i => dtoBuilder.GetBaseItemDto(i, user, fields)).AsParallel().Select(t => t.Result).ToArray();
  444. var result = new ThemeVideosResult
  445. {
  446. Items = items,
  447. TotalRecordCount = items.Length,
  448. OwnerId = DtoBuilder.GetClientItemId(item)
  449. };
  450. return ToOptimizedResult(result);
  451. }
  452. /// <summary>
  453. /// Gets the specified request.
  454. /// </summary>
  455. /// <param name="request">The request.</param>
  456. /// <returns>System.Object.</returns>
  457. public object Get(GetItem 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. // Get everything
  462. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  463. var dtoBuilder = new DtoBuilder(Logger, _libraryManager, _userDataRepository);
  464. var result = dtoBuilder.GetBaseItemDto(item, user, fields).Result;
  465. return ToOptimizedResult(result);
  466. }
  467. /// <summary>
  468. /// Gets the specified request.
  469. /// </summary>
  470. /// <param name="request">The request.</param>
  471. /// <returns>System.Object.</returns>
  472. public object Get(GetRootFolder request)
  473. {
  474. var user = _userManager.GetUserById(request.UserId);
  475. var item = user.RootFolder;
  476. // Get everything
  477. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  478. var dtoBuilder = new DtoBuilder(Logger, _libraryManager, _userDataRepository);
  479. var result = dtoBuilder.GetBaseItemDto(item, user, fields).Result;
  480. return ToOptimizedResult(result);
  481. }
  482. /// <summary>
  483. /// Gets the specified request.
  484. /// </summary>
  485. /// <param name="request">The request.</param>
  486. /// <returns>System.Object.</returns>
  487. public object Get(GetIntros request)
  488. {
  489. var user = _userManager.GetUserById(request.UserId);
  490. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  491. var result = _libraryManager.GetIntros(item, user);
  492. return ToOptimizedResult(result);
  493. }
  494. /// <summary>
  495. /// Posts the specified request.
  496. /// </summary>
  497. /// <param name="request">The request.</param>
  498. public void Post(MarkFavoriteItem request)
  499. {
  500. var user = _userManager.GetUserById(request.UserId);
  501. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  502. // Get the user data for this item
  503. var key = item.GetUserDataKey();
  504. var data = _userDataRepository.GetUserData(user.Id, key).Result;
  505. // Set favorite status
  506. data.IsFavorite = true;
  507. var task = _userDataRepository.SaveUserData(user.Id, key, data, CancellationToken.None);
  508. Task.WaitAll(task);
  509. }
  510. /// <summary>
  511. /// Deletes the specified request.
  512. /// </summary>
  513. /// <param name="request">The request.</param>
  514. public void Delete(UnmarkFavoriteItem request)
  515. {
  516. var user = _userManager.GetUserById(request.UserId);
  517. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  518. var key = item.GetUserDataKey();
  519. // Get the user data for this item
  520. var data = _userDataRepository.GetUserData(user.Id, key).Result;
  521. // Set favorite status
  522. data.IsFavorite = false;
  523. var task = _userDataRepository.SaveUserData(user.Id, key, data, CancellationToken.None);
  524. Task.WaitAll(task);
  525. }
  526. /// <summary>
  527. /// Deletes the specified request.
  528. /// </summary>
  529. /// <param name="request">The request.</param>
  530. public void Delete(DeleteUserItemRating request)
  531. {
  532. var user = _userManager.GetUserById(request.UserId);
  533. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  534. var key = item.GetUserDataKey();
  535. // Get the user data for this item
  536. var data = _userDataRepository.GetUserData(user.Id, key).Result;
  537. data.Rating = null;
  538. var task = _userDataRepository.SaveUserData(user.Id, key, data, CancellationToken.None);
  539. Task.WaitAll(task);
  540. }
  541. /// <summary>
  542. /// Posts the specified request.
  543. /// </summary>
  544. /// <param name="request">The request.</param>
  545. public void Post(UpdateUserItemRating request)
  546. {
  547. var user = _userManager.GetUserById(request.UserId);
  548. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  549. var key = item.GetUserDataKey();
  550. // Get the user data for this item
  551. var data = _userDataRepository.GetUserData(user.Id, key).Result;
  552. data.Likes = request.Likes;
  553. var task = _userDataRepository.SaveUserData(user.Id, key, data, CancellationToken.None);
  554. Task.WaitAll(task);
  555. }
  556. /// <summary>
  557. /// Posts the specified request.
  558. /// </summary>
  559. /// <param name="request">The request.</param>
  560. public void Post(MarkPlayedItem request)
  561. {
  562. var user = _userManager.GetUserById(request.UserId);
  563. var task = UpdatePlayedStatus(user, request.Id, true);
  564. Task.WaitAll(task);
  565. }
  566. /// <summary>
  567. /// Posts the specified request.
  568. /// </summary>
  569. /// <param name="request">The request.</param>
  570. public void Post(OnPlaybackStart request)
  571. {
  572. var user = _userManager.GetUserById(request.UserId);
  573. var item = DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  574. var auth = RequestFilterAttribute.GetAuthorization(RequestContext);
  575. if (auth != null)
  576. {
  577. _userManager.OnPlaybackStart(user, item, auth["Client"], auth["DeviceId"], auth["Device"] ?? string.Empty);
  578. }
  579. }
  580. /// <summary>
  581. /// Posts the specified request.
  582. /// </summary>
  583. /// <param name="request">The request.</param>
  584. public void Post(OnPlaybackProgress request)
  585. {
  586. var user = _userManager.GetUserById(request.UserId);
  587. var item = DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  588. var auth = RequestFilterAttribute.GetAuthorization(RequestContext);
  589. if (auth != null)
  590. {
  591. var task = _userManager.OnPlaybackProgress(user, item, request.PositionTicks, auth["Client"], auth["DeviceId"], auth["Device"] ?? string.Empty);
  592. Task.WaitAll(task);
  593. }
  594. }
  595. /// <summary>
  596. /// Posts the specified request.
  597. /// </summary>
  598. /// <param name="request">The request.</param>
  599. public void Delete(OnPlaybackStopped request)
  600. {
  601. var user = _userManager.GetUserById(request.UserId);
  602. var item = DtoBuilder.GetItemByClientId(request.Id, _userManager, _libraryManager, user.Id);
  603. var auth = RequestFilterAttribute.GetAuthorization(RequestContext);
  604. if (auth != null)
  605. {
  606. var task = _userManager.OnPlaybackStopped(user, item, request.PositionTicks, auth["Client"], auth["DeviceId"], auth["Device"] ?? string.Empty);
  607. Task.WaitAll(task);
  608. }
  609. }
  610. /// <summary>
  611. /// Deletes the specified request.
  612. /// </summary>
  613. /// <param name="request">The request.</param>
  614. public void Delete(MarkUnplayedItem request)
  615. {
  616. var user = _userManager.GetUserById(request.UserId);
  617. var task = UpdatePlayedStatus(user, request.Id, false);
  618. Task.WaitAll(task);
  619. }
  620. /// <summary>
  621. /// Updates the played status.
  622. /// </summary>
  623. /// <param name="user">The user.</param>
  624. /// <param name="itemId">The item id.</param>
  625. /// <param name="wasPlayed">if set to <c>true</c> [was played].</param>
  626. /// <returns>Task.</returns>
  627. private Task UpdatePlayedStatus(User user, string itemId, bool wasPlayed)
  628. {
  629. var item = DtoBuilder.GetItemByClientId(itemId, _userManager, _libraryManager, user.Id);
  630. return item.SetPlayedStatus(user, wasPlayed, _userDataRepository);
  631. }
  632. }
  633. }