From 5f1bab146dee48670288994812cd007f9844ec6c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Oskar=20Thor=C3=A9n?= Date: Tue, 20 Apr 2021 09:59:14 +0800 Subject: [PATCH] Log more in store protocol (#493) Makes it easier to see what is going on --- waku/v2/protocol/waku_store/waku_store.nim | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/waku/v2/protocol/waku_store/waku_store.nim b/waku/v2/protocol/waku_store/waku_store.nim index 006edb9fc..33a473e45 100644 --- a/waku/v2/protocol/waku_store/waku_store.nim +++ b/waku/v2/protocol/waku_store/waku_store.nim @@ -338,6 +338,7 @@ method init*(ws: WakuStore) = waku_store_errors.inc(labelValues = [decodeRpcFailure]) return + # TODO Print more info here info "received query" let value = res.value @@ -354,6 +355,8 @@ method init*(ws: WakuStore) = else: info "handle store swap is nil" + info "sending response", messages=response.messages.len + await conn.writeLp(HistoryRPC(requestId: value.requestId, response: response).encode().buffer) @@ -375,6 +378,7 @@ method init*(ws: WakuStore) = proc init*(T: type WakuStore, peerManager: PeerManager, rng: ref BrHmacDrbgContext, store: MessageStore = nil, wakuSwap: WakuSwap = nil): T = + debug "init" new result result.rng = rng result.peerManager = peerManager @@ -393,6 +397,7 @@ proc subscription*(proto: WakuStore): MessageNotificationSubscription = ## the filter should be used by the component that receives ## new messages. proc handle(topic: string, msg: WakuMessage) {.async.} = + debug "subscription handle", topic=topic let index = msg.computeIndex() proto.messages.add(IndexedWakuMessage(msg: msg, index: index)) waku_store_messages.inc(labelValues = ["stored"])