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) }