[WIP] tstore: Run updates in a transaction.

politeiad/backendv2/backendv2.go

@@ -8,6 +8,7 @@ import (
 	"errors"
 	"fmt"
 
+	"github.com/decred/dcrd/chaincfg/v3"
 	"github.com/decred/politeia/politeiad/api/v1/identity"
 )
 
@@ -256,6 +257,18 @@ type Inventory struct {
 	Vetted   map[StatusT][]string
 }
 
+// BackendSettings are the backend settings that are available to plugins.
+type BackendSettings struct {
+	// Identity contains the full identity that the plugin uses to
+	// create receipts, i.e. signatures of user provided data that
+	// prove the backend received and processed a plugin command.
+	Identity identity.FullIdentity
+
+	// Net contains the Decred network and its parameters that the
+	// backend is running on.
+	Net chaincfg.Params
+}
+
 // PluginSetting represents a configurable plugin setting.
 //
 // The value can either contain a single value or multiple values. Multiple
@@ -269,11 +282,6 @@ type PluginSetting struct {
 type Plugin struct {
 	ID       string
 	Settings []PluginSetting
-
-	// Identity contains the full identity that the plugin uses to
-	// create receipts, i.e. signatures of user provided data that
-	// prove the backend received and processed a plugin command.
-	Identity *identity.FullIdentity
 }
 
 // PluginError represents an error that occurred during plugin execution that

politeiad/backendv2/tstorebe/blobkv.go

@@ -0,0 +1,67 @@
+// Copyright (c) 2020-2021 The Decred developers
+// Use of this source code is governed by an ISC
+// license that can be found in the LICENSE file.
+
+package tstorebe
+
+import (
+	"fmt"
+
+	"github.com/decred/politeia/politeiad/backendv2/tstorebe/store"
+	"github.com/decred/politeia/politeiad/backendv2/tstorebe/store/localdb"
+	"github.com/decred/politeia/politeiad/backendv2/tstorebe/store/mysql"
+	"github.com/pkg/errors"
+)
+
+const (
+	// DBTypeLevelDB is the config option that sets the backing
+	// key-value store to a leveldb instance.
+	DBTypeLevelDB = "leveldb"
+
+	// DBTypeMySQL is a config option that sets the backing key-value
+	// store to a MySQL instance.
+	DBTypeMySQL = "mysql"
+
+	// dbUser contains the username that will be used to connect to
+	// the MySQL instance.
+	dbUser = "politeiad"
+)
+
+// blobKVOpts contains configuration options for a blob key-value store.
+type blobKVOpts struct {
+	Type string // Database type
+
+	// LevelDB options
+	AppDir  string // App home directory
+	DataDir string // App data directory
+
+	// MySQL options
+	Host     string // MySQL host
+	Password string // Password for politeiad user
+	Net      string // Active net name
+}
+
+// newBlobKV initializes and returns a new BlobKV.
+func newBlobKV(opts blobKVOpts) (store.BlobKV, error) {
+	var (
+		kv  store.BlobKV
+		err error
+	)
+	switch opts.Type {
+	case DBTypeLevelDB:
+		kv, err = localdb.New(opts.AppDir, opts.DataDir)
+		if err != nil {
+			return nil, err
+		}
+	case DBTypeMySQL:
+		dbName := fmt.Sprintf("%v_kv", opts.Net)
+		kv, err = mysql.New(opts.Host, dbUser, opts.Password, dbName)
+		if err != nil {
+			return nil, err
+		}
+	default:
+		return nil, errors.Errorf("invalid db type '%v'", opts.Type)
+	}
+
+	return kv, nil
+}