add items to multibase api

Author: kevodwyer

src/main/java/io/ipfs/api/IPFS.java

@@ -30,6 +30,7 @@ public enum PinType {all, direct, indirect, recursive}
     private final int readTimeoutMillis;
     public final Key key = new Key();
     public final Log log = new Log();
+    public final MultibaseAPI multibase = new MultibaseAPI();
     public final Pin pin = new Pin();
     public final Repo repo = new Repo();
     public final IPFSObject object = new IPFSObject();
@@ -262,6 +263,55 @@ public Map ls() throws IOException {
             return retrieveMap("log/ls");
         }
     }
+    public class MultibaseAPI {
+        public String decode(NamedStreamable encoded_file) {
+            Multipart m = new Multipart(protocol + "://" + host + ":" + port + version +
+                    "multibase/decode", "UTF-8");
+            try {
+                if (encoded_file.isDirectory()) {
+                    throw new IllegalArgumentException("encoded_file must be a file");
+                } else {
+                    m.addFilePart("file", Paths.get(""), encoded_file);
+                    return m.finish();
+                }
+            } catch (IOException e) {
+                throw new RuntimeException(e.getMessage(), e);
+            }
+        }
+        public String encode(Optional<String> encoding, NamedStreamable file) {
+            String b = encoding.map(f -> "?b=" + f).orElse("?b=base64url");
+            Multipart m = new Multipart(protocol + "://" + host + ":" + port + version +
+                    "multibase/encode" + b, "UTF-8");
+            try {
+                if (file.isDirectory()) {
+                    throw new IllegalArgumentException("Input must be a file");
+                } else {
+                    m.addFilePart("file", Paths.get(""), file);
+                    return m.finish();
+                }
+            } catch (IOException e) {
+                throw new RuntimeException(e.getMessage(), e);
+            }
+        }
+        public List<Map> list(boolean prefix, boolean  numeric) throws IOException {
+            return (List)retrieveAndParse("multibase/list?prefix=" + prefix + "&numeric=" + numeric);
+        }
+        public String transcode(Optional<String> encoding, NamedStreamable file) {
+            String b = encoding.map(f -> "?b=" + f).orElse("?b=base64url");
+            Multipart m = new Multipart(protocol + "://" + host + ":" + port + version +
+                    "multibase/transcode" + b, "UTF-8");
+            try {
+                if (file.isDirectory()) {
+                    throw new IllegalArgumentException("Input must be a file");
+                } else {
+                    m.addFilePart("file", Paths.get(""), file);
+                    return m.finish();
+                }
+            } catch (IOException e) {
+                throw new RuntimeException(e.getMessage(), e);
+            }
+        }
+    }
 
     /* 'ipfs repo' is a plumbing command used to manipulate the repo.
      */

src/test/java/io/ipfs/api/APITest.java

@@ -76,7 +76,7 @@ public void log() throws IOException {
         Map levelResult = ipfs.log.level("all", "info");
         Assert.assertTrue("Log level", ((String)levelResult.get("Message")).startsWith("Changed log level"));
     }
-    
+
     @Test
     public void ipldNode() {
         Function<Stream<Pair<String, CborObject>>, CborObject.CborMap> map =
@@ -271,6 +271,19 @@ public void filesTest() throws IOException {
         ipfs.files.rm("/filesTest", true, true);
     }
 
+    @Test
+    public void multibaseTest() throws IOException {
+        List<Map> encodings = ipfs.multibase.list(true, false);
+        Assert.assertTrue("multibase/list works", !encodings.isEmpty());
+        String encoded = ipfs.multibase.encode(Optional.empty(), new NamedStreamable.ByteArrayWrapper("hello".getBytes()));
+        Assert.assertTrue("multibase/encode works", encoded.equals("uaGVsbG8"));
+        String decoded = ipfs.multibase.decode(new NamedStreamable.ByteArrayWrapper(encoded.getBytes()));
+        Assert.assertTrue("multibase/decode works", decoded.equals("hello"));
+        String input = "f68656c6c6f";
+        String transcode = ipfs.multibase.transcode(Optional.of("base64url"), new NamedStreamable.ByteArrayWrapper(input.getBytes()));
+        Assert.assertTrue("multibase/transcode works", transcode.equals(encoded));
+    }
+
     @Test
     @Ignore("Experimental feature not enabled by default")
     public void fileStoreTest() throws IOException {