mirror of
https://github.com/fluencelabs/js-peer-id
synced 2025-07-04 23:11:50 +00:00
Compare commits
23 Commits
Author | SHA1 | Date | |
---|---|---|---|
fc9698476f | |||
ffe04c12a0 | |||
65e0b746a5 | |||
74cdb24544 | |||
b5335cd4ee | |||
519052693d | |||
bbf0416f08 | |||
4fbf859efc | |||
52bd949b43 | |||
544ca7d74b | |||
11d4ec10bd | |||
4d5bb2cfff | |||
a2ac32ac0f | |||
ed211a943b | |||
8ea480a3b0 | |||
f39fb24321 | |||
911aa634d3 | |||
94aa3483b3 | |||
1f1f86f576 | |||
76864184da | |||
f50b2ac016 | |||
6754752b05 | |||
17440a3f9a |
@ -22,7 +22,6 @@ jobs:
|
|||||||
|
|
||||||
- stage: check
|
- stage: check
|
||||||
script:
|
script:
|
||||||
- npx aegir commitlint --travis
|
|
||||||
- npx aegir dep-check
|
- npx aegir dep-check
|
||||||
- npm run lint
|
- npm run lint
|
||||||
|
|
||||||
|
65
CHANGELOG.md
65
CHANGELOG.md
@ -1,3 +1,68 @@
|
|||||||
|
<a name="0.13.6"></a>
|
||||||
|
## [0.13.6](https://github.com/libp2p/js-peer-id/compare/v0.13.5...v0.13.6) (2019-12-18)
|
||||||
|
|
||||||
|
|
||||||
|
### Bug Fixes
|
||||||
|
|
||||||
|
* catch errors thrown by multihash decode ([#109](https://github.com/libp2p/js-peer-id/issues/109)) ([65e0b74](https://github.com/libp2p/js-peer-id/commit/65e0b74))
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
<a name="0.13.5"></a>
|
||||||
|
## [0.13.5](https://github.com/libp2p/js-peer-id/compare/v0.13.4...v0.13.5) (2019-11-12)
|
||||||
|
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* deprecate isEqual in favor of equals ([#107](https://github.com/libp2p/js-peer-id/issues/107)) ([bbf0416](https://github.com/libp2p/js-peer-id/commit/bbf0416))
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
<a name="0.13.4"></a>
|
||||||
|
## [0.13.4](https://github.com/libp2p/js-peer-id/compare/v0.13.3...v0.13.4) (2019-11-04)
|
||||||
|
|
||||||
|
|
||||||
|
### Bug Fixes
|
||||||
|
|
||||||
|
* bang in bin.js ([#106](https://github.com/libp2p/js-peer-id/issues/106)) ([11d4ec1](https://github.com/libp2p/js-peer-id/commit/11d4ec1))
|
||||||
|
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* support Peer ID represented as CID ([#105](https://github.com/libp2p/js-peer-id/issues/105)) ([544ca7d](https://github.com/libp2p/js-peer-id/commit/544ca7d))
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
<a name="0.13.3"></a>
|
||||||
|
## [0.13.3](https://github.com/libp2p/js-peer-id/compare/v0.13.2...v0.13.3) (2019-09-25)
|
||||||
|
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* allow nested PeerIds to support pubKey function when using identity encoding ([#101](https://github.com/libp2p/js-peer-id/issues/101)) ([f39fb24](https://github.com/libp2p/js-peer-id/commit/f39fb24))
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
<a name="0.13.2"></a>
|
||||||
|
## [0.13.2](https://github.com/libp2p/js-peer-id/compare/v0.13.1...v0.13.2) (2019-07-12)
|
||||||
|
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* add compact protobuf format ([#76](https://github.com/libp2p/js-peer-id/issues/76)) ([7686418](https://github.com/libp2p/js-peer-id/commit/7686418))
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
<a name="0.13.1"></a>
|
||||||
|
## [0.13.1](https://github.com/libp2p/js-peer-id/compare/v0.13.0...v0.13.1) (2019-07-11)
|
||||||
|
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* **peerid:** support creating from secp256k1; harmonize algo with Go ([#95](https://github.com/libp2p/js-peer-id/issues/95)) ([17440a3](https://github.com/libp2p/js-peer-id/commit/17440a3))
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
<a name="0.13.0"></a>
|
<a name="0.13.0"></a>
|
||||||
# [0.13.0](https://github.com/libp2p/js-peer-id/compare/v0.12.2...v0.13.0) (2019-07-11)
|
# [0.13.0](https://github.com/libp2p/js-peer-id/compare/v0.12.2...v0.13.0) (2019-07-11)
|
||||||
|
|
||||||
|
66
README.md
66
README.md
@ -13,10 +13,13 @@
|
|||||||
|
|
||||||
## Lead Maintainer
|
## Lead Maintainer
|
||||||
|
|
||||||
[Pedro Teixeira](https://github.com/pgte)
|
[Vasco Santos](https://github.com/vasco-santos)
|
||||||
|
|
||||||
## Table of Contents
|
## Table of Contents
|
||||||
|
|
||||||
|
- [peer-id](#peer-id)
|
||||||
|
- [Lead Maintainer](#lead-maintainer)
|
||||||
|
- [Table of Contents](#table-of-contents)
|
||||||
- [Description](#description)
|
- [Description](#description)
|
||||||
- [Example](#example)
|
- [Example](#example)
|
||||||
- [Installation](#installation)
|
- [Installation](#installation)
|
||||||
@ -32,16 +35,23 @@
|
|||||||
- [Import](#import)
|
- [Import](#import)
|
||||||
- [`createFromHexString(str)`](#createfromhexstringstr)
|
- [`createFromHexString(str)`](#createfromhexstringstr)
|
||||||
- [`createFromBytes(buf)`](#createfrombytesbuf)
|
- [`createFromBytes(buf)`](#createfrombytesbuf)
|
||||||
|
- [`createFromCID(cid)`](#createfromcidcid)
|
||||||
- [`createFromB58String(str)`](#createfromb58stringstr)
|
- [`createFromB58String(str)`](#createfromb58stringstr)
|
||||||
- [`createFromPubKey(pubKey)`](#createfrompubkeypubkey)
|
- [`createFromPubKey(pubKey)`](#createfrompubkeypubkey)
|
||||||
- [`createFromPrivKey(privKey)`](#createfromprivkeyprivkey)
|
- [`createFromPrivKey(privKey)`](#createfromprivkeyprivkey)
|
||||||
- [`createFromJSON(obj)`](#createfromjsonobj)
|
- [`createFromJSON(obj)`](#createfromjsonobj)
|
||||||
|
- [`createFromProtobuf(buf)`](#createfromprotobufbuf)
|
||||||
- [Export](#export)
|
- [Export](#export)
|
||||||
- [`toHexString()`](#tohexstring)
|
- [`toHexString()`](#tohexstring)
|
||||||
- [`toBytes()`](#tobytes)
|
- [`toBytes()`](#tobytes)
|
||||||
|
- [`toString()`](#tostring)
|
||||||
- [`toB58String()`](#tob58string)
|
- [`toB58String()`](#tob58string)
|
||||||
- [`toJSON()`](#tojson)
|
- [`toJSON()`](#tojson)
|
||||||
|
- [`marshal(excludePrivateKey)`](#marshalexcludeprivatekey)
|
||||||
|
- [`marshalPubKey()`](#marshalpubkey)
|
||||||
- [`toPrint()`](#toprint)
|
- [`toPrint()`](#toprint)
|
||||||
|
- [`equals(id)`](#equalsid)
|
||||||
|
- [`isEqual(id)`](#isequalid)
|
||||||
- [License](#license)
|
- [License](#license)
|
||||||
|
|
||||||
# Description
|
# Description
|
||||||
@ -57,7 +67,7 @@ The public key is a base64 encoded string of a protobuf containing an RSA DER bu
|
|||||||
```JavaScript
|
```JavaScript
|
||||||
const PeerId = require('peer-id')
|
const PeerId = require('peer-id')
|
||||||
|
|
||||||
const id = await PeerId.create({ bits: 1024 })
|
const id = await PeerId.create({ bits: 1024, keyType: 'rsa' })
|
||||||
console.log(JSON.stringify(id.toJSON(), null, 2))
|
console.log(JSON.stringify(id.toJSON(), null, 2))
|
||||||
```
|
```
|
||||||
|
|
||||||
@ -117,7 +127,7 @@ const PeerId = require('peer-id')
|
|||||||
|
|
||||||
### `new PeerId(id[, privKey, pubKey])`
|
### `new PeerId(id[, privKey, pubKey])`
|
||||||
|
|
||||||
- `id: Buffer` - The multihash of the publick key as `Buffer`
|
- `id: Buffer` - The multihash of the public key as `Buffer`
|
||||||
- `privKey: RsaPrivateKey` - The private key
|
- `privKey: RsaPrivateKey` - The private key
|
||||||
- `pubKey: RsaPublicKey` - The public key
|
- `pubKey: RsaPublicKey` - The public key
|
||||||
|
|
||||||
@ -127,7 +137,7 @@ The key format is detailed in [libp2p-crypto](https://github.com/libp2p/js-libp2
|
|||||||
|
|
||||||
Generates a new Peer ID, complete with public/private keypair.
|
Generates a new Peer ID, complete with public/private keypair.
|
||||||
|
|
||||||
- `opts: Object`: Default: `{bits: 2048}`
|
- `opts: Object`: Default: `{bits: 2048, keyType: 'rsa'}`
|
||||||
|
|
||||||
Returns `Promise<PeerId>`.
|
Returns `Promise<PeerId>`.
|
||||||
|
|
||||||
@ -145,6 +155,14 @@ Creates a Peer ID from a buffer representing the key's multihash.
|
|||||||
|
|
||||||
Returns `PeerId`.
|
Returns `PeerId`.
|
||||||
|
|
||||||
|
### `createFromCID(cid)`
|
||||||
|
|
||||||
|
- `cid: CID|String|Buffer` - The multihash encoded as [CID](https://github.com/ipld/js-cid) (object, `String` or `Buffer`)
|
||||||
|
|
||||||
|
Creates a Peer ID from a CID representation of the key's multihash ([RFC 0001](https://github.com/libp2p/specs/blob/master/RFC/0001-text-peerid-cid.md)).
|
||||||
|
|
||||||
|
Returns `PeerId`.
|
||||||
|
|
||||||
### `createFromB58String(str)`
|
### `createFromB58String(str)`
|
||||||
|
|
||||||
Creates a Peer ID from a Base58 string representing the key's multihash.
|
Creates a Peer ID from a Base58 string representing the key's multihash.
|
||||||
@ -175,6 +193,10 @@ Returns `Promise<PeerId>`.
|
|||||||
|
|
||||||
Returns `Promise<PeerId>`.
|
Returns `Promise<PeerId>`.
|
||||||
|
|
||||||
|
### `createFromProtobuf(buf)`
|
||||||
|
|
||||||
|
`buf` is a protocol-buffers encoded PeerId (see `marshal()`)
|
||||||
|
|
||||||
## Export
|
## Export
|
||||||
|
|
||||||
### `toHexString()`
|
### `toHexString()`
|
||||||
@ -193,9 +215,18 @@ Returns the Peer ID's `id` as a buffer.
|
|||||||
<Buffer 12 20 d6 24 39 98 f2 fc 56 34 3a d7 ed 03 42 ab 78 86 a4 eb 18 d7 36 f1 b6 7d 44 b3 7f cc 81 e0 f3 9f>
|
<Buffer 12 20 d6 24 39 98 f2 fc 56 34 3a d7 ed 03 42 ab 78 86 a4 eb 18 d7 36 f1 b6 7d 44 b3 7f cc 81 e0 f3 9f>
|
||||||
```
|
```
|
||||||
|
|
||||||
|
|
||||||
|
### `toString()`
|
||||||
|
|
||||||
|
Returns the Peer ID's `id` as a self-describing CIDv1 in Base32 ([RFC 0001](https://github.com/libp2p/specs/blob/master/RFC/0001-text-peerid-cid.md))
|
||||||
|
|
||||||
|
```
|
||||||
|
bafzbeigweq4zr4x4ky2dvv7nanbkw6egutvrrvzw6g3h2rftp7gidyhtt4
|
||||||
|
```
|
||||||
|
|
||||||
### `toB58String()`
|
### `toB58String()`
|
||||||
|
|
||||||
Returns the Peer ID's `id` as a base58 string.
|
Returns the Peer ID's `id` as a base58 string (multihash/CIDv0).
|
||||||
|
|
||||||
```
|
```
|
||||||
QmckZzdVd72h9QUFuJJpQqhsZqGLwjhh81qSvZ9BhB2FQi
|
QmckZzdVd72h9QUFuJJpQqhsZqGLwjhh81qSvZ9BhB2FQi
|
||||||
@ -209,13 +240,38 @@ Returns an `obj` of the form
|
|||||||
- `obj.pubKey: String` - The public key in protobuf format, encoded in 'base64'
|
- `obj.pubKey: String` - The public key in protobuf format, encoded in 'base64'
|
||||||
- `obj.privKey: String` - The private key in protobuf format, encoded in 'base 64'
|
- `obj.privKey: String` - The private key in protobuf format, encoded in 'base 64'
|
||||||
|
|
||||||
|
### `marshal(excludePrivateKey)`
|
||||||
|
|
||||||
|
Returns a protocol-buffers encoded version of the id, public key and, if `excludePrivateKey` is not set, the private key.
|
||||||
|
|
||||||
|
### `marshalPubKey()`
|
||||||
|
|
||||||
|
Returns a protobuf of just the public key, compatible with `libp2p-crypto` (unlike `marshal` above).
|
||||||
|
|
||||||
|
For example:
|
||||||
|
```js
|
||||||
|
const crypto = require('libp2p-crypto')
|
||||||
|
|
||||||
|
PeerId.create({ bits: 256, keyType: 'ed25519' }).then( pid => {
|
||||||
|
let pk = crypto.keys.unmarshalPublicKey(pid.marshalPubKey())
|
||||||
|
// your code here
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
### `toPrint()`
|
### `toPrint()`
|
||||||
|
|
||||||
Returns the Peer ID as a printable string without the `Qm` prefix.
|
Returns the Peer ID as a printable string without the `Qm` prefix.
|
||||||
|
|
||||||
Example: `<peer.ID xxxxxx>`
|
Example: `<peer.ID xxxxxx>`
|
||||||
|
|
||||||
|
### `equals(id)`
|
||||||
|
|
||||||
|
Returns `true` if the given PeerId is equal to the current instance.
|
||||||
|
|
||||||
|
- `id` can be a PeerId or a Buffer containing the id
|
||||||
|
|
||||||
### `isEqual(id)`
|
### `isEqual(id)`
|
||||||
|
**Deprecation Notice**: Use [`equals`](#equalsid), `isEqual` will be removed in 0.14.0.
|
||||||
|
|
||||||
- `id` can be a PeerId or a Buffer containing the id
|
- `id` can be a PeerId or a Buffer containing the id
|
||||||
|
|
||||||
|
18
package.json
18
package.json
@ -1,8 +1,8 @@
|
|||||||
{
|
{
|
||||||
"name": "peer-id",
|
"name": "peer-id",
|
||||||
"version": "0.13.0",
|
"version": "0.13.6",
|
||||||
"description": "IPFS Peer Id implementation in Node.js",
|
"description": "IPFS Peer Id implementation in Node.js",
|
||||||
"leadMaintainer": "Pedro Teixeira <i@pgte.me>",
|
"leadMaintainer": "Vasco Santos <santos.vasco10@gmail.com>",
|
||||||
"main": "src/index.js",
|
"main": "src/index.js",
|
||||||
"bin": "src/bin.js",
|
"bin": "src/bin.js",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
@ -34,35 +34,43 @@
|
|||||||
},
|
},
|
||||||
"homepage": "https://github.com/libp2p/js-peer-id",
|
"homepage": "https://github.com/libp2p/js-peer-id",
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"aegir": "^19.0.5",
|
"aegir": "^20.0.0",
|
||||||
"bundlesize": "~0.18.0",
|
"bundlesize": "~0.18.0",
|
||||||
"chai": "^4.2.0",
|
"chai": "^4.2.0",
|
||||||
"dirty-chai": "^2.0.1"
|
"dirty-chai": "^2.0.1"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
|
"cids": "~0.7.1",
|
||||||
"class-is": "^1.1.0",
|
"class-is": "^1.1.0",
|
||||||
"libp2p-crypto": "~0.17.0",
|
"libp2p-crypto": "~0.17.0",
|
||||||
"multihashes": "~0.4.14"
|
"multihashes": "~0.4.15",
|
||||||
|
"protons": "^1.0.1"
|
||||||
},
|
},
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
"url": "https://github.com/libp2p/js-peer-id.git"
|
"url": "https://github.com/libp2p/js-peer-id.git"
|
||||||
},
|
},
|
||||||
"contributors": [
|
"contributors": [
|
||||||
|
"Arve Knudsen <arve.knudsen@gmail.com>",
|
||||||
|
"Christian Paul <info@jaller.de>",
|
||||||
"David Dias <daviddias.p@gmail.com>",
|
"David Dias <daviddias.p@gmail.com>",
|
||||||
"David Dias <mail@daviddias.me>",
|
"David Dias <mail@daviddias.me>",
|
||||||
"Friedel Ziegelmayer <dignifiedquire@gmail.com>",
|
"Friedel Ziegelmayer <dignifiedquire@gmail.com>",
|
||||||
"Henrique Dias <hacdias@gmail.com>",
|
"Henrique Dias <hacdias@gmail.com>",
|
||||||
"Hugo Dias <hugomrdias@gmail.com>",
|
"Hugo Dias <hugomrdias@gmail.com>",
|
||||||
|
"Jacob Heun <jacobheun@gmail.com>",
|
||||||
"Maciej Krüger <mkg20001@gmail.com>",
|
"Maciej Krüger <mkg20001@gmail.com>",
|
||||||
|
"Marcin Rataj <lidel@lidel.org>",
|
||||||
"Michael Garvin <gar+gh@danger.computer>",
|
"Michael Garvin <gar+gh@danger.computer>",
|
||||||
|
"Nate Foss <npfoss@gmail.com>",
|
||||||
"Pedro Teixeira <i@pgte.me>",
|
"Pedro Teixeira <i@pgte.me>",
|
||||||
"Prashanth Chandra <coolshanth94@gmail.com>",
|
"Prashanth Chandra <coolshanth94@gmail.com>",
|
||||||
"Richard Littauer <richard.littauer@gmail.com>",
|
"Richard Littauer <richard.littauer@gmail.com>",
|
||||||
"Richard Schneider <makaretu@gmail.com>",
|
"Richard Schneider <makaretu@gmail.com>",
|
||||||
"Stephen Whitmore <stephen.whitmore@gmail.com>",
|
"Stephen Whitmore <stephen.whitmore@gmail.com>",
|
||||||
"Vasco Santos <vasco.santos@ua.pt>",
|
"Topper Bowers <topper@quorumcontrol.com>",
|
||||||
"Vasco Santos <vasco.santos@moxy.studio>",
|
"Vasco Santos <vasco.santos@moxy.studio>",
|
||||||
|
"Vasco Santos <vasco.santos@ua.pt>",
|
||||||
"Yahya <ya7yaz@gmail.com>",
|
"Yahya <ya7yaz@gmail.com>",
|
||||||
"greenkeeperio-bot <support@greenkeeper.io>",
|
"greenkeeperio-bot <support@greenkeeper.io>",
|
||||||
"nginnever <ginneversource@gmail.com>",
|
"nginnever <ginneversource@gmail.com>",
|
||||||
|
@ -1,4 +1,4 @@
|
|||||||
#!/usr/local/bin/node
|
#!/usr/bin/env node
|
||||||
|
|
||||||
'use strict'
|
'use strict'
|
||||||
|
|
||||||
|
146
src/index.js
146
src/index.js
@ -5,9 +5,11 @@
|
|||||||
'use strict'
|
'use strict'
|
||||||
|
|
||||||
const mh = require('multihashes')
|
const mh = require('multihashes')
|
||||||
|
const CID = require('cids')
|
||||||
const cryptoKeys = require('libp2p-crypto/src/keys')
|
const cryptoKeys = require('libp2p-crypto/src/keys')
|
||||||
const assert = require('assert')
|
const assert = require('assert')
|
||||||
const withIs = require('class-is')
|
const withIs = require('class-is')
|
||||||
|
const { PeerIdProto } = require('./proto')
|
||||||
|
|
||||||
class PeerId {
|
class PeerId {
|
||||||
constructor (id, privKey, pubKey) {
|
constructor (id, privKey, pubKey) {
|
||||||
@ -47,6 +49,18 @@ class PeerId {
|
|||||||
if (this._privKey) {
|
if (this._privKey) {
|
||||||
return this._privKey.public
|
return this._privKey.public
|
||||||
}
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
const decoded = mh.decode(this.id)
|
||||||
|
|
||||||
|
if (decoded.name === 'identity') {
|
||||||
|
this._pubKey = cryptoKeys.unmarshalPublicKey(decoded.digest)
|
||||||
|
}
|
||||||
|
} catch (_) {
|
||||||
|
// Ignore, there is no valid public key
|
||||||
|
}
|
||||||
|
|
||||||
|
return this._pubKey
|
||||||
}
|
}
|
||||||
|
|
||||||
set pubKey (pubKey) {
|
set pubKey (pubKey) {
|
||||||
@ -67,6 +81,15 @@ class PeerId {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Return the protobuf version of the peer-id
|
||||||
|
marshal (excludePriv) {
|
||||||
|
return PeerIdProto.encode({
|
||||||
|
id: this.toBytes(),
|
||||||
|
pubKey: this.marshalPubKey(),
|
||||||
|
privKey: excludePriv ? null : this.marshalPrivKey()
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
toPrint () {
|
toPrint () {
|
||||||
let pid = this.toB58String()
|
let pid = this.toB58String()
|
||||||
// All sha256 nodes start with Qm
|
// All sha256 nodes start with Qm
|
||||||
@ -105,7 +128,22 @@ class PeerId {
|
|||||||
return this._idB58String
|
return this._idB58String
|
||||||
}
|
}
|
||||||
|
|
||||||
isEqual (id) {
|
// return self-describing String representation
|
||||||
|
// in default format from RFC 0001: https://github.com/libp2p/specs/pull/209
|
||||||
|
toString () {
|
||||||
|
if (!this._idCIDString) {
|
||||||
|
const cid = new CID(1, 'libp2p-key', this.id, 'base32')
|
||||||
|
this._idCIDString = cid.toBaseEncodedString('base32')
|
||||||
|
}
|
||||||
|
return this._idCIDString
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Checks the equality of `this` peer against a given PeerId.
|
||||||
|
* @param {Buffer|PeerId} id
|
||||||
|
* @returns {boolean}
|
||||||
|
*/
|
||||||
|
equals (id) {
|
||||||
if (Buffer.isBuffer(id)) {
|
if (Buffer.isBuffer(id)) {
|
||||||
return this.id.equals(id)
|
return this.id.equals(id)
|
||||||
} else if (id.id) {
|
} else if (id.id) {
|
||||||
@ -115,6 +153,16 @@ class PeerId {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Checks the equality of `this` peer against a given PeerId.
|
||||||
|
* @deprecated Use `.equals`
|
||||||
|
* @param {Buffer|PeerId} id
|
||||||
|
* @returns {boolean}
|
||||||
|
*/
|
||||||
|
isEqual (id) {
|
||||||
|
return this.equals(id)
|
||||||
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Check if this PeerId instance is valid (privKey -> pubKey -> Id)
|
* Check if this PeerId instance is valid (privKey -> pubKey -> Id)
|
||||||
*/
|
*/
|
||||||
@ -135,15 +183,27 @@ const PeerIdWithIs = withIs(PeerId, {
|
|||||||
|
|
||||||
exports = module.exports = PeerIdWithIs
|
exports = module.exports = PeerIdWithIs
|
||||||
|
|
||||||
|
const computeDigest = (pubKey) => {
|
||||||
|
if (pubKey.bytes.length <= 42) {
|
||||||
|
return mh.encode(pubKey.bytes, 'identity')
|
||||||
|
} else {
|
||||||
|
return pubKey.hash()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
const computePeerId = async (privKey, pubKey) => {
|
||||||
|
const digest = await computeDigest(pubKey)
|
||||||
|
return new PeerIdWithIs(digest, privKey, pubKey)
|
||||||
|
}
|
||||||
|
|
||||||
// generation
|
// generation
|
||||||
exports.create = async (opts) => {
|
exports.create = async (opts) => {
|
||||||
opts = opts || {}
|
opts = opts || {}
|
||||||
opts.bits = opts.bits || 2048
|
opts.bits = opts.bits || 2048
|
||||||
|
opts.keyType = opts.keyType || 'RSA'
|
||||||
|
|
||||||
const key = await cryptoKeys.generateKeyPair('RSA', opts.bits)
|
const key = await cryptoKeys.generateKeyPair(opts.keyType, opts.bits)
|
||||||
const digest = await key.public.hash()
|
return computePeerId(key, key.public)
|
||||||
|
|
||||||
return new PeerIdWithIs(digest, key)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
exports.createFromHexString = (str) => {
|
exports.createFromHexString = (str) => {
|
||||||
@ -155,7 +215,18 @@ exports.createFromBytes = (buf) => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
exports.createFromB58String = (str) => {
|
exports.createFromB58String = (str) => {
|
||||||
return new PeerIdWithIs(mh.fromB58String(str))
|
return exports.createFromCID(str) // B58String is CIDv0
|
||||||
|
}
|
||||||
|
|
||||||
|
const validMulticodec = (cid) => {
|
||||||
|
// supported: 'libp2p-key' (CIDv1) and 'dag-pb' (CIDv0 converted to CIDv1)
|
||||||
|
return cid.codec === 'libp2p-key' || cid.codec === 'dag-pb'
|
||||||
|
}
|
||||||
|
|
||||||
|
exports.createFromCID = (cid) => {
|
||||||
|
cid = CID.isCID(cid) ? cid : new CID(cid)
|
||||||
|
if (!validMulticodec(cid)) throw new Error('Supplied PeerID CID has invalid multicodec: ' + cid.codec)
|
||||||
|
return new PeerIdWithIs(cid.multihash)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Public Key input will be a buffer
|
// Public Key input will be a buffer
|
||||||
@ -171,8 +242,7 @@ exports.createFromPubKey = async (key) => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
const pubKey = await cryptoKeys.unmarshalPublicKey(buf)
|
const pubKey = await cryptoKeys.unmarshalPublicKey(buf)
|
||||||
const digest = await pubKey.hash()
|
return computePeerId(null, pubKey)
|
||||||
return new PeerIdWithIs(digest, null, pubKey)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Private key input will be a string
|
// Private key input will be a string
|
||||||
@ -188,27 +258,26 @@ exports.createFromPrivKey = async (key) => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
const privKey = await cryptoKeys.unmarshalPrivateKey(buf)
|
const privKey = await cryptoKeys.unmarshalPrivateKey(buf)
|
||||||
const digest = await privKey.public.hash()
|
return computePeerId(privKey, privKey.public)
|
||||||
|
|
||||||
return new PeerIdWithIs(digest, privKey, privKey.public)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
exports.createFromJSON = async (obj) => {
|
exports.createFromJSON = async (obj) => {
|
||||||
let id = mh.fromB58String(obj.id)
|
const id = mh.fromB58String(obj.id)
|
||||||
let rawPrivKey = obj.privKey && Buffer.from(obj.privKey, 'base64')
|
const rawPrivKey = obj.privKey && Buffer.from(obj.privKey, 'base64')
|
||||||
let rawPubKey = obj.pubKey && Buffer.from(obj.pubKey, 'base64')
|
const rawPubKey = obj.pubKey && Buffer.from(obj.pubKey, 'base64')
|
||||||
let pub = rawPubKey && await cryptoKeys.unmarshalPublicKey(rawPubKey)
|
const pub = rawPubKey && await cryptoKeys.unmarshalPublicKey(rawPubKey)
|
||||||
|
|
||||||
if (!rawPrivKey) {
|
if (!rawPrivKey) {
|
||||||
return new PeerIdWithIs(id, null, pub)
|
return new PeerIdWithIs(id, null, pub)
|
||||||
}
|
}
|
||||||
|
|
||||||
const privKey = await cryptoKeys.unmarshalPrivateKey(rawPrivKey)
|
const privKey = await cryptoKeys.unmarshalPrivateKey(rawPrivKey)
|
||||||
const privDigest = await privKey.public.hash()
|
const privDigest = await computeDigest(privKey.public)
|
||||||
|
|
||||||
let pubDigest
|
let pubDigest
|
||||||
|
|
||||||
if (pub) {
|
if (pub) {
|
||||||
pubDigest = await pub.hash()
|
pubDigest = await computeDigest(pub)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (pub && !privDigest.equals(pubDigest)) {
|
if (pub && !privDigest.equals(pubDigest)) {
|
||||||
@ -222,6 +291,49 @@ exports.createFromJSON = async (obj) => {
|
|||||||
return new PeerIdWithIs(id, privKey, pub)
|
return new PeerIdWithIs(id, privKey, pub)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
exports.createFromProtobuf = async (buf) => {
|
||||||
|
if (typeof buf === 'string') {
|
||||||
|
buf = Buffer.from(buf, 'hex')
|
||||||
|
}
|
||||||
|
|
||||||
|
let { id, privKey, pubKey } = PeerIdProto.decode(buf)
|
||||||
|
|
||||||
|
privKey = privKey ? await cryptoKeys.unmarshalPrivateKey(privKey) : false
|
||||||
|
pubKey = pubKey ? await cryptoKeys.unmarshalPublicKey(pubKey) : false
|
||||||
|
|
||||||
|
let pubDigest
|
||||||
|
let privDigest
|
||||||
|
|
||||||
|
if (privKey) {
|
||||||
|
privDigest = await computeDigest(privKey.public)
|
||||||
|
}
|
||||||
|
|
||||||
|
if (pubKey) {
|
||||||
|
pubDigest = await computeDigest(pubKey)
|
||||||
|
}
|
||||||
|
|
||||||
|
if (privKey) {
|
||||||
|
if (pubKey) {
|
||||||
|
if (!privDigest.equals(pubDigest)) {
|
||||||
|
throw new Error('Public and private key do not match')
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return new PeerIdWithIs(privDigest, privKey, privKey.public)
|
||||||
|
}
|
||||||
|
|
||||||
|
// TODO: val id and pubDigest
|
||||||
|
|
||||||
|
if (pubKey) {
|
||||||
|
return new PeerIdWithIs(pubDigest, null, pubKey)
|
||||||
|
}
|
||||||
|
|
||||||
|
if (id) {
|
||||||
|
return new PeerIdWithIs(id)
|
||||||
|
}
|
||||||
|
|
||||||
|
throw new Error('Protobuf did not contain any usable key material')
|
||||||
|
}
|
||||||
|
|
||||||
exports.isPeerId = (peerId) => {
|
exports.isPeerId = (peerId) => {
|
||||||
return Boolean(typeof peerId === 'object' &&
|
return Boolean(typeof peerId === 'object' &&
|
||||||
peerId._id &&
|
peerId._id &&
|
||||||
|
12
src/proto.js
Normal file
12
src/proto.js
Normal file
@ -0,0 +1,12 @@
|
|||||||
|
'use strict'
|
||||||
|
|
||||||
|
const protons = require('protons')
|
||||||
|
module.exports = protons(`
|
||||||
|
|
||||||
|
message PeerIdProto {
|
||||||
|
required bytes id = 1;
|
||||||
|
bytes pubKey = 2;
|
||||||
|
bytes privKey = 3;
|
||||||
|
}
|
||||||
|
|
||||||
|
`)
|
3
test/fixtures/sample-id.js
vendored
3
test/fixtures/sample-id.js
vendored
@ -3,5 +3,6 @@
|
|||||||
module.exports = {
|
module.exports = {
|
||||||
id: '122019318b6e5e0cf93a2314bf01269a2cc23cd3dcd452d742cdb9379d8646f6e4a9',
|
id: '122019318b6e5e0cf93a2314bf01269a2cc23cd3dcd452d742cdb9379d8646f6e4a9',
|
||||||
privKey: 'CAASpgkwggSiAgEAAoIBAQC2SKo/HMFZeBml1AF3XijzrxrfQXdJzjePBZAbdxqKR1Mc6juRHXij6HXYPjlAk01BhF1S3Ll4Lwi0cAHhggf457sMg55UWyeGKeUv0ucgvCpBwlR5cQ020i0MgzjPWOLWq1rtvSbNcAi2ZEVn6+Q2EcHo3wUvWRtLeKz+DZSZfw2PEDC+DGPJPl7f8g7zl56YymmmzH9liZLNrzg/qidokUv5u1pdGrcpLuPNeTODk0cqKB+OUbuKj9GShYECCEjaybJDl9276oalL9ghBtSeEv20kugatTvYy590wFlJkkvyl+nPxIH0EEYMKK9XRWlu9XYnoSfboiwcv8M3SlsjAgMBAAECggEAZtju/bcKvKFPz0mkHiaJcpycy9STKphorpCT83srBVQi59CdFU6Mj+aL/xt0kCPMVigJw8P3/YCEJ9J+rS8BsoWE+xWUEsJvtXoT7vzPHaAtM3ci1HZd302Mz1+GgS8Epdx+7F5p80XAFLDUnELzOzKftvWGZmWfSeDnslwVONkL/1VAzwKy7Ce6hk4SxRE7l2NE2OklSHOzCGU1f78ZzVYKSnS5Ag9YrGjOAmTOXDbKNKN/qIorAQ1bovzGoCwx3iGIatQKFOxyVCyO1PsJYT7JO+kZbhBWRRE+L7l+ppPER9bdLFxs1t5CrKc078h+wuUr05S1P1JjXk68pk3+kQKBgQDeK8AR11373Mzib6uzpjGzgNRMzdYNuExWjxyxAzz53NAR7zrPHvXvfIqjDScLJ4NcRO2TddhXAfZoOPVH5k4PJHKLBPKuXZpWlookCAyENY7+Pd55S8r+a+MusrMagYNljb5WbVTgN8cgdpim9lbbIFlpN6SZaVjLQL3J8TWH6wKBgQDSChzItkqWX11CNstJ9zJyUE20I7LrpyBJNgG1gtvz3ZMUQCn3PxxHtQzN9n1P0mSSYs+jBKPuoSyYLt1wwe10/lpgL4rkKWU3/m1Myt0tveJ9WcqHh6tzcAbb/fXpUFT/o4SWDimWkPkuCb+8j//2yiXk0a/T2f36zKMuZvujqQKBgC6B7BAQDG2H2B/ijofp12ejJU36nL98gAZyqOfpLJ+FeMz4TlBDQ+phIMhnHXA5UkdDapQ+zA3SrFk+6yGk9Vw4Hf46B+82SvOrSbmnMa+PYqKYIvUzR4gg34rL/7AhwnbEyD5hXq4dHwMNsIDq+l2elPjwm/U9V0gdAl2+r50HAoGALtsKqMvhv8HucAMBPrLikhXP/8um8mMKFMrzfqZ+otxfHzlhI0L08Bo3jQrb0Z7ByNY6M8epOmbCKADsbWcVre/AAY0ZkuSZK/CaOXNX/AhMKmKJh8qAOPRY02LIJRBCpfS4czEdnfUhYV/TYiFNnKRj57PPYZdTzUsxa/yVTmECgYBr7slQEjb5Onn5mZnGDh+72BxLNdgwBkhO0OCdpdISqk0F0Pxby22DFOKXZEpiyI9XYP1C8wPiJsShGm2yEwBPWXnrrZNWczaVuCbXHrZkWQogBDG3HGXNdU4MAWCyiYlyinIBpPpoAJZSzpGLmWbMWh28+RJS6AQX6KHrK1o2uw==',
|
privKey: 'CAASpgkwggSiAgEAAoIBAQC2SKo/HMFZeBml1AF3XijzrxrfQXdJzjePBZAbdxqKR1Mc6juRHXij6HXYPjlAk01BhF1S3Ll4Lwi0cAHhggf457sMg55UWyeGKeUv0ucgvCpBwlR5cQ020i0MgzjPWOLWq1rtvSbNcAi2ZEVn6+Q2EcHo3wUvWRtLeKz+DZSZfw2PEDC+DGPJPl7f8g7zl56YymmmzH9liZLNrzg/qidokUv5u1pdGrcpLuPNeTODk0cqKB+OUbuKj9GShYECCEjaybJDl9276oalL9ghBtSeEv20kugatTvYy590wFlJkkvyl+nPxIH0EEYMKK9XRWlu9XYnoSfboiwcv8M3SlsjAgMBAAECggEAZtju/bcKvKFPz0mkHiaJcpycy9STKphorpCT83srBVQi59CdFU6Mj+aL/xt0kCPMVigJw8P3/YCEJ9J+rS8BsoWE+xWUEsJvtXoT7vzPHaAtM3ci1HZd302Mz1+GgS8Epdx+7F5p80XAFLDUnELzOzKftvWGZmWfSeDnslwVONkL/1VAzwKy7Ce6hk4SxRE7l2NE2OklSHOzCGU1f78ZzVYKSnS5Ag9YrGjOAmTOXDbKNKN/qIorAQ1bovzGoCwx3iGIatQKFOxyVCyO1PsJYT7JO+kZbhBWRRE+L7l+ppPER9bdLFxs1t5CrKc078h+wuUr05S1P1JjXk68pk3+kQKBgQDeK8AR11373Mzib6uzpjGzgNRMzdYNuExWjxyxAzz53NAR7zrPHvXvfIqjDScLJ4NcRO2TddhXAfZoOPVH5k4PJHKLBPKuXZpWlookCAyENY7+Pd55S8r+a+MusrMagYNljb5WbVTgN8cgdpim9lbbIFlpN6SZaVjLQL3J8TWH6wKBgQDSChzItkqWX11CNstJ9zJyUE20I7LrpyBJNgG1gtvz3ZMUQCn3PxxHtQzN9n1P0mSSYs+jBKPuoSyYLt1wwe10/lpgL4rkKWU3/m1Myt0tveJ9WcqHh6tzcAbb/fXpUFT/o4SWDimWkPkuCb+8j//2yiXk0a/T2f36zKMuZvujqQKBgC6B7BAQDG2H2B/ijofp12ejJU36nL98gAZyqOfpLJ+FeMz4TlBDQ+phIMhnHXA5UkdDapQ+zA3SrFk+6yGk9Vw4Hf46B+82SvOrSbmnMa+PYqKYIvUzR4gg34rL/7AhwnbEyD5hXq4dHwMNsIDq+l2elPjwm/U9V0gdAl2+r50HAoGALtsKqMvhv8HucAMBPrLikhXP/8um8mMKFMrzfqZ+otxfHzlhI0L08Bo3jQrb0Z7ByNY6M8epOmbCKADsbWcVre/AAY0ZkuSZK/CaOXNX/AhMKmKJh8qAOPRY02LIJRBCpfS4czEdnfUhYV/TYiFNnKRj57PPYZdTzUsxa/yVTmECgYBr7slQEjb5Onn5mZnGDh+72BxLNdgwBkhO0OCdpdISqk0F0Pxby22DFOKXZEpiyI9XYP1C8wPiJsShGm2yEwBPWXnrrZNWczaVuCbXHrZkWQogBDG3HGXNdU4MAWCyiYlyinIBpPpoAJZSzpGLmWbMWh28+RJS6AQX6KHrK1o2uw==',
|
||||||
pubKey: 'CAASpgIwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQC2SKo/HMFZeBml1AF3XijzrxrfQXdJzjePBZAbdxqKR1Mc6juRHXij6HXYPjlAk01BhF1S3Ll4Lwi0cAHhggf457sMg55UWyeGKeUv0ucgvCpBwlR5cQ020i0MgzjPWOLWq1rtvSbNcAi2ZEVn6+Q2EcHo3wUvWRtLeKz+DZSZfw2PEDC+DGPJPl7f8g7zl56YymmmzH9liZLNrzg/qidokUv5u1pdGrcpLuPNeTODk0cqKB+OUbuKj9GShYECCEjaybJDl9276oalL9ghBtSeEv20kugatTvYy590wFlJkkvyl+nPxIH0EEYMKK9XRWlu9XYnoSfboiwcv8M3SlsjAgMBAAE='
|
pubKey: 'CAASpgIwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQC2SKo/HMFZeBml1AF3XijzrxrfQXdJzjePBZAbdxqKR1Mc6juRHXij6HXYPjlAk01BhF1S3Ll4Lwi0cAHhggf457sMg55UWyeGKeUv0ucgvCpBwlR5cQ020i0MgzjPWOLWq1rtvSbNcAi2ZEVn6+Q2EcHo3wUvWRtLeKz+DZSZfw2PEDC+DGPJPl7f8g7zl56YymmmzH9liZLNrzg/qidokUv5u1pdGrcpLuPNeTODk0cqKB+OUbuKj9GShYECCEjaybJDl9276oalL9ghBtSeEv20kugatTvYy590wFlJkkvyl+nPxIH0EEYMKK9XRWlu9XYnoSfboiwcv8M3SlsjAgMBAAE=',
|
||||||
|
marshaled: '0a22122019318b6e5e0cf93a2314bf01269a2cc23cd3dcd452d742cdb9379d8646f6e4a912ab02080012a60230820122300d06092a864886f70d01010105000382010f003082010a0282010100b648aa3f1cc1597819a5d401775e28f3af1adf417749ce378f05901b771a8a47531cea3b911d78a3e875d83e3940934d41845d52dcb9782f08b47001e18207f8e7bb0c839e545b278629e52fd2e720bc2a41c25479710d36d22d0c8338cf58e2d6ab5aedbd26cd7008b6644567ebe43611c1e8df052f591b4b78acfe0d94997f0d8f1030be0c63c93e5edff20ef3979e98ca69a6cc7f658992cdaf383faa2768914bf9bb5a5d1ab7292ee3cd79338393472a281f8e51bb8a8fd1928581020848dac9b24397ddbbea86a52fd82106d49e12fdb492e81ab53bd8cb9f74c05949924bf297e9cfc481f410460c28af5745696ef57627a127dba22c1cbfc3374a5b2302030100011aab09080012a609308204a20201000282010100b648aa3f1cc1597819a5d401775e28f3af1adf417749ce378f05901b771a8a47531cea3b911d78a3e875d83e3940934d41845d52dcb9782f08b47001e18207f8e7bb0c839e545b278629e52fd2e720bc2a41c25479710d36d22d0c8338cf58e2d6ab5aedbd26cd7008b6644567ebe43611c1e8df052f591b4b78acfe0d94997f0d8f1030be0c63c93e5edff20ef3979e98ca69a6cc7f658992cdaf383faa2768914bf9bb5a5d1ab7292ee3cd79338393472a281f8e51bb8a8fd1928581020848dac9b24397ddbbea86a52fd82106d49e12fdb492e81ab53bd8cb9f74c05949924bf297e9cfc481f410460c28af5745696ef57627a127dba22c1cbfc3374a5b2302030100010282010066d8eefdb70abca14fcf49a41e2689729c9ccbd4932a9868ae9093f37b2b055422e7d09d154e8c8fe68bff1b749023cc562809c3c3f7fd808427d27ead2f01b28584fb159412c26fb57a13eefccf1da02d337722d4765ddf4d8ccf5f86812f04a5dc7eec5e69f345c014b0d49c42f33b329fb6f58666659f49e0e7b25c1538d90bff5540cf02b2ec27ba864e12c5113b976344d8e9254873b30865357fbf19cd560a4a74b9020f58ac68ce0264ce5c36ca34a37fa88a2b010d5ba2fcc6a02c31de21886ad40a14ec72542c8ed4fb09613ec93be9196e105645113e2fb97ea693c447d6dd2c5c6cd6de42aca734efc87ec2e52bd394b53f52635e4ebca64dfe9102818100de2bc011d75dfbdccce26fabb3a631b380d44ccdd60db84c568f1cb1033cf9dcd011ef3acf1ef5ef7c8aa30d270b27835c44ed9375d85701f66838f547e64e0f24728b04f2ae5d9a56968a24080c84358efe3dde794bcafe6be32eb2b31a8183658dbe566d54e037c7207698a6f656db20596937a4996958cb40bdc9f13587eb02818100d20a1cc8b64a965f5d4236cb49f73272504db423b2eba720493601b582dbf3dd93144029f73f1c47b50ccdf67d4fd2649262cfa304a3eea12c982edd70c1ed74fe5a602f8ae4296537fe6d4ccadd2dbde27d59ca8787ab737006dbfdf5e95054ffa384960e299690f92e09bfbc8ffff6ca25e4d1afd3d9fdfacca32e66fba3a90281802e81ec10100c6d87d81fe28e87e9d767a3254dfa9cbf7c800672a8e7e92c9f8578ccf84e504343ea6120c8671d70395247436a943ecc0dd2ac593eeb21a4f55c381dfe3a07ef364af3ab49b9a731af8f62a29822f533478820df8acbffb021c276c4c83e615eae1d1f030db080eafa5d9e94f8f09bf53d57481d025dbeaf9d070281802edb0aa8cbe1bfc1ee7003013eb2e29215cfffcba6f2630a14caf37ea67ea2dc5f1f39612342f4f01a378d0adbd19ec1c8d63a33c7a93a66c22800ec6d6715adefc0018d1992e4992bf09a397357fc084c2a628987ca8038f458d362c8251042a5f4b873311d9df521615fd362214d9ca463e7b3cf619753cd4b316bfc954e610281806beec9501236f93a79f99999c60e1fbbd81c4b35d83006484ed0e09da5d212aa4d05d0fc5bcb6d8314e297644a62c88f5760fd42f303e226c4a11a6db213004f5979ebad9356733695b826d71eb664590a200431b71c65cd754e0c0160b28989728a7201a4fa68009652ce918b9966cc5a1dbcf91252e80417e8a1eb2b5a36bb'
|
||||||
}
|
}
|
||||||
|
@ -8,6 +8,7 @@ chai.use(dirtyChai)
|
|||||||
const expect = chai.expect
|
const expect = chai.expect
|
||||||
const crypto = require('libp2p-crypto')
|
const crypto = require('libp2p-crypto')
|
||||||
const mh = require('multihashes')
|
const mh = require('multihashes')
|
||||||
|
const CID = require('cids')
|
||||||
|
|
||||||
const PeerId = require('../src')
|
const PeerId = require('../src')
|
||||||
|
|
||||||
@ -17,6 +18,8 @@ const testId = require('./fixtures/sample-id')
|
|||||||
const testIdHex = testId.id
|
const testIdHex = testId.id
|
||||||
const testIdBytes = mh.fromHexString(testId.id)
|
const testIdBytes = mh.fromHexString(testId.id)
|
||||||
const testIdB58String = mh.toB58String(testIdBytes)
|
const testIdB58String = mh.toB58String(testIdBytes)
|
||||||
|
const testIdCID = new CID(1, 'libp2p-key', testIdBytes)
|
||||||
|
const testIdCIDString = testIdCID.toBaseEncodedString('base32')
|
||||||
|
|
||||||
const goId = require('./fixtures/go-private-key')
|
const goId = require('./fixtures/go-private-key')
|
||||||
|
|
||||||
@ -36,6 +39,18 @@ describe('PeerId', () => {
|
|||||||
expect(id.toB58String().length).to.equal(46)
|
expect(id.toB58String().length).to.equal(46)
|
||||||
})
|
})
|
||||||
|
|
||||||
|
it('can be created for a Secp256k1 key', async () => {
|
||||||
|
const id = await PeerId.create({ keyType: 'secp256k1', bits: 256 })
|
||||||
|
const expB58 = mh.toB58String(mh.encode(id.pubKey.bytes, 'identity'))
|
||||||
|
expect(id.toB58String()).to.equal(expB58)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('can get the public key from a Secp256k1 key', async () => {
|
||||||
|
const original = await PeerId.create({ keyType: 'secp256k1', bits: 256 })
|
||||||
|
const newId = PeerId.createFromB58String(original.toB58String())
|
||||||
|
expect(original.pubKey.bytes).to.eql(newId.pubKey.bytes)
|
||||||
|
})
|
||||||
|
|
||||||
it('isPeerId', async () => {
|
it('isPeerId', async () => {
|
||||||
const id = await PeerId.create(testOpts)
|
const id = await PeerId.create(testOpts)
|
||||||
expect(PeerId.isPeerId(id)).to.equal(true)
|
expect(PeerId.isPeerId(id)).to.equal(true)
|
||||||
@ -51,27 +66,96 @@ describe('PeerId', () => {
|
|||||||
}).to.throw(/immutable/)
|
}).to.throw(/immutable/)
|
||||||
})
|
})
|
||||||
|
|
||||||
it('recreate an Id from Hex string', () => {
|
it('recreate from Hex string', () => {
|
||||||
const id = PeerId.createFromHexString(testIdHex)
|
const id = PeerId.createFromHexString(testIdHex)
|
||||||
expect(testIdBytes).to.deep.equal(id.id)
|
expect(testIdBytes).to.deep.equal(id.toBytes())
|
||||||
})
|
})
|
||||||
|
|
||||||
it('Recreate an Id from a Buffer', () => {
|
it('recreate from a Buffer', () => {
|
||||||
const id = PeerId.createFromBytes(testIdBytes)
|
const id = PeerId.createFromBytes(testIdBytes)
|
||||||
expect(testId.id).to.equal(id.toHexString())
|
expect(testId.id).to.equal(id.toHexString())
|
||||||
|
expect(testIdBytes).to.deep.equal(id.toBytes())
|
||||||
})
|
})
|
||||||
|
|
||||||
it('Recreate a B58 String', () => {
|
it('recreate from a B58 String', () => {
|
||||||
const id = PeerId.createFromB58String(testIdB58String)
|
const id = PeerId.createFromB58String(testIdB58String)
|
||||||
expect(testIdB58String).to.equal(id.toB58String())
|
expect(testIdB58String).to.equal(id.toB58String())
|
||||||
|
expect(testIdBytes).to.deep.equal(id.toBytes())
|
||||||
})
|
})
|
||||||
|
|
||||||
it('Recreate from a Public Key', async () => {
|
it('recreate from CID object', () => {
|
||||||
|
const id = PeerId.createFromCID(testIdCID)
|
||||||
|
expect(testIdCIDString).to.equal(id.toString())
|
||||||
|
expect(testIdBytes).to.deep.equal(id.toBytes())
|
||||||
|
})
|
||||||
|
|
||||||
|
it('recreate from Base58 String (CIDv0))', () => {
|
||||||
|
const id = PeerId.createFromCID(testIdB58String)
|
||||||
|
expect(testIdCIDString).to.equal(id.toString())
|
||||||
|
expect(testIdBytes).to.deep.equal(id.toBytes())
|
||||||
|
})
|
||||||
|
|
||||||
|
it('recreate from CIDv1 Base32 (libp2p-key multicodec)', () => {
|
||||||
|
const cid = new CID(1, 'libp2p-key', testIdBytes)
|
||||||
|
const cidString = cid.toBaseEncodedString('base32')
|
||||||
|
const id = PeerId.createFromCID(cidString)
|
||||||
|
expect(cidString).to.equal(id.toString())
|
||||||
|
expect(testIdBytes).to.deep.equal(id.toBytes())
|
||||||
|
})
|
||||||
|
|
||||||
|
it('recreate from CIDv1 Base32 (dag-pb multicodec)', () => {
|
||||||
|
const cid = new CID(1, 'dag-pb', testIdBytes)
|
||||||
|
const cidString = cid.toBaseEncodedString('base32')
|
||||||
|
const id = PeerId.createFromCID(cidString)
|
||||||
|
// toString should return CID with multicodec set to libp2p-key
|
||||||
|
expect(new CID(id.toString()).codec).to.equal('libp2p-key')
|
||||||
|
expect(testIdBytes).to.deep.equal(id.toBytes())
|
||||||
|
})
|
||||||
|
|
||||||
|
it('recreate from CID Buffer', () => {
|
||||||
|
const id = PeerId.createFromCID(testIdCID.buffer)
|
||||||
|
expect(testIdCIDString).to.equal(id.toString())
|
||||||
|
expect(testIdBytes).to.deep.equal(id.toBytes())
|
||||||
|
})
|
||||||
|
|
||||||
|
it('throws on invalid CID multicodec', () => {
|
||||||
|
// only libp2p and dag-pb are supported
|
||||||
|
const invalidCID = new CID(1, 'raw', testIdBytes).toBaseEncodedString('base32')
|
||||||
|
expect(() => {
|
||||||
|
PeerId.createFromCID(invalidCID)
|
||||||
|
}).to.throw(/Supplied PeerID CID has invalid multicodec: raw/)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('throws on invalid CID value', () => {
|
||||||
|
// using function code that does not represent valid hash function
|
||||||
|
// https://github.com/multiformats/js-multihash/blob/b85999d5768bf06f1b0f16b926ef2cb6d9c14265/src/constants.js#L345
|
||||||
|
const invalidCID = 'QmaozNR7DZHQK1ZcU9p7QdrshMvXqWK6gpu5rmrkPdT3L'
|
||||||
|
expect(() => {
|
||||||
|
PeerId.createFromCID(invalidCID)
|
||||||
|
}).to.throw(/multihash unknown function code: 0x50/)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('throws on invalid CID object', () => {
|
||||||
|
const invalidCID = {}
|
||||||
|
expect(() => {
|
||||||
|
PeerId.createFromCID(invalidCID)
|
||||||
|
}).to.throw(/Invalid version, must be a number equal to 1 or 0/)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('throws on invalid CID object', () => {
|
||||||
|
const invalidCID = {}
|
||||||
|
expect(() => {
|
||||||
|
PeerId.createFromCID(invalidCID)
|
||||||
|
}).to.throw(/Invalid version, must be a number equal to 1 or 0/)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('recreate from a Public Key', async () => {
|
||||||
const id = await PeerId.createFromPubKey(testId.pubKey)
|
const id = await PeerId.createFromPubKey(testId.pubKey)
|
||||||
expect(testIdB58String).to.equal(id.toB58String())
|
expect(testIdB58String).to.equal(id.toB58String())
|
||||||
|
expect(testIdBytes).to.deep.equal(id.toBytes())
|
||||||
})
|
})
|
||||||
|
|
||||||
it('Recreate from a Private Key', async () => {
|
it('recreate from a Private Key', async () => {
|
||||||
const id = await PeerId.createFromPrivKey(testId.privKey)
|
const id = await PeerId.createFromPrivKey(testId.privKey)
|
||||||
expect(testIdB58String).to.equal(id.toB58String())
|
expect(testIdB58String).to.equal(id.toB58String())
|
||||||
const encoded = Buffer.from(testId.privKey, 'base64')
|
const encoded = Buffer.from(testId.privKey, 'base64')
|
||||||
@ -80,6 +164,30 @@ describe('PeerId', () => {
|
|||||||
expect(id.marshalPubKey()).to.deep.equal(id2.marshalPubKey())
|
expect(id.marshalPubKey()).to.deep.equal(id2.marshalPubKey())
|
||||||
})
|
})
|
||||||
|
|
||||||
|
it('recreate from Protobuf', async () => {
|
||||||
|
const id = await PeerId.createFromProtobuf(testId.marshaled)
|
||||||
|
expect(testIdB58String).to.equal(id.toB58String())
|
||||||
|
const encoded = Buffer.from(testId.privKey, 'base64')
|
||||||
|
const id2 = await PeerId.createFromPrivKey(encoded)
|
||||||
|
expect(testIdB58String).to.equal(id2.toB58String())
|
||||||
|
expect(id.marshalPubKey()).to.deep.equal(id2.marshalPubKey())
|
||||||
|
expect(id.marshal().toString('hex')).to.deep.equal(testId.marshaled)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('can be created from a Secp256k1 public key', async () => {
|
||||||
|
const privKey = await crypto.keys.generateKeyPair('secp256k1', 256)
|
||||||
|
const id = await PeerId.createFromPubKey(privKey.public.bytes)
|
||||||
|
const expB58 = mh.toB58String(mh.encode(id.pubKey.bytes, 'identity'))
|
||||||
|
expect(id.toB58String()).to.equal(expB58)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('can be created from a Secp256k1 private key', async () => {
|
||||||
|
const privKey = await crypto.keys.generateKeyPair('secp256k1', 256)
|
||||||
|
const id = await PeerId.createFromPrivKey(privKey.bytes)
|
||||||
|
const expB58 = mh.toB58String(mh.encode(id.pubKey.bytes, 'identity'))
|
||||||
|
expect(id.toB58String()).to.equal(expB58)
|
||||||
|
})
|
||||||
|
|
||||||
it('Compare generated ID with one created from PubKey', async () => {
|
it('Compare generated ID with one created from PubKey', async () => {
|
||||||
const id1 = await PeerId.create(testOpts)
|
const id1 = await PeerId.create(testOpts)
|
||||||
const id2 = await PeerId.createFromPubKey(id1.marshalPubKey())
|
const id2 = await PeerId.createFromPubKey(id1.marshalPubKey())
|
||||||
@ -123,6 +231,18 @@ describe('PeerId', () => {
|
|||||||
expect(ids[0].isEqual(ids[1].id)).to.equal(false)
|
expect(ids[0].isEqual(ids[1].id)).to.equal(false)
|
||||||
})
|
})
|
||||||
|
|
||||||
|
it('equals', async () => {
|
||||||
|
const ids = await Promise.all([
|
||||||
|
PeerId.create(testOpts),
|
||||||
|
PeerId.create(testOpts)
|
||||||
|
])
|
||||||
|
|
||||||
|
expect(ids[0].equals(ids[0])).to.equal(true)
|
||||||
|
expect(ids[0].equals(ids[1])).to.equal(false)
|
||||||
|
expect(ids[0].equals(ids[0].id)).to.equal(true)
|
||||||
|
expect(ids[0].equals(ids[1].id)).to.equal(false)
|
||||||
|
})
|
||||||
|
|
||||||
describe('fromJSON', () => {
|
describe('fromJSON', () => {
|
||||||
it('full node', async () => {
|
it('full node', async () => {
|
||||||
const id = await PeerId.create(testOpts)
|
const id = await PeerId.create(testOpts)
|
||||||
@ -180,7 +300,7 @@ describe('PeerId', () => {
|
|||||||
Buffer.from(''), 'aGVsbG93b3JsZA==', 'helloworld', ''
|
Buffer.from(''), 'aGVsbG93b3JsZA==', 'helloworld', ''
|
||||||
]
|
]
|
||||||
|
|
||||||
const fncs = ['createFromPubKey', 'createFromPrivKey', 'createFromJSON']
|
const fncs = ['createFromPubKey', 'createFromPrivKey', 'createFromJSON', 'createFromProtobuf']
|
||||||
|
|
||||||
for (const gb of garbage) {
|
for (const gb of garbage) {
|
||||||
for (const fn of fncs) {
|
for (const fn of fncs) {
|
||||||
|
Reference in New Issue
Block a user