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

add temporary logs

Browse Source
This commit is contained in:
Ivan Folgueira Bande 2025-10-13 17:59:42 +02:00
parent 7b234ec78a
commit 6a24f32c20
No known key found for this signature in database
GPG Key ID: 3C117481F89E24A7
3 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
waku/factory/waku.nim
View File

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

3
waku/node/waku_node.nim
View File

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

2
waku/waku_api/rest/filter/handlers.nim
View File

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