UserLibraryService.cs 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942
  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.Net;
  7. using MediaBrowser.Controller.Session;
  8. using MediaBrowser.Model.Dto;
  9. using MediaBrowser.Model.Entities;
  10. using MediaBrowser.Model.Library;
  11. using MediaBrowser.Model.Querying;
  12. using MediaBrowser.Model.Session;
  13. using ServiceStack;
  14. using System;
  15. using System.Collections.Generic;
  16. using System.Globalization;
  17. using System.Linq;
  18. using System.Threading;
  19. using System.Threading.Tasks;
  20. namespace MediaBrowser.Api.UserLibrary
  21. {
  22. /// <summary>
  23. /// Class GetItem
  24. /// </summary>
  25. [Route("/Users/{UserId}/Items/{Id}", "GET")]
  26. [Api(Description = "Gets an item from a user's library")]
  27. public class GetItem : IReturn<BaseItemDto>
  28. {
  29. /// <summary>
  30. /// Gets or sets the user id.
  31. /// </summary>
  32. /// <value>The user id.</value>
  33. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  34. public Guid UserId { get; set; }
  35. /// <summary>
  36. /// Gets or sets the id.
  37. /// </summary>
  38. /// <value>The id.</value>
  39. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  40. public string Id { get; set; }
  41. }
  42. [Route("/Users/{UserId}/Views", "GET")]
  43. public class GetUserViews : IReturn<QueryResult<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 string UserId { get; set; }
  51. [ApiMember(Name = "IncludeExternalContent", Description = "Whether or not to include external views such as channels or live tv", IsRequired = true, DataType = "boolean", ParameterType = "query", Verb = "POST")]
  52. public bool? IncludeExternalContent { get; set; }
  53. }
  54. /// <summary>
  55. /// Class GetItem
  56. /// </summary>
  57. [Route("/Users/{UserId}/Items/Root", "GET")]
  58. [Api(Description = "Gets the root folder from a user's library")]
  59. public class GetRootFolder : IReturn<BaseItemDto>
  60. {
  61. /// <summary>
  62. /// Gets or sets the user id.
  63. /// </summary>
  64. /// <value>The user id.</value>
  65. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  66. public Guid UserId { get; set; }
  67. }
  68. /// <summary>
  69. /// Class GetIntros
  70. /// </summary>
  71. [Route("/Users/{UserId}/Items/{Id}/Intros", "GET")]
  72. [Api(("Gets intros to play before the main media item plays"))]
  73. public class GetIntros : IReturn<ItemsResult>
  74. {
  75. /// <summary>
  76. /// Gets or sets the user id.
  77. /// </summary>
  78. /// <value>The user id.</value>
  79. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  80. public Guid UserId { get; set; }
  81. /// <summary>
  82. /// Gets or sets the item id.
  83. /// </summary>
  84. /// <value>The item id.</value>
  85. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  86. public string Id { get; set; }
  87. }
  88. /// <summary>
  89. /// Class MarkFavoriteItem
  90. /// </summary>
  91. [Route("/Users/{UserId}/FavoriteItems/{Id}", "POST")]
  92. [Api(Description = "Marks an item as a favorite")]
  93. public class MarkFavoriteItem : IReturn<UserItemDataDto>
  94. {
  95. /// <summary>
  96. /// Gets or sets the user id.
  97. /// </summary>
  98. /// <value>The user id.</value>
  99. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  100. public Guid UserId { get; set; }
  101. /// <summary>
  102. /// Gets or sets the id.
  103. /// </summary>
  104. /// <value>The id.</value>
  105. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  106. public string Id { get; set; }
  107. }
  108. /// <summary>
  109. /// Class UnmarkFavoriteItem
  110. /// </summary>
  111. [Route("/Users/{UserId}/FavoriteItems/{Id}", "DELETE")]
  112. [Api(Description = "Unmarks an item as a favorite")]
  113. public class UnmarkFavoriteItem : IReturn<UserItemDataDto>
  114. {
  115. /// <summary>
  116. /// Gets or sets the user id.
  117. /// </summary>
  118. /// <value>The user id.</value>
  119. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  120. public Guid UserId { get; set; }
  121. /// <summary>
  122. /// Gets or sets the id.
  123. /// </summary>
  124. /// <value>The id.</value>
  125. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  126. public string Id { get; set; }
  127. }
  128. /// <summary>
  129. /// Class ClearUserItemRating
  130. /// </summary>
  131. [Route("/Users/{UserId}/Items/{Id}/Rating", "DELETE")]
  132. [Api(Description = "Deletes a user's saved personal rating for an item")]
  133. public class DeleteUserItemRating : IReturn<UserItemDataDto>
  134. {
  135. /// <summary>
  136. /// Gets or sets the user id.
  137. /// </summary>
  138. /// <value>The user id.</value>
  139. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  140. public Guid UserId { get; set; }
  141. /// <summary>
  142. /// Gets or sets the id.
  143. /// </summary>
  144. /// <value>The id.</value>
  145. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  146. public string Id { get; set; }
  147. }
  148. /// <summary>
  149. /// Class UpdateUserItemRating
  150. /// </summary>
  151. [Route("/Users/{UserId}/Items/{Id}/Rating", "POST")]
  152. [Api(Description = "Updates a user's rating for an item")]
  153. public class UpdateUserItemRating : IReturn<UserItemDataDto>
  154. {
  155. /// <summary>
  156. /// Gets or sets the user id.
  157. /// </summary>
  158. /// <value>The user id.</value>
  159. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  160. public Guid UserId { get; set; }
  161. /// <summary>
  162. /// Gets or sets the id.
  163. /// </summary>
  164. /// <value>The id.</value>
  165. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  166. public string Id { get; set; }
  167. /// <summary>
  168. /// Gets or sets a value indicating whether this <see cref="UpdateUserItemRating" /> is likes.
  169. /// </summary>
  170. /// <value><c>true</c> if likes; otherwise, <c>false</c>.</value>
  171. [ApiMember(Name = "Likes", Description = "Whether the user likes the item or not. true/false", IsRequired = true, DataType = "boolean", ParameterType = "query", Verb = "POST")]
  172. public bool Likes { get; set; }
  173. }
  174. /// <summary>
  175. /// Class MarkPlayedItem
  176. /// </summary>
  177. [Route("/Users/{UserId}/PlayedItems/{Id}", "POST")]
  178. [Api(Description = "Marks an item as played")]
  179. public class MarkPlayedItem : IReturn<UserItemDataDto>
  180. {
  181. /// <summary>
  182. /// Gets or sets the user id.
  183. /// </summary>
  184. /// <value>The user id.</value>
  185. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  186. public Guid UserId { get; set; }
  187. [ApiMember(Name = "DatePlayed", Description = "The date the item was played (if any). Format = yyyyMMddHHmmss", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "POST")]
  188. public string DatePlayed { 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 = "POST")]
  194. public string Id { get; set; }
  195. }
  196. /// <summary>
  197. /// Class MarkUnplayedItem
  198. /// </summary>
  199. [Route("/Users/{UserId}/PlayedItems/{Id}", "DELETE")]
  200. [Api(Description = "Marks an item as unplayed")]
  201. public class MarkUnplayedItem : IReturn<UserItemDataDto>
  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 = "DELETE")]
  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 = "DELETE")]
  214. public string Id { get; set; }
  215. }
  216. [Route("/Sessions/Playing", "POST")]
  217. [Api(Description = "Reports playback has started within a session")]
  218. public class ReportPlaybackStart : PlaybackStartInfo, IReturnVoid
  219. {
  220. }
  221. [Route("/Sessions/Playing/Progress", "POST")]
  222. [Api(Description = "Reports playback progress within a session")]
  223. public class ReportPlaybackProgress : PlaybackProgressInfo, IReturnVoid
  224. {
  225. }
  226. [Route("/Sessions/Playing/Stopped", "POST")]
  227. [Api(Description = "Reports playback has stopped within a session")]
  228. public class ReportPlaybackStopped : PlaybackStopInfo, IReturnVoid
  229. {
  230. }
  231. /// <summary>
  232. /// Class OnPlaybackStart
  233. /// </summary>
  234. [Route("/Users/{UserId}/PlayingItems/{Id}", "POST")]
  235. [Api(Description = "Reports that a user has begun playing an item")]
  236. public class OnPlaybackStart : IReturnVoid
  237. {
  238. /// <summary>
  239. /// Gets or sets the user id.
  240. /// </summary>
  241. /// <value>The user id.</value>
  242. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  243. public Guid UserId { get; set; }
  244. /// <summary>
  245. /// Gets or sets the id.
  246. /// </summary>
  247. /// <value>The id.</value>
  248. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
  249. public string Id { get; set; }
  250. [ApiMember(Name = "MediaSourceId", Description = "The id of the MediaSource", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "POST")]
  251. public string MediaSourceId { get; set; }
  252. /// <summary>
  253. /// Gets or sets a value indicating whether this <see cref="UpdateUserItemRating" /> is likes.
  254. /// </summary>
  255. /// <value><c>true</c> if likes; otherwise, <c>false</c>.</value>
  256. [ApiMember(Name = "CanSeek", Description = "Indicates if the client can seek", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "POST")]
  257. public bool CanSeek { get; set; }
  258. /// <summary>
  259. /// Gets or sets the id.
  260. /// </summary>
  261. /// <value>The id.</value>
  262. [ApiMember(Name = "QueueableMediaTypes", Description = "A list of media types that can be queued from this item, comma delimited. Audio,Video,Book,Game", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "POST", AllowMultiple = true)]
  263. public string QueueableMediaTypes { get; set; }
  264. [ApiMember(Name = "AudioStreamIndex", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "POST")]
  265. public int? AudioStreamIndex { get; set; }
  266. [ApiMember(Name = "SubtitleStreamIndex", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "POST")]
  267. public int? SubtitleStreamIndex { get; set; }
  268. }
  269. /// <summary>
  270. /// Class OnPlaybackProgress
  271. /// </summary>
  272. [Route("/Users/{UserId}/PlayingItems/{Id}/Progress", "POST")]
  273. [Api(Description = "Reports a user's playback progress")]
  274. public class OnPlaybackProgress : IReturnVoid
  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 = "POST")]
  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 = "POST")]
  287. public string Id { get; set; }
  288. [ApiMember(Name = "MediaSourceId", Description = "The id of the MediaSource", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "POST")]
  289. public string MediaSourceId { get; set; }
  290. /// <summary>
  291. /// Gets or sets the position ticks.
  292. /// </summary>
  293. /// <value>The position ticks.</value>
  294. [ApiMember(Name = "PositionTicks", Description = "Optional. The current position, in ticks. 1 tick = 10000 ms", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "POST")]
  295. public long? PositionTicks { get; set; }
  296. [ApiMember(Name = "IsPaused", Description = "Indicates if the player is paused.", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "POST")]
  297. public bool IsPaused { get; set; }
  298. [ApiMember(Name = "IsMuted", Description = "Indicates if the player is muted.", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "POST")]
  299. public bool IsMuted { get; set; }
  300. [ApiMember(Name = "AudioStreamIndex", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "POST")]
  301. public int? AudioStreamIndex { get; set; }
  302. [ApiMember(Name = "SubtitleStreamIndex", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "POST")]
  303. public int? SubtitleStreamIndex { get; set; }
  304. [ApiMember(Name = "VolumeLevel", Description = "Scale of 0-100", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "POST")]
  305. public int? VolumeLevel { get; set; }
  306. }
  307. /// <summary>
  308. /// Class OnPlaybackStopped
  309. /// </summary>
  310. [Route("/Users/{UserId}/PlayingItems/{Id}", "DELETE")]
  311. [Api(Description = "Reports that a user has stopped playing an item")]
  312. public class OnPlaybackStopped : IReturnVoid
  313. {
  314. /// <summary>
  315. /// Gets or sets the user id.
  316. /// </summary>
  317. /// <value>The user id.</value>
  318. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  319. public Guid UserId { get; set; }
  320. /// <summary>
  321. /// Gets or sets the id.
  322. /// </summary>
  323. /// <value>The id.</value>
  324. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
  325. public string Id { get; set; }
  326. [ApiMember(Name = "MediaSourceId", Description = "The id of the MediaSource", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "DELETE")]
  327. public string MediaSourceId { get; set; }
  328. /// <summary>
  329. /// Gets or sets the position ticks.
  330. /// </summary>
  331. /// <value>The position ticks.</value>
  332. [ApiMember(Name = "PositionTicks", Description = "Optional. The position, in ticks, where playback stopped. 1 tick = 10000 ms", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "DELETE")]
  333. public long? PositionTicks { get; set; }
  334. }
  335. /// <summary>
  336. /// Class GetLocalTrailers
  337. /// </summary>
  338. [Route("/Users/{UserId}/Items/{Id}/LocalTrailers", "GET")]
  339. [Api(Description = "Gets local trailers for an item")]
  340. public class GetLocalTrailers : IReturn<List<BaseItemDto>>
  341. {
  342. /// <summary>
  343. /// Gets or sets the user id.
  344. /// </summary>
  345. /// <value>The user id.</value>
  346. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  347. public Guid UserId { get; set; }
  348. /// <summary>
  349. /// Gets or sets the id.
  350. /// </summary>
  351. /// <value>The id.</value>
  352. [ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  353. public string Id { get; set; }
  354. }
  355. /// <summary>
  356. /// Class GetSpecialFeatures
  357. /// </summary>
  358. [Route("/Users/{UserId}/Items/{Id}/SpecialFeatures", "GET")]
  359. [Api(Description = "Gets special features for an item")]
  360. public class GetSpecialFeatures : IReturn<List<BaseItemDto>>
  361. {
  362. /// <summary>
  363. /// Gets or sets the user id.
  364. /// </summary>
  365. /// <value>The user id.</value>
  366. [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  367. public Guid UserId { get; set; }
  368. /// <summary>
  369. /// Gets or sets the id.
  370. /// </summary>
  371. /// <value>The id.</value>
  372. [ApiMember(Name = "Id", Description = "Movie Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  373. public string Id { get; set; }
  374. }
  375. /// <summary>
  376. /// Class UserLibraryService
  377. /// </summary>
  378. [Authenticated]
  379. public class UserLibraryService : BaseApiService
  380. {
  381. /// <summary>
  382. /// The _user manager
  383. /// </summary>
  384. private readonly IUserManager _userManager;
  385. /// <summary>
  386. /// The _user data repository
  387. /// </summary>
  388. private readonly IUserDataManager _userDataRepository;
  389. /// <summary>
  390. /// The _library manager
  391. /// </summary>
  392. private readonly ILibraryManager _libraryManager;
  393. private readonly ISessionManager _sessionManager;
  394. private readonly IDtoService _dtoService;
  395. private readonly IUserViewManager _userViewManager;
  396. /// <summary>
  397. /// Initializes a new instance of the <see cref="UserLibraryService" /> class.
  398. /// </summary>
  399. /// <param name="userManager">The user manager.</param>
  400. /// <param name="libraryManager">The library manager.</param>
  401. /// <param name="userDataRepository">The user data repository.</param>
  402. /// <param name="sessionManager">The session manager.</param>
  403. /// <param name="dtoService">The dto service.</param>
  404. /// <exception cref="System.ArgumentNullException">jsonSerializer</exception>
  405. public UserLibraryService(IUserManager userManager, ILibraryManager libraryManager, IUserDataManager userDataRepository, ISessionManager sessionManager, IDtoService dtoService, IUserViewManager userViewManager)
  406. {
  407. _userManager = userManager;
  408. _libraryManager = libraryManager;
  409. _userDataRepository = userDataRepository;
  410. _sessionManager = sessionManager;
  411. _dtoService = dtoService;
  412. _userViewManager = userViewManager;
  413. }
  414. /// <summary>
  415. /// Gets the specified request.
  416. /// </summary>
  417. /// <param name="request">The request.</param>
  418. /// <returns>System.Object.</returns>
  419. public object Get(GetSpecialFeatures request)
  420. {
  421. var result = GetAsync(request);
  422. return ToOptimizedSerializedResultUsingCache(result);
  423. }
  424. public object Get(GetUserViews request)
  425. {
  426. var user = _userManager.GetUserById(new Guid(request.UserId));
  427. // Get everything
  428. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  429. var query = new UserViewQuery
  430. {
  431. UserId = request.UserId
  432. };
  433. if (request.IncludeExternalContent.HasValue)
  434. {
  435. query.IncludeExternalContent = request.IncludeExternalContent.Value;
  436. }
  437. var folders = _userViewManager.GetUserViews(query, CancellationToken.None).Result;
  438. var dtos = folders.OrderBy(i => i.SortName)
  439. .Select(i => _dtoService.GetBaseItemDto(i, fields, user))
  440. .ToArray();
  441. var result = new QueryResult<BaseItemDto>
  442. {
  443. Items = dtos,
  444. TotalRecordCount = dtos.Length
  445. };
  446. return ToOptimizedResult(result);
  447. }
  448. private List<BaseItemDto> GetAsync(GetSpecialFeatures request)
  449. {
  450. var user = _userManager.GetUserById(request.UserId);
  451. var item = string.IsNullOrEmpty(request.Id) ?
  452. user.RootFolder :
  453. _libraryManager.GetItemById(request.Id);
  454. // Get everything
  455. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  456. var movie = item as Movie;
  457. // Get them from the db
  458. if (movie != null)
  459. {
  460. // Avoid implicitly captured closure
  461. var movie1 = movie;
  462. var dtos = movie.SpecialFeatureIds
  463. .Select(_libraryManager.GetItemById)
  464. .OrderBy(i => i.SortName)
  465. .Select(i => _dtoService.GetBaseItemDto(i, fields, user, movie1));
  466. return dtos.ToList();
  467. }
  468. var series = item as Series;
  469. // Get them from the child tree
  470. if (series != null)
  471. {
  472. var dtos = series
  473. .GetRecursiveChildren()
  474. .Where(i => i is Episode && i.ParentIndexNumber.HasValue && i.ParentIndexNumber.Value == 0)
  475. .OrderBy(i =>
  476. {
  477. if (i.PremiereDate.HasValue)
  478. {
  479. return i.PremiereDate.Value;
  480. }
  481. if (i.ProductionYear.HasValue)
  482. {
  483. return new DateTime(i.ProductionYear.Value, 1, 1, 0, 0, 0, DateTimeKind.Utc);
  484. }
  485. return DateTime.MinValue;
  486. })
  487. .ThenBy(i => i.SortName)
  488. .Select(i => _dtoService.GetBaseItemDto(i, fields, user));
  489. return dtos.ToList();
  490. }
  491. return new List<BaseItemDto>();
  492. }
  493. /// <summary>
  494. /// Gets the specified request.
  495. /// </summary>
  496. /// <param name="request">The request.</param>
  497. /// <returns>System.Object.</returns>
  498. public object Get(GetLocalTrailers request)
  499. {
  500. var result = GetAsync(request);
  501. return ToOptimizedSerializedResultUsingCache(result);
  502. }
  503. private List<BaseItemDto> GetAsync(GetLocalTrailers request)
  504. {
  505. var user = _userManager.GetUserById(request.UserId);
  506. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : _libraryManager.GetItemById(request.Id);
  507. // Get everything
  508. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  509. var trailerIds = new List<Guid>();
  510. var hasTrailers = item as IHasTrailers;
  511. if (hasTrailers != null)
  512. {
  513. trailerIds = hasTrailers.LocalTrailerIds;
  514. }
  515. var dtos = trailerIds
  516. .Select(_libraryManager.GetItemById)
  517. .OrderBy(i => i.SortName)
  518. .Select(i => _dtoService.GetBaseItemDto(i, fields, user, item));
  519. return dtos.ToList();
  520. }
  521. /// <summary>
  522. /// Gets the specified request.
  523. /// </summary>
  524. /// <param name="request">The request.</param>
  525. /// <returns>System.Object.</returns>
  526. public object Get(GetItem request)
  527. {
  528. var user = _userManager.GetUserById(request.UserId);
  529. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : _libraryManager.GetItemById(request.Id);
  530. // Get everything
  531. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  532. var result = _dtoService.GetBaseItemDto(item, fields, user);
  533. return ToOptimizedSerializedResultUsingCache(result);
  534. }
  535. /// <summary>
  536. /// Gets the specified request.
  537. /// </summary>
  538. /// <param name="request">The request.</param>
  539. /// <returns>System.Object.</returns>
  540. public object Get(GetRootFolder request)
  541. {
  542. var user = _userManager.GetUserById(request.UserId);
  543. var item = user.RootFolder;
  544. // Get everything
  545. var fields = Enum.GetNames(typeof(ItemFields)).Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true)).ToList();
  546. var result = _dtoService.GetBaseItemDto(item, fields, user);
  547. return ToOptimizedSerializedResultUsingCache(result);
  548. }
  549. /// <summary>
  550. /// Gets the specified request.
  551. /// </summary>
  552. /// <param name="request">The request.</param>
  553. /// <returns>System.Object.</returns>
  554. public object Get(GetIntros request)
  555. {
  556. var user = _userManager.GetUserById(request.UserId);
  557. var item = string.IsNullOrEmpty(request.Id) ? user.RootFolder : _libraryManager.GetItemById(request.Id);
  558. var items = _libraryManager.GetIntros(item, user);
  559. // Get everything
  560. var fields = Enum.GetNames(typeof(ItemFields))
  561. .Select(i => (ItemFields)Enum.Parse(typeof(ItemFields), i, true))
  562. .ToList();
  563. var dtos = items.Select(i => _dtoService.GetBaseItemDto(i, fields, user))
  564. .ToArray();
  565. var result = new ItemsResult
  566. {
  567. Items = dtos,
  568. TotalRecordCount = dtos.Length
  569. };
  570. return ToOptimizedSerializedResultUsingCache(result);
  571. }
  572. /// <summary>
  573. /// Posts the specified request.
  574. /// </summary>
  575. /// <param name="request">The request.</param>
  576. public object Post(MarkFavoriteItem request)
  577. {
  578. var dto = MarkFavorite(request.UserId, request.Id, true).Result;
  579. return ToOptimizedResult(dto);
  580. }
  581. /// <summary>
  582. /// Deletes the specified request.
  583. /// </summary>
  584. /// <param name="request">The request.</param>
  585. public object Delete(UnmarkFavoriteItem request)
  586. {
  587. var dto = MarkFavorite(request.UserId, request.Id, false).Result;
  588. return ToOptimizedResult(dto);
  589. }
  590. /// <summary>
  591. /// Marks the favorite.
  592. /// </summary>
  593. /// <param name="userId">The user id.</param>
  594. /// <param name="itemId">The item id.</param>
  595. /// <param name="isFavorite">if set to <c>true</c> [is favorite].</param>
  596. /// <returns>Task{UserItemDataDto}.</returns>
  597. private async Task<UserItemDataDto> MarkFavorite(Guid userId, string itemId, bool isFavorite)
  598. {
  599. var user = _userManager.GetUserById(userId);
  600. var item = string.IsNullOrEmpty(itemId) ? user.RootFolder : _libraryManager.GetItemById(itemId);
  601. var key = item.GetUserDataKey();
  602. // Get the user data for this item
  603. var data = _userDataRepository.GetUserData(user.Id, key);
  604. // Set favorite status
  605. data.IsFavorite = isFavorite;
  606. await _userDataRepository.SaveUserData(user.Id, item, data, UserDataSaveReason.UpdateUserRating, CancellationToken.None).ConfigureAwait(false);
  607. data = _userDataRepository.GetUserData(user.Id, key);
  608. return _dtoService.GetUserItemDataDto(data);
  609. }
  610. /// <summary>
  611. /// Deletes the specified request.
  612. /// </summary>
  613. /// <param name="request">The request.</param>
  614. public object Delete(DeleteUserItemRating request)
  615. {
  616. var dto = UpdateUserItemRating(request.UserId, request.Id, null).Result;
  617. return ToOptimizedResult(dto);
  618. }
  619. /// <summary>
  620. /// Posts the specified request.
  621. /// </summary>
  622. /// <param name="request">The request.</param>
  623. public object Post(UpdateUserItemRating request)
  624. {
  625. var dto = UpdateUserItemRating(request.UserId, request.Id, request.Likes).Result;
  626. return ToOptimizedResult(dto);
  627. }
  628. /// <summary>
  629. /// Updates the user item rating.
  630. /// </summary>
  631. /// <param name="userId">The user id.</param>
  632. /// <param name="itemId">The item id.</param>
  633. /// <param name="likes">if set to <c>true</c> [likes].</param>
  634. /// <returns>Task{UserItemDataDto}.</returns>
  635. private async Task<UserItemDataDto> UpdateUserItemRating(Guid userId, string itemId, bool? likes)
  636. {
  637. var user = _userManager.GetUserById(userId);
  638. var item = string.IsNullOrEmpty(itemId) ? user.RootFolder : _libraryManager.GetItemById(itemId);
  639. var key = item.GetUserDataKey();
  640. // Get the user data for this item
  641. var data = _userDataRepository.GetUserData(user.Id, key);
  642. data.Likes = likes;
  643. await _userDataRepository.SaveUserData(user.Id, item, data, UserDataSaveReason.UpdateUserRating, CancellationToken.None).ConfigureAwait(false);
  644. data = _userDataRepository.GetUserData(user.Id, key);
  645. return _dtoService.GetUserItemDataDto(data);
  646. }
  647. /// <summary>
  648. /// Posts the specified request.
  649. /// </summary>
  650. /// <param name="request">The request.</param>
  651. public object Post(MarkPlayedItem request)
  652. {
  653. var result = MarkPlayed(request).Result;
  654. return ToOptimizedResult(result);
  655. }
  656. private async Task<UserItemDataDto> MarkPlayed(MarkPlayedItem request)
  657. {
  658. var user = _userManager.GetUserById(request.UserId);
  659. DateTime? datePlayed = null;
  660. if (!string.IsNullOrEmpty(request.DatePlayed))
  661. {
  662. datePlayed = DateTime.ParseExact(request.DatePlayed, "yyyyMMddHHmmss", CultureInfo.InvariantCulture, DateTimeStyles.AssumeUniversal);
  663. }
  664. var session = GetSession();
  665. var dto = await UpdatePlayedStatus(user, request.Id, true, datePlayed).ConfigureAwait(false);
  666. foreach (var additionalUserInfo in session.AdditionalUsers)
  667. {
  668. var additionalUser = _userManager.GetUserById(new Guid(additionalUserInfo.UserId));
  669. await UpdatePlayedStatus(additionalUser, request.Id, true, datePlayed).ConfigureAwait(false);
  670. }
  671. return dto;
  672. }
  673. /// <summary>
  674. /// Posts the specified request.
  675. /// </summary>
  676. /// <param name="request">The request.</param>
  677. public void Post(OnPlaybackStart request)
  678. {
  679. var queueableMediaTypes = (request.QueueableMediaTypes ?? string.Empty);
  680. Post(new ReportPlaybackStart
  681. {
  682. CanSeek = request.CanSeek,
  683. ItemId = request.Id,
  684. QueueableMediaTypes = queueableMediaTypes.Split(',').ToList(),
  685. MediaSourceId = request.MediaSourceId,
  686. AudioStreamIndex = request.AudioStreamIndex,
  687. SubtitleStreamIndex = request.SubtitleStreamIndex
  688. });
  689. }
  690. public void Post(ReportPlaybackStart request)
  691. {
  692. request.SessionId = GetSession().Id;
  693. var task = _sessionManager.OnPlaybackStart(request);
  694. Task.WaitAll(task);
  695. }
  696. /// <summary>
  697. /// Posts the specified request.
  698. /// </summary>
  699. /// <param name="request">The request.</param>
  700. public void Post(OnPlaybackProgress request)
  701. {
  702. Post(new ReportPlaybackProgress
  703. {
  704. ItemId = request.Id,
  705. PositionTicks = request.PositionTicks,
  706. IsMuted = request.IsMuted,
  707. IsPaused = request.IsPaused,
  708. MediaSourceId = request.MediaSourceId,
  709. AudioStreamIndex = request.AudioStreamIndex,
  710. SubtitleStreamIndex = request.SubtitleStreamIndex,
  711. VolumeLevel = request.VolumeLevel
  712. });
  713. }
  714. public void Post(ReportPlaybackProgress request)
  715. {
  716. request.SessionId = GetSession().Id;
  717. var task = _sessionManager.OnPlaybackProgress(request);
  718. Task.WaitAll(task);
  719. }
  720. /// <summary>
  721. /// Posts the specified request.
  722. /// </summary>
  723. /// <param name="request">The request.</param>
  724. public void Delete(OnPlaybackStopped request)
  725. {
  726. Post(new ReportPlaybackStopped
  727. {
  728. ItemId = request.Id,
  729. PositionTicks = request.PositionTicks,
  730. MediaSourceId = request.MediaSourceId
  731. });
  732. }
  733. public void Post(ReportPlaybackStopped request)
  734. {
  735. request.SessionId = GetSession().Id;
  736. var task = _sessionManager.OnPlaybackStopped(request);
  737. Task.WaitAll(task);
  738. }
  739. /// <summary>
  740. /// Deletes the specified request.
  741. /// </summary>
  742. /// <param name="request">The request.</param>
  743. public object Delete(MarkUnplayedItem request)
  744. {
  745. var task = MarkUnplayed(request);
  746. return ToOptimizedResult(task.Result);
  747. }
  748. private async Task<UserItemDataDto> MarkUnplayed(MarkUnplayedItem request)
  749. {
  750. var user = _userManager.GetUserById(request.UserId);
  751. var session = GetSession();
  752. var dto = await UpdatePlayedStatus(user, request.Id, false, null).ConfigureAwait(false);
  753. foreach (var additionalUserInfo in session.AdditionalUsers)
  754. {
  755. var additionalUser = _userManager.GetUserById(new Guid(additionalUserInfo.UserId));
  756. await UpdatePlayedStatus(additionalUser, request.Id, false, null).ConfigureAwait(false);
  757. }
  758. return dto;
  759. }
  760. /// <summary>
  761. /// Updates the played status.
  762. /// </summary>
  763. /// <param name="user">The user.</param>
  764. /// <param name="itemId">The item id.</param>
  765. /// <param name="wasPlayed">if set to <c>true</c> [was played].</param>
  766. /// <param name="datePlayed">The date played.</param>
  767. /// <returns>Task.</returns>
  768. private async Task<UserItemDataDto> UpdatePlayedStatus(User user, string itemId, bool wasPlayed, DateTime? datePlayed)
  769. {
  770. var item = _libraryManager.GetItemById(itemId);
  771. if (wasPlayed)
  772. {
  773. await item.MarkPlayed(user, datePlayed, _userDataRepository).ConfigureAwait(false);
  774. }
  775. else
  776. {
  777. await item.MarkUnplayed(user, _userDataRepository).ConfigureAwait(false);
  778. }
  779. return _dtoService.GetUserItemDataDto(_userDataRepository.GetUserData(user.Id, item.GetUserDataKey()));
  780. }
  781. }
  782. }