mirror of
https://github.com/fluencelabs/js-libp2p
synced 2025-07-09 05:41:33 +00:00
Compare commits
6 Commits
Author | SHA1 | Date | |
---|---|---|---|
66c8adb8bc | |||
d0c68f63fe | |||
6a1e6493cb | |||
89ed15e9d9 | |||
f3ee2f069b | |||
01f8ee1574 |
43
.travis.yml
Normal file
43
.travis.yml
Normal file
@ -0,0 +1,43 @@
|
|||||||
|
language: node_js
|
||||||
|
cache: npm
|
||||||
|
stages:
|
||||||
|
- check
|
||||||
|
- test
|
||||||
|
- cov
|
||||||
|
|
||||||
|
node_js:
|
||||||
|
- '10'
|
||||||
|
|
||||||
|
os:
|
||||||
|
- linux
|
||||||
|
- osx
|
||||||
|
|
||||||
|
script: npx nyc -s npm run test:node -- --bail
|
||||||
|
after_success: npx nyc report --reporter=text-lcov > coverage.lcov && npx codecov
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
include:
|
||||||
|
- os: windows
|
||||||
|
cache: false
|
||||||
|
|
||||||
|
- stage: check
|
||||||
|
script:
|
||||||
|
- npx aegir commitlint --travis
|
||||||
|
- npx aegir dep-check
|
||||||
|
- npm run lint
|
||||||
|
|
||||||
|
- stage: test
|
||||||
|
name: chrome
|
||||||
|
addons:
|
||||||
|
chrome: stable
|
||||||
|
script: npx aegir test -t browser -t webworker
|
||||||
|
|
||||||
|
- stage: test
|
||||||
|
name: firefox
|
||||||
|
addons:
|
||||||
|
firefox: latest
|
||||||
|
script: npx aegir test -t browser -t webworker -- --browsers FirefoxHeadless
|
||||||
|
|
||||||
|
notifications:
|
||||||
|
email: false
|
||||||
|
|
10
CHANGELOG.md
10
CHANGELOG.md
@ -1,3 +1,13 @@
|
|||||||
|
<a name="0.7.6"></a>
|
||||||
|
## [0.7.6](https://github.com/libp2p/js-libp2p-identify/compare/v0.7.5...v0.7.6) (2019-03-20)
|
||||||
|
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* add protocol support to identify ([#51](https://github.com/libp2p/js-libp2p-identify/issues/51)) ([89ed15e](https://github.com/libp2p/js-libp2p-identify/commit/89ed15e))
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
<a name="0.7.5"></a>
|
<a name="0.7.5"></a>
|
||||||
## [0.7.5](https://github.com/libp2p/js-libp2p-identify/compare/v0.7.4...v0.7.5) (2019-01-10)
|
## [0.7.5](https://github.com/libp2p/js-libp2p-identify/compare/v0.7.4...v0.7.5) (2019-01-10)
|
||||||
|
|
||||||
|
15
README.md
15
README.md
@ -1,15 +1,14 @@
|
|||||||
# js-libp2p-identify
|
# js-libp2p-identify
|
||||||
|
|
||||||
[](http://ipn.io)
|
[](http://protocol.ai)
|
||||||
[](http://ipfs.io/)
|
[](http://libp2p.io/)
|
||||||
[](http://webchat.freenode.net/?channels=%23ipfs)
|
[](http://webchat.freenode.net/?channels=%23libp2p)
|
||||||
[](https://coveralls.io/github/libp2p/js-libp2p-identify?branch=master)
|
[](https://codecov.io/gh/libp2p/js-libp2p-identify)
|
||||||
[](https://travis-ci.org/libp2p/js-libp2p-identify)
|
[](https://travis-ci.com/libp2p/js-libp2p-identify)
|
||||||
[](https://circleci.com/gh/libp2p/js-libp2p-identify)
|
|
||||||
[](https://david-dm.org/libp2p/js-libp2p-identify)
|
[](https://david-dm.org/libp2p/js-libp2p-identify)
|
||||||
[](https://github.com/feross/standard)
|
[](https://github.com/feross/standard)
|
||||||

|

|
||||||

|

|
||||||
|
|
||||||
> libp2p Identify Protocol
|
> libp2p Identify Protocol
|
||||||
|
|
||||||
|
2
ci/Jenkinsfile
vendored
2
ci/Jenkinsfile
vendored
@ -1,2 +0,0 @@
|
|||||||
// Warning: This file is automatically synced from https://github.com/ipfs/ci-sync so if you want to change it, please change it there and ask someone to sync all repositories.
|
|
||||||
javascript()
|
|
11
package.json
11
package.json
@ -1,9 +1,13 @@
|
|||||||
{
|
{
|
||||||
"name": "libp2p-identify",
|
"name": "libp2p-identify",
|
||||||
"version": "0.7.5",
|
"version": "0.7.6",
|
||||||
"description": "libp2p Identify Protocol",
|
"description": "libp2p Identify Protocol",
|
||||||
"leadMaintainer": "Jacob Heun <jacobheun@gmail.com>",
|
"leadMaintainer": "Jacob Heun <jacobheun@gmail.com>",
|
||||||
"main": "src/index.js",
|
"main": "src/index.js",
|
||||||
|
"files": [
|
||||||
|
"dist",
|
||||||
|
"src"
|
||||||
|
],
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"lint": "aegir lint",
|
"lint": "aegir lint",
|
||||||
"build": "aegir build",
|
"build": "aegir build",
|
||||||
@ -37,13 +41,13 @@
|
|||||||
},
|
},
|
||||||
"homepage": "https://github.com/libp2p/js-libp2p-identify#readme",
|
"homepage": "https://github.com/libp2p/js-libp2p-identify#readme",
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"aegir": "^18.0.3",
|
"aegir": "^18.1.0",
|
||||||
"chai": "^4.2.0",
|
"chai": "^4.2.0",
|
||||||
"dirty-chai": "^2.0.1",
|
"dirty-chai": "^2.0.1",
|
||||||
"pull-pair": "^1.1.0"
|
"pull-pair": "^1.1.0"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"multiaddr": "^6.0.3",
|
"multiaddr": "^6.0.4",
|
||||||
"peer-id": "~0.12.2",
|
"peer-id": "~0.12.2",
|
||||||
"peer-info": "~0.15.1",
|
"peer-info": "~0.15.1",
|
||||||
"protons": "^1.0.1",
|
"protons": "^1.0.1",
|
||||||
@ -60,6 +64,7 @@
|
|||||||
"Maciej Krüger <mkg20001@gmail.com>",
|
"Maciej Krüger <mkg20001@gmail.com>",
|
||||||
"Richard Littauer <richard.littauer@gmail.com>",
|
"Richard Littauer <richard.littauer@gmail.com>",
|
||||||
"Vasco Santos <vasco.santos@moxy.studio>",
|
"Vasco Santos <vasco.santos@moxy.studio>",
|
||||||
|
"Yusef Napora <yusef@protocol.ai>",
|
||||||
"ᴠɪᴄᴛᴏʀ ʙᴊᴇʟᴋʜᴏʟᴍ <victorbjelkholm@gmail.com>"
|
"ᴠɪᴄᴛᴏʀ ʙᴊᴇʟᴋʜᴏʟᴍ <victorbjelkholm@gmail.com>"
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
|
@ -58,6 +58,9 @@ module.exports = (conn, expectedPeerInfo, callback) => {
|
|||||||
return callback(err)
|
return callback(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Copy the protocols
|
||||||
|
peerInfo.protocols = new Set(input.protocols)
|
||||||
|
|
||||||
callback(null, peerInfo, observedAddr)
|
callback(null, peerInfo, observedAddr)
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
@ -22,7 +22,8 @@ module.exports = (conn, pInfoSelf) => {
|
|||||||
agentVersion: 'na',
|
agentVersion: 'na',
|
||||||
publicKey: publicKey,
|
publicKey: publicKey,
|
||||||
listenAddrs: pInfoSelf.multiaddrs.toArray().map((ma) => ma.buffer),
|
listenAddrs: pInfoSelf.multiaddrs.toArray().map((ma) => ma.buffer),
|
||||||
observedAddr: observedAddrs ? observedAddrs.buffer : Buffer.from('')
|
observedAddr: observedAddrs ? observedAddrs.buffer : Buffer.from(''),
|
||||||
|
protocols: Array.from(pInfoSelf.protocols)
|
||||||
})
|
})
|
||||||
|
|
||||||
pull(
|
pull(
|
||||||
|
@ -33,12 +33,16 @@ describe('identify.dialer', () => {
|
|||||||
it('works', (done) => {
|
it('works', (done) => {
|
||||||
const p = pair()
|
const p = pair()
|
||||||
original.multiaddrs.add(multiaddr('/ip4/127.0.0.1/tcp/5002'))
|
original.multiaddrs.add(multiaddr('/ip4/127.0.0.1/tcp/5002'))
|
||||||
|
original.protocols.add('/echo/1.0.0')
|
||||||
|
original.protocols.add('/ping/1.0.0')
|
||||||
|
|
||||||
const input = msg.encode({
|
const input = msg.encode({
|
||||||
protocolVersion: 'ipfs/0.1.0',
|
protocolVersion: 'ipfs/0.1.0',
|
||||||
agentVersion: 'na',
|
agentVersion: 'na',
|
||||||
publicKey: original.id.pubKey.bytes,
|
publicKey: original.id.pubKey.bytes,
|
||||||
listenAddrs: [multiaddr('/ip4/127.0.0.1/tcp/5002').buffer],
|
listenAddrs: [multiaddr('/ip4/127.0.0.1/tcp/5002').buffer],
|
||||||
observedAddr: multiaddr('/ip4/127.0.0.1/tcp/5001').buffer
|
observedAddr: multiaddr('/ip4/127.0.0.1/tcp/5001').buffer,
|
||||||
|
protocols: Array.from(original.protocols)
|
||||||
})
|
})
|
||||||
|
|
||||||
pull(
|
pull(
|
||||||
@ -58,6 +62,44 @@ describe('identify.dialer', () => {
|
|||||||
expect(observedAddrs)
|
expect(observedAddrs)
|
||||||
.to.eql([multiaddr('/ip4/127.0.0.1/tcp/5001')])
|
.to.eql([multiaddr('/ip4/127.0.0.1/tcp/5001')])
|
||||||
|
|
||||||
|
expect(info.protocols).to.eql(original.protocols)
|
||||||
|
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('should handle missing protocols', (done) => {
|
||||||
|
const p = pair()
|
||||||
|
original.multiaddrs.add(multiaddr('/ip4/127.0.0.1/tcp/5002'))
|
||||||
|
|
||||||
|
const input = msg.encode({
|
||||||
|
protocolVersion: 'ipfs/0.1.0',
|
||||||
|
agentVersion: 'na',
|
||||||
|
publicKey: original.id.pubKey.bytes,
|
||||||
|
listenAddrs: [multiaddr('/ip4/127.0.0.1/tcp/5002').buffer],
|
||||||
|
observedAddr: multiaddr('/ip4/127.0.0.1/tcp/5001').buffer,
|
||||||
|
protocols: Array.from(original.protocols)
|
||||||
|
})
|
||||||
|
|
||||||
|
pull(
|
||||||
|
values([input]),
|
||||||
|
lp.encode(),
|
||||||
|
p[0]
|
||||||
|
)
|
||||||
|
|
||||||
|
identify.dialer(p[1], (err, info, observedAddrs) => {
|
||||||
|
expect(err).to.not.exist()
|
||||||
|
expect(info.id.pubKey.bytes)
|
||||||
|
.to.eql(original.id.pubKey.bytes)
|
||||||
|
|
||||||
|
expect(info.multiaddrs.toArray())
|
||||||
|
.to.eql(original.multiaddrs.toArray())
|
||||||
|
|
||||||
|
expect(observedAddrs)
|
||||||
|
.to.eql([multiaddr('/ip4/127.0.0.1/tcp/5001')])
|
||||||
|
|
||||||
|
expect(Array.from(info.protocols)).to.eql([])
|
||||||
|
|
||||||
done()
|
done()
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
@ -26,6 +26,9 @@ describe('identify.listener', () => {
|
|||||||
return done(err)
|
return done(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
_info.protocols.add('/echo/1.0.0')
|
||||||
|
_info.protocols.add('/chat/1.0.0')
|
||||||
|
|
||||||
info = _info
|
info = _info
|
||||||
done()
|
done()
|
||||||
})
|
})
|
||||||
@ -51,7 +54,7 @@ describe('identify.listener', () => {
|
|||||||
publicKey: info.id.pubKey.bytes,
|
publicKey: info.id.pubKey.bytes,
|
||||||
listenAddrs: [multiaddr('/ip4/127.0.0.1/tcp/5002').buffer],
|
listenAddrs: [multiaddr('/ip4/127.0.0.1/tcp/5002').buffer],
|
||||||
observedAddr: multiaddr('/ip4/127.0.0.1/tcp/5001').buffer,
|
observedAddr: multiaddr('/ip4/127.0.0.1/tcp/5001').buffer,
|
||||||
protocols: []
|
protocols: ['/echo/1.0.0', '/chat/1.0.0']
|
||||||
})
|
})
|
||||||
done()
|
done()
|
||||||
})
|
})
|
||||||
|
Reference in New Issue
Block a user