feat: Add enable pubsub/namesys extra opt

Signed-off-by: Guilhem Fanton <guilhem.fanton@gmail.com>

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

@@ -197,6 +197,36 @@ synchronized public void restart() throws NodeStopException {
         try { start(); } catch(NodeStartException ignore) { /* Should never happen */ }
     }
 
+    /**
+    * Instantiate the ipfs node with the experimental pubsub feature enabled.
+    *
+    * @throws ExtraOptionException If enable the extra option failed
+    * @see <a href="https://github.com/ipfs/go-ipfs/blob/master/docs/experimental-features.md#ipfs-pubsub">Experimental features of IPFS</a>
+    */
+    synchronized public void enablePubsubExperiment() throws ExtraOptionException {
+        try {
+            openRepoIfClosed();
+            repo.enablePubsubExperiment();
+        } catch (Exception e) {
+            throw new ExtraOptionException("Enable pubsub experiment failed", e);
+        }
+    }
+
+    /**
+    * Enable IPNS record distribution through pubsub; enables pubsub.
+    *
+    * @throws ExtraOptionException If enable the extra option failed
+    * @see <a href="https://github.com/ipfs/go-ipfs/blob/master/docs/experimental-features.md#ipns-pubsub">Experimental features of IPFS</a>
+    */
+    synchronized public void enableNamesysPubsub() throws ExtraOptionException {
+        try {
+            openRepoIfClosed();
+            repo.enableNamesysPubsub();
+        } catch (Exception e) {
+            throw new ExtraOptionException("Enable namesys pubsub failed", e);
+        }
+    }
+
     /**
     * Gets the IPFS instance config as a JSON.
     *
@@ -332,8 +362,11 @@ synchronized private void openRepoIfClosed() throws RepoOpenException {
         }
     }
 
-
     // Exceptions
+    public static class ExtraOptionException extends Exception {
+        ExtraOptionException(String message, Throwable err) { super(message, err); }
+    }
+
     public static class ConfigCreationException extends Exception {
         ConfigCreationException(String message, Throwable err) { super(message, err); }
     }

go/bind/core/node.go

@@ -92,15 +92,11 @@ func (n *Node) ServeMultiaddr(smaddr string) (string, error) {
 func NewNode(r *Repo) (*Node, error) {
 	ctx := context.Background()
 
-	if _, err := loadPlugins(r.path); err != nil {
+	if _, err := loadPlugins(r.mr.Path); err != nil {
 		return nil, err
 	}
 
-	repo := &mobile_node.MobileRepo{
-		Repo: r.irepo,
-		Path: r.path,
-	}
-	mnode, err := mobile_node.NewNode(ctx, repo, &mobile_host.MobileConfig{})
+	mnode, err := mobile_node.NewNode(ctx, r.mr, &mobile_host.MobileConfig{})
 	if err != nil {
 		return nil, err
 	}

go/bind/core/repo.go

@@ -3,6 +3,7 @@ package core
 import (
 	"path/filepath"
 
+	"github.com/ipfs-shipyard/gomobile-ipfs/go/pkg/node"
 	ipfs_loader "github.com/ipfs/go-ipfs/plugin/loader"
 	ipfs_repo "github.com/ipfs/go-ipfs/repo"
 	ipfs_fsrepo "github.com/ipfs/go-ipfs/repo/fsrepo"
@@ -11,8 +12,7 @@ import (
 var plugins *ipfs_loader.PluginLoader
 
 type Repo struct {
-	irepo ipfs_repo.Repo
-	path  string
+	mr *node.MobileRepo
 }
 
 func RepoIsInitialized(path string) bool {
@@ -37,19 +37,32 @@ func OpenRepo(path string) (*Repo, error) {
 		return nil, err
 	}
 
-	return &Repo{irepo, path}, nil
+	mRepo := &node.MobileRepo{
+		Repo: irepo,
+		Path: path,
+	}
+
+	return &Repo{mRepo}, nil
+}
+
+func (r *Repo) EnablePubsubExperiment() {
+	r.mr.EnablePubsubExperiment = true
+}
+
+func (r *Repo) EnableNamesysPubsub() {
+	r.mr.EnableNamesysPubsub = true
 }
 
 func (r *Repo) GetRootPath() string {
-	return r.path
+	return r.mr.Path
 }
 
 func (r *Repo) SetConfig(c *Config) error {
-	return r.irepo.SetConfig(c.getConfig())
+	return r.mr.Repo.SetConfig(c.getConfig())
 }
 
 func (r *Repo) GetConfig() (*Config, error) {
-	cfg, err := r.irepo.Config()
+	cfg, err := r.mr.Repo.Config()
 	if err != nil {
 		return nil, err
 	}
@@ -58,11 +71,11 @@ func (r *Repo) GetConfig() (*Config, error) {
 }
 
 func (r *Repo) Close() error {
-	return r.irepo.Close()
+	return r.mr.Close()
 }
 
 func (r *Repo) getRepo() ipfs_repo.Repo {
-	return r.irepo
+	return r.mr
 }
 
 func loadPlugins(repoPath string) (*ipfs_loader.PluginLoader, error) {

go/pkg/node/node.go

@@ -30,6 +30,10 @@ func NewNode(ctx context.Context, repo *MobileRepo, mcfg *host.MobileConfig) (*I
 		NilRepo:                     false,
 		Repo:                        repo,
 		Host:                        host.NewMobileHostOption(mcfg),
+		ExtraOpts: map[string]bool{
+			"pubsub": repo.EnablePubsubExperiment,
+			"ipnsps": repo.EnableNamesysPubsub,
+		},
 	}
 
 	// create ipfs node

go/pkg/node/repo.go

@@ -9,8 +9,8 @@ var _ ipfs_repo.Repo = (*MobileRepo)(nil)
 type MobileRepo struct {
 	ipfs_repo.Repo
 	Path string
-}
 
-func NewMobileRepo(repo ipfs_repo.Repo, path string) *MobileRepo {
-	return &MobileRepo{repo, path}
+	// extra config
+	EnablePubsubExperiment bool
+	EnableNamesysPubsub    bool
 }

ios/Bridge/GomobileIPFS/Sources/IPFS.swift

@@ -128,6 +128,22 @@ public class IPFS {
         try self.start()
     }
 
+    /// Instantiate the ipfs node with the experimental pubsub feature enabled.
+    /// - Throws:
+    ///     - `RepoError`: If the opening of the repo failed
+    public func enablePubsubExperiment() throws {
+        try openRepoIfClosed()
+        self.repo!.goRepo.enablePubsubExperiment()
+    }
+
+    /// Enable IPNS record distribution through pubsub; enables pubsub.
+    /// - Throws:
+    ///     - `RepoError`: If the opening of the repo failed
+    public func enableNamesysPubsub() throws {
+        try openRepoIfClosed()
+        self.repo!.goRepo.enableNamesysPubsub()
+    }
+
     /// Gets the IPFS instance config as a dict
     /// - Throws:
     ///     - `RepoError`: If the opening of the repo or the getting of its config failed