LiveTvController.cs 56 KB

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