diff --git a/adding.go b/adding.go index af3ea77..30ef757 100644 --- a/adding.go +++ b/adding.go @@ -79,10 +79,5 @@ func (rl *Relay) AddEvent(ctx context.Context, evt *nostr.Event) error { } } - for _, ovw := range rl.OverwriteResponseEvent { - ovw(ctx, evt) - } - notifyListeners(evt) - return nil } diff --git a/handlers.go b/handlers.go index fe30568..4c4c49d 100644 --- a/handlers.go +++ b/handlers.go @@ -147,6 +147,10 @@ func (rl *Relay) HandleWebsocket(w http.ResponseWriter, r *http.Request) { var reason string if writeErr == nil { ok = true + for _, ovw := range rl.OverwriteResponseEvent { + ovw(ctx, &env.Event) + } + notifyListeners(&env.Event) } else { reason = writeErr.Error() if strings.HasPrefix(reason, "auth-required:") {