fix: add buffer (#118)

Adds buffer where needed and removes dependency on it-buffer

related to ipfs/js-ipfs#2924

package.json

@@ -31,20 +31,19 @@
   "dependencies": {
     "bl": "^4.0.0",
     "debug": "^4.1.1",
-    "it-buffer": "^0.1.1",
-    "it-length-prefixed": "^3.0.0",
+    "it-length-prefixed": "^3.0.1",
     "it-pair": "^1.0.0",
     "it-pb-rpc": "^0.1.4",
     "it-pipe": "^1.1.0",
-    "libp2p-crypto": "^0.17.1",
+    "libp2p-crypto": "^0.17.3",
     "libp2p-interfaces": "^0.2.1",
     "multiaddr": "^7.2.1",
     "multihashing-async": "^0.8.0",
     "peer-id": "^0.13.6",
-    "protons": "^1.1.0"
+    "protons": "^1.0.2"
   },
   "devDependencies": {
-    "aegir": "^21.0.2",
+    "aegir": "^21.4.2",
     "benchmark": "^2.1.4",
     "chai": "^4.2.0",
     "dirty-chai": "^2.0.1",

src/etm.js

@@ -6,7 +6,7 @@ const { InvalidCryptoTransmissionError } = require('libp2p-interfaces/src/crypto
 exports.createBoxStream = (cipher, mac) => {
   return async function * (source) {
     for await (const chunk of source) {
-      const data = await cipher.encrypt(chunk)
+      const data = await cipher.encrypt(BufferList.isBufferList(chunk) ? chunk.slice() : chunk)
       const digest = await mac.digest(data)
       yield new BufferList([data, digest])
     }

src/handshake/crypto.js

@@ -1,5 +1,6 @@
 'use strict'
 
+const { Buffer } = require('buffer')
 const PeerId = require('peer-id')
 const crypto = require('libp2p-crypto')
 const debug = require('debug')

src/handshake/finish.js

@@ -9,7 +9,6 @@ const pipe = require('it-pipe')
 const lp = require('it-length-prefixed')
 const Wrap = require('it-pb-rpc')
 const { int32BEEncode, int32BEDecode } = lp
-const ensureBuffer = require('it-buffer')
 
 const etm = require('../etm')
 const crypto = require('./crypto')
@@ -26,12 +25,10 @@ module.exports = async function finish (state, wrapped) {
 
   pipe(
     secure, // this is FROM the user
-    ensureBuffer,
     etm.createBoxStream(proto.local.cipher, proto.local.mac),
     lp.encode({ lengthEncoder: int32BEEncode }),
     network, // and gets piped INTO and FROM the network
     lp.decode({ lengthDecoder: int32BEDecode }),
-    ensureBuffer,
     etm.createUnboxStream(proto.remote.cipher, proto.remote.mac),
     secure // and gets piped TO the user
   )

src/support.js

@@ -1,5 +1,6 @@
 'use strict'
 
+const { Buffer } = require('buffer')
 const mh = require('multihashing-async')
 const crypto = require('libp2p-crypto')