js-libp2p/src/peer-store/key-book.js

'use strict'

const debug = require('debug')
const log = Object.assign(debug('libp2p:peer-store:key-book'), {
  error: debug('libp2p:peer-store:key-book:err')
})
const errcode = require('err-code')

const PeerId = require('peer-id')

const Book = require('./book')

const {
  codes: { ERR_INVALID_PARAMETERS }
} = require('../errors')

/**
 * @typedef {import('./')} PeerStore
 * @typedef {import('libp2p-crypto').PublicKey} PublicKey
 */

/**
 * @extends {Book<PeerId, PublicKey, PublicKey>}
 */
class KeyBook extends Book {
  /**
   * The KeyBook is responsible for keeping the known public keys of a peer.
   *
   * @class
   * @param {PeerStore} peerStore
   */
  constructor (peerStore) {
    super({
      peerStore,
      eventName: 'change:pubkey',
      eventProperty: 'pubkey',
      eventTransformer: (data) => data && data.pubKey,
      getTransformer: (data) => data && data.pubKey
    })

    /**
     * Map known peers to their known Public Key.
     *
     * @type {Map<string, PeerId>}
     */
    this.data = new Map()
  }

  /**
   * Set the Peer public key.
   *
   * @override
   * @param {PeerId} peerId
   * @param {PublicKey} publicKey
   * @returns {KeyBook}
   */
  set (peerId, publicKey) {
    if (!PeerId.isPeerId(peerId)) {
      log.error('peerId must be an instance of peer-id to store data')
      throw errcode(new Error('peerId must be an instance of peer-id'), ERR_INVALID_PARAMETERS)
    }

    const id = peerId.toB58String()
    const recPeerId = this.data.get(id)

    // If no record available, and this is valid
    if (!recPeerId && publicKey) {
      // This might be unecessary, but we want to store the PeerId
      // to avoid an async operation when reconstructing the PeerId
      peerId.pubKey = publicKey

      this._setData(peerId, peerId)
      log(`stored provided public key for ${id}`)
    }

    return this
  }
}

module.exports = KeyBook