mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-01-07 16:33:08 +00:00
fix: waku sync mounting (#3321)
This commit is contained in:
parent
ed0b260c2d
commit
d5f18cf455
@ -237,12 +237,24 @@ proc mountStoreSync*(
|
|||||||
|
|
||||||
node.wakuStoreReconciliation = recon
|
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(
|
let transfer = SyncTransfer.new(
|
||||||
node.peerManager, node.wakuArchive, idsChannel, wantsChannel, needsChannel
|
node.peerManager, node.wakuArchive, idsChannel, wantsChannel, needsChannel
|
||||||
)
|
)
|
||||||
|
|
||||||
node.wakuStoreTransfer = transfer
|
node.wakuStoreTransfer = transfer
|
||||||
|
|
||||||
|
let transMountRes = catch:
|
||||||
|
node.switch.mount(node.wakuStoreTransfer, protocolMatcher(WakuTransferCodec))
|
||||||
|
if transMountRes.isErr():
|
||||||
|
return err(transMountRes.error.msg)
|
||||||
|
|
||||||
return ok()
|
return ok()
|
||||||
|
|
||||||
## Waku relay
|
## Waku relay
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user