Coracle/nostrlib
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

eventstore: fix yield() usage on ReplaceEvent()

Browse Source
This commit is contained in:
fiatjaf
2025-08-05 23:58:13 -03:00
parent 4c459d70ba
commit 92f6f75388
3 changed files with 6 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
eventstore/boltdb/replace.go
View File

@@ -18,11 +18,10 @@ func (b *BoltBackend) ReplaceEvent(evt nostr.Event) error {
} }
// now we fetch the past events, whatever they are, delete them and then save the new // now we fetch the past events, whatever they are, delete them and then save the new
var yield_ func(nostr.Event) bool var err error
var results iter.Seq[nostr.Event] = func(yield func(nostr.Event) bool) { var results iter.Seq[nostr.Event] = func(yield func(nostr.Event) bool) {
yield_ = yield err = b.query(txn, filter, 10 /* in theory limit could be just 1 and this should work */, yield)
} }
err := b.query(txn, filter, 10 /* in theory limit could be just 1 and this should work */, yield_)
if err != nil { if err != nil {
return fmt.Errorf("failed to query past events with %s: %w", filter, err) return fmt.Errorf("failed to query past events with %s: %w", filter, err)
} }

5
eventstore/lmdb/replace.go
View File

@@ -18,11 +18,10 @@ func (b *LMDBBackend) ReplaceEvent(evt nostr.Event) error {
} }
// now we fetch the past events, whatever they are, delete them and then save the new // now we fetch the past events, whatever they are, delete them and then save the new
var yield_ func(nostr.Event) bool var err error
var results iter.Seq[nostr.Event] = func(yield func(nostr.Event) bool) { var results iter.Seq[nostr.Event] = func(yield func(nostr.Event) bool) {
yield_ = yield err = b.query(txn, filter, 10 /* in theory limit could be just 1 and this should work */, yield)
} }
err := b.query(txn, filter, 10 /* in theory limit could be just 1 and this should work */, yield_)
if err != nil { if err != nil {
return fmt.Errorf("failed to query past events with %s: %w", filter, err) return fmt.Errorf("failed to query past events with %s: %w", filter, err)
} }

5
eventstore/mmm/replace.go
View File

@@ -28,11 +28,10 @@ func (il *IndexingLayer) ReplaceEvent(evt nostr.Event) error {
return il.lmdbEnv.Update(func(iltxn *lmdb.Txn) error { return il.lmdbEnv.Update(func(iltxn *lmdb.Txn) error {
// now we fetch the past events, whatever they are, delete them and then save the new // now we fetch the past events, whatever they are, delete them and then save the new
var yield_ func(nostr.Event) bool var err error
var results iter.Seq[nostr.Event] = func(yield func(nostr.Event) bool) { var results iter.Seq[nostr.Event] = func(yield func(nostr.Event) bool) {
yield_ = yield err = il.query(iltxn, filter, 10 /* in theory limit could be just 1 and this should work */, yield)
} }
err := il.query(iltxn, filter, 10 /* in theory limit could be just 1 and this should work */, yield_)
if err != nil { if err != nil {
return fmt.Errorf("failed to query past events with %s: %w", filter, err) return fmt.Errorf("failed to query past events with %s: %w", filter, err)
} }