From 6a24f32c20bd3f3dafef7b23362dcf829de147be Mon Sep 17 00:00:00 2001 From: Ivan Folgueira Bande Date: Mon, 13 Oct 2025 17:59:42 +0200 Subject: [PATCH] add temporary logs --- waku/factory/waku.nim | 1 + waku/node/waku_node.nim | 3 +++ waku/waku_api/rest/filter/handlers.nim | 2 ++ 3 files changed, 6 insertions(+) diff --git a/waku/factory/waku.nim b/waku/factory/waku.nim index 2602120d8..e6d670d09 100644 --- a/waku/factory/waku.nim +++ b/waku/factory/waku.nim @@ -198,6 +198,7 @@ proc new*( ## Delivery Monitor var deliveryMonitor: DeliveryMonitor if wakuConf.p2pReliability: + debug "AAAAA Setting up delivery monitor" if wakuConf.remoteStoreNode.isNone(): return err("A storenode should be set when reliability mode is on") diff --git a/waku/node/waku_node.nim b/waku/node/waku_node.nim index ac72f3e37..ee777f945 100644 --- a/waku/node/waku_node.nim +++ b/waku/node/waku_node.nim @@ -546,6 +546,9 @@ proc filterSubscribe*( when (contentTopics is ContentTopic): let contentTopics = @[contentTopics] + + debug "AAAAAA subscribe to filter", pubsubTopic, contentTopics, remotePeer + let subRes = await node.wakuFilterClient.subscribe( remotePeer, pubsubTopic.get(), contentTopics ) diff --git a/waku/waku_api/rest/filter/handlers.nim b/waku/waku_api/rest/filter/handlers.nim index d684335f7..7c866c0e4 100644 --- a/waku/waku_api/rest/filter/handlers.nim +++ b/waku/waku_api/rest/filter/handlers.nim @@ -197,6 +197,8 @@ proc filterPostPutSubscriptionRequestHandler( peerOp.valueOr: return makeRestResponse(req.requestId, NoPeerNoneFoundError) + debug "AAAAA subscribing to filter", + pubsubTopic = req.pubsubTopic, contentFilter = req.contentFilters, peer let subFut = node.filterSubscribe(req.pubsubTopic, req.contentFilters, peer) if not await subFut.withTimeout(futTimeoutForSubscriptionProcessing):