fix: add buffer

package.json

@@ -40,6 +40,7 @@
     "abort-controller": "^3.0.0",
     "async": "^2.6.2",
     "base32.js": "~0.1.0",
+    "buffer": "^5.6.0",
     "cids": "~0.8.0",
     "debug": "^4.1.1",
     "err-code": "^2.0.0",

src/message/index.js

@@ -4,7 +4,7 @@ const PeerId = require('peer-id')
 const multiaddr = require('multiaddr')
 const protons = require('protons')
 const { Record } = require('libp2p-record')
-
+const { Buffer } = require('buffer')
 const pbm = protons(require('./dht.proto'))
 
 const MESSAGE_TYPE = pbm.Message.MessageType

src/providers.js

@@ -5,7 +5,7 @@ const varint = require('varint')
 const PeerId = require('peer-id')
 const { Key } = require('interface-datastore')
 const { default: Queue } = require('p-queue')
-
+const { Buffer } = require('buffer')
 const c = require('./constants')
 const utils = require('./utils')
 

src/rpc/handlers/find-node.js

@@ -1,5 +1,6 @@
 'use strict'
 
+const { Buffer } = require('buffer')
 const Message = require('../../message')
 const utils = require('../../utils')
 

src/utils.js

@@ -10,6 +10,7 @@ const pMap = require('p-map')
 const { Record } = require('libp2p-record')
 const PeerId = require('peer-id')
 const errcode = require('err-code')
+const { Buffer } = require('buffer')
 
 /**
  * Creates a DHT ID by hashing a given buffer.

test/kad-dht.spec.js

@@ -6,7 +6,7 @@ chai.use(require('dirty-chai'))
 chai.use(require('chai-checkmark'))
 const expect = chai.expect
 const sinon = require('sinon')
-
+const { Buffer } = require('buffer')
 const multiaddr = require('multiaddr')
 const { Record } = require('libp2p-record')
 const errcode = require('err-code')

test/kad-utils.spec.js

@@ -1,6 +1,7 @@
 /* eslint-env mocha */
 'use strict'
 
+const { Buffer } = require('buffer')
 const chai = require('chai')
 chai.use(require('dirty-chai'))
 const expect = chai.expect

test/message.spec.js

@@ -11,7 +11,7 @@ const random = require('lodash.random')
 const { Record } = require('libp2p-record')
 const fs = require('fs')
 const path = require('path')
-
+const { Buffer } = require('buffer')
 const Message = require('../src/message')
 
 describe('Message', () => {

test/multiple-nodes.spec.js

@@ -4,7 +4,7 @@
 const chai = require('chai')
 chai.use(require('dirty-chai'))
 const expect = chai.expect
-
+const { Buffer } = require('buffer')
 const TestDHT = require('./utils/test-dht')
 
 describe('multiple nodes', () => {

test/network.spec.js

@@ -4,7 +4,7 @@
 const chai = require('chai')
 chai.use(require('dirty-chai'))
 const expect = chai.expect
-
+const { Buffer } = require('buffer')
 const pair = require('it-pair')
 const pipe = require('it-pipe')
 const delay = require('delay')

test/peer-distance-list.spec.js

@@ -5,7 +5,7 @@ const chai = require('chai')
 chai.use(require('dirty-chai'))
 const expect = chai.expect
 const PeerId = require('peer-id')
-
+const { Buffer } = require('buffer')
 const kadUtils = require('../src/utils')
 const PeerDistanceList = require('../src/peer-list/peer-distance-list')
 

test/peer-queue.spec.js

@@ -5,7 +5,7 @@ const chai = require('chai')
 chai.use(require('dirty-chai'))
 const expect = chai.expect
 const PeerId = require('peer-id')
-
+const { Buffer } = require('buffer')
 const PeerQueue = require('../src/peer-list/peer-queue')
 
 describe('PeerQueue', () => {

test/providers.spec.js

@@ -10,7 +10,7 @@ const LevelStore = require('datastore-level')
 const path = require('path')
 const os = require('os')
 const multihashing = require('multihashing-async')
-
+const { Buffer } = require('buffer')
 const Providers = require('../src/providers')
 
 const createPeerId = require('./utils/create-peer-id')

test/query.spec.js

@@ -6,7 +6,7 @@ chai.use(require('dirty-chai'))
 const expect = chai.expect
 const pDefer = require('p-defer')
 const delay = require('delay')
-
+const { Buffer } = require('buffer')
 const Query = require('../src/query')
 const kadUtils = require('../src/utils')
 

test/query/index.spec.js

@@ -9,7 +9,7 @@ const expect = chai.expect
 const sinon = require('sinon')
 const delay = require('delay')
 const PeerStore = require('libp2p/src/peer-store')
-
+const { Buffer } = require('buffer')
 const Query = require('../../src/query')
 const Path = require('../../src/query/path')
 const Run = require('../../src/query/run')

test/rpc/handlers/add-provider.spec.js

@@ -5,7 +5,7 @@
 const chai = require('chai')
 chai.use(require('dirty-chai'))
 const expect = chai.expect
-
+const { Buffer } = require('buffer')
 const multiaddr = require('multiaddr')
 
 const Message = require('../../../src/message')

test/rpc/handlers/find-node.spec.js

@@ -4,7 +4,7 @@
 const chai = require('chai')
 chai.use(require('dirty-chai'))
 const expect = chai.expect
-
+const { Buffer } = require('buffer')
 const Message = require('../../../src/message')
 const handler = require('../../../src/rpc/handlers/find-node')
 

test/rpc/handlers/get-providers.spec.js

@@ -4,7 +4,7 @@
 const chai = require('chai')
 chai.use(require('dirty-chai'))
 const expect = chai.expect
-
+const { Buffer } = require('buffer')
 const Message = require('../../../src/message')
 const utils = require('../../../src/utils')
 const handler = require('../../../src/rpc/handlers/get-providers')

test/rpc/handlers/get-value.spec.js

@@ -4,7 +4,7 @@
 const chai = require('chai')
 chai.use(require('dirty-chai'))
 const expect = chai.expect
-
+const { Buffer } = require('buffer')
 const Message = require('../../../src/message')
 const handler = require('../../../src/rpc/handlers/get-value')
 const utils = require('../../../src/utils')

test/rpc/handlers/ping.spec.js

@@ -4,7 +4,7 @@
 const chai = require('chai')
 chai.use(require('dirty-chai'))
 const expect = chai.expect
-
+const { Buffer } = require('buffer')
 const Message = require('../../../src/message')
 const handler = require('../../../src/rpc/handlers/ping')
 

test/rpc/handlers/put-value.spec.js

@@ -7,7 +7,7 @@ chai.use(require('dirty-chai'))
 const expect = chai.expect
 const { Record } = require('libp2p-record')
 const delay = require('delay')
-
+const { Buffer } = require('buffer')
 const Message = require('../../../src/message')
 const handler = require('../../../src/rpc/handlers/put-value')
 const utils = require('../../../src/utils')

test/rpc/index.spec.js

@@ -8,7 +8,7 @@ const pDefer = require('p-defer')
 const pipe = require('it-pipe')
 const lp = require('it-length-prefixed')
 const { collect } = require('streaming-iterables')
-
+const { Buffer } = require('buffer')
 const Message = require('../../src/message')
 const rpc = require('../../src/rpc')
 

test/simulation/index.js

@@ -6,7 +6,7 @@
 const PeerStore = require('libp2p/src/peer-store')
 const PeerId = require('peer-id')
 const multihashes = require('multihashes')
-
+const { Buffer } = require('buffer')
 const RoutingTable = require('../../src/routing')
 const Message = require('../../src/message')
 const { convertBuffer } = require('../../src/utils')

test/utils/to-buffer.js

@@ -1,4 +1,6 @@
 'use strict'
+const { Buffer } = require('buffer')
+
 /**
  * Converts BufferList messages to Buffers
  * @param {*} source