From 077a7cf2e23f320ec8fc409c85bf52ca5bd8b6cf Mon Sep 17 00:00:00 2001 From: Barry Deen Date: Mon, 23 Sep 2024 16:25:27 -0400 Subject: [PATCH] put blastr in goroutines to prevent oom --- blastr.go | 17 ++++++++++------- 1 file changed, 10 insertions(+), 7 deletions(-) diff --git a/blastr.go b/blastr.go index cf36c25..ec4219f 100644 --- a/blastr.go +++ b/blastr.go @@ -10,12 +10,15 @@ import ( func blast(ev *nostr.Event) { ctx := context.Background() for _, relay := range config.BlastrRelays { - log.Println("🔫 blasting to", relay) - connect, err := nostr.RelayConnect(ctx, relay) - if err != nil { - log.Println("error connecting to relay", relay, err) - continue - } - connect.Publish(ctx, *ev) + go blastRoutine(ctx, relay, ev) } } + +func blastRoutine(ctx context.Context, relay string, ev *nostr.Event) { + connect, err := nostr.RelayConnect(ctx, relay) + if err != nil { + log.Println("error connecting to relay", relay, err) + } + connect.Publish(ctx, *ev) + log.Println("🔫 blasted to", relay) +}