Implement Consul K/V storage backend

Fixes #672

backend/context.go

@@ -121,6 +121,8 @@ func WithStoreBackendString(ctx context.Context, sb string) context.Context {
 		return WithStoreBackend(ctx, KVMock)
 	case "fs":
 		return WithStoreBackend(ctx, FS)
+	case "consul":
+		return WithStoreBackend(ctx, Consul)
 	default:
 		return WithStoreBackend(ctx, FS)
 	}
@@ -147,6 +149,8 @@ func StoreBackendName(sb StoreBackend) string {
 		return "fs"
 	case KVMock:
 		return "kvmock"
+	case Consul:
+		return "consul"
 	default:
 		return ""
 	}

backend/store.go

@@ -14,6 +14,8 @@ const (
 	KVMock StoreBackend = iota
 	// FS is a filesystem-backend storage
 	FS
+	// Consul is a consul backend storage
+	Consul
 )
 
 // Store is an storage backend

backend/store/kv/consul/store.go

@@ -0,0 +1,91 @@
+package consul
+
+import (
+	"context"
+
+	"github.com/blang/semver"
+	api "github.com/hashicorp/consul/api"
+)
+
+type Store struct {
+	api *api.Client
+}
+
+func New(host, datacenter, token string) (*Store, error) {
+	client, err := api.NewClient(&api.Config{
+		Address:    host,
+		Datacenter: datacenter,
+		Token:      token,
+	})
+	if err != nil {
+		return nil, err
+	}
+	return &Store{
+		api: client,
+	}, nil
+}
+
+func (s *Store) Get(ctx context.Context, name string) ([]byte, error) {
+	p, _, err := s.api.KV().Get(name, nil)
+	if err != nil {
+		return nil, err
+	}
+	if p == nil || p.Value == nil {
+		return nil, nil
+	}
+	return p.Value, nil
+}
+
+func (s *Store) Set(ctx context.Context, name string, value []byte) error {
+	p := &api.KVPair{
+		Key:   name,
+		Value: value,
+	}
+	_, err := s.api.KV().Put(p, nil)
+	return err
+}
+
+func (s *Store) Delete(ctx context.Context, name string) error {
+	_, err := s.api.KV().Delete(name, nil)
+	return err
+}
+
+func (s *Store) Exists(ctx context.Context, name string) bool {
+	v, err := s.Get(ctx, name)
+	if err == nil && v != nil {
+		return true
+	}
+	return false
+}
+
+func (s *Store) List(ctx context.Context, prefix string) ([]string, error) {
+	pairs, _, err := s.api.KV().List(prefix, nil)
+	if err != nil {
+		return nil, err
+	}
+	res := make([]string, len(pairs))
+	for _, kvp := range pairs {
+		res = append(res, kvp.Key)
+	}
+	return res, nil
+}
+
+func (s *Store) IsDir(ctx context.Context, name string) bool {
+	ls, err := s.List(ctx, name)
+	if err == nil && len(ls) > 1 {
+		return true
+	}
+	return false
+}
+
+func (s *Store) Prune(ctx context.Context, prefix string) error {
+	return s.Delete(ctx, prefix)
+}
+
+func (s *Store) Name() string {
+	return "consul"
+}
+
+func (s *Store) Version() semver.Version {
+	return semver.Version{Major: 1}
+}

store/sub/store.go

@@ -12,6 +12,7 @@ import (
 	"github.com/justwatchcom/gopass/backend/crypto/gpg/openpgp"
 	"github.com/justwatchcom/gopass/backend/crypto/xc"
 	"github.com/justwatchcom/gopass/backend/store/fs"
+	kvconsul "github.com/justwatchcom/gopass/backend/store/kv/consul"
 	kvmock "github.com/justwatchcom/gopass/backend/store/kv/mock"
 	gitcli "github.com/justwatchcom/gopass/backend/sync/git/cli"
 	"github.com/justwatchcom/gopass/backend/sync/git/gogit"
@@ -51,6 +52,14 @@ func New(ctx context.Context, alias, path string, cfgdir string) (*Store, error)
 	case backend.KVMock:
 		s.store = kvmock.New()
 		out.Debug(ctx, "Using Store Backend: kvmock")
+	case backend.Consul:
+		// TODO need #677 first
+		store, err := kvconsul.New("TODO", "TODO", "TODO")
+		if err != nil {
+			return nil, err
+		}
+		s.store = store
+		out.Debug(ctx, "Using Store Backend: consul")
 	default:
 		return nil, fmt.Errorf("Unknown store backend")
 	}