using MediaBrowser.Model.Drawing; using MediaBrowser.Model.Dto; using MediaBrowser.Model.Entities; using MediaBrowser.Model.Extensions; using MediaBrowser.Model.MediaInfo; using MediaBrowser.Model.Session; using System; using System.Collections.Generic; using System.Linq; namespace MediaBrowser.Model.Dlna { /// /// Class StreamInfo. /// public class StreamInfo { public StreamInfo() { AudioCodecs = new string[] { }; } public string ItemId { get; set; } public PlayMethod PlayMethod { get; set; } public EncodingContext Context { get; set; } public DlnaProfileType MediaType { get; set; } public string Container { get; set; } public string SubProtocol { get; set; } public long StartPositionTicks { get; set; } public string VideoCodec { get; set; } public string VideoProfile { get; set; } public bool RequireAvc { get; set; } public bool CopyTimestamps { get; set; } public bool EnableSubtitlesInManifest { get; set; } public bool EnableSplittingOnNonKeyFrames { get; set; } public string[] AudioCodecs { get; set; } public int? AudioStreamIndex { get; set; } public int? SubtitleStreamIndex { get; set; } public int? TranscodingMaxAudioChannels { get; set; } public int? MaxAudioChannels { get; set; } public int? AudioBitrate { get; set; } public int? VideoBitrate { get; set; } public int? VideoLevel { get; set; } public int? MaxWidth { get; set; } public int? MaxHeight { get; set; } public int? MaxVideoBitDepth { get; set; } public int? MaxRefFrames { get; set; } public float? MaxFramerate { get; set; } public DeviceProfile DeviceProfile { get; set; } public string DeviceProfileId { get; set; } public string DeviceId { get; set; } public long? RunTimeTicks { get; set; } public TranscodeSeekInfo TranscodeSeekInfo { get; set; } public bool EstimateContentLength { get; set; } public MediaSourceInfo MediaSource { get; set; } public SubtitleDeliveryMethod SubtitleDeliveryMethod { get; set; } public string SubtitleFormat { get; set; } public string PlaySessionId { get; set; } public List AllMediaSources { get; set; } public string MediaSourceId { get { return MediaSource == null ? null : MediaSource.Id; } } public bool IsDirectStream { get { return PlayMethod == PlayMethod.DirectStream || PlayMethod == PlayMethod.DirectPlay; } } public string ToUrl(string baseUrl, string accessToken) { if (PlayMethod == PlayMethod.DirectPlay) { return MediaSource.Path; } if (string.IsNullOrEmpty(baseUrl)) { throw new ArgumentNullException(baseUrl); } List list = new List(); foreach (NameValuePair pair in BuildParams(this, accessToken, false)) { if (string.IsNullOrEmpty(pair.Value)) { continue; } // Try to keep the url clean by omitting defaults if (StringHelper.EqualsIgnoreCase(pair.Name, "StartTimeTicks") && StringHelper.EqualsIgnoreCase(pair.Value, "0")) { continue; } if (StringHelper.EqualsIgnoreCase(pair.Name, "SubtitleStreamIndex") && StringHelper.EqualsIgnoreCase(pair.Value, "-1")) { continue; } if (StringHelper.EqualsIgnoreCase(pair.Name, "Static") && StringHelper.EqualsIgnoreCase(pair.Value, "false")) { continue; } list.Add(string.Format("{0}={1}", pair.Name, pair.Value)); } string queryString = string.Join("&", list.ToArray()); return GetUrl(baseUrl, queryString); } public string ToDlnaUrl(string baseUrl, string accessToken) { if (PlayMethod == PlayMethod.DirectPlay) { return MediaSource.Path; } string dlnaCommand = BuildDlnaParam(this, accessToken); return GetUrl(baseUrl, dlnaCommand); } private string GetUrl(string baseUrl, string queryString) { if (string.IsNullOrEmpty(baseUrl)) { throw new ArgumentNullException(baseUrl); } string extension = string.IsNullOrEmpty(Container) ? string.Empty : "." + Container; baseUrl = baseUrl.TrimEnd('/'); if (MediaType == DlnaProfileType.Audio) { if (StringHelper.EqualsIgnoreCase(SubProtocol, "hls")) { return string.Format("{0}/audio/{1}/master.m3u8?{2}", baseUrl, ItemId, queryString); } return string.Format("{0}/audio/{1}/stream{2}?{3}", baseUrl, ItemId, extension, queryString); } if (StringHelper.EqualsIgnoreCase(SubProtocol, "hls")) { return string.Format("{0}/videos/{1}/master.m3u8?{2}", baseUrl, ItemId, queryString); } return string.Format("{0}/videos/{1}/stream{2}?{3}", baseUrl, ItemId, extension, queryString); } private static string BuildDlnaParam(StreamInfo item, string accessToken) { List list = new List(); foreach (NameValuePair pair in BuildParams(item, accessToken, true)) { list.Add(pair.Value); } return string.Format("Params={0}", string.Join(";", list.ToArray())); } private static List BuildParams(StreamInfo item, string accessToken, bool isDlna) { List list = new List(); string audioCodecs = item.AudioCodecs.Length == 0 ? string.Empty : string.Join(",", item.AudioCodecs); list.Add(new NameValuePair("DeviceProfileId", item.DeviceProfileId ?? string.Empty)); list.Add(new NameValuePair("DeviceId", item.DeviceId ?? string.Empty)); list.Add(new NameValuePair("MediaSourceId", item.MediaSourceId ?? string.Empty)); list.Add(new NameValuePair("Static", item.IsDirectStream.ToString().ToLower())); list.Add(new NameValuePair("VideoCodec", item.VideoCodec ?? string.Empty)); list.Add(new NameValuePair("AudioCodec", audioCodecs)); list.Add(new NameValuePair("AudioStreamIndex", item.AudioStreamIndex.HasValue ? StringHelper.ToStringCultureInvariant(item.AudioStreamIndex.Value) : string.Empty)); list.Add(new NameValuePair("SubtitleStreamIndex", item.SubtitleStreamIndex.HasValue && item.SubtitleDeliveryMethod != SubtitleDeliveryMethod.External ? StringHelper.ToStringCultureInvariant(item.SubtitleStreamIndex.Value) : string.Empty)); list.Add(new NameValuePair("VideoBitrate", item.VideoBitrate.HasValue ? StringHelper.ToStringCultureInvariant(item.VideoBitrate.Value) : string.Empty)); list.Add(new NameValuePair("AudioBitrate", item.AudioBitrate.HasValue ? StringHelper.ToStringCultureInvariant(item.AudioBitrate.Value) : string.Empty)); list.Add(new NameValuePair("MaxAudioChannels", item.MaxAudioChannels.HasValue ? StringHelper.ToStringCultureInvariant(item.MaxAudioChannels.Value) : string.Empty)); list.Add(new NameValuePair("MaxFramerate", item.MaxFramerate.HasValue ? StringHelper.ToStringCultureInvariant(item.MaxFramerate.Value) : string.Empty)); list.Add(new NameValuePair("MaxWidth", item.MaxWidth.HasValue ? StringHelper.ToStringCultureInvariant(item.MaxWidth.Value) : string.Empty)); list.Add(new NameValuePair("MaxHeight", item.MaxHeight.HasValue ? StringHelper.ToStringCultureInvariant(item.MaxHeight.Value) : string.Empty)); var forceStartPosition = false; long startPositionTicks = item.StartPositionTicks; //if (item.MediaSource.DateLiveStreamOpened.HasValue && startPositionTicks == 0) //{ // var elapsed = DateTime.UtcNow - item.MediaSource.DateLiveStreamOpened.Value; // elapsed -= TimeSpan.FromSeconds(20); // if (elapsed.TotalSeconds >= 0) // { // startPositionTicks = elapsed.Ticks + startPositionTicks; // forceStartPosition = true; // } //} if (StringHelper.EqualsIgnoreCase(item.SubProtocol, "hls") && !forceStartPosition) { list.Add(new NameValuePair("StartTimeTicks", string.Empty)); } else { list.Add(new NameValuePair("StartTimeTicks", StringHelper.ToStringCultureInvariant(startPositionTicks))); } list.Add(new NameValuePair("Level", item.VideoLevel.HasValue ? StringHelper.ToStringCultureInvariant(item.VideoLevel.Value) : string.Empty)); list.Add(new NameValuePair("MaxRefFrames", item.MaxRefFrames.HasValue ? StringHelper.ToStringCultureInvariant(item.MaxRefFrames.Value) : string.Empty)); list.Add(new NameValuePair("MaxVideoBitDepth", item.MaxVideoBitDepth.HasValue ? StringHelper.ToStringCultureInvariant(item.MaxVideoBitDepth.Value) : string.Empty)); list.Add(new NameValuePair("Profile", item.VideoProfile ?? string.Empty)); // no longer used list.Add(new NameValuePair("Cabac", string.Empty)); list.Add(new NameValuePair("PlaySessionId", item.PlaySessionId ?? string.Empty)); list.Add(new NameValuePair("api_key", accessToken ?? string.Empty)); string liveStreamId = item.MediaSource == null ? null : item.MediaSource.LiveStreamId; list.Add(new NameValuePair("LiveStreamId", liveStreamId ?? string.Empty)); if (isDlna) { list.Add(new NameValuePair("ItemId", item.ItemId)); } list.Add(new NameValuePair("CopyTimestamps", item.CopyTimestamps.ToString().ToLower())); list.Add(new NameValuePair("SubtitleMethod", item.SubtitleStreamIndex.HasValue && item.SubtitleDeliveryMethod != SubtitleDeliveryMethod.External ? item.SubtitleDeliveryMethod.ToString() : string.Empty)); list.Add(new NameValuePair("TranscodingMaxAudioChannels", item.TranscodingMaxAudioChannels.HasValue ? StringHelper.ToStringCultureInvariant(item.TranscodingMaxAudioChannels.Value) : string.Empty)); list.Add(new NameValuePair("EnableSubtitlesInManifest", item.EnableSubtitlesInManifest.ToString().ToLower())); list.Add(new NameValuePair("Tag", item.MediaSource.ETag ?? string.Empty)); list.Add(new NameValuePair("EnableSplittingOnNonKeyFrames", item.EnableSplittingOnNonKeyFrames.ToString().ToLower())); list.Add(new NameValuePair("RequireAvc", item.RequireAvc.ToString().ToLower())); return list; } public List GetExternalSubtitles(bool includeSelectedTrackOnly, string baseUrl, string accessToken) { return GetExternalSubtitles(includeSelectedTrackOnly, false, baseUrl, accessToken); } public List GetExternalSubtitles(bool includeSelectedTrackOnly, bool enableAllProfiles, string baseUrl, string accessToken) { List list = GetSubtitleProfiles(includeSelectedTrackOnly, enableAllProfiles, baseUrl, accessToken); List newList = new List(); // First add the selected track foreach (SubtitleStreamInfo stream in list) { if (stream.DeliveryMethod == SubtitleDeliveryMethod.External) { newList.Add(stream); } } return newList; } public List GetSubtitleProfiles(bool includeSelectedTrackOnly, string baseUrl, string accessToken) { return GetSubtitleProfiles(includeSelectedTrackOnly, false, baseUrl, accessToken); } public List GetSubtitleProfiles(bool includeSelectedTrackOnly, bool enableAllProfiles, string baseUrl, string accessToken) { List list = new List(); // HLS will preserve timestamps so we can just grab the full subtitle stream long startPositionTicks = StringHelper.EqualsIgnoreCase(SubProtocol, "hls") ? 0 : (PlayMethod == PlayMethod.Transcode && !CopyTimestamps ? StartPositionTicks : 0); // First add the selected track if (SubtitleStreamIndex.HasValue) { foreach (MediaStream stream in MediaSource.MediaStreams) { if (stream.Type == MediaStreamType.Subtitle && stream.Index == SubtitleStreamIndex.Value) { AddSubtitleProfiles(list, stream, enableAllProfiles, baseUrl, accessToken, startPositionTicks); } } } if (!includeSelectedTrackOnly) { foreach (MediaStream stream in MediaSource.MediaStreams) { if (stream.Type == MediaStreamType.Subtitle && (!SubtitleStreamIndex.HasValue || stream.Index != SubtitleStreamIndex.Value)) { AddSubtitleProfiles(list, stream, enableAllProfiles, baseUrl, accessToken, startPositionTicks); } } } return list; } private void AddSubtitleProfiles(List list, MediaStream stream, bool enableAllProfiles, string baseUrl, string accessToken, long startPositionTicks) { if (enableAllProfiles) { foreach (SubtitleProfile profile in DeviceProfile.SubtitleProfiles) { SubtitleStreamInfo info = GetSubtitleStreamInfo(stream, baseUrl, accessToken, startPositionTicks, new[] { profile }); list.Add(info); } } else { SubtitleStreamInfo info = GetSubtitleStreamInfo(stream, baseUrl, accessToken, startPositionTicks, DeviceProfile.SubtitleProfiles); list.Add(info); } } private SubtitleStreamInfo GetSubtitleStreamInfo(MediaStream stream, string baseUrl, string accessToken, long startPositionTicks, SubtitleProfile[] subtitleProfiles) { SubtitleProfile subtitleProfile = StreamBuilder.GetSubtitleProfile(stream, subtitleProfiles, PlayMethod); SubtitleStreamInfo info = new SubtitleStreamInfo { IsForced = stream.IsForced, Language = stream.Language, Name = stream.Language ?? "Unknown", Format = subtitleProfile.Format, Index = stream.Index, DeliveryMethod = subtitleProfile.Method, DisplayTitle = stream.DisplayTitle }; if (info.DeliveryMethod == SubtitleDeliveryMethod.External) { if (MediaSource.Protocol == MediaProtocol.File || !StringHelper.EqualsIgnoreCase(stream.Codec, subtitleProfile.Format)) { info.Url = string.Format("{0}/Videos/{1}/{2}/Subtitles/{3}/{4}/Stream.{5}", baseUrl, ItemId, MediaSourceId, StringHelper.ToStringCultureInvariant(stream.Index), StringHelper.ToStringCultureInvariant(startPositionTicks), subtitleProfile.Format); if (!string.IsNullOrEmpty(accessToken)) { info.Url += "?api_key=" + accessToken; } info.IsExternalUrl = false; } else { info.Url = stream.Path; info.IsExternalUrl = true; } } return info; } /// /// Returns the audio stream that will be used /// public MediaStream TargetAudioStream { get { if (MediaSource != null) { return MediaSource.GetDefaultAudioStream(AudioStreamIndex); } return null; } } /// /// Returns the video stream that will be used /// public MediaStream TargetVideoStream { get { if (MediaSource != null) { return MediaSource.VideoStream; } return null; } } /// /// Predicts the audio sample rate that will be in the output stream /// public int? TargetAudioSampleRate { get { MediaStream stream = TargetAudioStream; return stream == null ? null : stream.SampleRate; } } /// /// Predicts the audio sample rate that will be in the output stream /// public int? TargetVideoBitDepth { get { MediaStream stream = TargetVideoStream; return stream == null || !IsDirectStream ? null : stream.BitDepth; } } /// /// Gets the target reference frames. /// /// The target reference frames. public int? TargetRefFrames { get { MediaStream stream = TargetVideoStream; return stream == null || !IsDirectStream ? null : stream.RefFrames; } } /// /// Predicts the audio sample rate that will be in the output stream /// public float? TargetFramerate { get { MediaStream stream = TargetVideoStream; return MaxFramerate.HasValue && !IsDirectStream ? MaxFramerate : stream == null ? null : stream.AverageFrameRate ?? stream.RealFrameRate; } } /// /// Predicts the audio sample rate that will be in the output stream /// public double? TargetVideoLevel { get { MediaStream stream = TargetVideoStream; return VideoLevel.HasValue && !IsDirectStream ? VideoLevel : stream == null ? null : stream.Level; } } /// /// Predicts the audio sample rate that will be in the output stream /// public int? TargetPacketLength { get { MediaStream stream = TargetVideoStream; return !IsDirectStream ? null : stream == null ? null : stream.PacketLength; } } /// /// Predicts the audio sample rate that will be in the output stream /// public string TargetVideoProfile { get { MediaStream stream = TargetVideoStream; return !string.IsNullOrEmpty(VideoProfile) && !IsDirectStream ? VideoProfile : stream == null ? null : stream.Profile; } } /// /// Gets the target video codec tag. /// /// The target video codec tag. public string TargetVideoCodecTag { get { MediaStream stream = TargetVideoStream; return !IsDirectStream ? null : stream == null ? null : stream.CodecTag; } } /// /// Predicts the audio bitrate that will be in the output stream /// public int? TargetAudioBitrate { get { MediaStream stream = TargetAudioStream; return AudioBitrate.HasValue && !IsDirectStream ? AudioBitrate : stream == null ? null : stream.BitRate; } } /// /// Predicts the audio channels that will be in the output stream /// public int? TargetAudioChannels { get { MediaStream stream = TargetAudioStream; int? streamChannels = stream == null ? null : stream.Channels; if (MaxAudioChannels.HasValue && !IsDirectStream) { if (streamChannels.HasValue) { return Math.Min(MaxAudioChannels.Value, streamChannels.Value); } return MaxAudioChannels.Value; } return streamChannels; } } /// /// Predicts the audio codec that will be in the output stream /// public string TargetAudioCodec { get { MediaStream stream = TargetAudioStream; string inputCodec = stream == null ? null : stream.Codec; if (IsDirectStream) { return inputCodec; } foreach (string codec in AudioCodecs) { if (StringHelper.EqualsIgnoreCase(codec, inputCodec)) { return codec; } } return AudioCodecs.Length == 0 ? null : AudioCodecs[0]; } } /// /// Predicts the audio channels that will be in the output stream /// public long? TargetSize { get { if (IsDirectStream) { return MediaSource.Size; } if (RunTimeTicks.HasValue) { int? totalBitrate = TargetTotalBitrate; double totalSeconds = RunTimeTicks.Value; // Convert to ms totalSeconds /= 10000; // Convert to seconds totalSeconds /= 1000; return totalBitrate.HasValue ? Convert.ToInt64(totalBitrate.Value * totalSeconds) : (long?)null; } return null; } } public int? TargetVideoBitrate { get { MediaStream stream = TargetVideoStream; return VideoBitrate.HasValue && !IsDirectStream ? VideoBitrate : stream == null ? null : stream.BitRate; } } public TransportStreamTimestamp TargetTimestamp { get { TransportStreamTimestamp defaultValue = StringHelper.EqualsIgnoreCase(Container, "m2ts") ? TransportStreamTimestamp.Valid : TransportStreamTimestamp.None; return !IsDirectStream ? defaultValue : MediaSource == null ? defaultValue : MediaSource.Timestamp ?? TransportStreamTimestamp.None; } } public int? TargetTotalBitrate { get { return (TargetAudioBitrate ?? 0) + (TargetVideoBitrate ?? 0); } } public bool? IsTargetAnamorphic { get { if (IsDirectStream) { return TargetVideoStream == null ? null : TargetVideoStream.IsAnamorphic; } return false; } } public bool? IsTargetAVC { get { if (IsDirectStream) { return TargetVideoStream == null ? null : TargetVideoStream.IsAVC; } return true; } } public int? TargetWidth { get { MediaStream videoStream = TargetVideoStream; if (videoStream != null && videoStream.Width.HasValue && videoStream.Height.HasValue) { ImageSize size = new ImageSize { Width = videoStream.Width.Value, Height = videoStream.Height.Value }; double? maxWidth = MaxWidth.HasValue ? (double)MaxWidth.Value : (double?)null; double? maxHeight = MaxHeight.HasValue ? (double)MaxHeight.Value : (double?)null; ImageSize newSize = DrawingUtils.Resize(size, null, null, maxWidth, maxHeight); return Convert.ToInt32(newSize.Width); } return MaxWidth; } } public int? TargetHeight { get { MediaStream videoStream = TargetVideoStream; if (videoStream != null && videoStream.Width.HasValue && videoStream.Height.HasValue) { ImageSize size = new ImageSize { Width = videoStream.Width.Value, Height = videoStream.Height.Value }; double? maxWidth = MaxWidth.HasValue ? (double)MaxWidth.Value : (double?)null; double? maxHeight = MaxHeight.HasValue ? (double)MaxHeight.Value : (double?)null; ImageSize newSize = DrawingUtils.Resize(size, null, null, maxWidth, maxHeight); return Convert.ToInt32(newSize.Height); } return MaxHeight; } } public int? TargetVideoStreamCount { get { if (IsDirectStream) { return GetMediaStreamCount(MediaStreamType.Video, int.MaxValue); } return GetMediaStreamCount(MediaStreamType.Video, 1); } } public int? TargetAudioStreamCount { get { if (IsDirectStream) { return GetMediaStreamCount(MediaStreamType.Audio, int.MaxValue); } return GetMediaStreamCount(MediaStreamType.Audio, 1); } } private int? GetMediaStreamCount(MediaStreamType type, int limit) { var count = MediaSource.GetStreamCount(type); if (count.HasValue) { count = Math.Min(count.Value, limit); } return count; } public List GetSelectableAudioStreams() { return GetSelectableStreams(MediaStreamType.Audio); } public List GetSelectableSubtitleStreams() { return GetSelectableStreams(MediaStreamType.Subtitle); } public List GetSelectableStreams(MediaStreamType type) { List list = new List(); foreach (MediaStream stream in MediaSource.MediaStreams) { if (type == stream.Type) { list.Add(stream); } } return list; } } }