From d3975679e4323e2436bc76d2c34cfecf72946d62 Mon Sep 17 00:00:00 2001
From: fiatjaf <fiatjaf@gmail.com>
Date: Thu, 14 Aug 2025 13:27:29 -0300
Subject: [PATCH] add labels to subscriptions for easier debugging.

---
 count.go | 4 +++-
 fetch.go | 4 +++-
 mcp.go   | 8 ++++++--
 req.go   | 4 +++-
 4 files changed, 15 insertions(+), 5 deletions(-)

diff --git a/count.go b/count.go
index f22ecb8..662baf7 100644
--- a/count.go
+++ b/count.go
@@ -141,7 +141,9 @@ var count = &cli.Command{
 			}
 			for _, relayUrl := range relayUrls {
 				relay, _ := sys.Pool.EnsureRelay(relayUrl)
-				count, hllRegisters, err := relay.Count(ctx, filter, nostr.SubscriptionOptions{})
+				count, hllRegisters, err := relay.Count(ctx, filter, nostr.SubscriptionOptions{
+					Label: "nak-count",
+				})
 				fmt.Fprintf(os.Stderr, "%s%s: ", strings.Repeat(" ", biggerUrlSize-len(relayUrl)), relayUrl)
 
 				if err != nil {
diff --git a/fetch.go b/fetch.go
index 7a1c370..ae84eec 100644
--- a/fetch.go
+++ b/fetch.go
@@ -106,7 +106,9 @@ var fetch = &cli.Command{
 				continue
 			}
 
-			for ie := range sys.Pool.FetchMany(ctx, relays, filter, nostr.SubscriptionOptions{}) {
+			for ie := range sys.Pool.FetchMany(ctx, relays, filter, nostr.SubscriptionOptions{
+				Label: "nak-fetch",
+			}) {
 				stdout(ie.Event)
 			}
 		}
diff --git a/mcp.go b/mcp.go
index bbf1062..e327ef9 100644
--- a/mcp.go
+++ b/mcp.go
@@ -165,7 +165,9 @@ var mcpServer = &cli.Command{
 			res := strings.Builder{}
 			res.WriteString("Search results: ")
 			l := 0
-			for result := range sys.Pool.FetchMany(ctx, []string{"relay.nostr.band", "nostr.wine"}, filter, nostr.SubscriptionOptions{}) {
+			for result := range sys.Pool.FetchMany(ctx, []string{"relay.nostr.band", "nostr.wine"}, filter, nostr.SubscriptionOptions{
+				Label: "nak-mcp-search",
+			}) {
 				l++
 				pm, _ := sdk.ParseMetadata(result.Event)
 				res.WriteString(fmt.Sprintf("\n\nResult %d\nUser name: \"%s\"\nPublic key: \"%s\"\nDescription: \"%s\"\n",
@@ -219,7 +221,9 @@ var mcpServer = &cli.Command{
 				}
 			}
 
-			events := sys.Pool.FetchMany(ctx, []string{relay}, filter, nostr.SubscriptionOptions{})
+			events := sys.Pool.FetchMany(ctx, []string{relay}, filter, nostr.SubscriptionOptions{
+				Label: "nak-mcp-profile-events",
+			})
 
 			result := strings.Builder{}
 			for ie := range events {
diff --git a/req.go b/req.go
index 57eaaed..2fe7301 100644
--- a/req.go
+++ b/req.go
@@ -154,7 +154,9 @@ example:
 						fn = sys.Pool.SubscribeMany
 					}
 
-					for ie := range fn(ctx, relayUrls, filter, nostr.SubscriptionOptions{}) {
+					for ie := range fn(ctx, relayUrls, filter, nostr.SubscriptionOptions{
+						Label: "nak-req",
+					}) {
 						stdout(ie.Event)
 					}
 				}