diff --git a/khatru/adding.go b/khatru/adding.go index 3871f0a..c352cee 100644 --- a/khatru/adding.go +++ b/khatru/adding.go @@ -46,7 +46,7 @@ func (rl *Relay) handleNormal(ctx context.Context, evt nostr.Event) (skipBroadca } else { // otherwise it's a replaceable if nil != rl.ReplaceEvent { - if _, err := rl.ReplaceEvent(ctx, evt); err != nil { + if err := rl.ReplaceEvent(ctx, evt); err != nil { switch err { case eventstore.ErrDupEvent: return true, nil diff --git a/khatru/relay.go b/khatru/relay.go index b919dd8..23a337c 100644 --- a/khatru/relay.go +++ b/khatru/relay.go @@ -68,7 +68,7 @@ type Relay struct { // hooks that will be called at various times OnEvent func(ctx context.Context, event nostr.Event) (reject bool, msg string) StoreEvent func(ctx context.Context, event nostr.Event) error - ReplaceEvent func(ctx context.Context, event nostr.Event) ([]nostr.Event, error) + ReplaceEvent func(ctx context.Context, event nostr.Event) error DeleteEvent func(ctx context.Context, id nostr.ID) error OnEventSaved func(ctx context.Context, event nostr.Event) OnEventDeleted func(ctx context.Context, deleted nostr.Event) @@ -145,8 +145,9 @@ func (rl *Relay) UseEventstore(store eventstore.Store, maxQueryLimit int) { rl.StoreEvent = func(ctx context.Context, event nostr.Event) error { return store.SaveEvent(event) } - rl.ReplaceEvent = func(ctx context.Context, event nostr.Event) ([]nostr.Event, error) { - return store.ReplaceEvent(event) + rl.ReplaceEvent = func(ctx context.Context, event nostr.Event) error { + _, err := store.ReplaceEvent(event) + return err } rl.DeleteEvent = func(ctx context.Context, id nostr.ID) error { return store.DeleteEvent(id)