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

Fix query

Browse Source
This commit is contained in:
Kieran
2024-02-21 20:37:48 +00:00
parent febeb1b0d4
commit d53845154f
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -115,12 +115,14 @@ public class NostrStreamManager : IStreamManager
var cost = (long)Math.Ceiling(_context.UserStream.Endpoint.Cost * (duration / 60d));
if (cost > 0)
{
await _context.Db.Streams
.Include(a => a.User)
.Where(a => a.PubKey == _context.User.PubKey && a.Id == _context.UserStream.Id)
await _context.Db.Users
.Where(a => a.PubKey == _context.User.PubKey)
.ExecuteUpdateAsync(o =>
o.SetProperty(v => v.User.Balance, v => v.User.Balance - cost)
.SetProperty(v => v.MilliSatsCollected, v => v.MilliSatsCollected + cost));
o.SetProperty(v => v.Balance, v => v.Balance - cost));
await _context.Db.Streams
.Where(a => a.Id == _context.UserStream.Id)
.ExecuteUpdateAsync(o =>
o.SetProperty(v => v.MilliSatsCollected, v => v.MilliSatsCollected + cost));
}
_logger.LogInformation("Stream produced {n} seconds for {pubkey} costing {cost:#,##0} milli-sats", duration,