StreamBuilder.cs 94 KB

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