Add ITranscodeManager service

5 files changed, 6 insertions, 258 deletions

diff --git a/Jellyfin.Api/Models/StreamingDtos/HlsAudioRequestDto.cs b/Jellyfin.Api/Models/StreamingDtos/HlsAudioRequestDto.cs
index 4f1abb1ff..bd176bb6a 100644
--- a/Jellyfin.Api/Models/StreamingDtos/HlsAudioRequestDto.cs
+++ b/Jellyfin.Api/Models/StreamingDtos/HlsAudioRequestDto.cs
@@ -1,4 +1,6 @@
-namespace Jellyfin.Api.Models.StreamingDtos;
+using MediaBrowser.Controller.Streaming;
+
+namespace Jellyfin.Api.Models.StreamingDtos;
 
 /// <summary>
 /// The hls video request dto.
diff --git a/Jellyfin.Api/Models/StreamingDtos/HlsVideoRequestDto.cs b/Jellyfin.Api/Models/StreamingDtos/HlsVideoRequestDto.cs
index 1cd3d0132..53b6d7575 100644
--- a/Jellyfin.Api/Models/StreamingDtos/HlsVideoRequestDto.cs
+++ b/Jellyfin.Api/Models/StreamingDtos/HlsVideoRequestDto.cs
@@ -1,4 +1,6 @@
-namespace Jellyfin.Api.Models.StreamingDtos;
+using MediaBrowser.Controller.Streaming;
+
+namespace Jellyfin.Api.Models.StreamingDtos;
 
 /// <summary>
 /// The hls video request dto.
diff --git a/Jellyfin.Api/Models/StreamingDtos/StreamState.cs b/Jellyfin.Api/Models/StreamingDtos/StreamState.cs
deleted file mode 100644
index 439f8052c..000000000
--- a/Jellyfin.Api/Models/StreamingDtos/StreamState.cs
+++ /dev/null
@@ -1,184 +0,0 @@
-using System;
-using Jellyfin.Api.Helpers;
-using MediaBrowser.Controller.Library;
-using MediaBrowser.Controller.MediaEncoding;
-using MediaBrowser.Model.Dlna;
-
-namespace Jellyfin.Api.Models.StreamingDtos;
-
-/// <summary>
-/// The stream state dto.
-/// </summary>
-public class StreamState : EncodingJobInfo, IDisposable
-{
-    private readonly IMediaSourceManager _mediaSourceManager;
-    private readonly TranscodingJobHelper _transcodingJobHelper;
-    private bool _disposed;
-
-    /// <summary>
-    /// Initializes a new instance of the <see cref="StreamState" /> class.
-    /// </summary>
-    /// <param name="mediaSourceManager">Instance of the <see cref="IMediaSourceManager" /> interface.</param>
-    /// <param name="transcodingType">The <see cref="TranscodingJobType" />.</param>
-    /// <param name="transcodingJobHelper">The <see cref="TranscodingJobHelper" /> singleton.</param>
-    public StreamState(IMediaSourceManager mediaSourceManager, TranscodingJobType transcodingType, TranscodingJobHelper transcodingJobHelper)
-        : base(transcodingType)
-    {
-        _mediaSourceManager = mediaSourceManager;
-        _transcodingJobHelper = transcodingJobHelper;
-    }
-
-    /// <summary>
-    /// Gets or sets the requested url.
-    /// </summary>
-    public string? RequestedUrl { get; set; }
-
-    /// <summary>
-    /// Gets or sets the request.
-    /// </summary>
-    public StreamingRequestDto Request
-    {
-        get => (StreamingRequestDto)BaseRequest;
-        set
-        {
-            BaseRequest = value;
-            IsVideoRequest = VideoRequest is not null;
-        }
-    }
-
-    /// <summary>
-    /// Gets the video request.
-    /// </summary>
-    public VideoRequestDto? VideoRequest => Request as VideoRequestDto;
-
-    /// <summary>
-    /// Gets or sets the direct stream provicer.
-    /// </summary>
-    /// <remarks>
-    /// Deprecated.
-    /// </remarks>
-    public IDirectStreamProvider? DirectStreamProvider { get; set; }
-
-    /// <summary>
-    /// Gets or sets the path to wait for.
-    /// </summary>
-    public string? WaitForPath { get; set; }
-
-    /// <summary>
-    /// Gets a value indicating whether the request outputs video.
-    /// </summary>
-    public bool IsOutputVideo => Request is VideoRequestDto;
-
-    /// <summary>
-    /// Gets the segment length.
-    /// </summary>
-    public int SegmentLength
-    {
-        get
-        {
-            if (Request.SegmentLength.HasValue)
-            {
-                return Request.SegmentLength.Value;
-            }
-
-            if (EncodingHelper.IsCopyCodec(OutputVideoCodec))
-            {
-                var userAgent = UserAgent ?? string.Empty;
-
-                if (userAgent.Contains("AppleTV", StringComparison.OrdinalIgnoreCase)
-                    || userAgent.Contains("cfnetwork", StringComparison.OrdinalIgnoreCase)
-                    || userAgent.Contains("ipad", StringComparison.OrdinalIgnoreCase)
-                    || userAgent.Contains("iphone", StringComparison.OrdinalIgnoreCase)
-                    || userAgent.Contains("ipod", StringComparison.OrdinalIgnoreCase))
-                {
-                    return 6;
-                }
-
-                if (IsSegmentedLiveStream)
-                {
-                    return 3;
-                }
-
-                return 6;
-            }
-
-            return 3;
-        }
-    }
-
-    /// <summary>
-    /// Gets the minimum number of segments.
-    /// </summary>
-    public int MinSegments
-    {
-        get
-        {
-            if (Request.MinSegments.HasValue)
-            {
-                return Request.MinSegments.Value;
-            }
-
-            return SegmentLength >= 10 ? 2 : 3;
-        }
-    }
-
-    /// <summary>
-    /// Gets or sets the user agent.
-    /// </summary>
-    public string? UserAgent { get; set; }
-
-    /// <summary>
-    /// Gets or sets a value indicating whether to estimate the content length.
-    /// </summary>
-    public bool EstimateContentLength { get; set; }
-
-    /// <summary>
-    /// Gets or sets the transcode seek info.
-    /// </summary>
-    public TranscodeSeekInfo TranscodeSeekInfo { get; set; }
-
-    /// <summary>
-    /// Gets or sets the transcoding job.
-    /// </summary>
-    public TranscodingJob? TranscodingJob { get; set; }
-
-    /// <inheritdoc />
-    public void Dispose()
-    {
-        Dispose(true);
-        GC.SuppressFinalize(this);
-    }
-
-    /// <inheritdoc />
-    public override void ReportTranscodingProgress(TimeSpan? transcodingPosition, float? framerate, double? percentComplete, long? bytesTranscoded, int? bitRate)
-    {
-        _transcodingJobHelper.ReportTranscodingProgress(TranscodingJob!, this, transcodingPosition, framerate, percentComplete, bytesTranscoded, bitRate);
-    }
-
-    /// <summary>
-    /// Disposes the stream state.
-    /// </summary>
-    /// <param name="disposing">Whether the object is currently being disposed.</param>
-    protected virtual void Dispose(bool disposing)
-    {
-        if (_disposed)
-        {
-            return;
-        }
-
-        if (disposing)
-        {
-            // REVIEW: Is this the right place for this?
-            if (MediaSource.RequiresClosing
-                && string.IsNullOrWhiteSpace(Request.LiveStreamId)
-                && !string.IsNullOrWhiteSpace(MediaSource.LiveStreamId))
-            {
-                _mediaSourceManager.CloseLiveStream(MediaSource.LiveStreamId).GetAwaiter().GetResult();
-            }
-        }
-
-        TranscodingJob = null;
-
-        _disposed = true;
-    }
-}
diff --git a/Jellyfin.Api/Models/StreamingDtos/StreamingRequestDto.cs b/Jellyfin.Api/Models/StreamingDtos/StreamingRequestDto.cs
deleted file mode 100644
index a357498d4..000000000
--- a/Jellyfin.Api/Models/StreamingDtos/StreamingRequestDto.cs
+++ /dev/null
@@ -1,49 +0,0 @@
-using MediaBrowser.Controller.MediaEncoding;
-
-namespace Jellyfin.Api.Models.StreamingDtos;
-
-/// <summary>
-/// The audio streaming request dto.
-/// </summary>
-public class StreamingRequestDto : BaseEncodingJobOptions
-{
-    /// <summary>
-    /// Gets or sets the params.
-    /// </summary>
-    public string? Params { get; set; }
-
-    /// <summary>
-    /// Gets or sets the play session id.
-    /// </summary>
-    public string? PlaySessionId { get; set; }
-
-    /// <summary>
-    /// Gets or sets the tag.
-    /// </summary>
-    public string? Tag { get; set; }
-
-    /// <summary>
-    /// Gets or sets the segment container.
-    /// </summary>
-    public string? SegmentContainer { get; set; }
-
-    /// <summary>
-    /// Gets or sets the segment length.
-    /// </summary>
-    public int? SegmentLength { get; set; }
-
-    /// <summary>
-    /// Gets or sets the min segments.
-    /// </summary>
-    public int? MinSegments { get; set; }
-
-    /// <summary>
-    /// Gets or sets the position of the requested segment in ticks.
-    /// </summary>
-    public long CurrentRuntimeTicks { get; set; }
-
-    /// <summary>
-    /// Gets or sets the actual segment length in ticks.
-    /// </summary>
-    public long ActualSegmentLengthTicks { get; set; }
-}
diff --git a/Jellyfin.Api/Models/StreamingDtos/VideoRequestDto.cs b/Jellyfin.Api/Models/StreamingDtos/VideoRequestDto.cs
deleted file mode 100644
index 8548fec1a..000000000
--- a/Jellyfin.Api/Models/StreamingDtos/VideoRequestDto.cs
+++ /dev/null
@@ -1,23 +0,0 @@
-namespace Jellyfin.Api.Models.StreamingDtos;
-
-/// <summary>
-/// The video request dto.
-/// </summary>
-public class VideoRequestDto : StreamingRequestDto
-{
-    /// <summary>
-    /// Gets a value indicating whether this instance has fixed resolution.
-    /// </summary>
-    /// <value><c>true</c> if this instance has fixed resolution; otherwise, <c>false</c>.</value>
-    public bool HasFixedResolution => Width.HasValue || Height.HasValue;
-
-    /// <summary>
-    /// Gets or sets a value indicating whether to enable subtitles in the manifest.
-    /// </summary>
-    public bool EnableSubtitlesInManifest { get; set; }
-
-    /// <summary>
-    /// Gets or sets a value indicating whether to enable trickplay images.
-    /// </summary>
-    public bool EnableTrickplay { get; set; }
-}