diff --git a/badger/query.go b/badger/query.go index 9762699..c1ffaa9 100644 --- a/badger/query.go +++ b/badger/query.go @@ -78,9 +78,10 @@ func (b BadgerBackend) QueryEvents(ctx context.Context, filter nostr.Filter) (ch idx, q.prefix, key, err) return } - err = item.Value(func(val []byte) error { + item.Value(func(val []byte) error { evt := &nostr.Event{} if err := nostr_binary.Unmarshal(val, evt); err != nil { + log.Printf("badger: value read error (id %x): %s\n", val[0:32], err) return err } @@ -91,9 +92,6 @@ func (b BadgerBackend) QueryEvents(ctx context.Context, filter nostr.Filter) (ch return nil }) - if err != nil { - log.Printf("badger: value read error: %s\n", err) - } } }(i, q) } diff --git a/lmdb/query.go b/lmdb/query.go index 6952a34..1c71fee 100644 --- a/lmdb/query.go +++ b/lmdb/query.go @@ -94,7 +94,7 @@ func (b *LMDBBackend) QueryEvents(ctx context.Context, filter nostr.Filter) (cha evt := &nostr.Event{} if err := nostr_binary.Unmarshal(val, evt); err != nil { - log.Printf("lmdb: value read error: %s\n", err) + log.Printf("lmdb: value read error (id %x): %s\n", val[0:32], err) break }