mirror of
https://github.com/fluencelabs/js-peer-id
synced 2025-07-04 15:41:33 +00:00
Compare commits
8 Commits
Author | SHA1 | Date | |
---|---|---|---|
af6575d06c | |||
ccf0b7875c | |||
733b40bb47 | |||
ac27907241 | |||
e206c46549 | |||
41d3e5be5b | |||
bc213dd818 | |||
3f4f670691 |
@ -203,6 +203,9 @@ Returns an `obj` of the form
|
||||
|
||||
Alias for `.toJSON()`.
|
||||
|
||||
### `isEqual(id)`
|
||||
|
||||
- `id` can be a PeerId or a Buffer containing the id
|
||||
|
||||
# License
|
||||
|
||||
|
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "peer-id",
|
||||
"version": "0.8.5",
|
||||
"version": "0.8.7",
|
||||
"description": "IPFS Peer Id implementation in Node.js",
|
||||
"main": "src/index.js",
|
||||
"bin": "src/bin.js",
|
||||
@ -40,7 +40,7 @@
|
||||
"pre-commit": "^1.2.2"
|
||||
},
|
||||
"dependencies": {
|
||||
"async": "^2.2.0",
|
||||
"async": "^2.3.0",
|
||||
"libp2p-crypto": "~0.8.7",
|
||||
"lodash": "^4.17.4",
|
||||
"multihashes": "~0.4.5"
|
||||
|
53
src/index.js
53
src/index.js
@ -35,26 +35,32 @@ class PeerId {
|
||||
return this._privKey
|
||||
}
|
||||
|
||||
set privKey (privKey) {
|
||||
this._privKey = privKey
|
||||
}
|
||||
|
||||
get pubKey () {
|
||||
if (this._pubKey) {
|
||||
return this._pubKey
|
||||
}
|
||||
|
||||
if (this.privKey) {
|
||||
return this.privKey.public
|
||||
if (this._privKey) {
|
||||
return this._privKey.public
|
||||
}
|
||||
}
|
||||
|
||||
// Return the protobuf version of the public key,
|
||||
// matching go ipfs formatting
|
||||
set pubKey (pubKey) {
|
||||
this._pubKey = pubKey
|
||||
}
|
||||
|
||||
// Return the protobuf version of the public key, matching go ipfs formatting
|
||||
marshalPubKey () {
|
||||
if (this.pubKey) {
|
||||
return crypto.marshalPublicKey(this.pubKey)
|
||||
}
|
||||
}
|
||||
|
||||
// Return the protobuf version of the private key,
|
||||
// matching go ipfs formatting
|
||||
// Return the protobuf version of the private key, matching go ipfs formatting
|
||||
marshalPrivKey () {
|
||||
if (this.privKey) {
|
||||
return crypto.marshalPrivateKey(this.privKey)
|
||||
@ -88,6 +94,32 @@ class PeerId {
|
||||
toB58String () {
|
||||
return this._idB58String
|
||||
}
|
||||
|
||||
isEqual (id) {
|
||||
if (Buffer.isBuffer(id)) {
|
||||
return this.id.equals(id)
|
||||
} else if (id.id) {
|
||||
return this.id.equals(id.id)
|
||||
} else {
|
||||
throw new Error('not valid Id')
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
* Check if this PeerId instance is valid (privKey -> pubKey -> Id)
|
||||
*/
|
||||
isValid (callback) {
|
||||
// TODO Needs better checking
|
||||
if (this.privKey &&
|
||||
this.privKey.public &&
|
||||
this.privKey.public.bytes &&
|
||||
Buffer.isBuffer(this.pubKey.bytes) &&
|
||||
this.privKey.public.bytes.equals(this.pubKey.bytes)) {
|
||||
callback()
|
||||
} else {
|
||||
callback(new Error('Keys not match'))
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
exports = module.exports = PeerId
|
||||
@ -129,16 +161,17 @@ exports.createFromB58String = function (str) {
|
||||
|
||||
// Public Key input will be a buffer
|
||||
exports.createFromPubKey = function (key, callback) {
|
||||
if (typeof callback !== 'function') {
|
||||
throw new Error('callback is required')
|
||||
}
|
||||
|
||||
let buf = key
|
||||
if (typeof buf === 'string') {
|
||||
buf = new Buffer(key, 'base64')
|
||||
}
|
||||
|
||||
if (typeof callback !== 'function') {
|
||||
throw new Error('callback is required')
|
||||
}
|
||||
|
||||
const pubKey = crypto.unmarshalPublicKey(buf)
|
||||
|
||||
pubKey.hash((err, digest) => {
|
||||
if (err) {
|
||||
return callback(err)
|
||||
|
@ -129,6 +129,20 @@ describe('PeerId', () => {
|
||||
expect(id.toBytes().toString('hex')).to.equal(testIdBytes.toString('hex'))
|
||||
})
|
||||
|
||||
it('isEqual', (done) => {
|
||||
parallel([
|
||||
(cb) => PeerId.create(cb),
|
||||
(cb) => PeerId.create(cb)
|
||||
], (err, ids) => {
|
||||
expect(err).to.not.exist()
|
||||
expect(ids[0].isEqual(ids[0])).to.equal(true)
|
||||
expect(ids[0].isEqual(ids[1])).to.equal(false)
|
||||
expect(ids[0].isEqual(ids[0].id)).to.equal(true)
|
||||
expect(ids[0].isEqual(ids[1].id)).to.equal(false)
|
||||
done()
|
||||
})
|
||||
})
|
||||
|
||||
describe('fromJSON', () => {
|
||||
it('full node', (done) => {
|
||||
PeerId.create({ bits: 1024 }, (err, id) => {
|
||||
@ -183,17 +197,56 @@ describe('PeerId', () => {
|
||||
})
|
||||
})
|
||||
|
||||
it('set privKey (valid)', (done) => {
|
||||
PeerId.create((err, peerId) => {
|
||||
expect(err).to.not.exist()
|
||||
peerId.privKey = peerId._privKey
|
||||
peerId.isValid(done)
|
||||
})
|
||||
})
|
||||
|
||||
it('set pubKey (valid)', (done) => {
|
||||
PeerId.create((err, peerId) => {
|
||||
expect(err).to.not.exist()
|
||||
peerId.pubKey = peerId._pubKey
|
||||
peerId.isValid(done)
|
||||
})
|
||||
})
|
||||
|
||||
it('set privKey (invalid)', (done) => {
|
||||
PeerId.create((err, peerId) => {
|
||||
expect(err).to.not.exist()
|
||||
peerId.privKey = new Buffer('bufff')
|
||||
peerId.isValid((err) => {
|
||||
expect(err).to.exist()
|
||||
done()
|
||||
})
|
||||
})
|
||||
})
|
||||
|
||||
it('set pubKey (invalid)', (done) => {
|
||||
PeerId.create((err, peerId) => {
|
||||
expect(err).to.not.exist()
|
||||
peerId.pubKey = new Buffer('buffff')
|
||||
peerId.isValid((err) => {
|
||||
expect(err).to.exist()
|
||||
done()
|
||||
})
|
||||
})
|
||||
})
|
||||
|
||||
describe('throws on inconsistent data', () => {
|
||||
let k1, k2, k3
|
||||
let k1
|
||||
let k2
|
||||
let k3
|
||||
|
||||
before((done) => {
|
||||
parallel([
|
||||
(cb) => crypto.generateKeyPair('RSA', 1024, cb),
|
||||
(cb) => crypto.generateKeyPair('RSA', 1024, cb),
|
||||
(cb) => crypto.generateKeyPair('RSA', 1024, cb)
|
||||
], (err, keys) => {
|
||||
if (err) {
|
||||
return done(err)
|
||||
}
|
||||
expect(err).to.not.exist()
|
||||
|
||||
k1 = keys[0]
|
||||
k2 = keys[1]
|
||||
@ -205,11 +258,8 @@ describe('PeerId', () => {
|
||||
it('missmatch private - public key', (done) => {
|
||||
k1.public.hash((err, digest) => {
|
||||
expect(err).to.not.exist()
|
||||
expect(
|
||||
() => new PeerId(digest, k1, k2.public)
|
||||
).to.throw(
|
||||
/inconsistent arguments/
|
||||
)
|
||||
expect(() => new PeerId(digest, k1, k2.public))
|
||||
.to.throw(/inconsistent arguments/)
|
||||
done()
|
||||
})
|
||||
})
|
||||
@ -217,11 +267,8 @@ describe('PeerId', () => {
|
||||
it('missmatch id - private - public key', (done) => {
|
||||
k1.public.hash((err, digest) => {
|
||||
expect(err).to.not.exist()
|
||||
expect(
|
||||
() => new PeerId(digest, k1, k3.public)
|
||||
).to.throw(
|
||||
/inconsistent arguments/
|
||||
)
|
||||
expect(() => new PeerId(digest, k1, k3.public))
|
||||
.to.throw(/inconsistent arguments/)
|
||||
done()
|
||||
})
|
||||
})
|
Reference in New Issue
Block a user