feat: implement Android IPFS class

android/app/src/main/java/ipfs/gomobile/example/MainActivity.java

@@ -13,18 +13,18 @@
 
 import org.json.JSONObject;
 
-import ipfs.gomobile.android.Bridge;
+import ipfs.gomobile.android.IPFS;
 
 public class MainActivity extends AppCompatActivity {
     static private final String TAG = "IPFS_Mobile_Example";
-    private Bridge bridge;
+    private IPFS bridge;
 
     @Override
     protected void onCreate(Bundle savedInstanceState) {
         super.onCreate(savedInstanceState);
         setContentView(R.layout.activity_main);
 
-        bridge = new Bridge(getApplicationContext());
+        bridge = new IPFS(getApplicationContext());
 
         new AsyncTask<Void, Void, String>() {
             @Override

android/bridge/src/main/java/ipfs/gomobile/android/IPFS.java

@@ -0,0 +1,151 @@
+package ipfs.gomobile.android;
+
+import android.content.Context;
+import android.util.Base64;
+import android.util.Log;
+
+import androidx.annotation.NonNull;
+
+import java.io.File;
+
+import mobile.Mobile;
+import mobile.Config;
+import mobile.Repo;
+import mobile.Node;
+import mobile.Shell;
+
+public final class IPFS {
+    // Default paths
+    private static final String defaultRepoPath = "/ipfs/repo";
+    private static final String apiSockFilename = "api.sock";
+
+    // Go IPFS objects
+    private final Repo repo;
+    private Node node;
+    private Shell shell;
+
+    public IPFS(@NonNull Context context)
+            throws ConfigCreationException, RepoInitException {
+        this(context, defaultRepoPath);
+    }
+
+    public IPFS(@NonNull Context context, @NonNull String repoPath)
+            throws ConfigCreationException, RepoInitException {
+        String absRepoPath = context.getFilesDir().getAbsolutePath() + repoPath;
+
+        if (!Mobile.repoIsInitialized(absRepoPath)) {
+            Config config;
+
+            try {
+                config = Mobile.newDefaultConfig();
+                config.setupUnixSocketAPI(apiSockFilename);
+            } catch (Exception e) {
+                throw new ConfigCreationException("Config creation failed", e);
+            }
+
+            final File repoDir = new File(absRepoPath);
+            if (!repoDir.exists()) {
+                if (!repoDir.mkdirs()) {
+                    throw new RepoInitException("Repo directory creation failed");
+                }
+            }
+            try {
+                Mobile.initRepo(absRepoPath, config);
+            } catch (Exception e) {
+                throw new RepoInitException("Repo initialisation failed", e);
+            }
+        }
+
+        try {
+            repo = Mobile.openRepo(absRepoPath);
+        } catch (Exception e) {
+            throw new RepoInitException("Repo opening failed", e);
+        }
+    }
+
+    synchronized public void start() throws NodeStartException, ShellInitException {
+        if (node != null) {
+            throw new NodeStartException("Node already started");
+        }
+
+        try {
+            node = Mobile.newNode(repo);
+        } catch (Exception e) {
+            throw new NodeStartException("Node start failed", e);
+        }
+
+        try {
+            shell = Mobile.newUDSShell(apiSockFilename);
+        } catch (Exception e) {
+            throw new ShellInitException("Shell init failed", e);
+        }
+    }
+
+    synchronized public void stop() throws NodeStopException {
+        if (node == null) {
+            throw new NodeStopException("Node not started yet");
+        }
+
+        try {
+            node.close();
+            node = null;
+        } catch (Exception e) {
+            throw new NodeStopException("Node stop failed", e);
+        }
+    }
+
+    synchronized public void restart()
+            throws NodeStartException, ShellInitException, NodeStopException {
+        stop();
+        start();
+    }
+
+    synchronized public String shellRequest(String command, String b64Body)
+            throws ShellRequestException {
+        if (node == null) {
+            throw new ShellRequestException("Shell request failed: node isn't started");
+        }
+
+        try {
+            byte[] req = new byte[0];
+
+            if (b64Body.length() > 0) {
+                req = Base64.decode(b64Body, Base64.DEFAULT);
+            }
+
+            byte[] res = shell.request(command, req);
+
+            return Base64.encodeToString(res, Base64.DEFAULT);
+        } catch (Exception err) {
+            throw new ShellRequestException("Shell request failed", err);
+        }
+    }
+
+    public class ConfigCreationException extends Exception {
+        public ConfigCreationException(String message, Throwable err) { super(message, err); }
+    }
+
+    public class ShellInitException extends Exception {
+        public ShellInitException(String message, Throwable err) { super(message, err); }
+    }
+
+    public class ShellRequestException extends Exception {
+        public ShellRequestException(String message) { super(message); }
+        public ShellRequestException(String message, Throwable err) { super(message, err); }
+    }
+
+    public class RepoInitException extends Exception {
+        public RepoInitException(String message) { super(message); }
+        public RepoInitException(String message, Throwable err) { super(message, err); }
+    }
+
+    public class NodeStartException extends Exception {
+        public NodeStartException(String message) { super(message); }
+        public NodeStartException(String message, Throwable err) { super(message, err); }
+    }
+
+    public class NodeStopException extends Exception {
+        public NodeStopException(String message) { super(message); }
+        public NodeStopException(String message, Throwable err) { super(message, err); }
+    }
+}

go/repo.go

@@ -44,7 +44,7 @@ func (r *Repo) GetRootPath() string {
 	return r.path
 }
 
-func (r *Repo) SetConfig(c Config) error {
+func (r *Repo) SetConfig(c *Config) error {
 	return r.irepo.SetConfig(c.getConfig())
 }