diff --git a/waku/node/waku_node.nim b/waku/node/waku_node.nim index e10d705ff..9eeb24321 100644 --- a/waku/node/waku_node.nim +++ b/waku/node/waku_node.nim @@ -237,12 +237,24 @@ proc mountStoreSync*( node.wakuStoreReconciliation = recon + let reconMountRes = catch: + node.switch.mount( + node.wakuStoreReconciliation, protocolMatcher(WakuReconciliationCodec) + ) + if reconMountRes.isErr(): + return err(reconMountRes.error.msg) + let transfer = SyncTransfer.new( node.peerManager, node.wakuArchive, idsChannel, wantsChannel, needsChannel ) node.wakuStoreTransfer = transfer + let transMountRes = catch: + node.switch.mount(node.wakuStoreTransfer, protocolMatcher(WakuTransferCodec)) + if transMountRes.isErr(): + return err(transMountRes.error.msg) + return ok() ## Waku relay