StreamBuilder.cs 92 KB

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