fluencelabs/js-libp2p-tcp
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p-tcp synced 2025-04-25 12:22:37 +00:00
Code Issues Projects Releases Wiki Activity

fix: transport should not handle connection if upgradeInbound throws (#119)

Browse Source
This commit is contained in:
Vasco Santos 2019-12-20 16:33:36 +00:00 committed by Jacob Heun
parent 657d3e6f4a
commit 21f87476f6
2 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
package.json
View File

@ -36,7 +36,7 @@
"aegir": "^20.4.1", "aegir": "^20.4.1",
"chai": "^4.2.0", "chai": "^4.2.0",
"dirty-chai": "^2.0.1", "dirty-chai": "^2.0.1",
"libp2p-interfaces": "^0.1.6", "libp2p-interfaces": "^0.2.0",
"it-pipe": "^1.1.0", "it-pipe": "^1.1.0",
"sinon": "^7.5.0", "sinon": "^7.5.0",
"streaming-iterables": "^4.1.1" "streaming-iterables": "^4.1.1"

14
src/listener.js
View File

@ -2,7 +2,10 @@
const net = require('net') const net = require('net')
const EventEmitter = require('events') const EventEmitter = require('events')
const log = require('debug')('libp2p:tcp:listener') const debug = require('debug')
const log = debug('libp2p:tcp:listener')
log.error = debug('libp2p:tcp:listener:error')
const toConnection = require('./socket-to-conn') const toConnection = require('./socket-to-conn')
const { CODE_P2P } = require('./constants') const { CODE_P2P } = require('./constants')
const { const {
@ -20,7 +23,14 @@ module.exports = ({ handler, upgrader }, options) => {
const maConn = toConnection(socket, { listeningAddr }) const maConn = toConnection(socket, { listeningAddr })
log('new inbound connection %s', maConn.remoteAddr) log('new inbound connection %s', maConn.remoteAddr)
const conn = await upgrader.upgradeInbound(maConn) let conn
try {
conn = await upgrader.upgradeInbound(maConn)
} catch (err) {
log.error('inbound connection failed to upgrade', err)
return maConn.close()
}
log('inbound connection %s upgraded', maConn.remoteAddr) log('inbound connection %s upgraded', maConn.remoteAddr)
trackConn(server, maConn) trackConn(server, maConn)