dht.put implemented

Author: ianopolous

src/org/ipfs/IPFS.java

@@ -170,7 +170,30 @@ class Name {
     }
 
     class DHT {
-        // TODO findprovs get put
+        public Map findprovs(MerkleNode node) throws IOException {
+            Map res = (Map) retrieveAndParse("dht/findprovs?arg=" + node.hash);
+            return res;
+        }
+
+        public Map query(NodeAddress addr) throws IOException {
+            Map res = (Map) retrieveAndParse("dht/query?arg=" + addr.address);
+            return res;
+        }
+
+        public Map findpeer(NodeAddress addr) throws IOException {
+            Map res = (Map) retrieveAndParse("dht/findpeer?arg=" + addr.address);
+            return res;
+        }
+
+        public Map get(MerkleNode node) throws IOException {
+            Map res = (Map) retrieveAndParse("dht/get?arg=" + node.hash);
+            return res;
+        }
+
+        public Map put(String key, String value) throws IOException {
+            Map res = (Map) retrieveAndParse("dht/put?arg=" + key + "&arg="+value);
+            return res;
+        }
     }
 
     class File {

test/org/ipfs/Test.java

@@ -117,7 +117,20 @@ public void mountTest() {
         }
     }
 
-
+    @org.junit.Test
+    public void dhtTest() {
+        try {
+            MerkleNode pointer = new MerkleNode("QmPZ9gcCEpqKTo6aq61g2nXGUhM4iCL3ewB6LDXZCtioEB");
+            Map get = ipfs.dht.get(pointer);
+            Map put = ipfs.dht.put("somekey", "somevalue");
+            Map findprovs = ipfs.dht.findprovs(pointer);
+            List<NodeAddress> peers = ipfs.swarm.peers();
+            Map query = ipfs.dht.query(peers.get(0));
+            Map find = ipfs.dht.findpeer(peers.get(0));
+        } catch (IOException e) {
+            throw new RuntimeException(e);
+        }
+    }
 
     @org.junit.Test
     public void statsTest() {