StreamBuilder.cs 95 KB

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