aboutsummaryrefslogtreecommitdiff
path: root/cmd/bolt/main_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'cmd/bolt/main_test.go')
-rw-r--r--cmd/bolt/main_test.go75
1 files changed, 75 insertions, 0 deletions
diff --git a/cmd/bolt/main_test.go b/cmd/bolt/main_test.go
new file mode 100644
index 0000000..5c70c97
--- /dev/null
+++ b/cmd/bolt/main_test.go
@@ -0,0 +1,75 @@
+package main_test
+
+import (
+ "io/ioutil"
+ "os"
+ "strings"
+ "testing"
+
+ "github.com/boltdb/bolt"
+ . "github.com/boltdb/bolt/cmd/bolt"
+ "github.com/stretchr/testify/assert"
+)
+
+// Ensure that a value can be retrieved from the CLI.
+func TestGet(t *testing.T) {
+ SetTestMode(true)
+ open(func(db *bolt.DB) {
+ db.Do(func(tx *bolt.Tx) error {
+ tx.CreateBucket("widgets")
+ tx.Bucket("widgets").Put([]byte("foo"), []byte("bar"))
+ return nil
+ })
+ output := run("get", db.Path(), "widgets", "foo")
+ assert.Equal(t, "bar", output)
+ })
+}
+
+// Ensure that an error is reported if the database is not found.
+func TestGetDBNotFound(t *testing.T) {
+ SetTestMode(true)
+ output := run("get", "no/such/db", "widgets", "foo")
+ assert.Equal(t, "stat no/such/db: no such file or directory", output)
+}
+
+// Ensure that an error is reported if the bucket is not found.
+func TestGetBucketNotFound(t *testing.T) {
+ SetTestMode(true)
+ open(func(db *bolt.DB) {
+ output := run("get", db.Path(), "widgets", "foo")
+ assert.Equal(t, "bucket not found: widgets", output)
+ })
+}
+
+// Ensure that an error is reported if the key is not found.
+func TestGetKeyNotFound(t *testing.T) {
+ SetTestMode(true)
+ open(func(db *bolt.DB) {
+ db.Do(func(tx *bolt.Tx) error {
+ return tx.CreateBucket("widgets")
+ })
+ output := run("get", db.Path(), "widgets", "foo")
+ assert.Equal(t, "key not found: foo", output)
+ })
+}
+
+// open creates and opens a Bolt database in the temp directory.
+func open(fn func(*bolt.DB)) {
+ f, _ := ioutil.TempFile("", "bolt-")
+ f.Close()
+ os.Remove(f.Name())
+ defer os.RemoveAll(f.Name())
+
+ db, err := bolt.Open(f.Name(), 0600)
+ if err != nil {
+ panic("db open error: " + err.Error())
+ }
+ fn(db)
+}
+
+// run executes a command against the CLI and returns the output.
+func run(args ...string) string {
+ args = append([]string{"bolt"}, args...)
+ NewApp().Run(args)
+ return strings.TrimSpace(LogBuffer())
+}