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

Merge pull request #6 from diasdavid/feature/filter-addrs

Browse Source 
add filter feature
This commit is contained in:
David Dias 2016-03-14 17:00:37 +00:00
commit c3b5c132c0
4 changed files with 29 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
README.md
View File

@ -1,11 +1,16 @@
js-libp2p-tcp js-libp2p-tcp
=============== ===============
[![](https://img.shields.io/badge/made%20by-Protocol%20Labs-blue.svg?style=flat-square)](http://ipn.io) [[![](https://img.shields.io/badge/freenode-%23ipfs-blue.svg?style=flat-square)](http://webchat.freenode.net/?channels=%23ipfs) ![Build Status](https://travis-ci.org/diasdavid/js-libp2p-tcp.svg?style=flat-square)](https://travis-ci.org/diasdavid/js-libp2p-tcp) ![](https://img.shields.io/badge/coverage-%3F-yellow.svg?style=flat-square) [![Dependency Status](https://david-dm.org/diasdavid/js-libp2p-tcp.svg?style=flat-square)](https://david-dm.org/diasdavid/js-libp2p-tcp) [![js-standard-style](https://img.shields.io/badge/code%20style-standard-brightgreen.svg?style=flat-square)](https://github.com/feross/standard) [![](https://img.shields.io/badge/made%20by-Protocol%20Labs-blue.svg?style=flat-square)](http://ipn.io)
[![](https://img.shields.io/badge/freenode-%23ipfs-blue.svg?style=flat-square)](http://webchat.freenode.net/?channels=%23ipfs)
[![Build Status](https://travis-ci.org/diasdavid/js-libp2p-tcp.svg?style=flat-square)](https://travis-ci.org/diasdavid/js-libp2p-tcp)
![](https://img.shields.io/badge/coverage-%3F-yellow.svg?style=flat-square)
[![Dependency Status](https://david-dm.org/diasdavid/js-libp2p-tcp.svg?style=flat-square)](https://david-dm.org/diasdavid/js-libp2p-tcp)
[![js-standard-style](https://img.shields.io/badge/code%20style-standard-brightgreen.svg?style=flat-square)](https://github.com/feross/standard)
![](https://raw.githubusercontent.com/diasdavid/abstract-connection/master/img/badge.png) ![](https://raw.githubusercontent.com/diasdavid/abstract-connection/master/img/badge.png)
![](https://raw.githubusercontent.com/diasdavid/abstract-transport/master/img/badge.png) ![](https://raw.githubusercontent.com/diasdavid/abstract-transport/master/img/badge.png)
> Node.js implementation of the TCP module that libp2p uses, which implements the [abstract-connection]() interface for dial/listen. > Node.js implementation of the TCP module that libp2p uses, which implements the [interface-connection]() interface for dial/listen.
note: libp2p-tcp in Node.js is a very thin shim that adds the support to dial to a `multiaddr`. This small shim will enable libp2p to use other different transports. note: libp2p-tcp in Node.js is a very thin shim that adds the support to dial to a `multiaddr`. This small shim will enable libp2p to use other different transports.

1
package.json
View File

@ -40,6 +40,7 @@
}, },
"dependencies": { "dependencies": {
"ip-address": "^5.8.0", "ip-address": "^5.8.0",
"mafmt": "^1.0.1",
"multiaddr": "^1.1.1" "multiaddr": "^1.1.1"
} }
} }

10
src/index.js
View File

@ -3,6 +3,7 @@
const tcp = require('net') const tcp = require('net')
const multiaddr = require('multiaddr') const multiaddr = require('multiaddr')
const Address6 = require('ip-address').Address6 const Address6 = require('ip-address').Address6
const mafmt = require('mafmt')
exports = module.exports = TCP exports = module.exports = TCP
@ -79,6 +80,15 @@ function TCP () {
}) })
}) })
} }
this.filter = (multiaddrs) => {
if (!Array.isArray(multiaddrs)) {
multiaddrs = [multiaddrs]
}
return multiaddrs.filter((ma) => {
return mafmt.TCP.matches(ma)
})
}
} }
function getMultiaddr (conn) { function getMultiaddr (conn) {

11
tests/libp2p-tcp-test.js
View File

@ -77,5 +77,16 @@ describe('libp2p-tcp', function () {
}) })
}) })
it('filter valid addrs for this transport', (done) => {
const mh1 = multiaddr('/ip4/127.0.0.1/tcp/9090')
const mh2 = multiaddr('/ip4/127.0.0.1/udp/9090')
const mh3 = multiaddr('/ip4/127.0.0.1/tcp/9090/http')
const valid = tcp.filter([mh1, mh2, mh3])
expect(valid.length).to.equal(1)
expect(valid[0]).to.deep.equal(mh1)
done()
})
it.skip('listen on IPv6', (done) => {}) it.skip('listen on IPv6', (done) => {})
}) })