dist/dhtOnlineBase.d.ts

@@ -15,17 +15,19 @@ export default class DHTOnlineBase extends EventEmitter {
     get online(): string[];
     broadcast(data: any, ttl?: number): void;
     getPeerData(id: Buffer | string): any;
-    setData(data: any): void;
+    protected setData(data: any): void;
     private _broadcastData;
     protected onAddPeer(id: Buffer): void;
     protected onRemovePeer(id: Buffer): void;
     protected onGetBroadcast(message: Buffer, id: Buffer): void;
     private _hasSeenPeer;
     private _setPeer;
+    private _removePeer;
     private _ensurePeer;
     private _addPeerConnection;
     private _removePeerConnection;
     private _bootstrapFrom;
+    private _getPeerConnectedTo;
     private _getBootstrapInfo;
     private _recalculate;
     private _maybeHexify;

dist/dhtOnlineBase.d.ts.map

@@ -1 +1 @@
-{"version":3,"file":"dhtOnlineBase.d.ts","sourceRoot":"","sources":["../src/dhtOnlineBase.ts"],"names":[],"mappings":";;AAAA,OAAO,YAAY,MAAM,QAAQ,CAAC;AAYlC,MAAM,CAAC,OAAO,OAAO,aAAc,SAAQ,YAAY;IACrD,OAAO,CAAC,EAAE,CAAS;IACnB,OAAO,CAAC,YAAY,CAAU;IAC9B,OAAO,CAAC,KAAK,CAAM;IACnB,OAAO,CAAC,WAAW,CAAW;IAC9B,OAAO,CAAC,IAAI,CAAK;IACjB,OAAO,CAAC,QAAQ,CAAoB;gBAExB,EAAE,EAAE,MAAM,EAAE,EAAE,QAA2B,EAAE;;KAAK;IAa5D,OAAO,CAAC,OAAO,CAAW;IAE1B,IAAI,MAAM,IAAI,MAAM,EAAE,CAErB;IAED,SAAS,CAAC,IAAI,EAAE,GAAG,EAAE,GAAG,CAAC,EAAE,MAAM;IAIjC,WAAW,CAAC,EAAE,EAAE,MAAM,GAAG,MAAM;IAIxB,OAAO,CAAC,IAAI,EAAE,GAAG;IAQxB,OAAO,CAAC,cAAc;IAgBtB,SAAS,CAAC,SAAS,CAAC,EAAE,EAAE,MAAM;IAqC9B,SAAS,CAAC,YAAY,CAAC,EAAE,EAAE,MAAM;IAiBjC,SAAS,CAAC,cAAc,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE,EAAE,MAAM;IA6CpD,OAAO,CAAC,YAAY;IAIpB,OAAO,CAAC,QAAQ;IAGhB,OAAO,CAAC,WAAW;IAOnB,OAAO,CAAC,kBAAkB;IAY1B,OAAO,CAAC,qBAAqB;IAa7B,OAAO,CAAC,cAAc;IA2BtB,OAAO,CAAC,iBAAiB;IAczB,OAAO,CAAC,YAAY;IAwBpB,OAAO,CAAC,YAAY;CAOrB"}
+{"version":3,"file":"dhtOnlineBase.d.ts","sourceRoot":"","sources":["../src/dhtOnlineBase.ts"],"names":[],"mappings":";;AAAA,OAAO,YAAY,MAAM,QAAQ,CAAC;AAYlC,MAAM,CAAC,OAAO,OAAO,aAAc,SAAQ,YAAY;IACrD,OAAO,CAAC,EAAE,CAAS;IACnB,OAAO,CAAC,YAAY,CAAU;IAC9B,OAAO,CAAC,KAAK,CAAM;IACnB,OAAO,CAAC,WAAW,CAAW;IAC9B,OAAO,CAAC,IAAI,CAAK;IACjB,OAAO,CAAC,QAAQ,CAAoB;gBAExB,EAAE,EAAE,MAAM,EAAE,EAAE,QAA2B,EAAE;;KAAK;IAa5D,OAAO,CAAC,OAAO,CAAW;IAE1B,IAAI,MAAM,IAAI,MAAM,EAAE,CAErB;IAED,SAAS,CAAC,IAAI,EAAE,GAAG,EAAE,GAAG,CAAC,EAAE,MAAM;IAIjC,WAAW,CAAC,EAAE,EAAE,MAAM,GAAG,MAAM;IAI/B,SAAS,CAAC,OAAO,CAAC,IAAI,EAAE,GAAG;IAQ3B,OAAO,CAAC,cAAc;IAgBtB,SAAS,CAAC,SAAS,CAAC,EAAE,EAAE,MAAM;IAqC9B,SAAS,CAAC,YAAY,CAAC,EAAE,EAAE,MAAM;IAiBjC,SAAS,CAAC,cAAc,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE,EAAE,MAAM;IA6CpD,OAAO,CAAC,YAAY;IAIpB,OAAO,CAAC,QAAQ;IAIhB,OAAO,CAAC,WAAW;IAInB,OAAO,CAAC,WAAW;IAOnB,OAAO,CAAC,kBAAkB;IAY1B,OAAO,CAAC,qBAAqB;IAa7B,OAAO,CAAC,cAAc;IA4BtB,OAAO,CAAC,mBAAmB;IAI3B,OAAO,CAAC,iBAAiB;IAczB,OAAO,CAAC,YAAY;IAwBpB,OAAO,CAAC,YAAY;CAOrB"}

dist/dhtOnlineBase.js

@@ -135,6 +135,9 @@ class DHTOnlineBase extends events_1.default {
     _setPeer(id, data) {
         this.graph.addNode(this._maybeHexify(id), data);
     }
+    _removePeer(id) {
+        this.graph.removeNode(this._maybeHexify(id));
+    }
     _ensurePeer(id) {
         id = this._maybeHexify(id);
         if (!this._hasSeenPeer(id)) {
@@ -182,6 +185,9 @@ class DHTOnlineBase extends events_1.default {
         this.emit("bootstrapped");
         this._recalculate();
     }
+    _getPeerConnectedTo(id) {
+        return this.graph.successors(id);
+    }
     _getBootstrapInfo() {
         const state = {};
         for (const [id, rawData] of this.graph.nodes(true)) {

src/dhtOnlineBase.ts

@@ -45,7 +45,7 @@ export default class DHTOnlineBase extends EventEmitter {
     return this.graph.node.get(this._maybeHexify(id));
   }
 
-  public setData(data: any) {
+  protected setData(data: any) {
     this.data = data;
 
     this._setPeer(this.id, data);
@@ -175,6 +175,11 @@ export default class DHTOnlineBase extends EventEmitter {
   private _setPeer(id: Buffer | string, data: any) {
     this.graph.addNode(this._maybeHexify(id), data);
   }
+
+  private _removePeer(id: Buffer | string) {
+    this.graph.removeNode(this._maybeHexify(id));
+  }
+
   private _ensurePeer(id: Buffer | string) {
     id = this._maybeHexify(id);
     if (!this._hasSeenPeer(id)) {
@@ -234,6 +239,11 @@ export default class DHTOnlineBase extends EventEmitter {
 
     this._recalculate();
   }
+
+  private _getPeerConnectedTo(id: string) {
+    return this.graph.successors(id);
+  }
+
   private _getBootstrapInfo() {
     const state: Bootstrap = {};
     for (const [id, rawData] of this.graph.nodes(true)) {