From ade77ad6c9f8d52f8d5c2f1a90144bbaef46cb84 Mon Sep 17 00:00:00 2001 From: fiatjaf Date: Thu, 26 Sep 2024 21:08:40 -0300 Subject: [PATCH] sdk: label some default queries. --- sdk/metadata.go | 2 +- sdk/replaceable_loader.go | 2 +- sdk/search.go | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/sdk/metadata.go b/sdk/metadata.go index 62373e6..529e4cf 100644 --- a/sdk/metadata.go +++ b/sdk/metadata.go @@ -128,7 +128,7 @@ func (sys *System) FetchUserEvents(ctx context.Context, filter nostr.Filter) (ma go func(relayURL string, filter nostr.Filter) { defer wg.Done() 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) } }(relayURL, filter) diff --git a/sdk/replaceable_loader.go b/sdk/replaceable_loader.go index be11275..e2c8040 100644 --- a/sdk/replaceable_loader.go +++ b/sdk/replaceable_loader.go @@ -170,7 +170,7 @@ func (sys *System) batchReplaceableRelayQueries( defer cancel() 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 received++ if received >= n { diff --git a/sdk/search.go b/sdk/search.go index 3dd6ee7..300bea8 100644 --- a/sdk/search.go +++ b/sdk/search.go @@ -15,7 +15,7 @@ func (sys *System) SearchUsers(ctx context.Context, query string) []ProfileMetad Search: query, Limit: limit, }, - }) { + }, nostr.WithLabel("search")) { m, _ := ParseMetadata(ie.Event) profiles = append(profiles, m) }