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

Update timestamps

Browse Source
This commit is contained in:
Kieran
2023-08-25 20:02:24 +01:00
parent b3b3ee542e
commit 201344b622
7 changed files with 360 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
NostrStreamer/Services/Background/BackgroundStreamManager.cs
View File

@ -35,8 +35,7 @@ public class BackgroundStreamManager : BackgroundService
foreach (var id in liveStreams)
{
var manager = await streamManager.ForStream(id);
var lastSegment = await manager.GetLatestRecordingSegment();
var timeoutStream = DateTime.UtcNow.Subtract(TimeSpan.FromMinutes(2)) > lastSegment?.Timestamp;
var timeoutStream = DateTime.UtcNow.Subtract(TimeSpan.FromMinutes(2)) > manager.GetStream().LastSegment;
if (timeoutStream)
{
await manager.StreamStopped();

6
NostrStreamer/Services/StreamManager/NostrStreamManager.cs
View File

@ -128,9 +128,13 @@ public class NostrStreamManager : IStreamManager
Duration = result.Duration,
Timestamp = DateTime.UtcNow //DateTimeOffset.FromUnixTimeMilliseconds(long.Parse(matches.Groups[1].Value)).UtcDateTime
});
await _context.Db.SaveChangesAsync();
}
await _context.Db.Streams
.Where(a => a.Id == _context.UserStream.Id)
.ExecuteUpdateAsync(a => a.SetProperty(b => b.LastSegment, DateTime.UtcNow));
}
public async Task UpdateEvent()