diff --git a/waku/node/delivery_service/send_service/relay_processor.nim b/waku/node/delivery_service/send_service/relay_processor.nim index 94cb63776..974c22f6c 100644 --- a/waku/node/delivery_service/send_service/relay_processor.nim +++ b/waku/node/delivery_service/send_service/relay_processor.nim @@ -70,7 +70,9 @@ method sendImpl*(self: RelaySendProcessor, task: DeliveryTask) {.async.} = if noOfPublishedPeers > 0: info "Message propagated via Relay", - requestId = task.requestId, msgHash = task.msgHash.to0xHex(), noOfPeers = noOfPublishedPeers + requestId = task.requestId, + msgHash = task.msgHash.to0xHex(), + noOfPeers = noOfPublishedPeers task.state = DeliveryState.SuccessfullyPropagated task.deliveryTime = Moment.now() else: diff --git a/waku/waku_mix/protocol.nim b/waku/waku_mix/protocol.nim index 5353a470d..e57352d92 100644 --- a/waku/waku_mix/protocol.nim +++ b/waku/waku_mix/protocol.nim @@ -14,10 +14,7 @@ import eth/common/keys import - ../node/peer_manager, - ../waku_core, - ../waku_enr, - ../node/peer_manager/waku_peer_store + ../node/peer_manager, ../waku_core, ../waku_enr, ../node/peer_manager/waku_peer_store logScope: topics = "waku mix" @@ -91,7 +88,9 @@ proc new*( var m = WakuMix(peerManager: peermgr, clusterId: clusterId, pubKey: mixPubKey) procCall MixProtocol(m).init( - localMixNodeInfo, peermgr.switch, delayStrategy = NoSamplingDelayStrategy.new(crypto.newRng()) + localMixNodeInfo, + peermgr.switch, + delayStrategy = NoSamplingDelayStrategy.new(crypto.newRng()), ) processBootNodes(bootnodes, peermgr, m)