UserLibraryService.cs 29 KB

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