feat: wasm support

Signed-off-by: Norman Meier <[email protected]>

baseorbitdb/keystore.go

@@ -0,0 +1,36 @@
+//go:build !js
+
+package baseorbitdb
+
+import (
+	"fmt"
+	"path"
+
+	"berty.tech/go-ipfs-log/keystore"
+	"berty.tech/go-orbit-db/cache/cacheleveldown"
+	leveldb "github.com/ipfs/go-ds-leveldb"
+	"github.com/libp2p/go-libp2p/core/peer"
+)
+
+func NewKeystore(id peer.ID, directory string) (*keystore.Keystore, func() error, error) {
+	var err error
+	var ds *leveldb.Datastore
+
+	// create new datastore
+	if directory == cacheleveldown.InMemoryDirectory {
+		ds, err = leveldb.NewDatastore("", nil)
+	} else {
+		ds, err = leveldb.NewDatastore(path.Join(directory, id.String(), "/keystore"), nil)
+	}
+
+	if err != nil {
+		return nil, nil, fmt.Errorf("unable to create data store used by keystore: %w", err)
+	}
+
+	ks, err := keystore.NewKeystore(ds)
+	if err != nil {
+		return nil, nil, fmt.Errorf("unable to create keystore: %w", err)
+	}
+
+	return ks, ds.Close, nil
+}

baseorbitdb/keystore_js.go

@@ -0,0 +1,14 @@
+//go:build js
+
+package baseorbitdb
+
+import (
+	"errors"
+
+	"berty.tech/go-ipfs-log/keystore"
+	"github.com/libp2p/go-libp2p/core/peer"
+)
+
+func NewKeystore(id peer.ID, directory string) (*keystore.Keystore, func() error, error) {
+	return nil, nil, errors.New("can't create default keystore in js")
+}

baseorbitdb/orbitdb.go

@@ -24,7 +24,7 @@ import (
 	"berty.tech/go-orbit-db/utils"
 	cid "github.com/ipfs/go-cid"
 	datastore "github.com/ipfs/go-datastore"
-	leveldb "github.com/ipfs/go-ds-leveldb"
+
 	cbornode "github.com/ipfs/go-ipld-cbor"
 	coreapi "github.com/ipfs/interface-go-ipfs-core"
 	"github.com/libp2p/go-libp2p/core/event"
@@ -429,27 +429,12 @@ func NewOrbitDB(ctx context.Context, ipfs coreapi.CoreAPI, options *NewOrbitDBOp
 	}
 
 	if options.Keystore == nil {
-		var err error
-		var ds *leveldb.Datastore
-
-		// create new datastore
-		if *options.Directory == cacheleveldown.InMemoryDirectory {
-			ds, err = leveldb.NewDatastore("", nil)
-		} else {
-			ds, err = leveldb.NewDatastore(path.Join(*options.Directory, id.String(), "/keystore"), nil)
-		}
-
+		ks, closeKeystore, err := NewKeystore(id, *options.Directory)
 		if err != nil {
-			return nil, fmt.Errorf("unable to create data store used by keystore: %w", err)
-		}
-
-		ks, err := keystore.NewKeystore(ds)
-		if err != nil {
-			return nil, fmt.Errorf("unable to create keystore: %w", err)
+			return nil, err
 		}
-
 		options.Keystore = ks
-		options.CloseKeystore = ds.Close
+		options.CloseKeystore = closeKeystore
 	}
 
 	if options.ID == nil {

cache/cacheleveldown/leveldown.go

@@ -1,3 +1,5 @@
+//go:build !js
+
 package cacheleveldown
 
 import (
@@ -11,6 +13,7 @@ import (
 	"berty.tech/go-orbit-db/cache"
 	datastore "github.com/ipfs/go-datastore"
 	"github.com/ipfs/go-datastore/query"
+
 	leveldb "github.com/ipfs/go-ds-leveldb"
 	"go.uber.org/zap"
 )

cache/cacheleveldown/leveldown_js.go

@@ -0,0 +1,14 @@
+//go:build js
+
+package cacheleveldown
+
+import (
+	"berty.tech/go-orbit-db/cache"
+)
+
+var InMemoryDirectory = ":memory:"
+
+// New Creates a new leveldb data store
+func New(opts *cache.Options) cache.Interface {
+	panic("cacheleveldown not implemented in js")
+}

tests/create_open_test.go

@@ -1,3 +1,5 @@
+//go:build !js
+
 package tests
 
 import (

tests/docs_test.go

@@ -1,3 +1,5 @@
+//go:build !js
+
 package tests
 
 import (

tests/eventlog_test.go

@@ -1,3 +1,5 @@
+//go:build !js
+
 package tests
 
 import (

tests/keyvalue_test.go

@@ -1,3 +1,5 @@
+//go:build !js
+
 package tests
 
 import (

tests/persistence_test.go

@@ -1,3 +1,5 @@
+//go:build !js
+
 package tests
 
 import (

tests/replicate_automatically_test.go

@@ -1,3 +1,5 @@
+//go:build !js
+
 package tests
 
 import (

tests/replicate_test.go

@@ -1,3 +1,5 @@
+//go:build !js
+
 package tests
 
 import (
@@ -15,8 +17,8 @@ import (
 	"berty.tech/go-orbit-db/pubsub/pubsubraw"
 	orbitstores "berty.tech/go-orbit-db/stores"
 	"berty.tech/go-orbit-db/stores/operation"
-	"github.com/libp2p/go-libp2p/p2p/host/eventbus"
 	"github.com/libp2p/go-libp2p/core/event"
+	"github.com/libp2p/go-libp2p/p2p/host/eventbus"
 	mocknet "github.com/libp2p/go-libp2p/p2p/net/mock"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"

tests/replication_status_test.go

@@ -1,3 +1,5 @@
+//go:build !js
+
 package tests
 
 import (

tests/testing_test.go

@@ -1,3 +1,5 @@
+//go:build !js
+
 package tests
 
 import (

tests/write_permissions_test.go

@@ -1,3 +1,5 @@
+//go:build !js
+
 package tests
 
 import (