mirror of
https://github.com/hashicorp/vault.git
synced 2025-08-10 00:27:02 +02:00
792d219aa9
* logbridge with hclog and identical output * Initial search & replace This compiles, but there is a fair amount of TODO and commented out code, especially around the plugin logclient/logserver code. * strip logbridge * fix majority of tests * update logxi aliases * WIP fixing tests * more test fixes * Update test to hclog * Fix format * Rename hclog -> log * WIP making hclog and logxi love each other * update logger_test.go * clean up merged comments * Replace RawLogger interface with a Logger * Add some logger names * Replace Trace with Debug * update builtin logical logging patterns * Fix build errors * More log updates * update log approach in command and builtin * More log updates * update helper, http, and logical directories * Update loggers * Log updates * Update logging * Update logging * Update logging * Update logging * update logging in physical * prefixing and lowercase * Update logging * Move phyisical logging name to server command * Fix som tests * address jims feedback so far * incorporate brians feedback so far * strip comments * move vault.go to logging package * update Debug to Trace * Update go-plugin deps * Update logging based on review comments * Updates from review * Unvendor logxi * Remove null_logger.go
104 lines
2.3 KiB
Go
104 lines
2.3 KiB
Go
package cockroachdb
|
|
|
|
import (
|
|
"database/sql"
|
|
"fmt"
|
|
"os"
|
|
"testing"
|
|
|
|
dockertest "gopkg.in/ory-am/dockertest.v3"
|
|
|
|
log "github.com/hashicorp/go-hclog"
|
|
"github.com/hashicorp/vault/helper/logging"
|
|
"github.com/hashicorp/vault/physical"
|
|
|
|
_ "github.com/lib/pq"
|
|
)
|
|
|
|
func prepareCockroachDBTestContainer(t *testing.T) (cleanup func(), retURL, tableName string) {
|
|
tableName = os.Getenv("CR_TABLE")
|
|
if tableName == "" {
|
|
tableName = "vault_kv_store"
|
|
}
|
|
retURL = os.Getenv("CR_URL")
|
|
if retURL != "" {
|
|
return func() {}, retURL, tableName
|
|
}
|
|
|
|
pool, err := dockertest.NewPool("")
|
|
if err != nil {
|
|
t.Fatalf("Failed to connect to docker: %s", err)
|
|
}
|
|
|
|
dockerOptions := &dockertest.RunOptions{
|
|
Repository: "cockroachdb/cockroach",
|
|
Tag: "release-1.0",
|
|
Cmd: []string{"start", "--insecure"},
|
|
}
|
|
resource, err := pool.RunWithOptions(dockerOptions)
|
|
if err != nil {
|
|
t.Fatalf("Could not start local CockroachDB docker container: %s", err)
|
|
}
|
|
|
|
cleanup = func() {
|
|
err := pool.Purge(resource)
|
|
if err != nil {
|
|
t.Fatalf("Failed to cleanup local container: %s", err)
|
|
}
|
|
}
|
|
|
|
retURL = fmt.Sprintf("postgresql://root@localhost:%s/?sslmode=disable", resource.GetPort("26257/tcp"))
|
|
database := "database"
|
|
tableName = database + ".vault_kv"
|
|
|
|
// exponential backoff-retry
|
|
if err = pool.Retry(func() error {
|
|
var err error
|
|
db, err := sql.Open("postgres", retURL)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
_, err = db.Exec("CREATE DATABASE database")
|
|
return err
|
|
}); err != nil {
|
|
cleanup()
|
|
t.Fatalf("Could not connect to docker: %s", err)
|
|
}
|
|
return cleanup, retURL, tableName
|
|
}
|
|
|
|
func TestCockroachDBBackend(t *testing.T) {
|
|
cleanup, connURL, table := prepareCockroachDBTestContainer(t)
|
|
defer cleanup()
|
|
|
|
// Run vault tests
|
|
logger := logging.NewVaultLogger(log.Debug)
|
|
|
|
b, err := NewCockroachDBBackend(map[string]string{
|
|
"connection_url": connURL,
|
|
"table": table,
|
|
}, logger)
|
|
|
|
if err != nil {
|
|
t.Fatalf("Failed to create new backend: %v", err)
|
|
}
|
|
|
|
defer func() {
|
|
truncate(t, b)
|
|
}()
|
|
|
|
physical.ExerciseBackend(t, b)
|
|
truncate(t, b)
|
|
physical.ExerciseBackend_ListPrefix(t, b)
|
|
truncate(t, b)
|
|
physical.ExerciseTransactionalBackend(t, b)
|
|
}
|
|
|
|
func truncate(t *testing.T, b physical.Backend) {
|
|
crdb := b.(*CockroachDBBackend)
|
|
_, err := crdb.client.Exec("TRUNCATE TABLE " + crdb.table)
|
|
if err != nil {
|
|
t.Fatalf("Failed to drop table: %v", err)
|
|
}
|
|
}
|