|
|
@ -1,5 +1,6 @@ |
|
|
|
const { Readable } = require('stream') |
|
|
|
const nodes = require('ipv4-peers').idLength(32) |
|
|
|
const peers = require('ipv4-peers') |
|
|
|
const nodes = peers.idLength(32) |
|
|
|
const QueryTable = require('./query-table') |
|
|
|
|
|
|
|
const BOOTSTRAPPING = Symbol('BOOTSTRAPPING') |
|
|
@ -101,6 +102,7 @@ class QueryStream extends Readable { |
|
|
|
|
|
|
|
const data = this._map({ |
|
|
|
type, |
|
|
|
to: message.to && message.to.length === 6 ? peers.decode(message.to)[0] : null, |
|
|
|
node: { |
|
|
|
id: message.id, |
|
|
|
port: peer.port, |
|
|
|