LumeWeb
/
kernel-swarm-client
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

*dht missing on connect call

This commit is contained in:
Derrick Hammer 2022-08-03 21:36:30 -04:00
parent cc2def1901
commit 395edfe75a
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/index.ts
View File

@ -1,7 +1,7 @@
import { EventEmitter } from "events"; import { EventEmitter } from "events";
import { DataFn, ErrTuple } from "libskynet"; import { DataFn, ErrTuple } from "libskynet";
import { Buffer } from "buffer"; import { Buffer } from "buffer";
import {create} from "domain"; import { create } from "domain";
const DHT_MODULE = "AQD1IgE4lTZkq1fqdoYGojKRNrSk0YQ_wrHbRtIiHDrnow"; const DHT_MODULE = "AQD1IgE4lTZkq1fqdoYGojKRNrSk0YQ_wrHbRtIiHDrnow";
@ -32,7 +32,11 @@ export class DHT {
public async connect(pubkey: string): Promise<Socket> { public async connect(pubkey: string): Promise<Socket> {
await this.setup(); await this.setup();
const [resp, err] = await callModule(DHT_MODULE, "connect", { pubkey }); const dht = !this.useDefaultDht ? this.id : undefined;
const [resp, err] = await callModule(DHT_MODULE, "connect", {
pubkey,
dht,
});
if (err) { if (err) {
throw new Error(err); throw new Error(err);
} }
@ -99,9 +103,9 @@ export class DHT {
return true; return true;
} }
private async setup(){ private async setup() {
await loadLibs(); await loadLibs();
await this.create(); await this.create();
} }
} }