highperfocused/go-nostr
1
0
Fork 0
mirror of https://github.com/nbd-wtf/go-nostr.git synced 2025-05-18 14:39:58 +02:00
Code Issues Packages Projects Releases Wiki Activity

rename option pool.WithQueryMiddleware() to pool.WithAuthorKindQueryMiddleware().

Browse Source
This commit is contained in:
fiatjaf 2025-01-03 00:12:33 -03:00
parent 668720f4bc
commit b33cfb19fa
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pool.go
View File

@ -123,9 +123,9 @@ func (h WithEventMiddleware) ApplyPoolOption(pool *SimplePool) {
// WithQueryMiddleware is a function that will be called with every combination of relay+pubkey+kind queried // WithQueryMiddleware is a function that will be called with every combination of relay+pubkey+kind queried
// in a .SubMany*() call -- when applicable (i.e. when the query contains a pubkey and a kind). // in a .SubMany*() call -- when applicable (i.e. when the query contains a pubkey and a kind).
type WithQueryMiddleware func(relay string, pubkey string, kind int) type WithAuthorKindQueryMiddleware func(relay string, pubkey string, kind int)
func (h WithQueryMiddleware) ApplyPoolOption(pool *SimplePool) { func (h WithAuthorKindQueryMiddleware) ApplyPoolOption(pool *SimplePool) {
pool.queryMiddleware = h pool.queryMiddleware = h
} }
@ -508,7 +508,7 @@ func (pool *SimplePool) CountMany(
filter Filter, filter Filter,
opts []SubscriptionOption, opts []SubscriptionOption,
) int { ) int {
hll := hyperloglog.New(0) // offset is irrelevant here, so we just pass 0 hll := hyperloglog.New(0) // offset is irrelevant here
wg := sync.WaitGroup{} wg := sync.WaitGroup{}
wg.Add(len(urls)) wg.Add(len(urls))

2
sdk/system.go
View File

@ -106,7 +106,7 @@ func NewSystem(mods ...SystemModifier) *System {
} }
sys.Pool = nostr.NewSimplePool(context.Background(), sys.Pool = nostr.NewSimplePool(context.Background(),
nostr.WithQueryMiddleware(sys.TrackQueryAttempts), nostr.WithAuthorKindQueryMiddleware(sys.TrackQueryAttempts),
nostr.WithEventMiddleware(sys.TrackEventHints), nostr.WithEventMiddleware(sys.TrackEventHints),
nostr.WithPenaltyBox(), nostr.WithPenaltyBox(),
) )