mirror of
https://github.com/fluencelabs/js-peer-id
synced 2025-07-04 14:21:46 +00:00
Compare commits
10 Commits
Author | SHA1 | Date | |
---|---|---|---|
3da91b92fa | |||
ad9a43b7c8 | |||
c67bf150f2 | |||
6624c27d8d | |||
26ac06d21c | |||
f0d72b7bfe | |||
78d96d0b14 | |||
bebb0a7eae | |||
5d6a962b6c | |||
531c9f1086 |
1
.gitignore
vendored
1
.gitignore
vendored
@ -27,4 +27,3 @@ build/Release
|
|||||||
node_modules
|
node_modules
|
||||||
|
|
||||||
dist
|
dist
|
||||||
docs
|
|
113
README.md
113
README.md
@ -22,6 +22,22 @@
|
|||||||
- [Browser: Browserify, Webpack, other bundlers](#browser-browserify-webpack-other-bundlers)
|
- [Browser: Browserify, Webpack, other bundlers](#browser-browserify-webpack-other-bundlers)
|
||||||
- [Browser: `<script>` Tag](#browser-script-tag)
|
- [Browser: `<script>` Tag](#browser-script-tag)
|
||||||
- [API](#api)
|
- [API](#api)
|
||||||
|
- [Create](#create)
|
||||||
|
- [`new PeerId(id[, privKey, pubKey])`](#new-peeridid-privkey-pubkey)
|
||||||
|
- [`create([opts], callback)`](#createopts-callback)
|
||||||
|
- [Import](#import)
|
||||||
|
- [`createFromHexString(str)`](#createfromhexstringstr)
|
||||||
|
- [`createFromBytes(buf)`](#createfrombytesbuf)
|
||||||
|
- [`createFromB58String(str)`](#createfromb58stringstr)
|
||||||
|
- [`createFromPubKey(pubKey)`](#createfrompubkeypubkey)
|
||||||
|
- [`createFromPrivKey(privKey)`](#createfromprivkeyprivkey)
|
||||||
|
- [`createFromJSON(obj)`](#createfromjsonobj)
|
||||||
|
- [Export](#export)
|
||||||
|
- [`toHexString()`](#tohexstring)
|
||||||
|
- [`toBytes()`](#tobytes)
|
||||||
|
- [`toB58String()`](#tob58string)
|
||||||
|
- [`toJSON()`](#tojson)
|
||||||
|
- [`toPrint()`](#toprint)
|
||||||
- [License](#license)
|
- [License](#license)
|
||||||
|
|
||||||
# Description
|
# Description
|
||||||
@ -39,9 +55,10 @@ to the multihash for ID generation.*
|
|||||||
|
|
||||||
```js
|
```js
|
||||||
var PeerId = require('peer-id')
|
var PeerId = require('peer-id')
|
||||||
|
var bs58 = require('bs58')
|
||||||
|
|
||||||
PeerId.create({ bits: 1024 }, (err, id) => {
|
PeerId.create({ bits: 1024 }, (err, id) => {
|
||||||
console.log(JSON.stringify(id.toJSON(), null, 2)
|
console.log(JSON.stringify(id.toJSON(), null, 2))
|
||||||
})
|
})
|
||||||
```
|
```
|
||||||
|
|
||||||
@ -93,6 +110,100 @@ the global namespace.
|
|||||||
|
|
||||||
# API
|
# API
|
||||||
|
|
||||||
|
```js
|
||||||
|
const PeerId = require('peer-id')
|
||||||
|
```
|
||||||
|
|
||||||
|
## Create
|
||||||
|
|
||||||
|
### `new PeerId(id[, privKey, pubKey])`
|
||||||
|
|
||||||
|
- `id: Buffer` - The multihash of the publick key as `Buffer`
|
||||||
|
- `privKey: RsaPrivateKey` - The private key
|
||||||
|
- `pubKey: RsaPublicKey` - The public key
|
||||||
|
|
||||||
|
The key format is detailed in [libp2p-crypto](https://github.com/libp2p/js-libp2p-crypto).
|
||||||
|
|
||||||
|
### `create([opts], callback)`
|
||||||
|
|
||||||
|
Generates a new Peer ID, complete with public/private keypair.
|
||||||
|
|
||||||
|
- `opts: Object`: Default: `{bits: 2048}`
|
||||||
|
- `callback: Function`
|
||||||
|
|
||||||
|
Calls back `callback` with `err, id`.
|
||||||
|
|
||||||
|
## Import
|
||||||
|
|
||||||
|
### `createFromHexString(str)`
|
||||||
|
|
||||||
|
Creates a Peer ID from hex string representing the key's multihash.
|
||||||
|
|
||||||
|
### `createFromBytes(buf)`
|
||||||
|
|
||||||
|
Creates a Peer ID from a buffer representing the key's multihash.
|
||||||
|
|
||||||
|
### `createFromB58String(str)`
|
||||||
|
Creates a Peer ID from a Base58 string representing the key's multihash.
|
||||||
|
|
||||||
|
### `createFromPubKey(pubKey)`
|
||||||
|
|
||||||
|
- `publicKey: Buffer`
|
||||||
|
|
||||||
|
Creates a Peer ID from a buffer containing a public key.
|
||||||
|
|
||||||
|
### `createFromPrivKey(privKey)`
|
||||||
|
|
||||||
|
- `privKey: Buffer`
|
||||||
|
|
||||||
|
Creates a Peer ID from a buffer containing a private key.
|
||||||
|
|
||||||
|
### `createFromJSON(obj)`
|
||||||
|
|
||||||
|
- `obj.id: String` - The multihash encoded in `base58`
|
||||||
|
- `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'
|
||||||
|
|
||||||
|
## Export
|
||||||
|
|
||||||
|
### `toHexString()`
|
||||||
|
|
||||||
|
Returns the Peer ID's `id` as a hex string.
|
||||||
|
|
||||||
|
```
|
||||||
|
1220d6243998f2fc56343ad7ed0342ab7886a4eb18d736f1b67d44b37fcc81e0f39f
|
||||||
|
```
|
||||||
|
|
||||||
|
### `toBytes()`
|
||||||
|
|
||||||
|
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>
|
||||||
|
```
|
||||||
|
|
||||||
|
### `toB58String()`
|
||||||
|
|
||||||
|
Returns the Peer ID's `id` as a base58 string.
|
||||||
|
|
||||||
|
```
|
||||||
|
QmckZzdVd72h9QUFuJJpQqhsZqGLwjhh81qSvZ9BhB2FQi
|
||||||
|
```
|
||||||
|
|
||||||
|
### `toJSON()`
|
||||||
|
|
||||||
|
Returns an `obj` of the form
|
||||||
|
|
||||||
|
- `obj.id: String` - The multihash encoded in `base58`
|
||||||
|
- `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'
|
||||||
|
|
||||||
|
|
||||||
|
### `toPrint()`
|
||||||
|
|
||||||
|
Alias for `.toJSON()`.
|
||||||
|
|
||||||
|
|
||||||
# License
|
# License
|
||||||
|
|
||||||
MIT
|
MIT
|
||||||
|
@ -1,5 +0,0 @@
|
|||||||
toc:
|
|
||||||
- name: Introduction
|
|
||||||
file: intro.md
|
|
||||||
- PeerId
|
|
||||||
- PeerIdJson
|
|
61
intro.md
61
intro.md
@ -1,61 +0,0 @@
|
|||||||
Generate, import, and export PeerIDs, for use with [IPFS](https://github.com/ipfs/ipfs).
|
|
||||||
|
|
||||||
> A Peer ID is the SHA-256 [multihash](https://github.com/multiformats/multihash) of a public key.
|
|
||||||
>
|
|
||||||
> The public key is a base64 encoded string of a protobuf containing an RSA DER buffer. This uses a node buffer to pass the base64 encoded public key protobuf to the multihash for ID generation.
|
|
||||||
|
|
||||||
## Example
|
|
||||||
|
|
||||||
```js
|
|
||||||
var PeerId = require('peer-id')
|
|
||||||
|
|
||||||
PeerId.create({ bits: 1024 }, (err, id) => {
|
|
||||||
console.log(JSON.stringify(id.toJSON(), null, 2)
|
|
||||||
})
|
|
||||||
```
|
|
||||||
|
|
||||||
```json
|
|
||||||
{
|
|
||||||
"id": "Qma9T5YraSnpRDZqRR4krcSJabThc8nwZuJV3LercPHufi",
|
|
||||||
"privKey": "CAAS4AQwggJcAgEAAoGBAMBgbIqyOL26oV3nGPBYrdpbv..",
|
|
||||||
"pubKey": "CAASogEwgZ8wDQYJKoZIhvcNAQEBBQADgY0AMIGJAoGBAMBgbIqyOL26oV3nGPBYrdpbvzCY..."
|
|
||||||
}
|
|
||||||
```
|
|
||||||
|
|
||||||
## Installation
|
|
||||||
|
|
||||||
### npm
|
|
||||||
|
|
||||||
```sh
|
|
||||||
> npm i peer-id
|
|
||||||
```
|
|
||||||
|
|
||||||
## Setup
|
|
||||||
|
|
||||||
### Node.js
|
|
||||||
|
|
||||||
```js
|
|
||||||
var PeerId = require('peer-id')
|
|
||||||
```
|
|
||||||
|
|
||||||
### Browser: Browserify, Webpack, other bundlers
|
|
||||||
|
|
||||||
The code published to npm that gets loaded on require is in fact a ES5
|
|
||||||
transpiled version with the right shims added. This means that you can require
|
|
||||||
it and use with your favourite bundler without having to adjust asset management
|
|
||||||
process.
|
|
||||||
|
|
||||||
```js
|
|
||||||
var PeerId = require('peer-id')
|
|
||||||
```
|
|
||||||
|
|
||||||
### Browser: `<script>` Tag
|
|
||||||
|
|
||||||
Loading this module through a script tag will make the `PeerId` obj available in
|
|
||||||
the global namespace.
|
|
||||||
|
|
||||||
```html
|
|
||||||
<script src="https://unpkg.com/peer-id/dist/index.min.js"></script>
|
|
||||||
<!-- OR -->
|
|
||||||
<script src="https://unpkg.com/peer-id/dist/index.js"></script>
|
|
||||||
```
|
|
23
package.json
23
package.json
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "peer-id",
|
"name": "peer-id",
|
||||||
"version": "0.8.0",
|
"version": "0.8.2",
|
||||||
"description": "IPFS Peer Id implementation in Node.js",
|
"description": "IPFS Peer Id implementation in Node.js",
|
||||||
"main": "src/index.js",
|
"main": "src/index.js",
|
||||||
"bin": "src/bin.js",
|
"bin": "src/bin.js",
|
||||||
@ -14,8 +14,7 @@
|
|||||||
"release-minor": "aegir-release --type minor",
|
"release-minor": "aegir-release --type minor",
|
||||||
"release-major": "aegir-release --type major",
|
"release-major": "aegir-release --type major",
|
||||||
"coverage": "aegir-coverage",
|
"coverage": "aegir-coverage",
|
||||||
"coverage-publish": "aegir-coverage publish",
|
"coverage-publish": "aegir-coverage publish"
|
||||||
"docs": "aegir-docs"
|
|
||||||
},
|
},
|
||||||
"keywords": [
|
"keywords": [
|
||||||
"IPFS"
|
"IPFS"
|
||||||
@ -27,21 +26,22 @@
|
|||||||
"test"
|
"test"
|
||||||
],
|
],
|
||||||
"engines": {
|
"engines": {
|
||||||
"node": ">=4.0.0"
|
"node": ">=4.0.0",
|
||||||
|
"npm": ">=3.0.0"
|
||||||
},
|
},
|
||||||
"bugs": {
|
"bugs": {
|
||||||
"url": "https://github.com/libp2p/js-peer-id/issues"
|
"url": "https://github.com/libp2p/js-peer-id/issues"
|
||||||
},
|
},
|
||||||
"homepage": "https://github.com/libp2p/js-peer-id",
|
"homepage": "https://github.com/libp2p/js-peer-id",
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"aegir": "^9.1.2",
|
"aegir": "^10.0.0",
|
||||||
"chai": "^3.5.0",
|
"chai": "^3.5.0",
|
||||||
"pre-commit": "^1.1.3"
|
"pre-commit": "^1.2.2"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"async": "^2.0.1",
|
"libp2p-crypto": "~0.8.0",
|
||||||
"libp2p-crypto": "^0.7.0",
|
"multihashes": "~0.3.3",
|
||||||
"multihashes": "^0.3.0"
|
"async": "^2.1.4"
|
||||||
},
|
},
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
@ -51,10 +51,11 @@
|
|||||||
"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>",
|
||||||
|
"Greenkeeper <support@greenkeeper.io>",
|
||||||
|
"Prashanth Chandra <coolshanth94@gmail.com>",
|
||||||
"Richard Littauer <richard.littauer@gmail.com>",
|
"Richard Littauer <richard.littauer@gmail.com>",
|
||||||
"Stephen Whitmore <stephen.whitmore@gmail.com>",
|
"Stephen Whitmore <stephen.whitmore@gmail.com>",
|
||||||
"greenkeeperio-bot <support@greenkeeper.io>",
|
|
||||||
"nginnever <ginneversource@gmail.com>",
|
"nginnever <ginneversource@gmail.com>",
|
||||||
"npmcdn-to-unpkg-bot <npmcdn-to-unpkg-bot@users.noreply.github.com>"
|
"npmcdn-to-unpkg-bot <npmcdn-to-unpkg-bot@users.noreply.github.com>"
|
||||||
]
|
]
|
||||||
}
|
}
|
419
src/index.js
419
src/index.js
@ -1,3 +1,7 @@
|
|||||||
|
/*
|
||||||
|
* Id is an object representation of a peer Id. a peer Id is a multihash
|
||||||
|
*/
|
||||||
|
|
||||||
'use strict'
|
'use strict'
|
||||||
|
|
||||||
const mh = require('multihashes')
|
const mh = require('multihashes')
|
||||||
@ -5,28 +9,7 @@ const crypto = require('libp2p-crypto')
|
|||||||
const assert = require('assert')
|
const assert = require('assert')
|
||||||
const waterfall = require('async/waterfall')
|
const waterfall = require('async/waterfall')
|
||||||
|
|
||||||
/**
|
|
||||||
* @name PeerIdJson
|
|
||||||
* @type {Object}
|
|
||||||
* @typedef {Object} PeerIdJson
|
|
||||||
* @param {string} id - `Base58` encoded peer id
|
|
||||||
* @param {string=} privKey - The RSA private key in protobuf format, encoded in `base64`.
|
|
||||||
* @param {string=} pubKey - The RSA public key in protobuf format, encoded in `base64`.
|
|
||||||
*/
|
|
||||||
|
|
||||||
/**
|
|
||||||
* A Peer ID is the SHA-256
|
|
||||||
* [multihash](https://github.com/multiformats/multihash) of a
|
|
||||||
* public key.
|
|
||||||
* @class PeerId
|
|
||||||
* @see [libp2p-crypto](htttps://github.com/libp2p/js-libp2p-crypto)
|
|
||||||
*/
|
|
||||||
class PeerId {
|
class PeerId {
|
||||||
/**
|
|
||||||
* @param {Buffer} id
|
|
||||||
* @param {RSAPrivateKey=} privKey
|
|
||||||
* @param {RSAPublickKey=} pubKey
|
|
||||||
*/
|
|
||||||
constructor (id, privKey, pubKey) {
|
constructor (id, privKey, pubKey) {
|
||||||
assert(Buffer.isBuffer(id), 'invalid id provided')
|
assert(Buffer.isBuffer(id), 'invalid id provided')
|
||||||
|
|
||||||
@ -34,28 +17,24 @@ class PeerId {
|
|||||||
assert(privKey.public.bytes.equals(pubKey.bytes), 'inconsistent arguments')
|
assert(privKey.public.bytes.equals(pubKey.bytes), 'inconsistent arguments')
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
this._id = id
|
||||||
* @type {Buffer}
|
this._idB58String = mh.toB58String(this.id)
|
||||||
*/
|
|
||||||
this.id = id
|
|
||||||
this._privKey = privKey
|
this._privKey = privKey
|
||||||
this._pubKey = pubKey
|
this._pubKey = pubKey
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
get id () {
|
||||||
* The private key of this id, if it exists.
|
return this._id
|
||||||
*
|
}
|
||||||
* @type {RSAPrivateKey|undefined}
|
|
||||||
*/
|
set id (val) {
|
||||||
|
throw new Error('Id is immutable')
|
||||||
|
}
|
||||||
|
|
||||||
get privKey () {
|
get privKey () {
|
||||||
return this._privKey
|
return this._privKey
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* The public key of this id, if it exists.
|
|
||||||
*
|
|
||||||
* @type {(RSAPublicKey|undefined)}
|
|
||||||
*/
|
|
||||||
get pubKey () {
|
get pubKey () {
|
||||||
if (this._pubKey) {
|
if (this._pubKey) {
|
||||||
return this._pubKey
|
return this._pubKey
|
||||||
@ -66,274 +45,182 @@ class PeerId {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/** Create the protobuf version of the public key,
|
// Return the protobuf version of the public key,
|
||||||
* matching go-ipfs formatting.
|
// matching go ipfs formatting
|
||||||
*
|
|
||||||
* @returns {Buffer} - The marshalled public key
|
|
||||||
*/
|
|
||||||
marshalPubKey () {
|
marshalPubKey () {
|
||||||
if (this.pubKey) {
|
if (this.pubKey) {
|
||||||
return crypto.marshalPublicKey(this.pubKey)
|
return crypto.marshalPublicKey(this.pubKey)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/** Create the protobuf version of the private key,
|
// Return the protobuf version of the private key,
|
||||||
* matching go-ipfs formatting.
|
// matching go ipfs formatting
|
||||||
*
|
|
||||||
* @returns {Buffer}
|
|
||||||
*/
|
|
||||||
marshalPrivKey () {
|
marshalPrivKey () {
|
||||||
if (this.privKey) {
|
if (this.privKey) {
|
||||||
return crypto.marshalPrivateKey(this.privKey)
|
return crypto.marshalPrivateKey(this.privKey)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
// pretty print
|
||||||
* Alias for `toJSON`.
|
|
||||||
*
|
|
||||||
* @returns {PeerIdJson}
|
|
||||||
*/
|
|
||||||
toPrint () {
|
toPrint () {
|
||||||
return this.toJSON()
|
return this.toJSON()
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
// return the jsonified version of the key, matching the formatting
|
||||||
* Return the jsonified version of the key, matching the formatting
|
// of go-ipfs for its config file
|
||||||
* of go-ipfs for its config file.
|
|
||||||
*
|
|
||||||
* @returns {PeerIdJson}
|
|
||||||
*/
|
|
||||||
toJSON () {
|
toJSON () {
|
||||||
return {
|
return {
|
||||||
id: mh.toB58String(this.id),
|
id: this.toB58String(),
|
||||||
privKey: toB64Opt(this.marshalPrivKey()),
|
privKey: toB64Opt(this.marshalPrivKey()),
|
||||||
pubKey: toB64Opt(this.marshalPubKey())
|
pubKey: toB64Opt(this.marshalPubKey())
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
// encode/decode functions
|
||||||
* Returns the Peer ID's `id` as a hex string.
|
|
||||||
*
|
|
||||||
* @returns {String}
|
|
||||||
*/
|
|
||||||
toHexString () {
|
toHexString () {
|
||||||
return mh.toHexString(this.id)
|
return mh.toHexString(this.id)
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Returns the Peer ID's `id` as a buffer.
|
|
||||||
*
|
|
||||||
* @returns {Buffer}
|
|
||||||
*/
|
|
||||||
toBytes () {
|
toBytes () {
|
||||||
return this.id
|
return this.id
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Returns the Peer ID's `id` as a base58 string.
|
|
||||||
*
|
|
||||||
* @returns {String}
|
|
||||||
*/
|
|
||||||
toB58String () {
|
toB58String () {
|
||||||
return mh.toB58String(this.id)
|
return this._idB58String
|
||||||
}
|
}
|
||||||
|
}
|
||||||
/**
|
|
||||||
* Create a new `PeerId` by generating a new public/private keypair.
|
exports = module.exports = PeerId
|
||||||
*
|
exports.Buffer = Buffer
|
||||||
* @param {Object=} opts - Configuration object.
|
|
||||||
* @param {number} [opts.bits=2048] - How many bits to use for the RSA key generation.
|
// generation
|
||||||
* @param {function(Error, PeerId)} callback - Node.js style callback.
|
exports.create = function (opts, callback) {
|
||||||
* @returns {undefined}
|
if (typeof opts === 'function') {
|
||||||
*
|
callback = opts
|
||||||
* @example
|
opts = {}
|
||||||
* const PeerId = require('peer-id')
|
}
|
||||||
*
|
opts = opts || {}
|
||||||
* PeerId.create((err, id) => {
|
opts.bits = opts.bits || 2048
|
||||||
* if (err) {
|
|
||||||
* throw err
|
waterfall([
|
||||||
* }
|
(cb) => crypto.generateKeyPair('RSA', opts.bits, cb),
|
||||||
* console.log('id', JSON.stringify(id))
|
(privKey, cb) => privKey.public.hash((err, digest) => {
|
||||||
* })
|
cb(err, digest, privKey)
|
||||||
*
|
})
|
||||||
*/
|
], (err, digest, privKey) => {
|
||||||
static create (opts, callback) {
|
if (err) {
|
||||||
if (typeof opts === 'function') {
|
return callback(err)
|
||||||
callback = opts
|
}
|
||||||
opts = {}
|
|
||||||
}
|
callback(null, new PeerId(digest, privKey))
|
||||||
opts = opts || {}
|
})
|
||||||
opts.bits = opts.bits || 2048
|
}
|
||||||
|
|
||||||
waterfall([
|
exports.createFromHexString = function (str) {
|
||||||
(cb) => crypto.generateKeyPair('RSA', opts.bits, cb),
|
return new PeerId(mh.fromHexString(str))
|
||||||
(privKey, cb) => privKey.public.hash((err, digest) => {
|
}
|
||||||
cb(err, digest, privKey)
|
|
||||||
})
|
exports.createFromBytes = function (buf) {
|
||||||
], (err, digest, privKey) => {
|
return new PeerId(buf)
|
||||||
if (err) {
|
}
|
||||||
return callback(err)
|
|
||||||
}
|
exports.createFromB58String = function (str) {
|
||||||
|
return new PeerId(mh.fromB58String(str))
|
||||||
callback(null, new PeerId(digest, privKey))
|
}
|
||||||
})
|
|
||||||
}
|
// Public Key input will be a buffer
|
||||||
|
exports.createFromPubKey = function (key, callback) {
|
||||||
/**
|
let buf = key
|
||||||
* Creates a Peer ID from hex string representing the key's multihash.
|
if (typeof buf === 'string') {
|
||||||
*
|
buf = new Buffer(key, 'base64')
|
||||||
* @param {string} str - Hex encoded id
|
}
|
||||||
* @returns {PeerId}
|
|
||||||
*/
|
if (typeof callback !== 'function') {
|
||||||
static createFromHexString (str) {
|
throw new Error('callback is required')
|
||||||
return new PeerId(mh.fromHexString(str))
|
}
|
||||||
}
|
|
||||||
|
const pubKey = crypto.unmarshalPublicKey(buf)
|
||||||
/**
|
pubKey.hash((err, digest) => {
|
||||||
* Creates a Peer ID from a buffer representing the key's multihash.
|
if (err) {
|
||||||
*
|
return callback(err)
|
||||||
* @param {Buffer} buf
|
}
|
||||||
* @returns {PeerId}
|
|
||||||
*/
|
callback(null, new PeerId(digest, null, pubKey))
|
||||||
static createFromBytes (buf) {
|
})
|
||||||
return new PeerId(buf)
|
}
|
||||||
}
|
|
||||||
|
// Private key input will be a string
|
||||||
/**
|
exports.createFromPrivKey = function (key, callback) {
|
||||||
* Creates a Peer ID from a `base58` string representing the
|
let buf = key
|
||||||
* key's multihash.
|
if (typeof buf === 'string') {
|
||||||
*
|
buf = new Buffer(key, 'base64')
|
||||||
* @param {string} str - `base58` encoded id
|
}
|
||||||
* @returns {PeerId}
|
|
||||||
*/
|
if (typeof callback !== 'function') {
|
||||||
static createFromB58String (str) {
|
throw new Error('callback is required')
|
||||||
return new PeerId(mh.fromB58String(str))
|
}
|
||||||
}
|
|
||||||
|
waterfall([
|
||||||
/**
|
(cb) => crypto.unmarshalPrivateKey(buf, cb),
|
||||||
* Creates a Peer ID from a buffer containing a public key.
|
(privKey, cb) => privKey.public.hash((err, digest) => {
|
||||||
*
|
cb(err, digest, privKey)
|
||||||
* @param {string|Buffer} key
|
})
|
||||||
* @param {function(Error, PeerId)} callback
|
], (err, digest, privKey) => {
|
||||||
* @returns {undefined}
|
if (err) {
|
||||||
*/
|
return callback(err)
|
||||||
static createFromPubKey (key, callback) {
|
}
|
||||||
let buf = key
|
|
||||||
if (typeof buf === 'string') {
|
callback(null, new PeerId(digest, privKey))
|
||||||
buf = new Buffer(key, 'base64')
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
if (typeof callback !== 'function') {
|
exports.createFromJSON = function (obj, callback) {
|
||||||
throw new Error('callback is required')
|
if (typeof callback !== 'function') {
|
||||||
}
|
throw new Error('callback is required')
|
||||||
|
}
|
||||||
const pubKey = crypto.unmarshalPublicKey(buf)
|
|
||||||
pubKey.hash((err, digest) => {
|
const id = mh.fromB58String(obj.id)
|
||||||
if (err) {
|
const rawPrivKey = obj.privKey && new Buffer(obj.privKey, 'base64')
|
||||||
return callback(err)
|
const rawPubKey = obj.pubKey && new Buffer(obj.pubKey, 'base64')
|
||||||
}
|
const pub = rawPubKey && crypto.unmarshalPublicKey(rawPubKey)
|
||||||
|
|
||||||
callback(null, new PeerId(digest, null, pubKey))
|
if (rawPrivKey) {
|
||||||
})
|
waterfall([
|
||||||
}
|
(cb) => crypto.unmarshalPrivateKey(rawPrivKey, cb),
|
||||||
|
(priv, cb) => priv.public.hash((err, digest) => {
|
||||||
/**
|
cb(err, digest, priv)
|
||||||
* Creates a Peer ID from a buffer containing a private key.
|
}),
|
||||||
*
|
(privDigest, priv, cb) => {
|
||||||
* @param {string|Buffer} key - The private key, if passed as
|
if (pub) {
|
||||||
* string `base64` encoding is assumed.
|
pub.hash((err, pubDigest) => {
|
||||||
* @param {function(Error, PeerId)} callback
|
cb(err, privDigest, priv, pubDigest)
|
||||||
* @returns {undefined}
|
})
|
||||||
*/
|
} else {
|
||||||
static createFromPrivKey (key, callback) {
|
cb(null, privDigest, priv)
|
||||||
let buf = key
|
}
|
||||||
if (typeof buf === 'string') {
|
}
|
||||||
buf = new Buffer(key, 'base64')
|
], (err, privDigest, priv, pubDigest) => {
|
||||||
}
|
if (err) {
|
||||||
|
return callback(err)
|
||||||
if (typeof callback !== 'function') {
|
}
|
||||||
throw new Error('callback is required')
|
|
||||||
}
|
if (pub && !privDigest.equals(pubDigest)) {
|
||||||
|
return callback(new Error('Public and private key do not match'))
|
||||||
waterfall([
|
}
|
||||||
(cb) => crypto.unmarshalPrivateKey(buf, cb),
|
|
||||||
(privKey, cb) => privKey.public.hash((err, digest) => {
|
if (id && !privDigest.equals(id)) {
|
||||||
cb(err, digest, privKey)
|
return callback(new Error('Id and private key do not match'))
|
||||||
})
|
}
|
||||||
], (err, digest, privKey) => {
|
|
||||||
if (err) {
|
callback(null, new PeerId(id, priv, pub))
|
||||||
return callback(err)
|
})
|
||||||
}
|
} else {
|
||||||
|
callback(null, new PeerId(id, null, pub))
|
||||||
callback(null, new PeerId(digest, privKey))
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Import a `PeerId` from a serialized JSON object.
|
|
||||||
*
|
|
||||||
* @param {PeerIdJson} obj
|
|
||||||
* @param {function(Error, PeerId)} callback
|
|
||||||
* @returns {undefined}
|
|
||||||
*/
|
|
||||||
static createFromJSON (obj, callback) {
|
|
||||||
if (typeof callback !== 'function') {
|
|
||||||
throw new Error('callback is required')
|
|
||||||
}
|
|
||||||
|
|
||||||
const id = mh.fromB58String(obj.id)
|
|
||||||
const rawPrivKey = obj.privKey && new Buffer(obj.privKey, 'base64')
|
|
||||||
const rawPubKey = obj.pubKey && new Buffer(obj.pubKey, 'base64')
|
|
||||||
const pub = rawPubKey && crypto.unmarshalPublicKey(rawPubKey)
|
|
||||||
|
|
||||||
if (rawPrivKey) {
|
|
||||||
waterfall([
|
|
||||||
(cb) => crypto.unmarshalPrivateKey(rawPrivKey, cb),
|
|
||||||
(priv, cb) => priv.public.hash((err, digest) => {
|
|
||||||
cb(err, digest, priv)
|
|
||||||
}),
|
|
||||||
(privDigest, priv, cb) => {
|
|
||||||
if (pub) {
|
|
||||||
pub.hash((err, pubDigest) => {
|
|
||||||
cb(err, privDigest, priv, pubDigest)
|
|
||||||
})
|
|
||||||
} else {
|
|
||||||
cb(null, privDigest, priv)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
], (err, privDigest, priv, pubDigest) => {
|
|
||||||
if (err) {
|
|
||||||
return callback(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
if (pub && !privDigest.equals(pubDigest)) {
|
|
||||||
return callback(new Error('Public and private key do not match'))
|
|
||||||
}
|
|
||||||
|
|
||||||
if (id && !privDigest.equals(id)) {
|
|
||||||
return callback(new Error('Id and private key do not match'))
|
|
||||||
}
|
|
||||||
|
|
||||||
callback(null, new PeerId(id, priv, pub))
|
|
||||||
})
|
|
||||||
} else {
|
|
||||||
callback(null, new PeerId(id, null, pub))
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Convert a given `Buffer` to a `base64` encoded string.
|
|
||||||
* If no `val` is given it just returns `undefined`.
|
|
||||||
*
|
|
||||||
* @private
|
|
||||||
* @param {Buffer=} val
|
|
||||||
* @returns {string|undefined}
|
|
||||||
*/
|
|
||||||
function toB64Opt (val) {
|
function toB64Opt (val) {
|
||||||
if (val) {
|
if (val) {
|
||||||
return val.toString('base64')
|
return val.toString('base64')
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
exports = module.exports = PeerId
|
|
||||||
|
@ -29,6 +29,17 @@ describe('PeerId', () => {
|
|||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
|
it('throws on changing the id', (done) => {
|
||||||
|
PeerId.create((err, id) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
expect(id.toB58String().length).to.equal(46)
|
||||||
|
expect(() => {
|
||||||
|
id.id = new Buffer('hello')
|
||||||
|
}).to.throw(/immutable/)
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
it('recreate an Id from Hex string', () => {
|
it('recreate an Id 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.id)
|
||||||
|
Reference in New Issue
Block a user