Kieran/zap-stream-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fetch source stream ctx

Browse Source
This commit is contained in:
Kieran
2023-07-11 16:26:21 +01:00
parent 1fba6c3c37
commit 3f00187836
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
NostrStreamer/Controllers/PlaylistController.cs
View File

@ -85,14 +85,18 @@ public class PlaylistController : Controller
return; return;
} }
var hlsCtx = await GetHlsCtx(key);
if (string.IsNullOrEmpty(hlsCtx))
{
Response.StatusCode = 404;
return;
}
Response.ContentType = "application/x-mpegurl"; Response.ContentType = "application/x-mpegurl";
await using var sw = new StreamWriter(Response.Body); await using var sw = new StreamWriter(Response.Body);
var streams = await _srsApi.ListStreams(); var streams = await _srsApi.ListStreams();
await sw.WriteLineAsync("#EXTM3U"); await sw.WriteLineAsync("#EXTM3U");
var hlsCtx = await GetHlsCtx(key);
foreach (var variant in _config.Variants.OrderBy(a => a.Bandwidth)) foreach (var variant in _config.Variants.OrderBy(a => a.Bandwidth))
{ {
var stream = streams.FirstOrDefault(a => var stream = streams.FirstOrDefault(a =>
@ -129,7 +133,7 @@ public class PlaylistController : Controller
private async Task<string?> GetHlsCtx(string key) private async Task<string?> GetHlsCtx(string key)
{ {
var path = $"/{_config.App}/{key}.m3u8"; var path = $"/{_config.App}/source/{key}.m3u8";
var ub = new Uri(_config.SrsHttpHost, path); var ub = new Uri(_config.SrsHttpHost, path);
using var rsp = await _client.GetAsync(ub); using var rsp = await _client.GetAsync(ub);
if (!rsp.IsSuccessStatusCode) if (!rsp.IsSuccessStatusCode)