82 lines
4.0 KiB
C#
82 lines
4.0 KiB
C#
using System.Net.Http;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace Jellyfin.Plugin.SRFPlay.Services.Interfaces;
|
|
|
|
/// <summary>
|
|
/// Interface for proxying SRF Play streams and managing authentication.
|
|
/// </summary>
|
|
public interface IStreamProxyService
|
|
{
|
|
/// <summary>
|
|
/// Registers a stream for deferred authentication (authenticates on first playback request).
|
|
/// Use this when browsing to avoid wasting 30-second tokens before the user clicks play.
|
|
/// </summary>
|
|
/// <param name="itemId">The item ID.</param>
|
|
/// <param name="unauthenticatedUrl">The unauthenticated stream URL.</param>
|
|
/// <param name="urn">The SRF URN for this content.</param>
|
|
/// <param name="isLiveStream">Whether this is a livestream.</param>
|
|
void RegisterStreamDeferred(string itemId, string unauthenticatedUrl, string? urn = null, bool isLiveStream = false);
|
|
|
|
/// <summary>
|
|
/// Gets stream metadata for an item (URN and isLiveStream flag).
|
|
/// </summary>
|
|
/// <param name="itemId">The item ID.</param>
|
|
/// <returns>A tuple of (URN, IsLiveStream), or null if not found.</returns>
|
|
(string? Urn, bool IsLiveStream)? GetStreamMetadata(string itemId);
|
|
|
|
/// <summary>
|
|
/// Gets the authenticated URL for an item.
|
|
/// </summary>
|
|
/// <param name="itemId">The item ID.</param>
|
|
/// <param name="cancellationToken">Cancellation token.</param>
|
|
/// <returns>The authenticated URL, or null if not found or expired.</returns>
|
|
Task<string?> GetAuthenticatedUrlAsync(string itemId, CancellationToken cancellationToken = default);
|
|
|
|
/// <summary>
|
|
/// Fetches and rewrites an HLS manifest to use proxy URLs.
|
|
/// </summary>
|
|
/// <param name="itemId">The item ID.</param>
|
|
/// <param name="baseProxyUrl">The base proxy URL.</param>
|
|
/// <param name="cancellationToken">Cancellation token.</param>
|
|
/// <returns>The rewritten manifest content.</returns>
|
|
Task<string?> GetRewrittenManifestAsync(string itemId, string baseProxyUrl, CancellationToken cancellationToken = default);
|
|
|
|
/// <summary>
|
|
/// Fetches a segment from the original source.
|
|
/// </summary>
|
|
/// <param name="itemId">The item ID.</param>
|
|
/// <param name="segmentPath">The segment path.</param>
|
|
/// <param name="queryString">The original query string from the request (preserves segment-specific parameters like timestamps).</param>
|
|
/// <param name="cancellationToken">Cancellation token.</param>
|
|
/// <returns>The segment content as bytes.</returns>
|
|
Task<byte[]?> GetSegmentAsync(string itemId, string segmentPath, string? queryString = null, CancellationToken cancellationToken = default);
|
|
|
|
/// <summary>
|
|
/// Fetches a segment from the original source as a streaming response.
|
|
/// Returns the HttpResponseMessage for streaming directly to the client, reducing TTFB.
|
|
/// The caller is responsible for disposing the response.
|
|
/// </summary>
|
|
/// <param name="itemId">The item ID.</param>
|
|
/// <param name="segmentPath">The segment path.</param>
|
|
/// <param name="queryString">The original query string from the request.</param>
|
|
/// <param name="cancellationToken">Cancellation token.</param>
|
|
/// <returns>The HTTP response for streaming, or null if not found.</returns>
|
|
Task<HttpResponseMessage?> GetSegmentStreamAsync(string itemId, string segmentPath, string? queryString = null, CancellationToken cancellationToken = default);
|
|
|
|
/// <summary>
|
|
/// Rewrites URLs in a variant (sub) manifest to point to the proxy.
|
|
/// </summary>
|
|
/// <param name="manifestContent">The variant manifest content.</param>
|
|
/// <param name="baseProxyUrl">The base proxy URL (without query params).</param>
|
|
/// <param name="queryParams">Query parameters to append to rewritten URLs (e.g., "?token=abc").</param>
|
|
/// <returns>The rewritten manifest content.</returns>
|
|
string RewriteVariantManifestUrls(string manifestContent, string baseProxyUrl, string queryParams);
|
|
|
|
/// <summary>
|
|
/// Cleans up old and expired stream mappings.
|
|
/// </summary>
|
|
void CleanupOldMappings();
|
|
}
|