From d53845154f243bc065f757294f48a2878d22119a Mon Sep 17 00:00:00 2001 From: Kieran Date: Wed, 21 Feb 2024 20:37:48 +0000 Subject: [PATCH] Fix query --- .../Services/StreamManager/NostrStreamManager.cs | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/NostrStreamer/Services/StreamManager/NostrStreamManager.cs b/NostrStreamer/Services/StreamManager/NostrStreamManager.cs index b9d06cd..43b9764 100644 --- a/NostrStreamer/Services/StreamManager/NostrStreamManager.cs +++ b/NostrStreamer/Services/StreamManager/NostrStreamManager.cs @@ -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,