using MediaBrowser.Common.Configuration ;
using MediaBrowser.Common.Net ;
using MediaBrowser.Controller.Dto ;
using MediaBrowser.Controller.Library ;
using MediaBrowser.Controller.LiveTv ;
using MediaBrowser.Controller.Net ;
using MediaBrowser.Model.Dto ;
using MediaBrowser.Model.Entities ;
using MediaBrowser.Model.LiveTv ;
using MediaBrowser.Model.Querying ;
using ServiceStack ;
using System ;
using System.Collections.Generic ;
using System.Globalization ;
using System.IO ;
using System.Linq ;
using System.Threading ;
using System.Threading.Tasks ;
using CommonIO ;
using MediaBrowser.Api.Playback.Progressive ;
using MediaBrowser.Controller.Configuration ;
namespace MediaBrowser.Api.LiveTv
{
/// <summary>
/// This is insecure right now to avoid windows phone refactoring
/// </summary>
[Route("/LiveTv/Info", "GET", Summary = "Gets available live tv services.")]
[Authenticated]
public class GetLiveTvInfo : IReturn < LiveTvInfo >
{
}
[Route("/LiveTv/Channels", "GET", Summary = "Gets available live tv channels.")]
[Authenticated]
public class GetChannels : IReturn < QueryResult < ChannelInfoDto > > , IHasDtoOptions
{
[ApiMember(Name = "Type", Description = "Optional filter by channel type.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public ChannelType ? Type { get ; set ; }
[ApiMember(Name = "UserId", Description = "Optional filter by user and attach user data.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string UserId { get ; set ; }
/// <summary>
/// Skips over a given number of items within the results. Use for paging.
/// </summary>
/// <value>The start index.</value>
[ApiMember(Name = "StartIndex", Description = "Optional. The record index to start at. All items with a lower index will be dropped from the results.", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? StartIndex { get ; set ; }
[ApiMember(Name = "IsMovie", Description = "Optional filter for movies.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET,POST")]
public bool? IsMovie { get ; set ; }
[ApiMember(Name = "IsSeries", Description = "Optional filter for movies.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET,POST")]
public bool? IsSeries { get ; set ; }
[ApiMember(Name = "IsNews", Description = "Optional filter for news.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET,POST")]
public bool? IsNews { get ; set ; }
[ApiMember(Name = "IsKids", Description = "Optional filter for kids.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET,POST")]
public bool? IsKids { get ; set ; }
[ApiMember(Name = "IsSports", Description = "Optional filter for sports.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET,POST")]
public bool? IsSports { get ; set ; }
/// <summary>
/// The maximum number of items to return
/// </summary>
/// <value>The limit.</value>
[ApiMember(Name = "Limit", Description = "Optional. The maximum number of records to return", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? Limit { get ; set ; }
[ApiMember(Name = "IsFavorite", Description = "Filter by channels that are favorites, or not.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
public bool? IsFavorite { get ; set ; }
[ApiMember(Name = "IsLiked", Description = "Filter by channels that are liked, or not.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
public bool? IsLiked { get ; set ; }
[ApiMember(Name = "IsDisliked", Description = "Filter by channels that are disliked, or not.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
public bool? IsDisliked { get ; set ; }
[ApiMember(Name = "EnableFavoriteSorting", Description = "Incorporate favorite and like status into channel sorting.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
public bool EnableFavoriteSorting { get ; set ; }
[ApiMember(Name = "EnableImages", Description = "Optional, include image information in output", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "GET")]
public bool? EnableImages { get ; set ; }
[ApiMember(Name = "ImageTypeLimit", Description = "Optional, the max number of images to return, per image type", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? ImageTypeLimit { get ; set ; }
[ApiMember(Name = "EnableImageTypes", Description = "Optional. The image types to include in the output.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string EnableImageTypes { get ; set ; }
/// <summary>
/// Fields to return within the items, in addition to basic information
/// </summary>
/// <value>The fields.</value>
[ApiMember(Name = "Fields", Description = "Optional. Specify additional fields of information to return in the output. This allows multiple, comma delimeted. Options: Budget, Chapters, CriticRatingSummary, DateCreated, Genres, HomePageUrl, IndexOptions, MediaStreams, Overview, ParentId, Path, People, ProviderIds, PrimaryImageAspectRatio, Revenue, SortName, Studios, Taglines", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
public string Fields { get ; set ; }
[ApiMember(Name = "AddCurrentProgram", Description = "Optional. Adds current program info to each channel", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public bool AddCurrentProgram { get ; set ; }
[ApiMember(Name = "EnableUserData", Description = "Optional, include user data", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "GET")]
public bool? EnableUserData { get ; set ; }
public string SortBy { get ; set ; }
public SortOrder ? SortOrder { get ; set ; }
/// <summary>
/// Gets the order by.
/// </summary>
/// <returns>IEnumerable{ItemSortBy}.</returns>
public string [ ] GetOrderBy ( )
{
var val = SortBy ;
if ( string . IsNullOrEmpty ( val ) )
{
return new string [ ] { } ;
}
return val . Split ( ',' ) ;
}
public GetChannels ( )
{
AddCurrentProgram = true ;
}
}
[Route("/LiveTv/Channels/{Id}", "GET", Summary = "Gets a live tv channel")]
[Authenticated]
public class GetChannel : IReturn < ChannelInfoDto >
{
/// <summary>
/// Gets or sets the id.
/// </summary>
/// <value>The id.</value>
[ApiMember(Name = "Id", Description = "Channel Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
public string Id { get ; set ; }
[ApiMember(Name = "UserId", Description = "Optional attach user data.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string UserId { get ; set ; }
}
[Route("/LiveTv/Recordings", "GET", Summary = "Gets live tv recordings")]
[Authenticated]
public class GetRecordings : IReturn < QueryResult < BaseItemDto > > , IHasDtoOptions
{
[ApiMember(Name = "ChannelId", Description = "Optional filter by channel id.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string ChannelId { get ; set ; }
[ApiMember(Name = "UserId", Description = "Optional filter by user and attach user data.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string UserId { get ; set ; }
[ApiMember(Name = "GroupId", Description = "Optional filter by recording group.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string GroupId { get ; set ; }
[ApiMember(Name = "StartIndex", Description = "Optional. The record index to start at. All items with a lower index will be dropped from the results.", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? StartIndex { get ; set ; }
[ApiMember(Name = "Limit", Description = "Optional. The maximum number of records to return", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? Limit { get ; set ; }
[ApiMember(Name = "Status", Description = "Optional filter by recording status.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public RecordingStatus ? Status { get ; set ; }
[ApiMember(Name = "Status", Description = "Optional filter by recordings that are in progress, or not.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
public bool? IsInProgress { get ; set ; }
[ApiMember(Name = "SeriesTimerId", Description = "Optional filter by recordings belonging to a series timer", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string SeriesTimerId { get ; set ; }
[ApiMember(Name = "EnableImages", Description = "Optional, include image information in output", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "GET")]
public bool? EnableImages { get ; set ; }
[ApiMember(Name = "ImageTypeLimit", Description = "Optional, the max number of images to return, per image type", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? ImageTypeLimit { get ; set ; }
[ApiMember(Name = "EnableImageTypes", Description = "Optional. The image types to include in the output.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string EnableImageTypes { get ; set ; }
/// <summary>
/// Fields to return within the items, in addition to basic information
/// </summary>
/// <value>The fields.</value>
[ApiMember(Name = "Fields", Description = "Optional. Specify additional fields of information to return in the output. This allows multiple, comma delimeted. Options: Budget, Chapters, CriticRatingSummary, DateCreated, Genres, HomePageUrl, IndexOptions, MediaStreams, Overview, ParentId, Path, People, ProviderIds, PrimaryImageAspectRatio, Revenue, SortName, Studios, Taglines", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
public string Fields { get ; set ; }
public bool EnableTotalRecordCount { get ; set ; }
[ApiMember(Name = "EnableUserData", Description = "Optional, include user data", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "GET")]
public bool? EnableUserData { get ; set ; }
public bool? IsMovie { get ; set ; }
public bool? IsSeries { get ; set ; }
public bool? IsKids { get ; set ; }
public bool? IsSports { get ; set ; }
public bool? IsNews { get ; set ; }
public GetRecordings ( )
{
EnableTotalRecordCount = true ;
}
}
[Route("/LiveTv/Recordings/Series", "GET", Summary = "Gets live tv recordings")]
[Authenticated]
public class GetRecordingSeries : IReturn < QueryResult < BaseItemDto > > , IHasDtoOptions
{
[ApiMember(Name = "ChannelId", Description = "Optional filter by channel id.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string ChannelId { get ; set ; }
[ApiMember(Name = "UserId", Description = "Optional filter by user and attach user data.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string UserId { get ; set ; }
[ApiMember(Name = "GroupId", Description = "Optional filter by recording group.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string GroupId { get ; set ; }
[ApiMember(Name = "StartIndex", Description = "Optional. The record index to start at. All items with a lower index will be dropped from the results.", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? StartIndex { get ; set ; }
[ApiMember(Name = "Limit", Description = "Optional. The maximum number of records to return", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? Limit { get ; set ; }
[ApiMember(Name = "Status", Description = "Optional filter by recording status.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public RecordingStatus ? Status { get ; set ; }
[ApiMember(Name = "Status", Description = "Optional filter by recordings that are in progress, or not.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
public bool? IsInProgress { get ; set ; }
[ApiMember(Name = "SeriesTimerId", Description = "Optional filter by recordings belonging to a series timer", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string SeriesTimerId { get ; set ; }
[ApiMember(Name = "EnableImages", Description = "Optional, include image information in output", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "GET")]
public bool? EnableImages { get ; set ; }
[ApiMember(Name = "ImageTypeLimit", Description = "Optional, the max number of images to return, per image type", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? ImageTypeLimit { get ; set ; }
[ApiMember(Name = "EnableImageTypes", Description = "Optional. The image types to include in the output.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string EnableImageTypes { get ; set ; }
/// <summary>
/// Fields to return within the items, in addition to basic information
/// </summary>
/// <value>The fields.</value>
[ApiMember(Name = "Fields", Description = "Optional. Specify additional fields of information to return in the output. This allows multiple, comma delimeted. Options: Budget, Chapters, CriticRatingSummary, DateCreated, Genres, HomePageUrl, IndexOptions, MediaStreams, Overview, ParentId, Path, People, ProviderIds, PrimaryImageAspectRatio, Revenue, SortName, Studios, Taglines", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
public string Fields { get ; set ; }
public bool EnableTotalRecordCount { get ; set ; }
[ApiMember(Name = "EnableUserData", Description = "Optional, include user data", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "GET")]
public bool? EnableUserData { get ; set ; }
public GetRecordingSeries ( )
{
EnableTotalRecordCount = true ;
}
}
[Route("/LiveTv/Recordings/Groups", "GET", Summary = "Gets live tv recording groups")]
[Authenticated]
public class GetRecordingGroups : IReturn < QueryResult < BaseItemDto > >
{
[ApiMember(Name = "UserId", Description = "Optional filter by user and attach user data.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string UserId { get ; set ; }
}
[Route("/LiveTv/Recordings/{Id}", "GET", Summary = "Gets a live tv recording")]
[Authenticated]
public class GetRecording : IReturn < BaseItemDto >
{
[ApiMember(Name = "Id", Description = "Recording Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
public string Id { get ; set ; }
[ApiMember(Name = "UserId", Description = "Optional attach user data.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string UserId { get ; set ; }
}
[Route("/LiveTv/Tuners/{Id}/Reset", "POST", Summary = "Resets a tv tuner")]
[Authenticated]
public class ResetTuner : IReturnVoid
{
[ApiMember(Name = "Id", Description = "Tuner Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
public string Id { get ; set ; }
}
[Route("/LiveTv/Timers/{Id}", "GET", Summary = "Gets a live tv timer")]
[Authenticated]
public class GetTimer : IReturn < TimerInfoDto >
{
[ApiMember(Name = "Id", Description = "Timer Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
public string Id { get ; set ; }
}
[Route("/LiveTv/Timers/Defaults", "GET", Summary = "Gets default values for a new timer")]
[Authenticated]
public class GetDefaultTimer : IReturn < SeriesTimerInfoDto >
{
[ApiMember(Name = "ProgramId", Description = "Optional, to attach default values based on a program.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string ProgramId { get ; set ; }
}
[Route("/LiveTv/Timers", "GET", Summary = "Gets live tv timers")]
[Authenticated]
public class GetTimers : IReturn < QueryResult < TimerInfoDto > >
{
[ApiMember(Name = "ChannelId", Description = "Optional filter by channel id.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string ChannelId { get ; set ; }
[ApiMember(Name = "SeriesTimerId", Description = "Optional filter by timers belonging to a series timer", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string SeriesTimerId { get ; set ; }
public bool? IsActive { get ; set ; }
}
[Route("/LiveTv/Programs", "GET,POST", Summary = "Gets available live tv epgs..")]
[Authenticated]
public class GetPrograms : IReturn < QueryResult < BaseItemDto > > , IHasDtoOptions
{
[ApiMember(Name = "ChannelIds", Description = "The channels to return guide information for.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
public string ChannelIds { get ; set ; }
[ApiMember(Name = "UserId", Description = "Optional filter by user id.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
public string UserId { get ; set ; }
[ApiMember(Name = "MinStartDate", Description = "Optional. The minimum premiere date. Format = ISO", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
public string MinStartDate { get ; set ; }
[ApiMember(Name = "HasAired", Description = "Optional. Filter by programs that have completed airing, or not.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
public bool? HasAired { get ; set ; }
[ApiMember(Name = "MaxStartDate", Description = "Optional. The maximum premiere date. Format = ISO", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
public string MaxStartDate { get ; set ; }
[ApiMember(Name = "MinEndDate", Description = "Optional. The minimum premiere date. Format = ISO", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
public string MinEndDate { get ; set ; }
[ApiMember(Name = "MaxEndDate", Description = "Optional. The maximum premiere date. Format = ISO", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
public string MaxEndDate { get ; set ; }
[ApiMember(Name = "IsMovie", Description = "Optional filter for movies.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET,POST")]
public bool? IsMovie { get ; set ; }
[ApiMember(Name = "IsSeries", Description = "Optional filter for movies.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET,POST")]
public bool? IsSeries { get ; set ; }
[ApiMember(Name = "IsNews", Description = "Optional filter for news.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET,POST")]
public bool? IsNews { get ; set ; }
[ApiMember(Name = "IsKids", Description = "Optional filter for kids.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET,POST")]
public bool? IsKids { get ; set ; }
[ApiMember(Name = "IsSports", Description = "Optional filter for sports.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET,POST")]
public bool? IsSports { get ; set ; }
[ApiMember(Name = "StartIndex", Description = "Optional. The record index to start at. All items with a lower index will be dropped from the results.", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? StartIndex { get ; set ; }
[ApiMember(Name = "Limit", Description = "Optional. The maximum number of records to return", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? Limit { get ; set ; }
[ApiMember(Name = "SortBy", Description = "Optional. Specify one or more sort orders, comma delimeted. Options: Name, StartDate", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
public string SortBy { get ; set ; }
[ApiMember(Name = "SortOrder", Description = "Sort Order - Ascending,Descending", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public SortOrder ? SortOrder { get ; set ; }
[ApiMember(Name = "Genres", Description = "The genres to return guide information for.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
public string Genres { get ; set ; }
[ApiMember(Name = "EnableImages", Description = "Optional, include image information in output", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "GET")]
public bool? EnableImages { get ; set ; }
public bool EnableTotalRecordCount { get ; set ; }
[ApiMember(Name = "ImageTypeLimit", Description = "Optional, the max number of images to return, per image type", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? ImageTypeLimit { get ; set ; }
[ApiMember(Name = "EnableImageTypes", Description = "Optional. The image types to include in the output.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string EnableImageTypes { get ; set ; }
[ApiMember(Name = "EnableUserData", Description = "Optional, include user data", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "GET")]
public bool? EnableUserData { get ; set ; }
/// <summary>
/// Fields to return within the items, in addition to basic information
/// </summary>
/// <value>The fields.</value>
[ApiMember(Name = "Fields", Description = "Optional. Specify additional fields of information to return in the output. This allows multiple, comma delimeted. Options: Budget, Chapters, CriticRatingSummary, DateCreated, Genres, HomePageUrl, IndexOptions, MediaStreams, Overview, ParentId, Path, People, ProviderIds, PrimaryImageAspectRatio, Revenue, SortName, Studios, Taglines", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
public string Fields { get ; set ; }
public GetPrograms ( )
{
EnableTotalRecordCount = true ;
}
}
[Route("/LiveTv/Programs/Recommended", "GET", Summary = "Gets available live tv epgs..")]
[Authenticated]
public class GetRecommendedPrograms : IReturn < QueryResult < BaseItemDto > > , IHasDtoOptions
{
public bool EnableTotalRecordCount { get ; set ; }
public GetRecommendedPrograms ( )
{
EnableTotalRecordCount = true ;
}
[ApiMember(Name = "UserId", Description = "Optional filter by user id.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
public string UserId { get ; set ; }
[ApiMember(Name = "Limit", Description = "Optional. The maximum number of records to return", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? Limit { get ; set ; }
[ApiMember(Name = "IsAiring", Description = "Optional. Filter by programs that are currently airing, or not.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
public bool? IsAiring { get ; set ; }
[ApiMember(Name = "HasAired", Description = "Optional. Filter by programs that have completed airing, or not.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
public bool? HasAired { get ; set ; }
[ApiMember(Name = "IsSeries", Description = "Optional filter for movies.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET,POST")]
public bool? IsSeries { get ; set ; }
[ApiMember(Name = "IsMovie", Description = "Optional filter for movies.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET,POST")]
public bool? IsMovie { get ; set ; }
[ApiMember(Name = "IsNews", Description = "Optional filter for news.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET,POST")]
public bool? IsNews { get ; set ; }
[ApiMember(Name = "IsKids", Description = "Optional filter for kids.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET,POST")]
public bool? IsKids { get ; set ; }
[ApiMember(Name = "IsSports", Description = "Optional filter for sports.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET,POST")]
public bool? IsSports { get ; set ; }
[ApiMember(Name = "EnableImages", Description = "Optional, include image information in output", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "GET")]
public bool? EnableImages { get ; set ; }
[ApiMember(Name = "ImageTypeLimit", Description = "Optional, the max number of images to return, per image type", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? ImageTypeLimit { get ; set ; }
[ApiMember(Name = "EnableImageTypes", Description = "Optional. The image types to include in the output.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string EnableImageTypes { get ; set ; }
/// <summary>
/// Fields to return within the items, in addition to basic information
/// </summary>
/// <value>The fields.</value>
[ApiMember(Name = "Fields", Description = "Optional. Specify additional fields of information to return in the output. This allows multiple, comma delimeted. Options: Budget, Chapters, CriticRatingSummary, DateCreated, Genres, HomePageUrl, IndexOptions, MediaStreams, Overview, ParentId, Path, People, ProviderIds, PrimaryImageAspectRatio, Revenue, SortName, Studios, Taglines", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
public string Fields { get ; set ; }
[ApiMember(Name = "EnableUserData", Description = "Optional, include user data", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "GET")]
public bool? EnableUserData { get ; set ; }
}
[Route("/LiveTv/Programs/{Id}", "GET", Summary = "Gets a live tv program")]
[Authenticated]
public class GetProgram : IReturn < BaseItemDto >
{
[ApiMember(Name = "Id", Description = "Program Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
public string Id { get ; set ; }
[ApiMember(Name = "UserId", Description = "Optional attach user data.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string UserId { get ; set ; }
}
[Route("/LiveTv/Recordings/{Id}", "DELETE", Summary = "Deletes a live tv recording")]
[Authenticated]
public class DeleteRecording : IReturnVoid
{
[ApiMember(Name = "Id", Description = "Recording Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
public string Id { get ; set ; }
}
[Route("/LiveTv/Timers/{Id}", "DELETE", Summary = "Cancels a live tv timer")]
[Authenticated]
public class CancelTimer : IReturnVoid
{
[ApiMember(Name = "Id", Description = "Timer Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
public string Id { get ; set ; }
}
[Route("/LiveTv/Timers/{Id}", "POST", Summary = "Updates a live tv timer")]
[Authenticated]
public class UpdateTimer : TimerInfoDto , IReturnVoid
{
}
[Route("/LiveTv/Timers", "POST", Summary = "Creates a live tv timer")]
[Authenticated]
public class CreateTimer : TimerInfoDto , IReturnVoid
{
}
[Route("/LiveTv/SeriesTimers/{Id}", "GET", Summary = "Gets a live tv series timer")]
[Authenticated]
public class GetSeriesTimer : IReturn < TimerInfoDto >
{
[ApiMember(Name = "Id", Description = "Timer Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
public string Id { get ; set ; }
}
[Route("/LiveTv/SeriesTimers", "GET", Summary = "Gets live tv series timers")]
[Authenticated]
public class GetSeriesTimers : IReturn < QueryResult < SeriesTimerInfoDto > >
{
[ApiMember(Name = "SortBy", Description = "Optional. Sort by SortName or Priority", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
public string SortBy { get ; set ; }
[ApiMember(Name = "SortOrder", Description = "Optional. Sort in Ascending or Descending order", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
public SortOrder SortOrder { get ; set ; }
}
[Route("/LiveTv/SeriesTimers/{Id}", "DELETE", Summary = "Cancels a live tv series timer")]
[Authenticated]
public class CancelSeriesTimer : IReturnVoid
{
[ApiMember(Name = "Id", Description = "Timer Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
public string Id { get ; set ; }
}
[Route("/LiveTv/SeriesTimers/{Id}", "POST", Summary = "Updates a live tv series timer")]
[Authenticated]
public class UpdateSeriesTimer : SeriesTimerInfoDto , IReturnVoid
{
}
[Route("/LiveTv/SeriesTimers", "POST", Summary = "Creates a live tv series timer")]
[Authenticated]
public class CreateSeriesTimer : SeriesTimerInfoDto , IReturnVoid
{
}
[Route("/LiveTv/Recordings/Groups/{Id}", "GET", Summary = "Gets a recording group")]
[Authenticated]
public class GetRecordingGroup : IReturn < BaseItemDto >
{
[ApiMember(Name = "Id", Description = "Recording group Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
public string Id { get ; set ; }
}
[Route("/LiveTv/GuideInfo", "GET", Summary = "Gets guide info")]
[Authenticated]
public class GetGuideInfo : IReturn < GuideInfo >
{
}
[Route("/LiveTv/Folder", "GET", Summary = "Gets the users live tv folder, along with configured images")]
[Authenticated]
public class GetLiveTvFolder : IReturn < BaseItemDto >
{
[ApiMember(Name = "UserId", Description = "Optional attach user data.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string UserId { get ; set ; }
}
[Route("/LiveTv/TunerHosts", "POST", Summary = "Adds a tuner host")]
[Authenticated]
public class AddTunerHost : TunerHostInfo , IReturn < TunerHostInfo >
{
}
[Route("/LiveTv/TunerHosts", "DELETE", Summary = "Deletes a tuner host")]
[Authenticated]
public class DeleteTunerHost : IReturnVoid
{
[ApiMember(Name = "Id", Description = "Tuner host id", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "DELETE")]
public string Id { get ; set ; }
}
[Route("/LiveTv/ListingProviders/Default", "GET")]
[Authenticated(AllowBeforeStartupWizard = true)]
public class GetDefaultListingProvider : ListingsProviderInfo , IReturn < ListingsProviderInfo >
{
}
[Route("/LiveTv/ListingProviders", "POST", Summary = "Adds a listing provider")]
[Authenticated(AllowBeforeStartupWizard = true)]
public class AddListingProvider : ListingsProviderInfo , IReturn < ListingsProviderInfo >
{
public bool ValidateLogin { get ; set ; }
public bool ValidateListings { get ; set ; }
}
[Route("/LiveTv/ListingProviders", "DELETE", Summary = "Deletes a listing provider")]
[Authenticated(AllowBeforeStartupWizard = true)]
public class DeleteListingProvider : IReturnVoid
{
[ApiMember(Name = "Id", Description = "Provider id", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "DELETE")]
public string Id { get ; set ; }
}
[Route("/LiveTv/ListingProviders/Lineups", "GET", Summary = "Gets available lineups")]
[Authenticated(AllowBeforeStartupWizard = true)]
public class GetLineups : IReturn < List < NameIdPair > >
{
[ApiMember(Name = "Id", Description = "Provider id", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string Id { get ; set ; }
[ApiMember(Name = "Type", Description = "Provider Type", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string Type { get ; set ; }
[ApiMember(Name = "Location", Description = "Location", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string Location { get ; set ; }
[ApiMember(Name = "Country", Description = "Country", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string Country { get ; set ; }
}
[Route("/LiveTv/ListingProviders/SchedulesDirect/Countries", "GET", Summary = "Gets available lineups")]
[Authenticated(AllowBeforeStartupWizard = true)]
public class GetSchedulesDirectCountries
{
}
[Route("/LiveTv/ChannelMappingOptions")]
[Authenticated(AllowBeforeStartupWizard = true)]
public class GetChannelMappingOptions
{
[ApiMember(Name = "Id", Description = "Provider id", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "GET")]
public string ProviderId { get ; set ; }
}
[Route("/LiveTv/ChannelMappings")]
[Authenticated(AllowBeforeStartupWizard = true)]
public class SetChannelMapping
{
[ApiMember(Name = "Id", Description = "Provider id", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "GET")]
public string ProviderId { get ; set ; }
public string TunerChannelNumber { get ; set ; }
public string ProviderChannelNumber { get ; set ; }
}
public class ChannelMappingOptions
{
public List < TunerChannelMapping > TunerChannels { get ; set ; }
public List < NameIdPair > ProviderChannels { get ; set ; }
public List < NameValuePair > Mappings { get ; set ; }
public string ProviderName { get ; set ; }
}
[Route("/LiveTv/Registration", "GET")]
[Authenticated]
public class GetLiveTvRegistrationInfo : IReturn < MBRegistrationRecord >
{
[ApiMember(Name = "Feature", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string Feature { get ; set ; }
}
[Route("/LiveTv/TunerHosts/Satip/IniMappings", "GET", Summary = "Gets available mappings")]
[Authenticated(AllowBeforeStartupWizard = true)]
public class GetSatIniMappings : IReturn < List < NameValuePair > >
{
}
[Route("/LiveTv/TunerHosts/Satip/ChannelScan", "GET", Summary = "Scans for available channels")]
[Authenticated(AllowBeforeStartupWizard = true)]
public class GetSatChannnelScanResult : TunerHostInfo
{
}
[Route("/LiveTv/LiveStreamFiles/{Id}/stream.{Container}", "GET", Summary = "Gets a live tv channel")]
public class GetLiveStreamFile
{
public string Id { get ; set ; }
public string Container { get ; set ; }
public long T { get ; set ; }
public long S { get ; set ; }
}
public class LiveTvService : BaseApiService
{
private readonly ILiveTvManager _liveTvManager ;
private readonly IUserManager _userManager ;
private readonly IServerConfigurationManager _config ;
private readonly IHttpClient _httpClient ;
private readonly ILibraryManager _libraryManager ;
private readonly IDtoService _dtoService ;
private readonly IFileSystem _fileSystem ;
public LiveTvService ( ILiveTvManager liveTvManager , IUserManager userManager , IServerConfigurationManager config , IHttpClient httpClient , ILibraryManager libraryManager , IDtoService dtoService , IFileSystem fileSystem )
{
_liveTvManager = liveTvManager ;
_userManager = userManager ;
_config = config ;
_httpClient = httpClient ;
_libraryManager = libraryManager ;
_dtoService = dtoService ;
_fileSystem = fileSystem ;
}
public object Get ( GetLiveStreamFile request )
{
var filePath = Path . Combine ( _config . ApplicationPaths . TranscodingTempPath , request . Id + ".ts" ) ;
var outputHeaders = new Dictionary < string , string > ( StringComparer . OrdinalIgnoreCase ) ;
outputHeaders [ "Content-Type" ] = MimeTypes . GetMimeType ( filePath ) ;
long startPosition = 0 ;
if ( request . T > 0 )
{
var now = DateTime . UtcNow ;
var totalTicks = now . Ticks - request . S ;
if ( totalTicks > 0 )
{
double requestedOffset = request . T ;
requestedOffset = Math . Max ( 0 , requestedOffset - TimeSpan . FromSeconds ( 10 ) . Ticks ) ;
var pct = requestedOffset / totalTicks ;
Logger . Info ( "Live stream offset pct {0}" , pct ) ;
var bytes = new FileInfo ( filePath ) . Length ;
Logger . Info ( "Live stream total bytes {0}" , bytes ) ;
startPosition = Convert . ToInt64 ( pct * bytes ) ;
}
}
Logger . Info ( "Live stream starting byte position {0}" , startPosition ) ;
var streamSource = new ProgressiveFileCopier ( _fileSystem , filePath , outputHeaders , null , Logger , CancellationToken . None )
{
AllowEndOfFile = false ,
StartPosition = startPosition
} ;
return ResultFactory . GetAsyncStreamWriter ( streamSource ) ;
}
public object Get ( GetDefaultListingProvider request )
{
return ToOptimizedResult ( new ListingsProviderInfo ( ) ) ;
}
public async Task < object > Get ( GetSatChannnelScanResult request )
{
var result = await _liveTvManager . GetSatChannelScanResult ( request , CancellationToken . None ) . ConfigureAwait ( false ) ;
return ToOptimizedResult ( result ) ;
}
public async Task < object > Get ( GetLiveTvRegistrationInfo request )
{
var result = await _liveTvManager . GetRegistrationInfo ( request . Feature ) . ConfigureAwait ( false ) ;
return ToOptimizedResult ( result ) ;
}
public async Task < object > Post ( SetChannelMapping request )
{
return await _liveTvManager . SetChannelMapping ( request . ProviderId , request . TunerChannelNumber , request . ProviderChannelNumber ) . ConfigureAwait ( false ) ;
}
public async Task < object > Get ( GetChannelMappingOptions request )
{
var config = GetConfiguration ( ) ;
var listingsProviderInfo = config . ListingProviders . First ( i = > string . Equals ( request . ProviderId , i . Id , StringComparison . OrdinalIgnoreCase ) ) ;
var listingsProviderName = _liveTvManager . ListingProviders . First ( i = > string . Equals ( i . Type , listingsProviderInfo . Type , StringComparison . OrdinalIgnoreCase ) ) . Name ;
var tunerChannels = await _liveTvManager . GetChannelsForListingsProvider ( request . ProviderId , CancellationToken . None )
. ConfigureAwait ( false ) ;
var providerChannels = await _liveTvManager . GetChannelsFromListingsProviderData ( request . ProviderId , CancellationToken . None )
. ConfigureAwait ( false ) ;
var mappings = listingsProviderInfo . ChannelMappings . ToList ( ) ;
var result = new ChannelMappingOptions
{
TunerChannels = tunerChannels . Select ( i = > _liveTvManager . GetTunerChannelMapping ( i , mappings , providerChannels ) ) . ToList ( ) ,
ProviderChannels = providerChannels . Select ( i = > new NameIdPair
{
Name = i . Name ,
Id = i . Number
} ) . ToList ( ) ,
Mappings = mappings ,
ProviderName = listingsProviderName
} ;
return ToOptimizedResult ( result ) ;
}
public object Get ( GetSatIniMappings request )
{
return ToOptimizedResult ( _liveTvManager . GetSatIniMappings ( ) ) ;
}
public async Task < object > Get ( GetSchedulesDirectCountries request )
{
// https://json.schedulesdirect.org/20141201/available/countries
var response = await _httpClient . Get ( new HttpRequestOptions
{
Url = "https://json.schedulesdirect.org/20141201/available/countries"
} ) . ConfigureAwait ( false ) ;
return ResultFactory . GetResult ( response , "application/json" ) ;
}
private void AssertUserCanManageLiveTv ( )
{
var user = SessionContext . GetUser ( Request ) . Result ;
if ( user = = null )
{
throw new SecurityException ( "Anonymous live tv management is not allowed." ) ;
}
if ( ! user . Policy . EnableLiveTvManagement )
{
throw new SecurityException ( "The current user does not have permission to manage live tv." ) ;
}
}
public async Task < object > Post ( AddListingProvider request )
{
var result = await _liveTvManager . SaveListingProvider ( request , request . ValidateLogin , request . ValidateListings ) . ConfigureAwait ( false ) ;
return ToOptimizedResult ( result ) ;
}
public void Delete ( DeleteListingProvider request )
{
_liveTvManager . DeleteListingsProvider ( request . Id ) ;
}
public async Task < object > Post ( AddTunerHost request )
{
var result = await _liveTvManager . SaveTunerHost ( request ) . ConfigureAwait ( false ) ;
return ToOptimizedResult ( result ) ;
}
public void Delete ( DeleteTunerHost request )
{
var config = GetConfiguration ( ) ;
config . TunerHosts = config . TunerHosts . Where ( i = > ! string . Equals ( request . Id , i . Id , StringComparison . OrdinalIgnoreCase ) ) . ToList ( ) ;
_config . SaveConfiguration ( "livetv" , config ) ;
}
private LiveTvOptions GetConfiguration ( )
{
return _config . GetConfiguration < LiveTvOptions > ( "livetv" ) ;
}
private void UpdateConfiguration ( LiveTvOptions options )
{
_config . SaveConfiguration ( "livetv" , options ) ;
}
public async Task < object > Get ( GetLineups request )
{
var info = await _liveTvManager . GetLineups ( request . Type , request . Id , request . Country , request . Location ) . ConfigureAwait ( false ) ;
return ToOptimizedSerializedResultUsingCache ( info ) ;
}
public async Task < object > Get ( GetLiveTvInfo request )
{
var info = await _liveTvManager . GetLiveTvInfo ( CancellationToken . None ) . ConfigureAwait ( false ) ;
return ToOptimizedSerializedResultUsingCache ( info ) ;
}
public async Task < object > Get ( GetChannels request )
{
var channelResult = await _liveTvManager . GetInternalChannels ( new LiveTvChannelQuery
{
ChannelType = request . Type ,
UserId = request . UserId ,
StartIndex = request . StartIndex ,
Limit = request . Limit ,
IsFavorite = request . IsFavorite ,
IsLiked = request . IsLiked ,
IsDisliked = request . IsDisliked ,
EnableFavoriteSorting = request . EnableFavoriteSorting ,
IsMovie = request . IsMovie ,
IsSeries = request . IsSeries ,
IsNews = request . IsNews ,
IsKids = request . IsKids ,
IsSports = request . IsSports ,
SortBy = request . GetOrderBy ( ) ,
SortOrder = request . SortOrder ? ? SortOrder . Ascending ,
AddCurrentProgram = request . AddCurrentProgram
} , CancellationToken . None ) . ConfigureAwait ( false ) ;
var user = string . IsNullOrEmpty ( request . UserId ) ? null : _userManager . GetUserById ( request . UserId ) ;
var options = GetDtoOptions ( request ) ;
RemoveFields ( options ) ;
options . AddCurrentProgram = request . AddCurrentProgram ;
var returnArray = ( await _dtoService . GetBaseItemDtos ( channelResult . Items , options , user ) . ConfigureAwait ( false ) ) . ToArray ( ) ;
var result = new QueryResult < BaseItemDto >
{
Items = returnArray ,
TotalRecordCount = channelResult . TotalRecordCount
} ;
return ToOptimizedSerializedResultUsingCache ( result ) ;
}
private void RemoveFields ( DtoOptions options )
{
options . Fields . Remove ( ItemFields . CanDelete ) ;
options . Fields . Remove ( ItemFields . CanDownload ) ;
options . Fields . Remove ( ItemFields . DisplayPreferencesId ) ;
options . Fields . Remove ( ItemFields . Etag ) ;
}
public object Get ( GetChannel request )
{
var user = string . IsNullOrWhiteSpace ( request . UserId ) ? null : _userManager . GetUserById ( request . UserId ) ;
var item = _libraryManager . GetItemById ( request . Id ) ;
var dtoOptions = GetDtoOptions ( request ) ;
var result = _dtoService . GetBaseItemDto ( item , dtoOptions , user ) ;
return ToOptimizedSerializedResultUsingCache ( result ) ;
}
public async Task < object > Get ( GetLiveTvFolder request )
{
return ToOptimizedResult ( await _liveTvManager . GetLiveTvFolder ( request . UserId , CancellationToken . None ) . ConfigureAwait ( false ) ) ;
}
public async Task < object > Get ( GetPrograms request )
{
var query = new ProgramQuery
{
ChannelIds = ( request . ChannelIds ? ? string . Empty ) . Split ( new [ ] { ',' } , StringSplitOptions . RemoveEmptyEntries ) . ToArray ( ) ,
UserId = request . UserId ,
HasAired = request . HasAired ,
EnableTotalRecordCount = request . EnableTotalRecordCount
} ;
if ( ! string . IsNullOrEmpty ( request . MinStartDate ) )
{
query . MinStartDate = DateTime . Parse ( request . MinStartDate , null , DateTimeStyles . RoundtripKind ) . ToUniversalTime ( ) ;
}
if ( ! string . IsNullOrEmpty ( request . MinEndDate ) )
{
query . MinEndDate = DateTime . Parse ( request . MinEndDate , null , DateTimeStyles . RoundtripKind ) . ToUniversalTime ( ) ;
}
if ( ! string . IsNullOrEmpty ( request . MaxStartDate ) )
{
query . MaxStartDate = DateTime . Parse ( request . MaxStartDate , null , DateTimeStyles . RoundtripKind ) . ToUniversalTime ( ) ;
}
if ( ! string . IsNullOrEmpty ( request . MaxEndDate ) )
{
query . MaxEndDate = DateTime . Parse ( request . MaxEndDate , null , DateTimeStyles . RoundtripKind ) . ToUniversalTime ( ) ;
}
query . StartIndex = request . StartIndex ;
query . Limit = request . Limit ;
query . SortBy = ( request . SortBy ? ? String . Empty ) . Split ( new [ ] { ',' } , StringSplitOptions . RemoveEmptyEntries ) ;
query . SortOrder = request . SortOrder ;
query . IsNews = request . IsNews ;
query . IsMovie = request . IsMovie ;
query . IsSeries = request . IsSeries ;
query . IsKids = request . IsKids ;
query . IsSports = request . IsSports ;
query . Genres = ( request . Genres ? ? String . Empty ) . Split ( new [ ] { ',' } , StringSplitOptions . RemoveEmptyEntries ) ;
var result = await _liveTvManager . GetPrograms ( query , GetDtoOptions ( request ) , CancellationToken . None ) . ConfigureAwait ( false ) ;
return ToOptimizedResult ( result ) ;
}
public async Task < object > Get ( GetRecommendedPrograms request )
{
var query = new RecommendedProgramQuery
{
UserId = request . UserId ,
IsAiring = request . IsAiring ,
Limit = request . Limit ,
HasAired = request . HasAired ,
IsSeries = request . IsSeries ,
IsMovie = request . IsMovie ,
IsKids = request . IsKids ,
IsNews = request . IsNews ,
IsSports = request . IsSports ,
EnableTotalRecordCount = request . EnableTotalRecordCount
} ;
var result = await _liveTvManager . GetRecommendedPrograms ( query , GetDtoOptions ( request ) , CancellationToken . None ) . ConfigureAwait ( false ) ;
return ToOptimizedResult ( result ) ;
}
public object Post ( GetPrograms request )
{
return Get ( request ) ;
}
public async Task < object > Get ( GetRecordings request )
{
var options = GetDtoOptions ( request ) ;
options . DeviceId = AuthorizationContext . GetAuthorizationInfo ( Request ) . DeviceId ;
var result = await _liveTvManager . GetRecordings ( new RecordingQuery
{
ChannelId = request . ChannelId ,
UserId = request . UserId ,
GroupId = request . GroupId ,
StartIndex = request . StartIndex ,
Limit = request . Limit ,
Status = request . Status ,
SeriesTimerId = request . SeriesTimerId ,
IsInProgress = request . IsInProgress ,
EnableTotalRecordCount = request . EnableTotalRecordCount ,
IsMovie = request . IsMovie ,
IsNews = request . IsNews ,
IsSeries = request . IsSeries ,
IsKids = request . IsKids ,
IsSports = request . IsSports
} , options , CancellationToken . None ) . ConfigureAwait ( false ) ;
return ToOptimizedResult ( result ) ;
}
public async Task < object > Get ( GetRecordingSeries request )
{
var options = GetDtoOptions ( request ) ;
options . DeviceId = AuthorizationContext . GetAuthorizationInfo ( Request ) . DeviceId ;
var result = await _liveTvManager . GetRecordingSeries ( new RecordingQuery
{
ChannelId = request . ChannelId ,
UserId = request . UserId ,
GroupId = request . GroupId ,
StartIndex = request . StartIndex ,
Limit = request . Limit ,
Status = request . Status ,
SeriesTimerId = request . SeriesTimerId ,
IsInProgress = request . IsInProgress ,
EnableTotalRecordCount = request . EnableTotalRecordCount
} , options , CancellationToken . None ) . ConfigureAwait ( false ) ;
return ToOptimizedResult ( result ) ;
}
public async Task < object > Get ( GetRecording request )
{
var user = string . IsNullOrEmpty ( request . UserId ) ? null : _userManager . GetUserById ( request . UserId ) ;
var options = new DtoOptions ( ) ;
options . DeviceId = AuthorizationContext . GetAuthorizationInfo ( Request ) . DeviceId ;
var result = await _liveTvManager . GetRecording ( request . Id , options , CancellationToken . None , user ) . ConfigureAwait ( false ) ;
return ToOptimizedSerializedResultUsingCache ( result ) ;
}
public async Task < object > Get ( GetTimer request )
{
var result = await _liveTvManager . GetTimer ( request . Id , CancellationToken . None ) . ConfigureAwait ( false ) ;
return ToOptimizedSerializedResultUsingCache ( result ) ;
}
public async Task < object > Get ( GetTimers request )
{
var result = await _liveTvManager . GetTimers ( new TimerQuery
{
ChannelId = request . ChannelId ,
SeriesTimerId = request . SeriesTimerId ,
IsActive = request . IsActive
} , CancellationToken . None ) . ConfigureAwait ( false ) ;
return ToOptimizedSerializedResultUsingCache ( result ) ;
}
public void Delete ( DeleteRecording request )
{
AssertUserCanManageLiveTv ( ) ;
var task = _liveTvManager . DeleteRecording ( request . Id ) ;
Task . WaitAll ( task ) ;
}
public void Delete ( CancelTimer request )
{
AssertUserCanManageLiveTv ( ) ;
var task = _liveTvManager . CancelTimer ( request . Id ) ;
Task . WaitAll ( task ) ;
}
public void Post ( UpdateTimer request )
{
AssertUserCanManageLiveTv ( ) ;
var task = _liveTvManager . UpdateTimer ( request , CancellationToken . None ) ;
Task . WaitAll ( task ) ;
}
public async Task < object > Get ( GetSeriesTimers request )
{
var result = await _liveTvManager . GetSeriesTimers ( new SeriesTimerQuery
{
SortOrder = request . SortOrder ,
SortBy = request . SortBy
} , CancellationToken . None ) . ConfigureAwait ( false ) ;
return ToOptimizedSerializedResultUsingCache ( result ) ;
}
public async Task < object > Get ( GetSeriesTimer request )
{
var result = await _liveTvManager . GetSeriesTimer ( request . Id , CancellationToken . None ) . ConfigureAwait ( false ) ;
return ToOptimizedSerializedResultUsingCache ( result ) ;
}
public void Delete ( CancelSeriesTimer request )
{
AssertUserCanManageLiveTv ( ) ;
var task = _liveTvManager . CancelSeriesTimer ( request . Id ) ;
Task . WaitAll ( task ) ;
}
public void Post ( UpdateSeriesTimer request )
{
AssertUserCanManageLiveTv ( ) ;
var task = _liveTvManager . UpdateSeriesTimer ( request , CancellationToken . None ) ;
Task . WaitAll ( task ) ;
}
public async Task < object > Get ( GetDefaultTimer request )
{
if ( string . IsNullOrEmpty ( request . ProgramId ) )
{
var result = await _liveTvManager . GetNewTimerDefaults ( CancellationToken . None ) . ConfigureAwait ( false ) ;
return ToOptimizedSerializedResultUsingCache ( result ) ;
}
else
{
var result = await _liveTvManager . GetNewTimerDefaults ( request . ProgramId , CancellationToken . None ) . ConfigureAwait ( false ) ;
return ToOptimizedSerializedResultUsingCache ( result ) ;
}
}
public async Task < object > Get ( GetProgram request )
{
var user = string . IsNullOrEmpty ( request . UserId ) ? null : _userManager . GetUserById ( request . UserId ) ;
var result = await _liveTvManager . GetProgram ( request . Id , CancellationToken . None , user ) . ConfigureAwait ( false ) ;
return ToOptimizedSerializedResultUsingCache ( result ) ;
}
public void Post ( CreateSeriesTimer request )
{
AssertUserCanManageLiveTv ( ) ;
var task = _liveTvManager . CreateSeriesTimer ( request , CancellationToken . None ) ;
Task . WaitAll ( task ) ;
}
public void Post ( CreateTimer request )
{
AssertUserCanManageLiveTv ( ) ;
var task = _liveTvManager . CreateTimer ( request , CancellationToken . None ) ;
Task . WaitAll ( task ) ;
}
public async Task < object > Get ( GetRecordingGroups request )
{
var result = await _liveTvManager . GetRecordingGroups ( new RecordingGroupQuery
{
UserId = request . UserId
} , CancellationToken . None ) . ConfigureAwait ( false ) ;
return ToOptimizedSerializedResultUsingCache ( result ) ;
}
public async Task < object > Get ( GetRecordingGroup request )
{
var result = await _liveTvManager . GetRecordingGroups ( new RecordingGroupQuery ( ) , CancellationToken . None ) . ConfigureAwait ( false ) ;
var group = result . Items . FirstOrDefault ( i = > string . Equals ( i . Id , request . Id , StringComparison . OrdinalIgnoreCase ) ) ;
return ToOptimizedSerializedResultUsingCache ( group ) ;
}
public object Get ( GetGuideInfo request )
{
return ToOptimizedResult ( _liveTvManager . GetGuideInfo ( ) ) ;
}
public void Post ( ResetTuner request )
{
AssertUserCanManageLiveTv ( ) ;
var task = _liveTvManager . ResetTuner ( request . Id , CancellationToken . None ) ;
Task . WaitAll ( task ) ;
}
}
}