2013-11-01 15:59:42 +00:00
using MediaBrowser.Common.IO ;
2013-12-15 19:39:21 +00:00
using MediaBrowser.Controller.Configuration ;
2013-09-04 17:02:19 +00:00
using MediaBrowser.Controller.Dto ;
2013-02-27 23:33:40 +00:00
using MediaBrowser.Controller.Library ;
2013-12-21 18:37:34 +00:00
using MediaBrowser.Controller.LiveTv ;
2014-01-12 06:31:21 +00:00
using MediaBrowser.Controller.MediaInfo ;
2013-12-06 03:39:44 +00:00
using MediaBrowser.Controller.Persistence ;
2013-08-10 01:16:31 +00:00
using MediaBrowser.Model.IO ;
2013-12-07 15:52:38 +00:00
using ServiceStack ;
2013-07-02 18:24:29 +00:00
using System ;
2014-01-13 05:41:00 +00:00
using System.IO ;
using System.Linq ;
2014-01-12 21:32:13 +00:00
using System.Threading.Tasks ;
2013-02-27 23:33:40 +00:00
namespace MediaBrowser.Api.Playback.Hls
{
2013-04-29 16:01:23 +00:00
/// <summary>
/// Class GetHlsVideoStream
/// </summary>
2013-03-09 06:13:10 +00:00
[Route("/Videos/{Id}/stream.m3u8", "GET")]
2013-03-28 14:42:03 +00:00
[Api(Description = "Gets a video stream using HTTP live streaming.")]
2013-03-09 06:13:10 +00:00
public class GetHlsVideoStream : VideoStreamRequest
{
2013-09-06 17:27:06 +00:00
[ApiMember(Name = "BaselineStreamAudioBitRate", Description = "Optional. Specify the audio bitrate for the baseline stream.", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? BaselineStreamAudioBitRate { get ; set ; }
2013-03-09 06:13:10 +00:00
2013-09-06 17:27:06 +00:00
[ApiMember(Name = "AppendBaselineStream", Description = "Optional. Whether or not to include a baseline audio-only stream in the master playlist.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
public bool AppendBaselineStream { get ; set ; }
2013-09-19 20:03:14 +00:00
[ApiMember(Name = "TimeStampOffsetMs", Description = "Optional. Alter the timestamps in the playlist by a given amount, in ms. Default is 1000.", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int TimeStampOffsetMs { get ; set ; }
2013-03-09 06:13:10 +00:00
}
2014-01-13 05:41:00 +00:00
/// <summary>
/// Class GetHlsVideoSegment
/// </summary>
[Route("/Videos/{Id}/hls/{PlaylistId}/{SegmentId}.ts", "GET")]
[Api(Description = "Gets an Http live streaming segment file. Internal use only.")]
2014-01-23 18:05:41 +00:00
public class GetHlsVideoSegment : VideoStreamRequest
2014-01-13 05:41:00 +00:00
{
/// <summary>
/// Gets or sets the id.
/// </summary>
/// <value>The id.</value>
public string Id { get ; set ; }
public string PlaylistId { get ; set ; }
/// <summary>
/// Gets or sets the segment id.
/// </summary>
/// <value>The segment id.</value>
public string SegmentId { get ; set ; }
}
2013-04-29 16:01:23 +00:00
/// <summary>
/// Class VideoHlsService
/// </summary>
2013-02-27 23:33:40 +00:00
public class VideoHlsService : BaseHlsService
{
2013-12-21 18:37:34 +00:00
public VideoHlsService ( IServerConfigurationManager serverConfig , IUserManager userManager , ILibraryManager libraryManager , IIsoManager isoManager , IMediaEncoder mediaEncoder , IDtoService dtoService , IFileSystem fileSystem , IItemRepository itemRepository , ILiveTvManager liveTvManager )
: base ( serverConfig , userManager , libraryManager , isoManager , mediaEncoder , dtoService , fileSystem , itemRepository , liveTvManager )
2013-02-27 23:33:40 +00:00
{
}
2014-01-13 05:41:00 +00:00
/// <summary>
/// Gets the specified request.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>System.Object.</returns>
public object Get ( GetHlsVideoSegment request )
{
var file = request . SegmentId + Path . GetExtension ( Request . PathInfo ) ;
file = Path . Combine ( ServerConfigurationManager . ApplicationPaths . TranscodingTempPath , file ) ;
OnBeginRequest ( request . PlaylistId ) ;
return ResultFactory . GetStaticFileResult ( Request , file ) ;
}
2014-01-23 18:05:41 +00:00
/// <summary>
/// Called when [begin request].
/// </summary>
/// <param name="playlistId">The playlist id.</param>
protected void OnBeginRequest ( string playlistId )
2014-01-12 21:32:13 +00:00
{
2014-01-23 18:05:41 +00:00
var normalizedPlaylistId = playlistId . Replace ( "-low" , string . Empty ) ;
2014-01-12 21:32:13 +00:00
2014-01-23 18:05:41 +00:00
foreach ( var playlist in Directory . EnumerateFiles ( ServerConfigurationManager . ApplicationPaths . TranscodingTempPath , "*.m3u8" )
. Where ( i = > i . IndexOf ( normalizedPlaylistId , StringComparison . OrdinalIgnoreCase ) ! = - 1 )
. ToList ( ) )
2014-01-12 21:32:13 +00:00
{
2014-01-23 18:05:41 +00:00
ExtendPlaylistTimer ( playlist ) ;
2014-01-12 21:32:13 +00:00
}
}
2014-01-23 18:05:41 +00:00
private async void ExtendPlaylistTimer ( string playlist )
2014-01-12 21:32:13 +00:00
{
2014-01-23 18:05:41 +00:00
ApiEntryPoint . Instance . OnTranscodeBeginRequest ( playlist , TranscodingJobType . Hls ) ;
2014-01-12 21:32:13 +00:00
2014-01-23 18:05:41 +00:00
await Task . Delay ( 20000 ) . ConfigureAwait ( false ) ;
2014-01-12 21:32:13 +00:00
2014-01-23 18:05:41 +00:00
ApiEntryPoint . Instance . OnTranscodeEndRequest ( playlist , TranscodingJobType . Hls ) ;
2014-01-12 21:32:13 +00:00
}
2013-03-09 06:13:10 +00:00
/// <summary>
/// Gets the specified request.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>System.Object.</returns>
public object Get ( GetHlsVideoStream request )
{
return ProcessRequest ( request ) ;
}
2013-04-29 16:01:23 +00:00
2013-02-27 23:33:40 +00:00
/// <summary>
/// Gets the audio arguments.
/// </summary>
/// <param name="state">The state.</param>
/// <returns>System.String.</returns>
protected override string GetAudioArguments ( StreamState state )
{
2013-03-20 14:27:56 +00:00
var codec = GetAudioCodec ( state . Request ) ;
if ( codec . Equals ( "copy" , StringComparison . OrdinalIgnoreCase ) )
2013-02-27 23:33:40 +00:00
{
return "-codec:a:0 copy" ;
}
var args = "-codec:a:0 " + codec ;
if ( state . AudioStream ! = null )
{
var channels = GetNumAudioChannelsParam ( state . Request , state . AudioStream ) ;
if ( channels . HasValue )
{
args + = " -ac " + channels . Value ;
}
2013-08-30 02:13:58 +00:00
var bitrate = GetAudioBitrateParam ( state ) ;
if ( bitrate . HasValue )
2013-02-27 23:33:40 +00:00
{
2013-08-30 02:13:58 +00:00
args + = " -ab " + bitrate . Value . ToString ( UsCulture ) ;
2013-02-27 23:33:40 +00:00
}
2014-01-10 13:52:01 +00:00
args + = " " + GetAudioFilterParam ( state , true ) ;
2013-03-20 14:27:56 +00:00
2013-02-27 23:33:40 +00:00
return args ;
}
return args ;
}
/// <summary>
/// Gets the video arguments.
/// </summary>
/// <param name="state">The state.</param>
2013-04-29 16:01:23 +00:00
/// <param name="performSubtitleConversion">if set to <c>true</c> [perform subtitle conversion].</param>
2013-02-27 23:33:40 +00:00
/// <returns>System.String.</returns>
2013-04-29 16:01:23 +00:00
protected override string GetVideoArguments ( StreamState state , bool performSubtitleConversion )
2013-02-27 23:33:40 +00:00
{
2013-03-09 02:34:54 +00:00
var codec = GetVideoCodec ( state . VideoRequest ) ;
2013-02-27 23:33:40 +00:00
// See if we can save come cpu cycles by avoiding encoding
if ( codec . Equals ( "copy" , StringComparison . OrdinalIgnoreCase ) )
{
return IsH264 ( state . VideoStream ) ? "-codec:v:0 copy -bsf h264_mp4toannexb" : "-codec:v:0 copy" ;
}
2013-09-02 20:19:11 +00:00
const string keyFrameArg = " -force_key_frames expr:if(isnan(prev_forced_t),gte(t,.1),gte(t,prev_forced_t+5))" ;
2013-03-28 15:22:05 +00:00
2013-11-20 15:50:54 +00:00
var hasGraphicalSubs = state . SubtitleStream ! = null & & ! state . SubtitleStream . IsExternal & &
( state . SubtitleStream . Codec . IndexOf ( "pgs" , StringComparison . OrdinalIgnoreCase ) ! = - 1 | |
state . SubtitleStream . Codec . IndexOf ( "dvd" , StringComparison . OrdinalIgnoreCase ) ! = - 1 ) ;
2013-12-06 03:39:44 +00:00
2013-12-15 19:39:21 +00:00
var args = "-codec:v:0 " + codec + " " + GetVideoQualityParam ( state , "libx264" ) + keyFrameArg ;
2013-02-27 23:33:40 +00:00
2013-08-30 02:13:58 +00:00
var bitrate = GetVideoBitrateParam ( state ) ;
2013-02-27 23:33:40 +00:00
2013-08-30 02:13:58 +00:00
if ( bitrate . HasValue )
{
2013-12-15 07:25:33 +00:00
args + = string . Format ( " -b:v {0} -maxrate ({0}*.80) -bufsize {0}" , bitrate . Value . ToString ( UsCulture ) ) ;
2013-06-02 14:47:28 +00:00
}
2013-12-06 03:39:44 +00:00
2013-02-27 23:33:40 +00:00
// Add resolution params, if specified
2013-11-20 15:50:54 +00:00
if ( ! hasGraphicalSubs )
2013-02-27 23:33:40 +00:00
{
2013-11-20 15:50:54 +00:00
if ( state . VideoRequest . Width . HasValue | | state . VideoRequest . Height . HasValue | | state . VideoRequest . MaxHeight . HasValue | | state . VideoRequest . MaxWidth . HasValue )
{
args + = GetOutputSizeParam ( state , codec , performSubtitleConversion ) ;
}
2013-02-27 23:33:40 +00:00
}
2014-01-24 18:09:50 +00:00
var framerate = GetFramerateParam ( state ) ;
if ( framerate . HasValue )
2013-02-27 23:33:40 +00:00
{
2014-01-24 18:09:50 +00:00
args + = string . Format ( " -r {0}" , framerate . Value . ToString ( UsCulture ) ) ;
2013-02-27 23:33:40 +00:00
}
2014-01-24 18:09:50 +00:00
if ( ! string . IsNullOrEmpty ( state . VideoSync ) )
{
args + = " -vsync " + state . VideoSync ;
}
2013-03-24 03:56:01 +00:00
2013-03-28 14:42:03 +00:00
if ( ! string . IsNullOrEmpty ( state . VideoRequest . Profile ) )
{
2013-03-29 12:26:40 +00:00
args + = " -profile:v " + state . VideoRequest . Profile ;
2013-03-28 14:42:03 +00:00
}
if ( ! string . IsNullOrEmpty ( state . VideoRequest . Level ) )
{
2013-03-29 05:45:45 +00:00
args + = " -level " + state . VideoRequest . Level ;
2013-03-28 14:42:03 +00:00
}
2013-11-20 15:50:54 +00:00
// This is for internal graphical subs
if ( hasGraphicalSubs )
2013-03-24 03:56:01 +00:00
{
2013-11-20 15:50:54 +00:00
args + = GetInternalGraphicalSubtitleParam ( state , codec ) ;
2013-03-24 03:56:01 +00:00
}
2013-12-06 03:39:44 +00:00
2013-02-27 23:33:40 +00:00
return args ;
}
/// <summary>
/// Gets the segment file extension.
/// </summary>
/// <param name="state">The state.</param>
/// <returns>System.String.</returns>
protected override string GetSegmentFileExtension ( StreamState state )
{
return ".ts" ;
}
}
}