feat: metadata book

libp2p · May 13, 2020 · 8076b42 · 8076b42
1 parent 171af8a
commit 8076b42
Show file tree

Hide file tree

Showing 11 changed files with 885 additions and 15 deletions.
diff --git a/doc/API.md b/doc/API.md
@@ -29,6 +29,11 @@
   * [`peerStore.keyBook.delete`](#peerstorekeybookdelete)
   * [`peerStore.keyBook.get`](#peerstorekeybookget)
   * [`peerStore.keyBook.set`](#peerstorekeybookset)
+  * [`peerStore.metadataBook.delete`](#peerstoremetadatabookdelete)
+  * [`peerStore.metadataBook.deleteValue`](#peerstoremetadatabookdeletevalue)
+  * [`peerStore.metadataBook.get`](#peerstoremetadatabookget)
+  * [`peerStore.metadataBook.getValue`](#peerstoremetadatabookgetvalue)
+  * [`peerStore.metadataBook.set`](#peerstoremetadatabookset)
   * [`peerStore.protoBook.add`](#peerstoreprotobookadd)
   * [`peerStore.protoBook.delete`](#peerstoreprotobookdelete)
   * [`peerStore.protoBook.get`](#peerstoreprotobookget)
@@ -939,6 +944,146 @@ const publicKey = peerId.pubKey
 peerStore.keyBook.set(peerId, publicKey)
 ```
 
+### peerStore.metadataBook.delete
+
+Delete the provided peer from the book.
+
+`peerStore.metadataBook.delete(peerId)`
+
+#### Parameters
+
+| Name | Type | Description |
+|------|------|-------------|
+| peerId | [`PeerId`][peer-id] | peerId to remove |
+
+#### Returns
+
+| Type | Description |
+|------|-------------|
+| `boolean` | true if found and removed |
+
+#### Example
+
+```js
+peerStore.metadataBook.delete(peerId)
+// false
+peerStore.metadataBook.set(peerId, 'nickname', Buffer.from('homePeer'))
+peerStore.metadataBook.delete(peerId)
+// true
+```
+
+### peerStore.metadataBook.deleteValue
+
+Deletes the provided peer metadata key from the book.
+
+`peerStore.metadataBook.deleteValue(peerId, key)`
+
+#### Parameters
+
+| Name | Type | Description |
+|------|------|-------------|
+| peerId | [`PeerId`][peer-id] | peerId to remove |
+| key | `string` | key of the metadata value to remove |
+
+#### Returns
+
+| Type | Description |
+|------|-------------|
+| `boolean` | true if found and removed |
+
+#### Example
+
+```js
+peerStore.metadataBook.deleteValue(peerId, 'location')
+// false
+peerStore.metadataBook.set(peerId, 'location', Buffer.from('Berlin'))
+peerStore.metadataBook.deleteValue(peerId, 'location')
+// true
+```
+
+### peerStore.metadataBook.get
+
+Get the known metadata of a provided peer.
+
+`peerStore.metadataBook.get(peerId)`
+
+#### Parameters
+
+| Name | Type | Description |
+|------|------|-------------|
+| peerId | [`PeerId`][peer-id] | peerId to get |
+
+#### Returns
+
+| Type | Description |
+|------|-------------|
+| `Map<string, Buffer>` | Peer Metadata |
+
+#### Example
+
+```js
+peerStore.metadataBook.get(peerId)
+// undefined
+peerStore.metadataBook.set(peerId, 'location', Buffer.from('Berlin'))
+peerStore.metadataBook.get(peerId)
+// Metadata Map
+```
+
+### peerStore.metadataBook.getValue
+
+Get specific metadata of a provided peer.
+
+`peerStore.metadataBook.getValue(peerId)`
+
+#### Parameters
+
+| Name | Type | Description |
+|------|------|-------------|
+| peerId | [`PeerId`][peer-id] | peerId to get |
+| key | `string` | key of the metadata value to get |
+
+#### Returns
+
+| Type | Description |
+|------|-------------|
+| `Map<string, Buffer>` | Peer Metadata |
+
+#### Example
+
+```js
+peerStore.metadataBook.getValue(peerId, 'location')
+// undefined
+peerStore.metadataBook.set(peerId, 'location', Buffer.from('Berlin'))
+peerStore.metadataBook.getValue(peerId, 'location')
+// Metadata Map
+```
+
+### peerStore.metadataBook.set
+
+Set known metadata of a given `peerId`.
+
+`peerStore.metadataBook.set(peerId, key, value)`
+
+#### Parameters
+
+| Name | Type | Description |
+|------|------|-------------|
+| peerId | [`PeerId`][peer-id] | peerId to set |
+| key | `string` | key of the metadata value to store |
+| value | `Buffer` | metadata value to store |
+
+#### Returns
+
+| Type | Description |
+|------|-------------|
+| `MetadataBook` | Returns the Metadata Book component |
+
+#### Example
+
+```js
+peerStore.metadataBook.set(peerId, 'location', Buffer.from('Berlin'))
+```
+
 ### peerStore.protoBook.delete
 
 Delete the provided peer from the book.

diff --git a/src/peer-store/README.md b/src/peer-store/README.md
@@ -70,7 +70,11 @@ A `peerId.toB58String()` identifier mapping to a `Set` of protocol identifier st
 
 #### Metadata Book
 
-**Not Yet Implemented**
+The `metadataBook` keeps track of the known metadata of a peer. Its metadata is stored in a key value fashion, where a key identifier (`string`) represents a metadata value (`Buffer`).
+
+`Map<string, Map<string, Buffer>>`
+
+A `peerId.toB58String()` identifier mapping to the peer metadata Map.
 
 ### API
 
@@ -80,13 +84,16 @@ Access to its underlying books:
 
 - `peerStore.addressBook.*`
 - `peerStore.keyBook.*`
+- `peerStore.metadataBook.*`
 - `peerStore.protoBook.*`
 
 ### Events
 
 - `peer` - emitted when a new peer is added.
 - `change:multiaadrs` - emitted when a known peer has a different set of multiaddrs.
 - `change:protocols` - emitted when a known peer supports a different set of protocols.
+- `change:pubkey` - emitted when a peer's public key is known.
+- `change:metadata` - emitted when known metadata of a peer changes.
 
 ## Data Persistence
 
@@ -118,8 +125,6 @@ All public keys are stored under the following pattern:
 
 **MetadataBook**
 
-_NOT_YET_IMPLEMENTED_
-
 Metadata is stored under the following key pattern:
 
 `/peers/metadata/<b32 peer id no padding>/<key>`

diff --git a/src/peer-store/address-book.js b/src/peer-store/address-book.js
@@ -97,7 +97,6 @@ class AddressBook extends Book {
   /**
    * Add known addresses of a provided peer.
    * If the peer is not known, it is set with the given addresses.
-   * @override
    * @param {PeerId} peerId
    * @param {Array<Multiaddr>} multiaddrs
    * @returns {AddressBook}

diff --git a/src/peer-store/index.js b/src/peer-store/index.js
@@ -10,6 +10,7 @@ const PeerId = require('peer-id')
 
 const AddressBook = require('./address-book')
 const KeyBook = require('./key-book')
+const MetadataBook = require('./metadata-book')
 const ProtoBook = require('./proto-book')
 
 const {
@@ -21,6 +22,8 @@ const {
  * @fires PeerStore#peer Emitted when a new peer is added.
  * @fires PeerStore#change:protocols Emitted when a known peer supports a different set of protocols.
  * @fires PeerStore#change:multiaddrs Emitted when a known peer has a different set of multiaddrs.
+ * @fires PeerStore#change:pubkey Emitted emitted when a peer's public key is known.
+ * @fires PeerStore#change:metadata Emitted when the known metadata of a peer change.
  */
 class PeerStore extends EventEmitter {
   /**
@@ -47,6 +50,11 @@ class PeerStore extends EventEmitter {
      */
     this.keyBook = new KeyBook(this)
 
+    /**
+     * MetadataBook containing a map of peerIdStr to their metadata Map.
+     */
+    this.metadataBook = new MetadataBook(this)
+
     /**
      * ProtoBook containing a map of peerIdStr to supported protocols.
      */
@@ -76,6 +84,7 @@ class PeerStore extends EventEmitter {
       peersData.set(idStr, {
         id,
         addresses,
+        metadata: this.metadataBook.get(id),
         protocols: this.protoBook.get(id) || []
       })
     }
@@ -89,11 +98,40 @@ class PeerStore extends EventEmitter {
         peersData.set(idStr, {
           id,
           addresses: [],
+          metadata: this.metadataBook.get(id),
           protocols: Array.from(protocols)
         })
       }
     }
 
+    // KeyBook
+    for (const [idStr, peerId] of this.protoBook.data.entries()) {
+      const pData = peersData.get(idStr)
+
+      if (!pData) {
+        peersData.set(idStr, {
+          id: peerId,
+          addresses: [],
+          metadata: this.metadataBook.get(peerId),
+          protocols: []
+        })
+      }
+    }
+
+    // MetadataBook
+    for (const [idStr, metadata] of this.metadataBook.data.entries()) {
+      const pData = peersData.get(idStr)
+
+      if (!pData) {
+        peersData.set(idStr, {
+          id: PeerId.createFromCID(idStr),
+          addresses: [],
+          metadata,
+          protocols: []
+        })
+      }
+    }
+
     return peersData
   }
 
@@ -106,8 +144,9 @@ class PeerStore extends EventEmitter {
     const addressesDeleted = this.addressBook.delete(peerId)
     const keyDeleted = this.keyBook.delete(peerId)
     const protocolsDeleted = this.protoBook.delete(peerId)
+    const metadataDeleted = this.metadataBook.delete(peerId)
 
-    return addressesDeleted || keyDeleted || protocolsDeleted
+    return addressesDeleted || keyDeleted || protocolsDeleted || metadataDeleted
   }
 
   /**
@@ -122,16 +161,18 @@ class PeerStore extends EventEmitter {
 
     const id = this.keyBook.data.get(peerId.toB58String())
     const addresses = this.addressBook.get(peerId)
+    const metadata = this.metadataBook.get(peerId)
     const protocols = this.protoBook.get(peerId)
 
-    if (!addresses && !protocols) {
+    if (!addresses && !metadata && !protocols) {
       return undefined
     }
 
     return {
       id: id || peerId,
       addresses: addresses || [],
-      protocols: protocols || []
+      protocols: protocols || [],
+      metadata: metadata
     }
   }
 }