logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-01-04 23:13:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

adding more logs and updating vendor

Browse Source
This commit is contained in:
Gabriel mermelstein 2025-06-10 16:16:12 +02:00
parent 8244cb6cb9
commit 4645f50440
3 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
vendor/nim-eth vendored

@ -1 +1 @@
Subproject commit a1f7d63ababa6ce90798e16a110fc4e43ac93f03
Subproject commit f1de8ae83509ac3fbd678ae4c6981d2048c6c651

6
waku/node/waku_node.nim
View File

@ -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()

2
waku/waku_metadata/protocol.nim
View File

@ -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: