fix: feedback

Author: hugomrdias

package.json

@@ -51,7 +51,6 @@
     "events": "^3.1.0",
     "hashlru": "^2.3.0",
     "ipfs-utils": "^1.0.0",
-    "iso-random-stream": "^1.1.1",
     "it-all": "^1.0.1",
     "it-buffer": "^0.1.2",
     "it-handshake": "^1.0.1",
@@ -73,6 +72,7 @@
     "peer-id": "^0.13.4",
     "peer-info": "^0.17.0",
     "protons": "^1.0.1",
+    "streaming-iterables": "^4.1.0",
     "retimer": "^2.0.0",
     "timeout-abort-controller": "^1.0.0",
     "xsalsa20": "^1.0.2"
@@ -107,7 +107,6 @@
     "p-times": "^2.1.0",
     "p-wait-for": "^3.1.0",
     "sinon": "^9.0.0",
-    "streaming-iterables": "^4.1.0",
     "wrtc": "^0.4.1"
   },
   "contributors": [

src/connection-manager/latency-monitor.js

@@ -1,5 +1,9 @@
 'use strict'
 
+/**
+ * This code is based on `latency-monitor` (https://github.com/mlucool/latency-monitor) by `mlucool` (https://github.com/mlucool), available under Apache License 2.0 (https://github.com/mlucool/latency-monitor/blob/master/LICENSE)
+ */
+
 /* global window */
 const globalThis = require('ipfs-utils/src/globalthis')
 const EventEmitter = require('events')

src/connection-manager/visibility-change-emitter.js

@@ -1,4 +1,8 @@
 /* global document */
+
+/**
+ * This code is based on `latency-monitor` (https://github.com/mlucool/latency-monitor) by `mlucool` (https://github.com/mlucool), available under Apache License 2.0 (https://github.com/mlucool/latency-monitor/blob/master/LICENSE)
+ */
 'use strict'
 const EventEmitter = require('events')
 

src/identify/index.js

@@ -5,7 +5,7 @@ const debug = require('debug')
 const pb = require('it-protocol-buffers')
 const lp = require('it-length-prefixed')
 const pipe = require('it-pipe')
-const { collect, take, consume } = require('../../src/utils')
+const { collect, take, consume } = require('streaming-iterables')
 
 const PeerInfo = require('peer-info')
 const PeerId = require('peer-id')

src/metrics/index.js

@@ -2,7 +2,7 @@
 
 const mergeOptions = require('merge-options')
 const pipe = require('it-pipe')
-const { tap } = require('../utils')
+const { tap } = require('streaming-iterables')
 const oldPeerLRU = require('./old-peers')
 const { METRICS: defaultOptions } = require('../constants')
 const Stats = require('./stats')

src/ping/index.js

@@ -8,7 +8,7 @@ const errCode = require('err-code')
 const crypto = require('libp2p-crypto')
 const pipe = require('it-pipe')
 const { toBuffer } = require('it-buffer')
-const { collect, take } = require('../utils')
+const { collect, take } = require('streaming-iterables')
 
 const { PROTOCOL, PING_LENGTH } = require('./constants')
 

src/pnet/key-generator.js

@@ -1,6 +1,6 @@
 'use strict'
 
-const randomBytes = require('iso-random-stream/src/random')
+const crypto = require('libp2p-crypto')
 const KEY_LENGTH = 32
 
 /**
@@ -9,7 +9,7 @@ const KEY_LENGTH = 32
  * @returns {void}
  */
 function generate (writer) {
-  const psk = randomBytes(KEY_LENGTH).toString('hex')
+  const psk = crypto.randomBytes(KEY_LENGTH).toString('hex')
   writer.write('/key/swarm/psk/1.0.0/\n/base16/\n' + psk)
 }
 

src/utils.js

@@ -9,7 +9,7 @@ const { expect } = chai
 const sinon = require('sinon')
 
 const multiaddr = require('multiaddr')
-const { collect } = require('../../src/utils')
+const { collect } = require('streaming-iterables')
 const pipe = require('it-pipe')
 const AggregateError = require('aggregate-error')
 const { createPeerInfo } = require('../utils/creators/peer')

test/dialing/relay.node.js

@@ -12,7 +12,7 @@ const duplexPair = require('it-pair/duplex')
 const pipe = require('it-pipe')
 const concat = require('it-concat')
 const pushable = require('it-pushable')
-const { consume } = require('../../src/utils')
+const { consume } = require('streaming-iterables')
 const delay = require('delay')
 
 const Metrics = require('../../src/metrics')