From 122443f6c0df0af6e3e8e6123f451e5a41480349 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 297df637e..73cf4d4a2 100644 --- a/waku/waku_lightpush/client.nim +++ b/waku/waku_lightpush/client.nim @@ -119,14 +119,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), @@ -140,5 +146,5 @@ proc publishWithConn*( obs.onMessagePublished(pubSubTopic, message) #TODO: Implement response handling. - + return lightpushSuccessResult(1)