StreamBuilder.cs 77 KB

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