mirror of
https://github.com/fluencelabs/js-libp2p-tcp
synced 2025-07-02 00:41:34 +00:00
Compare commits
3 Commits
api-docs-r
...
v0.13.0
Author | SHA1 | Date | |
---|---|---|---|
3aad2ed243 | |||
01cfbda2e7 | |||
eba0b48744 |
@ -26,5 +26,4 @@ build/Release
|
||||
# https://www.npmjs.org/doc/misc/npm-faq.html#should-i-check-my-node_modules-folder-into-git
|
||||
node_modules
|
||||
|
||||
test
|
||||
docs
|
||||
test
|
10
CHANGELOG.md
10
CHANGELOG.md
@ -1,3 +1,13 @@
|
||||
<a name="0.13.0"></a>
|
||||
# [0.13.0](https://github.com/libp2p/js-libp2p-tcp/compare/v0.12.1...v0.13.0) (2018-09-12)
|
||||
|
||||
|
||||
### Features
|
||||
|
||||
* add support for dialing over dns ([eba0b48](https://github.com/libp2p/js-libp2p-tcp/commit/eba0b48))
|
||||
|
||||
|
||||
|
||||
<a name="0.12.1"></a>
|
||||
## [0.12.1](https://github.com/libp2p/js-libp2p-tcp/compare/v0.12.0...v0.12.1) (2018-07-31)
|
||||
|
||||
|
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "libp2p-tcp",
|
||||
"version": "0.12.1",
|
||||
"version": "0.13.0",
|
||||
"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",
|
||||
@ -39,7 +39,7 @@
|
||||
"dirty-chai": "^2.0.1",
|
||||
"interface-transport": "~0.3.6",
|
||||
"lodash.isfunction": "^3.0.9",
|
||||
"pull-stream": "^3.6.7"
|
||||
"pull-stream": "^3.6.9"
|
||||
},
|
||||
"dependencies": {
|
||||
"class-is": "^1.1.0",
|
||||
@ -48,8 +48,8 @@
|
||||
"ip-address": "^5.8.9",
|
||||
"lodash.includes": "^4.3.0",
|
||||
"lodash.isfunction": "^3.0.9",
|
||||
"mafmt": "^6.0.0",
|
||||
"multiaddr": "^4.0.0",
|
||||
"mafmt": "^6.0.2",
|
||||
"multiaddr": "^5.0.0",
|
||||
"once": "^1.4.0",
|
||||
"stream-to-pull-stream": "^1.7.2"
|
||||
},
|
||||
|
25
src/index.js
25
src/index.js
@ -15,18 +15,7 @@ const createListener = require('./listener')
|
||||
|
||||
function noop () {}
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
class TCP {
|
||||
/**
|
||||
* Dial to another peer.
|
||||
*
|
||||
* @param {Multiaddr} ma - The address of the peer we want to dial to.
|
||||
* @param {Object} [options={}]
|
||||
* @param {function(Error?, Array<Multiaddr>?)} [callback]
|
||||
* @returns {Connection}
|
||||
*/
|
||||
dial (ma, options, callback) {
|
||||
if (isFunction(options)) {
|
||||
callback = options
|
||||
@ -63,13 +52,6 @@ class TCP {
|
||||
return conn
|
||||
}
|
||||
|
||||
/**
|
||||
* Listen for incoming `TCP` connetions.
|
||||
*
|
||||
* @param {Object} [options={}]
|
||||
* @param {function(Connection)} [handler] - Called with newly incomin connections.
|
||||
* @returns {Listener}
|
||||
*/
|
||||
createListener (options, handler) {
|
||||
if (isFunction(options)) {
|
||||
handler = options
|
||||
@ -81,13 +63,6 @@ class TCP {
|
||||
return createListener(handler)
|
||||
}
|
||||
|
||||
/**
|
||||
* Filter a list of multiaddrs for those which contain
|
||||
* valid `TCP` addresses.
|
||||
*
|
||||
* @param {Multiaddr|Array<Multiaddr>} multiaddrs
|
||||
* @returns {Array<Multiaddr>}
|
||||
*/
|
||||
filter (multiaddrs) {
|
||||
if (!Array.isArray(multiaddrs)) {
|
||||
multiaddrs = [multiaddrs]
|
||||
|
@ -17,49 +17,7 @@ const CLOSE_TIMEOUT = 2000
|
||||
|
||||
function noop () {}
|
||||
|
||||
/**
|
||||
* Listening for incoming connections.
|
||||
*
|
||||
* @event listening
|
||||
* @instance
|
||||
* @memberof Listener
|
||||
*/
|
||||
|
||||
/**
|
||||
* The server closes.
|
||||
*
|
||||
* @event close
|
||||
* @instance
|
||||
* @memberof Listener
|
||||
*/
|
||||
|
||||
/**
|
||||
* New connection established.
|
||||
*
|
||||
* @event connection
|
||||
* @instance
|
||||
* @type {Connection}
|
||||
* @memberof Listener
|
||||
*/
|
||||
|
||||
/**
|
||||
* The underlying server encountered an error.
|
||||
*
|
||||
* @event error
|
||||
* @instance
|
||||
* @type {Error}
|
||||
* @memberof Listener
|
||||
*/
|
||||
|
||||
module.exports = (handler) => {
|
||||
/**
|
||||
* @alias Listener
|
||||
* @type {Eventemitter}
|
||||
* @fires Listener#listening
|
||||
* @fires Listener#close
|
||||
* @fires Listener#connection
|
||||
* @fires Listener#error
|
||||
*/
|
||||
const listener = new EventEmitter()
|
||||
|
||||
const server = net.createServer((socket) => {
|
||||
|
@ -12,7 +12,8 @@ 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('/ip4/127.0.0.1/tcp/9093'),
|
||||
multiaddr('/dns4/ipfs.io')
|
||||
]
|
||||
cb(null, tcp, addrs)
|
||||
},
|
||||
|
@ -25,9 +25,11 @@ describe('filter addrs', () => {
|
||||
const ma4 = multiaddr(base + '/tcp/9090/ipfs/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
||||
const ma5 = multiaddr(base + '/tcp/9090/http' + ipfs)
|
||||
const ma6 = multiaddr('/ip4/127.0.0.1/tcp/9090/p2p-circuit' + ipfs)
|
||||
const ma7 = multiaddr('/dns4/libp2p.io/tcp/9090')
|
||||
const ma8 = multiaddr('/dnsaddr/libp2p.io/tcp/9090')
|
||||
|
||||
const valid = tcp.filter([ma1, ma2, ma3, ma4, ma5, ma6])
|
||||
expect(valid.length).to.equal(2)
|
||||
const valid = tcp.filter([ma1, ma2, ma3, ma4, ma5, ma6, ma7, ma8])
|
||||
expect(valid.length).to.equal(4)
|
||||
expect(valid[0]).to.deep.equal(ma1)
|
||||
expect(valid[1]).to.deep.equal(ma4)
|
||||
})
|
||||
|
Reference in New Issue
Block a user