This commit is contained in:
@ -99,7 +99,7 @@ public class SrsController : Controller
|
|||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
{
|
{
|
||||||
_logger.LogWarning("Failed to start stream: {message}", ex.Message);
|
_logger.LogWarning("Failed to process stream: {message}", ex.Message);
|
||||||
}
|
}
|
||||||
|
|
||||||
return new()
|
return new()
|
||||||
|
@ -166,13 +166,15 @@ public class NostrStreamManager : IStreamManager
|
|||||||
_eventBuilder.BroadcastEvent(chat);
|
_eventBuilder.BroadcastEvent(chat);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (_context.User.Balance <= 0)
|
if (_context.User.Balance <= 0 || _context.User.IsBlocked)
|
||||||
{
|
{
|
||||||
_logger.LogInformation("Kicking stream due to low balance");
|
_logger.LogInformation("Kicking stream due to low balance");
|
||||||
if (!string.IsNullOrEmpty(_context.UserStream.ForwardClientId))
|
if (!string.IsNullOrEmpty(_context.UserStream.ForwardClientId))
|
||||||
{
|
{
|
||||||
await _context.EdgeApi.KickClient(_context.UserStream.ForwardClientId);
|
await _context.EdgeApi.KickClient(_context.UserStream.ForwardClientId);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
throw new Exception("User balance too low or user is blocked");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user