LiveTvController.cs 62 KB

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