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) +}