From ae4f5943945fdf188894ffed655355102f64fee7 Mon Sep 17 00:00:00 2001 From: Kieran Date: Wed, 8 May 2024 18:59:33 +0100 Subject: [PATCH] Dont block on notification --- .../StreamManager/NostrStreamManager.cs | 30 +++++++++++-------- 1 file changed, 17 insertions(+), 13 deletions(-) diff --git a/NostrStreamer/Services/StreamManager/NostrStreamManager.cs b/NostrStreamer/Services/StreamManager/NostrStreamManager.cs index 17f29f0..a503517 100644 --- a/NostrStreamer/Services/StreamManager/NostrStreamManager.cs +++ b/NostrStreamer/Services/StreamManager/NostrStreamManager.cs @@ -84,22 +84,26 @@ public class NostrStreamManager : IStreamManager var ev = await UpdateStreamState(UserStreamState.Live); - if (_config.DiscordLiveWebhook != default) + _ = Task.Factory.StartNew(async () => { - try + if (_config.DiscordLiveWebhook != default) { - var npub = NostrConverter.ToBech32(_context.User.PubKey, "npub")!; - var profile = await _nostrApi.Profile(npub); - var name = profile?.Name ?? npub; - var id = ev.ToIdentifier(); - await _webhook.SendMessage(_config.DiscordLiveWebhook, - $"{name} went live!\nhttps://zap.stream/{id.ToBech32()}"); + try + { + var npub = NostrConverter.ToBech32(_context.User.PubKey, "npub")!; + var profile = await _nostrApi.Profile(npub); + var name = profile?.Name ?? npub; + var id = ev.ToIdentifier(); + await _webhook.SendMessage(_config.DiscordLiveWebhook, + $"{name} went live!\nhttps://zap.stream/{id.ToBech32()}"); + } + catch (Exception ex) + { + _logger.LogWarning("Failed to send notification {msg}", ex.Message); + } } - catch (Exception ex) - { - _logger.LogWarning("Failed to send notification {msg}", ex.Message); - } - } + }); + } public async Task StreamStopped()