dist/index.d.ts

@@ -1,12 +1,11 @@
-/// <reference types="node" />
 import DHTOnlineBase from "./dhtOnlineBase.js";
 export default class DHTOnline extends DHTOnlineBase {
     private flood;
     private swarm;
-    constructor(swarm: any, { id, data, ...opts }?: {
+    constructor(swarm: any, { id, data, protocol, ...opts }?: {
-        id?: Buffer;
+        protocol: undefined;
-        data?: {};
+        id?: any;
-        opts?: any;
+        data?: {} | undefined;
     });
     handlePeerAdd(peer: any): void;
     handlePeerRemove(peer: any): void;

dist/index.d.ts.map

@@ -1 +1 @@
-{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";AAAA,OAAO,aAAa,MAAM,oBAAoB,CAAC;AAK/C,MAAM,CAAC,OAAO,OAAO,SAAU,SAAQ,aAAa;IAClD,OAAO,CAAC,KAAK,CAAW;IACxB,OAAO,CAAC,KAAK,CAAM;gBAGjB,KAAK,EAAE,GAAG,EACV,EACE,EAA4B,EAC5B,IAAS,EACT,GAAG,IAAI,EACR,GAAE;QAAE,EAAE,CAAC,EAAE,MAAM,CAAC;QAAC,IAAI,CAAC,EAAE,EAAE,CAAC;QAAC,IAAI,CAAC,EAAE,GAAG,CAAA;KAAO;IAmBhD,aAAa,CAAC,IAAI,EAAE,GAAG;IAKvB,gBAAgB,CAAC,IAAI,EAAE,GAAG;IAW1B,SAAS,CAAC,OAAO,EAAE,GAAG,EAAE,GAAG,CAAC,EAAE,MAAM;CAGrC"}
+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA,OAAO,aAAa,MAAM,oBAAoB,CAAC;AAM/C,MAAM,CAAC,OAAO,OAAO,SAAU,SAAQ,aAAa;IAClD,OAAO,CAAC,KAAK,CAAW;IACxB,OAAO,CAAC,KAAK,CAAM;gBAGjB,KAAK,EAAE,GAAG,EACV,EAAE,EAA4B,EAAE,IAAS,EAAE,QAAQ,EAAE,GAAG,IAAI,EAAE;;;;KAE7D;IAmBH,aAAa,CAAC,IAAI,EAAE,GAAG;IAKvB,gBAAgB,CAAC,IAAI,EAAE,GAAG;IAW1B,SAAS,CAAC,OAAO,EAAE,GAAG,EAAE,GAAG,CAAC,EAAE,MAAM;CAGrC"}

dist/index.js

@@ -9,9 +9,11 @@ const DISCONNECT_SMOOTH = 500;
 class DHTOnline extends dhtOnlineBase_js_1.default {
     flood;
     swarm;
-    constructor(swarm, { id = swarm.keyPair.publicKey, data = {}, ...opts } = {}) {
+    constructor(swarm, { id = swarm.keyPair.publicKey, data = {}, protocol, ...opts } = {
+        protocol: undefined,
+    }) {
         super(id, opts);
-        this.flood = new dht_flood_1.default({ id, swarm, ...opts });
+        this.flood = new dht_flood_1.default({ id, swarm, protocol, ...opts });
         this.swarm = swarm;
         this.flood.on("peer-open", (peer) => this.handlePeerAdd(peer));
         this.flood.on("peer-remove", (peer) => this.handlePeerRemove(peer));

src/index.ts

@@ -1,5 +1,6 @@
 import DHTOnlineBase from "./dhtOnlineBase.js";
 import DHTFlood from "@lumeweb/dht-flood";
+import * as stream from "stream";
 
 const DISCONNECT_SMOOTH = 500;
 
@@ -9,14 +10,12 @@ export default class DHTOnline extends DHTOnlineBase {
 
   constructor(
     swarm: any,
-    {
+    { id = swarm.keyPair.publicKey, data = {}, protocol, ...opts } = {
-      id = swarm.keyPair.publicKey,
+      protocol: undefined,
-      data = {},
+    }
-      ...opts
-    }: { id?: Buffer; data?: {}; opts?: any } = {}
   ) {
-    super(id, opts as any);
+    super(id, opts);
-    this.flood = new DHTFlood({ id, swarm, ...opts });
+    this.flood = new DHTFlood({ id, swarm, protocol, ...opts });
     this.swarm = swarm;
 
     this.flood.on("peer-open", (peer) => this.handlePeerAdd(peer));