LiveTvController.cs 56 KB

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