mirror of
https://github.com/fluencelabs/js-libp2p-tcp
synced 2025-07-02 05:01:34 +00:00
Compare commits
4 Commits
Author | SHA1 | Date | |
---|---|---|---|
524acbe372 | |||
1b210e71c0 | |||
a385f0eb34 | |||
605ee279ae |
1
.gitignore
vendored
1
.gitignore
vendored
@ -2,3 +2,4 @@ node_modules
|
||||
package-lock.json
|
||||
coverage
|
||||
.nyc_output
|
||||
docs
|
||||
|
10
CHANGELOG.md
10
CHANGELOG.md
@ -1,3 +1,13 @@
|
||||
<a name="0.14.1"></a>
|
||||
## [0.14.1](https://github.com/libp2p/js-libp2p-tcp/compare/v0.14.0...v0.14.1) (2019-09-20)
|
||||
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* ensure timeline.close is set ([#113](https://github.com/libp2p/js-libp2p-tcp/issues/113)) ([605ee27](https://github.com/libp2p/js-libp2p-tcp/commit/605ee27))
|
||||
|
||||
|
||||
|
||||
<a name="0.14.0"></a>
|
||||
# [0.14.0](https://github.com/libp2p/js-libp2p-tcp/compare/v0.13.1...v0.14.0) (2019-09-16)
|
||||
|
||||
|
@ -44,9 +44,13 @@ const multiaddr = require('multiaddr')
|
||||
const pipe = require('it-pipe')
|
||||
const { collect } = require('streaming-iterables')
|
||||
|
||||
const addr = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
||||
// A simple upgrader that just returns the MultiaddrConnection
|
||||
const upgrader = {
|
||||
upgradeInbound: maConn => maConn,
|
||||
upgradeOutbound: maConn => maConn
|
||||
}
|
||||
|
||||
const tcp = new TCP()
|
||||
const tcp = new TCP({ upgrader })
|
||||
|
||||
const listener = tcp.createListener((socket) => {
|
||||
console.log('new connection opened')
|
||||
@ -56,6 +60,7 @@ const listener = tcp.createListener((socket) => {
|
||||
)
|
||||
})
|
||||
|
||||
const addr = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
||||
await listener.listen(addr)
|
||||
console.log('listening')
|
||||
|
||||
|
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "libp2p-tcp",
|
||||
"version": "0.14.0",
|
||||
"version": "0.14.1",
|
||||
"description": "Node.js implementation of the TCP module that libp2p uses, which implements the interface-connection and interface-transport interfaces",
|
||||
"leadMaintainer": "Jacob Heun <jacobheun@gmail.com>",
|
||||
"main": "src/index.js",
|
||||
@ -36,7 +36,7 @@
|
||||
"aegir": "^20.0.0",
|
||||
"chai": "^4.2.0",
|
||||
"dirty-chai": "^2.0.1",
|
||||
"interface-transport": "^0.6.1",
|
||||
"interface-transport": "^0.7.0",
|
||||
"sinon": "^7.3.1"
|
||||
},
|
||||
"dependencies": {
|
||||
@ -45,7 +45,7 @@
|
||||
"debug": "^4.1.1",
|
||||
"err-code": "^2.0.0",
|
||||
"ip-address": "^6.1.0",
|
||||
"mafmt": "^6.0.9",
|
||||
"mafmt": "^7.0.0",
|
||||
"multiaddr": "^7.1.0",
|
||||
"stream-to-it": "^0.1.1"
|
||||
},
|
||||
|
@ -79,5 +79,14 @@ module.exports = (socket, options) => {
|
||||
}
|
||||
}
|
||||
|
||||
socket.once('close', () => {
|
||||
// In instances where `close` was not explicitly called,
|
||||
// such as an iterable stream ending, ensure we have set the close
|
||||
// timeline
|
||||
if (!maConn.timeline.close) {
|
||||
maConn.timeline.close = Date.now()
|
||||
}
|
||||
})
|
||||
|
||||
return maConn
|
||||
}
|
||||
|
@ -14,8 +14,7 @@ describe('interface-transport compliance', () => {
|
||||
const addrs = [
|
||||
multiaddr('/ip4/127.0.0.1/tcp/9091'),
|
||||
multiaddr('/ip4/127.0.0.1/tcp/9092'),
|
||||
multiaddr('/ip4/127.0.0.1/tcp/9093'),
|
||||
multiaddr('/dns4/ipfs.io')
|
||||
multiaddr('/ip4/127.0.0.1/tcp/9093')
|
||||
]
|
||||
|
||||
// Used by the dial tests to simulate a delayed connect
|
||||
|
Reference in New Issue
Block a user