LiveTvService.cs 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614
  1. using MediaBrowser.Controller.Library;
  2. using MediaBrowser.Controller.LiveTv;
  3. using MediaBrowser.Controller.Net;
  4. using MediaBrowser.Model.Dto;
  5. using MediaBrowser.Model.Entities;
  6. using MediaBrowser.Model.LiveTv;
  7. using MediaBrowser.Model.Querying;
  8. using ServiceStack;
  9. using System;
  10. using System.Globalization;
  11. using System.Linq;
  12. using System.Threading;
  13. using System.Threading.Tasks;
  14. namespace MediaBrowser.Api.LiveTv
  15. {
  16. /// <summary>
  17. /// This is insecure right now to avoid windows phone refactoring
  18. /// </summary>
  19. [Route("/LiveTv/Info", "GET", Summary = "Gets available live tv services.")]
  20. [Authenticated]
  21. public class GetLiveTvInfo : IReturn<LiveTvInfo>
  22. {
  23. }
  24. [Route("/LiveTv/Channels", "GET", Summary = "Gets available live tv channels.")]
  25. [Authenticated]
  26. public class GetChannels : IReturn<QueryResult<ChannelInfoDto>>
  27. {
  28. [ApiMember(Name = "Type", Description = "Optional filter by channel type.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  29. public ChannelType? Type { get; set; }
  30. [ApiMember(Name = "UserId", Description = "Optional filter by user and attach user data.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  31. public string UserId { get; set; }
  32. /// <summary>
  33. /// Skips over a given number of items within the results. Use for paging.
  34. /// </summary>
  35. /// <value>The start index.</value>
  36. [ApiMember(Name = "StartIndex", Description = "Optional. The record index to start at. All items with a lower index will be dropped from the results.", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
  37. public int? StartIndex { get; set; }
  38. /// <summary>
  39. /// The maximum number of items to return
  40. /// </summary>
  41. /// <value>The limit.</value>
  42. [ApiMember(Name = "Limit", Description = "Optional. The maximum number of records to return", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
  43. public int? Limit { get; set; }
  44. [ApiMember(Name = "IsFavorite", Description = "Filter by channels that are favorites, or not.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
  45. public bool? IsFavorite { get; set; }
  46. [ApiMember(Name = "IsLiked", Description = "Filter by channels that are liked, or not.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
  47. public bool? IsLiked { get; set; }
  48. [ApiMember(Name = "IsDisliked", Description = "Filter by channels that are disliked, or not.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
  49. public bool? IsDisliked { get; set; }
  50. [ApiMember(Name = "EnableFavoriteSorting", Description = "Incorporate favorite and like status into channel sorting.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
  51. public bool EnableFavoriteSorting { get; set; }
  52. }
  53. [Route("/LiveTv/Channels/{Id}", "GET", Summary = "Gets a live tv channel")]
  54. [Authenticated]
  55. public class GetChannel : IReturn<ChannelInfoDto>
  56. {
  57. /// <summary>
  58. /// Gets or sets the id.
  59. /// </summary>
  60. /// <value>The id.</value>
  61. [ApiMember(Name = "Id", Description = "Channel Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  62. public string Id { get; set; }
  63. [ApiMember(Name = "UserId", Description = "Optional attach user data.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  64. public string UserId { get; set; }
  65. }
  66. [Route("/LiveTv/Recordings", "GET", Summary = "Gets live tv recordings")]
  67. [Authenticated]
  68. public class GetRecordings : IReturn<QueryResult<RecordingInfoDto>>
  69. {
  70. [ApiMember(Name = "ChannelId", Description = "Optional filter by channel id.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  71. public string ChannelId { get; set; }
  72. [ApiMember(Name = "UserId", Description = "Optional filter by user and attach user data.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  73. public string UserId { get; set; }
  74. [ApiMember(Name = "GroupId", Description = "Optional filter by recording group.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  75. public string GroupId { get; set; }
  76. [ApiMember(Name = "StartIndex", Description = "Optional. The record index to start at. All items with a lower index will be dropped from the results.", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
  77. public int? StartIndex { get; set; }
  78. [ApiMember(Name = "Limit", Description = "Optional. The maximum number of records to return", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
  79. public int? Limit { get; set; }
  80. [ApiMember(Name = "Status", Description = "Optional filter by recording status.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  81. public RecordingStatus? Status { get; set; }
  82. [ApiMember(Name = "Status", Description = "Optional filter by recordings that are in progress, or not.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
  83. public bool? IsInProgress { get; set; }
  84. [ApiMember(Name = "SeriesTimerId", Description = "Optional filter by recordings belonging to a series timer", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  85. public string SeriesTimerId { get; set; }
  86. }
  87. [Route("/LiveTv/Recordings/Groups", "GET", Summary = "Gets live tv recording groups")]
  88. [Authenticated]
  89. public class GetRecordingGroups : IReturn<QueryResult<RecordingGroupDto>>
  90. {
  91. [ApiMember(Name = "UserId", Description = "Optional filter by user and attach user data.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  92. public string UserId { get; set; }
  93. }
  94. [Route("/LiveTv/Recordings/{Id}", "GET", Summary = "Gets a live tv recording")]
  95. [Authenticated]
  96. public class GetRecording : IReturn<RecordingInfoDto>
  97. {
  98. [ApiMember(Name = "Id", Description = "Recording Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  99. public string Id { get; set; }
  100. [ApiMember(Name = "UserId", Description = "Optional attach user data.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  101. public string UserId { get; set; }
  102. }
  103. [Route("/LiveTv/Tuners/{Id}/Reset", "POST", Summary = "Resets a tv tuner")]
  104. [Authenticated]
  105. public class ResetTuner : IReturnVoid
  106. {
  107. [ApiMember(Name = "Id", Description = "Tuner Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  108. public string Id { get; set; }
  109. }
  110. [Route("/LiveTv/Timers/{Id}", "GET", Summary = "Gets a live tv timer")]
  111. [Authenticated]
  112. public class GetTimer : IReturn<TimerInfoDto>
  113. {
  114. [ApiMember(Name = "Id", Description = "Timer Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  115. public string Id { get; set; }
  116. }
  117. [Route("/LiveTv/Timers/Defaults", "GET", Summary = "Gets default values for a new timer")]
  118. [Authenticated]
  119. public class GetDefaultTimer : IReturn<SeriesTimerInfoDto>
  120. {
  121. [ApiMember(Name = "ProgramId", Description = "Optional, to attach default values based on a program.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  122. public string ProgramId { get; set; }
  123. }
  124. [Route("/LiveTv/Timers", "GET", Summary = "Gets live tv timers")]
  125. [Authenticated]
  126. public class GetTimers : IReturn<QueryResult<TimerInfoDto>>
  127. {
  128. [ApiMember(Name = "ChannelId", Description = "Optional filter by channel id.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  129. public string ChannelId { get; set; }
  130. [ApiMember(Name = "SeriesTimerId", Description = "Optional filter by timers belonging to a series timer", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  131. public string SeriesTimerId { get; set; }
  132. }
  133. [Route("/LiveTv/Programs", "GET,POST", Summary = "Gets available live tv epgs..")]
  134. [Authenticated]
  135. public class GetPrograms : IReturn<QueryResult<ProgramInfoDto>>
  136. {
  137. [ApiMember(Name = "ChannelIds", Description = "The channels to return guide information for.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
  138. public string ChannelIds { get; set; }
  139. [ApiMember(Name = "UserId", Description = "Optional filter by user id.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
  140. public string UserId { get; set; }
  141. [ApiMember(Name = "MinStartDate", Description = "Optional. The minimum premiere date. Format = ISO", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
  142. public string MinStartDate { get; set; }
  143. [ApiMember(Name = "HasAired", Description = "Optional. Filter by programs that have completed airing, or not.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
  144. public bool? HasAired { get; set; }
  145. [ApiMember(Name = "MaxStartDate", Description = "Optional. The maximum premiere date. Format = ISO", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
  146. public string MaxStartDate { get; set; }
  147. [ApiMember(Name = "MinEndDate", Description = "Optional. The minimum premiere date. Format = ISO", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
  148. public string MinEndDate { get; set; }
  149. [ApiMember(Name = "MaxEndDate", Description = "Optional. The maximum premiere date. Format = ISO", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
  150. public string MaxEndDate { get; set; }
  151. }
  152. [Route("/LiveTv/Programs/Recommended", "GET", Summary = "Gets available live tv epgs..")]
  153. [Authenticated]
  154. public class GetRecommendedPrograms : IReturn<QueryResult<ProgramInfoDto>>
  155. {
  156. [ApiMember(Name = "UserId", Description = "Optional filter by user id.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
  157. public string UserId { get; set; }
  158. [ApiMember(Name = "Limit", Description = "Optional. The maximum number of records to return", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
  159. public int? Limit { get; set; }
  160. [ApiMember(Name = "IsAiring", Description = "Optional. Filter by programs that are currently airing, or not.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
  161. public bool? IsAiring { get; set; }
  162. [ApiMember(Name = "HasAired", Description = "Optional. Filter by programs that have completed airing, or not.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
  163. public bool? HasAired { get; set; }
  164. }
  165. [Route("/LiveTv/Programs/{Id}", "GET", Summary = "Gets a live tv program")]
  166. [Authenticated]
  167. public class GetProgram : IReturn<ProgramInfoDto>
  168. {
  169. [ApiMember(Name = "Id", Description = "Program Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  170. public string Id { get; set; }
  171. [ApiMember(Name = "UserId", Description = "Optional attach user data.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  172. public string UserId { get; set; }
  173. }
  174. [Route("/LiveTv/Recordings/{Id}", "DELETE", Summary = "Deletes a live tv recording")]
  175. [Authenticated]
  176. public class DeleteRecording : IReturnVoid
  177. {
  178. [ApiMember(Name = "Id", Description = "Recording Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  179. public string Id { get; set; }
  180. }
  181. [Route("/LiveTv/Timers/{Id}", "DELETE", Summary = "Cancels a live tv timer")]
  182. [Authenticated]
  183. public class CancelTimer : IReturnVoid
  184. {
  185. [ApiMember(Name = "Id", Description = "Timer Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  186. public string Id { get; set; }
  187. }
  188. [Route("/LiveTv/Timers/{Id}", "POST", Summary = "Updates a live tv timer")]
  189. [Authenticated]
  190. public class UpdateTimer : TimerInfoDto, IReturnVoid
  191. {
  192. }
  193. [Route("/LiveTv/Timers", "POST", Summary = "Creates a live tv timer")]
  194. [Authenticated]
  195. public class CreateTimer : TimerInfoDto, IReturnVoid
  196. {
  197. }
  198. [Route("/LiveTv/SeriesTimers/{Id}", "GET", Summary = "Gets a live tv series timer")]
  199. [Authenticated]
  200. public class GetSeriesTimer : IReturn<TimerInfoDto>
  201. {
  202. [ApiMember(Name = "Id", Description = "Timer Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  203. public string Id { get; set; }
  204. }
  205. [Route("/LiveTv/SeriesTimers", "GET", Summary = "Gets live tv series timers")]
  206. [Authenticated]
  207. public class GetSeriesTimers : IReturn<QueryResult<SeriesTimerInfoDto>>
  208. {
  209. [ApiMember(Name = "SortBy", Description = "Optional. Sort by SortName or Priority", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
  210. public string SortBy { get; set; }
  211. [ApiMember(Name = "SortOrder", Description = "Optional. Sort in Ascending or Descending order", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
  212. public SortOrder SortOrder { get; set; }
  213. }
  214. [Route("/LiveTv/SeriesTimers/{Id}", "DELETE", Summary = "Cancels a live tv series timer")]
  215. [Authenticated]
  216. public class CancelSeriesTimer : IReturnVoid
  217. {
  218. [ApiMember(Name = "Id", Description = "Timer Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  219. public string Id { get; set; }
  220. }
  221. [Route("/LiveTv/SeriesTimers/{Id}", "POST", Summary = "Updates a live tv series timer")]
  222. [Authenticated]
  223. public class UpdateSeriesTimer : SeriesTimerInfoDto, IReturnVoid
  224. {
  225. }
  226. [Route("/LiveTv/SeriesTimers", "POST", Summary = "Creates a live tv series timer")]
  227. [Authenticated]
  228. public class CreateSeriesTimer : SeriesTimerInfoDto, IReturnVoid
  229. {
  230. }
  231. [Route("/LiveTv/Recordings/Groups/{Id}", "GET", Summary = "Gets a recording group")]
  232. [Authenticated]
  233. public class GetRecordingGroup : IReturn<RecordingGroupDto>
  234. {
  235. [ApiMember(Name = "Id", Description = "Recording group Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
  236. public string Id { get; set; }
  237. }
  238. [Route("/LiveTv/GuideInfo", "GET", Summary = "Gets guide info")]
  239. [Authenticated]
  240. public class GetGuideInfo : IReturn<GuideInfo>
  241. {
  242. }
  243. [Route("/LiveTv/Folder", "GET", Summary = "Gets the users live tv folder, along with configured images")]
  244. [Authenticated]
  245. public class GetLiveTvFolder : IReturn<BaseItemDto>
  246. {
  247. [ApiMember(Name = "UserId", Description = "Optional attach user data.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
  248. public string UserId { get; set; }
  249. }
  250. public class LiveTvService : BaseApiService
  251. {
  252. private readonly ILiveTvManager _liveTvManager;
  253. private readonly IUserManager _userManager;
  254. public LiveTvService(ILiveTvManager liveTvManager, IUserManager userManager)
  255. {
  256. _liveTvManager = liveTvManager;
  257. _userManager = userManager;
  258. }
  259. private void AssertUserCanManageLiveTv()
  260. {
  261. var user = SessionContext.GetUser(Request).Result;
  262. if (user == null)
  263. {
  264. throw new UnauthorizedAccessException("Anonymous live tv management is not allowed.");
  265. }
  266. if (!user.Policy.EnableLiveTvManagement)
  267. {
  268. throw new UnauthorizedAccessException("The current user does not have permission to manage live tv.");
  269. }
  270. }
  271. public async Task<object> Get(GetLiveTvInfo request)
  272. {
  273. var info = await _liveTvManager.GetLiveTvInfo(CancellationToken.None).ConfigureAwait(false);
  274. return ToOptimizedSerializedResultUsingCache(info);
  275. }
  276. public async Task<object> Get(GetChannels request)
  277. {
  278. var result = await _liveTvManager.GetChannels(new LiveTvChannelQuery
  279. {
  280. ChannelType = request.Type,
  281. UserId = request.UserId,
  282. StartIndex = request.StartIndex,
  283. Limit = request.Limit,
  284. IsFavorite = request.IsFavorite,
  285. IsLiked = request.IsLiked,
  286. IsDisliked = request.IsDisliked,
  287. EnableFavoriteSorting = request.EnableFavoriteSorting
  288. }, CancellationToken.None).ConfigureAwait(false);
  289. return ToOptimizedSerializedResultUsingCache(result);
  290. }
  291. public async Task<object> Get(GetChannel request)
  292. {
  293. var user = string.IsNullOrEmpty(request.UserId) ? null : _userManager.GetUserById(request.UserId);
  294. var result = await _liveTvManager.GetChannel(request.Id, CancellationToken.None, user).ConfigureAwait(false);
  295. return ToOptimizedSerializedResultUsingCache(result);
  296. }
  297. public async Task<object> Get(GetLiveTvFolder request)
  298. {
  299. return ToOptimizedResult(await _liveTvManager.GetLiveTvFolder(request.UserId, CancellationToken.None).ConfigureAwait(false));
  300. }
  301. public async Task<object> Get(GetPrograms request)
  302. {
  303. var query = new ProgramQuery
  304. {
  305. ChannelIdList = (request.ChannelIds ?? string.Empty).Split(new[] { ',' }, StringSplitOptions.RemoveEmptyEntries).ToArray(),
  306. UserId = request.UserId,
  307. HasAired = request.HasAired
  308. };
  309. if (!string.IsNullOrEmpty(request.MinStartDate))
  310. {
  311. query.MinStartDate = DateTime.Parse(request.MinStartDate, null, DateTimeStyles.RoundtripKind).ToUniversalTime();
  312. }
  313. if (!string.IsNullOrEmpty(request.MinEndDate))
  314. {
  315. query.MinEndDate = DateTime.Parse(request.MinEndDate, null, DateTimeStyles.RoundtripKind).ToUniversalTime();
  316. }
  317. if (!string.IsNullOrEmpty(request.MaxStartDate))
  318. {
  319. query.MaxStartDate = DateTime.Parse(request.MaxStartDate, null, DateTimeStyles.RoundtripKind).ToUniversalTime();
  320. }
  321. if (!string.IsNullOrEmpty(request.MaxEndDate))
  322. {
  323. query.MaxEndDate = DateTime.Parse(request.MaxEndDate, null, DateTimeStyles.RoundtripKind).ToUniversalTime();
  324. }
  325. var result = await _liveTvManager.GetPrograms(query, CancellationToken.None).ConfigureAwait(false);
  326. return ToOptimizedSerializedResultUsingCache(result);
  327. }
  328. public async Task<object> Get(GetRecommendedPrograms request)
  329. {
  330. var query = new RecommendedProgramQuery
  331. {
  332. UserId = request.UserId,
  333. IsAiring = request.IsAiring,
  334. Limit = request.Limit,
  335. HasAired = request.HasAired
  336. };
  337. var result = await _liveTvManager.GetRecommendedPrograms(query, CancellationToken.None).ConfigureAwait(false);
  338. return ToOptimizedSerializedResultUsingCache(result);
  339. }
  340. public object Post(GetPrograms request)
  341. {
  342. return Get(request);
  343. }
  344. public async Task<object> Get(GetRecordings request)
  345. {
  346. var result = await _liveTvManager.GetRecordings(new RecordingQuery
  347. {
  348. ChannelId = request.ChannelId,
  349. UserId = request.UserId,
  350. GroupId = request.GroupId,
  351. StartIndex = request.StartIndex,
  352. Limit = request.Limit,
  353. Status = request.Status,
  354. SeriesTimerId = request.SeriesTimerId,
  355. IsInProgress = request.IsInProgress
  356. }, CancellationToken.None).ConfigureAwait(false);
  357. return ToOptimizedSerializedResultUsingCache(result);
  358. }
  359. public async Task<object> Get(GetRecording request)
  360. {
  361. var user = string.IsNullOrEmpty(request.UserId) ? null : _userManager.GetUserById(request.UserId);
  362. var result = await _liveTvManager.GetRecording(request.Id, CancellationToken.None, user).ConfigureAwait(false);
  363. return ToOptimizedSerializedResultUsingCache(result);
  364. }
  365. public async Task<object> Get(GetTimer request)
  366. {
  367. var result = await _liveTvManager.GetTimer(request.Id, CancellationToken.None).ConfigureAwait(false);
  368. return ToOptimizedSerializedResultUsingCache(result);
  369. }
  370. public async Task<object> Get(GetTimers request)
  371. {
  372. var result = await _liveTvManager.GetTimers(new TimerQuery
  373. {
  374. ChannelId = request.ChannelId,
  375. SeriesTimerId = request.SeriesTimerId
  376. }, CancellationToken.None).ConfigureAwait(false);
  377. return ToOptimizedSerializedResultUsingCache(result);
  378. }
  379. public void Delete(DeleteRecording request)
  380. {
  381. AssertUserCanManageLiveTv();
  382. var task = _liveTvManager.DeleteRecording(request.Id);
  383. Task.WaitAll(task);
  384. }
  385. public void Delete(CancelTimer request)
  386. {
  387. AssertUserCanManageLiveTv();
  388. var task = _liveTvManager.CancelTimer(request.Id);
  389. Task.WaitAll(task);
  390. }
  391. public void Post(UpdateTimer request)
  392. {
  393. AssertUserCanManageLiveTv();
  394. var task = _liveTvManager.UpdateTimer(request, CancellationToken.None);
  395. Task.WaitAll(task);
  396. }
  397. public async Task<object> Get(GetSeriesTimers request)
  398. {
  399. var result = await _liveTvManager.GetSeriesTimers(new SeriesTimerQuery
  400. {
  401. SortOrder = request.SortOrder,
  402. SortBy = request.SortBy
  403. }, CancellationToken.None).ConfigureAwait(false);
  404. return ToOptimizedSerializedResultUsingCache(result);
  405. }
  406. public async Task<object> Get(GetSeriesTimer request)
  407. {
  408. var result = await _liveTvManager.GetSeriesTimer(request.Id, CancellationToken.None).ConfigureAwait(false);
  409. return ToOptimizedSerializedResultUsingCache(result);
  410. }
  411. public void Delete(CancelSeriesTimer request)
  412. {
  413. AssertUserCanManageLiveTv();
  414. var task = _liveTvManager.CancelSeriesTimer(request.Id);
  415. Task.WaitAll(task);
  416. }
  417. public void Post(UpdateSeriesTimer request)
  418. {
  419. AssertUserCanManageLiveTv();
  420. var task = _liveTvManager.UpdateSeriesTimer(request, CancellationToken.None);
  421. Task.WaitAll(task);
  422. }
  423. public async Task<object> Get(GetDefaultTimer request)
  424. {
  425. if (string.IsNullOrEmpty(request.ProgramId))
  426. {
  427. var result = await _liveTvManager.GetNewTimerDefaults(CancellationToken.None).ConfigureAwait(false);
  428. return ToOptimizedSerializedResultUsingCache(result);
  429. }
  430. else
  431. {
  432. var result = await _liveTvManager.GetNewTimerDefaults(request.ProgramId, CancellationToken.None).ConfigureAwait(false);
  433. return ToOptimizedSerializedResultUsingCache(result);
  434. }
  435. }
  436. public async Task<object> Get(GetProgram request)
  437. {
  438. var user = string.IsNullOrEmpty(request.UserId) ? null : _userManager.GetUserById(request.UserId);
  439. var result = await _liveTvManager.GetProgram(request.Id, CancellationToken.None, user).ConfigureAwait(false);
  440. return ToOptimizedSerializedResultUsingCache(result);
  441. }
  442. public void Post(CreateSeriesTimer request)
  443. {
  444. AssertUserCanManageLiveTv();
  445. var task = _liveTvManager.CreateSeriesTimer(request, CancellationToken.None);
  446. Task.WaitAll(task);
  447. }
  448. public void Post(CreateTimer request)
  449. {
  450. AssertUserCanManageLiveTv();
  451. var task = _liveTvManager.CreateTimer(request, CancellationToken.None);
  452. Task.WaitAll(task);
  453. }
  454. public async Task<object> Get(GetRecordingGroups request)
  455. {
  456. var result = await _liveTvManager.GetRecordingGroups(new RecordingGroupQuery
  457. {
  458. UserId = request.UserId
  459. }, CancellationToken.None).ConfigureAwait(false);
  460. return ToOptimizedSerializedResultUsingCache(result);
  461. }
  462. public async Task<object> Get(GetRecordingGroup request)
  463. {
  464. var result = await _liveTvManager.GetRecordingGroups(new RecordingGroupQuery
  465. {
  466. }, CancellationToken.None).ConfigureAwait(false);
  467. var group = result.Items.FirstOrDefault(i => string.Equals(i.Id, request.Id, StringComparison.OrdinalIgnoreCase));
  468. return ToOptimizedSerializedResultUsingCache(group);
  469. }
  470. public object Get(GetGuideInfo request)
  471. {
  472. return ToOptimizedResult(_liveTvManager.GetGuideInfo());
  473. }
  474. public void Post(ResetTuner request)
  475. {
  476. AssertUserCanManageLiveTv();
  477. var task = _liveTvManager.ResetTuner(request.Id, CancellationToken.None);
  478. Task.WaitAll(task);
  479. }
  480. }
  481. }