java780
diff --git a/‎pom.xml‎
Lines changed: 8 additions & 0 deletions b/‎pom.xml‎
Lines changed: 8 additions & 0 deletions
diff --git a/‎src/main/java/io/ipfs/cluster/api/IPFSCluster.java‎
Lines changed: 17 additions & 10 deletions b/‎src/main/java/io/ipfs/cluster/api/IPFSCluster.java‎
Lines changed: 17 additions & 10 deletions
diff --git a/‎src/main/java/io/ipfs/cluster/api/TEST.java‎
Lines changed: 20 additions & 0 deletions b/‎src/main/java/io/ipfs/cluster/api/TEST.java‎
Lines changed: 20 additions & 0 deletions
diff --git a/‎src/main/java/io/ipfs/cluster/api/URLConnectionUtil.java‎
Lines changed: 125 additions & 0 deletions b/‎src/main/java/io/ipfs/cluster/api/URLConnectionUtil.java‎
Lines changed: 125 additions & 0 deletions
@@ -84,6 +84,14 @@
 			<scope>system</scope>
 			<systemPath>${project.basedir}/lib/cid.jar</systemPath>
 		</dependency>
+
+		<!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
+		<dependency>
+			<groupId>com.alibaba</groupId>
+			<artifactId>fastjson</artifactId>
+			<version>1.2.47</version>
+		</dependency>
+
 	</dependencies>
 
 	<build>
 
@@ -1,5 +1,7 @@
 package io.ipfs.cluster.api;
 
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
 import io.ipfs.cid.*;
 import io.ipfs.multihash.Multihash;
 import io.ipfs.multiaddr.MultiAddress;
@@ -25,7 +27,7 @@ public enum PinType {all, direct, indirect, recursive}
      */
     public class Pin {
         public List<Multihash> add(Multihash hash) throws IOException {
-            return ((List<Object>)((Map)retrieveAndParse("pin/add?stream-channels=true&arg=" + hash)).get("Pins"))
+            return ((List<Object>)((Map)retrieveAndParse("pins/add?stream-channels=true&arg=" + hash)).get("Pins"))
                     .stream()
                     .map(x -> Cid.decode((String) x))
                     .collect(Collectors.toList());
@@ -36,7 +38,7 @@ public Map<Multihash, Object> ls() throws IOException {
         }
 
         public Map<Multihash, Object> ls(PinType type) throws IOException {
-            return ((Map<String, Object>)(((Map)retrieveAndParse("pin/ls?stream-channels=true&t="+type.name())).get("Keys"))).entrySet()
+            return ((Map<String, Object>)(((Map)retrieveAndParse("pins?stream-channels=true&t="+type.name())).get("Keys"))).entrySet()
                     .stream()
                     .collect(Collectors.toMap(x -> Cid.decode(x.getKey()), x-> x.getValue()));
         }
@@ -46,7 +48,7 @@ public List<Multihash> rm(Multihash hash) throws IOException {
         }
 
         public List<Multihash> rm(Multihash hash, boolean recursive) throws IOException {
-            Map json = retrieveMap("pin/rm?stream-channels=true&r=" + recursive + "&arg=" + hash);
+            Map json = retrieveMap("pins/rm?stream-channels=true&r=" + recursive + "&arg=" + hash);
             return ((List<Object>) json.get("Pins")).stream().map(x -> Cid.decode((String) x)).collect(Collectors.toList());
         }
     }
@@ -59,15 +61,20 @@ public List<Multihash> add(Multihash hash) throws IOException {
                     .collect(Collectors.toList());
         }
 
-        public Map<Multihash, Object> ls() throws IOException {
-            return ls(PinType.direct);
+        public List<Map<String, Object>> ls() throws IOException {
+            List<Map<String, Object>> map = ((List<Map<String, Object>>)retrieveAndParse("peers"));
+            return map;
         }
 
-        public Map<Multihash, Object> ls(PinType type) throws IOException {
-            return ((Map<String, Object>)(((Map)retrieveAndParse("peers/ls?stream-channels=true&t="+type.name())).get("Keys"))).entrySet()
-                    .stream()
-                    .collect(Collectors.toMap(x -> Cid.decode(x.getKey()), x-> x.getValue()));
-        }
+//        public Map<Multihash, Object> ls() throws IOException {
+//            return ls(PinType.direct);
+//        }
+
+//        public Map<Multihash, Object> ls(PinType type) throws IOException {
+//            return ((Map<String, Object>)(((Map)retrieveAndParse("peers")).get("Keys"))).entrySet()
+//                    .stream()
+//                    .collect(Collectors.toMap(x -> Cid.decode(x.getKey()), x-> x.getValue()));
+//        }
 
         public List<Multihash> rm(Multihash hash) throws IOException {
             return rm(hash, true);
 
@@ -0,0 +1,20 @@
+package io.ipfs.cluster.api;
+
+import java.io.IOException;
+
+public class TEST {
+
+    public static void main(String args[]){
+
+        IPFSCluster ipfsCluster = new IPFSCluster("127.0.0.1", 9094);
+        try {
+            System.out.println("id" + ipfsCluster.id());
+            System.out.println("version" + ipfsCluster.version());
+            System.out.println("peers.ls" + ipfsCluster.peers.ls());
+            System.out.println("pin.ls" + ipfsCluster.peers.ls());
+
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}
@@ -0,0 +1,125 @@
+package io.ipfs.cluster.api;
+
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.net.URLConnection;
+import java.util.HashMap;
+import java.util.Map;
+
+public class URLConnectionUtil {
+
+    private static final String SERVLET_POST = "POST" ;
+    private static final String SERVLET_GET = "GET" ;
+    private static final String SERVLET_DELETE = "DELETE" ;
+    private static final String SERVLET_PUT = "PUT" ;
+
+    private static String prepareParam(Map<String,Object> paramMap){
+        StringBuffer sb = new StringBuffer();
+        if(paramMap.isEmpty()){
+            return "" ;
+        }else{
+            for(String key: paramMap.keySet()){
+                String value = (String)paramMap.get(key);
+                if(sb.length()<1){
+                    sb.append(key).append("=").append(value);
+                }else{
+                    sb.append("&").append(key).append("=").append(value);
+                }
+            }
+            return sb.toString();
+        }
+    }
+
+    public static void  doPost(String urlStr,Map<String,Object> paramMap ) throws Exception{
+        URL url = new URL(urlStr);
+        HttpURLConnection conn = (HttpURLConnection)url.openConnection();
+        conn.setRequestMethod(SERVLET_POST);
+        String paramStr = prepareParam(paramMap);
+        conn.setDoInput(true);
+        conn.setDoOutput(true);
+        OutputStream os = conn.getOutputStream();
+        os.write(paramStr.toString().getBytes("utf-8"));
+        os.close();
+
+        BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream()));
+        String line ;
+        String result ="";
+        while( (line =br.readLine()) != null ){
+            result += "/n"+line;
+        }
+        System.out.println(result);
+        br.close();
+
+    }
+
+    public static void  doGet(String urlStr,Map<String,Object> paramMap ) throws Exception{
+        String paramStr = prepareParam(paramMap);
+        if(paramStr == null || paramStr.trim().length()<1){
+
+        }else{
+            urlStr +="?"+paramStr;
+        }
+        System.out.println(urlStr);
+        URL url = new URL(urlStr);
+        HttpURLConnection conn = (HttpURLConnection)url.openConnection();
+        conn.setRequestMethod(SERVLET_PUT);
+        conn.setRequestProperty("Content-Type","text/html; charset=UTF-8");
+
+        conn.connect();
+        BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream()));
+        String line ;
+        String result ="";
+        while( (line =br.readLine()) != null ){
+            result += "/n"+line;
+        }
+        System.out.println(result);
+        br.close();
+    }
+
+    public static void doPut(String urlStr,Map<String,Object> paramMap) throws Exception{
+        URL url = new URL(urlStr);
+        HttpURLConnection conn = (HttpURLConnection)url.openConnection();
+        conn.setRequestMethod(SERVLET_PUT);
+        String paramStr = prepareParam(paramMap);
+        conn.setDoInput(true);
+        conn.setDoOutput(true);
+        OutputStream os = conn.getOutputStream();
+        os.write(paramStr.toString().getBytes("utf-8"));
+        os.close();
+
+        BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream()));
+        String line ;
+        String result ="";
+        while( (line =br.readLine()) != null ){
+            result += "/n"+line;
+        }
+        System.out.println(result);
+        br.close();
+
+    }
+
+    public static void doDelete(String urlStr,Map<String,Object> paramMap) throws Exception{
+        String paramStr = prepareParam(paramMap);
+        if(paramStr == null || paramStr.trim().length()<1){
+
+        }else{
+            urlStr +="?"+paramStr;
+        }
+        System.out.println(urlStr);
+        URL url = new URL(urlStr);
+        HttpURLConnection conn = (HttpURLConnection)url.openConnection();
+        conn.setDoOutput(true);
+        conn.setRequestMethod(SERVLET_DELETE);
+
+        if(conn.getResponseCode() ==200){
+            System.out.println("success!");
+        }else{
+            System.out.println(conn.getResponseCode());
+        }
+    }
+
+
+}