StreamBuilder.cs 90 KB

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