LiveTvController.cs 56 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203
  1. using System;
  2. using System.Collections.Generic;
  3. using System.ComponentModel.DataAnnotations;
  4. using System.Diagnostics.CodeAnalysis;
  5. using System.Linq;
  6. using System.Net.Http;
  7. using System.Net.Mime;
  8. using System.Security.Cryptography;
  9. using System.Text;
  10. using System.Threading;
  11. using System.Threading.Tasks;
  12. using Jellyfin.Api.Attributes;
  13. using Jellyfin.Api.Constants;
  14. using Jellyfin.Api.Extensions;
  15. using Jellyfin.Api.Helpers;
  16. using Jellyfin.Api.ModelBinders;
  17. using Jellyfin.Api.Models.LiveTvDtos;
  18. using Jellyfin.Data.Enums;
  19. using MediaBrowser.Common.Configuration;
  20. using MediaBrowser.Common.Net;
  21. using MediaBrowser.Controller.Dto;
  22. using MediaBrowser.Controller.Entities;
  23. using MediaBrowser.Controller.Entities.TV;
  24. using MediaBrowser.Controller.Library;
  25. using MediaBrowser.Controller.LiveTv;
  26. using MediaBrowser.Model.Dto;
  27. using MediaBrowser.Model.Entities;
  28. using MediaBrowser.Model.LiveTv;
  29. using MediaBrowser.Model.Net;
  30. using MediaBrowser.Model.Querying;
  31. using Microsoft.AspNetCore.Authorization;
  32. using Microsoft.AspNetCore.Http;
  33. using Microsoft.AspNetCore.Mvc;
  34. namespace Jellyfin.Api.Controllers;
  35. /// <summary>
  36. /// Live tv controller.
  37. /// </summary>
  38. public class LiveTvController : BaseJellyfinApiController
  39. {
  40. private readonly ILiveTvManager _liveTvManager;
  41. private readonly IUserManager _userManager;
  42. private readonly IHttpClientFactory _httpClientFactory;
  43. private readonly ILibraryManager _libraryManager;
  44. private readonly IDtoService _dtoService;
  45. private readonly IMediaSourceManager _mediaSourceManager;
  46. private readonly IConfigurationManager _configurationManager;
  47. private readonly TranscodingJobHelper _transcodingJobHelper;
  48. /// <summary>
  49. /// Initializes a new instance of the <see cref="LiveTvController"/> class.
  50. /// </summary>
  51. /// <param name="liveTvManager">Instance of the <see cref="ILiveTvManager"/> interface.</param>
  52. /// <param name="userManager">Instance of the <see cref="IUserManager"/> interface.</param>
  53. /// <param name="httpClientFactory">Instance of the <see cref="IHttpClientFactory"/> interface.</param>
  54. /// <param name="libraryManager">Instance of the <see cref="ILibraryManager"/> interface.</param>
  55. /// <param name="dtoService">Instance of the <see cref="IDtoService"/> interface.</param>
  56. /// <param name="mediaSourceManager">Instance of the <see cref="IMediaSourceManager"/> interface.</param>
  57. /// <param name="configurationManager">Instance of the <see cref="IConfigurationManager"/> interface.</param>
  58. /// <param name="transcodingJobHelper">Instance of the <see cref="TranscodingJobHelper"/> class.</param>
  59. public LiveTvController(
  60. ILiveTvManager liveTvManager,
  61. IUserManager userManager,
  62. IHttpClientFactory httpClientFactory,
  63. ILibraryManager libraryManager,
  64. IDtoService dtoService,
  65. IMediaSourceManager mediaSourceManager,
  66. IConfigurationManager configurationManager,
  67. TranscodingJobHelper transcodingJobHelper)
  68. {
  69. _liveTvManager = liveTvManager;
  70. _userManager = userManager;
  71. _httpClientFactory = httpClientFactory;
  72. _libraryManager = libraryManager;
  73. _dtoService = dtoService;
  74. _mediaSourceManager = mediaSourceManager;
  75. _configurationManager = configurationManager;
  76. _transcodingJobHelper = transcodingJobHelper;
  77. }
  78. /// <summary>
  79. /// Gets available live tv services.
  80. /// </summary>
  81. /// <response code="200">Available live tv services returned.</response>
  82. /// <returns>
  83. /// An <see cref="OkResult"/> containing the available live tv services.
  84. /// </returns>
  85. [HttpGet("Info")]
  86. [ProducesResponseType(StatusCodes.Status200OK)]
  87. [Authorize(Policy = Policies.LiveTvAccess)]
  88. public ActionResult<LiveTvInfo> GetLiveTvInfo()
  89. {
  90. return _liveTvManager.GetLiveTvInfo(CancellationToken.None);
  91. }
  92. /// <summary>
  93. /// Gets available live tv channels.
  94. /// </summary>
  95. /// <param name="type">Optional. Filter by channel type.</param>
  96. /// <param name="userId">Optional. Filter by user and attach user data.</param>
  97. /// <param name="startIndex">Optional. The record index to start at. All items with a lower index will be dropped from the results.</param>
  98. /// <param name="isMovie">Optional. Filter for movies.</param>
  99. /// <param name="isSeries">Optional. Filter for series.</param>
  100. /// <param name="isNews">Optional. Filter for news.</param>
  101. /// <param name="isKids">Optional. Filter for kids.</param>
  102. /// <param name="isSports">Optional. Filter for sports.</param>
  103. /// <param name="limit">Optional. The maximum number of records to return.</param>
  104. /// <param name="isFavorite">Optional. Filter by channels that are favorites, or not.</param>
  105. /// <param name="isLiked">Optional. Filter by channels that are liked, or not.</param>
  106. /// <param name="isDisliked">Optional. Filter by channels that are disliked, or not.</param>
  107. /// <param name="enableImages">Optional. Include image information in output.</param>
  108. /// <param name="imageTypeLimit">Optional. The max number of images to return, per image type.</param>
  109. /// <param name="enableImageTypes">"Optional. The image types to include in the output.</param>
  110. /// <param name="fields">Optional. Specify additional fields of information to return in the output.</param>
  111. /// <param name="enableUserData">Optional. Include user data.</param>
  112. /// <param name="sortBy">Optional. Key to sort by.</param>
  113. /// <param name="sortOrder">Optional. Sort order.</param>
  114. /// <param name="enableFavoriteSorting">Optional. Incorporate favorite and like status into channel sorting.</param>
  115. /// <param name="addCurrentProgram">Optional. Adds current program info to each channel.</param>
  116. /// <response code="200">Available live tv channels returned.</response>
  117. /// <returns>
  118. /// An <see cref="OkResult"/> containing the resulting available live tv channels.
  119. /// </returns>
  120. [HttpGet("Channels")]
  121. [ProducesResponseType(StatusCodes.Status200OK)]
  122. [Authorize(Policy = Policies.LiveTvAccess)]
  123. public ActionResult<QueryResult<BaseItemDto>> GetLiveTvChannels(
  124. [FromQuery] ChannelType? type,
  125. [FromQuery] Guid? userId,
  126. [FromQuery] int? startIndex,
  127. [FromQuery] bool? isMovie,
  128. [FromQuery] bool? isSeries,
  129. [FromQuery] bool? isNews,
  130. [FromQuery] bool? isKids,
  131. [FromQuery] bool? isSports,
  132. [FromQuery] int? limit,
  133. [FromQuery] bool? isFavorite,
  134. [FromQuery] bool? isLiked,
  135. [FromQuery] bool? isDisliked,
  136. [FromQuery] bool? enableImages,
  137. [FromQuery] int? imageTypeLimit,
  138. [FromQuery, ModelBinder(typeof(CommaDelimitedArrayModelBinder))] ImageType[] enableImageTypes,
  139. [FromQuery, ModelBinder(typeof(CommaDelimitedArrayModelBinder))] ItemFields[] fields,
  140. [FromQuery] bool? enableUserData,
  141. [FromQuery, ModelBinder(typeof(CommaDelimitedArrayModelBinder))] ItemSortBy[] sortBy,
  142. [FromQuery] SortOrder? sortOrder,
  143. [FromQuery] bool enableFavoriteSorting = false,
  144. [FromQuery] bool addCurrentProgram = true)
  145. {
  146. userId = RequestHelpers.GetUserId(User, userId);
  147. var dtoOptions = new DtoOptions { Fields = fields }
  148. .AddClientFields(User)
  149. .AddAdditionalDtoOptions(enableImages, enableUserData, imageTypeLimit, enableImageTypes);
  150. var channelResult = _liveTvManager.GetInternalChannels(
  151. new LiveTvChannelQuery
  152. {
  153. ChannelType = type,
  154. UserId = userId.Value,
  155. StartIndex = startIndex,
  156. Limit = limit,
  157. IsFavorite = isFavorite,
  158. IsLiked = isLiked,
  159. IsDisliked = isDisliked,
  160. EnableFavoriteSorting = enableFavoriteSorting,
  161. IsMovie = isMovie,
  162. IsSeries = isSeries,
  163. IsNews = isNews,
  164. IsKids = isKids,
  165. IsSports = isSports,
  166. SortBy = sortBy,
  167. SortOrder = sortOrder ?? SortOrder.Ascending,
  168. AddCurrentProgram = addCurrentProgram
  169. },
  170. dtoOptions,
  171. CancellationToken.None);
  172. var user = userId.Value.Equals(default)
  173. ? null
  174. : _userManager.GetUserById(userId.Value);
  175. var fieldsList = dtoOptions.Fields.ToList();
  176. fieldsList.Remove(ItemFields.CanDelete);
  177. fieldsList.Remove(ItemFields.CanDownload);
  178. fieldsList.Remove(ItemFields.DisplayPreferencesId);
  179. fieldsList.Remove(ItemFields.Etag);
  180. dtoOptions.Fields = fieldsList.ToArray();
  181. dtoOptions.AddCurrentProgram = addCurrentProgram;
  182. var returnArray = _dtoService.GetBaseItemDtos(channelResult.Items, dtoOptions, user);
  183. return new QueryResult<BaseItemDto>(
  184. startIndex,
  185. channelResult.TotalRecordCount,
  186. returnArray);
  187. }
  188. /// <summary>
  189. /// Gets a live tv channel.
  190. /// </summary>
  191. /// <param name="channelId">Channel id.</param>
  192. /// <param name="userId">Optional. Attach user data.</param>
  193. /// <response code="200">Live tv channel returned.</response>
  194. /// <returns>An <see cref="OkResult"/> containing the live tv channel.</returns>
  195. [HttpGet("Channels/{channelId}")]
  196. [ProducesResponseType(StatusCodes.Status200OK)]
  197. [Authorize(Policy = Policies.LiveTvAccess)]
  198. public ActionResult<BaseItemDto> GetChannel([FromRoute, Required] Guid channelId, [FromQuery] Guid? userId)
  199. {
  200. userId = RequestHelpers.GetUserId(User, userId);
  201. var user = userId.Value.Equals(default)
  202. ? null
  203. : _userManager.GetUserById(userId.Value);
  204. var item = channelId.Equals(default)
  205. ? _libraryManager.GetUserRootFolder()
  206. : _libraryManager.GetItemById(channelId);
  207. var dtoOptions = new DtoOptions()
  208. .AddClientFields(User);
  209. return _dtoService.GetBaseItemDto(item, dtoOptions, user);
  210. }
  211. /// <summary>
  212. /// Gets live tv recordings.
  213. /// </summary>
  214. /// <param name="channelId">Optional. Filter by channel id.</param>
  215. /// <param name="userId">Optional. Filter by user and attach user data.</param>
  216. /// <param name="startIndex">Optional. The record index to start at. All items with a lower index will be dropped from the results.</param>
  217. /// <param name="limit">Optional. The maximum number of records to return.</param>
  218. /// <param name="status">Optional. Filter by recording status.</param>
  219. /// <param name="isInProgress">Optional. Filter by recordings that are in progress, or not.</param>
  220. /// <param name="seriesTimerId">Optional. Filter by recordings belonging to a series timer.</param>
  221. /// <param name="enableImages">Optional. Include image information in output.</param>
  222. /// <param name="imageTypeLimit">Optional. The max number of images to return, per image type.</param>
  223. /// <param name="enableImageTypes">Optional. The image types to include in the output.</param>
  224. /// <param name="fields">Optional. Specify additional fields of information to return in the output.</param>
  225. /// <param name="enableUserData">Optional. Include user data.</param>
  226. /// <param name="isMovie">Optional. Filter for movies.</param>
  227. /// <param name="isSeries">Optional. Filter for series.</param>
  228. /// <param name="isKids">Optional. Filter for kids.</param>
  229. /// <param name="isSports">Optional. Filter for sports.</param>
  230. /// <param name="isNews">Optional. Filter for news.</param>
  231. /// <param name="isLibraryItem">Optional. Filter for is library item.</param>
  232. /// <param name="enableTotalRecordCount">Optional. Return total record count.</param>
  233. /// <response code="200">Live tv recordings returned.</response>
  234. /// <returns>An <see cref="OkResult"/> containing the live tv recordings.</returns>
  235. [HttpGet("Recordings")]
  236. [ProducesResponseType(StatusCodes.Status200OK)]
  237. [Authorize(Policy = Policies.LiveTvAccess)]
  238. public async Task<ActionResult<QueryResult<BaseItemDto>>> GetRecordings(
  239. [FromQuery] string? channelId,
  240. [FromQuery] Guid? userId,
  241. [FromQuery] int? startIndex,
  242. [FromQuery] int? limit,
  243. [FromQuery] RecordingStatus? status,
  244. [FromQuery] bool? isInProgress,
  245. [FromQuery] string? seriesTimerId,
  246. [FromQuery] bool? enableImages,
  247. [FromQuery] int? imageTypeLimit,
  248. [FromQuery, ModelBinder(typeof(CommaDelimitedArrayModelBinder))] ImageType[] enableImageTypes,
  249. [FromQuery, ModelBinder(typeof(CommaDelimitedArrayModelBinder))] ItemFields[] fields,
  250. [FromQuery] bool? enableUserData,
  251. [FromQuery] bool? isMovie,
  252. [FromQuery] bool? isSeries,
  253. [FromQuery] bool? isKids,
  254. [FromQuery] bool? isSports,
  255. [FromQuery] bool? isNews,
  256. [FromQuery] bool? isLibraryItem,
  257. [FromQuery] bool enableTotalRecordCount = true)
  258. {
  259. userId = RequestHelpers.GetUserId(User, userId);
  260. var dtoOptions = new DtoOptions { Fields = fields }
  261. .AddClientFields(User)
  262. .AddAdditionalDtoOptions(enableImages, enableUserData, imageTypeLimit, enableImageTypes);
  263. return await _liveTvManager.GetRecordingsAsync(
  264. new RecordingQuery
  265. {
  266. ChannelId = channelId,
  267. UserId = userId.Value,
  268. StartIndex = startIndex,
  269. Limit = limit,
  270. Status = status,
  271. SeriesTimerId = seriesTimerId,
  272. IsInProgress = isInProgress,
  273. EnableTotalRecordCount = enableTotalRecordCount,
  274. IsMovie = isMovie,
  275. IsNews = isNews,
  276. IsSeries = isSeries,
  277. IsKids = isKids,
  278. IsSports = isSports,
  279. IsLibraryItem = isLibraryItem,
  280. Fields = fields,
  281. ImageTypeLimit = imageTypeLimit,
  282. EnableImages = enableImages
  283. },
  284. dtoOptions).ConfigureAwait(false);
  285. }
  286. /// <summary>
  287. /// Gets live tv recording series.
  288. /// </summary>
  289. /// <param name="channelId">Optional. Filter by channel id.</param>
  290. /// <param name="userId">Optional. Filter by user and attach user data.</param>
  291. /// <param name="groupId">Optional. Filter by recording group.</param>
  292. /// <param name="startIndex">Optional. The record index to start at. All items with a lower index will be dropped from the results.</param>
  293. /// <param name="limit">Optional. The maximum number of records to return.</param>
  294. /// <param name="status">Optional. Filter by recording status.</param>
  295. /// <param name="isInProgress">Optional. Filter by recordings that are in progress, or not.</param>
  296. /// <param name="seriesTimerId">Optional. Filter by recordings belonging to a series timer.</param>
  297. /// <param name="enableImages">Optional. Include image information in output.</param>
  298. /// <param name="imageTypeLimit">Optional. The max number of images to return, per image type.</param>
  299. /// <param name="enableImageTypes">Optional. The image types to include in the output.</param>
  300. /// <param name="fields">Optional. Specify additional fields of information to return in the output.</param>
  301. /// <param name="enableUserData">Optional. Include user data.</param>
  302. /// <param name="enableTotalRecordCount">Optional. Return total record count.</param>
  303. /// <response code="200">Live tv recordings returned.</response>
  304. /// <returns>An <see cref="OkResult"/> containing the live tv recordings.</returns>
  305. [HttpGet("Recordings/Series")]
  306. [ProducesResponseType(StatusCodes.Status200OK)]
  307. [Authorize(Policy = Policies.LiveTvAccess)]
  308. [Obsolete("This endpoint is obsolete.")]
  309. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "channelId", Justification = "Imported from ServiceStack")]
  310. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "userId", Justification = "Imported from ServiceStack")]
  311. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "groupId", Justification = "Imported from ServiceStack")]
  312. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "startIndex", Justification = "Imported from ServiceStack")]
  313. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "limit", Justification = "Imported from ServiceStack")]
  314. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "status", Justification = "Imported from ServiceStack")]
  315. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "isInProgress", Justification = "Imported from ServiceStack")]
  316. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "seriesTimerId", Justification = "Imported from ServiceStack")]
  317. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "enableImages", Justification = "Imported from ServiceStack")]
  318. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "imageTypeLimit", Justification = "Imported from ServiceStack")]
  319. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "enableImageTypes", Justification = "Imported from ServiceStack")]
  320. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "fields", Justification = "Imported from ServiceStack")]
  321. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "enableUserData", Justification = "Imported from ServiceStack")]
  322. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "enableTotalRecordCount", Justification = "Imported from ServiceStack")]
  323. public ActionResult<QueryResult<BaseItemDto>> GetRecordingsSeries(
  324. [FromQuery] string? channelId,
  325. [FromQuery] Guid? userId,
  326. [FromQuery] string? groupId,
  327. [FromQuery] int? startIndex,
  328. [FromQuery] int? limit,
  329. [FromQuery] RecordingStatus? status,
  330. [FromQuery] bool? isInProgress,
  331. [FromQuery] string? seriesTimerId,
  332. [FromQuery] bool? enableImages,
  333. [FromQuery] int? imageTypeLimit,
  334. [FromQuery, ModelBinder(typeof(CommaDelimitedArrayModelBinder))] ImageType[] enableImageTypes,
  335. [FromQuery, ModelBinder(typeof(CommaDelimitedArrayModelBinder))] ItemFields[] fields,
  336. [FromQuery] bool? enableUserData,
  337. [FromQuery] bool enableTotalRecordCount = true)
  338. {
  339. return new QueryResult<BaseItemDto>();
  340. }
  341. /// <summary>
  342. /// Gets live tv recording groups.
  343. /// </summary>
  344. /// <param name="userId">Optional. Filter by user and attach user data.</param>
  345. /// <response code="200">Recording groups returned.</response>
  346. /// <returns>An <see cref="OkResult"/> containing the recording groups.</returns>
  347. [HttpGet("Recordings/Groups")]
  348. [ProducesResponseType(StatusCodes.Status200OK)]
  349. [Authorize(Policy = Policies.LiveTvAccess)]
  350. [Obsolete("This endpoint is obsolete.")]
  351. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "userId", Justification = "Imported from ServiceStack")]
  352. public ActionResult<QueryResult<BaseItemDto>> GetRecordingGroups([FromQuery] Guid? userId)
  353. {
  354. return new QueryResult<BaseItemDto>();
  355. }
  356. /// <summary>
  357. /// Gets recording folders.
  358. /// </summary>
  359. /// <param name="userId">Optional. Filter by user and attach user data.</param>
  360. /// <response code="200">Recording folders returned.</response>
  361. /// <returns>An <see cref="OkResult"/> containing the recording folders.</returns>
  362. [HttpGet("Recordings/Folders")]
  363. [ProducesResponseType(StatusCodes.Status200OK)]
  364. [Authorize(Policy = Policies.LiveTvAccess)]
  365. public async Task<ActionResult<QueryResult<BaseItemDto>>> GetRecordingFolders([FromQuery] Guid? userId)
  366. {
  367. userId = RequestHelpers.GetUserId(User, userId);
  368. var user = userId.Value.Equals(default)
  369. ? null
  370. : _userManager.GetUserById(userId.Value);
  371. var folders = await _liveTvManager.GetRecordingFoldersAsync(user).ConfigureAwait(false);
  372. var returnArray = _dtoService.GetBaseItemDtos(folders, new DtoOptions(), user);
  373. return new QueryResult<BaseItemDto>(returnArray);
  374. }
  375. /// <summary>
  376. /// Gets a live tv recording.
  377. /// </summary>
  378. /// <param name="recordingId">Recording id.</param>
  379. /// <param name="userId">Optional. Attach user data.</param>
  380. /// <response code="200">Recording returned.</response>
  381. /// <returns>An <see cref="OkResult"/> containing the live tv recording.</returns>
  382. [HttpGet("Recordings/{recordingId}")]
  383. [ProducesResponseType(StatusCodes.Status200OK)]
  384. [Authorize(Policy = Policies.LiveTvAccess)]
  385. public ActionResult<BaseItemDto> GetRecording([FromRoute, Required] Guid recordingId, [FromQuery] Guid? userId)
  386. {
  387. userId = RequestHelpers.GetUserId(User, userId);
  388. var user = userId.Value.Equals(default)
  389. ? null
  390. : _userManager.GetUserById(userId.Value);
  391. var item = recordingId.Equals(default) ? _libraryManager.GetUserRootFolder() : _libraryManager.GetItemById(recordingId);
  392. var dtoOptions = new DtoOptions()
  393. .AddClientFields(User);
  394. return _dtoService.GetBaseItemDto(item, dtoOptions, user);
  395. }
  396. /// <summary>
  397. /// Resets a tv tuner.
  398. /// </summary>
  399. /// <param name="tunerId">Tuner id.</param>
  400. /// <response code="204">Tuner reset.</response>
  401. /// <returns>A <see cref="NoContentResult"/>.</returns>
  402. [HttpPost("Tuners/{tunerId}/Reset")]
  403. [ProducesResponseType(StatusCodes.Status204NoContent)]
  404. [Authorize(Policy = Policies.LiveTvManagement)]
  405. public async Task<ActionResult> ResetTuner([FromRoute, Required] string tunerId)
  406. {
  407. await _liveTvManager.ResetTuner(tunerId, CancellationToken.None).ConfigureAwait(false);
  408. return NoContent();
  409. }
  410. /// <summary>
  411. /// Gets a timer.
  412. /// </summary>
  413. /// <param name="timerId">Timer id.</param>
  414. /// <response code="200">Timer returned.</response>
  415. /// <returns>
  416. /// A <see cref="Task"/> containing an <see cref="OkResult"/> which contains the timer.
  417. /// </returns>
  418. [HttpGet("Timers/{timerId}")]
  419. [ProducesResponseType(StatusCodes.Status200OK)]
  420. [Authorize(Policy = Policies.LiveTvAccess)]
  421. public async Task<ActionResult<TimerInfoDto>> GetTimer([FromRoute, Required] string timerId)
  422. {
  423. return await _liveTvManager.GetTimer(timerId, CancellationToken.None).ConfigureAwait(false);
  424. }
  425. /// <summary>
  426. /// Gets the default values for a new timer.
  427. /// </summary>
  428. /// <param name="programId">Optional. To attach default values based on a program.</param>
  429. /// <response code="200">Default values returned.</response>
  430. /// <returns>
  431. /// A <see cref="Task"/> containing an <see cref="OkResult"/> which contains the default values for a timer.
  432. /// </returns>
  433. [HttpGet("Timers/Defaults")]
  434. [ProducesResponseType(StatusCodes.Status200OK)]
  435. [Authorize(Policy = Policies.LiveTvAccess)]
  436. public async Task<ActionResult<SeriesTimerInfoDto>> GetDefaultTimer([FromQuery] string? programId)
  437. {
  438. return string.IsNullOrEmpty(programId)
  439. ? await _liveTvManager.GetNewTimerDefaults(CancellationToken.None).ConfigureAwait(false)
  440. : await _liveTvManager.GetNewTimerDefaults(programId, CancellationToken.None).ConfigureAwait(false);
  441. }
  442. /// <summary>
  443. /// Gets the live tv timers.
  444. /// </summary>
  445. /// <param name="channelId">Optional. Filter by channel id.</param>
  446. /// <param name="seriesTimerId">Optional. Filter by timers belonging to a series timer.</param>
  447. /// <param name="isActive">Optional. Filter by timers that are active.</param>
  448. /// <param name="isScheduled">Optional. Filter by timers that are scheduled.</param>
  449. /// <returns>
  450. /// A <see cref="Task"/> containing an <see cref="OkResult"/> which contains the live tv timers.
  451. /// </returns>
  452. [HttpGet("Timers")]
  453. [ProducesResponseType(StatusCodes.Status200OK)]
  454. [Authorize(Policy = Policies.LiveTvAccess)]
  455. public async Task<ActionResult<QueryResult<TimerInfoDto>>> GetTimers(
  456. [FromQuery] string? channelId,
  457. [FromQuery] string? seriesTimerId,
  458. [FromQuery] bool? isActive,
  459. [FromQuery] bool? isScheduled)
  460. {
  461. return await _liveTvManager.GetTimers(
  462. new TimerQuery
  463. {
  464. ChannelId = channelId,
  465. SeriesTimerId = seriesTimerId,
  466. IsActive = isActive,
  467. IsScheduled = isScheduled
  468. },
  469. CancellationToken.None).ConfigureAwait(false);
  470. }
  471. /// <summary>
  472. /// Gets available live tv epgs.
  473. /// </summary>
  474. /// <param name="channelIds">The channels to return guide information for.</param>
  475. /// <param name="userId">Optional. Filter by user id.</param>
  476. /// <param name="minStartDate">Optional. The minimum premiere start date.</param>
  477. /// <param name="hasAired">Optional. Filter by programs that have completed airing, or not.</param>
  478. /// <param name="isAiring">Optional. Filter by programs that are currently airing, or not.</param>
  479. /// <param name="maxStartDate">Optional. The maximum premiere start date.</param>
  480. /// <param name="minEndDate">Optional. The minimum premiere end date.</param>
  481. /// <param name="maxEndDate">Optional. The maximum premiere end date.</param>
  482. /// <param name="isMovie">Optional. Filter for movies.</param>
  483. /// <param name="isSeries">Optional. Filter for series.</param>
  484. /// <param name="isNews">Optional. Filter for news.</param>
  485. /// <param name="isKids">Optional. Filter for kids.</param>
  486. /// <param name="isSports">Optional. Filter for sports.</param>
  487. /// <param name="startIndex">Optional. The record index to start at. All items with a lower index will be dropped from the results.</param>
  488. /// <param name="limit">Optional. The maximum number of records to return.</param>
  489. /// <param name="sortBy">Optional. Specify one or more sort orders, comma delimited. Options: Name, StartDate.</param>
  490. /// <param name="sortOrder">Sort Order - Ascending,Descending.</param>
  491. /// <param name="genres">The genres to return guide information for.</param>
  492. /// <param name="genreIds">The genre ids to return guide information for.</param>
  493. /// <param name="enableImages">Optional. Include image information in output.</param>
  494. /// <param name="imageTypeLimit">Optional. The max number of images to return, per image type.</param>
  495. /// <param name="enableImageTypes">Optional. The image types to include in the output.</param>
  496. /// <param name="enableUserData">Optional. Include user data.</param>
  497. /// <param name="seriesTimerId">Optional. Filter by series timer id.</param>
  498. /// <param name="librarySeriesId">Optional. Filter by library series id.</param>
  499. /// <param name="fields">Optional. Specify additional fields of information to return in the output.</param>
  500. /// <param name="enableTotalRecordCount">Retrieve total record count.</param>
  501. /// <response code="200">Live tv epgs returned.</response>
  502. /// <returns>
  503. /// A <see cref="Task"/> containing a <see cref="OkResult"/> which contains the live tv epgs.
  504. /// </returns>
  505. [HttpGet("Programs")]
  506. [ProducesResponseType(StatusCodes.Status200OK)]
  507. [Authorize(Policy = Policies.LiveTvAccess)]
  508. public async Task<ActionResult<QueryResult<BaseItemDto>>> GetLiveTvPrograms(
  509. [FromQuery, ModelBinder(typeof(CommaDelimitedArrayModelBinder))] Guid[] channelIds,
  510. [FromQuery] Guid? userId,
  511. [FromQuery] DateTime? minStartDate,
  512. [FromQuery] bool? hasAired,
  513. [FromQuery] bool? isAiring,
  514. [FromQuery] DateTime? maxStartDate,
  515. [FromQuery] DateTime? minEndDate,
  516. [FromQuery] DateTime? maxEndDate,
  517. [FromQuery] bool? isMovie,
  518. [FromQuery] bool? isSeries,
  519. [FromQuery] bool? isNews,
  520. [FromQuery] bool? isKids,
  521. [FromQuery] bool? isSports,
  522. [FromQuery] int? startIndex,
  523. [FromQuery] int? limit,
  524. [FromQuery, ModelBinder(typeof(CommaDelimitedArrayModelBinder))] ItemSortBy[] sortBy,
  525. [FromQuery, ModelBinder(typeof(CommaDelimitedArrayModelBinder))] SortOrder[] sortOrder,
  526. [FromQuery, ModelBinder(typeof(PipeDelimitedArrayModelBinder))] string[] genres,
  527. [FromQuery, ModelBinder(typeof(CommaDelimitedArrayModelBinder))] Guid[] genreIds,
  528. [FromQuery] bool? enableImages,
  529. [FromQuery] int? imageTypeLimit,
  530. [FromQuery, ModelBinder(typeof(CommaDelimitedArrayModelBinder))] ImageType[] enableImageTypes,
  531. [FromQuery] bool? enableUserData,
  532. [FromQuery] string? seriesTimerId,
  533. [FromQuery] Guid? librarySeriesId,
  534. [FromQuery, ModelBinder(typeof(CommaDelimitedArrayModelBinder))] ItemFields[] fields,
  535. [FromQuery] bool enableTotalRecordCount = true)
  536. {
  537. userId = RequestHelpers.GetUserId(User, userId);
  538. var user = userId.Value.Equals(default)
  539. ? null
  540. : _userManager.GetUserById(userId.Value);
  541. var query = new InternalItemsQuery(user)
  542. {
  543. ChannelIds = channelIds,
  544. HasAired = hasAired,
  545. IsAiring = isAiring,
  546. EnableTotalRecordCount = enableTotalRecordCount,
  547. MinStartDate = minStartDate,
  548. MinEndDate = minEndDate,
  549. MaxStartDate = maxStartDate,
  550. MaxEndDate = maxEndDate,
  551. StartIndex = startIndex,
  552. Limit = limit,
  553. OrderBy = RequestHelpers.GetOrderBy(sortBy, sortOrder),
  554. IsNews = isNews,
  555. IsMovie = isMovie,
  556. IsSeries = isSeries,
  557. IsKids = isKids,
  558. IsSports = isSports,
  559. SeriesTimerId = seriesTimerId,
  560. Genres = genres,
  561. GenreIds = genreIds
  562. };
  563. if (librarySeriesId.HasValue && !librarySeriesId.Equals(default))
  564. {
  565. query.IsSeries = true;
  566. if (_libraryManager.GetItemById(librarySeriesId.Value) is Series series)
  567. {
  568. query.Name = series.Name;
  569. }
  570. }
  571. var dtoOptions = new DtoOptions { Fields = fields }
  572. .AddClientFields(User)
  573. .AddAdditionalDtoOptions(enableImages, enableUserData, imageTypeLimit, enableImageTypes);
  574. return await _liveTvManager.GetPrograms(query, dtoOptions, CancellationToken.None).ConfigureAwait(false);
  575. }
  576. /// <summary>
  577. /// Gets available live tv epgs.
  578. /// </summary>
  579. /// <param name="body">Request body.</param>
  580. /// <response code="200">Live tv epgs returned.</response>
  581. /// <returns>
  582. /// A <see cref="Task"/> containing a <see cref="OkResult"/> which contains the live tv epgs.
  583. /// </returns>
  584. [HttpPost("Programs")]
  585. [ProducesResponseType(StatusCodes.Status200OK)]
  586. [Authorize(Policy = Policies.LiveTvAccess)]
  587. public async Task<ActionResult<QueryResult<BaseItemDto>>> GetPrograms([FromBody] GetProgramsDto body)
  588. {
  589. var user = body.UserId.Equals(default) ? null : _userManager.GetUserById(body.UserId);
  590. var query = new InternalItemsQuery(user)
  591. {
  592. ChannelIds = body.ChannelIds,
  593. HasAired = body.HasAired,
  594. IsAiring = body.IsAiring,
  595. EnableTotalRecordCount = body.EnableTotalRecordCount,
  596. MinStartDate = body.MinStartDate,
  597. MinEndDate = body.MinEndDate,
  598. MaxStartDate = body.MaxStartDate,
  599. MaxEndDate = body.MaxEndDate,
  600. StartIndex = body.StartIndex,
  601. Limit = body.Limit,
  602. OrderBy = RequestHelpers.GetOrderBy(body.SortBy, body.SortOrder),
  603. IsNews = body.IsNews,
  604. IsMovie = body.IsMovie,
  605. IsSeries = body.IsSeries,
  606. IsKids = body.IsKids,
  607. IsSports = body.IsSports,
  608. SeriesTimerId = body.SeriesTimerId,
  609. Genres = body.Genres,
  610. GenreIds = body.GenreIds
  611. };
  612. if (!body.LibrarySeriesId.Equals(default))
  613. {
  614. query.IsSeries = true;
  615. if (_libraryManager.GetItemById(body.LibrarySeriesId) is Series series)
  616. {
  617. query.Name = series.Name;
  618. }
  619. }
  620. var dtoOptions = new DtoOptions { Fields = body.Fields }
  621. .AddClientFields(User)
  622. .AddAdditionalDtoOptions(body.EnableImages, body.EnableUserData, body.ImageTypeLimit, body.EnableImageTypes);
  623. return await _liveTvManager.GetPrograms(query, dtoOptions, CancellationToken.None).ConfigureAwait(false);
  624. }
  625. /// <summary>
  626. /// Gets recommended live tv epgs.
  627. /// </summary>
  628. /// <param name="userId">Optional. filter by user id.</param>
  629. /// <param name="limit">Optional. The maximum number of records to return.</param>
  630. /// <param name="isAiring">Optional. Filter by programs that are currently airing, or not.</param>
  631. /// <param name="hasAired">Optional. Filter by programs that have completed airing, or not.</param>
  632. /// <param name="isSeries">Optional. Filter for series.</param>
  633. /// <param name="isMovie">Optional. Filter for movies.</param>
  634. /// <param name="isNews">Optional. Filter for news.</param>
  635. /// <param name="isKids">Optional. Filter for kids.</param>
  636. /// <param name="isSports">Optional. Filter for sports.</param>
  637. /// <param name="enableImages">Optional. Include image information in output.</param>
  638. /// <param name="imageTypeLimit">Optional. The max number of images to return, per image type.</param>
  639. /// <param name="enableImageTypes">Optional. The image types to include in the output.</param>
  640. /// <param name="genreIds">The genres to return guide information for.</param>
  641. /// <param name="fields">Optional. Specify additional fields of information to return in the output.</param>
  642. /// <param name="enableUserData">Optional. include user data.</param>
  643. /// <param name="enableTotalRecordCount">Retrieve total record count.</param>
  644. /// <response code="200">Recommended epgs returned.</response>
  645. /// <returns>A <see cref="OkResult"/> containing the queryresult of recommended epgs.</returns>
  646. [HttpGet("Programs/Recommended")]
  647. [Authorize(Policy = Policies.LiveTvAccess)]
  648. [ProducesResponseType(StatusCodes.Status200OK)]
  649. public async Task<ActionResult<QueryResult<BaseItemDto>>> GetRecommendedPrograms(
  650. [FromQuery] Guid? userId,
  651. [FromQuery] int? limit,
  652. [FromQuery] bool? isAiring,
  653. [FromQuery] bool? hasAired,
  654. [FromQuery] bool? isSeries,
  655. [FromQuery] bool? isMovie,
  656. [FromQuery] bool? isNews,
  657. [FromQuery] bool? isKids,
  658. [FromQuery] bool? isSports,
  659. [FromQuery] bool? enableImages,
  660. [FromQuery] int? imageTypeLimit,
  661. [FromQuery, ModelBinder(typeof(CommaDelimitedArrayModelBinder))] ImageType[] enableImageTypes,
  662. [FromQuery, ModelBinder(typeof(CommaDelimitedArrayModelBinder))] Guid[] genreIds,
  663. [FromQuery, ModelBinder(typeof(CommaDelimitedArrayModelBinder))] ItemFields[] fields,
  664. [FromQuery] bool? enableUserData,
  665. [FromQuery] bool enableTotalRecordCount = true)
  666. {
  667. userId = RequestHelpers.GetUserId(User, userId);
  668. var user = userId.Value.Equals(default)
  669. ? null
  670. : _userManager.GetUserById(userId.Value);
  671. var query = new InternalItemsQuery(user)
  672. {
  673. IsAiring = isAiring,
  674. Limit = limit,
  675. HasAired = hasAired,
  676. IsSeries = isSeries,
  677. IsMovie = isMovie,
  678. IsKids = isKids,
  679. IsNews = isNews,
  680. IsSports = isSports,
  681. EnableTotalRecordCount = enableTotalRecordCount,
  682. GenreIds = genreIds
  683. };
  684. var dtoOptions = new DtoOptions { Fields = fields }
  685. .AddClientFields(User)
  686. .AddAdditionalDtoOptions(enableImages, enableUserData, imageTypeLimit, enableImageTypes);
  687. return await _liveTvManager.GetRecommendedProgramsAsync(query, dtoOptions, CancellationToken.None).ConfigureAwait(false);
  688. }
  689. /// <summary>
  690. /// Gets a live tv program.
  691. /// </summary>
  692. /// <param name="programId">Program id.</param>
  693. /// <param name="userId">Optional. Attach user data.</param>
  694. /// <response code="200">Program returned.</response>
  695. /// <returns>An <see cref="OkResult"/> containing the livetv program.</returns>
  696. [HttpGet("Programs/{programId}")]
  697. [Authorize(Policy = Policies.LiveTvAccess)]
  698. [ProducesResponseType(StatusCodes.Status200OK)]
  699. public async Task<ActionResult<BaseItemDto>> GetProgram(
  700. [FromRoute, Required] string programId,
  701. [FromQuery] Guid? userId)
  702. {
  703. userId = RequestHelpers.GetUserId(User, userId);
  704. var user = userId.Value.Equals(default)
  705. ? null
  706. : _userManager.GetUserById(userId.Value);
  707. return await _liveTvManager.GetProgram(programId, CancellationToken.None, user).ConfigureAwait(false);
  708. }
  709. /// <summary>
  710. /// Deletes a live tv recording.
  711. /// </summary>
  712. /// <param name="recordingId">Recording id.</param>
  713. /// <response code="204">Recording deleted.</response>
  714. /// <response code="404">Item not found.</response>
  715. /// <returns>A <see cref="NoContentResult"/> on success, or a <see cref="NotFoundResult"/> if item not found.</returns>
  716. [HttpDelete("Recordings/{recordingId}")]
  717. [Authorize(Policy = Policies.LiveTvManagement)]
  718. [ProducesResponseType(StatusCodes.Status204NoContent)]
  719. [ProducesResponseType(StatusCodes.Status404NotFound)]
  720. public ActionResult DeleteRecording([FromRoute, Required] Guid recordingId)
  721. {
  722. var item = _libraryManager.GetItemById(recordingId);
  723. if (item is null)
  724. {
  725. return NotFound();
  726. }
  727. _libraryManager.DeleteItem(item, new DeleteOptions
  728. {
  729. DeleteFileLocation = false
  730. });
  731. return NoContent();
  732. }
  733. /// <summary>
  734. /// Cancels a live tv timer.
  735. /// </summary>
  736. /// <param name="timerId">Timer id.</param>
  737. /// <response code="204">Timer deleted.</response>
  738. /// <returns>A <see cref="NoContentResult"/>.</returns>
  739. [HttpDelete("Timers/{timerId}")]
  740. [Authorize(Policy = Policies.LiveTvManagement)]
  741. [ProducesResponseType(StatusCodes.Status204NoContent)]
  742. public async Task<ActionResult> CancelTimer([FromRoute, Required] string timerId)
  743. {
  744. await _liveTvManager.CancelTimer(timerId).ConfigureAwait(false);
  745. return NoContent();
  746. }
  747. /// <summary>
  748. /// Updates a live tv timer.
  749. /// </summary>
  750. /// <param name="timerId">Timer id.</param>
  751. /// <param name="timerInfo">New timer info.</param>
  752. /// <response code="204">Timer updated.</response>
  753. /// <returns>A <see cref="NoContentResult"/>.</returns>
  754. [HttpPost("Timers/{timerId}")]
  755. [Authorize(Policy = Policies.LiveTvManagement)]
  756. [ProducesResponseType(StatusCodes.Status204NoContent)]
  757. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "timerId", Justification = "Imported from ServiceStack")]
  758. public async Task<ActionResult> UpdateTimer([FromRoute, Required] string timerId, [FromBody] TimerInfoDto timerInfo)
  759. {
  760. await _liveTvManager.UpdateTimer(timerInfo, CancellationToken.None).ConfigureAwait(false);
  761. return NoContent();
  762. }
  763. /// <summary>
  764. /// Creates a live tv timer.
  765. /// </summary>
  766. /// <param name="timerInfo">New timer info.</param>
  767. /// <response code="204">Timer created.</response>
  768. /// <returns>A <see cref="NoContentResult"/>.</returns>
  769. [HttpPost("Timers")]
  770. [Authorize(Policy = Policies.LiveTvManagement)]
  771. [ProducesResponseType(StatusCodes.Status204NoContent)]
  772. public async Task<ActionResult> CreateTimer([FromBody] TimerInfoDto timerInfo)
  773. {
  774. await _liveTvManager.CreateTimer(timerInfo, CancellationToken.None).ConfigureAwait(false);
  775. return NoContent();
  776. }
  777. /// <summary>
  778. /// Gets a live tv series timer.
  779. /// </summary>
  780. /// <param name="timerId">Timer id.</param>
  781. /// <response code="200">Series timer returned.</response>
  782. /// <response code="404">Series timer not found.</response>
  783. /// <returns>A <see cref="OkResult"/> on success, or a <see cref="NotFoundResult"/> if timer not found.</returns>
  784. [HttpGet("SeriesTimers/{timerId}")]
  785. [Authorize(Policy = Policies.LiveTvAccess)]
  786. [ProducesResponseType(StatusCodes.Status200OK)]
  787. [ProducesResponseType(StatusCodes.Status404NotFound)]
  788. public async Task<ActionResult<SeriesTimerInfoDto>> GetSeriesTimer([FromRoute, Required] string timerId)
  789. {
  790. var timer = await _liveTvManager.GetSeriesTimer(timerId, CancellationToken.None).ConfigureAwait(false);
  791. if (timer is null)
  792. {
  793. return NotFound();
  794. }
  795. return timer;
  796. }
  797. /// <summary>
  798. /// Gets live tv series timers.
  799. /// </summary>
  800. /// <param name="sortBy">Optional. Sort by SortName or Priority.</param>
  801. /// <param name="sortOrder">Optional. Sort in Ascending or Descending order.</param>
  802. /// <response code="200">Timers returned.</response>
  803. /// <returns>An <see cref="OkResult"/> of live tv series timers.</returns>
  804. [HttpGet("SeriesTimers")]
  805. [Authorize(Policy = Policies.LiveTvAccess)]
  806. [ProducesResponseType(StatusCodes.Status200OK)]
  807. public async Task<ActionResult<QueryResult<SeriesTimerInfoDto>>> GetSeriesTimers([FromQuery] string? sortBy, [FromQuery] SortOrder? sortOrder)
  808. {
  809. return await _liveTvManager.GetSeriesTimers(
  810. new SeriesTimerQuery
  811. {
  812. SortOrder = sortOrder ?? SortOrder.Ascending,
  813. SortBy = sortBy
  814. },
  815. CancellationToken.None).ConfigureAwait(false);
  816. }
  817. /// <summary>
  818. /// Cancels a live tv series timer.
  819. /// </summary>
  820. /// <param name="timerId">Timer id.</param>
  821. /// <response code="204">Timer cancelled.</response>
  822. /// <returns>A <see cref="NoContentResult"/>.</returns>
  823. [HttpDelete("SeriesTimers/{timerId}")]
  824. [Authorize(Policy = Policies.LiveTvManagement)]
  825. [ProducesResponseType(StatusCodes.Status204NoContent)]
  826. public async Task<ActionResult> CancelSeriesTimer([FromRoute, Required] string timerId)
  827. {
  828. await _liveTvManager.CancelSeriesTimer(timerId).ConfigureAwait(false);
  829. return NoContent();
  830. }
  831. /// <summary>
  832. /// Updates a live tv series timer.
  833. /// </summary>
  834. /// <param name="timerId">Timer id.</param>
  835. /// <param name="seriesTimerInfo">New series timer info.</param>
  836. /// <response code="204">Series timer updated.</response>
  837. /// <returns>A <see cref="NoContentResult"/>.</returns>
  838. [HttpPost("SeriesTimers/{timerId}")]
  839. [Authorize(Policy = Policies.LiveTvManagement)]
  840. [ProducesResponseType(StatusCodes.Status204NoContent)]
  841. [SuppressMessage("Microsoft.Performance", "CA1801:ReviewUnusedParameters", MessageId = "timerId", Justification = "Imported from ServiceStack")]
  842. public async Task<ActionResult> UpdateSeriesTimer([FromRoute, Required] string timerId, [FromBody] SeriesTimerInfoDto seriesTimerInfo)
  843. {
  844. await _liveTvManager.UpdateSeriesTimer(seriesTimerInfo, CancellationToken.None).ConfigureAwait(false);
  845. return NoContent();
  846. }
  847. /// <summary>
  848. /// Creates a live tv series timer.
  849. /// </summary>
  850. /// <param name="seriesTimerInfo">New series timer info.</param>
  851. /// <response code="204">Series timer info created.</response>
  852. /// <returns>A <see cref="NoContentResult"/>.</returns>
  853. [HttpPost("SeriesTimers")]
  854. [Authorize(Policy = Policies.LiveTvManagement)]
  855. [ProducesResponseType(StatusCodes.Status204NoContent)]
  856. public async Task<ActionResult> CreateSeriesTimer([FromBody] SeriesTimerInfoDto seriesTimerInfo)
  857. {
  858. await _liveTvManager.CreateSeriesTimer(seriesTimerInfo, CancellationToken.None).ConfigureAwait(false);
  859. return NoContent();
  860. }
  861. /// <summary>
  862. /// Get recording group.
  863. /// </summary>
  864. /// <param name="groupId">Group id.</param>
  865. /// <returns>A <see cref="NotFoundResult"/>.</returns>
  866. [HttpGet("Recordings/Groups/{groupId}")]
  867. [Authorize(Policy = Policies.LiveTvAccess)]
  868. [ProducesResponseType(StatusCodes.Status404NotFound)]
  869. [Obsolete("This endpoint is obsolete.")]
  870. public ActionResult<BaseItemDto> GetRecordingGroup([FromRoute, Required] Guid groupId)
  871. {
  872. return NotFound();
  873. }
  874. /// <summary>
  875. /// Get guid info.
  876. /// </summary>
  877. /// <response code="200">Guid info returned.</response>
  878. /// <returns>An <see cref="OkResult"/> containing the guide info.</returns>
  879. [HttpGet("GuideInfo")]
  880. [Authorize(Policy = Policies.LiveTvAccess)]
  881. [ProducesResponseType(StatusCodes.Status200OK)]
  882. public ActionResult<GuideInfo> GetGuideInfo()
  883. {
  884. return _liveTvManager.GetGuideInfo();
  885. }
  886. /// <summary>
  887. /// Adds a tuner host.
  888. /// </summary>
  889. /// <param name="tunerHostInfo">New tuner host.</param>
  890. /// <response code="200">Created tuner host returned.</response>
  891. /// <returns>A <see cref="OkResult"/> containing the created tuner host.</returns>
  892. [HttpPost("TunerHosts")]
  893. [Authorize(Policy = Policies.LiveTvManagement)]
  894. [ProducesResponseType(StatusCodes.Status200OK)]
  895. public async Task<ActionResult<TunerHostInfo>> AddTunerHost([FromBody] TunerHostInfo tunerHostInfo)
  896. {
  897. return await _liveTvManager.SaveTunerHost(tunerHostInfo).ConfigureAwait(false);
  898. }
  899. /// <summary>
  900. /// Deletes a tuner host.
  901. /// </summary>
  902. /// <param name="id">Tuner host id.</param>
  903. /// <response code="204">Tuner host deleted.</response>
  904. /// <returns>A <see cref="NoContentResult"/>.</returns>
  905. [HttpDelete("TunerHosts")]
  906. [Authorize(Policy = Policies.LiveTvManagement)]
  907. [ProducesResponseType(StatusCodes.Status204NoContent)]
  908. public ActionResult DeleteTunerHost([FromQuery] string? id)
  909. {
  910. var config = _configurationManager.GetConfiguration<LiveTvOptions>("livetv");
  911. config.TunerHosts = config.TunerHosts.Where(i => !string.Equals(id, i.Id, StringComparison.OrdinalIgnoreCase)).ToArray();
  912. _configurationManager.SaveConfiguration("livetv", config);
  913. return NoContent();
  914. }
  915. /// <summary>
  916. /// Gets default listings provider info.
  917. /// </summary>
  918. /// <response code="200">Default listings provider info returned.</response>
  919. /// <returns>An <see cref="OkResult"/> containing the default listings provider info.</returns>
  920. [HttpGet("ListingProviders/Default")]
  921. [Authorize(Policy = Policies.LiveTvAccess)]
  922. [ProducesResponseType(StatusCodes.Status200OK)]
  923. public ActionResult<ListingsProviderInfo> GetDefaultListingProvider()
  924. {
  925. return new ListingsProviderInfo();
  926. }
  927. /// <summary>
  928. /// Adds a listings provider.
  929. /// </summary>
  930. /// <param name="pw">Password.</param>
  931. /// <param name="listingsProviderInfo">New listings info.</param>
  932. /// <param name="validateListings">Validate listings.</param>
  933. /// <param name="validateLogin">Validate login.</param>
  934. /// <response code="200">Created listings provider returned.</response>
  935. /// <returns>A <see cref="OkResult"/> containing the created listings provider.</returns>
  936. [HttpPost("ListingProviders")]
  937. [Authorize(Policy = Policies.LiveTvManagement)]
  938. [ProducesResponseType(StatusCodes.Status200OK)]
  939. [SuppressMessage("Microsoft.Performance", "CA5350:RemoveSha1", MessageId = "AddListingProvider", Justification = "Imported from ServiceStack")]
  940. public async Task<ActionResult<ListingsProviderInfo>> AddListingProvider(
  941. [FromQuery] string? pw,
  942. [FromBody] ListingsProviderInfo listingsProviderInfo,
  943. [FromQuery] bool validateListings = false,
  944. [FromQuery] bool validateLogin = false)
  945. {
  946. if (!string.IsNullOrEmpty(pw))
  947. {
  948. // TODO: remove ToLower when Convert.ToHexString supports lowercase
  949. // Schedules Direct requires the hex to be lowercase
  950. listingsProviderInfo.Password = Convert.ToHexString(SHA1.HashData(Encoding.UTF8.GetBytes(pw))).ToLowerInvariant();
  951. }
  952. return await _liveTvManager.SaveListingProvider(listingsProviderInfo, validateLogin, validateListings).ConfigureAwait(false);
  953. }
  954. /// <summary>
  955. /// Delete listing provider.
  956. /// </summary>
  957. /// <param name="id">Listing provider id.</param>
  958. /// <response code="204">Listing provider deleted.</response>
  959. /// <returns>A <see cref="NoContentResult"/>.</returns>
  960. [HttpDelete("ListingProviders")]
  961. [Authorize(Policy = Policies.LiveTvManagement)]
  962. [ProducesResponseType(StatusCodes.Status204NoContent)]
  963. public ActionResult DeleteListingProvider([FromQuery] string? id)
  964. {
  965. _liveTvManager.DeleteListingsProvider(id);
  966. return NoContent();
  967. }
  968. /// <summary>
  969. /// Gets available lineups.
  970. /// </summary>
  971. /// <param name="id">Provider id.</param>
  972. /// <param name="type">Provider type.</param>
  973. /// <param name="location">Location.</param>
  974. /// <param name="country">Country.</param>
  975. /// <response code="200">Available lineups returned.</response>
  976. /// <returns>A <see cref="OkResult"/> containing the available lineups.</returns>
  977. [HttpGet("ListingProviders/Lineups")]
  978. [Authorize(Policy = Policies.LiveTvAccess)]
  979. [ProducesResponseType(StatusCodes.Status200OK)]
  980. public async Task<ActionResult<IEnumerable<NameIdPair>>> GetLineups(
  981. [FromQuery] string? id,
  982. [FromQuery] string? type,
  983. [FromQuery] string? location,
  984. [FromQuery] string? country)
  985. {
  986. return await _liveTvManager.GetLineups(type, id, country, location).ConfigureAwait(false);
  987. }
  988. /// <summary>
  989. /// Gets available countries.
  990. /// </summary>
  991. /// <response code="200">Available countries returned.</response>
  992. /// <returns>A <see cref="FileResult"/> containing the available countries.</returns>
  993. [HttpGet("ListingProviders/SchedulesDirect/Countries")]
  994. [Authorize(Policy = Policies.LiveTvAccess)]
  995. [ProducesResponseType(StatusCodes.Status200OK)]
  996. [ProducesFile(MediaTypeNames.Application.Json)]
  997. public async Task<ActionResult> GetSchedulesDirectCountries()
  998. {
  999. var client = _httpClientFactory.CreateClient(NamedClient.Default);
  1000. // https://json.schedulesdirect.org/20141201/available/countries
  1001. // Can't dispose the response as it's required up the call chain.
  1002. var response = await client.GetAsync(new Uri("https://json.schedulesdirect.org/20141201/available/countries"))
  1003. .ConfigureAwait(false);
  1004. return File(await response.Content.ReadAsStreamAsync().ConfigureAwait(false), MediaTypeNames.Application.Json);
  1005. }
  1006. /// <summary>
  1007. /// Get channel mapping options.
  1008. /// </summary>
  1009. /// <param name="providerId">Provider id.</param>
  1010. /// <response code="200">Channel mapping options returned.</response>
  1011. /// <returns>An <see cref="OkResult"/> containing the channel mapping options.</returns>
  1012. [HttpGet("ChannelMappingOptions")]
  1013. [Authorize(Policy = Policies.LiveTvAccess)]
  1014. [ProducesResponseType(StatusCodes.Status200OK)]
  1015. public async Task<ActionResult<ChannelMappingOptionsDto>> GetChannelMappingOptions([FromQuery] string? providerId)
  1016. {
  1017. var config = _configurationManager.GetConfiguration<LiveTvOptions>("livetv");
  1018. var listingsProviderInfo = config.ListingProviders.First(i => string.Equals(providerId, i.Id, StringComparison.OrdinalIgnoreCase));
  1019. var listingsProviderName = _liveTvManager.ListingProviders.First(i => string.Equals(i.Type, listingsProviderInfo.Type, StringComparison.OrdinalIgnoreCase)).Name;
  1020. var tunerChannels = await _liveTvManager.GetChannelsForListingsProvider(providerId, CancellationToken.None)
  1021. .ConfigureAwait(false);
  1022. var providerChannels = await _liveTvManager.GetChannelsFromListingsProviderData(providerId, CancellationToken.None)
  1023. .ConfigureAwait(false);
  1024. var mappings = listingsProviderInfo.ChannelMappings;
  1025. return new ChannelMappingOptionsDto
  1026. {
  1027. TunerChannels = tunerChannels.Select(i => _liveTvManager.GetTunerChannelMapping(i, mappings, providerChannels)).ToList(),
  1028. ProviderChannels = providerChannels.Select(i => new NameIdPair
  1029. {
  1030. Name = i.Name,
  1031. Id = i.Id
  1032. }).ToList(),
  1033. Mappings = mappings,
  1034. ProviderName = listingsProviderName
  1035. };
  1036. }
  1037. /// <summary>
  1038. /// Set channel mappings.
  1039. /// </summary>
  1040. /// <param name="setChannelMappingDto">The set channel mapping dto.</param>
  1041. /// <response code="200">Created channel mapping returned.</response>
  1042. /// <returns>An <see cref="OkResult"/> containing the created channel mapping.</returns>
  1043. [HttpPost("ChannelMappings")]
  1044. [Authorize(Policy = Policies.LiveTvManagement)]
  1045. [ProducesResponseType(StatusCodes.Status200OK)]
  1046. public async Task<ActionResult<TunerChannelMapping>> SetChannelMapping([FromBody, Required] SetChannelMappingDto setChannelMappingDto)
  1047. {
  1048. return await _liveTvManager.SetChannelMapping(setChannelMappingDto.ProviderId, setChannelMappingDto.TunerChannelId, setChannelMappingDto.ProviderChannelId).ConfigureAwait(false);
  1049. }
  1050. /// <summary>
  1051. /// Get tuner host types.
  1052. /// </summary>
  1053. /// <response code="200">Tuner host types returned.</response>
  1054. /// <returns>An <see cref="OkResult"/> containing the tuner host types.</returns>
  1055. [HttpGet("TunerHosts/Types")]
  1056. [Authorize(Policy = Policies.LiveTvAccess)]
  1057. [ProducesResponseType(StatusCodes.Status200OK)]
  1058. public ActionResult<IEnumerable<NameIdPair>> GetTunerHostTypes()
  1059. {
  1060. return _liveTvManager.GetTunerHostTypes();
  1061. }
  1062. /// <summary>
  1063. /// Discover tuners.
  1064. /// </summary>
  1065. /// <param name="newDevicesOnly">Only discover new tuners.</param>
  1066. /// <response code="200">Tuners returned.</response>
  1067. /// <returns>An <see cref="OkResult"/> containing the tuners.</returns>
  1068. [HttpGet("Tuners/Discvover", Name = "DiscvoverTuners")]
  1069. [HttpGet("Tuners/Discover")]
  1070. [Authorize(Policy = Policies.LiveTvManagement)]
  1071. [ProducesResponseType(StatusCodes.Status200OK)]
  1072. public async Task<ActionResult<IEnumerable<TunerHostInfo>>> DiscoverTuners([FromQuery] bool newDevicesOnly = false)
  1073. {
  1074. return await _liveTvManager.DiscoverTuners(newDevicesOnly, CancellationToken.None).ConfigureAwait(false);
  1075. }
  1076. /// <summary>
  1077. /// Gets a live tv recording stream.
  1078. /// </summary>
  1079. /// <param name="recordingId">Recording id.</param>
  1080. /// <response code="200">Recording stream returned.</response>
  1081. /// <response code="404">Recording not found.</response>
  1082. /// <returns>
  1083. /// An <see cref="OkResult"/> containing the recording stream on success,
  1084. /// or a <see cref="NotFoundResult"/> if recording not found.
  1085. /// </returns>
  1086. [HttpGet("LiveRecordings/{recordingId}/stream")]
  1087. [ProducesResponseType(StatusCodes.Status200OK)]
  1088. [ProducesResponseType(StatusCodes.Status404NotFound)]
  1089. [ProducesVideoFile]
  1090. public ActionResult GetLiveRecordingFile([FromRoute, Required] string recordingId)
  1091. {
  1092. var path = _liveTvManager.GetEmbyTvActiveRecordingPath(recordingId);
  1093. if (string.IsNullOrWhiteSpace(path))
  1094. {
  1095. return NotFound();
  1096. }
  1097. var stream = new ProgressiveFileStream(path, null, _transcodingJobHelper);
  1098. return new FileStreamResult(stream, MimeTypes.GetMimeType(path));
  1099. }
  1100. /// <summary>
  1101. /// Gets a live tv channel stream.
  1102. /// </summary>
  1103. /// <param name="streamId">Stream id.</param>
  1104. /// <param name="container">Container type.</param>
  1105. /// <response code="200">Stream returned.</response>
  1106. /// <response code="404">Stream not found.</response>
  1107. /// <returns>
  1108. /// An <see cref="OkResult"/> containing the channel stream on success,
  1109. /// or a <see cref="NotFoundResult"/> if stream not found.
  1110. /// </returns>
  1111. [HttpGet("LiveStreamFiles/{streamId}/stream.{container}")]
  1112. [ProducesResponseType(StatusCodes.Status200OK)]
  1113. [ProducesResponseType(StatusCodes.Status404NotFound)]
  1114. [ProducesVideoFile]
  1115. public ActionResult GetLiveStreamFile([FromRoute, Required] string streamId, [FromRoute, Required] string container)
  1116. {
  1117. var liveStreamInfo = _mediaSourceManager.GetLiveStreamInfoByUniqueId(streamId);
  1118. if (liveStreamInfo is null)
  1119. {
  1120. return NotFound();
  1121. }
  1122. var liveStream = new ProgressiveFileStream(liveStreamInfo.GetStream());
  1123. return new FileStreamResult(liveStream, MimeTypes.GetMimeType("file." + container));
  1124. }
  1125. }