StreamingHelpers.cs 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Globalization;
  4. using System.IO;
  5. using System.Linq;
  6. using System.Threading;
  7. using System.Threading.Tasks;
  8. using Jellyfin.Api.Extensions;
  9. using Jellyfin.Api.Models.StreamingDtos;
  10. using Jellyfin.Data.Enums;
  11. using Jellyfin.Extensions;
  12. using MediaBrowser.Common.Configuration;
  13. using MediaBrowser.Common.Extensions;
  14. using MediaBrowser.Controller.Configuration;
  15. using MediaBrowser.Controller.Devices;
  16. using MediaBrowser.Controller.Dlna;
  17. using MediaBrowser.Controller.Library;
  18. using MediaBrowser.Controller.MediaEncoding;
  19. using MediaBrowser.Model.Dlna;
  20. using MediaBrowser.Model.Dto;
  21. using MediaBrowser.Model.Entities;
  22. using Microsoft.AspNetCore.Http;
  23. using Microsoft.Extensions.Primitives;
  24. using Microsoft.Net.Http.Headers;
  25. namespace Jellyfin.Api.Helpers;
  26. /// <summary>
  27. /// The streaming helpers.
  28. /// </summary>
  29. public static class StreamingHelpers
  30. {
  31. /// <summary>
  32. /// Gets the current streaming state.
  33. /// </summary>
  34. /// <param name="streamingRequest">The <see cref="StreamingRequestDto"/>.</param>
  35. /// <param name="httpContext">The <see cref="HttpContext"/>.</param>
  36. /// <param name="mediaSourceManager">Instance of the <see cref="IMediaSourceManager"/> interface.</param>
  37. /// <param name="userManager">Instance of the <see cref="IUserManager"/> interface.</param>
  38. /// <param name="libraryManager">Instance of the <see cref="ILibraryManager"/> interface.</param>
  39. /// <param name="serverConfigurationManager">Instance of the <see cref="IServerConfigurationManager"/> interface.</param>
  40. /// <param name="mediaEncoder">Instance of the <see cref="IMediaEncoder"/> interface.</param>
  41. /// <param name="encodingHelper">Instance of <see cref="EncodingHelper"/>.</param>
  42. /// <param name="dlnaManager">Instance of the <see cref="IDlnaManager"/> interface.</param>
  43. /// <param name="deviceManager">Instance of the <see cref="IDeviceManager"/> interface.</param>
  44. /// <param name="transcodingJobHelper">Initialized <see cref="TranscodingJobHelper"/>.</param>
  45. /// <param name="transcodingJobType">The <see cref="TranscodingJobType"/>.</param>
  46. /// <param name="cancellationToken">The <see cref="CancellationToken"/>.</param>
  47. /// <returns>A <see cref="Task"/> containing the current <see cref="StreamState"/>.</returns>
  48. public static async Task<StreamState> GetStreamingState(
  49. StreamingRequestDto streamingRequest,
  50. HttpContext httpContext,
  51. IMediaSourceManager mediaSourceManager,
  52. IUserManager userManager,
  53. ILibraryManager libraryManager,
  54. IServerConfigurationManager serverConfigurationManager,
  55. IMediaEncoder mediaEncoder,
  56. EncodingHelper encodingHelper,
  57. IDlnaManager dlnaManager,
  58. IDeviceManager deviceManager,
  59. TranscodingJobHelper transcodingJobHelper,
  60. TranscodingJobType transcodingJobType,
  61. CancellationToken cancellationToken)
  62. {
  63. var httpRequest = httpContext.Request;
  64. // Parse the DLNA time seek header
  65. if (!streamingRequest.StartTimeTicks.HasValue)
  66. {
  67. var timeSeek = httpRequest.Headers["TimeSeekRange.dlna.org"];
  68. streamingRequest.StartTimeTicks = ParseTimeSeekHeader(timeSeek.ToString());
  69. }
  70. if (!string.IsNullOrWhiteSpace(streamingRequest.Params))
  71. {
  72. ParseParams(streamingRequest);
  73. }
  74. streamingRequest.StreamOptions = ParseStreamOptions(httpRequest.Query);
  75. if (httpRequest.Path.Value is null)
  76. {
  77. throw new ResourceNotFoundException(nameof(httpRequest.Path));
  78. }
  79. var url = httpRequest.Path.Value.AsSpan().RightPart('.').ToString();
  80. if (string.IsNullOrEmpty(streamingRequest.AudioCodec))
  81. {
  82. streamingRequest.AudioCodec = encodingHelper.InferAudioCodec(url);
  83. }
  84. var enableDlnaHeaders = !string.IsNullOrWhiteSpace(streamingRequest.Params) ||
  85. streamingRequest.StreamOptions.ContainsKey("dlnaheaders") ||
  86. string.Equals(httpRequest.Headers["GetContentFeatures.DLNA.ORG"], "1", StringComparison.OrdinalIgnoreCase);
  87. var state = new StreamState(mediaSourceManager, transcodingJobType, transcodingJobHelper)
  88. {
  89. Request = streamingRequest,
  90. RequestedUrl = url,
  91. UserAgent = httpRequest.Headers[HeaderNames.UserAgent],
  92. EnableDlnaHeaders = enableDlnaHeaders
  93. };
  94. var userId = httpContext.User.GetUserId();
  95. if (!userId.Equals(default))
  96. {
  97. state.User = userManager.GetUserById(userId);
  98. }
  99. if (state.IsVideoRequest && !string.IsNullOrWhiteSpace(state.Request.VideoCodec))
  100. {
  101. state.SupportedVideoCodecs = state.Request.VideoCodec.Split(',', StringSplitOptions.RemoveEmptyEntries);
  102. state.Request.VideoCodec = state.SupportedVideoCodecs.FirstOrDefault();
  103. }
  104. if (!string.IsNullOrWhiteSpace(streamingRequest.AudioCodec))
  105. {
  106. state.SupportedAudioCodecs = streamingRequest.AudioCodec.Split(',', StringSplitOptions.RemoveEmptyEntries);
  107. state.Request.AudioCodec = state.SupportedAudioCodecs.FirstOrDefault(mediaEncoder.CanEncodeToAudioCodec)
  108. ?? state.SupportedAudioCodecs.FirstOrDefault();
  109. }
  110. if (!string.IsNullOrWhiteSpace(streamingRequest.SubtitleCodec))
  111. {
  112. state.SupportedSubtitleCodecs = streamingRequest.SubtitleCodec.Split(',', StringSplitOptions.RemoveEmptyEntries);
  113. state.Request.SubtitleCodec = state.SupportedSubtitleCodecs.FirstOrDefault(mediaEncoder.CanEncodeToSubtitleCodec)
  114. ?? state.SupportedSubtitleCodecs.FirstOrDefault();
  115. }
  116. var item = libraryManager.GetItemById(streamingRequest.Id);
  117. state.IsInputVideo = item.MediaType == MediaType.Video;
  118. MediaSourceInfo? mediaSource = null;
  119. if (string.IsNullOrWhiteSpace(streamingRequest.LiveStreamId))
  120. {
  121. var currentJob = !string.IsNullOrWhiteSpace(streamingRequest.PlaySessionId)
  122. ? transcodingJobHelper.GetTranscodingJob(streamingRequest.PlaySessionId)
  123. : null;
  124. if (currentJob is not null)
  125. {
  126. mediaSource = currentJob.MediaSource;
  127. }
  128. if (mediaSource is null)
  129. {
  130. var mediaSources = await mediaSourceManager.GetPlaybackMediaSources(libraryManager.GetItemById(streamingRequest.Id), null, false, false, cancellationToken).ConfigureAwait(false);
  131. mediaSource = string.IsNullOrEmpty(streamingRequest.MediaSourceId)
  132. ? mediaSources[0]
  133. : mediaSources.Find(i => string.Equals(i.Id, streamingRequest.MediaSourceId, StringComparison.Ordinal));
  134. if (mediaSource is null && Guid.Parse(streamingRequest.MediaSourceId).Equals(streamingRequest.Id))
  135. {
  136. mediaSource = mediaSources[0];
  137. }
  138. }
  139. }
  140. else
  141. {
  142. var liveStreamInfo = await mediaSourceManager.GetLiveStreamWithDirectStreamProvider(streamingRequest.LiveStreamId, cancellationToken).ConfigureAwait(false);
  143. mediaSource = liveStreamInfo.Item1;
  144. state.DirectStreamProvider = liveStreamInfo.Item2;
  145. }
  146. var encodingOptions = serverConfigurationManager.GetEncodingOptions();
  147. encodingHelper.AttachMediaSourceInfo(state, encodingOptions, mediaSource, url);
  148. string? containerInternal = Path.GetExtension(state.RequestedUrl);
  149. if (!string.IsNullOrEmpty(streamingRequest.Container))
  150. {
  151. containerInternal = streamingRequest.Container;
  152. }
  153. if (string.IsNullOrEmpty(containerInternal))
  154. {
  155. containerInternal = streamingRequest.Static ?
  156. StreamBuilder.NormalizeMediaSourceFormatIntoSingleContainer(state.InputContainer, null, DlnaProfileType.Audio)
  157. : GetOutputFileExtension(state, mediaSource);
  158. }
  159. var outputAudioCodec = streamingRequest.AudioCodec;
  160. if (EncodingHelper.LosslessAudioCodecs.Contains(outputAudioCodec))
  161. {
  162. state.OutputAudioBitrate = state.AudioStream.BitRate ?? 0;
  163. }
  164. else
  165. {
  166. state.OutputAudioBitrate = encodingHelper.GetAudioBitrateParam(streamingRequest.AudioBitRate, streamingRequest.AudioCodec, state.AudioStream, state.OutputAudioChannels) ?? 0;
  167. }
  168. if (outputAudioCodec.StartsWith("pcm_", StringComparison.Ordinal))
  169. {
  170. containerInternal = ".pcm";
  171. }
  172. state.OutputAudioCodec = outputAudioCodec;
  173. state.OutputContainer = (containerInternal ?? string.Empty).TrimStart('.');
  174. state.OutputAudioChannels = encodingHelper.GetNumAudioChannelsParam(state, state.AudioStream, state.OutputAudioCodec);
  175. if (state.VideoRequest is not null)
  176. {
  177. state.OutputVideoCodec = state.Request.VideoCodec;
  178. state.OutputVideoBitrate = encodingHelper.GetVideoBitrateParamValue(state.VideoRequest, state.VideoStream, state.OutputVideoCodec);
  179. encodingHelper.TryStreamCopy(state);
  180. if (!EncodingHelper.IsCopyCodec(state.OutputVideoCodec) && state.OutputVideoBitrate.HasValue)
  181. {
  182. var isVideoResolutionNotRequested = !state.VideoRequest.Width.HasValue
  183. && !state.VideoRequest.Height.HasValue
  184. && !state.VideoRequest.MaxWidth.HasValue
  185. && !state.VideoRequest.MaxHeight.HasValue;
  186. if (isVideoResolutionNotRequested
  187. && state.VideoStream is not null
  188. && state.VideoRequest.VideoBitRate.HasValue
  189. && state.VideoStream.BitRate.HasValue
  190. && state.VideoRequest.VideoBitRate.Value >= state.VideoStream.BitRate.Value)
  191. {
  192. // Don't downscale the resolution if the width/height/MaxWidth/MaxHeight is not requested,
  193. // and the requested video bitrate is higher than source video bitrate.
  194. if (state.VideoStream.Width.HasValue || state.VideoStream.Height.HasValue)
  195. {
  196. state.VideoRequest.MaxWidth = state.VideoStream?.Width;
  197. state.VideoRequest.MaxHeight = state.VideoStream?.Height;
  198. }
  199. }
  200. else
  201. {
  202. var resolution = ResolutionNormalizer.Normalize(
  203. state.VideoStream?.BitRate,
  204. state.OutputVideoBitrate.Value,
  205. state.VideoRequest.MaxWidth,
  206. state.VideoRequest.MaxHeight);
  207. state.VideoRequest.MaxWidth = resolution.MaxWidth;
  208. state.VideoRequest.MaxHeight = resolution.MaxHeight;
  209. }
  210. }
  211. }
  212. ApplyDeviceProfileSettings(state, dlnaManager, deviceManager, httpRequest, streamingRequest.DeviceProfileId, streamingRequest.Static);
  213. var ext = string.IsNullOrWhiteSpace(state.OutputContainer)
  214. ? GetOutputFileExtension(state, mediaSource)
  215. : ("." + state.OutputContainer);
  216. state.OutputFilePath = GetOutputFilePath(state, ext, serverConfigurationManager, streamingRequest.DeviceId, streamingRequest.PlaySessionId);
  217. return state;
  218. }
  219. /// <summary>
  220. /// Adds the dlna headers.
  221. /// </summary>
  222. /// <param name="state">The state.</param>
  223. /// <param name="responseHeaders">The response headers.</param>
  224. /// <param name="isStaticallyStreamed">if set to <c>true</c> [is statically streamed].</param>
  225. /// <param name="startTimeTicks">The start time in ticks.</param>
  226. /// <param name="request">The <see cref="HttpRequest"/>.</param>
  227. /// <param name="dlnaManager">Instance of the <see cref="IDlnaManager"/> interface.</param>
  228. public static void AddDlnaHeaders(
  229. StreamState state,
  230. IHeaderDictionary responseHeaders,
  231. bool isStaticallyStreamed,
  232. long? startTimeTicks,
  233. HttpRequest request,
  234. IDlnaManager dlnaManager)
  235. {
  236. if (!state.EnableDlnaHeaders)
  237. {
  238. return;
  239. }
  240. var profile = state.DeviceProfile;
  241. StringValues transferMode = request.Headers["transferMode.dlna.org"];
  242. responseHeaders.Append("transferMode.dlna.org", string.IsNullOrEmpty(transferMode) ? "Streaming" : transferMode.ToString());
  243. responseHeaders.Append("realTimeInfo.dlna.org", "DLNA.ORG_TLAG=*");
  244. if (state.RunTimeTicks.HasValue)
  245. {
  246. if (string.Equals(request.Headers["getMediaInfo.sec"], "1", StringComparison.OrdinalIgnoreCase))
  247. {
  248. var ms = TimeSpan.FromTicks(state.RunTimeTicks.Value).TotalMilliseconds;
  249. responseHeaders.Append("MediaInfo.sec", string.Format(
  250. CultureInfo.InvariantCulture,
  251. "SEC_Duration={0};",
  252. Convert.ToInt32(ms)));
  253. }
  254. if (!isStaticallyStreamed && profile is not null)
  255. {
  256. AddTimeSeekResponseHeaders(state, responseHeaders, startTimeTicks);
  257. }
  258. }
  259. profile ??= dlnaManager.GetDefaultProfile();
  260. var audioCodec = state.ActualOutputAudioCodec;
  261. if (!state.IsVideoRequest)
  262. {
  263. responseHeaders.Append("contentFeatures.dlna.org", ContentFeatureBuilder.BuildAudioHeader(
  264. profile,
  265. state.OutputContainer,
  266. audioCodec,
  267. state.OutputAudioBitrate,
  268. state.OutputAudioSampleRate,
  269. state.OutputAudioChannels,
  270. state.OutputAudioBitDepth,
  271. isStaticallyStreamed,
  272. state.RunTimeTicks,
  273. state.TranscodeSeekInfo));
  274. }
  275. else
  276. {
  277. var videoCodec = state.ActualOutputVideoCodec;
  278. responseHeaders.Append(
  279. "contentFeatures.dlna.org",
  280. ContentFeatureBuilder.BuildVideoHeader(profile, state.OutputContainer, videoCodec, audioCodec, state.OutputWidth, state.OutputHeight, state.TargetVideoBitDepth, state.OutputVideoBitrate, state.TargetTimestamp, isStaticallyStreamed, state.RunTimeTicks, state.TargetVideoProfile, state.TargetVideoRangeType, state.TargetVideoLevel, state.TargetFramerate, state.TargetPacketLength, state.TranscodeSeekInfo, state.IsTargetAnamorphic, state.IsTargetInterlaced, state.TargetRefFrames, state.TargetVideoStreamCount, state.TargetAudioStreamCount, state.TargetVideoCodecTag, state.IsTargetAVC).FirstOrDefault() ?? string.Empty);
  281. }
  282. }
  283. /// <summary>
  284. /// Parses the time seek header.
  285. /// </summary>
  286. /// <param name="value">The time seek header string.</param>
  287. /// <returns>A nullable <see cref="long"/> representing the seek time in ticks.</returns>
  288. private static long? ParseTimeSeekHeader(ReadOnlySpan<char> value)
  289. {
  290. if (value.IsEmpty)
  291. {
  292. return null;
  293. }
  294. const string npt = "npt=";
  295. if (!value.StartsWith(npt, StringComparison.OrdinalIgnoreCase))
  296. {
  297. throw new ArgumentException("Invalid timeseek header");
  298. }
  299. var index = value.IndexOf('-');
  300. value = index == -1
  301. ? value.Slice(npt.Length)
  302. : value.Slice(npt.Length, index - npt.Length);
  303. if (!value.Contains(':'))
  304. {
  305. // Parses npt times in the format of '417.33'
  306. if (double.TryParse(value, CultureInfo.InvariantCulture, out var seconds))
  307. {
  308. return TimeSpan.FromSeconds(seconds).Ticks;
  309. }
  310. throw new ArgumentException("Invalid timeseek header");
  311. }
  312. try
  313. {
  314. // Parses npt times in the format of '10:19:25.7'
  315. return TimeSpan.Parse(value, CultureInfo.InvariantCulture).Ticks;
  316. }
  317. catch
  318. {
  319. throw new ArgumentException("Invalid timeseek header");
  320. }
  321. }
  322. /// <summary>
  323. /// Parses query parameters as StreamOptions.
  324. /// </summary>
  325. /// <param name="queryString">The query string.</param>
  326. /// <returns>A <see cref="Dictionary{String,String}"/> containing the stream options.</returns>
  327. private static Dictionary<string, string?> ParseStreamOptions(IQueryCollection queryString)
  328. {
  329. Dictionary<string, string?> streamOptions = new Dictionary<string, string?>();
  330. foreach (var param in queryString)
  331. {
  332. if (char.IsLower(param.Key[0]))
  333. {
  334. // This was probably not parsed initially and should be a StreamOptions
  335. // or the generated URL should correctly serialize it
  336. // TODO: This should be incorporated either in the lower framework for parsing requests
  337. streamOptions[param.Key] = param.Value;
  338. }
  339. }
  340. return streamOptions;
  341. }
  342. /// <summary>
  343. /// Adds the dlna time seek headers to the response.
  344. /// </summary>
  345. /// <param name="state">The current <see cref="StreamState"/>.</param>
  346. /// <param name="responseHeaders">The <see cref="IHeaderDictionary"/> of the response.</param>
  347. /// <param name="startTimeTicks">The start time in ticks.</param>
  348. private static void AddTimeSeekResponseHeaders(StreamState state, IHeaderDictionary responseHeaders, long? startTimeTicks)
  349. {
  350. var runtimeSeconds = TimeSpan.FromTicks(state.RunTimeTicks!.Value).TotalSeconds.ToString(CultureInfo.InvariantCulture);
  351. var startSeconds = TimeSpan.FromTicks(startTimeTicks ?? 0).TotalSeconds.ToString(CultureInfo.InvariantCulture);
  352. responseHeaders.Append("TimeSeekRange.dlna.org", string.Format(
  353. CultureInfo.InvariantCulture,
  354. "npt={0}-{1}/{1}",
  355. startSeconds,
  356. runtimeSeconds));
  357. responseHeaders.Append("X-AvailableSeekRange", string.Format(
  358. CultureInfo.InvariantCulture,
  359. "1 npt={0}-{1}",
  360. startSeconds,
  361. runtimeSeconds));
  362. }
  363. /// <summary>
  364. /// Gets the output file extension.
  365. /// </summary>
  366. /// <param name="state">The state.</param>
  367. /// <param name="mediaSource">The mediaSource.</param>
  368. /// <returns>System.String.</returns>
  369. private static string GetOutputFileExtension(StreamState state, MediaSourceInfo? mediaSource)
  370. {
  371. var ext = Path.GetExtension(state.RequestedUrl);
  372. if (!string.IsNullOrEmpty(ext))
  373. {
  374. return ext;
  375. }
  376. // Try to infer based on the desired video codec
  377. if (state.IsVideoRequest)
  378. {
  379. var videoCodec = state.Request.VideoCodec;
  380. if (string.Equals(videoCodec, "h264", StringComparison.OrdinalIgnoreCase))
  381. {
  382. return ".ts";
  383. }
  384. if (string.Equals(videoCodec, "hevc", StringComparison.OrdinalIgnoreCase)
  385. || string.Equals(videoCodec, "av1", StringComparison.OrdinalIgnoreCase))
  386. {
  387. return ".mp4";
  388. }
  389. if (string.Equals(videoCodec, "theora", StringComparison.OrdinalIgnoreCase))
  390. {
  391. return ".ogv";
  392. }
  393. if (string.Equals(videoCodec, "vp8", StringComparison.OrdinalIgnoreCase)
  394. || string.Equals(videoCodec, "vp9", StringComparison.OrdinalIgnoreCase)
  395. || string.Equals(videoCodec, "vpx", StringComparison.OrdinalIgnoreCase))
  396. {
  397. return ".webm";
  398. }
  399. if (string.Equals(videoCodec, "wmv", StringComparison.OrdinalIgnoreCase))
  400. {
  401. return ".asf";
  402. }
  403. }
  404. else
  405. {
  406. // Try to infer based on the desired audio codec
  407. var audioCodec = state.Request.AudioCodec;
  408. if (string.Equals("aac", audioCodec, StringComparison.OrdinalIgnoreCase))
  409. {
  410. return ".aac";
  411. }
  412. if (string.Equals("mp3", audioCodec, StringComparison.OrdinalIgnoreCase))
  413. {
  414. return ".mp3";
  415. }
  416. if (string.Equals("vorbis", audioCodec, StringComparison.OrdinalIgnoreCase))
  417. {
  418. return ".ogg";
  419. }
  420. if (string.Equals("wma", audioCodec, StringComparison.OrdinalIgnoreCase))
  421. {
  422. return ".wma";
  423. }
  424. }
  425. // Fallback to the container of mediaSource
  426. if (!string.IsNullOrEmpty(mediaSource?.Container))
  427. {
  428. var idx = mediaSource.Container.IndexOf(',', StringComparison.OrdinalIgnoreCase);
  429. return '.' + (idx == -1 ? mediaSource.Container : mediaSource.Container[..idx]).Trim();
  430. }
  431. throw new InvalidOperationException("Failed to find an appropriate file extension");
  432. }
  433. /// <summary>
  434. /// Gets the output file path for transcoding.
  435. /// </summary>
  436. /// <param name="state">The current <see cref="StreamState"/>.</param>
  437. /// <param name="outputFileExtension">The file extension of the output file.</param>
  438. /// <param name="serverConfigurationManager">Instance of the <see cref="IServerConfigurationManager"/> interface.</param>
  439. /// <param name="deviceId">The device id.</param>
  440. /// <param name="playSessionId">The play session id.</param>
  441. /// <returns>The complete file path, including the folder, for the transcoding file.</returns>
  442. private static string GetOutputFilePath(StreamState state, string outputFileExtension, IServerConfigurationManager serverConfigurationManager, string? deviceId, string? playSessionId)
  443. {
  444. var data = $"{state.MediaPath}-{state.UserAgent}-{deviceId!}-{playSessionId!}";
  445. var filename = data.GetMD5().ToString("N", CultureInfo.InvariantCulture);
  446. var ext = outputFileExtension.ToLowerInvariant();
  447. var folder = serverConfigurationManager.GetTranscodePath();
  448. return Path.Combine(folder, filename + ext);
  449. }
  450. private static void ApplyDeviceProfileSettings(StreamState state, IDlnaManager dlnaManager, IDeviceManager deviceManager, HttpRequest request, string? deviceProfileId, bool? @static)
  451. {
  452. if (!string.IsNullOrWhiteSpace(deviceProfileId))
  453. {
  454. state.DeviceProfile = dlnaManager.GetProfile(deviceProfileId);
  455. if (state.DeviceProfile is null)
  456. {
  457. var caps = deviceManager.GetCapabilities(deviceProfileId);
  458. state.DeviceProfile = caps is null ? dlnaManager.GetProfile(request.Headers) : caps.DeviceProfile;
  459. }
  460. }
  461. var profile = state.DeviceProfile;
  462. if (profile is null)
  463. {
  464. // Don't use settings from the default profile.
  465. // Only use a specific profile if it was requested.
  466. return;
  467. }
  468. var audioCodec = state.ActualOutputAudioCodec;
  469. var videoCodec = state.ActualOutputVideoCodec;
  470. var mediaProfile = !state.IsVideoRequest
  471. ? profile.GetAudioMediaProfile(state.OutputContainer, audioCodec, state.OutputAudioChannels, state.OutputAudioBitrate, state.OutputAudioSampleRate, state.OutputAudioBitDepth)
  472. : profile.GetVideoMediaProfile(
  473. state.OutputContainer,
  474. audioCodec,
  475. videoCodec,
  476. state.OutputWidth,
  477. state.OutputHeight,
  478. state.TargetVideoBitDepth,
  479. state.OutputVideoBitrate,
  480. state.TargetVideoProfile,
  481. state.TargetVideoRangeType,
  482. state.TargetVideoLevel,
  483. state.TargetFramerate,
  484. state.TargetPacketLength,
  485. state.TargetTimestamp,
  486. state.IsTargetAnamorphic,
  487. state.IsTargetInterlaced,
  488. state.TargetRefFrames,
  489. state.TargetVideoStreamCount,
  490. state.TargetAudioStreamCount,
  491. state.TargetVideoCodecTag,
  492. state.IsTargetAVC);
  493. if (mediaProfile is not null)
  494. {
  495. state.MimeType = mediaProfile.MimeType;
  496. }
  497. if (!(@static.HasValue && @static.Value))
  498. {
  499. var transcodingProfile = !state.IsVideoRequest ? profile.GetAudioTranscodingProfile(state.OutputContainer, audioCodec) : profile.GetVideoTranscodingProfile(state.OutputContainer, audioCodec, videoCodec);
  500. if (transcodingProfile is not null)
  501. {
  502. state.EstimateContentLength = transcodingProfile.EstimateContentLength;
  503. // state.EnableMpegtsM2TsMode = transcodingProfile.EnableMpegtsM2TsMode;
  504. state.TranscodeSeekInfo = transcodingProfile.TranscodeSeekInfo;
  505. if (state.VideoRequest is not null)
  506. {
  507. state.VideoRequest.CopyTimestamps = transcodingProfile.CopyTimestamps;
  508. state.VideoRequest.EnableSubtitlesInManifest = transcodingProfile.EnableSubtitlesInManifest;
  509. }
  510. }
  511. }
  512. }
  513. /// <summary>
  514. /// Parses the parameters.
  515. /// </summary>
  516. /// <param name="request">The request.</param>
  517. private static void ParseParams(StreamingRequestDto request)
  518. {
  519. if (string.IsNullOrEmpty(request.Params))
  520. {
  521. return;
  522. }
  523. var vals = request.Params.Split(';');
  524. var videoRequest = request as VideoRequestDto;
  525. for (var i = 0; i < vals.Length; i++)
  526. {
  527. var val = vals[i];
  528. if (string.IsNullOrWhiteSpace(val))
  529. {
  530. continue;
  531. }
  532. switch (i)
  533. {
  534. case 0:
  535. request.DeviceProfileId = val;
  536. break;
  537. case 1:
  538. request.DeviceId = val;
  539. break;
  540. case 2:
  541. request.MediaSourceId = val;
  542. break;
  543. case 3:
  544. request.Static = string.Equals("true", val, StringComparison.OrdinalIgnoreCase);
  545. break;
  546. case 4:
  547. if (videoRequest is not null)
  548. {
  549. videoRequest.VideoCodec = val;
  550. }
  551. break;
  552. case 5:
  553. request.AudioCodec = val;
  554. break;
  555. case 6:
  556. if (videoRequest is not null)
  557. {
  558. videoRequest.AudioStreamIndex = int.Parse(val, CultureInfo.InvariantCulture);
  559. }
  560. break;
  561. case 7:
  562. if (videoRequest is not null)
  563. {
  564. videoRequest.SubtitleStreamIndex = int.Parse(val, CultureInfo.InvariantCulture);
  565. }
  566. break;
  567. case 8:
  568. if (videoRequest is not null)
  569. {
  570. videoRequest.VideoBitRate = int.Parse(val, CultureInfo.InvariantCulture);
  571. }
  572. break;
  573. case 9:
  574. request.AudioBitRate = int.Parse(val, CultureInfo.InvariantCulture);
  575. break;
  576. case 10:
  577. request.MaxAudioChannels = int.Parse(val, CultureInfo.InvariantCulture);
  578. break;
  579. case 11:
  580. if (videoRequest is not null)
  581. {
  582. videoRequest.MaxFramerate = float.Parse(val, CultureInfo.InvariantCulture);
  583. }
  584. break;
  585. case 12:
  586. if (videoRequest is not null)
  587. {
  588. videoRequest.MaxWidth = int.Parse(val, CultureInfo.InvariantCulture);
  589. }
  590. break;
  591. case 13:
  592. if (videoRequest is not null)
  593. {
  594. videoRequest.MaxHeight = int.Parse(val, CultureInfo.InvariantCulture);
  595. }
  596. break;
  597. case 14:
  598. request.StartTimeTicks = long.Parse(val, CultureInfo.InvariantCulture);
  599. break;
  600. case 15:
  601. if (videoRequest is not null)
  602. {
  603. videoRequest.Level = val;
  604. }
  605. break;
  606. case 16:
  607. if (videoRequest is not null)
  608. {
  609. videoRequest.MaxRefFrames = int.Parse(val, CultureInfo.InvariantCulture);
  610. }
  611. break;
  612. case 17:
  613. if (videoRequest is not null)
  614. {
  615. videoRequest.MaxVideoBitDepth = int.Parse(val, CultureInfo.InvariantCulture);
  616. }
  617. break;
  618. case 18:
  619. if (videoRequest is not null)
  620. {
  621. videoRequest.Profile = val;
  622. }
  623. break;
  624. case 19:
  625. // cabac no longer used
  626. break;
  627. case 20:
  628. request.PlaySessionId = val;
  629. break;
  630. case 21:
  631. // api_key
  632. break;
  633. case 22:
  634. request.LiveStreamId = val;
  635. break;
  636. case 23:
  637. // Duplicating ItemId because of MediaMonkey
  638. break;
  639. case 24:
  640. if (videoRequest is not null)
  641. {
  642. videoRequest.CopyTimestamps = string.Equals("true", val, StringComparison.OrdinalIgnoreCase);
  643. }
  644. break;
  645. case 25:
  646. if (!string.IsNullOrWhiteSpace(val) && videoRequest is not null)
  647. {
  648. if (Enum.TryParse(val, out SubtitleDeliveryMethod method))
  649. {
  650. videoRequest.SubtitleMethod = method;
  651. }
  652. }
  653. break;
  654. case 26:
  655. request.TranscodingMaxAudioChannels = int.Parse(val, CultureInfo.InvariantCulture);
  656. break;
  657. case 27:
  658. if (videoRequest is not null)
  659. {
  660. videoRequest.EnableSubtitlesInManifest = string.Equals("true", val, StringComparison.OrdinalIgnoreCase);
  661. }
  662. break;
  663. case 28:
  664. request.Tag = val;
  665. break;
  666. case 29:
  667. if (videoRequest is not null)
  668. {
  669. videoRequest.RequireAvc = string.Equals("true", val, StringComparison.OrdinalIgnoreCase);
  670. }
  671. break;
  672. case 30:
  673. request.SubtitleCodec = val;
  674. break;
  675. case 31:
  676. if (videoRequest is not null)
  677. {
  678. videoRequest.RequireNonAnamorphic = string.Equals("true", val, StringComparison.OrdinalIgnoreCase);
  679. }
  680. break;
  681. case 32:
  682. if (videoRequest is not null)
  683. {
  684. videoRequest.DeInterlace = string.Equals("true", val, StringComparison.OrdinalIgnoreCase);
  685. }
  686. break;
  687. case 33:
  688. request.TranscodeReasons = val;
  689. break;
  690. }
  691. }
  692. }
  693. }