highperfocused/go-nostr
1
0
Fork 0
mirror of https://github.com/nbd-wtf/go-nostr.git synced 2025-03-28 18:51:53 +01:00
Code Issues Packages Projects Releases Wiki Activity

sdk: label some default queries.

Browse Source
This commit is contained in:
fiatjaf 2024-09-26 21:08:40 -03:00
parent 2c19358c3a
commit ade77ad6c9
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
sdk/metadata.go
View File

@ -128,7 +128,7 @@ func (sys *System) FetchUserEvents(ctx context.Context, filter nostr.Filter) (ma
go func(relayURL string, filter nostr.Filter) { go func(relayURL string, filter nostr.Filter) {
defer wg.Done() defer wg.Done()
filter.Limit = filter.Limit * len(filter.Authors) // hack filter.Limit = filter.Limit * len(filter.Authors) // hack
for ie := range sys.Pool.SubManyEose(ctx, []string{relayURL}, nostr.Filters{filter}) { for ie := range sys.Pool.SubManyEose(ctx, []string{relayURL}, nostr.Filters{filter}, nostr.WithLabel("userevts")) {
results[ie.PubKey] = append(results[ie.PubKey], ie.Event) results[ie.PubKey] = append(results[ie.PubKey], ie.Event)
} }
}(relayURL, filter) }(relayURL, filter)

2
sdk/replaceable_loader.go
View File

@ -170,7 +170,7 @@ func (sys *System) batchReplaceableRelayQueries(
defer cancel() defer cancel()
received := 0 received := 0
for ie := range sys.Pool.SubManyEose(ctx, []string{url}, nostr.Filters{filter}) { for ie := range sys.Pool.SubManyEose(ctx, []string{url}, nostr.Filters{filter}, nostr.WithLabel("repl")) {
all <- ie.Event all <- ie.Event
received++ received++
if received >= n { if received >= n {

2
sdk/search.go
View File

@ -15,7 +15,7 @@ func (sys *System) SearchUsers(ctx context.Context, query string) []ProfileMetad
Search: query, Search: query,
Limit: limit, Limit: limit,
}, },
}) { }, nostr.WithLabel("search")) {
m, _ := ParseMetadata(ie.Event) m, _ := ParseMetadata(ie.Event)
profiles = append(profiles, m) profiles = append(profiles, m)
} }