mirror of
https://github.com/vacp2p/mix.git
synced 2026-01-09 02:38:00 -05:00
fix: trace log
This commit is contained in:
@@ -36,8 +36,6 @@ proc init*(T: typedesc[ExitLayer], switch: Switch): T =
|
||||
proc runHandler(
|
||||
self: ExitLayer, codec: string, message: seq[byte]
|
||||
) {.async: (raises: [CancelledError]).} =
|
||||
trace "Received: ", receiver = multiAddr, codec, message
|
||||
|
||||
let exitConn = MixExitConnection.new(message)
|
||||
|
||||
await self.pHandler(exitConn, codec)
|
||||
@@ -52,6 +50,7 @@ proc onMessage*(
|
||||
self: ExitLayer, codec: string, message: seq[byte], nextHop: Hop
|
||||
) {.async: (raises: [CancelledError]).} =
|
||||
if nextHop == Hop():
|
||||
trace "onMessage - exit is destination", codec, message
|
||||
await self.runHandler(codec, message)
|
||||
return
|
||||
|
||||
@@ -80,6 +79,8 @@ proc onMessage*(
|
||||
mix_messages_error.inc(labelValues = ["ExitLayer", "INVALID_DEST"])
|
||||
return
|
||||
|
||||
trace "onMessage - exit is not destination", peerId, locationAddr, codec, message
|
||||
|
||||
var destConn: Connection
|
||||
try:
|
||||
destConn = await self.switch.dial(peerId, @[locationAddr], codec)
|
||||
|
||||
Reference in New Issue
Block a user