From 4645f5044039921d6025ffa9f4e41aa824a230b6 Mon Sep 17 00:00:00 2001
From: Gabriel mermelstein <gabrielmermelstein@gmail.com>
Date: Tue, 10 Jun 2025 16:16:12 +0200
Subject: [PATCH] adding more logs and updating vendor

---
 vendor/nim-eth                  | 2 +-
 waku/node/waku_node.nim         | 6 ++++++
 waku/waku_metadata/protocol.nim | 2 ++
 3 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/vendor/nim-eth b/vendor/nim-eth
index a1f7d63ab..f1de8ae83 160000
--- a/vendor/nim-eth
+++ b/vendor/nim-eth
@@ -1 +1 @@
-Subproject commit a1f7d63ababa6ce90798e16a110fc4e43ac93f03
+Subproject commit f1de8ae83509ac3fbd678ae4c6981d2048c6c651
diff --git a/waku/node/waku_node.nim b/waku/node/waku_node.nim
index ac72f3e37..a339aaa53 100644
--- a/waku/node/waku_node.nim
+++ b/waku/node/waku_node.nim
@@ -333,6 +333,7 @@ proc subscribe*(
     return ok()
 
   node.registerRelayHandler(pubsubTopic, handler)
+  echo "------------ subscribe topicSubscriptionQueue.emit"
   node.topicSubscriptionQueue.emit((kind: PubsubSub, topic: pubsubTopic))
 
   return ok()
@@ -365,6 +366,7 @@ proc unsubscribe*(
 
   debug "unsubscribe", pubsubTopic, contentTopicOp
   node.wakuRelay.unsubscribe(pubsubTopic)
+  echo "------------ unsubscribe topicSubscriptionQueue.emit"
   node.topicSubscriptionQueue.emit((kind: PubsubUnsub, topic: pubsubTopic))
 
   return ok()
@@ -554,6 +556,7 @@ proc filterSubscribe*(
         pubsubTopic = pubsubTopic, contentTopics = contentTopics
 
       # Purpose is to update Waku Metadata
+      echo "------------ filterSubscribe topicSubscriptionQueue.emit"
       node.topicSubscriptionQueue.emit((kind: PubsubSub, topic: pubsubTopic.get()))
     else:
       error "failed filter v2 subscription", error = subRes.error
@@ -593,6 +596,7 @@ proc filterSubscribe*(
         info "subscribed to topic", pubsubTopic = pubsub, contentTopics = topics
 
         # Purpose is to update Waku Metadata
+        echo "------------ filterSubscribe topicSubscriptionQueue.emit 2"
         node.topicSubscriptionQueue.emit((kind: PubsubSub, topic: $pubsub))
     except CatchableError:
       let errMsg = "exception in filterSubscribe: " & getCurrentExceptionMsg()
@@ -633,6 +637,7 @@ proc filterUnsubscribe*(
         pubsubTopic = pubsubTopic.get(), contentTopics = contentTopics
 
       # Purpose is to update Waku Metadata
+      echo "------------ filterUnsubscribe topicSubscriptionQueue.emit"
       node.topicSubscriptionQueue.emit((kind: PubsubUnsub, topic: pubsubTopic.get()))
     else:
       error "failed filter unsubscription", error = unsubRes.error
@@ -672,6 +677,7 @@ proc filterUnsubscribe*(
         info "unsubscribed from topic", pubsubTopic = pubsub, contentTopics = topics
 
         # Purpose is to update Waku Metadata
+        echo "------------ filterUnsubscribe topicSubscriptionQueue.emit 2"
         node.topicSubscriptionQueue.emit((kind: PubsubUnsub, topic: $pubsub))
     except CatchableError:
       let errMsg = "exception in filterUnsubscribe: " & getCurrentExceptionMsg()
diff --git a/waku/waku_metadata/protocol.nim b/waku/waku_metadata/protocol.nim
index 13a2916b3..df6eecc0c 100644
--- a/waku/waku_metadata/protocol.nim
+++ b/waku/waku_metadata/protocol.nim
@@ -129,6 +129,8 @@ proc new*(
 proc subscriptionsListener(wm: WakuMetadata) {.async.} =
   ## Listen for pubsub topics subscriptions changes
 
+  echo "--------- entered subscriptionsListener"
+
   let key = wm.topicSubscriptionQueue.register()
 
   while wm.started: