StreamBuilder.cs 77 KB

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