From e272bec9c543337a597de7fc2ecc1bee3fa5d945 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?rich=CE=9Brd?= Date: Wed, 30 Aug 2023 18:10:51 -0400 Subject: [PATCH] chore: add debug log indicating succesful message pushes and also log the message hash (#1965) --- waku/waku_filter_v2/protocol.nim | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/waku/waku_filter_v2/protocol.nim b/waku/waku_filter_v2/protocol.nim index 86282c191..36c488e06 100644 --- a/waku/waku_filter_v2/protocol.nim +++ b/waku/waku_filter_v2/protocol.nim @@ -7,6 +7,7 @@ else: import std/[options,sequtils,sets,strutils,tables], + stew/byteutils, chronicles, chronos, libp2p/peerid, @@ -158,7 +159,7 @@ proc pushToPeer(wf: WakuFilter, peer: PeerId, buffer: seq[byte]) {.async.} = await conn.get().writeLp(buffer) proc pushToPeers(wf: WakuFilter, peers: seq[PeerId], messagePush: MessagePush) {.async.} = - trace "pushing message to subscribed peers", peers=peers, messagePush=messagePush + debug "pushing message to subscribed peers", pubsubTopic=messagePush.pubsubTopic, contentTopic=messagePush.wakuMessage.contentTopic, peers=peers, hash=messagePush.pubsubTopic.digest(messagePush.wakuMessage).to0xHex() let bufferToPublish = messagePush.encode().buffer @@ -205,8 +206,11 @@ proc handleMessage*(wf: WakuFilter, pubsubTopic: PubsubTopic, message: WakuMessa wakuMessage: message) if not await wf.pushToPeers(subscribedPeers, messagePush).withTimeout(MessagePushTimeout): - debug "timed out pushing message to peers", pubsubTopic=pubsubTopic, contentTopic=message.contentTopic + debug "timed out pushing message to peers", pubsubTopic=pubsubTopic, contentTopic=message.contentTopic, hash=pubsubTopic.digest(message).to0xHex() waku_filter_errors.inc(labelValues = [pushTimeoutFailure]) + else: + debug "pushed message succesfully to all subscribers", pubsubTopic=pubsubTopic, contentTopic=message.contentTopic, hash=pubsubTopic.digest(message).to0xHex() + let handleMessageDuration = Moment.now() - handleMessageStartTime