open.go

package encrepo

import (
	"context"

	"github.com/ipfs/go-datastore"
	sync_ds "github.com/ipfs/go-datastore/sync"
	"github.com/ipfs/kubo/repo"
	"github.com/pkg/errors"
)

var (
	onlyOne repo.OnlyOne
)

func Open(dbPath string, key []byte, opts SQLCipherDatastoreOptions) (repo.Repo, error) {
	fn := func() (repo.Repo, error) {
		ctx, cancel := context.WithCancel(context.Background())
		defer cancel()
		return open(ctx, dbPath, key, opts)
	}
	return onlyOne.Open(dbPath, fn)
}

func open(ctx context.Context, dbPath string, key []byte, opts SQLCipherDatastoreOptions) (repo.Repo, error) {
	packageLock.Lock()
	defer packageLock.Unlock()

	uroot, err := OpenSQLCipherDatastore("sqlite3", dbPath, tableName, key, opts)
	if err != nil {
		return nil, errors.Wrap(err, "instantiate datastore")
	}

	root := sync_ds.MutexWrap(uroot)

	conf, err := getConfigFromDatastore(ctx, root)
	if err != nil {
		return nil, errors.Wrap(err, "get config")
	}

	return &encRepo{
		root:   root,
		ds:     NewNamespacedDatastore(root, datastore.NewKey("data")),
		ks:     KeystoreFromDatastore(NewNamespacedDatastore(root, datastore.NewKey("keys"))),
		config: conf,
	}, nil
}