StreamBuilder.cs 100 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Globalization;
  4. using System.Linq;
  5. using Jellyfin.Data.Enums;
  6. using Jellyfin.Extensions;
  7. using MediaBrowser.Model.Dto;
  8. using MediaBrowser.Model.Entities;
  9. using MediaBrowser.Model.MediaInfo;
  10. using MediaBrowser.Model.Session;
  11. using Microsoft.Extensions.Logging;
  12. namespace MediaBrowser.Model.Dlna
  13. {
  14. /// <summary>
  15. /// Class StreamBuilder.
  16. /// </summary>
  17. public class StreamBuilder
  18. {
  19. // Aliases
  20. internal const TranscodeReason ContainerReasons = TranscodeReason.ContainerNotSupported | TranscodeReason.ContainerBitrateExceedsLimit;
  21. internal const TranscodeReason AudioReasons = TranscodeReason.AudioCodecNotSupported | TranscodeReason.AudioBitrateNotSupported | TranscodeReason.AudioChannelsNotSupported | TranscodeReason.AudioProfileNotSupported | TranscodeReason.AudioSampleRateNotSupported | TranscodeReason.SecondaryAudioNotSupported | TranscodeReason.AudioBitDepthNotSupported | TranscodeReason.AudioIsExternal;
  22. internal const TranscodeReason VideoReasons = TranscodeReason.VideoCodecNotSupported | TranscodeReason.VideoResolutionNotSupported | TranscodeReason.AnamorphicVideoNotSupported | TranscodeReason.InterlacedVideoNotSupported | TranscodeReason.VideoBitDepthNotSupported | TranscodeReason.VideoBitrateNotSupported | TranscodeReason.VideoFramerateNotSupported | TranscodeReason.VideoLevelNotSupported | TranscodeReason.RefFramesNotSupported;
  23. internal const TranscodeReason DirectStreamReasons = AudioReasons | TranscodeReason.ContainerNotSupported;
  24. private readonly ILogger _logger;
  25. private readonly ITranscoderSupport _transcoderSupport;
  26. private static readonly string[] _supportedHlsVideoCodecs = new string[] { "h264", "hevc", "av1" };
  27. private static readonly string[] _supportedHlsAudioCodecsTs = new string[] { "aac", "ac3", "eac3", "mp3" };
  28. private static readonly string[] _supportedHlsAudioCodecsMp4 = new string[] { "aac", "ac3", "eac3", "mp3", "alac", "flac", "opus", "dca", "truehd" };
  29. /// <summary>
  30. /// Initializes a new instance of the <see cref="StreamBuilder"/> class.
  31. /// </summary>
  32. /// <param name="transcoderSupport">The <see cref="ITranscoderSupport"/> object.</param>
  33. /// <param name="logger">The <see cref="ILogger"/> object.</param>
  34. public StreamBuilder(ITranscoderSupport transcoderSupport, ILogger logger)
  35. {
  36. _transcoderSupport = transcoderSupport;
  37. _logger = logger;
  38. }
  39. /// <summary>
  40. /// Gets the optimal audio stream.
  41. /// </summary>
  42. /// <param name="options">The <see cref="MediaOptions"/> object to get the audio stream from.</param>
  43. /// <returns>The <see cref="StreamInfo"/> of the optimal audio stream.</returns>
  44. public StreamInfo? GetOptimalAudioStream(MediaOptions options)
  45. {
  46. ValidateMediaOptions(options, false);
  47. var streams = new List<StreamInfo>();
  48. foreach (var mediaSource in options.MediaSources)
  49. {
  50. if (!(string.IsNullOrEmpty(options.MediaSourceId)
  51. || string.Equals(mediaSource.Id, options.MediaSourceId, StringComparison.OrdinalIgnoreCase)))
  52. {
  53. continue;
  54. }
  55. StreamInfo? streamInfo = GetOptimalAudioStream(mediaSource, options);
  56. if (streamInfo is not null)
  57. {
  58. streamInfo.DeviceId = options.DeviceId;
  59. streamInfo.DeviceProfileId = options.Profile.Id;
  60. streams.Add(streamInfo);
  61. }
  62. }
  63. return GetOptimalStream(streams, options.GetMaxBitrate(true) ?? 0);
  64. }
  65. private StreamInfo? GetOptimalAudioStream(MediaSourceInfo item, MediaOptions options)
  66. {
  67. var playlistItem = new StreamInfo
  68. {
  69. ItemId = options.ItemId,
  70. MediaType = DlnaProfileType.Audio,
  71. MediaSource = item,
  72. RunTimeTicks = item.RunTimeTicks,
  73. Context = options.Context,
  74. DeviceProfile = options.Profile
  75. };
  76. if (options.ForceDirectPlay)
  77. {
  78. playlistItem.PlayMethod = PlayMethod.DirectPlay;
  79. playlistItem.Container = NormalizeMediaSourceFormatIntoSingleContainer(item.Container, options.Profile, DlnaProfileType.Audio);
  80. return playlistItem;
  81. }
  82. if (options.ForceDirectStream)
  83. {
  84. playlistItem.PlayMethod = PlayMethod.DirectStream;
  85. playlistItem.Container = NormalizeMediaSourceFormatIntoSingleContainer(item.Container, options.Profile, DlnaProfileType.Audio);
  86. return playlistItem;
  87. }
  88. MediaStream audioStream = item.GetDefaultAudioStream(null);
  89. var directPlayInfo = GetAudioDirectPlayProfile(item, audioStream, options);
  90. var directPlayMethod = directPlayInfo.PlayMethod;
  91. var transcodeReasons = directPlayInfo.TranscodeReasons;
  92. var inputAudioChannels = audioStream?.Channels;
  93. var inputAudioBitrate = audioStream?.BitRate;
  94. var inputAudioSampleRate = audioStream?.SampleRate;
  95. var inputAudioBitDepth = audioStream?.BitDepth;
  96. if (directPlayMethod is PlayMethod.DirectPlay)
  97. {
  98. var profile = options.Profile;
  99. var audioFailureConditions = GetProfileConditionsForAudio(profile.CodecProfiles, item.Container, audioStream?.Codec, inputAudioChannels, inputAudioBitrate, inputAudioSampleRate, inputAudioBitDepth, true);
  100. var audioFailureReasons = AggregateFailureConditions(item, profile, "AudioCodecProfile", audioFailureConditions);
  101. transcodeReasons |= audioFailureReasons;
  102. if (audioFailureReasons == 0)
  103. {
  104. playlistItem.PlayMethod = directPlayMethod.Value;
  105. playlistItem.Container = NormalizeMediaSourceFormatIntoSingleContainer(item.Container, options.Profile, DlnaProfileType.Audio, directPlayInfo.Profile);
  106. return playlistItem;
  107. }
  108. }
  109. if (directPlayMethod is PlayMethod.DirectStream)
  110. {
  111. var remuxContainer = item.TranscodingContainer ?? "ts";
  112. var supportedHlsContainers = new[] { "ts", "mp4" };
  113. // If the container specified for the profile is an HLS supported container, use that container instead, overriding the preference
  114. // The client should be responsible to ensure this container is compatible
  115. remuxContainer = Array.Exists(supportedHlsContainers, element => element == directPlayInfo.Profile?.Container) ? directPlayInfo.Profile?.Container : remuxContainer;
  116. bool codeIsSupported;
  117. if (item.TranscodingSubProtocol == MediaStreamProtocol.hls)
  118. {
  119. // Enforce HLS audio codec restrictions
  120. if (string.Equals(remuxContainer, "mp4", StringComparison.OrdinalIgnoreCase))
  121. {
  122. codeIsSupported = _supportedHlsAudioCodecsMp4.Contains(directPlayInfo.Profile?.AudioCodec ?? directPlayInfo.Profile?.Container);
  123. }
  124. else
  125. {
  126. codeIsSupported = _supportedHlsAudioCodecsTs.Contains(directPlayInfo.Profile?.AudioCodec ?? directPlayInfo.Profile?.Container);
  127. }
  128. }
  129. else
  130. {
  131. // Let's assume the client has given a correct container for http
  132. codeIsSupported = true;
  133. }
  134. if (codeIsSupported)
  135. {
  136. playlistItem.PlayMethod = directPlayMethod.Value;
  137. playlistItem.Container = remuxContainer;
  138. playlistItem.TranscodeReasons = transcodeReasons;
  139. playlistItem.SubProtocol = item.TranscodingSubProtocol;
  140. item.TranscodingContainer = remuxContainer;
  141. return playlistItem;
  142. }
  143. transcodeReasons |= TranscodeReason.AudioCodecNotSupported;
  144. playlistItem.TranscodeReasons = transcodeReasons;
  145. }
  146. TranscodingProfile? transcodingProfile = null;
  147. foreach (var tcProfile in options.Profile.TranscodingProfiles)
  148. {
  149. if (tcProfile.Type == playlistItem.MediaType
  150. && tcProfile.Context == options.Context
  151. && _transcoderSupport.CanEncodeToAudioCodec(tcProfile.AudioCodec ?? tcProfile.Container))
  152. {
  153. transcodingProfile = tcProfile;
  154. break;
  155. }
  156. }
  157. if (transcodingProfile is not null)
  158. {
  159. if (!item.SupportsTranscoding)
  160. {
  161. return null;
  162. }
  163. SetStreamInfoOptionsFromTranscodingProfile(item, playlistItem, transcodingProfile);
  164. var audioTranscodingConditions = GetProfileConditionsForAudio(options.Profile.CodecProfiles, transcodingProfile.Container, transcodingProfile.AudioCodec, inputAudioChannels, inputAudioBitrate, inputAudioSampleRate, inputAudioBitDepth, false).ToArray();
  165. ApplyTranscodingConditions(playlistItem, audioTranscodingConditions, null, true, true);
  166. // Honor requested max channels
  167. playlistItem.GlobalMaxAudioChannels = options.MaxAudioChannels;
  168. var configuredBitrate = options.GetMaxBitrate(true);
  169. long transcodingBitrate = options.AudioTranscodingBitrate
  170. ?? (options.Context == EncodingContext.Streaming ? options.Profile.MusicStreamingTranscodingBitrate : null)
  171. ?? configuredBitrate
  172. ?? 128000;
  173. if (configuredBitrate.HasValue)
  174. {
  175. transcodingBitrate = Math.Min(configuredBitrate.Value, transcodingBitrate);
  176. }
  177. var longBitrate = Math.Min(transcodingBitrate, playlistItem.AudioBitrate ?? transcodingBitrate);
  178. playlistItem.AudioBitrate = longBitrate > int.MaxValue ? int.MaxValue : Convert.ToInt32(longBitrate);
  179. }
  180. playlistItem.TranscodeReasons = transcodeReasons;
  181. return playlistItem;
  182. }
  183. /// <summary>
  184. /// Gets the optimal video stream.
  185. /// </summary>
  186. /// <param name="options">The <see cref="MediaOptions"/> object to get the video stream from.</param>
  187. /// <returns>The <see cref="StreamInfo"/> of the optimal video stream.</returns>
  188. public StreamInfo? GetOptimalVideoStream(MediaOptions options)
  189. {
  190. ValidateMediaOptions(options, true);
  191. var mediaSources = string.IsNullOrEmpty(options.MediaSourceId)
  192. ? options.MediaSources
  193. : options.MediaSources.Where(x => string.Equals(x.Id, options.MediaSourceId, StringComparison.OrdinalIgnoreCase));
  194. var streams = new List<StreamInfo>();
  195. foreach (var mediaSourceInfo in mediaSources)
  196. {
  197. var streamInfo = BuildVideoItem(mediaSourceInfo, options);
  198. if (streamInfo is not null)
  199. {
  200. streams.Add(streamInfo);
  201. }
  202. }
  203. foreach (var stream in streams)
  204. {
  205. stream.DeviceId = options.DeviceId;
  206. stream.DeviceProfileId = options.Profile.Id;
  207. }
  208. return GetOptimalStream(streams, options.GetMaxBitrate(false) ?? 0);
  209. }
  210. private static StreamInfo? GetOptimalStream(List<StreamInfo> streams, long maxBitrate)
  211. => SortMediaSources(streams, maxBitrate).FirstOrDefault();
  212. private static IOrderedEnumerable<StreamInfo> SortMediaSources(List<StreamInfo> streams, long maxBitrate)
  213. {
  214. return streams.OrderBy(i =>
  215. {
  216. // Nothing beats direct playing a file
  217. if (i.PlayMethod == PlayMethod.DirectPlay && i.MediaSource?.Protocol == MediaProtocol.File)
  218. {
  219. return 0;
  220. }
  221. return 1;
  222. }).ThenBy(i =>
  223. {
  224. switch (i.PlayMethod)
  225. {
  226. // Let's assume direct streaming a file is just as desirable as direct playing a remote url
  227. case PlayMethod.DirectStream:
  228. case PlayMethod.DirectPlay:
  229. return 0;
  230. default:
  231. return 1;
  232. }
  233. }).ThenBy(i =>
  234. {
  235. switch (i.MediaSource?.Protocol)
  236. {
  237. case MediaProtocol.File:
  238. return 0;
  239. default:
  240. return 1;
  241. }
  242. }).ThenBy(i =>
  243. {
  244. if (maxBitrate > 0)
  245. {
  246. if (i.MediaSource?.Bitrate is not null)
  247. {
  248. return Math.Abs(i.MediaSource.Bitrate.Value - maxBitrate);
  249. }
  250. }
  251. return 0;
  252. }).ThenBy(streams.IndexOf);
  253. }
  254. private static TranscodeReason GetTranscodeReasonForFailedCondition(ProfileCondition condition)
  255. {
  256. switch (condition.Property)
  257. {
  258. case ProfileConditionValue.AudioBitrate:
  259. return TranscodeReason.AudioBitrateNotSupported;
  260. case ProfileConditionValue.AudioChannels:
  261. return TranscodeReason.AudioChannelsNotSupported;
  262. case ProfileConditionValue.AudioProfile:
  263. return TranscodeReason.AudioProfileNotSupported;
  264. case ProfileConditionValue.AudioSampleRate:
  265. return TranscodeReason.AudioSampleRateNotSupported;
  266. case ProfileConditionValue.Has64BitOffsets:
  267. // TODO
  268. return 0;
  269. case ProfileConditionValue.Height:
  270. return TranscodeReason.VideoResolutionNotSupported;
  271. case ProfileConditionValue.IsAnamorphic:
  272. return TranscodeReason.AnamorphicVideoNotSupported;
  273. case ProfileConditionValue.IsAvc:
  274. // TODO
  275. return 0;
  276. case ProfileConditionValue.IsInterlaced:
  277. return TranscodeReason.InterlacedVideoNotSupported;
  278. case ProfileConditionValue.IsSecondaryAudio:
  279. return TranscodeReason.SecondaryAudioNotSupported;
  280. case ProfileConditionValue.NumAudioStreams:
  281. // TODO
  282. return 0;
  283. case ProfileConditionValue.NumVideoStreams:
  284. // TODO
  285. return 0;
  286. case ProfileConditionValue.PacketLength:
  287. // TODO
  288. return 0;
  289. case ProfileConditionValue.RefFrames:
  290. return TranscodeReason.RefFramesNotSupported;
  291. case ProfileConditionValue.VideoBitDepth:
  292. return TranscodeReason.VideoBitDepthNotSupported;
  293. case ProfileConditionValue.AudioBitDepth:
  294. return TranscodeReason.AudioBitDepthNotSupported;
  295. case ProfileConditionValue.VideoBitrate:
  296. return TranscodeReason.VideoBitrateNotSupported;
  297. case ProfileConditionValue.VideoCodecTag:
  298. return TranscodeReason.VideoCodecNotSupported;
  299. case ProfileConditionValue.VideoFramerate:
  300. return TranscodeReason.VideoFramerateNotSupported;
  301. case ProfileConditionValue.VideoLevel:
  302. return TranscodeReason.VideoLevelNotSupported;
  303. case ProfileConditionValue.VideoProfile:
  304. return TranscodeReason.VideoProfileNotSupported;
  305. case ProfileConditionValue.VideoRangeType:
  306. return TranscodeReason.VideoRangeTypeNotSupported;
  307. case ProfileConditionValue.VideoTimestamp:
  308. // TODO
  309. return 0;
  310. case ProfileConditionValue.Width:
  311. return TranscodeReason.VideoResolutionNotSupported;
  312. default:
  313. return 0;
  314. }
  315. }
  316. /// <summary>
  317. /// Normalizes input container.
  318. /// </summary>
  319. /// <param name="inputContainer">The input container.</param>
  320. /// <param name="profile">The <see cref="DeviceProfile"/>.</param>
  321. /// <param name="type">The <see cref="DlnaProfileType"/>.</param>
  322. /// <param name="playProfile">The <see cref="DirectPlayProfile"/> object to get the video stream from.</param>
  323. /// <returns>The normalized input container.</returns>
  324. public static string? NormalizeMediaSourceFormatIntoSingleContainer(string inputContainer, DeviceProfile? profile, DlnaProfileType type, DirectPlayProfile? playProfile = null)
  325. {
  326. if (string.IsNullOrEmpty(inputContainer))
  327. {
  328. return null;
  329. }
  330. var formats = ContainerProfile.SplitValue(inputContainer);
  331. if (profile is not null)
  332. {
  333. var playProfiles = playProfile is null ? profile.DirectPlayProfiles : new[] { playProfile };
  334. foreach (var format in formats)
  335. {
  336. foreach (var directPlayProfile in playProfiles)
  337. {
  338. if (directPlayProfile.Type == type
  339. && directPlayProfile.SupportsContainer(format))
  340. {
  341. return format;
  342. }
  343. }
  344. }
  345. }
  346. return formats[0];
  347. }
  348. private (DirectPlayProfile? Profile, PlayMethod? PlayMethod, TranscodeReason TranscodeReasons) GetAudioDirectPlayProfile(MediaSourceInfo item, MediaStream audioStream, MediaOptions options)
  349. {
  350. var directPlayProfile = options.Profile.DirectPlayProfiles
  351. .FirstOrDefault(x => x.Type == DlnaProfileType.Audio && IsAudioDirectPlaySupported(x, item, audioStream));
  352. TranscodeReason transcodeReasons = 0;
  353. if (directPlayProfile is null)
  354. {
  355. _logger.LogDebug(
  356. "Profile: {0}, No audio direct play profiles found for {1} with codec {2}",
  357. options.Profile.Name ?? "Unknown Profile",
  358. item.Path ?? "Unknown path",
  359. audioStream.Codec ?? "Unknown codec");
  360. var directStreamProfile = options.Profile.DirectPlayProfiles
  361. .FirstOrDefault(x => x.Type == DlnaProfileType.Audio && IsAudioDirectStreamSupported(x, item, audioStream));
  362. if (directStreamProfile is not null)
  363. {
  364. directPlayProfile = directStreamProfile;
  365. transcodeReasons |= TranscodeReason.ContainerNotSupported;
  366. }
  367. else
  368. {
  369. return (null, null, GetTranscodeReasonsFromDirectPlayProfile(item, null, audioStream, options.Profile.DirectPlayProfiles));
  370. }
  371. }
  372. // The profile describes what the device supports
  373. // If device requirements are satisfied then allow both direct stream and direct play
  374. // Note: As of 10.10 codebase, SupportsDirectPlay is always true because the MediaSourceInfo initializes this key as true
  375. // Need to check additionally for current transcode reasons
  376. if (item.SupportsDirectPlay && transcodeReasons == 0)
  377. {
  378. if (!IsBitrateLimitExceeded(item, options.GetMaxBitrate(true) ?? 0))
  379. {
  380. if (options.EnableDirectPlay)
  381. {
  382. return (directPlayProfile, PlayMethod.DirectPlay, 0);
  383. }
  384. }
  385. else
  386. {
  387. transcodeReasons |= TranscodeReason.ContainerBitrateExceedsLimit;
  388. }
  389. }
  390. // While options takes the network and other factors into account. Only applies to direct stream
  391. if (item.SupportsDirectStream)
  392. {
  393. if (!IsBitrateLimitExceeded(item, options.GetMaxBitrate(true) ?? 0))
  394. {
  395. // Note: as of 10.10 codebase, the options.EnableDirectStream is always false due to
  396. // "direct-stream http streaming is currently broken"
  397. // Don't check that option for audio as we always assume that is supported
  398. if (transcodeReasons == TranscodeReason.ContainerNotSupported)
  399. {
  400. return (directPlayProfile, PlayMethod.DirectStream, transcodeReasons);
  401. }
  402. }
  403. else
  404. {
  405. transcodeReasons |= TranscodeReason.ContainerBitrateExceedsLimit;
  406. }
  407. }
  408. return (directPlayProfile, null, transcodeReasons);
  409. }
  410. private static TranscodeReason GetTranscodeReasonsFromDirectPlayProfile(MediaSourceInfo item, MediaStream? videoStream, MediaStream audioStream, IEnumerable<DirectPlayProfile> directPlayProfiles)
  411. {
  412. var mediaType = videoStream is null ? DlnaProfileType.Audio : DlnaProfileType.Video;
  413. var containerSupported = false;
  414. var audioSupported = false;
  415. var videoSupported = false;
  416. foreach (var profile in directPlayProfiles)
  417. {
  418. // Check container type
  419. if (profile.Type == mediaType && profile.SupportsContainer(item.Container))
  420. {
  421. containerSupported = true;
  422. videoSupported = videoStream is null || profile.SupportsVideoCodec(videoStream.Codec);
  423. audioSupported = audioStream is null || profile.SupportsAudioCodec(audioStream.Codec);
  424. if (videoSupported && audioSupported)
  425. {
  426. break;
  427. }
  428. }
  429. }
  430. TranscodeReason reasons = 0;
  431. if (!containerSupported)
  432. {
  433. reasons |= TranscodeReason.ContainerNotSupported;
  434. }
  435. if (!videoSupported)
  436. {
  437. reasons |= TranscodeReason.VideoCodecNotSupported;
  438. }
  439. if (!audioSupported)
  440. {
  441. reasons |= TranscodeReason.AudioCodecNotSupported;
  442. }
  443. return reasons;
  444. }
  445. private static int? GetDefaultSubtitleStreamIndex(MediaSourceInfo item, SubtitleProfile[] subtitleProfiles)
  446. {
  447. int highestScore = -1;
  448. foreach (var stream in item.MediaStreams)
  449. {
  450. if (stream.Type == MediaStreamType.Subtitle
  451. && stream.Score.HasValue
  452. && stream.Score.Value > highestScore)
  453. {
  454. highestScore = stream.Score.Value;
  455. }
  456. }
  457. var topStreams = new List<MediaStream>();
  458. foreach (var stream in item.MediaStreams)
  459. {
  460. if (stream.Type == MediaStreamType.Subtitle && stream.Score.HasValue && stream.Score.Value == highestScore)
  461. {
  462. topStreams.Add(stream);
  463. }
  464. }
  465. // If multiple streams have an equal score, try to pick the most efficient one
  466. if (topStreams.Count > 1)
  467. {
  468. foreach (var stream in topStreams)
  469. {
  470. foreach (var profile in subtitleProfiles)
  471. {
  472. if (profile.Method == SubtitleDeliveryMethod.External && string.Equals(profile.Format, stream.Codec, StringComparison.OrdinalIgnoreCase))
  473. {
  474. return stream.Index;
  475. }
  476. }
  477. }
  478. }
  479. // If no optimization panned out, just use the original default
  480. return item.DefaultSubtitleStreamIndex;
  481. }
  482. private static void SetStreamInfoOptionsFromTranscodingProfile(MediaSourceInfo item, StreamInfo playlistItem, TranscodingProfile transcodingProfile)
  483. {
  484. var container = transcodingProfile.Container;
  485. var protocol = transcodingProfile.Protocol;
  486. item.TranscodingContainer = container;
  487. item.TranscodingSubProtocol = protocol;
  488. if (playlistItem.PlayMethod == PlayMethod.Transcode)
  489. {
  490. playlistItem.Container = container;
  491. playlistItem.SubProtocol = protocol;
  492. }
  493. playlistItem.TranscodeSeekInfo = transcodingProfile.TranscodeSeekInfo;
  494. if (int.TryParse(transcodingProfile.MaxAudioChannels, CultureInfo.InvariantCulture, out int transcodingMaxAudioChannels))
  495. {
  496. playlistItem.TranscodingMaxAudioChannels = transcodingMaxAudioChannels;
  497. }
  498. playlistItem.EstimateContentLength = transcodingProfile.EstimateContentLength;
  499. playlistItem.CopyTimestamps = transcodingProfile.CopyTimestamps;
  500. playlistItem.EnableSubtitlesInManifest = transcodingProfile.EnableSubtitlesInManifest;
  501. playlistItem.EnableMpegtsM2TsMode = transcodingProfile.EnableMpegtsM2TsMode;
  502. playlistItem.BreakOnNonKeyFrames = transcodingProfile.BreakOnNonKeyFrames;
  503. if (transcodingProfile.MinSegments > 0)
  504. {
  505. playlistItem.MinSegments = transcodingProfile.MinSegments;
  506. }
  507. if (transcodingProfile.SegmentLength > 0)
  508. {
  509. playlistItem.SegmentLength = transcodingProfile.SegmentLength;
  510. }
  511. }
  512. private static void SetStreamInfoOptionsFromDirectPlayProfile(MediaOptions options, MediaSourceInfo item, StreamInfo playlistItem, DirectPlayProfile? directPlayProfile)
  513. {
  514. var container = NormalizeMediaSourceFormatIntoSingleContainer(item.Container, options.Profile, DlnaProfileType.Video, directPlayProfile);
  515. var protocol = MediaStreamProtocol.http;
  516. item.TranscodingContainer = container;
  517. item.TranscodingSubProtocol = protocol;
  518. playlistItem.Container = container;
  519. playlistItem.SubProtocol = protocol;
  520. playlistItem.VideoCodecs = new[] { item.VideoStream.Codec };
  521. playlistItem.AudioCodecs = ContainerProfile.SplitValue(directPlayProfile?.AudioCodec);
  522. }
  523. private StreamInfo BuildVideoItem(MediaSourceInfo item, MediaOptions options)
  524. {
  525. ArgumentNullException.ThrowIfNull(item);
  526. StreamInfo playlistItem = new StreamInfo
  527. {
  528. ItemId = options.ItemId,
  529. MediaType = DlnaProfileType.Video,
  530. MediaSource = item,
  531. RunTimeTicks = item.RunTimeTicks,
  532. Context = options.Context,
  533. DeviceProfile = options.Profile,
  534. SubtitleStreamIndex = options.SubtitleStreamIndex ?? GetDefaultSubtitleStreamIndex(item, options.Profile.SubtitleProfiles)
  535. };
  536. var subtitleStream = playlistItem.SubtitleStreamIndex.HasValue ? item.GetMediaStream(MediaStreamType.Subtitle, playlistItem.SubtitleStreamIndex.Value) : null;
  537. var audioStream = item.GetDefaultAudioStream(options.AudioStreamIndex ?? item.DefaultAudioStreamIndex);
  538. if (audioStream is not null)
  539. {
  540. playlistItem.AudioStreamIndex = audioStream.Index;
  541. }
  542. // Collect candidate audio streams
  543. ICollection<MediaStream> candidateAudioStreams = audioStream is null ? Array.Empty<MediaStream>() : new[] { audioStream };
  544. if (!options.AudioStreamIndex.HasValue || options.AudioStreamIndex < 0)
  545. {
  546. if (audioStream?.IsDefault == true)
  547. {
  548. candidateAudioStreams = item.MediaStreams.Where(stream => stream.Type == MediaStreamType.Audio && stream.IsDefault).ToArray();
  549. }
  550. else
  551. {
  552. candidateAudioStreams = item.MediaStreams.Where(stream => stream.Type == MediaStreamType.Audio && stream.Language == audioStream?.Language).ToArray();
  553. }
  554. }
  555. var videoStream = item.VideoStream;
  556. var bitrateLimitExceeded = IsBitrateLimitExceeded(item, options.GetMaxBitrate(false) ?? 0);
  557. var isEligibleForDirectPlay = options.EnableDirectPlay && (options.ForceDirectPlay || !bitrateLimitExceeded);
  558. var isEligibleForDirectStream = options.EnableDirectStream && (options.ForceDirectStream || !bitrateLimitExceeded);
  559. TranscodeReason transcodeReasons = 0;
  560. // Force transcode or remux for BD/DVD folders
  561. if (item.VideoType == VideoType.Dvd || item.VideoType == VideoType.BluRay)
  562. {
  563. isEligibleForDirectPlay = false;
  564. }
  565. if (bitrateLimitExceeded)
  566. {
  567. transcodeReasons = TranscodeReason.ContainerBitrateExceedsLimit;
  568. }
  569. _logger.LogDebug(
  570. "Profile: {0}, Path: {1}, isEligibleForDirectPlay: {2}, isEligibleForDirectStream: {3}",
  571. options.Profile.Name ?? "Unknown Profile",
  572. item.Path ?? "Unknown path",
  573. isEligibleForDirectPlay,
  574. isEligibleForDirectStream);
  575. DirectPlayProfile? directPlayProfile = null;
  576. if (isEligibleForDirectPlay || isEligibleForDirectStream)
  577. {
  578. // See if it can be direct played
  579. var directPlayInfo = GetVideoDirectPlayProfile(options, item, videoStream, audioStream, candidateAudioStreams, subtitleStream, isEligibleForDirectPlay, isEligibleForDirectStream);
  580. var directPlay = directPlayInfo.PlayMethod;
  581. transcodeReasons |= directPlayInfo.TranscodeReasons;
  582. if (directPlay.HasValue)
  583. {
  584. directPlayProfile = directPlayInfo.Profile;
  585. playlistItem.PlayMethod = directPlay.Value;
  586. playlistItem.Container = NormalizeMediaSourceFormatIntoSingleContainer(item.Container, options.Profile, DlnaProfileType.Video, directPlayProfile);
  587. playlistItem.VideoCodecs = new[] { videoStream.Codec };
  588. if (directPlay == PlayMethod.DirectPlay)
  589. {
  590. playlistItem.SubProtocol = MediaStreamProtocol.http;
  591. var audioStreamIndex = directPlayInfo.AudioStreamIndex ?? audioStream?.Index;
  592. if (audioStreamIndex.HasValue)
  593. {
  594. playlistItem.AudioStreamIndex = audioStreamIndex;
  595. var audioCodec = item.GetMediaStream(MediaStreamType.Audio, audioStreamIndex.Value)?.Codec;
  596. playlistItem.AudioCodecs = audioCodec is null ? Array.Empty<string>() : new[] { audioCodec };
  597. }
  598. }
  599. else if (directPlay == PlayMethod.DirectStream)
  600. {
  601. playlistItem.AudioStreamIndex = audioStream?.Index;
  602. if (audioStream is not null)
  603. {
  604. playlistItem.AudioCodecs = ContainerProfile.SplitValue(directPlayProfile?.AudioCodec);
  605. }
  606. SetStreamInfoOptionsFromDirectPlayProfile(options, item, playlistItem, directPlayProfile);
  607. BuildStreamVideoItem(playlistItem, options, item, videoStream, audioStream, candidateAudioStreams, directPlayProfile?.Container, directPlayProfile?.VideoCodec, directPlayProfile?.AudioCodec);
  608. }
  609. if (subtitleStream is not null)
  610. {
  611. var subtitleProfile = GetSubtitleProfile(item, subtitleStream, options.Profile.SubtitleProfiles, directPlay.Value, _transcoderSupport, directPlayProfile?.Container, null);
  612. playlistItem.SubtitleDeliveryMethod = subtitleProfile.Method;
  613. playlistItem.SubtitleFormat = subtitleProfile.Format;
  614. }
  615. }
  616. _logger.LogDebug(
  617. "DirectPlay Result for Profile: {0}, Path: {1}, PlayMethod: {2}, AudioStreamIndex: {3}, SubtitleStreamIndex: {4}, Reasons: {5}",
  618. options.Profile.Name ?? "Anonymous Profile",
  619. item.Path ?? "Unknown path",
  620. directPlayInfo.PlayMethod,
  621. directPlayInfo.AudioStreamIndex ?? audioStream?.Index,
  622. playlistItem.SubtitleStreamIndex,
  623. directPlayInfo.TranscodeReasons);
  624. }
  625. playlistItem.TranscodeReasons = transcodeReasons;
  626. if (playlistItem.PlayMethod != PlayMethod.DirectStream && playlistItem.PlayMethod != PlayMethod.DirectPlay)
  627. {
  628. // Can't direct play, find the transcoding profile
  629. // If we do this for direct-stream we will overwrite the info
  630. var transcodingProfile = GetVideoTranscodeProfile(item, options, videoStream, audioStream, candidateAudioStreams, subtitleStream, playlistItem);
  631. if (transcodingProfile is not null)
  632. {
  633. SetStreamInfoOptionsFromTranscodingProfile(item, playlistItem, transcodingProfile);
  634. BuildStreamVideoItem(playlistItem, options, item, videoStream, audioStream, candidateAudioStreams, transcodingProfile.Container, transcodingProfile.VideoCodec, transcodingProfile.AudioCodec);
  635. playlistItem.PlayMethod = PlayMethod.Transcode;
  636. if (subtitleStream is not null)
  637. {
  638. var subtitleProfile = GetSubtitleProfile(item, subtitleStream, options.Profile.SubtitleProfiles, PlayMethod.Transcode, _transcoderSupport, transcodingProfile.Container, transcodingProfile.Protocol);
  639. playlistItem.SubtitleDeliveryMethod = subtitleProfile.Method;
  640. playlistItem.SubtitleFormat = subtitleProfile.Format;
  641. playlistItem.SubtitleCodecs = new[] { subtitleProfile.Format };
  642. }
  643. if ((playlistItem.TranscodeReasons & (VideoReasons | TranscodeReason.ContainerBitrateExceedsLimit)) != 0)
  644. {
  645. ApplyTranscodingConditions(playlistItem, transcodingProfile.Conditions, null, true, true);
  646. }
  647. }
  648. }
  649. _logger.LogDebug(
  650. "StreamBuilder.BuildVideoItem( Profile={0}, Path={1}, AudioStreamIndex={2}, SubtitleStreamIndex={3} ) => ( PlayMethod={4}, TranscodeReason={5} ) {6}",
  651. options.Profile.Name ?? "Anonymous Profile",
  652. item.Path ?? "Unknown path",
  653. options.AudioStreamIndex,
  654. options.SubtitleStreamIndex,
  655. playlistItem.PlayMethod,
  656. playlistItem.TranscodeReasons,
  657. playlistItem.ToUrl("media:", "<token>"));
  658. item.Container = NormalizeMediaSourceFormatIntoSingleContainer(item.Container, options.Profile, DlnaProfileType.Video, directPlayProfile);
  659. return playlistItem;
  660. }
  661. private TranscodingProfile? GetVideoTranscodeProfile(
  662. MediaSourceInfo item,
  663. MediaOptions options,
  664. MediaStream? videoStream,
  665. MediaStream? audioStream,
  666. IEnumerable<MediaStream> candidateAudioStreams,
  667. MediaStream? subtitleStream,
  668. StreamInfo playlistItem)
  669. {
  670. if (!(item.SupportsTranscoding || item.SupportsDirectStream))
  671. {
  672. return null;
  673. }
  674. var transcodingProfiles = options.Profile.TranscodingProfiles
  675. .Where(i => i.Type == playlistItem.MediaType && i.Context == options.Context);
  676. if (options.AllowVideoStreamCopy)
  677. {
  678. // prefer direct copy profile
  679. float videoFramerate = videoStream?.AverageFrameRate ?? videoStream?.RealFrameRate ?? 0;
  680. TransportStreamTimestamp? timestamp = videoStream is null ? TransportStreamTimestamp.None : item.Timestamp;
  681. int? numAudioStreams = item.GetStreamCount(MediaStreamType.Audio);
  682. int? numVideoStreams = item.GetStreamCount(MediaStreamType.Video);
  683. transcodingProfiles = transcodingProfiles.ToLookup(transcodingProfile =>
  684. {
  685. var videoCodecs = ContainerProfile.SplitValue(transcodingProfile.VideoCodec);
  686. if (ContainerProfile.ContainsContainer(videoCodecs, item.VideoStream?.Codec))
  687. {
  688. var videoCodec = videoStream?.Codec;
  689. var container = transcodingProfile.Container;
  690. var appliedVideoConditions = options.Profile.CodecProfiles
  691. .Where(i => i.Type == CodecType.Video &&
  692. i.ContainsAnyCodec(videoCodec, container) &&
  693. i.ApplyConditions.All(applyCondition => ConditionProcessor.IsVideoConditionSatisfied(applyCondition, videoStream?.Width, videoStream?.Height, videoStream?.BitDepth, videoStream?.BitRate, videoStream?.Profile, videoStream?.VideoRangeType, videoStream?.Level, videoFramerate, videoStream?.PacketLength, timestamp, videoStream?.IsAnamorphic, videoStream?.IsInterlaced, videoStream?.RefFrames, numVideoStreams, numAudioStreams, videoStream?.CodecTag, videoStream?.IsAVC)))
  694. .Select(i =>
  695. i.Conditions.All(condition => ConditionProcessor.IsVideoConditionSatisfied(condition, videoStream?.Width, videoStream?.Height, videoStream?.BitDepth, videoStream?.BitRate, videoStream?.Profile, videoStream?.VideoRangeType, videoStream?.Level, videoFramerate, videoStream?.PacketLength, timestamp, videoStream?.IsAnamorphic, videoStream?.IsInterlaced, videoStream?.RefFrames, numVideoStreams, numAudioStreams, videoStream?.CodecTag, videoStream?.IsAVC)));
  696. // An empty appliedVideoConditions means that the codec has no conditions for the current video stream
  697. var conditionsSatisfied = appliedVideoConditions.All(satisfied => satisfied);
  698. return conditionsSatisfied ? 1 : 2;
  699. }
  700. return 3;
  701. })
  702. .OrderBy(lookup => lookup.Key)
  703. .SelectMany(lookup => lookup);
  704. }
  705. return transcodingProfiles.FirstOrDefault();
  706. }
  707. private void BuildStreamVideoItem(
  708. StreamInfo playlistItem,
  709. MediaOptions options,
  710. MediaSourceInfo item,
  711. MediaStream? videoStream,
  712. MediaStream? audioStream,
  713. IEnumerable<MediaStream> candidateAudioStreams,
  714. string? container,
  715. string? videoCodec,
  716. string? audioCodec)
  717. {
  718. // Prefer matching video codecs
  719. var videoCodecs = ContainerProfile.SplitValue(videoCodec);
  720. // Enforce HLS video codec restrictions
  721. if (playlistItem.SubProtocol == MediaStreamProtocol.hls)
  722. {
  723. videoCodecs = videoCodecs.Where(codec => _supportedHlsVideoCodecs.Contains(codec)).ToArray();
  724. }
  725. var directVideoCodec = ContainerProfile.ContainsContainer(videoCodecs, videoStream?.Codec) ? videoStream?.Codec : null;
  726. if (directVideoCodec is not null)
  727. {
  728. // merge directVideoCodec to videoCodecs
  729. Array.Resize(ref videoCodecs, videoCodecs.Length + 1);
  730. videoCodecs[^1] = directVideoCodec;
  731. }
  732. playlistItem.VideoCodecs = videoCodecs;
  733. // Copy video codec options as a starting point, this applies to transcode and direct-stream
  734. playlistItem.MaxFramerate = videoStream?.AverageFrameRate;
  735. var qualifier = videoStream?.Codec;
  736. if (videoStream?.Level is not null)
  737. {
  738. playlistItem.SetOption(qualifier, "level", videoStream.Level.Value.ToString(CultureInfo.InvariantCulture));
  739. }
  740. if (videoStream?.BitDepth is not null)
  741. {
  742. playlistItem.SetOption(qualifier, "videobitdepth", videoStream.BitDepth.Value.ToString(CultureInfo.InvariantCulture));
  743. }
  744. if (!string.IsNullOrEmpty(videoStream?.Profile))
  745. {
  746. playlistItem.SetOption(qualifier, "profile", videoStream.Profile.ToLowerInvariant());
  747. }
  748. // Prefer matching audio codecs, could do better here
  749. var audioCodecs = ContainerProfile.SplitValue(audioCodec);
  750. // Enforce HLS audio codec restrictions
  751. if (playlistItem.SubProtocol == MediaStreamProtocol.hls)
  752. {
  753. if (string.Equals(playlistItem.Container, "mp4", StringComparison.OrdinalIgnoreCase))
  754. {
  755. audioCodecs = audioCodecs.Where(codec => _supportedHlsAudioCodecsMp4.Contains(codec)).ToArray();
  756. }
  757. else
  758. {
  759. audioCodecs = audioCodecs.Where(codec => _supportedHlsAudioCodecsTs.Contains(codec)).ToArray();
  760. }
  761. }
  762. var directAudioStream = candidateAudioStreams.FirstOrDefault(stream => ContainerProfile.ContainsContainer(audioCodecs, stream.Codec));
  763. playlistItem.AudioCodecs = audioCodecs;
  764. if (directAudioStream is not null)
  765. {
  766. audioStream = directAudioStream;
  767. playlistItem.AudioStreamIndex = audioStream.Index;
  768. playlistItem.AudioCodecs = new[] { audioStream.Codec };
  769. // Copy matching audio codec options
  770. playlistItem.AudioSampleRate = audioStream.SampleRate;
  771. playlistItem.SetOption(qualifier, "audiochannels", audioStream.Channels?.ToString(CultureInfo.InvariantCulture) ?? string.Empty);
  772. if (!string.IsNullOrEmpty(audioStream.Profile))
  773. {
  774. playlistItem.SetOption(audioStream.Codec, "profile", audioStream.Profile.ToLowerInvariant());
  775. }
  776. if (audioStream.Level.HasValue && audioStream.Level.Value != 0)
  777. {
  778. playlistItem.SetOption(audioStream.Codec, "level", audioStream.Level.Value.ToString(CultureInfo.InvariantCulture));
  779. }
  780. }
  781. int? width = videoStream?.Width;
  782. int? height = videoStream?.Height;
  783. int? bitDepth = videoStream?.BitDepth;
  784. int? videoBitrate = videoStream?.BitRate;
  785. double? videoLevel = videoStream?.Level;
  786. string? videoProfile = videoStream?.Profile;
  787. VideoRangeType? videoRangeType = videoStream?.VideoRangeType;
  788. float videoFramerate = videoStream is null ? 0 : videoStream.AverageFrameRate ?? videoStream.AverageFrameRate ?? 0;
  789. bool? isAnamorphic = videoStream?.IsAnamorphic;
  790. bool? isInterlaced = videoStream?.IsInterlaced;
  791. string? videoCodecTag = videoStream?.CodecTag;
  792. bool? isAvc = videoStream?.IsAVC;
  793. TransportStreamTimestamp? timestamp = videoStream is null ? TransportStreamTimestamp.None : item.Timestamp;
  794. int? packetLength = videoStream?.PacketLength;
  795. int? refFrames = videoStream?.RefFrames;
  796. int? numAudioStreams = item.GetStreamCount(MediaStreamType.Audio);
  797. int? numVideoStreams = item.GetStreamCount(MediaStreamType.Video);
  798. var appliedVideoConditions = options.Profile.CodecProfiles
  799. .Where(i => i.Type == CodecType.Video &&
  800. i.ContainsAnyCodec(videoStream?.Codec, container) &&
  801. i.ApplyConditions.All(applyCondition => ConditionProcessor.IsVideoConditionSatisfied(applyCondition, width, height, bitDepth, videoBitrate, videoProfile, videoRangeType, videoLevel, videoFramerate, packetLength, timestamp, isAnamorphic, isInterlaced, refFrames, numVideoStreams, numAudioStreams, videoCodecTag, isAvc)));
  802. var isFirstAppliedCodecProfile = true;
  803. foreach (var i in appliedVideoConditions)
  804. {
  805. var transcodingVideoCodecs = ContainerProfile.SplitValue(videoCodec);
  806. foreach (var transcodingVideoCodec in transcodingVideoCodecs)
  807. {
  808. if (i.ContainsAnyCodec(transcodingVideoCodec, container))
  809. {
  810. ApplyTranscodingConditions(playlistItem, i.Conditions, transcodingVideoCodec, true, isFirstAppliedCodecProfile);
  811. isFirstAppliedCodecProfile = false;
  812. continue;
  813. }
  814. }
  815. }
  816. // Honor requested max channels
  817. playlistItem.GlobalMaxAudioChannels = options.MaxAudioChannels;
  818. int audioBitrate = GetAudioBitrate(options.GetMaxBitrate(true) ?? 0, playlistItem.TargetAudioCodec, audioStream, playlistItem);
  819. playlistItem.AudioBitrate = Math.Min(playlistItem.AudioBitrate ?? audioBitrate, audioBitrate);
  820. bool? isSecondaryAudio = audioStream is null ? null : item.IsSecondaryAudio(audioStream);
  821. int? inputAudioBitrate = audioStream?.BitRate;
  822. int? audioChannels = audioStream?.Channels;
  823. string? audioProfile = audioStream?.Profile;
  824. int? inputAudioSampleRate = audioStream?.SampleRate;
  825. int? inputAudioBitDepth = audioStream?.BitDepth;
  826. var appliedAudioConditions = options.Profile.CodecProfiles
  827. .Where(i => i.Type == CodecType.VideoAudio &&
  828. i.ContainsAnyCodec(audioStream?.Codec, container) &&
  829. i.ApplyConditions.All(applyCondition => ConditionProcessor.IsVideoAudioConditionSatisfied(applyCondition, audioChannels, inputAudioBitrate, inputAudioSampleRate, inputAudioBitDepth, audioProfile, isSecondaryAudio)));
  830. isFirstAppliedCodecProfile = true;
  831. foreach (var codecProfile in appliedAudioConditions)
  832. {
  833. var transcodingAudioCodecs = ContainerProfile.SplitValue(audioCodec);
  834. foreach (var transcodingAudioCodec in transcodingAudioCodecs)
  835. {
  836. if (codecProfile.ContainsAnyCodec(transcodingAudioCodec, container))
  837. {
  838. ApplyTranscodingConditions(playlistItem, codecProfile.Conditions, transcodingAudioCodec, true, isFirstAppliedCodecProfile);
  839. isFirstAppliedCodecProfile = false;
  840. break;
  841. }
  842. }
  843. }
  844. var maxBitrateSetting = options.GetMaxBitrate(false);
  845. // Honor max rate
  846. if (maxBitrateSetting.HasValue)
  847. {
  848. var availableBitrateForVideo = maxBitrateSetting.Value;
  849. if (playlistItem.AudioBitrate.HasValue)
  850. {
  851. availableBitrateForVideo -= playlistItem.AudioBitrate.Value;
  852. }
  853. // Make sure the video bitrate is lower than bitrate settings but at least 64k
  854. // Don't use Math.Clamp as availableBitrateForVideo can be lower then 64k.
  855. var currentValue = playlistItem.VideoBitrate ?? availableBitrateForVideo;
  856. playlistItem.VideoBitrate = Math.Max(Math.Min(availableBitrateForVideo, currentValue), 64_000);
  857. }
  858. _logger.LogDebug(
  859. "Transcode Result for Profile: {Profile}, Path: {Path}, PlayMethod: {PlayMethod}, AudioStreamIndex: {AudioStreamIndex}, SubtitleStreamIndex: {SubtitleStreamIndex}, Reasons: {TranscodeReason}",
  860. options.Profile?.Name ?? "Anonymous Profile",
  861. item.Path ?? "Unknown path",
  862. playlistItem?.PlayMethod,
  863. audioStream?.Index,
  864. playlistItem?.SubtitleStreamIndex,
  865. playlistItem?.TranscodeReasons);
  866. }
  867. private static int GetDefaultAudioBitrate(string? audioCodec, int? audioChannels)
  868. {
  869. if (!string.IsNullOrEmpty(audioCodec))
  870. {
  871. // Default to a higher bitrate for stream copy
  872. if (string.Equals(audioCodec, "aac", StringComparison.OrdinalIgnoreCase)
  873. || string.Equals(audioCodec, "mp3", StringComparison.OrdinalIgnoreCase)
  874. || string.Equals(audioCodec, "ac3", StringComparison.OrdinalIgnoreCase)
  875. || string.Equals(audioCodec, "eac3", StringComparison.OrdinalIgnoreCase))
  876. {
  877. if ((audioChannels ?? 0) < 2)
  878. {
  879. return 128000;
  880. }
  881. return (audioChannels ?? 0) >= 6 ? 640000 : 384000;
  882. }
  883. if (string.Equals(audioCodec, "flac", StringComparison.OrdinalIgnoreCase)
  884. || string.Equals(audioCodec, "alac", StringComparison.OrdinalIgnoreCase))
  885. {
  886. if ((audioChannels ?? 0) < 2)
  887. {
  888. return 768000;
  889. }
  890. return (audioChannels ?? 0) >= 6 ? 3584000 : 1536000;
  891. }
  892. }
  893. return 192000;
  894. }
  895. private static int GetAudioBitrate(long maxTotalBitrate, string[] targetAudioCodecs, MediaStream? audioStream, StreamInfo item)
  896. {
  897. string? targetAudioCodec = targetAudioCodecs.Length == 0 ? null : targetAudioCodecs[0];
  898. int? targetAudioChannels = item.GetTargetAudioChannels(targetAudioCodec);
  899. int defaultBitrate;
  900. int encoderAudioBitrateLimit = int.MaxValue;
  901. if (audioStream is null)
  902. {
  903. defaultBitrate = 192000;
  904. }
  905. else
  906. {
  907. if (targetAudioChannels.HasValue
  908. && audioStream.Channels.HasValue
  909. && audioStream.Channels.Value > targetAudioChannels.Value)
  910. {
  911. // Reduce the bitrate if we're downmixing.
  912. defaultBitrate = GetDefaultAudioBitrate(targetAudioCodec, targetAudioChannels);
  913. }
  914. else if (targetAudioChannels.HasValue
  915. && audioStream.Channels.HasValue
  916. && audioStream.Channels.Value <= targetAudioChannels.Value
  917. && !string.IsNullOrEmpty(audioStream.Codec)
  918. && targetAudioCodecs is not null
  919. && targetAudioCodecs.Length > 0
  920. && !Array.Exists(targetAudioCodecs, elem => string.Equals(audioStream.Codec, elem, StringComparison.OrdinalIgnoreCase)))
  921. {
  922. // Shift the bitrate if we're transcoding to a different audio codec.
  923. defaultBitrate = GetDefaultAudioBitrate(targetAudioCodec, audioStream.Channels.Value);
  924. }
  925. else
  926. {
  927. defaultBitrate = audioStream.BitRate ?? GetDefaultAudioBitrate(targetAudioCodec, targetAudioChannels);
  928. }
  929. // Seeing webm encoding failures when source has 1 audio channel and 22k bitrate.
  930. // Any attempts to transcode over 64k will fail
  931. if (audioStream.Channels == 1
  932. && (audioStream.BitRate ?? 0) < 64000)
  933. {
  934. encoderAudioBitrateLimit = 64000;
  935. }
  936. }
  937. if (maxTotalBitrate > 0)
  938. {
  939. defaultBitrate = Math.Min(GetMaxAudioBitrateForTotalBitrate(maxTotalBitrate), defaultBitrate);
  940. }
  941. return Math.Min(defaultBitrate, encoderAudioBitrateLimit);
  942. }
  943. private static int GetMaxAudioBitrateForTotalBitrate(long totalBitrate)
  944. {
  945. if (totalBitrate <= 640000)
  946. {
  947. return 128000;
  948. }
  949. if (totalBitrate <= 2000000)
  950. {
  951. return 384000;
  952. }
  953. if (totalBitrate <= 3000000)
  954. {
  955. return 448000;
  956. }
  957. if (totalBitrate <= 4000000)
  958. {
  959. return 640000;
  960. }
  961. if (totalBitrate <= 5000000)
  962. {
  963. return 768000;
  964. }
  965. if (totalBitrate <= 10000000)
  966. {
  967. return 1536000;
  968. }
  969. if (totalBitrate <= 15000000)
  970. {
  971. return 2304000;
  972. }
  973. if (totalBitrate <= 20000000)
  974. {
  975. return 3584000;
  976. }
  977. return 7168000;
  978. }
  979. private (DirectPlayProfile? Profile, PlayMethod? PlayMethod, int? AudioStreamIndex, TranscodeReason TranscodeReasons) GetVideoDirectPlayProfile(
  980. MediaOptions options,
  981. MediaSourceInfo mediaSource,
  982. MediaStream? videoStream,
  983. MediaStream? audioStream,
  984. ICollection<MediaStream> candidateAudioStreams,
  985. MediaStream? subtitleStream,
  986. bool isEligibleForDirectPlay,
  987. bool isEligibleForDirectStream)
  988. {
  989. if (options.ForceDirectPlay)
  990. {
  991. return (null, PlayMethod.DirectPlay, audioStream?.Index, 0);
  992. }
  993. if (options.ForceDirectStream)
  994. {
  995. return (null, PlayMethod.DirectStream, audioStream?.Index, 0);
  996. }
  997. DeviceProfile profile = options.Profile;
  998. string container = mediaSource.Container;
  999. // Video
  1000. int? width = videoStream?.Width;
  1001. int? height = videoStream?.Height;
  1002. int? bitDepth = videoStream?.BitDepth;
  1003. int? videoBitrate = videoStream?.BitRate;
  1004. double? videoLevel = videoStream?.Level;
  1005. string? videoProfile = videoStream?.Profile;
  1006. VideoRangeType? videoRangeType = videoStream?.VideoRangeType;
  1007. float videoFramerate = videoStream is null ? 0 : videoStream.AverageFrameRate ?? videoStream.AverageFrameRate ?? 0;
  1008. bool? isAnamorphic = videoStream?.IsAnamorphic;
  1009. bool? isInterlaced = videoStream?.IsInterlaced;
  1010. string? videoCodecTag = videoStream?.CodecTag;
  1011. bool? isAvc = videoStream?.IsAVC;
  1012. TransportStreamTimestamp? timestamp = videoStream is null ? TransportStreamTimestamp.None : mediaSource.Timestamp;
  1013. int? packetLength = videoStream?.PacketLength;
  1014. int? refFrames = videoStream?.RefFrames;
  1015. int? numAudioStreams = mediaSource.GetStreamCount(MediaStreamType.Audio);
  1016. int? numVideoStreams = mediaSource.GetStreamCount(MediaStreamType.Video);
  1017. var checkVideoConditions = (ProfileCondition[] conditions) =>
  1018. conditions.Where(applyCondition => !ConditionProcessor.IsVideoConditionSatisfied(applyCondition, width, height, bitDepth, videoBitrate, videoProfile, videoRangeType, videoLevel, videoFramerate, packetLength, timestamp, isAnamorphic, isInterlaced, refFrames, numVideoStreams, numAudioStreams, videoCodecTag, isAvc));
  1019. // Check container conditions
  1020. var containerProfileReasons = AggregateFailureConditions(
  1021. mediaSource,
  1022. profile,
  1023. "VideoCodecProfile",
  1024. profile.ContainerProfiles
  1025. .Where(containerProfile => containerProfile.Type == DlnaProfileType.Video && containerProfile.ContainsContainer(container))
  1026. .SelectMany(containerProfile => checkVideoConditions(containerProfile.Conditions)));
  1027. // Check video conditions
  1028. var videoCodecProfileReasons = AggregateFailureConditions(
  1029. mediaSource,
  1030. profile,
  1031. "VideoCodecProfile",
  1032. profile.CodecProfiles
  1033. .Where(codecProfile => codecProfile.Type == CodecType.Video &&
  1034. codecProfile.ContainsAnyCodec(videoStream?.Codec, container) &&
  1035. !checkVideoConditions(codecProfile.ApplyConditions).Any())
  1036. .SelectMany(codecProfile => checkVideoConditions(codecProfile.Conditions)));
  1037. // Check audiocandidates profile conditions
  1038. var audioStreamMatches = candidateAudioStreams.ToDictionary(s => s, audioStream => CheckVideoAudioStreamDirectPlay(options, mediaSource, container, audioStream));
  1039. TranscodeReason subtitleProfileReasons = 0;
  1040. if (subtitleStream is not null)
  1041. {
  1042. var subtitleProfile = GetSubtitleProfile(mediaSource, subtitleStream, options.Profile.SubtitleProfiles, PlayMethod.DirectPlay, _transcoderSupport, container, null);
  1043. if (subtitleProfile.Method != SubtitleDeliveryMethod.Drop
  1044. && subtitleProfile.Method != SubtitleDeliveryMethod.External
  1045. && subtitleProfile.Method != SubtitleDeliveryMethod.Embed)
  1046. {
  1047. _logger.LogDebug("Not eligible for {0} due to unsupported subtitles", PlayMethod.DirectPlay);
  1048. subtitleProfileReasons |= TranscodeReason.SubtitleCodecNotSupported;
  1049. }
  1050. }
  1051. var rankings = new[] { VideoReasons, AudioReasons, ContainerReasons };
  1052. var rank = (ref TranscodeReason a) =>
  1053. {
  1054. var index = 1;
  1055. foreach (var flag in rankings)
  1056. {
  1057. var reason = a & flag;
  1058. if (reason != 0)
  1059. {
  1060. return index;
  1061. }
  1062. index++;
  1063. }
  1064. return index;
  1065. };
  1066. var containerSupported = false;
  1067. // Check DirectPlay profiles to see if it can be direct played
  1068. var analyzedProfiles = profile.DirectPlayProfiles
  1069. .Where(directPlayProfile => directPlayProfile.Type == DlnaProfileType.Video)
  1070. .Select((directPlayProfile, order) =>
  1071. {
  1072. TranscodeReason directPlayProfileReasons = 0;
  1073. TranscodeReason audioCodecProfileReasons = 0;
  1074. // Check container type
  1075. if (!directPlayProfile.SupportsContainer(container))
  1076. {
  1077. directPlayProfileReasons |= TranscodeReason.ContainerNotSupported;
  1078. }
  1079. else
  1080. {
  1081. containerSupported = true;
  1082. }
  1083. // Check video codec
  1084. string? videoCodec = videoStream?.Codec;
  1085. if (!directPlayProfile.SupportsVideoCodec(videoCodec))
  1086. {
  1087. directPlayProfileReasons |= TranscodeReason.VideoCodecNotSupported;
  1088. }
  1089. // Check audio codec
  1090. MediaStream? selectedAudioStream = null;
  1091. if (candidateAudioStreams.Any())
  1092. {
  1093. selectedAudioStream = candidateAudioStreams.FirstOrDefault(audioStream => directPlayProfile.SupportsAudioCodec(audioStream.Codec));
  1094. if (selectedAudioStream is null)
  1095. {
  1096. directPlayProfileReasons |= TranscodeReason.AudioCodecNotSupported;
  1097. }
  1098. else
  1099. {
  1100. audioCodecProfileReasons = audioStreamMatches.GetValueOrDefault(selectedAudioStream);
  1101. }
  1102. }
  1103. var failureReasons = directPlayProfileReasons | containerProfileReasons | subtitleProfileReasons;
  1104. if ((failureReasons & TranscodeReason.VideoCodecNotSupported) == 0)
  1105. {
  1106. failureReasons |= videoCodecProfileReasons;
  1107. }
  1108. if ((failureReasons & TranscodeReason.AudioCodecNotSupported) == 0)
  1109. {
  1110. failureReasons |= audioCodecProfileReasons;
  1111. }
  1112. var directStreamFailureReasons = failureReasons & (~DirectStreamReasons);
  1113. PlayMethod? playMethod = null;
  1114. if (failureReasons == 0 && isEligibleForDirectPlay && mediaSource.SupportsDirectPlay)
  1115. {
  1116. playMethod = PlayMethod.DirectPlay;
  1117. }
  1118. else if (directStreamFailureReasons == 0 && isEligibleForDirectStream && mediaSource.SupportsDirectStream)
  1119. {
  1120. playMethod = PlayMethod.DirectStream;
  1121. }
  1122. var ranked = rank(ref failureReasons);
  1123. return (Result: (Profile: directPlayProfile, PlayMethod: playMethod, AudioStreamIndex: selectedAudioStream?.Index, TranscodeReason: failureReasons), Order: order, Rank: ranked);
  1124. })
  1125. .OrderByDescending(analysis => analysis.Result.PlayMethod)
  1126. .ThenByDescending(analysis => analysis.Rank)
  1127. .ThenBy(analysis => analysis.Order)
  1128. .ToArray()
  1129. .ToLookup(analysis => analysis.Result.PlayMethod is not null);
  1130. var profileMatch = analyzedProfiles[true]
  1131. .Select(analysis => analysis.Result)
  1132. .FirstOrDefault();
  1133. if (profileMatch.Profile is not null)
  1134. {
  1135. return profileMatch;
  1136. }
  1137. var failureReasons = analyzedProfiles[false]
  1138. .Select(analysis => analysis.Result)
  1139. .Where(result => !containerSupported || (result.TranscodeReason & TranscodeReason.ContainerNotSupported) == 0)
  1140. .FirstOrDefault().TranscodeReason;
  1141. if (failureReasons == 0)
  1142. {
  1143. failureReasons = TranscodeReason.DirectPlayError;
  1144. }
  1145. return (Profile: null, PlayMethod: null, AudioStreamIndex: null, TranscodeReasons: failureReasons);
  1146. }
  1147. private TranscodeReason CheckVideoAudioStreamDirectPlay(MediaOptions options, MediaSourceInfo mediaSource, string container, MediaStream audioStream)
  1148. {
  1149. var profile = options.Profile;
  1150. var audioFailureConditions = GetProfileConditionsForVideoAudio(profile.CodecProfiles, container, audioStream.Codec, audioStream.Channels, audioStream.BitRate, audioStream.SampleRate, audioStream.BitDepth, audioStream.Profile, mediaSource.IsSecondaryAudio(audioStream));
  1151. var audioStreamFailureReasons = AggregateFailureConditions(mediaSource, profile, "VideoAudioCodecProfile", audioFailureConditions);
  1152. if (audioStream.IsExternal == true)
  1153. {
  1154. audioStreamFailureReasons |= TranscodeReason.AudioIsExternal;
  1155. }
  1156. return audioStreamFailureReasons;
  1157. }
  1158. private TranscodeReason AggregateFailureConditions(MediaSourceInfo mediaSource, DeviceProfile profile, string type, IEnumerable<ProfileCondition> conditions)
  1159. {
  1160. return conditions.Aggregate<ProfileCondition, TranscodeReason>(0, (reasons, i) =>
  1161. {
  1162. LogConditionFailure(profile, type, i, mediaSource);
  1163. var transcodeReasons = GetTranscodeReasonForFailedCondition(i);
  1164. return reasons | transcodeReasons;
  1165. });
  1166. }
  1167. private void LogConditionFailure(DeviceProfile profile, string type, ProfileCondition condition, MediaSourceInfo mediaSource)
  1168. {
  1169. _logger.LogDebug(
  1170. "Profile: {0}, DirectPlay=false. Reason={1}.{2} Condition: {3}. ConditionValue: {4}. IsRequired: {5}. Path: {6}",
  1171. type,
  1172. profile.Name ?? "Unknown Profile",
  1173. condition.Property,
  1174. condition.Condition,
  1175. condition.Value ?? string.Empty,
  1176. condition.IsRequired,
  1177. mediaSource.Path ?? "Unknown path");
  1178. }
  1179. /// <summary>
  1180. /// Normalizes input container.
  1181. /// </summary>
  1182. /// <param name="mediaSource">The <see cref="MediaSourceInfo"/>.</param>
  1183. /// <param name="subtitleStream">The <see cref="MediaStream"/> of the subtitle stream.</param>
  1184. /// <param name="subtitleProfiles">The list of supported <see cref="SubtitleProfile"/>s.</param>
  1185. /// <param name="playMethod">The <see cref="PlayMethod"/>.</param>
  1186. /// <param name="transcoderSupport">The <see cref="ITranscoderSupport"/>.</param>
  1187. /// <param name="outputContainer">The output container.</param>
  1188. /// <param name="transcodingSubProtocol">The subtitle transoding protocol.</param>
  1189. /// <returns>The normalized input container.</returns>
  1190. public static SubtitleProfile GetSubtitleProfile(
  1191. MediaSourceInfo mediaSource,
  1192. MediaStream subtitleStream,
  1193. SubtitleProfile[] subtitleProfiles,
  1194. PlayMethod playMethod,
  1195. ITranscoderSupport transcoderSupport,
  1196. string? outputContainer,
  1197. MediaStreamProtocol? transcodingSubProtocol)
  1198. {
  1199. if (!subtitleStream.IsExternal && (playMethod != PlayMethod.Transcode || transcodingSubProtocol != MediaStreamProtocol.hls))
  1200. {
  1201. // Look for supported embedded subs of the same format
  1202. foreach (var profile in subtitleProfiles)
  1203. {
  1204. if (!profile.SupportsLanguage(subtitleStream.Language))
  1205. {
  1206. continue;
  1207. }
  1208. if (profile.Method != SubtitleDeliveryMethod.Embed)
  1209. {
  1210. continue;
  1211. }
  1212. if (!ContainerProfile.ContainsContainer(profile.Container, outputContainer))
  1213. {
  1214. continue;
  1215. }
  1216. if (playMethod == PlayMethod.Transcode && !IsSubtitleEmbedSupported(outputContainer))
  1217. {
  1218. continue;
  1219. }
  1220. if (subtitleStream.IsTextSubtitleStream == MediaStream.IsTextFormat(profile.Format) && string.Equals(profile.Format, subtitleStream.Codec, StringComparison.OrdinalIgnoreCase))
  1221. {
  1222. return profile;
  1223. }
  1224. }
  1225. // Look for supported embedded subs of a convertible format
  1226. foreach (var profile in subtitleProfiles)
  1227. {
  1228. if (!profile.SupportsLanguage(subtitleStream.Language))
  1229. {
  1230. continue;
  1231. }
  1232. if (profile.Method != SubtitleDeliveryMethod.Embed)
  1233. {
  1234. continue;
  1235. }
  1236. if (!ContainerProfile.ContainsContainer(profile.Container, outputContainer))
  1237. {
  1238. continue;
  1239. }
  1240. if (playMethod == PlayMethod.Transcode && !IsSubtitleEmbedSupported(outputContainer))
  1241. {
  1242. continue;
  1243. }
  1244. if (subtitleStream.IsTextSubtitleStream && subtitleStream.SupportsSubtitleConversionTo(profile.Format))
  1245. {
  1246. return profile;
  1247. }
  1248. }
  1249. }
  1250. // Look for an external or hls profile that matches the stream type (text/graphical) and doesn't require conversion
  1251. return GetExternalSubtitleProfile(mediaSource, subtitleStream, subtitleProfiles, playMethod, transcoderSupport, false) ??
  1252. GetExternalSubtitleProfile(mediaSource, subtitleStream, subtitleProfiles, playMethod, transcoderSupport, true) ??
  1253. new SubtitleProfile
  1254. {
  1255. Method = SubtitleDeliveryMethod.Encode,
  1256. Format = subtitleStream.Codec
  1257. };
  1258. }
  1259. private static bool IsSubtitleEmbedSupported(string? transcodingContainer)
  1260. {
  1261. if (!string.IsNullOrEmpty(transcodingContainer))
  1262. {
  1263. string[] normalizedContainers = ContainerProfile.SplitValue(transcodingContainer);
  1264. if (ContainerProfile.ContainsContainer(normalizedContainers, "ts")
  1265. || ContainerProfile.ContainsContainer(normalizedContainers, "mpegts")
  1266. || ContainerProfile.ContainsContainer(normalizedContainers, "mp4"))
  1267. {
  1268. return false;
  1269. }
  1270. if (ContainerProfile.ContainsContainer(normalizedContainers, "mkv")
  1271. || ContainerProfile.ContainsContainer(normalizedContainers, "matroska"))
  1272. {
  1273. return true;
  1274. }
  1275. }
  1276. return false;
  1277. }
  1278. private static SubtitleProfile? GetExternalSubtitleProfile(MediaSourceInfo mediaSource, MediaStream subtitleStream, SubtitleProfile[] subtitleProfiles, PlayMethod playMethod, ITranscoderSupport transcoderSupport, bool allowConversion)
  1279. {
  1280. foreach (var profile in subtitleProfiles)
  1281. {
  1282. if (profile.Method != SubtitleDeliveryMethod.External && profile.Method != SubtitleDeliveryMethod.Hls)
  1283. {
  1284. continue;
  1285. }
  1286. if (profile.Method == SubtitleDeliveryMethod.Hls && playMethod != PlayMethod.Transcode)
  1287. {
  1288. continue;
  1289. }
  1290. if (!profile.SupportsLanguage(subtitleStream.Language))
  1291. {
  1292. continue;
  1293. }
  1294. if (!subtitleStream.IsExternal && !transcoderSupport.CanExtractSubtitles(subtitleStream.Codec))
  1295. {
  1296. continue;
  1297. }
  1298. if ((profile.Method == SubtitleDeliveryMethod.External && subtitleStream.IsTextSubtitleStream == MediaStream.IsTextFormat(profile.Format)) ||
  1299. (profile.Method == SubtitleDeliveryMethod.Hls && subtitleStream.IsTextSubtitleStream))
  1300. {
  1301. bool requiresConversion = !string.Equals(subtitleStream.Codec, profile.Format, StringComparison.OrdinalIgnoreCase);
  1302. if (!requiresConversion)
  1303. {
  1304. return profile;
  1305. }
  1306. if (!allowConversion)
  1307. {
  1308. continue;
  1309. }
  1310. // TODO: Build this into subtitleStream.SupportsExternalStream
  1311. if (mediaSource.IsInfiniteStream)
  1312. {
  1313. continue;
  1314. }
  1315. if (subtitleStream.IsTextSubtitleStream && subtitleStream.SupportsExternalStream && subtitleStream.SupportsSubtitleConversionTo(profile.Format))
  1316. {
  1317. return profile;
  1318. }
  1319. }
  1320. }
  1321. return null;
  1322. }
  1323. private bool IsBitrateLimitExceeded(MediaSourceInfo item, long maxBitrate)
  1324. {
  1325. // Don't restrict bitrate if item is remote.
  1326. if (item.IsRemote)
  1327. {
  1328. return false;
  1329. }
  1330. // If no maximum bitrate is set, default to no maximum bitrate.
  1331. long requestedMaxBitrate = maxBitrate > 0 ? maxBitrate : int.MaxValue;
  1332. // If we don't know the item bitrate, then force a transcode if requested max bitrate is under 40 mbps
  1333. int itemBitrate = item.Bitrate ?? 40000000;
  1334. if (itemBitrate > requestedMaxBitrate)
  1335. {
  1336. _logger.LogDebug(
  1337. "Bitrate exceeds limit: media bitrate: {MediaBitrate}, max bitrate: {MaxBitrate}",
  1338. itemBitrate,
  1339. requestedMaxBitrate);
  1340. return true;
  1341. }
  1342. return false;
  1343. }
  1344. private static void ValidateMediaOptions(MediaOptions options, bool isMediaSource)
  1345. {
  1346. if (options.ItemId.IsEmpty())
  1347. {
  1348. ArgumentException.ThrowIfNullOrEmpty(options.DeviceId);
  1349. }
  1350. if (options.Profile is null)
  1351. {
  1352. throw new ArgumentException("Profile is required");
  1353. }
  1354. if (options.MediaSources is null)
  1355. {
  1356. throw new ArgumentException("MediaSources is required");
  1357. }
  1358. if (isMediaSource)
  1359. {
  1360. if (options.AudioStreamIndex.HasValue && string.IsNullOrEmpty(options.MediaSourceId))
  1361. {
  1362. throw new ArgumentException("MediaSourceId is required when a specific audio stream is requested");
  1363. }
  1364. if (options.SubtitleStreamIndex.HasValue && string.IsNullOrEmpty(options.MediaSourceId))
  1365. {
  1366. throw new ArgumentException("MediaSourceId is required when a specific subtitle stream is requested");
  1367. }
  1368. }
  1369. }
  1370. private static IEnumerable<ProfileCondition> GetProfileConditionsForVideoAudio(
  1371. IEnumerable<CodecProfile> codecProfiles,
  1372. string container,
  1373. string codec,
  1374. int? audioChannels,
  1375. int? audioBitrate,
  1376. int? audioSampleRate,
  1377. int? audioBitDepth,
  1378. string audioProfile,
  1379. bool? isSecondaryAudio)
  1380. {
  1381. return codecProfiles
  1382. .Where(profile => profile.Type == CodecType.VideoAudio &&
  1383. profile.ContainsAnyCodec(codec, container) &&
  1384. profile.ApplyConditions.All(applyCondition => ConditionProcessor.IsVideoAudioConditionSatisfied(applyCondition, audioChannels, audioBitrate, audioSampleRate, audioBitDepth, audioProfile, isSecondaryAudio)))
  1385. .SelectMany(profile => profile.Conditions)
  1386. .Where(condition => !ConditionProcessor.IsVideoAudioConditionSatisfied(condition, audioChannels, audioBitrate, audioSampleRate, audioBitDepth, audioProfile, isSecondaryAudio));
  1387. }
  1388. private static IEnumerable<ProfileCondition> GetProfileConditionsForAudio(
  1389. IEnumerable<CodecProfile> codecProfiles,
  1390. string container,
  1391. string? codec,
  1392. int? audioChannels,
  1393. int? audioBitrate,
  1394. int? audioSampleRate,
  1395. int? audioBitDepth,
  1396. bool checkConditions)
  1397. {
  1398. var conditions = codecProfiles
  1399. .Where(profile => profile.Type == CodecType.Audio &&
  1400. profile.ContainsAnyCodec(codec, container) &&
  1401. profile.ApplyConditions.All(applyCondition => ConditionProcessor.IsAudioConditionSatisfied(applyCondition, audioChannels, audioBitrate, audioSampleRate, audioBitDepth)))
  1402. .SelectMany(profile => profile.Conditions);
  1403. if (!checkConditions)
  1404. {
  1405. return conditions;
  1406. }
  1407. return conditions.Where(condition => !ConditionProcessor.IsAudioConditionSatisfied(condition, audioChannels, audioBitrate, audioSampleRate, audioBitDepth));
  1408. }
  1409. private void ApplyTranscodingConditions(StreamInfo item, IEnumerable<ProfileCondition> conditions, string? qualifier, bool enableQualifiedConditions, bool enableNonQualifiedConditions)
  1410. {
  1411. foreach (ProfileCondition condition in conditions)
  1412. {
  1413. string value = condition.Value;
  1414. if (string.IsNullOrEmpty(value))
  1415. {
  1416. continue;
  1417. }
  1418. // No way to express this
  1419. if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1420. {
  1421. continue;
  1422. }
  1423. switch (condition.Property)
  1424. {
  1425. case ProfileConditionValue.AudioBitrate:
  1426. {
  1427. if (!enableNonQualifiedConditions)
  1428. {
  1429. continue;
  1430. }
  1431. if (int.TryParse(value, CultureInfo.InvariantCulture, out var num))
  1432. {
  1433. if (condition.Condition == ProfileConditionType.Equals)
  1434. {
  1435. item.AudioBitrate = num;
  1436. }
  1437. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1438. {
  1439. item.AudioBitrate = Math.Min(num, item.AudioBitrate ?? num);
  1440. }
  1441. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1442. {
  1443. item.AudioBitrate = Math.Max(num, item.AudioBitrate ?? num);
  1444. }
  1445. }
  1446. break;
  1447. }
  1448. case ProfileConditionValue.AudioSampleRate:
  1449. {
  1450. if (!enableNonQualifiedConditions)
  1451. {
  1452. continue;
  1453. }
  1454. if (int.TryParse(value, CultureInfo.InvariantCulture, out var num))
  1455. {
  1456. if (condition.Condition == ProfileConditionType.Equals)
  1457. {
  1458. item.AudioSampleRate = num;
  1459. }
  1460. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1461. {
  1462. item.AudioSampleRate = Math.Min(num, item.AudioSampleRate ?? num);
  1463. }
  1464. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1465. {
  1466. item.AudioSampleRate = Math.Max(num, item.AudioSampleRate ?? num);
  1467. }
  1468. }
  1469. break;
  1470. }
  1471. case ProfileConditionValue.AudioChannels:
  1472. {
  1473. if (string.IsNullOrEmpty(qualifier))
  1474. {
  1475. if (!enableNonQualifiedConditions)
  1476. {
  1477. continue;
  1478. }
  1479. }
  1480. else
  1481. {
  1482. if (!enableQualifiedConditions)
  1483. {
  1484. continue;
  1485. }
  1486. }
  1487. if (int.TryParse(value, CultureInfo.InvariantCulture, out var num))
  1488. {
  1489. if (condition.Condition == ProfileConditionType.Equals)
  1490. {
  1491. item.SetOption(qualifier, "audiochannels", num.ToString(CultureInfo.InvariantCulture));
  1492. }
  1493. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1494. {
  1495. item.SetOption(qualifier, "audiochannels", Math.Min(num, item.GetTargetAudioChannels(qualifier) ?? num).ToString(CultureInfo.InvariantCulture));
  1496. }
  1497. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1498. {
  1499. item.SetOption(qualifier, "audiochannels", Math.Max(num, item.GetTargetAudioChannels(qualifier) ?? num).ToString(CultureInfo.InvariantCulture));
  1500. }
  1501. }
  1502. break;
  1503. }
  1504. case ProfileConditionValue.IsAvc:
  1505. {
  1506. if (!enableNonQualifiedConditions)
  1507. {
  1508. continue;
  1509. }
  1510. if (bool.TryParse(value, out var isAvc))
  1511. {
  1512. if (isAvc && condition.Condition == ProfileConditionType.Equals)
  1513. {
  1514. item.RequireAvc = true;
  1515. }
  1516. else if (!isAvc && condition.Condition == ProfileConditionType.NotEquals)
  1517. {
  1518. item.RequireAvc = true;
  1519. }
  1520. }
  1521. break;
  1522. }
  1523. case ProfileConditionValue.IsAnamorphic:
  1524. {
  1525. if (!enableNonQualifiedConditions)
  1526. {
  1527. continue;
  1528. }
  1529. if (bool.TryParse(value, out var isAnamorphic))
  1530. {
  1531. if (isAnamorphic && condition.Condition == ProfileConditionType.Equals)
  1532. {
  1533. item.RequireNonAnamorphic = true;
  1534. }
  1535. else if (!isAnamorphic && condition.Condition == ProfileConditionType.NotEquals)
  1536. {
  1537. item.RequireNonAnamorphic = true;
  1538. }
  1539. }
  1540. break;
  1541. }
  1542. case ProfileConditionValue.IsInterlaced:
  1543. {
  1544. if (string.IsNullOrEmpty(qualifier))
  1545. {
  1546. if (!enableNonQualifiedConditions)
  1547. {
  1548. continue;
  1549. }
  1550. }
  1551. else
  1552. {
  1553. if (!enableQualifiedConditions)
  1554. {
  1555. continue;
  1556. }
  1557. }
  1558. if (bool.TryParse(value, out var isInterlaced))
  1559. {
  1560. if (!isInterlaced && condition.Condition == ProfileConditionType.Equals)
  1561. {
  1562. item.SetOption(qualifier, "deinterlace", "true");
  1563. }
  1564. else if (isInterlaced && condition.Condition == ProfileConditionType.NotEquals)
  1565. {
  1566. item.SetOption(qualifier, "deinterlace", "true");
  1567. }
  1568. }
  1569. break;
  1570. }
  1571. case ProfileConditionValue.AudioProfile:
  1572. case ProfileConditionValue.Has64BitOffsets:
  1573. case ProfileConditionValue.PacketLength:
  1574. case ProfileConditionValue.NumAudioStreams:
  1575. case ProfileConditionValue.NumVideoStreams:
  1576. case ProfileConditionValue.IsSecondaryAudio:
  1577. case ProfileConditionValue.VideoTimestamp:
  1578. {
  1579. // Not supported yet
  1580. break;
  1581. }
  1582. case ProfileConditionValue.RefFrames:
  1583. {
  1584. if (string.IsNullOrEmpty(qualifier))
  1585. {
  1586. if (!enableNonQualifiedConditions)
  1587. {
  1588. continue;
  1589. }
  1590. }
  1591. else
  1592. {
  1593. if (!enableQualifiedConditions)
  1594. {
  1595. continue;
  1596. }
  1597. }
  1598. if (int.TryParse(value, CultureInfo.InvariantCulture, out var num))
  1599. {
  1600. if (condition.Condition == ProfileConditionType.Equals)
  1601. {
  1602. item.SetOption(qualifier, "maxrefframes", num.ToString(CultureInfo.InvariantCulture));
  1603. }
  1604. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1605. {
  1606. item.SetOption(qualifier, "maxrefframes", Math.Min(num, item.GetTargetRefFrames(qualifier) ?? num).ToString(CultureInfo.InvariantCulture));
  1607. }
  1608. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1609. {
  1610. item.SetOption(qualifier, "maxrefframes", Math.Max(num, item.GetTargetRefFrames(qualifier) ?? num).ToString(CultureInfo.InvariantCulture));
  1611. }
  1612. }
  1613. break;
  1614. }
  1615. case ProfileConditionValue.VideoBitDepth:
  1616. {
  1617. if (string.IsNullOrEmpty(qualifier))
  1618. {
  1619. if (!enableNonQualifiedConditions)
  1620. {
  1621. continue;
  1622. }
  1623. }
  1624. else
  1625. {
  1626. if (!enableQualifiedConditions)
  1627. {
  1628. continue;
  1629. }
  1630. }
  1631. if (int.TryParse(value, CultureInfo.InvariantCulture, out var num))
  1632. {
  1633. if (condition.Condition == ProfileConditionType.Equals)
  1634. {
  1635. item.SetOption(qualifier, "videobitdepth", num.ToString(CultureInfo.InvariantCulture));
  1636. }
  1637. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1638. {
  1639. item.SetOption(qualifier, "videobitdepth", Math.Min(num, item.GetTargetVideoBitDepth(qualifier) ?? num).ToString(CultureInfo.InvariantCulture));
  1640. }
  1641. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1642. {
  1643. item.SetOption(qualifier, "videobitdepth", Math.Max(num, item.GetTargetVideoBitDepth(qualifier) ?? num).ToString(CultureInfo.InvariantCulture));
  1644. }
  1645. }
  1646. break;
  1647. }
  1648. case ProfileConditionValue.VideoProfile:
  1649. {
  1650. if (string.IsNullOrEmpty(qualifier))
  1651. {
  1652. continue;
  1653. }
  1654. // Change from split by | to comma
  1655. // Strip spaces to avoid having to encode
  1656. var values = value
  1657. .Split('|', StringSplitOptions.RemoveEmptyEntries);
  1658. if (condition.Condition == ProfileConditionType.Equals)
  1659. {
  1660. item.SetOption(qualifier, "profile", string.Join(',', values));
  1661. }
  1662. else if (condition.Condition == ProfileConditionType.EqualsAny)
  1663. {
  1664. var currentValue = item.GetOption(qualifier, "profile");
  1665. if (!string.IsNullOrEmpty(currentValue) && values.Any(value => value == currentValue))
  1666. {
  1667. item.SetOption(qualifier, "profile", currentValue);
  1668. }
  1669. else
  1670. {
  1671. item.SetOption(qualifier, "profile", string.Join(',', values));
  1672. }
  1673. }
  1674. break;
  1675. }
  1676. case ProfileConditionValue.VideoRangeType:
  1677. {
  1678. if (string.IsNullOrEmpty(qualifier))
  1679. {
  1680. continue;
  1681. }
  1682. // change from split by | to comma
  1683. // strip spaces to avoid having to encode
  1684. var values = value
  1685. .Split('|', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries);
  1686. if (condition.Condition == ProfileConditionType.Equals)
  1687. {
  1688. item.SetOption(qualifier, "rangetype", string.Join(',', values));
  1689. }
  1690. else if (condition.Condition == ProfileConditionType.NotEquals)
  1691. {
  1692. item.SetOption(qualifier, "rangetype", string.Join(',', Enum.GetNames(typeof(VideoRangeType)).Except(values)));
  1693. }
  1694. else if (condition.Condition == ProfileConditionType.EqualsAny)
  1695. {
  1696. var currentValue = item.GetOption(qualifier, "rangetype");
  1697. if (!string.IsNullOrEmpty(currentValue) && values.Any(v => string.Equals(v, currentValue, StringComparison.OrdinalIgnoreCase)))
  1698. {
  1699. item.SetOption(qualifier, "rangetype", currentValue);
  1700. }
  1701. else
  1702. {
  1703. item.SetOption(qualifier, "rangetype", string.Join(',', values));
  1704. }
  1705. }
  1706. break;
  1707. }
  1708. case ProfileConditionValue.VideoCodecTag:
  1709. {
  1710. if (string.IsNullOrEmpty(qualifier))
  1711. {
  1712. continue;
  1713. }
  1714. // change from split by | to comma
  1715. // strip spaces to avoid having to encode
  1716. var values = value
  1717. .Split('|', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries);
  1718. if (condition.Condition == ProfileConditionType.Equals)
  1719. {
  1720. item.SetOption(qualifier, "codectag", string.Join(',', values));
  1721. }
  1722. else if (condition.Condition == ProfileConditionType.EqualsAny)
  1723. {
  1724. var currentValue = item.GetOption(qualifier, "codectag");
  1725. if (!string.IsNullOrEmpty(currentValue) && values.Any(v => string.Equals(v, currentValue, StringComparison.OrdinalIgnoreCase)))
  1726. {
  1727. item.SetOption(qualifier, "codectag", currentValue);
  1728. }
  1729. else
  1730. {
  1731. item.SetOption(qualifier, "codectag", string.Join(',', values));
  1732. }
  1733. }
  1734. break;
  1735. }
  1736. case ProfileConditionValue.Height:
  1737. {
  1738. if (!enableNonQualifiedConditions)
  1739. {
  1740. continue;
  1741. }
  1742. if (int.TryParse(value, CultureInfo.InvariantCulture, out var num))
  1743. {
  1744. if (condition.Condition == ProfileConditionType.Equals)
  1745. {
  1746. item.MaxHeight = num;
  1747. }
  1748. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1749. {
  1750. item.MaxHeight = Math.Min(num, item.MaxHeight ?? num);
  1751. }
  1752. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1753. {
  1754. item.MaxHeight = Math.Max(num, item.MaxHeight ?? num);
  1755. }
  1756. }
  1757. break;
  1758. }
  1759. case ProfileConditionValue.VideoBitrate:
  1760. {
  1761. if (!enableNonQualifiedConditions)
  1762. {
  1763. continue;
  1764. }
  1765. if (int.TryParse(value, CultureInfo.InvariantCulture, out var num))
  1766. {
  1767. if (condition.Condition == ProfileConditionType.Equals)
  1768. {
  1769. item.VideoBitrate = num;
  1770. }
  1771. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1772. {
  1773. item.VideoBitrate = Math.Min(num, item.VideoBitrate ?? num);
  1774. }
  1775. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1776. {
  1777. item.VideoBitrate = Math.Max(num, item.VideoBitrate ?? num);
  1778. }
  1779. }
  1780. break;
  1781. }
  1782. case ProfileConditionValue.VideoFramerate:
  1783. {
  1784. if (!enableNonQualifiedConditions)
  1785. {
  1786. continue;
  1787. }
  1788. if (float.TryParse(value, CultureInfo.InvariantCulture, out var num))
  1789. {
  1790. if (condition.Condition == ProfileConditionType.Equals)
  1791. {
  1792. item.MaxFramerate = num;
  1793. }
  1794. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1795. {
  1796. item.MaxFramerate = Math.Min(num, item.MaxFramerate ?? num);
  1797. }
  1798. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1799. {
  1800. item.MaxFramerate = Math.Max(num, item.MaxFramerate ?? num);
  1801. }
  1802. }
  1803. break;
  1804. }
  1805. case ProfileConditionValue.VideoLevel:
  1806. {
  1807. if (string.IsNullOrEmpty(qualifier))
  1808. {
  1809. continue;
  1810. }
  1811. if (int.TryParse(value, CultureInfo.InvariantCulture, out var num))
  1812. {
  1813. if (condition.Condition == ProfileConditionType.Equals)
  1814. {
  1815. item.SetOption(qualifier, "level", num.ToString(CultureInfo.InvariantCulture));
  1816. }
  1817. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1818. {
  1819. item.SetOption(qualifier, "level", Math.Min(num, item.GetTargetVideoLevel(qualifier) ?? num).ToString(CultureInfo.InvariantCulture));
  1820. }
  1821. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1822. {
  1823. item.SetOption(qualifier, "level", Math.Max(num, item.GetTargetVideoLevel(qualifier) ?? num).ToString(CultureInfo.InvariantCulture));
  1824. }
  1825. }
  1826. break;
  1827. }
  1828. case ProfileConditionValue.Width:
  1829. {
  1830. if (!enableNonQualifiedConditions)
  1831. {
  1832. continue;
  1833. }
  1834. if (int.TryParse(value, CultureInfo.InvariantCulture, out var num))
  1835. {
  1836. if (condition.Condition == ProfileConditionType.Equals)
  1837. {
  1838. item.MaxWidth = num;
  1839. }
  1840. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1841. {
  1842. item.MaxWidth = Math.Min(num, item.MaxWidth ?? num);
  1843. }
  1844. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1845. {
  1846. item.MaxWidth = Math.Max(num, item.MaxWidth ?? num);
  1847. }
  1848. }
  1849. break;
  1850. }
  1851. default:
  1852. break;
  1853. }
  1854. }
  1855. }
  1856. private static bool IsAudioDirectPlaySupported(DirectPlayProfile profile, MediaSourceInfo item, MediaStream audioStream)
  1857. {
  1858. // Check container type
  1859. if (!profile.SupportsContainer(item.Container))
  1860. {
  1861. return false;
  1862. }
  1863. // Check audio codec
  1864. string? audioCodec = audioStream?.Codec;
  1865. if (!profile.SupportsAudioCodec(audioCodec))
  1866. {
  1867. return false;
  1868. }
  1869. return true;
  1870. }
  1871. private static bool IsAudioDirectStreamSupported(DirectPlayProfile profile, MediaSourceInfo item, MediaStream audioStream)
  1872. {
  1873. // Check container type, this should NOT be supported
  1874. // If the container is supported, the file should be directly played
  1875. if (!profile.SupportsContainer(item.Container))
  1876. {
  1877. // Check audio codec, we cannot use the SupportsAudioCodec here
  1878. // Because that one assumes empty container supports all codec, which is just useless
  1879. string? audioCodec = audioStream?.Codec;
  1880. if (string.Equals(profile.AudioCodec, audioCodec, StringComparison.OrdinalIgnoreCase) ||
  1881. string.Equals(profile.Container, audioCodec, StringComparison.OrdinalIgnoreCase))
  1882. {
  1883. return true;
  1884. }
  1885. }
  1886. return false;
  1887. }
  1888. }
  1889. }