From 3f199cf9816d092eca55511ad58ec0ab9aa5c25c Mon Sep 17 00:00:00 2001 From: Mathias Buus Date: Fri, 21 May 2021 10:16:46 +0200 Subject: [PATCH] move to version 2 to avoid utp clashes fully (utp uses 1) --- index.js | 4 ++-- lib/messages.js | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/index.js b/index.js index 1df1a43..444b24d 100644 --- a/index.js +++ b/index.js @@ -140,7 +140,7 @@ class DHT extends EventEmitter { const token = to.token || (opts && opts.token) || null return this.rpc.request({ - version: 1, + version: 2, tid: 0, from: null, to, @@ -608,7 +608,7 @@ class DHT extends EventEmitter { const closerNodes = target ? this.table.closest(target) : null const ephemeral = socket !== this.rpc.socket || this.ephemeral const reply = { - version: 1, + version: 2, tid, from: null, to, diff --git a/lib/messages.js b/lib/messages.js index 83c991a..930fc57 100644 --- a/lib/messages.js +++ b/lib/messages.js @@ -66,7 +66,7 @@ exports.message = { (m.target ? HAS_TARGET : 0) | (m.command ? IS_REQUEST : 0) - state.buffer[state.start++] = 1 + state.buffer[state.start++] = 2 state.buffer[state.start++] = flags cenc.uint16.encode(state, m.tid) @@ -84,14 +84,14 @@ exports.message = { decode (state) { const version = state.buffer[state.start++] - if (version !== 1) { + if (version !== 2) { throw new Error('Incompatible version') } const flags = cenc.uint.decode(state) return { - version: 1, + version: 2, tid: cenc.uint16.decode(state), from: null, // populated in caller to: peerIPv4.decode(state),