chore: fix types

package.json

@@ -31,6 +31,7 @@
     "src"
   ],
   "scripts": {
+    "prepare": "npm run build",
     "build": "npm run build:proto && npm run build:proto-types && npm run build:bundle",
     "build:proto": "pbjs -t static-module -w commonjs --force-number --no-verify --no-delimited --no-create --no-beautify --no-defaults --lint eslint-disable -o src/types/message/message.js src/types/message/message.proto",
     "build:proto-types": "pbts -o src/types/message/message.d.ts src/types/message/message.js",
@@ -70,7 +71,7 @@
     "assert": "^2.0.0",
     "benchmark": "^2.1.4",
     "delay": "^5.0.0",
-    "ipfs-repo": "^9.0.0",
+    "ipfs-repo": "^9.1.0",
     "ipfs-utils": "^6.0.1",
     "iso-random-stream": "^2.0.0",
     "it-all": "^1.0.5",
@@ -97,10 +98,9 @@
   "dependencies": {
     "abort-controller": "^3.0.0",
     "any-signal": "^2.1.2",
-    "bignumber.js": "^9.0.0",
     "cids": "^1.1.6",
     "debug": "^4.2.0",
-    "ipfs-core-types": "^0.3.1",
+    "ipfs-core-types": "next",
     "ipld-block": "^0.11.0",
     "it-length-prefixed": "^5.0.2",
     "it-pipe": "^1.1.0",

src/decision-engine/index.js

@@ -1,9 +1,9 @@
 'use strict'
 
 /**
- * @typedef {import('peer-id')} PeerId
- * @typedef {import('ipfs-core-types/src/block-service').Block} Block
+ * @typedef {import('ipld-block')} Block
  * @typedef {import('../types/message/entry')} BitswapMessageEntry
+ * @typedef {import('peer-id')} PeerId
  */
 
 const CID = require('cids')
@@ -34,7 +34,7 @@ const MAX_SIZE_REPLACE_HAS_WITH_BLOCK = 1024
 class DecisionEngine {
   /**
    * @param {PeerId} peerId
-   * @param {import('ipfs-core-types/src/block-store').BlockStore} blockstore
+   * @param {import('ipfs-repo').Blockstore} blockstore
    * @param {import('../network')} network
    * @param {import('../stats')} stats
    * @param {Object} [opts]
@@ -180,15 +180,16 @@ class DecisionEngine {
 
   /**
    * @param {PeerId} peerId
-   * @returns {import('ipfs-core-types/src/bitswap').LedgerForPeer|null}
    */
   ledgerForPeer (peerId) {
     const peerIdStr = peerId.toB58String()
 
     const ledger = this.ledgerMap.get(peerIdStr)
+
     if (!ledger) {
       return null
     }
+
     return {
       peer: ledger.partner.toPrint(),
       value: ledger.debtRatio(),

src/index.js

@@ -10,11 +10,7 @@ const { AbortController } = require('native-abort-controller')
 const { anySignal } = require('any-signal')
 
 /**
- * @typedef {import('ipfs-core-types/src/basic').AbortOptions} AbortOptions
- * @typedef {import('ipfs-core-types/src/bitswap').Bitswap} API
- * @typedef {import('ipfs-core-types/src/bitswap').WantListEntry} WantListEntry
- * @typedef {import('ipfs-core-types/src/bitswap').LedgerForPeer} LedgerForPeer
- * @typedef {import('ipfs-core-types/src/block-service').Block} Block
+ * @typedef {import('ipld-block')} Block
  * @typedef {import('peer-id')} PeerId
  * @typedef {import('./types/message')} BitswapMessage
  * @typedef {import('cids')} CID
@@ -40,13 +36,11 @@ const statsKeys = [
 /**
  * JavaScript implementation of the Bitswap 'data exchange' protocol
  * used by IPFS.
- *
- * @implements {API}
  */
 class Bitswap {
   /**
    * @param {import('libp2p')} libp2p
-   * @param {import('ipfs-core-types/src/block-store').BlockStore} blockstore
+   * @param {import('ipfs-repo').Blockstore} blockstore
    * @param {Object} [options]
    * @param {boolean} [options.statsEnabled=false]
    * @param {number} [options.statsComputeThrottleTimeout=1000]
@@ -91,7 +85,6 @@ class Bitswap {
    *
    * @param {PeerId} peerId
    * @param {BitswapMessage} incoming
-   * @returns {Promise<void>}
    */
   async _receiveMessage (peerId, incoming) {
     try {
@@ -130,7 +123,6 @@ class Bitswap {
    * @param {PeerId} peerId
    * @param {Block} block
    * @param {boolean} wasWanted
-   * @returns {Promise<void>}
    */
   async _handleReceivedBlock (peerId, block, wasWanted) {
     this._log('received block')
@@ -166,7 +158,6 @@ class Bitswap {
    * handle errors on the receiving channel
    *
    * @param {Error} err
-   * @returns {void}
    */
   _receiveError (err) {
     this._log.error('ReceiveError: %s', err.message)
@@ -192,16 +183,10 @@ class Bitswap {
     this._stats.disconnected(peerId)
   }
 
-  /**
-   * @returns {void}
-   */
   enableStats () {
     this._stats.enable()
   }
 
-  /**
-   * @returns {void}
-   */
   disableStats () {
     this._stats.disable()
   }
@@ -210,8 +195,7 @@ class Bitswap {
    * Return the current wantlist for a given `peerId`
    *
    * @param {PeerId} peerId
-   * @param {AbortOptions} [_options]
-   * @returns {Map<string, WantListEntry>}
+   * @param {any} [_options]
    */
   wantlistForPeer (peerId, _options) {
     return this.engine.wantlistForPeer(peerId)
@@ -221,7 +205,6 @@ class Bitswap {
    * Return ledger information for a given `peerId`
    *
    * @param {PeerId} peerId
-   * @returns {null|LedgerForPeer}
    */
   ledgerForPeer (peerId) {
     return this.engine.ledgerForPeer(peerId)
@@ -234,14 +217,12 @@ class Bitswap {
    * @param {CID} cid
    * @param {Object} [options]
    * @param {AbortSignal} [options.signal]
-   * @returns {Promise<Block>}
    */
   async get (cid, options = {}) {
     /**
      * @param {CID} cid
      * @param {Object} options
      * @param {AbortSignal} options.signal
-     * @returns {Promise<Block>}
      */
     const fetchFromNetwork = (cid, options) => {
       // add it to the want list - n.b. later we will abort the AbortSignal
@@ -258,7 +239,6 @@ class Bitswap {
      * @param {CID} cid
      * @param {Object} options
      * @param {AbortSignal} options.signal
-     * @returns {Promise<Block>}
      */
     const loadOrFetchFromNetwork = async (cid, options) => {
       try {
@@ -314,7 +294,6 @@ class Bitswap {
    * @param {AsyncIterable<CID>|Iterable<CID>} cids
    * @param {Object} [options]
    * @param {AbortSignal} [options.signal]
-   * @returns {AsyncIterable<Block>}
    */
   async * getMany (cids, options = {}) {
     for await (const cid of cids) {
@@ -331,7 +310,6 @@ class Bitswap {
    * AbortSignal in to `.get` or `.getMany` and abort it.
    *
    * @param {CID[]|CID} cids
-   * @returns {void}
    */
   unwant (cids) {
     const cidsArray = Array.isArray(cids) ? cids : [cids]
@@ -346,7 +324,6 @@ class Bitswap {
    * call `unwant(cids)` instead.
    *
    * @param {CID[]|CID} cids
-   * @returns {void}
    */
   cancelWants (cids) {
     this.wm.cancelWants(Array.isArray(cids) ? cids : [cids])
@@ -357,8 +334,7 @@ class Bitswap {
    * send it to nodes that have it in their wantlist.
    *
    * @param {Block} block
-   * @param {AbortOptions} [_options]
-   * @returns {Promise<void>}
+   * @param {any} [_options]
    */
   async put (block, _options) {
     await this.blockstore.put(block)
@@ -370,7 +346,6 @@ class Bitswap {
    * send it to nodes that have it them their wantlist.
    *
    * @param {AsyncIterable<Block>|Iterable<Block>} blocks
-   * @returns {AsyncIterable<Block>}
    */
   async * putMany (blocks) {
     for await (const block of this.blockstore.putMany(blocks)) {
@@ -396,36 +371,28 @@ class Bitswap {
   }
 
   /**
-   * Get the current list of wants.
-   *
-   * @returns {Iterable<[string, WantListEntry]>}
+   * Get the current list of wants
    */
   getWantlist () {
     return this.wm.wantlist.entries()
   }
 
   /**
-   * Get the current list of partners.
-   *
-   * @returns {PeerId[]}
+   * Get the current list of partners
    */
   peers () {
     return this.engine.peers()
   }
 
   /**
-   * Get stats about the bitswap node.
-   *
-   * @returns {import('ipfs-core-types/src/bitswap').Stats}
+   * Get stats about the bitswap node
    */
   stat () {
     return this._stats
   }
 
   /**
-   * Start the bitswap node.
-   *
-   * @returns {void}
+   * Start the bitswap node
    */
   start () {
     this.wm.start()
@@ -434,9 +401,7 @@ class Bitswap {
   }
 
   /**
-   * Stop the bitswap node.
-   *
-   * @returns {void}
+   * Stop the bitswap node
    */
   stop () {
     this._stats.stop()

src/network.js

@@ -102,7 +102,6 @@ class Network {
    * @param {string} connection.protocol - The protocol the stream is running
    * @param {Stream} connection.stream - A duplex iterable stream
    * @param {Connection} connection.connection - A libp2p Connection
-   * @returns {Promise<void>}
    */
   async _onConnection ({ protocol, stream, connection }) {
     if (!this._running) { return }
@@ -143,7 +142,6 @@ class Network {
   /**
    * @private
    * @param {PeerId} peerId
-   * @returns {void}
    */
   _onPeerDisconnect (peerId) {
     this._bitswap._onPeerDisconnected(peerId)
@@ -177,7 +175,6 @@ class Network {
    * @param {CID} cid
    * @param {Object} [options]
    * @param {AbortSignal} [options.signal]
-   * @returns {Promise<void>}
    */
   async findAndConnect (cid, options) {
     const connectAttempts = []
@@ -194,7 +191,6 @@ class Network {
    * @param {CID} cid
    * @param {Object} [options]
    * @param {AbortSignal} [options.signal]
-   * @returns {Promise<void>}
    */
   async provide (cid, options) {
     // @ts-expect-error - contentRouting takes no options
@@ -207,7 +203,6 @@ class Network {
    *
    * @param {PeerId} peer
    * @param {Message} msg
-   * @returns {Promise<void>}
    */
   async sendMessage (peer, msg) {
     if (!this._running) throw new Error('network isn\'t running')

src/notifications.js

@@ -9,7 +9,7 @@ const CONSTANTS = require('./constants')
 const logger = require('./utils').logger
 
 /**
- * @typedef {import('ipfs-core-types/src/block-service').Block} Block
+ * @typedef {import('ipld-block')} Block
  */
 
 /**

src/stats/index.js

@@ -4,8 +4,8 @@ const { EventEmitter } = require('events')
 const Stat = require('./stat')
 
 /**
+ * @typedef {import('cids')} CID
  * @typedef {import('peer-id')} PeerId
- * @typedef {import('ipfs-core-types/src/bitswap').Stats} API
  */
 
 /**
@@ -22,9 +22,6 @@ const defaultOptions = {
   ])
 }
 
-/**
- * @implements {API}
- */
 class Stats extends EventEmitter {
   /**
    * @param {string[]} [initialCounters]

src/stats/stat.js

@@ -1,7 +1,6 @@
 'use strict'
 
 const { EventEmitter } = require('events')
-const { BigNumber: Big } = require('bignumber.js')
 const MovingAverage = require('moving-average')
 
 /**
@@ -24,7 +23,7 @@ class Stats extends EventEmitter {
     this._options = options
     /** @type {Op[]} */
     this._queue = []
-    /** @type {Record<string, Big>} */
+    /** @type {Record<string, bigint>} */
     this._stats = {}
 
     this._frequencyLastTime = Date.now()
@@ -37,7 +36,7 @@ class Stats extends EventEmitter {
     this._update = this._update.bind(this)
 
     initialCounters.forEach((key) => {
-      this._stats[key] = new Big(0)
+      this._stats[key] = BigInt(0)
       this._movingAverages[key] = {}
       this._options.movingAverageIntervals.forEach((interval) => {
         const ma = this._movingAverages[key][interval] = MovingAverage(interval)
@@ -173,14 +172,11 @@ class Stats extends EventEmitter {
       throw new Error(`invalid increment number: ${inc}`)
     }
 
-    let n
-
     if (!Object.prototype.hasOwnProperty.call(this._stats, key)) {
-      n = this._stats[key] = new Big(0)
-    } else {
-      n = this._stats[key]
+      this._stats[key] = BigInt(0)
     }
-    this._stats[key] = n.plus(inc)
+
+    this._stats[key] = BigInt(this._stats[key]) + BigInt(inc)
 
     if (!this._frequencyAccumulators[key]) {
       this._frequencyAccumulators[key] = 0