add tursodb (mvcc) mode flag with db create command (#1028)

Added `--tursodb` flag to create database with Tursodb as the backend.

Author: penberg

internal/cmd/db_create.go

@@ -62,6 +62,7 @@ func init() {
 	addSizeLimitFlag(createCmd)
 	addRemoteEncryptionCipherFlag(createCmd)
 	addRemoteEncryptionKeyFlag(createCmd)
+	addTursoDBFlag(createCmd)
 }
 
 var createCmd = &cobra.Command{
@@ -126,7 +127,7 @@ func CreateDatabase(name string) error {
 	spinner := prompt.Spinner(fmt.Sprintf("Creating database %s in group %s...", internal.Emph(name), internal.Emph(groupName)))
 	defer spinner.Stop()
 
-	if _, err = client.Databases.Create(name, location, "", "", groupName, schemaFlag, typeFlag == "schema", seed, sizeLimitFlag, remoteEncryptionCipherFlag, remoteEncryptionKeyFlag(), spinner); err != nil {
+	if _, err = client.Databases.Create(name, location, "", "", groupName, schemaFlag, typeFlag == "schema", seed, sizeLimitFlag, remoteEncryptionCipherFlag, remoteEncryptionKeyFlag(), tursoDBFlag, spinner); err != nil {
 		return fmt.Errorf("could not create database %s: %w", name, err)
 	}
 

internal/cmd/tursodb_flag.go

@@ -0,0 +1,9 @@
+package cmd
+
+import "github.com/spf13/cobra"
+
+var tursoDBFlag bool
+
+func addTursoDBFlag(cmd *cobra.Command) {
+	cmd.Flags().BoolVar(&tursoDBFlag, "tursodb", false, "Create the database using TursoDB (MVCC).")
+}

internal/turso/databases.go

@@ -150,9 +150,10 @@ type CreateDatabaseBody struct {
 	IsSchema         bool              `json:"is_schema,omitempty"`
 	SizeLimit        string            `json:"size_limit,omitempty"`
 	RemoteEncryption *RemoteEncryption `json:"remote_encryption,omitempty"`
+	UseTursoDB       bool              `json:"use_tursodb,omitempty"`
 }
 
-func (d *DatabasesClient) Create(name, location, image, extensions, group string, schema string, isSchema bool, seed *DBSeed, sizeLimit, remoteEncryptionCipher, remoteEncryptionKey string, spinner *prompt.SpinnerT) (*CreateDatabaseResponse, error) {
+func (d *DatabasesClient) Create(name, location, image, extensions, group string, schema string, isSchema bool, seed *DBSeed, sizeLimit, remoteEncryptionCipher, remoteEncryptionKey string, useTursoDB bool, spinner *prompt.SpinnerT) (*CreateDatabaseResponse, error) {
 	isTursoServerUpload := seed != nil && seed.Type == "database_upload" && seed.Filepath != ""
 	var uploadFilepath string
 	var params CreateDatabaseBody
@@ -164,13 +165,14 @@ func (d *DatabasesClient) Create(name, location, image, extensions, group string
 		seed.URL = ""
 		seed.Timestamp = nil
 		params = CreateDatabaseBody{
-			Name:     name,
-			Location: location,
-			Group:    group,
-			Seed:     seed,
+			Name:       name,
+			Location:   location,
+			Group:      group,
+			Seed:       seed,
+			UseTursoDB: useTursoDB,
 		}
 	} else {
-		params = CreateDatabaseBody{name, location, image, extensions, group, seed, schema, isSchema, sizeLimit, nil}
+		params = CreateDatabaseBody{name, location, image, extensions, group, seed, schema, isSchema, sizeLimit, nil, useTursoDB}
 	}
 
 	if remoteEncryptionKey != "" {