StreamBuilder.cs 42 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055
  1. using MediaBrowser.Model.Dto;
  2. using MediaBrowser.Model.Entities;
  3. using MediaBrowser.Model.Extensions;
  4. using MediaBrowser.Model.Logging;
  5. using MediaBrowser.Model.MediaInfo;
  6. using MediaBrowser.Model.Session;
  7. using System;
  8. using System.Collections.Generic;
  9. namespace MediaBrowser.Model.Dlna
  10. {
  11. public class StreamBuilder
  12. {
  13. private readonly ILocalPlayer _localPlayer;
  14. private readonly ILogger _logger;
  15. public StreamBuilder(ILocalPlayer localPlayer, ILogger logger)
  16. {
  17. _localPlayer = localPlayer;
  18. _logger = logger;
  19. }
  20. public StreamBuilder(ILogger logger)
  21. : this(new NullLocalPlayer(), logger)
  22. {
  23. }
  24. public StreamInfo BuildAudioItem(AudioOptions options)
  25. {
  26. ValidateAudioInput(options);
  27. List<MediaSourceInfo> mediaSources = new List<MediaSourceInfo>();
  28. foreach (MediaSourceInfo i in options.MediaSources)
  29. {
  30. if (string.IsNullOrEmpty(options.MediaSourceId) ||
  31. StringHelper.EqualsIgnoreCase(i.Id, options.MediaSourceId))
  32. {
  33. mediaSources.Add(i);
  34. }
  35. }
  36. List<StreamInfo> streams = new List<StreamInfo>();
  37. foreach (MediaSourceInfo i in mediaSources)
  38. {
  39. StreamInfo streamInfo = BuildAudioItem(i, options);
  40. if (streamInfo != null)
  41. {
  42. streams.Add(streamInfo);
  43. }
  44. }
  45. foreach (StreamInfo stream in streams)
  46. {
  47. stream.DeviceId = options.DeviceId;
  48. stream.DeviceProfileId = options.Profile.Id;
  49. }
  50. return GetOptimalStream(streams);
  51. }
  52. public StreamInfo BuildVideoItem(VideoOptions options)
  53. {
  54. ValidateInput(options);
  55. List<MediaSourceInfo> mediaSources = new List<MediaSourceInfo>();
  56. foreach (MediaSourceInfo i in options.MediaSources)
  57. {
  58. if (string.IsNullOrEmpty(options.MediaSourceId) ||
  59. StringHelper.EqualsIgnoreCase(i.Id, options.MediaSourceId))
  60. {
  61. mediaSources.Add(i);
  62. }
  63. }
  64. List<StreamInfo> streams = new List<StreamInfo>();
  65. foreach (MediaSourceInfo i in mediaSources)
  66. {
  67. StreamInfo streamInfo = BuildVideoItem(i, options);
  68. if (streamInfo != null)
  69. {
  70. streams.Add(streamInfo);
  71. }
  72. }
  73. foreach (StreamInfo stream in streams)
  74. {
  75. stream.DeviceId = options.DeviceId;
  76. stream.DeviceProfileId = options.Profile.Id;
  77. }
  78. return GetOptimalStream(streams);
  79. }
  80. private StreamInfo GetOptimalStream(List<StreamInfo> streams)
  81. {
  82. streams = StreamInfoSorter.SortMediaSources(streams);
  83. foreach (StreamInfo stream in streams)
  84. {
  85. return stream;
  86. }
  87. return null;
  88. }
  89. private StreamInfo BuildAudioItem(MediaSourceInfo item, AudioOptions options)
  90. {
  91. StreamInfo playlistItem = new StreamInfo
  92. {
  93. ItemId = options.ItemId,
  94. MediaType = DlnaProfileType.Audio,
  95. MediaSource = item,
  96. RunTimeTicks = item.RunTimeTicks,
  97. Context = options.Context,
  98. DeviceProfile = options.Profile
  99. };
  100. MediaStream audioStream = item.GetDefaultAudioStream(null);
  101. List<PlayMethod> directPlayMethods = GetAudioDirectPlayMethods(item, audioStream, options);
  102. if (directPlayMethods.Count > 0)
  103. {
  104. string audioCodec = audioStream == null ? null : audioStream.Codec;
  105. // Make sure audio codec profiles are satisfied
  106. if (!string.IsNullOrEmpty(audioCodec))
  107. {
  108. ConditionProcessor conditionProcessor = new ConditionProcessor();
  109. List<ProfileCondition> conditions = new List<ProfileCondition>();
  110. foreach (CodecProfile i in options.Profile.CodecProfiles)
  111. {
  112. if (i.Type == CodecType.Audio && i.ContainsCodec(audioCodec, item.Container))
  113. {
  114. foreach (ProfileCondition c in i.Conditions)
  115. {
  116. conditions.Add(c);
  117. }
  118. }
  119. }
  120. int? audioChannels = audioStream.Channels;
  121. int? audioBitrate = audioStream.BitRate;
  122. bool all = true;
  123. foreach (ProfileCondition c in conditions)
  124. {
  125. if (!conditionProcessor.IsAudioConditionSatisfied(c, audioChannels, audioBitrate))
  126. {
  127. LogConditionFailure(options.Profile, "AudioCodecProfile", c, item);
  128. all = false;
  129. break;
  130. }
  131. }
  132. if (all)
  133. {
  134. if (item.Protocol == MediaProtocol.File &&
  135. directPlayMethods.Contains(PlayMethod.DirectPlay) &&
  136. _localPlayer.CanAccessFile(item.Path))
  137. {
  138. playlistItem.PlayMethod = PlayMethod.DirectPlay;
  139. }
  140. else if (item.Protocol == MediaProtocol.Http &&
  141. directPlayMethods.Contains(PlayMethod.DirectPlay) &&
  142. _localPlayer.CanAccessUrl(item.Path, item.RequiredHttpHeaders.Count > 0))
  143. {
  144. playlistItem.PlayMethod = PlayMethod.DirectPlay;
  145. }
  146. else if (directPlayMethods.Contains(PlayMethod.DirectStream))
  147. {
  148. playlistItem.PlayMethod = PlayMethod.DirectStream;
  149. }
  150. playlistItem.Container = item.Container;
  151. return playlistItem;
  152. }
  153. }
  154. }
  155. TranscodingProfile transcodingProfile = null;
  156. foreach (TranscodingProfile i in options.Profile.TranscodingProfiles)
  157. {
  158. if (i.Type == playlistItem.MediaType && i.Context == options.Context)
  159. {
  160. transcodingProfile = i;
  161. break;
  162. }
  163. }
  164. if (transcodingProfile != null)
  165. {
  166. if (!item.SupportsTranscoding)
  167. {
  168. return null;
  169. }
  170. playlistItem.PlayMethod = PlayMethod.Transcode;
  171. playlistItem.TranscodeSeekInfo = transcodingProfile.TranscodeSeekInfo;
  172. playlistItem.EstimateContentLength = transcodingProfile.EstimateContentLength;
  173. playlistItem.Container = transcodingProfile.Container;
  174. playlistItem.AudioCodec = transcodingProfile.AudioCodec;
  175. playlistItem.SubProtocol = transcodingProfile.Protocol;
  176. List<CodecProfile> audioCodecProfiles = new List<CodecProfile>();
  177. foreach (CodecProfile i in options.Profile.CodecProfiles)
  178. {
  179. if (i.Type == CodecType.Audio && i.ContainsCodec(transcodingProfile.AudioCodec, transcodingProfile.Container))
  180. {
  181. audioCodecProfiles.Add(i);
  182. }
  183. if (audioCodecProfiles.Count >= 1) break;
  184. }
  185. List<ProfileCondition> audioTranscodingConditions = new List<ProfileCondition>();
  186. foreach (CodecProfile i in audioCodecProfiles)
  187. {
  188. foreach (ProfileCondition c in i.Conditions)
  189. {
  190. audioTranscodingConditions.Add(c);
  191. }
  192. }
  193. ApplyTranscodingConditions(playlistItem, audioTranscodingConditions);
  194. // Honor requested max channels
  195. if (options.MaxAudioChannels.HasValue)
  196. {
  197. int currentValue = playlistItem.MaxAudioChannels ?? options.MaxAudioChannels.Value;
  198. playlistItem.MaxAudioChannels = Math.Min(options.MaxAudioChannels.Value, currentValue);
  199. }
  200. int configuredBitrate = options.AudioTranscodingBitrate ??
  201. (options.Context == EncodingContext.Static ? options.Profile.MusicSyncBitrate : options.Profile.MusicStreamingTranscodingBitrate) ??
  202. 128000;
  203. playlistItem.AudioBitrate = Math.Min(configuredBitrate, playlistItem.AudioBitrate ?? configuredBitrate);
  204. }
  205. return playlistItem;
  206. }
  207. private int? GetBitrateForDirectPlayCheck(MediaSourceInfo item, AudioOptions options)
  208. {
  209. if (item.Protocol == MediaProtocol.File)
  210. {
  211. return options.Profile.MaxStaticBitrate;
  212. }
  213. return options.GetMaxBitrate();
  214. }
  215. private List<PlayMethod> GetAudioDirectPlayMethods(MediaSourceInfo item, MediaStream audioStream, AudioOptions options)
  216. {
  217. DirectPlayProfile directPlayProfile = null;
  218. foreach (DirectPlayProfile i in options.Profile.DirectPlayProfiles)
  219. {
  220. if (i.Type == DlnaProfileType.Audio && IsAudioDirectPlaySupported(i, item, audioStream))
  221. {
  222. directPlayProfile = i;
  223. break;
  224. }
  225. }
  226. List<PlayMethod> playMethods = new List<PlayMethod>();
  227. if (directPlayProfile != null)
  228. {
  229. // While options takes the network and other factors into account. Only applies to direct stream
  230. if (item.SupportsDirectStream && IsAudioEligibleForDirectPlay(item, options.GetMaxBitrate()))
  231. {
  232. playMethods.Add(PlayMethod.DirectStream);
  233. }
  234. // The profile describes what the device supports
  235. // If device requirements are satisfied then allow both direct stream and direct play
  236. if (item.SupportsDirectPlay &&
  237. IsAudioEligibleForDirectPlay(item, GetBitrateForDirectPlayCheck(item, options)))
  238. {
  239. playMethods.Add(PlayMethod.DirectPlay);
  240. }
  241. }
  242. else
  243. {
  244. _logger.Info("Profile: {0}, No direct play profiles found for Path: {1}",
  245. options.Profile.Name ?? "Unknown Profile",
  246. item.Path ?? "Unknown path");
  247. }
  248. return playMethods;
  249. }
  250. private int? GetDefaultSubtitleStreamIndex(MediaSourceInfo item, SubtitleProfile[] subtitleProfiles)
  251. {
  252. int highestScore = -1;
  253. foreach (MediaStream stream in item.MediaStreams)
  254. {
  255. if (stream.Type == MediaStreamType.Subtitle && stream.Score.HasValue)
  256. {
  257. if (stream.Score.Value > highestScore)
  258. {
  259. highestScore = stream.Score.Value;
  260. }
  261. }
  262. }
  263. List<MediaStream> topStreams = new List<MediaStream>();
  264. foreach (MediaStream stream in item.MediaStreams)
  265. {
  266. if (stream.Type == MediaStreamType.Subtitle && stream.Score.HasValue && stream.Score.Value == highestScore)
  267. {
  268. topStreams.Add(stream);
  269. }
  270. }
  271. // If multiple streams have an equal score, try to pick the most efficient one
  272. if (topStreams.Count > 1)
  273. {
  274. foreach (MediaStream stream in topStreams)
  275. {
  276. foreach (SubtitleProfile profile in subtitleProfiles)
  277. {
  278. if (profile.Method == SubtitleDeliveryMethod.External && StringHelper.EqualsIgnoreCase(profile.Format, stream.Codec))
  279. {
  280. return stream.Index;
  281. }
  282. }
  283. }
  284. }
  285. // If no optimization panned out, just use the original default
  286. return item.DefaultSubtitleStreamIndex;
  287. }
  288. private StreamInfo BuildVideoItem(MediaSourceInfo item, VideoOptions options)
  289. {
  290. StreamInfo playlistItem = new StreamInfo
  291. {
  292. ItemId = options.ItemId,
  293. MediaType = DlnaProfileType.Video,
  294. MediaSource = item,
  295. RunTimeTicks = item.RunTimeTicks,
  296. Context = options.Context,
  297. DeviceProfile = options.Profile
  298. };
  299. playlistItem.SubtitleStreamIndex = options.SubtitleStreamIndex ?? GetDefaultSubtitleStreamIndex(item, options.Profile.SubtitleProfiles);
  300. MediaStream subtitleStream = playlistItem.SubtitleStreamIndex.HasValue ? item.GetMediaStream(MediaStreamType.Subtitle, playlistItem.SubtitleStreamIndex.Value) : null;
  301. MediaStream audioStream = item.GetDefaultAudioStream(options.AudioStreamIndex ?? item.DefaultAudioStreamIndex);
  302. int? audioStreamIndex = null;
  303. if (audioStream != null)
  304. {
  305. audioStreamIndex = audioStream.Index;
  306. }
  307. MediaStream videoStream = item.VideoStream;
  308. // TODO: This doesn't accout for situation of device being able to handle media bitrate, but wifi connection not fast enough
  309. bool isEligibleForDirectPlay = IsEligibleForDirectPlay(item, GetBitrateForDirectPlayCheck(item, options), subtitleStream, options, PlayMethod.DirectPlay);
  310. bool isEligibleForDirectStream = IsEligibleForDirectPlay(item, options.GetMaxBitrate(), subtitleStream, options, PlayMethod.DirectStream);
  311. _logger.Info("Profile: {0}, Path: {1}, isEligibleForDirectPlay: {2}, isEligibleForDirectStream: {3}",
  312. options.Profile.Name ?? "Unknown Profile",
  313. item.Path ?? "Unknown path",
  314. isEligibleForDirectPlay,
  315. isEligibleForDirectStream);
  316. if (isEligibleForDirectPlay || isEligibleForDirectStream)
  317. {
  318. // See if it can be direct played
  319. PlayMethod? directPlay = GetVideoDirectPlayProfile(options.Profile, item, videoStream, audioStream, isEligibleForDirectPlay, isEligibleForDirectStream);
  320. if (directPlay != null)
  321. {
  322. playlistItem.PlayMethod = directPlay.Value;
  323. playlistItem.Container = item.Container;
  324. if (subtitleStream != null)
  325. {
  326. SubtitleProfile subtitleProfile = GetSubtitleProfile(subtitleStream, options.Profile.SubtitleProfiles, options.Context, directPlay.Value);
  327. playlistItem.SubtitleDeliveryMethod = subtitleProfile.Method;
  328. playlistItem.SubtitleFormat = subtitleProfile.Format;
  329. }
  330. return playlistItem;
  331. }
  332. }
  333. // Can't direct play, find the transcoding profile
  334. TranscodingProfile transcodingProfile = null;
  335. foreach (TranscodingProfile i in options.Profile.TranscodingProfiles)
  336. {
  337. if (i.Type == playlistItem.MediaType && i.Context == options.Context)
  338. {
  339. transcodingProfile = i;
  340. break;
  341. }
  342. }
  343. if (transcodingProfile != null)
  344. {
  345. if (!item.SupportsTranscoding)
  346. {
  347. return null;
  348. }
  349. if (subtitleStream != null)
  350. {
  351. SubtitleProfile subtitleProfile = GetSubtitleProfile(subtitleStream, options.Profile.SubtitleProfiles, options.Context, PlayMethod.Transcode);
  352. playlistItem.SubtitleDeliveryMethod = subtitleProfile.Method;
  353. playlistItem.SubtitleFormat = subtitleProfile.Format;
  354. }
  355. playlistItem.PlayMethod = PlayMethod.Transcode;
  356. playlistItem.Container = transcodingProfile.Container;
  357. playlistItem.EstimateContentLength = transcodingProfile.EstimateContentLength;
  358. playlistItem.TranscodeSeekInfo = transcodingProfile.TranscodeSeekInfo;
  359. playlistItem.AudioCodec = transcodingProfile.AudioCodec.Split(',')[0];
  360. playlistItem.VideoCodec = transcodingProfile.VideoCodec;
  361. playlistItem.CopyTimestamps = transcodingProfile.CopyTimestamps;
  362. playlistItem.SubProtocol = transcodingProfile.Protocol;
  363. playlistItem.AudioStreamIndex = audioStreamIndex;
  364. List<ProfileCondition> videoTranscodingConditions = new List<ProfileCondition>();
  365. foreach (CodecProfile i in options.Profile.CodecProfiles)
  366. {
  367. if (i.Type == CodecType.Video && i.ContainsCodec(transcodingProfile.VideoCodec, transcodingProfile.Container))
  368. {
  369. foreach (ProfileCondition c in i.Conditions)
  370. {
  371. videoTranscodingConditions.Add(c);
  372. }
  373. break;
  374. }
  375. }
  376. ApplyTranscodingConditions(playlistItem, videoTranscodingConditions);
  377. List<ProfileCondition> audioTranscodingConditions = new List<ProfileCondition>();
  378. foreach (CodecProfile i in options.Profile.CodecProfiles)
  379. {
  380. if (i.Type == CodecType.VideoAudio && i.ContainsCodec(playlistItem.AudioCodec, transcodingProfile.Container))
  381. {
  382. foreach (ProfileCondition c in i.Conditions)
  383. {
  384. audioTranscodingConditions.Add(c);
  385. }
  386. break;
  387. }
  388. }
  389. ApplyTranscodingConditions(playlistItem, audioTranscodingConditions);
  390. // Honor requested max channels
  391. if (options.MaxAudioChannels.HasValue)
  392. {
  393. int currentValue = playlistItem.MaxAudioChannels ?? options.MaxAudioChannels.Value;
  394. playlistItem.MaxAudioChannels = Math.Min(options.MaxAudioChannels.Value, currentValue);
  395. }
  396. int audioBitrate = GetAudioBitrate(options.GetMaxBitrate(), playlistItem.TargetAudioChannels, playlistItem.TargetAudioCodec, audioStream);
  397. playlistItem.AudioBitrate = Math.Min(playlistItem.AudioBitrate ?? audioBitrate, audioBitrate);
  398. int? maxBitrateSetting = options.GetMaxBitrate();
  399. // Honor max rate
  400. if (maxBitrateSetting.HasValue)
  401. {
  402. int videoBitrate = maxBitrateSetting.Value;
  403. if (playlistItem.AudioBitrate.HasValue)
  404. {
  405. videoBitrate -= playlistItem.AudioBitrate.Value;
  406. }
  407. // Make sure the video bitrate is lower than bitrate settings but at least 64k
  408. int currentValue = playlistItem.VideoBitrate ?? videoBitrate;
  409. playlistItem.VideoBitrate = Math.Max(Math.Min(videoBitrate, currentValue), 64000);
  410. }
  411. }
  412. return playlistItem;
  413. }
  414. private int GetAudioBitrate(int? maxTotalBitrate, int? targetAudioChannels, string targetAudioCodec, MediaStream audioStream)
  415. {
  416. var defaultBitrate = 128000;
  417. if (targetAudioChannels.HasValue)
  418. {
  419. if (targetAudioChannels.Value >= 5 && (maxTotalBitrate ?? 0) >= 2000000)
  420. {
  421. defaultBitrate = 320000;
  422. }
  423. }
  424. int encoderAudioBitrateLimit = int.MaxValue;
  425. if (audioStream != null)
  426. {
  427. // Seeing webm encoding failures when source has 1 audio channel and 22k bitrate.
  428. // Any attempts to transcode over 64k will fail
  429. if (audioStream.Channels.HasValue &&
  430. audioStream.Channels.Value == 1)
  431. {
  432. if ((audioStream.BitRate ?? 0) < 64000)
  433. {
  434. encoderAudioBitrateLimit = 64000;
  435. }
  436. }
  437. }
  438. return Math.Min(defaultBitrate, encoderAudioBitrateLimit);
  439. }
  440. private PlayMethod? GetVideoDirectPlayProfile(DeviceProfile profile,
  441. MediaSourceInfo mediaSource,
  442. MediaStream videoStream,
  443. MediaStream audioStream,
  444. bool isEligibleForDirectPlay,
  445. bool isEligibleForDirectStream)
  446. {
  447. if (videoStream == null)
  448. {
  449. _logger.Info("Profile: {0}, Cannot direct stream with no known video stream. Path: {1}",
  450. profile.Name ?? "Unknown Profile",
  451. mediaSource.Path ?? "Unknown path");
  452. return null;
  453. }
  454. // See if it can be direct played
  455. DirectPlayProfile directPlay = null;
  456. foreach (DirectPlayProfile i in profile.DirectPlayProfiles)
  457. {
  458. if (i.Type == DlnaProfileType.Video && IsVideoDirectPlaySupported(i, mediaSource, videoStream, audioStream))
  459. {
  460. directPlay = i;
  461. break;
  462. }
  463. }
  464. if (directPlay == null)
  465. {
  466. _logger.Info("Profile: {0}, No direct play profiles found for Path: {1}",
  467. profile.Name ?? "Unknown Profile",
  468. mediaSource.Path ?? "Unknown path");
  469. return null;
  470. }
  471. string container = mediaSource.Container;
  472. List<ProfileCondition> conditions = new List<ProfileCondition>();
  473. foreach (ContainerProfile i in profile.ContainerProfiles)
  474. {
  475. if (i.Type == DlnaProfileType.Video &&
  476. ListHelper.ContainsIgnoreCase(i.GetContainers(), container))
  477. {
  478. foreach (ProfileCondition c in i.Conditions)
  479. {
  480. conditions.Add(c);
  481. }
  482. }
  483. }
  484. ConditionProcessor conditionProcessor = new ConditionProcessor();
  485. int? width = videoStream == null ? null : videoStream.Width;
  486. int? height = videoStream == null ? null : videoStream.Height;
  487. int? bitDepth = videoStream == null ? null : videoStream.BitDepth;
  488. int? videoBitrate = videoStream == null ? null : videoStream.BitRate;
  489. double? videoLevel = videoStream == null ? null : videoStream.Level;
  490. string videoProfile = videoStream == null ? null : videoStream.Profile;
  491. float? videoFramerate = videoStream == null ? null : videoStream.AverageFrameRate ?? videoStream.AverageFrameRate;
  492. bool? isAnamorphic = videoStream == null ? null : videoStream.IsAnamorphic;
  493. bool? isCabac = videoStream == null ? null : videoStream.IsCabac;
  494. string videoCodecTag = videoStream == null ? null : videoStream.CodecTag;
  495. int? audioBitrate = audioStream == null ? null : audioStream.BitRate;
  496. int? audioChannels = audioStream == null ? null : audioStream.Channels;
  497. string audioProfile = audioStream == null ? null : audioStream.Profile;
  498. TransportStreamTimestamp? timestamp = videoStream == null ? TransportStreamTimestamp.None : mediaSource.Timestamp;
  499. int? packetLength = videoStream == null ? null : videoStream.PacketLength;
  500. int? refFrames = videoStream == null ? null : videoStream.RefFrames;
  501. int? numAudioStreams = mediaSource.GetStreamCount(MediaStreamType.Audio);
  502. int? numVideoStreams = mediaSource.GetStreamCount(MediaStreamType.Video);
  503. // Check container conditions
  504. foreach (ProfileCondition i in conditions)
  505. {
  506. if (!conditionProcessor.IsVideoConditionSatisfied(i, width, height, bitDepth, videoBitrate, videoProfile, videoLevel, videoFramerate, packetLength, timestamp, isAnamorphic, isCabac, refFrames, numVideoStreams, numAudioStreams, videoCodecTag))
  507. {
  508. LogConditionFailure(profile, "VideoContainerProfile", i, mediaSource);
  509. return null;
  510. }
  511. }
  512. string videoCodec = videoStream == null ? null : videoStream.Codec;
  513. if (string.IsNullOrEmpty(videoCodec))
  514. {
  515. _logger.Info("Profile: {0}, DirectPlay=false. Reason=Unknown video codec. Path: {1}",
  516. profile.Name ?? "Unknown Profile",
  517. mediaSource.Path ?? "Unknown path");
  518. return null;
  519. }
  520. conditions = new List<ProfileCondition>();
  521. foreach (CodecProfile i in profile.CodecProfiles)
  522. {
  523. if (i.Type == CodecType.Video && i.ContainsCodec(videoCodec, container))
  524. {
  525. foreach (ProfileCondition c in i.Conditions)
  526. {
  527. conditions.Add(c);
  528. }
  529. }
  530. }
  531. foreach (ProfileCondition i in conditions)
  532. {
  533. if (!conditionProcessor.IsVideoConditionSatisfied(i, width, height, bitDepth, videoBitrate, videoProfile, videoLevel, videoFramerate, packetLength, timestamp, isAnamorphic, isCabac, refFrames, numVideoStreams, numAudioStreams, videoCodecTag))
  534. {
  535. LogConditionFailure(profile, "VideoCodecProfile", i, mediaSource);
  536. return null;
  537. }
  538. }
  539. if (audioStream != null)
  540. {
  541. string audioCodec = audioStream.Codec;
  542. if (string.IsNullOrEmpty(audioCodec))
  543. {
  544. _logger.Info("Profile: {0}, DirectPlay=false. Reason=Unknown audio codec. Path: {1}",
  545. profile.Name ?? "Unknown Profile",
  546. mediaSource.Path ?? "Unknown path");
  547. return null;
  548. }
  549. conditions = new List<ProfileCondition>();
  550. foreach (CodecProfile i in profile.CodecProfiles)
  551. {
  552. if (i.Type == CodecType.VideoAudio && i.ContainsCodec(audioCodec, container))
  553. {
  554. foreach (ProfileCondition c in i.Conditions)
  555. {
  556. conditions.Add(c);
  557. }
  558. }
  559. }
  560. foreach (ProfileCondition i in conditions)
  561. {
  562. bool? isSecondaryAudio = audioStream == null ? null : mediaSource.IsSecondaryAudio(audioStream);
  563. if (!conditionProcessor.IsVideoAudioConditionSatisfied(i, audioChannels, audioBitrate, audioProfile, isSecondaryAudio))
  564. {
  565. LogConditionFailure(profile, "VideoAudioCodecProfile", i, mediaSource);
  566. return null;
  567. }
  568. }
  569. }
  570. if (isEligibleForDirectPlay && mediaSource.SupportsDirectPlay)
  571. {
  572. if (mediaSource.Protocol == MediaProtocol.Http)
  573. {
  574. if (_localPlayer.CanAccessUrl(mediaSource.Path, mediaSource.RequiredHttpHeaders.Count > 0))
  575. {
  576. return PlayMethod.DirectPlay;
  577. }
  578. }
  579. else if (mediaSource.Protocol == MediaProtocol.File)
  580. {
  581. if (_localPlayer.CanAccessFile(mediaSource.Path))
  582. {
  583. return PlayMethod.DirectPlay;
  584. }
  585. }
  586. }
  587. if (isEligibleForDirectStream && mediaSource.SupportsDirectStream)
  588. {
  589. return PlayMethod.DirectStream;
  590. }
  591. return null;
  592. }
  593. private void LogConditionFailure(DeviceProfile profile, string type, ProfileCondition condition, MediaSourceInfo mediaSource)
  594. {
  595. _logger.Info("Profile: {0}, DirectPlay=false. Reason={1}.{2} Condition: {3}. ConditionValue: {4}. IsRequired: {5}. Path: {6}",
  596. type,
  597. profile.Name ?? "Unknown Profile",
  598. condition.Property,
  599. condition.Condition,
  600. condition.Value ?? string.Empty,
  601. condition.IsRequired,
  602. mediaSource.Path ?? "Unknown path");
  603. }
  604. private bool IsEligibleForDirectPlay(MediaSourceInfo item,
  605. int? maxBitrate,
  606. MediaStream subtitleStream,
  607. VideoOptions options,
  608. PlayMethod playMethod)
  609. {
  610. if (subtitleStream != null)
  611. {
  612. SubtitleProfile subtitleProfile = GetSubtitleProfile(subtitleStream, options.Profile.SubtitleProfiles, options.Context, playMethod);
  613. if (subtitleProfile.Method != SubtitleDeliveryMethod.External && subtitleProfile.Method != SubtitleDeliveryMethod.Embed)
  614. {
  615. _logger.Info("Not eligible for {0} due to unsupported subtitles", playMethod);
  616. return false;
  617. }
  618. }
  619. return IsAudioEligibleForDirectPlay(item, maxBitrate);
  620. }
  621. public static SubtitleProfile GetSubtitleProfile(MediaStream subtitleStream, SubtitleProfile[] subtitleProfiles, EncodingContext context, PlayMethod playMethod)
  622. {
  623. if (playMethod != PlayMethod.Transcode && !subtitleStream.IsExternal)
  624. {
  625. // Look for supported embedded subs
  626. foreach (SubtitleProfile profile in subtitleProfiles)
  627. {
  628. if (!profile.SupportsLanguage(subtitleStream.Language))
  629. {
  630. continue;
  631. }
  632. if (profile.Method != SubtitleDeliveryMethod.Embed)
  633. {
  634. continue;
  635. }
  636. if (subtitleStream.IsTextSubtitleStream == MediaStream.IsTextFormat(profile.Format) && StringHelper.EqualsIgnoreCase(profile.Format, subtitleStream.Codec))
  637. {
  638. return profile;
  639. }
  640. }
  641. }
  642. // Look for an external profile that matches the stream type (text/graphical)
  643. foreach (SubtitleProfile profile in subtitleProfiles)
  644. {
  645. if (profile.Method != SubtitleDeliveryMethod.External && profile.Method != SubtitleDeliveryMethod.Hls)
  646. {
  647. continue;
  648. }
  649. if (!profile.SupportsLanguage(subtitleStream.Language))
  650. {
  651. continue;
  652. }
  653. if ((profile.Method == SubtitleDeliveryMethod.External && subtitleStream.IsTextSubtitleStream == MediaStream.IsTextFormat(profile.Format)) ||
  654. (profile.Method == SubtitleDeliveryMethod.Hls && subtitleStream.IsTextSubtitleStream))
  655. {
  656. bool requiresConversion = !StringHelper.EqualsIgnoreCase(subtitleStream.Codec, profile.Format);
  657. if (subtitleStream.IsTextSubtitleStream || !requiresConversion)
  658. {
  659. if (subtitleStream.SupportsExternalStream)
  660. {
  661. return profile;
  662. }
  663. // For sync we can handle the longer extraction times
  664. if (context == EncodingContext.Static && subtitleStream.IsTextSubtitleStream)
  665. {
  666. return profile;
  667. }
  668. }
  669. }
  670. }
  671. return new SubtitleProfile
  672. {
  673. Method = SubtitleDeliveryMethod.Encode,
  674. Format = subtitleStream.Codec
  675. };
  676. }
  677. private bool IsAudioEligibleForDirectPlay(MediaSourceInfo item, int? maxBitrate)
  678. {
  679. if (!maxBitrate.HasValue || (item.Bitrate.HasValue && item.Bitrate.Value <= maxBitrate.Value))
  680. {
  681. return true;
  682. }
  683. _logger.Info("Bitrate exceeds DirectPlay limit");
  684. return false;
  685. }
  686. private void ValidateInput(VideoOptions options)
  687. {
  688. ValidateAudioInput(options);
  689. if (options.AudioStreamIndex.HasValue && string.IsNullOrEmpty(options.MediaSourceId))
  690. {
  691. throw new ArgumentException("MediaSourceId is required when a specific audio stream is requested");
  692. }
  693. if (options.SubtitleStreamIndex.HasValue && string.IsNullOrEmpty(options.MediaSourceId))
  694. {
  695. throw new ArgumentException("MediaSourceId is required when a specific subtitle stream is requested");
  696. }
  697. }
  698. private void ValidateAudioInput(AudioOptions options)
  699. {
  700. if (string.IsNullOrEmpty(options.ItemId))
  701. {
  702. throw new ArgumentException("ItemId is required");
  703. }
  704. if (string.IsNullOrEmpty(options.DeviceId))
  705. {
  706. throw new ArgumentException("DeviceId is required");
  707. }
  708. if (options.Profile == null)
  709. {
  710. throw new ArgumentException("Profile is required");
  711. }
  712. if (options.MediaSources == null)
  713. {
  714. throw new ArgumentException("MediaSources is required");
  715. }
  716. }
  717. private void ApplyTranscodingConditions(StreamInfo item, IEnumerable<ProfileCondition> conditions)
  718. {
  719. foreach (ProfileCondition condition in conditions)
  720. {
  721. string value = condition.Value;
  722. if (string.IsNullOrEmpty(value))
  723. {
  724. continue;
  725. }
  726. // No way to express this
  727. if (condition.Condition == ProfileConditionType.GreaterThanEqual)
  728. {
  729. continue;
  730. }
  731. switch (condition.Property)
  732. {
  733. case ProfileConditionValue.AudioBitrate:
  734. {
  735. int num;
  736. if (IntHelper.TryParseCultureInvariant(value, out num))
  737. {
  738. item.AudioBitrate = num;
  739. }
  740. break;
  741. }
  742. case ProfileConditionValue.AudioChannels:
  743. {
  744. int num;
  745. if (IntHelper.TryParseCultureInvariant(value, out num))
  746. {
  747. item.MaxAudioChannels = num;
  748. }
  749. break;
  750. }
  751. case ProfileConditionValue.IsCabac:
  752. {
  753. bool val;
  754. if (BoolHelper.TryParseCultureInvariant(value, out val))
  755. {
  756. if (condition.Condition == ProfileConditionType.Equals)
  757. {
  758. item.Cabac = val;
  759. }
  760. else if (condition.Condition == ProfileConditionType.NotEquals)
  761. {
  762. item.Cabac = !val;
  763. }
  764. }
  765. break;
  766. }
  767. case ProfileConditionValue.IsAnamorphic:
  768. case ProfileConditionValue.AudioProfile:
  769. case ProfileConditionValue.Has64BitOffsets:
  770. case ProfileConditionValue.PacketLength:
  771. case ProfileConditionValue.NumAudioStreams:
  772. case ProfileConditionValue.NumVideoStreams:
  773. case ProfileConditionValue.IsSecondaryAudio:
  774. case ProfileConditionValue.VideoTimestamp:
  775. {
  776. // Not supported yet
  777. break;
  778. }
  779. case ProfileConditionValue.RefFrames:
  780. {
  781. int num;
  782. if (IntHelper.TryParseCultureInvariant(value, out num))
  783. {
  784. item.MaxRefFrames = num;
  785. }
  786. break;
  787. }
  788. case ProfileConditionValue.VideoBitDepth:
  789. {
  790. int num;
  791. if (IntHelper.TryParseCultureInvariant(value, out num))
  792. {
  793. item.MaxVideoBitDepth = num;
  794. }
  795. break;
  796. }
  797. case ProfileConditionValue.VideoProfile:
  798. {
  799. item.VideoProfile = (value ?? string.Empty).Split('|')[0];
  800. break;
  801. }
  802. case ProfileConditionValue.Height:
  803. {
  804. int num;
  805. if (IntHelper.TryParseCultureInvariant(value, out num))
  806. {
  807. item.MaxHeight = num;
  808. }
  809. break;
  810. }
  811. case ProfileConditionValue.VideoBitrate:
  812. {
  813. int num;
  814. if (IntHelper.TryParseCultureInvariant(value, out num))
  815. {
  816. item.VideoBitrate = num;
  817. }
  818. break;
  819. }
  820. case ProfileConditionValue.VideoFramerate:
  821. {
  822. float num;
  823. if (FloatHelper.TryParseCultureInvariant(value, out num))
  824. {
  825. item.MaxFramerate = num;
  826. }
  827. break;
  828. }
  829. case ProfileConditionValue.VideoLevel:
  830. {
  831. int num;
  832. if (IntHelper.TryParseCultureInvariant(value, out num))
  833. {
  834. item.VideoLevel = num;
  835. }
  836. break;
  837. }
  838. case ProfileConditionValue.Width:
  839. {
  840. int num;
  841. if (IntHelper.TryParseCultureInvariant(value, out num))
  842. {
  843. item.MaxWidth = num;
  844. }
  845. break;
  846. }
  847. }
  848. }
  849. }
  850. private bool IsAudioDirectPlaySupported(DirectPlayProfile profile, MediaSourceInfo item, MediaStream audioStream)
  851. {
  852. if (profile.Container.Length > 0)
  853. {
  854. // Check container type
  855. string mediaContainer = item.Container ?? string.Empty;
  856. bool any = false;
  857. foreach (string i in profile.GetContainers())
  858. {
  859. if (StringHelper.EqualsIgnoreCase(i, mediaContainer))
  860. {
  861. any = true;
  862. break;
  863. }
  864. }
  865. if (!any)
  866. {
  867. return false;
  868. }
  869. }
  870. return true;
  871. }
  872. private bool IsVideoDirectPlaySupported(DirectPlayProfile profile, MediaSourceInfo item, MediaStream videoStream, MediaStream audioStream)
  873. {
  874. if (profile.Container.Length > 0)
  875. {
  876. // Check container type
  877. string mediaContainer = item.Container ?? string.Empty;
  878. bool any = false;
  879. foreach (string i in profile.GetContainers())
  880. {
  881. if (StringHelper.EqualsIgnoreCase(i, mediaContainer))
  882. {
  883. any = true;
  884. break;
  885. }
  886. }
  887. if (!any)
  888. {
  889. return false;
  890. }
  891. }
  892. // Check video codec
  893. List<string> videoCodecs = profile.GetVideoCodecs();
  894. if (videoCodecs.Count > 0)
  895. {
  896. string videoCodec = videoStream == null ? null : videoStream.Codec;
  897. if (string.IsNullOrEmpty(videoCodec) || !ListHelper.ContainsIgnoreCase(videoCodecs, videoCodec))
  898. {
  899. return false;
  900. }
  901. }
  902. List<string> audioCodecs = profile.GetAudioCodecs();
  903. if (audioCodecs.Count > 0)
  904. {
  905. // Check audio codecs
  906. string audioCodec = audioStream == null ? null : audioStream.Codec;
  907. if (string.IsNullOrEmpty(audioCodec) || !ListHelper.ContainsIgnoreCase(audioCodecs, audioCodec))
  908. {
  909. return false;
  910. }
  911. }
  912. return true;
  913. }
  914. }
  915. }