StreamBuilder.cs 92 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044
  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 != 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 != 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 != null)
  202. {
  203. var playProfiles = playProfile == 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 != 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 == 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 == 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 == null || profile.SupportsVideoCodec(videoStream.Codec);
  361. audioSupported = audioStream == 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. if (item == null)
  464. {
  465. throw new ArgumentNullException(nameof(item));
  466. }
  467. StreamInfo playlistItem = new StreamInfo
  468. {
  469. ItemId = options.ItemId,
  470. MediaType = DlnaProfileType.Video,
  471. MediaSource = item,
  472. RunTimeTicks = item.RunTimeTicks,
  473. Context = options.Context,
  474. DeviceProfile = options.Profile
  475. };
  476. playlistItem.SubtitleStreamIndex = options.SubtitleStreamIndex ?? GetDefaultSubtitleStreamIndex(item, options.Profile.SubtitleProfiles);
  477. var subtitleStream = playlistItem.SubtitleStreamIndex.HasValue ? item.GetMediaStream(MediaStreamType.Subtitle, playlistItem.SubtitleStreamIndex.Value) : null;
  478. var audioStream = item.GetDefaultAudioStream(options.AudioStreamIndex ?? item.DefaultAudioStreamIndex);
  479. if (audioStream != null)
  480. {
  481. playlistItem.AudioStreamIndex = audioStream.Index;
  482. }
  483. // Collect candidate audio streams
  484. ICollection<MediaStream> candidateAudioStreams = audioStream == null ? Array.Empty<MediaStream>() : new[] { audioStream };
  485. if (!options.AudioStreamIndex.HasValue || options.AudioStreamIndex < 0)
  486. {
  487. if (audioStream?.IsDefault == true)
  488. {
  489. candidateAudioStreams = item.MediaStreams.Where(stream => stream.Type == MediaStreamType.Audio && stream.IsDefault).ToArray();
  490. }
  491. else
  492. {
  493. candidateAudioStreams = item.MediaStreams.Where(stream => stream.Type == MediaStreamType.Audio && stream.Language == audioStream?.Language).ToArray();
  494. }
  495. }
  496. var videoStream = item.VideoStream;
  497. var directPlayBitrateEligibility = IsBitrateEligibleForDirectPlayback(item, options.GetMaxBitrate(false) ?? 0, options, PlayMethod.DirectPlay);
  498. var directStreamBitrateEligibility = IsBitrateEligibleForDirectPlayback(item, options.GetMaxBitrate(false) ?? 0, options, PlayMethod.DirectStream);
  499. bool isEligibleForDirectPlay = options.EnableDirectPlay && (options.ForceDirectPlay || directPlayBitrateEligibility == 0);
  500. bool isEligibleForDirectStream = options.EnableDirectStream && (options.ForceDirectStream || directStreamBitrateEligibility == 0);
  501. var transcodeReasons = directPlayBitrateEligibility | directStreamBitrateEligibility;
  502. _logger.LogDebug(
  503. "Profile: {0}, Path: {1}, isEligibleForDirectPlay: {2}, isEligibleForDirectStream: {3}",
  504. options.Profile.Name ?? "Unknown Profile",
  505. item.Path ?? "Unknown path",
  506. isEligibleForDirectPlay,
  507. isEligibleForDirectStream);
  508. DirectPlayProfile directPlayProfile = null;
  509. if (isEligibleForDirectPlay || isEligibleForDirectStream)
  510. {
  511. // See if it can be direct played
  512. var directPlayInfo = GetVideoDirectPlayProfile(options, item, videoStream, audioStream, candidateAudioStreams, subtitleStream, isEligibleForDirectPlay, isEligibleForDirectStream);
  513. var directPlay = directPlayInfo.PlayMethod;
  514. transcodeReasons |= directPlayInfo.TranscodeReasons;
  515. if (directPlay.HasValue)
  516. {
  517. directPlayProfile = directPlayInfo.Profile;
  518. playlistItem.PlayMethod = directPlay.Value;
  519. playlistItem.Container = NormalizeMediaSourceFormatIntoSingleContainer(item.Container, options.Profile, DlnaProfileType.Video, directPlayProfile);
  520. playlistItem.VideoCodecs = new[] { videoStream.Codec };
  521. if (directPlay == PlayMethod.DirectPlay)
  522. {
  523. playlistItem.SubProtocol = "http";
  524. var audioStreamIndex = directPlayInfo.AudioStreamIndex ?? audioStream?.Index;
  525. if (audioStreamIndex.HasValue)
  526. {
  527. playlistItem.AudioStreamIndex = audioStreamIndex;
  528. playlistItem.AudioCodecs = new[] { item.GetMediaStream(MediaStreamType.Audio, audioStreamIndex.Value)?.Codec };
  529. }
  530. }
  531. else if (directPlay == PlayMethod.DirectStream)
  532. {
  533. playlistItem.AudioStreamIndex = audioStream?.Index;
  534. if (audioStream != null)
  535. {
  536. playlistItem.AudioCodecs = ContainerProfile.SplitValue(directPlayProfile.AudioCodec);
  537. }
  538. SetStreamInfoOptionsFromDirectPlayProfile(options, item, playlistItem, directPlayProfile);
  539. BuildStreamVideoItem(playlistItem, options, item, videoStream, audioStream, candidateAudioStreams, directPlayProfile.Container, directPlayProfile.VideoCodec, directPlayProfile.AudioCodec);
  540. }
  541. if (subtitleStream != null)
  542. {
  543. var subtitleProfile = GetSubtitleProfile(item, subtitleStream, options.Profile.SubtitleProfiles, directPlay.Value, _transcoderSupport, directPlayProfile.Container, null);
  544. playlistItem.SubtitleDeliveryMethod = subtitleProfile.Method;
  545. playlistItem.SubtitleFormat = subtitleProfile.Format;
  546. }
  547. }
  548. _logger.LogDebug(
  549. "DirectPlay Result for Profile: {0}, Path: {1}, PlayMethod: {2}, AudioStreamIndex: {3}, SubtitleStreamIndex: {4}, Reasons: {5}",
  550. options.Profile.Name ?? "Anonymous Profile",
  551. item.Path ?? "Unknown path",
  552. directPlayInfo.PlayMethod,
  553. directPlayInfo.AudioStreamIndex ?? audioStream?.Index,
  554. playlistItem.SubtitleStreamIndex,
  555. directPlayInfo.TranscodeReasons);
  556. }
  557. playlistItem.TranscodeReasons = transcodeReasons;
  558. if (playlistItem.PlayMethod != PlayMethod.DirectStream && playlistItem.PlayMethod != PlayMethod.DirectPlay)
  559. {
  560. // Can't direct play, find the transcoding profile
  561. // If we do this for direct-stream we will overwrite the info
  562. var transcodingProfile = GetVideoTranscodeProfile(item, options, videoStream, audioStream, candidateAudioStreams, subtitleStream, playlistItem);
  563. if (transcodingProfile != null)
  564. {
  565. SetStreamInfoOptionsFromTranscodingProfile(item, playlistItem, transcodingProfile);
  566. BuildStreamVideoItem(playlistItem, options, item, videoStream, audioStream, candidateAudioStreams, transcodingProfile.Container, transcodingProfile.VideoCodec, transcodingProfile.AudioCodec);
  567. playlistItem.PlayMethod = PlayMethod.Transcode;
  568. if (subtitleStream != null)
  569. {
  570. var subtitleProfile = GetSubtitleProfile(item, subtitleStream, options.Profile.SubtitleProfiles, PlayMethod.Transcode, _transcoderSupport, transcodingProfile.Container, transcodingProfile.Protocol);
  571. playlistItem.SubtitleDeliveryMethod = subtitleProfile.Method;
  572. playlistItem.SubtitleFormat = subtitleProfile.Format;
  573. playlistItem.SubtitleCodecs = new[] { subtitleProfile.Format };
  574. }
  575. if ((playlistItem.TranscodeReasons & (VideoReasons | TranscodeReason.ContainerBitrateExceedsLimit)) != 0)
  576. {
  577. ApplyTranscodingConditions(playlistItem, transcodingProfile.Conditions, null, true, true);
  578. }
  579. }
  580. }
  581. _logger.LogInformation(
  582. "StreamBuilder.BuildVideoItem( Profile={0}, Path={1}, AudioStreamIndex={2}, SubtitleStreamIndex={3} ) => ( PlayMethod={4}, TranscodeReason={5} ) {6}",
  583. options.Profile.Name ?? "Anonymous Profile",
  584. item.Path ?? "Unknown path",
  585. options.AudioStreamIndex,
  586. options.SubtitleStreamIndex,
  587. playlistItem.PlayMethod,
  588. playlistItem.TranscodeReasons,
  589. playlistItem.ToUrl("media:", "<token>"));
  590. item.Container = NormalizeMediaSourceFormatIntoSingleContainer(item.Container, options.Profile, DlnaProfileType.Video, directPlayProfile);
  591. return playlistItem;
  592. }
  593. private TranscodingProfile GetVideoTranscodeProfile(MediaSourceInfo item, VideoOptions options, MediaStream videoStream, MediaStream audioStream, IEnumerable<MediaStream> candidateAudioStreams, MediaStream subtitleStream, StreamInfo playlistItem)
  594. {
  595. if (!(item.SupportsTranscoding || item.SupportsDirectStream))
  596. {
  597. return null;
  598. }
  599. var transcodingProfiles = options.Profile.TranscodingProfiles
  600. .Where(i => i.Type == playlistItem.MediaType && i.Context == options.Context);
  601. if (options.AllowVideoStreamCopy)
  602. {
  603. // prefer direct copy profile
  604. float videoFramerate = videoStream == null ? 0 : videoStream.AverageFrameRate ?? videoStream.AverageFrameRate ?? 0;
  605. TransportStreamTimestamp? timestamp = videoStream == null ? TransportStreamTimestamp.None : item.Timestamp;
  606. int? numAudioStreams = item.GetStreamCount(MediaStreamType.Audio);
  607. int? numVideoStreams = item.GetStreamCount(MediaStreamType.Video);
  608. transcodingProfiles = transcodingProfiles.ToLookup(transcodingProfile =>
  609. {
  610. var videoCodecs = ContainerProfile.SplitValue(transcodingProfile.VideoCodec);
  611. if (ContainerProfile.ContainsContainer(videoCodecs, item.VideoStream?.Codec))
  612. {
  613. var videoCodec = transcodingProfile.VideoCodec;
  614. var container = transcodingProfile.Container;
  615. var appliedVideoConditions = options.Profile.CodecProfiles
  616. .Where(i => i.Type == CodecType.Video &&
  617. i.ContainsAnyCodec(videoCodec, container) &&
  618. 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)))
  619. .Select(i =>
  620. 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)));
  621. // An empty appliedVideoConditions means that the codec has no conditions for the current video stream
  622. var conditionsSatisfied = appliedVideoConditions.All(satisfied => satisfied);
  623. return conditionsSatisfied ? 1 : 2;
  624. }
  625. return 3;
  626. })
  627. .OrderBy(lookup => lookup.Key)
  628. .SelectMany(lookup => lookup);
  629. }
  630. return transcodingProfiles.FirstOrDefault();
  631. }
  632. private void BuildStreamVideoItem(StreamInfo playlistItem, VideoOptions options, MediaSourceInfo item, MediaStream videoStream, MediaStream audioStream, IEnumerable<MediaStream> candidateAudioStreams, string container, string videoCodec, string audioCodec)
  633. {
  634. // Prefer matching video codecs
  635. var videoCodecs = ContainerProfile.SplitValue(videoCodec);
  636. var directVideoCodec = ContainerProfile.ContainsContainer(videoCodecs, videoStream?.Codec) ? videoStream?.Codec : null;
  637. if (directVideoCodec != null)
  638. {
  639. // merge directVideoCodec to videoCodecs
  640. Array.Resize(ref videoCodecs, videoCodecs.Length + 1);
  641. videoCodecs[^1] = directVideoCodec;
  642. }
  643. playlistItem.VideoCodecs = videoCodecs;
  644. // Copy video codec options as a starting point, this applies to transcode and direct-stream
  645. playlistItem.MaxFramerate = videoStream?.AverageFrameRate;
  646. var qualifier = videoStream?.Codec;
  647. if (videoStream?.Level != null)
  648. {
  649. playlistItem.SetOption(qualifier, "level", videoStream.Level.Value.ToString(CultureInfo.InvariantCulture));
  650. }
  651. if (videoStream?.BitDepth != null)
  652. {
  653. playlistItem.SetOption(qualifier, "videobitdepth", videoStream.BitDepth.Value.ToString(CultureInfo.InvariantCulture));
  654. }
  655. if (!string.IsNullOrEmpty(videoStream?.Profile))
  656. {
  657. playlistItem.SetOption(qualifier, "profile", videoStream.Profile.ToLowerInvariant());
  658. }
  659. if (videoStream != null && videoStream.Level != 0)
  660. {
  661. playlistItem.SetOption(qualifier, "level", videoStream.Level.ToString());
  662. }
  663. // Prefer matching audio codecs, could do better here
  664. var audioCodecs = ContainerProfile.SplitValue(audioCodec);
  665. var directAudioStream = candidateAudioStreams.FirstOrDefault(stream => ContainerProfile.ContainsContainer(audioCodecs, stream.Codec));
  666. playlistItem.AudioCodecs = audioCodecs;
  667. if (directAudioStream != null)
  668. {
  669. audioStream = directAudioStream;
  670. playlistItem.AudioStreamIndex = audioStream.Index;
  671. playlistItem.AudioCodecs = new[] { audioStream.Codec };
  672. // Copy matching audio codec options
  673. playlistItem.AudioSampleRate = audioStream.SampleRate;
  674. playlistItem.SetOption(qualifier, "audiochannels", audioStream.Channels.ToString());
  675. if (!string.IsNullOrEmpty(audioStream.Profile))
  676. {
  677. playlistItem.SetOption(audioStream.Codec, "profile", audioStream.Profile.ToLowerInvariant());
  678. }
  679. if (audioStream.Level != 0)
  680. {
  681. playlistItem.SetOption(audioStream.Codec, "level", audioStream.Level.ToString());
  682. }
  683. }
  684. int? width = videoStream?.Width;
  685. int? height = videoStream?.Height;
  686. int? bitDepth = videoStream?.BitDepth;
  687. int? videoBitrate = videoStream?.BitRate;
  688. double? videoLevel = videoStream?.Level;
  689. string videoProfile = videoStream?.Profile;
  690. string videoRangeType = videoStream?.VideoRangeType;
  691. float videoFramerate = videoStream == null ? 0 : videoStream.AverageFrameRate ?? videoStream.AverageFrameRate ?? 0;
  692. bool? isAnamorphic = videoStream?.IsAnamorphic;
  693. bool? isInterlaced = videoStream?.IsInterlaced;
  694. string videoCodecTag = videoStream?.CodecTag;
  695. bool? isAvc = videoStream?.IsAVC;
  696. TransportStreamTimestamp? timestamp = videoStream == null ? TransportStreamTimestamp.None : item.Timestamp;
  697. int? packetLength = videoStream?.PacketLength;
  698. int? refFrames = videoStream?.RefFrames;
  699. int? numAudioStreams = item.GetStreamCount(MediaStreamType.Audio);
  700. int? numVideoStreams = item.GetStreamCount(MediaStreamType.Video);
  701. var appliedVideoConditions = options.Profile.CodecProfiles
  702. .Where(i => i.Type == CodecType.Video &&
  703. i.ContainsAnyCodec(videoCodec, container) &&
  704. i.ApplyConditions.All(applyCondition => ConditionProcessor.IsVideoConditionSatisfied(applyCondition, width, height, bitDepth, videoBitrate, videoProfile, videoRangeType, videoLevel, videoFramerate, packetLength, timestamp, isAnamorphic, isInterlaced, refFrames, numVideoStreams, numAudioStreams, videoCodecTag, isAvc)));
  705. var isFirstAppliedCodecProfile = true;
  706. foreach (var i in appliedVideoConditions)
  707. {
  708. var transcodingVideoCodecs = ContainerProfile.SplitValue(videoCodec);
  709. foreach (var transcodingVideoCodec in transcodingVideoCodecs)
  710. {
  711. if (i.ContainsAnyCodec(transcodingVideoCodec, container))
  712. {
  713. ApplyTranscodingConditions(playlistItem, i.Conditions, transcodingVideoCodec, true, isFirstAppliedCodecProfile);
  714. isFirstAppliedCodecProfile = false;
  715. continue;
  716. }
  717. }
  718. }
  719. // Honor requested max channels
  720. playlistItem.GlobalMaxAudioChannels = options.MaxAudioChannels;
  721. int audioBitrate = GetAudioBitrate(options.GetMaxBitrate(false) ?? 0, playlistItem.TargetAudioCodec, audioStream, playlistItem);
  722. playlistItem.AudioBitrate = Math.Min(playlistItem.AudioBitrate ?? audioBitrate, audioBitrate);
  723. bool? isSecondaryAudio = audioStream == null ? null : item.IsSecondaryAudio(audioStream);
  724. int? inputAudioBitrate = audioStream == null ? null : audioStream.BitRate;
  725. int? audioChannels = audioStream == null ? null : audioStream.Channels;
  726. string audioProfile = audioStream == null ? null : audioStream.Profile;
  727. int? inputAudioSampleRate = audioStream == null ? null : audioStream.SampleRate;
  728. int? inputAudioBitDepth = audioStream == null ? null : audioStream.BitDepth;
  729. var appliedAudioConditions = options.Profile.CodecProfiles
  730. .Where(i => i.Type == CodecType.VideoAudio &&
  731. i.ContainsAnyCodec(audioCodec, container) &&
  732. i.ApplyConditions.All(applyCondition => ConditionProcessor.IsVideoAudioConditionSatisfied(applyCondition, audioChannels, inputAudioBitrate, inputAudioSampleRate, inputAudioBitDepth, audioProfile, isSecondaryAudio)));
  733. isFirstAppliedCodecProfile = true;
  734. foreach (var i in appliedAudioConditions)
  735. {
  736. var transcodingAudioCodecs = ContainerProfile.SplitValue(audioCodec);
  737. foreach (var transcodingAudioCodec in transcodingAudioCodecs)
  738. {
  739. if (i.ContainsAnyCodec(transcodingAudioCodec, container))
  740. {
  741. ApplyTranscodingConditions(playlistItem, i.Conditions, transcodingAudioCodec, true, isFirstAppliedCodecProfile);
  742. isFirstAppliedCodecProfile = false;
  743. break;
  744. }
  745. }
  746. }
  747. var maxBitrateSetting = options.GetMaxBitrate(false);
  748. // Honor max rate
  749. if (maxBitrateSetting.HasValue)
  750. {
  751. var availableBitrateForVideo = maxBitrateSetting.Value;
  752. if (playlistItem.AudioBitrate.HasValue)
  753. {
  754. availableBitrateForVideo -= playlistItem.AudioBitrate.Value;
  755. }
  756. // Make sure the video bitrate is lower than bitrate settings but at least 64k
  757. // Don't use Math.Clamp as availableBitrateForVideo can be lower then 64k.
  758. var currentValue = playlistItem.VideoBitrate ?? availableBitrateForVideo;
  759. playlistItem.VideoBitrate = Math.Max(Math.Min(availableBitrateForVideo, currentValue), 64_000);
  760. }
  761. _logger.LogDebug(
  762. "Transcode Result for Profile: {Profile}, Path: {Path}, PlayMethod: {PlayMethod}, AudioStreamIndex: {AudioStreamIndex}, SubtitleStreamIndex: {SubtitleStreamIndex}, Reasons: {TranscodeReason}",
  763. options.Profile?.Name ?? "Anonymous Profile",
  764. item.Path ?? "Unknown path",
  765. playlistItem?.PlayMethod,
  766. audioStream?.Index,
  767. playlistItem?.SubtitleStreamIndex,
  768. playlistItem?.TranscodeReasons);
  769. }
  770. private static int GetDefaultAudioBitrate(string audioCodec, int? audioChannels)
  771. {
  772. if (!string.IsNullOrEmpty(audioCodec))
  773. {
  774. // Default to a higher bitrate for stream copy
  775. if (string.Equals(audioCodec, "aac", StringComparison.OrdinalIgnoreCase)
  776. || string.Equals(audioCodec, "mp3", StringComparison.OrdinalIgnoreCase)
  777. || string.Equals(audioCodec, "ac3", StringComparison.OrdinalIgnoreCase)
  778. || string.Equals(audioCodec, "eac3", StringComparison.OrdinalIgnoreCase))
  779. {
  780. if ((audioChannels ?? 0) < 2)
  781. {
  782. return 128000;
  783. }
  784. return (audioChannels ?? 0) >= 6 ? 640000 : 384000;
  785. }
  786. if (string.Equals(audioCodec, "flac", StringComparison.OrdinalIgnoreCase)
  787. || string.Equals(audioCodec, "alac", StringComparison.OrdinalIgnoreCase))
  788. {
  789. if ((audioChannels ?? 0) < 2)
  790. {
  791. return 768000;
  792. }
  793. return (audioChannels ?? 0) >= 6 ? 3584000 : 1536000;
  794. }
  795. }
  796. return 192000;
  797. }
  798. private static int GetAudioBitrate(long maxTotalBitrate, string[] targetAudioCodecs, MediaStream audioStream, StreamInfo item)
  799. {
  800. string targetAudioCodec = targetAudioCodecs.Length == 0 ? null : targetAudioCodecs[0];
  801. int? targetAudioChannels = item.GetTargetAudioChannels(targetAudioCodec);
  802. int defaultBitrate;
  803. int encoderAudioBitrateLimit = int.MaxValue;
  804. if (audioStream == null)
  805. {
  806. defaultBitrate = 192000;
  807. }
  808. else
  809. {
  810. if (targetAudioChannels.HasValue
  811. && audioStream.Channels.HasValue
  812. && audioStream.Channels.Value > targetAudioChannels.Value)
  813. {
  814. // Reduce the bitrate if we're downmixing.
  815. defaultBitrate = GetDefaultAudioBitrate(targetAudioCodec, targetAudioChannels);
  816. }
  817. else if (targetAudioChannels.HasValue
  818. && audioStream.Channels.HasValue
  819. && audioStream.Channels.Value <= targetAudioChannels.Value
  820. && !string.IsNullOrEmpty(audioStream.Codec)
  821. && targetAudioCodecs != null
  822. && targetAudioCodecs.Length > 0
  823. && !Array.Exists(targetAudioCodecs, elem => string.Equals(audioStream.Codec, elem, StringComparison.OrdinalIgnoreCase)))
  824. {
  825. // Shift the bitrate if we're transcoding to a different audio codec.
  826. defaultBitrate = GetDefaultAudioBitrate(targetAudioCodec, audioStream.Channels.Value);
  827. }
  828. else
  829. {
  830. defaultBitrate = audioStream.BitRate ?? GetDefaultAudioBitrate(targetAudioCodec, targetAudioChannels);
  831. }
  832. // Seeing webm encoding failures when source has 1 audio channel and 22k bitrate.
  833. // Any attempts to transcode over 64k will fail
  834. if (audioStream.Channels == 1
  835. && (audioStream.BitRate ?? 0) < 64000)
  836. {
  837. encoderAudioBitrateLimit = 64000;
  838. }
  839. }
  840. if (maxTotalBitrate > 0)
  841. {
  842. defaultBitrate = Math.Min(GetMaxAudioBitrateForTotalBitrate(maxTotalBitrate), defaultBitrate);
  843. }
  844. return Math.Min(defaultBitrate, encoderAudioBitrateLimit);
  845. }
  846. private static int GetMaxAudioBitrateForTotalBitrate(long totalBitrate)
  847. {
  848. if (totalBitrate <= 640000)
  849. {
  850. return 128000;
  851. }
  852. else if (totalBitrate <= 2000000)
  853. {
  854. return 384000;
  855. }
  856. else if (totalBitrate <= 3000000)
  857. {
  858. return 448000;
  859. }
  860. else if (totalBitrate <= 4000000)
  861. {
  862. return 640000;
  863. }
  864. else if (totalBitrate <= 5000000)
  865. {
  866. return 768000;
  867. }
  868. else if (totalBitrate <= 10000000)
  869. {
  870. return 1536000;
  871. }
  872. else if (totalBitrate <= 15000000)
  873. {
  874. return 2304000;
  875. }
  876. else if (totalBitrate <= 20000000)
  877. {
  878. return 3584000;
  879. }
  880. return 7168000;
  881. }
  882. private (DirectPlayProfile Profile, PlayMethod? PlayMethod, int? AudioStreamIndex, TranscodeReason TranscodeReasons) GetVideoDirectPlayProfile(
  883. VideoOptions options,
  884. MediaSourceInfo mediaSource,
  885. MediaStream videoStream,
  886. MediaStream audioStream,
  887. ICollection<MediaStream> candidateAudioStreams,
  888. MediaStream subtitleStream,
  889. bool isEligibleForDirectPlay,
  890. bool isEligibleForDirectStream)
  891. {
  892. if (options.ForceDirectPlay)
  893. {
  894. return (null, PlayMethod.DirectPlay, audioStream?.Index, 0);
  895. }
  896. if (options.ForceDirectStream)
  897. {
  898. return (null, PlayMethod.DirectStream, audioStream?.Index, 0);
  899. }
  900. DeviceProfile profile = options.Profile;
  901. string container = mediaSource.Container;
  902. // Video
  903. int? width = videoStream?.Width;
  904. int? height = videoStream?.Height;
  905. int? bitDepth = videoStream?.BitDepth;
  906. int? videoBitrate = videoStream?.BitRate;
  907. double? videoLevel = videoStream?.Level;
  908. string videoProfile = videoStream?.Profile;
  909. string videoRangeType = videoStream?.VideoRangeType;
  910. float videoFramerate = videoStream == null ? 0 : videoStream.AverageFrameRate ?? videoStream.AverageFrameRate ?? 0;
  911. bool? isAnamorphic = videoStream?.IsAnamorphic;
  912. bool? isInterlaced = videoStream?.IsInterlaced;
  913. string videoCodecTag = videoStream?.CodecTag;
  914. bool? isAvc = videoStream?.IsAVC;
  915. TransportStreamTimestamp? timestamp = videoStream == null ? TransportStreamTimestamp.None : mediaSource.Timestamp;
  916. int? packetLength = videoStream?.PacketLength;
  917. int? refFrames = videoStream?.RefFrames;
  918. int? numAudioStreams = mediaSource.GetStreamCount(MediaStreamType.Audio);
  919. int? numVideoStreams = mediaSource.GetStreamCount(MediaStreamType.Video);
  920. var checkVideoConditions = (ProfileCondition[] conditions) =>
  921. conditions.Where(applyCondition => !ConditionProcessor.IsVideoConditionSatisfied(applyCondition, width, height, bitDepth, videoBitrate, videoProfile, videoRangeType, videoLevel, videoFramerate, packetLength, timestamp, isAnamorphic, isInterlaced, refFrames, numVideoStreams, numAudioStreams, videoCodecTag, isAvc));
  922. // Check container conditions
  923. var containerProfileReasons = AggregateFailureConditions(
  924. mediaSource,
  925. profile,
  926. "VideoCodecProfile",
  927. profile.ContainerProfiles
  928. .Where(containerProfile => containerProfile.Type == DlnaProfileType.Video && containerProfile.ContainsContainer(container))
  929. .SelectMany(containerProfile => checkVideoConditions(containerProfile.Conditions)));
  930. // Check video conditions
  931. var videoCodecProfileReasons = AggregateFailureConditions(
  932. mediaSource,
  933. profile,
  934. "VideoCodecProfile",
  935. profile.CodecProfiles
  936. .Where(codecProfile => codecProfile.Type == CodecType.Video && codecProfile.ContainsAnyCodec(videoStream?.Codec, container) &&
  937. !checkVideoConditions(codecProfile.ApplyConditions).Any())
  938. .SelectMany(codecProfile => checkVideoConditions(codecProfile.Conditions)));
  939. // Check audiocandidates profile conditions
  940. var audioStreamMatches = candidateAudioStreams.ToDictionary(s => s, audioStream => CheckVideoAudioStreamDirectPlay(options, mediaSource, container, audioStream));
  941. TranscodeReason subtitleProfileReasons = 0;
  942. if (subtitleStream != null)
  943. {
  944. var subtitleProfile = GetSubtitleProfile(mediaSource, subtitleStream, options.Profile.SubtitleProfiles, PlayMethod.DirectPlay, _transcoderSupport, container, null);
  945. if (subtitleProfile.Method != SubtitleDeliveryMethod.Drop
  946. && subtitleProfile.Method != SubtitleDeliveryMethod.External
  947. && subtitleProfile.Method != SubtitleDeliveryMethod.Embed)
  948. {
  949. _logger.LogDebug("Not eligible for {0} due to unsupported subtitles", PlayMethod.DirectPlay);
  950. subtitleProfileReasons |= TranscodeReason.SubtitleCodecNotSupported;
  951. }
  952. }
  953. var rankings = new[] { VideoReasons, AudioReasons, ContainerReasons };
  954. var rank = (ref TranscodeReason a) =>
  955. {
  956. var index = 1;
  957. foreach (var flag in rankings)
  958. {
  959. var reason = a & flag;
  960. if (reason != 0)
  961. {
  962. a = reason;
  963. return index;
  964. }
  965. index++;
  966. }
  967. return index;
  968. };
  969. // Check DirectPlay profiles to see if it can be direct played
  970. var analyzedProfiles = profile.DirectPlayProfiles
  971. .Where(directPlayProfile => directPlayProfile.Type == DlnaProfileType.Video)
  972. .Select((directPlayProfile, order) =>
  973. {
  974. TranscodeReason directPlayProfileReasons = 0;
  975. TranscodeReason audioCodecProfileReasons = 0;
  976. // Check container type
  977. if (!directPlayProfile.SupportsContainer(container))
  978. {
  979. directPlayProfileReasons |= TranscodeReason.ContainerNotSupported;
  980. }
  981. // Check video codec
  982. string videoCodec = videoStream?.Codec;
  983. if (!directPlayProfile.SupportsVideoCodec(videoCodec))
  984. {
  985. directPlayProfileReasons |= TranscodeReason.VideoCodecNotSupported;
  986. }
  987. // Check audio codec
  988. MediaStream selectedAudioStream = null;
  989. if (candidateAudioStreams.Any())
  990. {
  991. selectedAudioStream = candidateAudioStreams.FirstOrDefault(audioStream => directPlayProfile.SupportsAudioCodec(audioStream.Codec));
  992. if (selectedAudioStream == null)
  993. {
  994. directPlayProfileReasons |= TranscodeReason.AudioCodecNotSupported;
  995. }
  996. else
  997. {
  998. audioCodecProfileReasons = audioStreamMatches.GetValueOrDefault(selectedAudioStream);
  999. }
  1000. }
  1001. var failureReasons = directPlayProfileReasons | containerProfileReasons | subtitleProfileReasons;
  1002. if ((failureReasons & TranscodeReason.VideoCodecNotSupported) == 0)
  1003. {
  1004. failureReasons |= videoCodecProfileReasons;
  1005. }
  1006. if ((failureReasons & TranscodeReason.AudioCodecNotSupported) == 0)
  1007. {
  1008. failureReasons |= audioCodecProfileReasons;
  1009. }
  1010. var directStreamFailureReasons = failureReasons & (~DirectStreamReasons);
  1011. PlayMethod? playMethod = null;
  1012. if (failureReasons == 0 && isEligibleForDirectPlay && mediaSource.SupportsDirectPlay)
  1013. {
  1014. playMethod = PlayMethod.DirectPlay;
  1015. }
  1016. else if (directStreamFailureReasons == 0 && isEligibleForDirectStream && mediaSource.SupportsDirectStream && directPlayProfile != null)
  1017. {
  1018. playMethod = PlayMethod.DirectStream;
  1019. }
  1020. var ranked = rank(ref failureReasons);
  1021. return (Result: (Profile: directPlayProfile, PlayMethod: playMethod, AudioStreamIndex: selectedAudioStream?.Index, TranscodeReason: failureReasons), Order: order, Rank: ranked);
  1022. })
  1023. .OrderByDescending(analysis => analysis.Result.PlayMethod)
  1024. .ThenByDescending(analysis => analysis.Rank)
  1025. .ThenBy(analysis => analysis.Order)
  1026. .ToArray()
  1027. .ToLookup(analysis => analysis.Result.PlayMethod != null);
  1028. var profileMatch = analyzedProfiles[true]
  1029. .Select(analysis => analysis.Result)
  1030. .FirstOrDefault();
  1031. if (profileMatch.Profile != null)
  1032. {
  1033. return profileMatch;
  1034. }
  1035. var failureReasons = analyzedProfiles[false].Select(analysis => analysis.Result).FirstOrDefault().TranscodeReason;
  1036. if (failureReasons == 0)
  1037. {
  1038. failureReasons = TranscodeReason.DirectPlayError;
  1039. }
  1040. return (Profile: null, PlayMethod: null, AudioStreamIndex: null, TranscodeReasons: failureReasons);
  1041. }
  1042. private TranscodeReason CheckVideoAudioStreamDirectPlay(VideoOptions options, MediaSourceInfo mediaSource, string container, MediaStream audioStream)
  1043. {
  1044. var profile = options.Profile;
  1045. var audioFailureConditions = GetProfileConditionsForVideoAudio(profile.CodecProfiles, container, audioStream.Codec, audioStream.Channels, audioStream.BitRate, audioStream.SampleRate, audioStream.BitDepth, audioStream.Profile, mediaSource.IsSecondaryAudio(audioStream));
  1046. var audioStreamFailureReasons = AggregateFailureConditions(mediaSource, profile, "VideoAudioCodecProfile", audioFailureConditions);
  1047. if (audioStream?.IsExternal == true)
  1048. {
  1049. audioStreamFailureReasons |= TranscodeReason.AudioIsExternal;
  1050. }
  1051. return audioStreamFailureReasons;
  1052. }
  1053. private TranscodeReason AggregateFailureConditions(MediaSourceInfo mediaSource, DeviceProfile profile, string type, IEnumerable<ProfileCondition> conditions)
  1054. {
  1055. return conditions.Aggregate<ProfileCondition, TranscodeReason>(0, (reasons, i) =>
  1056. {
  1057. LogConditionFailure(profile, type, i, mediaSource);
  1058. var transcodeReasons = GetTranscodeReasonForFailedCondition(i);
  1059. return reasons | transcodeReasons;
  1060. });
  1061. }
  1062. private void LogConditionFailure(DeviceProfile profile, string type, ProfileCondition condition, MediaSourceInfo mediaSource)
  1063. {
  1064. _logger.LogDebug(
  1065. "Profile: {0}, DirectPlay=false. Reason={1}.{2} Condition: {3}. ConditionValue: {4}. IsRequired: {5}. Path: {6}",
  1066. type,
  1067. profile.Name ?? "Unknown Profile",
  1068. condition.Property,
  1069. condition.Condition,
  1070. condition.Value ?? string.Empty,
  1071. condition.IsRequired,
  1072. mediaSource.Path ?? "Unknown path");
  1073. }
  1074. private TranscodeReason IsBitrateEligibleForDirectPlayback(
  1075. MediaSourceInfo item,
  1076. long maxBitrate,
  1077. VideoOptions options,
  1078. PlayMethod playMethod)
  1079. {
  1080. bool result = IsItemBitrateEligibleForDirectPlayback(item, maxBitrate, playMethod);
  1081. if (!result)
  1082. {
  1083. return TranscodeReason.ContainerBitrateExceedsLimit;
  1084. }
  1085. else
  1086. {
  1087. return 0;
  1088. }
  1089. }
  1090. public static SubtitleProfile GetSubtitleProfile(
  1091. MediaSourceInfo mediaSource,
  1092. MediaStream subtitleStream,
  1093. SubtitleProfile[] subtitleProfiles,
  1094. PlayMethod playMethod,
  1095. ITranscoderSupport transcoderSupport,
  1096. string outputContainer,
  1097. string transcodingSubProtocol)
  1098. {
  1099. if (!subtitleStream.IsExternal && (playMethod != PlayMethod.Transcode || !string.Equals(transcodingSubProtocol, "hls", StringComparison.OrdinalIgnoreCase)))
  1100. {
  1101. // Look for supported embedded subs of the same format
  1102. foreach (var profile in subtitleProfiles)
  1103. {
  1104. if (!profile.SupportsLanguage(subtitleStream.Language))
  1105. {
  1106. continue;
  1107. }
  1108. if (profile.Method != SubtitleDeliveryMethod.Embed)
  1109. {
  1110. continue;
  1111. }
  1112. if (!ContainerProfile.ContainsContainer(profile.Container, outputContainer))
  1113. {
  1114. continue;
  1115. }
  1116. if (playMethod == PlayMethod.Transcode && !IsSubtitleEmbedSupported(outputContainer))
  1117. {
  1118. continue;
  1119. }
  1120. if (subtitleStream.IsTextSubtitleStream == MediaStream.IsTextFormat(profile.Format) && string.Equals(profile.Format, subtitleStream.Codec, StringComparison.OrdinalIgnoreCase))
  1121. {
  1122. return profile;
  1123. }
  1124. }
  1125. // Look for supported embedded subs of a convertible format
  1126. foreach (var profile in subtitleProfiles)
  1127. {
  1128. if (!profile.SupportsLanguage(subtitleStream.Language))
  1129. {
  1130. continue;
  1131. }
  1132. if (profile.Method != SubtitleDeliveryMethod.Embed)
  1133. {
  1134. continue;
  1135. }
  1136. if (!ContainerProfile.ContainsContainer(profile.Container, outputContainer))
  1137. {
  1138. continue;
  1139. }
  1140. if (playMethod == PlayMethod.Transcode && !IsSubtitleEmbedSupported(outputContainer))
  1141. {
  1142. continue;
  1143. }
  1144. if (subtitleStream.IsTextSubtitleStream && subtitleStream.SupportsSubtitleConversionTo(profile.Format))
  1145. {
  1146. return profile;
  1147. }
  1148. }
  1149. }
  1150. // Look for an external or hls profile that matches the stream type (text/graphical) and doesn't require conversion
  1151. return GetExternalSubtitleProfile(mediaSource, subtitleStream, subtitleProfiles, playMethod, transcoderSupport, false) ??
  1152. GetExternalSubtitleProfile(mediaSource, subtitleStream, subtitleProfiles, playMethod, transcoderSupport, true) ??
  1153. new SubtitleProfile
  1154. {
  1155. Method = SubtitleDeliveryMethod.Encode,
  1156. Format = subtitleStream.Codec
  1157. };
  1158. }
  1159. private static bool IsSubtitleEmbedSupported(string transcodingContainer)
  1160. {
  1161. if (!string.IsNullOrEmpty(transcodingContainer))
  1162. {
  1163. string[] normalizedContainers = ContainerProfile.SplitValue(transcodingContainer);
  1164. if (ContainerProfile.ContainsContainer(normalizedContainers, "ts")
  1165. || ContainerProfile.ContainsContainer(normalizedContainers, "mpegts")
  1166. || ContainerProfile.ContainsContainer(normalizedContainers, "mp4"))
  1167. {
  1168. return false;
  1169. }
  1170. else if (ContainerProfile.ContainsContainer(normalizedContainers, "mkv")
  1171. || ContainerProfile.ContainsContainer(normalizedContainers, "matroska"))
  1172. {
  1173. return true;
  1174. }
  1175. }
  1176. return false;
  1177. }
  1178. private static SubtitleProfile GetExternalSubtitleProfile(MediaSourceInfo mediaSource, MediaStream subtitleStream, SubtitleProfile[] subtitleProfiles, PlayMethod playMethod, ITranscoderSupport transcoderSupport, bool allowConversion)
  1179. {
  1180. foreach (var profile in subtitleProfiles)
  1181. {
  1182. if (profile.Method != SubtitleDeliveryMethod.External && profile.Method != SubtitleDeliveryMethod.Hls)
  1183. {
  1184. continue;
  1185. }
  1186. if (profile.Method == SubtitleDeliveryMethod.Hls && playMethod != PlayMethod.Transcode)
  1187. {
  1188. continue;
  1189. }
  1190. if (!profile.SupportsLanguage(subtitleStream.Language))
  1191. {
  1192. continue;
  1193. }
  1194. if (!subtitleStream.IsExternal && !transcoderSupport.CanExtractSubtitles(subtitleStream.Codec))
  1195. {
  1196. continue;
  1197. }
  1198. if ((profile.Method == SubtitleDeliveryMethod.External && subtitleStream.IsTextSubtitleStream == MediaStream.IsTextFormat(profile.Format)) ||
  1199. (profile.Method == SubtitleDeliveryMethod.Hls && subtitleStream.IsTextSubtitleStream))
  1200. {
  1201. bool requiresConversion = !string.Equals(subtitleStream.Codec, profile.Format, StringComparison.OrdinalIgnoreCase);
  1202. if (!requiresConversion)
  1203. {
  1204. return profile;
  1205. }
  1206. if (!allowConversion)
  1207. {
  1208. continue;
  1209. }
  1210. // TODO: Build this into subtitleStream.SupportsExternalStream
  1211. if (mediaSource.IsInfiniteStream)
  1212. {
  1213. continue;
  1214. }
  1215. if (subtitleStream.IsTextSubtitleStream && subtitleStream.SupportsExternalStream && subtitleStream.SupportsSubtitleConversionTo(profile.Format))
  1216. {
  1217. return profile;
  1218. }
  1219. }
  1220. }
  1221. return null;
  1222. }
  1223. private bool IsItemBitrateEligibleForDirectPlayback(MediaSourceInfo item, long maxBitrate, PlayMethod playMethod)
  1224. {
  1225. // Don't restrict by bitrate if coming from an external domain
  1226. if (item.IsRemote)
  1227. {
  1228. return true;
  1229. }
  1230. long requestedMaxBitrate = maxBitrate > 0 ? maxBitrate : 1000000;
  1231. // If we don't know the bitrate, then force a transcode if requested max bitrate is under 40 mbps
  1232. int itemBitrate = item.Bitrate ?? 40000000;
  1233. if (itemBitrate > requestedMaxBitrate)
  1234. {
  1235. _logger.LogDebug(
  1236. "Bitrate exceeds {PlayBackMethod} limit: media bitrate: {MediaBitrate}, max bitrate: {MaxBitrate}",
  1237. playMethod,
  1238. itemBitrate,
  1239. requestedMaxBitrate);
  1240. return false;
  1241. }
  1242. return true;
  1243. }
  1244. private static void ValidateInput(VideoOptions options)
  1245. {
  1246. ValidateAudioInput(options);
  1247. if (options.AudioStreamIndex.HasValue && string.IsNullOrEmpty(options.MediaSourceId))
  1248. {
  1249. throw new ArgumentException("MediaSourceId is required when a specific audio stream is requested");
  1250. }
  1251. if (options.SubtitleStreamIndex.HasValue && string.IsNullOrEmpty(options.MediaSourceId))
  1252. {
  1253. throw new ArgumentException("MediaSourceId is required when a specific subtitle stream is requested");
  1254. }
  1255. }
  1256. private static void ValidateAudioInput(AudioOptions options)
  1257. {
  1258. if (options.ItemId.Equals(default))
  1259. {
  1260. throw new ArgumentException("ItemId is required");
  1261. }
  1262. if (string.IsNullOrEmpty(options.DeviceId))
  1263. {
  1264. throw new ArgumentException("DeviceId is required");
  1265. }
  1266. if (options.Profile == null)
  1267. {
  1268. throw new ArgumentException("Profile is required");
  1269. }
  1270. if (options.MediaSources == null)
  1271. {
  1272. throw new ArgumentException("MediaSources is required");
  1273. }
  1274. }
  1275. private static IEnumerable<ProfileCondition> GetProfileConditionsForVideoAudio(
  1276. IEnumerable<CodecProfile> codecProfiles,
  1277. string container,
  1278. string codec,
  1279. int? audioChannels,
  1280. int? audioBitrate,
  1281. int? audioSampleRate,
  1282. int? audioBitDepth,
  1283. string audioProfile,
  1284. bool? isSecondaryAudio)
  1285. {
  1286. return codecProfiles
  1287. .Where(profile => profile.Type == CodecType.VideoAudio && profile.ContainsAnyCodec(codec, container) &&
  1288. profile.ApplyConditions.All(applyCondition => ConditionProcessor.IsVideoAudioConditionSatisfied(applyCondition, audioChannels, audioBitrate, audioSampleRate, audioBitDepth, audioProfile, isSecondaryAudio)))
  1289. .SelectMany(profile => profile.Conditions)
  1290. .Where(condition => !ConditionProcessor.IsVideoAudioConditionSatisfied(condition, audioChannels, audioBitrate, audioSampleRate, audioBitDepth, audioProfile, isSecondaryAudio));
  1291. }
  1292. private static IEnumerable<ProfileCondition> GetProfileConditionsForAudio(
  1293. IEnumerable<CodecProfile> codecProfiles,
  1294. string container,
  1295. string codec,
  1296. int? audioChannels,
  1297. int? audioBitrate,
  1298. int? audioSampleRate,
  1299. int? audioBitDepth,
  1300. bool checkConditions)
  1301. {
  1302. var conditions = codecProfiles
  1303. .Where(profile => profile.Type == CodecType.Audio && profile.ContainsAnyCodec(codec, container) &&
  1304. profile.ApplyConditions.All(applyCondition => ConditionProcessor.IsAudioConditionSatisfied(applyCondition, audioChannels, audioBitrate, audioSampleRate, audioBitDepth)))
  1305. .SelectMany(profile => profile.Conditions);
  1306. if (!checkConditions)
  1307. {
  1308. return conditions;
  1309. }
  1310. return conditions.Where(condition => !ConditionProcessor.IsAudioConditionSatisfied(condition, audioChannels, audioBitrate, audioSampleRate, audioBitDepth));
  1311. }
  1312. private void ApplyTranscodingConditions(StreamInfo item, IEnumerable<ProfileCondition> conditions, string qualifier, bool enableQualifiedConditions, bool enableNonQualifiedConditions)
  1313. {
  1314. foreach (ProfileCondition condition in conditions)
  1315. {
  1316. string value = condition.Value;
  1317. if (string.IsNullOrEmpty(value))
  1318. {
  1319. continue;
  1320. }
  1321. // No way to express this
  1322. if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1323. {
  1324. continue;
  1325. }
  1326. switch (condition.Property)
  1327. {
  1328. case ProfileConditionValue.AudioBitrate:
  1329. {
  1330. if (!enableNonQualifiedConditions)
  1331. {
  1332. continue;
  1333. }
  1334. if (int.TryParse(value, NumberStyles.Any, CultureInfo.InvariantCulture, out var num))
  1335. {
  1336. if (condition.Condition == ProfileConditionType.Equals)
  1337. {
  1338. item.AudioBitrate = num;
  1339. }
  1340. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1341. {
  1342. item.AudioBitrate = Math.Min(num, item.AudioBitrate ?? num);
  1343. }
  1344. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1345. {
  1346. item.AudioBitrate = Math.Max(num, item.AudioBitrate ?? num);
  1347. }
  1348. }
  1349. break;
  1350. }
  1351. case ProfileConditionValue.AudioSampleRate:
  1352. {
  1353. if (!enableNonQualifiedConditions)
  1354. {
  1355. continue;
  1356. }
  1357. if (int.TryParse(value, NumberStyles.Any, CultureInfo.InvariantCulture, out var num))
  1358. {
  1359. if (condition.Condition == ProfileConditionType.Equals)
  1360. {
  1361. item.AudioSampleRate = num;
  1362. }
  1363. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1364. {
  1365. item.AudioSampleRate = Math.Min(num, item.AudioSampleRate ?? num);
  1366. }
  1367. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1368. {
  1369. item.AudioSampleRate = Math.Max(num, item.AudioSampleRate ?? num);
  1370. }
  1371. }
  1372. break;
  1373. }
  1374. case ProfileConditionValue.AudioChannels:
  1375. {
  1376. if (string.IsNullOrEmpty(qualifier))
  1377. {
  1378. if (!enableNonQualifiedConditions)
  1379. {
  1380. continue;
  1381. }
  1382. }
  1383. else
  1384. {
  1385. if (!enableQualifiedConditions)
  1386. {
  1387. continue;
  1388. }
  1389. }
  1390. if (int.TryParse(value, NumberStyles.Any, CultureInfo.InvariantCulture, out var num))
  1391. {
  1392. if (condition.Condition == ProfileConditionType.Equals)
  1393. {
  1394. item.SetOption(qualifier, "audiochannels", num.ToString(CultureInfo.InvariantCulture));
  1395. }
  1396. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1397. {
  1398. item.SetOption(qualifier, "audiochannels", Math.Min(num, item.GetTargetAudioChannels(qualifier) ?? num).ToString(CultureInfo.InvariantCulture));
  1399. }
  1400. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1401. {
  1402. item.SetOption(qualifier, "audiochannels", Math.Max(num, item.GetTargetAudioChannels(qualifier) ?? num).ToString(CultureInfo.InvariantCulture));
  1403. }
  1404. }
  1405. break;
  1406. }
  1407. case ProfileConditionValue.IsAvc:
  1408. {
  1409. if (!enableNonQualifiedConditions)
  1410. {
  1411. continue;
  1412. }
  1413. if (bool.TryParse(value, out var isAvc))
  1414. {
  1415. if (isAvc && condition.Condition == ProfileConditionType.Equals)
  1416. {
  1417. item.RequireAvc = true;
  1418. }
  1419. else if (!isAvc && condition.Condition == ProfileConditionType.NotEquals)
  1420. {
  1421. item.RequireAvc = true;
  1422. }
  1423. }
  1424. break;
  1425. }
  1426. case ProfileConditionValue.IsAnamorphic:
  1427. {
  1428. if (!enableNonQualifiedConditions)
  1429. {
  1430. continue;
  1431. }
  1432. if (bool.TryParse(value, out var isAnamorphic))
  1433. {
  1434. if (isAnamorphic && condition.Condition == ProfileConditionType.Equals)
  1435. {
  1436. item.RequireNonAnamorphic = true;
  1437. }
  1438. else if (!isAnamorphic && condition.Condition == ProfileConditionType.NotEquals)
  1439. {
  1440. item.RequireNonAnamorphic = true;
  1441. }
  1442. }
  1443. break;
  1444. }
  1445. case ProfileConditionValue.IsInterlaced:
  1446. {
  1447. if (string.IsNullOrEmpty(qualifier))
  1448. {
  1449. if (!enableNonQualifiedConditions)
  1450. {
  1451. continue;
  1452. }
  1453. }
  1454. else
  1455. {
  1456. if (!enableQualifiedConditions)
  1457. {
  1458. continue;
  1459. }
  1460. }
  1461. if (bool.TryParse(value, out var isInterlaced))
  1462. {
  1463. if (!isInterlaced && condition.Condition == ProfileConditionType.Equals)
  1464. {
  1465. item.SetOption(qualifier, "deinterlace", "true");
  1466. }
  1467. else if (isInterlaced && condition.Condition == ProfileConditionType.NotEquals)
  1468. {
  1469. item.SetOption(qualifier, "deinterlace", "true");
  1470. }
  1471. }
  1472. break;
  1473. }
  1474. case ProfileConditionValue.AudioProfile:
  1475. case ProfileConditionValue.Has64BitOffsets:
  1476. case ProfileConditionValue.PacketLength:
  1477. case ProfileConditionValue.NumAudioStreams:
  1478. case ProfileConditionValue.NumVideoStreams:
  1479. case ProfileConditionValue.IsSecondaryAudio:
  1480. case ProfileConditionValue.VideoTimestamp:
  1481. {
  1482. // Not supported yet
  1483. break;
  1484. }
  1485. case ProfileConditionValue.RefFrames:
  1486. {
  1487. if (string.IsNullOrEmpty(qualifier))
  1488. {
  1489. if (!enableNonQualifiedConditions)
  1490. {
  1491. continue;
  1492. }
  1493. }
  1494. else
  1495. {
  1496. if (!enableQualifiedConditions)
  1497. {
  1498. continue;
  1499. }
  1500. }
  1501. if (int.TryParse(value, NumberStyles.Any, CultureInfo.InvariantCulture, out var num))
  1502. {
  1503. if (condition.Condition == ProfileConditionType.Equals)
  1504. {
  1505. item.SetOption(qualifier, "maxrefframes", num.ToString(CultureInfo.InvariantCulture));
  1506. }
  1507. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1508. {
  1509. item.SetOption(qualifier, "maxrefframes", Math.Min(num, item.GetTargetRefFrames(qualifier) ?? num).ToString(CultureInfo.InvariantCulture));
  1510. }
  1511. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1512. {
  1513. item.SetOption(qualifier, "maxrefframes", Math.Max(num, item.GetTargetRefFrames(qualifier) ?? num).ToString(CultureInfo.InvariantCulture));
  1514. }
  1515. }
  1516. break;
  1517. }
  1518. case ProfileConditionValue.VideoBitDepth:
  1519. {
  1520. if (string.IsNullOrEmpty(qualifier))
  1521. {
  1522. if (!enableNonQualifiedConditions)
  1523. {
  1524. continue;
  1525. }
  1526. }
  1527. else
  1528. {
  1529. if (!enableQualifiedConditions)
  1530. {
  1531. continue;
  1532. }
  1533. }
  1534. if (int.TryParse(value, NumberStyles.Any, CultureInfo.InvariantCulture, out var num))
  1535. {
  1536. if (condition.Condition == ProfileConditionType.Equals)
  1537. {
  1538. item.SetOption(qualifier, "videobitdepth", num.ToString(CultureInfo.InvariantCulture));
  1539. }
  1540. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1541. {
  1542. item.SetOption(qualifier, "videobitdepth", Math.Min(num, item.GetTargetVideoBitDepth(qualifier) ?? num).ToString(CultureInfo.InvariantCulture));
  1543. }
  1544. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1545. {
  1546. item.SetOption(qualifier, "videobitdepth", Math.Max(num, item.GetTargetVideoBitDepth(qualifier) ?? num).ToString(CultureInfo.InvariantCulture));
  1547. }
  1548. }
  1549. break;
  1550. }
  1551. case ProfileConditionValue.VideoProfile:
  1552. {
  1553. if (string.IsNullOrEmpty(qualifier))
  1554. {
  1555. continue;
  1556. }
  1557. // change from split by | to comma
  1558. // strip spaces to avoid having to encode
  1559. var values = value
  1560. .Split('|', StringSplitOptions.RemoveEmptyEntries);
  1561. if (condition.Condition == ProfileConditionType.Equals)
  1562. {
  1563. item.SetOption(qualifier, "profile", string.Join(',', values));
  1564. }
  1565. else if (condition.Condition == ProfileConditionType.EqualsAny)
  1566. {
  1567. var currentValue = item.GetOption(qualifier, "profile");
  1568. if (!string.IsNullOrEmpty(currentValue) && values.Any(value => value == currentValue))
  1569. {
  1570. item.SetOption(qualifier, "profile", currentValue);
  1571. }
  1572. else
  1573. {
  1574. item.SetOption(qualifier, "profile", string.Join(',', values));
  1575. }
  1576. }
  1577. break;
  1578. }
  1579. case ProfileConditionValue.VideoRangeType:
  1580. {
  1581. if (string.IsNullOrEmpty(qualifier))
  1582. {
  1583. continue;
  1584. }
  1585. // change from split by | to comma
  1586. // strip spaces to avoid having to encode
  1587. var values = value
  1588. .Split('|', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries);
  1589. if (condition.Condition == ProfileConditionType.Equals)
  1590. {
  1591. item.SetOption(qualifier, "rangetype", string.Join(',', values));
  1592. }
  1593. else if (condition.Condition == ProfileConditionType.EqualsAny)
  1594. {
  1595. var currentValue = item.GetOption(qualifier, "rangetype");
  1596. if (!string.IsNullOrEmpty(currentValue) && values.Any(v => string.Equals(v, currentValue, StringComparison.OrdinalIgnoreCase)))
  1597. {
  1598. item.SetOption(qualifier, "rangetype", currentValue);
  1599. }
  1600. else
  1601. {
  1602. item.SetOption(qualifier, "rangetype", string.Join(',', values));
  1603. }
  1604. }
  1605. break;
  1606. }
  1607. case ProfileConditionValue.Height:
  1608. {
  1609. if (!enableNonQualifiedConditions)
  1610. {
  1611. continue;
  1612. }
  1613. if (int.TryParse(value, NumberStyles.Any, CultureInfo.InvariantCulture, out var num))
  1614. {
  1615. if (condition.Condition == ProfileConditionType.Equals)
  1616. {
  1617. item.MaxHeight = num;
  1618. }
  1619. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1620. {
  1621. item.MaxHeight = Math.Min(num, item.MaxHeight ?? num);
  1622. }
  1623. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1624. {
  1625. item.MaxHeight = Math.Max(num, item.MaxHeight ?? num);
  1626. }
  1627. }
  1628. break;
  1629. }
  1630. case ProfileConditionValue.VideoBitrate:
  1631. {
  1632. if (!enableNonQualifiedConditions)
  1633. {
  1634. continue;
  1635. }
  1636. if (int.TryParse(value, NumberStyles.Any, CultureInfo.InvariantCulture, out var num))
  1637. {
  1638. if (condition.Condition == ProfileConditionType.Equals)
  1639. {
  1640. item.VideoBitrate = num;
  1641. }
  1642. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1643. {
  1644. item.VideoBitrate = Math.Min(num, item.VideoBitrate ?? num);
  1645. }
  1646. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1647. {
  1648. item.VideoBitrate = Math.Max(num, item.VideoBitrate ?? num);
  1649. }
  1650. }
  1651. break;
  1652. }
  1653. case ProfileConditionValue.VideoFramerate:
  1654. {
  1655. if (!enableNonQualifiedConditions)
  1656. {
  1657. continue;
  1658. }
  1659. if (float.TryParse(value, NumberStyles.Any, CultureInfo.InvariantCulture, out var num))
  1660. {
  1661. if (condition.Condition == ProfileConditionType.Equals)
  1662. {
  1663. item.MaxFramerate = num;
  1664. }
  1665. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1666. {
  1667. item.MaxFramerate = Math.Min(num, item.MaxFramerate ?? num);
  1668. }
  1669. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1670. {
  1671. item.MaxFramerate = Math.Max(num, item.MaxFramerate ?? num);
  1672. }
  1673. }
  1674. break;
  1675. }
  1676. case ProfileConditionValue.VideoLevel:
  1677. {
  1678. if (string.IsNullOrEmpty(qualifier))
  1679. {
  1680. continue;
  1681. }
  1682. if (int.TryParse(value, NumberStyles.Any, CultureInfo.InvariantCulture, out var num))
  1683. {
  1684. if (condition.Condition == ProfileConditionType.Equals)
  1685. {
  1686. item.SetOption(qualifier, "level", num.ToString(CultureInfo.InvariantCulture));
  1687. }
  1688. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1689. {
  1690. item.SetOption(qualifier, "level", Math.Min(num, item.GetTargetVideoLevel(qualifier) ?? num).ToString(CultureInfo.InvariantCulture));
  1691. }
  1692. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1693. {
  1694. item.SetOption(qualifier, "level", Math.Max(num, item.GetTargetVideoLevel(qualifier) ?? num).ToString(CultureInfo.InvariantCulture));
  1695. }
  1696. }
  1697. break;
  1698. }
  1699. case ProfileConditionValue.Width:
  1700. {
  1701. if (!enableNonQualifiedConditions)
  1702. {
  1703. continue;
  1704. }
  1705. if (int.TryParse(value, NumberStyles.Any, CultureInfo.InvariantCulture, out var num))
  1706. {
  1707. if (condition.Condition == ProfileConditionType.Equals)
  1708. {
  1709. item.MaxWidth = num;
  1710. }
  1711. else if (condition.Condition == ProfileConditionType.LessThanEqual)
  1712. {
  1713. item.MaxWidth = Math.Min(num, item.MaxWidth ?? num);
  1714. }
  1715. else if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  1716. {
  1717. item.MaxWidth = Math.Max(num, item.MaxWidth ?? num);
  1718. }
  1719. }
  1720. break;
  1721. }
  1722. default:
  1723. break;
  1724. }
  1725. }
  1726. }
  1727. private static bool IsAudioDirectPlaySupported(DirectPlayProfile profile, MediaSourceInfo item, MediaStream audioStream)
  1728. {
  1729. // Check container type
  1730. if (!profile.SupportsContainer(item.Container))
  1731. {
  1732. return false;
  1733. }
  1734. // Check audio codec
  1735. string audioCodec = audioStream?.Codec;
  1736. if (!profile.SupportsAudioCodec(audioCodec))
  1737. {
  1738. return false;
  1739. }
  1740. return true;
  1741. }
  1742. }
  1743. }