StreamBuilder.cs 77 KB

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