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)