From 95f83d4b78a4f2696320b8371635a288b1324fd3 Mon Sep 17 00:00:00 2001 From: Prem Chaitanya Prathi Date: Wed, 9 Apr 2025 11:05:06 +0530 Subject: [PATCH] publish log for analysis --- waku/waku_lightpush/client.nim | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/waku/waku_lightpush/client.nim b/waku/waku_lightpush/client.nim index c50f08641..d00ce6cfe 100644 --- a/waku/waku_lightpush/client.nim +++ b/waku/waku_lightpush/client.nim @@ -111,14 +111,20 @@ proc publishToAny*( return lightpushSuccessResult(publishedCount) - proc publishWithConn*( - wl: WakuLightPushClient, pubSubTopic: PubsubTopic, message: WakuMessage, conn: Connection + wl: WakuLightPushClient, + pubSubTopic: PubsubTopic, + message: WakuMessage, + conn: Connection, ): Future[WakuLightPushResult] {.async, gcsafe.} = ## This proc is similar to the publish one but in this case ## we use existing connection to publish. - info "publishWithConn", msg_hash = computeMessageHash(pubsubTopic, message).to0xHex + info "publishWithConn", + my_peer_id = wl.peerManager.switch.peerInfo.peerId, + peer_id = conn.peerId, + msg_hash = computeMessageHash(pubsubTopic, message).to0xHex, + sentTime = getNowInNanosecondTime() let pushRequest = LightpushRequest( requestId: generateRequestId(wl.rng), @@ -132,5 +138,5 @@ proc publishWithConn*( obs.onMessagePublished(pubSubTopic, message) #TODO: Implement response handling. - + return lightpushSuccessResult(1)