LumeWeb
/
dht-flood
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: LumeWeb:21f7f2e67d41cbd0df2f637670d87fe9c827fc8a
Branches Tags
LumeWeb:master
...
compare: LumeWeb:81191ed7ce7195ccb1bf31019f78a8576e5b2b99
Branches Tags
LumeWeb:master

2 Commits
21f7f2e67d ... 81191ed7ce

Author SHA1 Message Date
Derrick Hammer 81191ed7ce
*Update dist 2022-11-26 18:09:41 -05:00
Derrick Hammer f82a689e0f
*Bug fix channel opening 2022-11-26 18:09:20 -05:00
3 changed files with 9 additions and 5 deletions
Show Stats Expand all files Collapse all files

2
dist/index.d.ts.map vendored
View File

@ -1 +1 @@
{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;AAAA,OAAO,YAAY,MAAM,QAAQ,CAAC;AAkBlC,eAAO,MAAM,YAAY,eAAuB,CAAC;AAEjD,MAAM,CAAC,OAAO,OAAO,QAAS,SAAQ,YAAY;IAChD,OAAO,CAAC,EAAE,CAAS;IACnB,OAAO,CAAC,GAAG,CAAS;IACpB,OAAO,CAAC,aAAa,CAAS;IAC9B,OAAO,CAAC,GAAG,CAAM;IACjB,OAAO,CAAC,KAAK,CAAM;IACnB,OAAO,CAAC,QAAQ,CAAS;gBAEb,EACV,OAAkB,EAClB,GAAS,EACT,aAAiB,EACjB,EAA2B,EAC3B,KAAY,EACZ,QAAmB,GACpB;;;;;;;KAAK;IAmBN,OAAO,CAAC,aAAa;IAkCrB,OAAO,CAAC,SAAS;IA6CjB,SAAS,CAAC,IAAI,EAAE,GAAG,EAAE,GAAG,SAAW;IAenC,IAAI,CAAC,IAAI,EAAE,GAAG,EAAE,IAAI,EAAE,GAAG,EAAE,GAAG,SAAW;CAY1C"} {"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;AAAA,OAAO,YAAY,MAAM,QAAQ,CAAC;AAkBlC,eAAO,MAAM,YAAY,eAAuB,CAAC;AAEjD,MAAM,CAAC,OAAO,OAAO,QAAS,SAAQ,YAAY;IAChD,OAAO,CAAC,EAAE,CAAS;IACnB,OAAO,CAAC,GAAG,CAAS;IACpB,OAAO,CAAC,aAAa,CAAS;IAC9B,OAAO,CAAC,GAAG,CAAM;IACjB,OAAO,CAAC,KAAK,CAAM;IACnB,OAAO,CAAC,QAAQ,CAAS;gBAEb,EACV,OAAkB,EAClB,GAAS,EACT,aAAiB,EACjB,EAA2B,EAC3B,KAAY,EACZ,QAAmB,GACpB;;;;;;;KAAK;IAmBN,OAAO,CAAC,aAAa;IAkCrB,OAAO,CAAC,SAAS;IA+CjB,SAAS,CAAC,IAAI,EAAE,GAAG,EAAE,GAAG,SAAW;IAenC,IAAI,CAAC,IAAI,EAAE,GAAG,EAAE,IAAI,EAAE,GAAG,EAAE,GAAG,SAAW;CAY1C"}

4
dist/index.js vendored
View File

@ -68,7 +68,7 @@ class DHTFlood extends events_1.default {
const mux = protomux_1.default.from(peer); const mux = protomux_1.default.from(peer);
let chan; let chan;
const self = this; const self = this;
if (!mux.opened({ protocol: PROTOCOL })) { if (!mux.opened({ protocol: this.protocol })) {
chan = mux.createChannel({ chan = mux.createChannel({
protocol: this.protocol, protocol: this.protocol,
async onopen() { async onopen() {
@ -78,8 +78,10 @@ class DHTFlood extends events_1.default {
self.emit("peer-remove", peer); self.emit("peer-remove", peer);
}, },
}); });
if (chan) {
peer[exports.FLOOD_SYMBOL] = chan; peer[exports.FLOOD_SYMBOL] = chan;
} }
}
chan = peer[exports.FLOOD_SYMBOL]; chan = peer[exports.FLOOD_SYMBOL];
if (!chan) { if (!chan) {
throw new Error("could not find channel"); throw new Error("could not find channel");

4
src/index.ts
View File

@ -92,7 +92,7 @@ export default class DHTFlood extends EventEmitter {
const self = this; const self = this;
if (!mux.opened({ protocol: PROTOCOL })) { if (!mux.opened({ protocol: this.protocol })) {
chan = mux.createChannel({ chan = mux.createChannel({
protocol: this.protocol, protocol: this.protocol,
async onopen() { async onopen() {
@ -102,8 +102,10 @@ export default class DHTFlood extends EventEmitter {
self.emit("peer-remove", peer); self.emit("peer-remove", peer);
}, },
}); });
if (chan) {
peer[FLOOD_SYMBOL] = chan; peer[FLOOD_SYMBOL] = chan;
} }
}
chan = peer[FLOOD_SYMBOL]; chan = peer[FLOOD_SYMBOL];