Print DHT info for channels

snowblossomcoin · Feb 3, 2020 · 50e4a04 · 50e4a04
1 parent 30e7655
commit 50e4a04
Show file tree

Hide file tree

Showing 2 changed files with 25 additions and 1 deletion.
diff --git a/src/ChannelPeerMaintainer.java b/src/ChannelPeerMaintainer.java
@@ -147,7 +147,21 @@ private void saveDHT(ChannelID cid, List<ByteString> dht_element_lst, ChannelPee
 
   }
 
-  private LinkedList<ChannelPeerInfo> getAllDHTPeers(ChannelID cid, List<ByteString> dht_element_lst, Set<AddressSpecHash> connected_set)
+  public LinkedList<ChannelPeerInfo> getAllDHTPeers(ChannelID cid)
+  {
+    return getAllDHTPeers(cid, new HashSet<AddressSpecHash>());
+  }
+  public LinkedList<ChannelPeerInfo> getAllDHTPeers(ChannelID cid, Set<AddressSpecHash> connected_set)
+  {
+
+    // TODO - actually get head settings
+    ChannelSettings settings = null;
+    List<ByteString> dht_element_lst = node.getDHTStratUtil().getDHTLocations(cid, settings);
+
+    return getAllDHTPeers(cid, dht_element_lst, connected_set); 
+  }
+
+  public LinkedList<ChannelPeerInfo> getAllDHTPeers(ChannelID cid, List<ByteString> dht_element_lst, Set<AddressSpecHash> connected_set)
   {
     HashMap<ByteString, SignedMessagePayload> peer_map = new HashMap<>();
 

diff --git a/src/iceleaf/ChannelNodePanel.java b/src/iceleaf/ChannelNodePanel.java
@@ -5,6 +5,7 @@
 import java.awt.GridBagConstraints;
 import java.awt.event.ActionEvent;
 import java.io.File;
+import java.util.LinkedList;
 import java.util.TreeMap;
 import javax.swing.JButton;
 import javax.swing.JLabel;
@@ -20,7 +21,9 @@
 import snowblossom.channels.ChunkMapUtils;
 import snowblossom.channels.MiscUtils;
 import snowblossom.channels.PeerLink;
+import snowblossom.channels.PrintUtil;
 import snowblossom.channels.SocksServer;
+import snowblossom.channels.proto.ChannelPeerInfo;
 import snowblossom.iceleaf.BasePanel;
 import snowblossom.iceleaf.IceLeaf;
 import snowblossom.iceleaf.ThreadActionListener;
@@ -337,6 +340,13 @@ public void threadActionPerformed(ActionEvent e)
             sb.append("  " + link);
             sb.append("\n");
           }
+          sb.append("DHT Peers:\n");
+          LinkedList<ChannelPeerInfo> peer_infos = node.getChannelPeerMaintainer().getAllDHTPeers(cid);
+          for(ChannelPeerInfo info : peer_infos)
+          {
+            sb.append("  ");
+            sb.append(PrintUtil.print(info));
+          }
         }