diff --git a/.pinned b/.pinned index 58df7d7e3..1ac94dfb3 100644 --- a/.pinned +++ b/.pinned @@ -15,6 +15,6 @@ serialization;https://github.com/status-im/nim-serialization@#4bdbc29e54fe540499 stew;https://github.com/status-im/nim-stew@#3159137d9a3110edb4024145ce0ba778975de40e testutils;https://github.com/status-im/nim-testutils@#dfc4c1b39f9ded9baf6365014de2b4bfb4dafc34 unittest2;https://github.com/status-im/nim-unittest2@#2300fa9924a76e6c96bc4ea79d043e3a0f27120c -webrtc;https://github.com/status-im/nim-webrtc.git@#ec51a19880f533d2f0afc9e79fa9894f81f25c40 +webrtc;https://github.com/status-im/nim-webrtc.git@#525fb37882397dead197152e0e49af38796940b5 websock;https://github.com/status-im/nim-websock@#f8ed9b40a5ff27ad02a3c237c4905b0924e3f982 zlib;https://github.com/status-im/nim-zlib@#a2f44bb7f65571a894227ff6fde9298a104e03a5 diff --git a/libp2p/transports/webrtctransport.nim b/libp2p/transports/webrtctransport.nim index 0ef714edb..28057330f 100644 --- a/libp2p/transports/webrtctransport.nim +++ b/libp2p/transports/webrtctransport.nim @@ -141,6 +141,7 @@ method write*(s: WebRtcStream, msg2: seq[byte]): Future[void] = return retFuture proc actuallyClose(s: WebRtcStream) {.async.} = + debug "stream closed" if s.rxState == Closed and s.txState == Closed and s.readData.len == 0: #TODO add support to DataChannel #await s.dataChannel.close() @@ -269,7 +270,6 @@ method upgrade*( stream, initiator = true, # we are always the initiator in webrtc-direct peerId = peerId - #TODO: add prelude data ) # Peer proved its identity, we can close this @@ -367,10 +367,9 @@ proc connHandler(self: WebRtcTransport, observedAddr: Opt[MultiAddress], dir: Direction): Future[Connection] {.async.} = - trace "Handling ws connection", address = $observedAddr, - dir = $dir, - clients = self.clients[Direction.In].len + - self.clients[Direction.Out].len + trace "Handling webrtc connection", address = $observedAddr, dir = $dir, + clients = self.clients[Direction.In].len + + self.clients[Direction.Out].len let conn: Connection = WebRtcConnection.new(