luxolus/open-consul
2
0
Fork 0
Code Issues 1 Pull requests Packages Releases Wiki Activity

command/keyring: refactor, adjust tests

Browse source
This commit is contained in:
Ryan Uber 2014-09-29 15:49:47 -07:00
parent c1ea291112
commit bea19b5135
2 changed files with 8 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
command/keyring.go
View file

@ -11,7 +11,6 @@ import (
"github.com/hashicorp/consul/command/agent"
"github.com/mitchellh/cli"
"github.com/ryanuber/columnize"
)
const (
@ -97,7 +96,7 @@ func (c *KeyringCommand) Run(args []string) int {
defer client.Close()
if listKeys {
c.Ui.Info("Asking all members for installed keys...")
c.Ui.Info("Gathering installed encryption keys...")
r, err := client.ListKeys()
if err != nil {
c.Ui.Error(fmt.Sprintf("error: %s", err))
@ -161,17 +160,12 @@ func (c *KeyringCommand) handleResponse(
c.Ui.Error("")
c.Ui.Error(fmt.Sprintf("%s error: %s", pool, i.Error))
var errors []string
for _, msg := range messages {
if msg.Datacenter != i.Datacenter || msg.Pool != i.Pool {
continue
}
errors = append(errors, fmt.Sprintf(
"failed: %s | %s",
msg.Node,
msg.Message))
c.Ui.Error(fmt.Sprintf(" %s: %s", msg.Node, msg.Message))
}
c.Ui.Error(columnize.SimpleFormat(errors))
rval = 1
}
}
@ -208,16 +202,13 @@ func (c *KeyringCommand) handleList(
installed[pool][key.Key] = []int{key.Count, nodes}
}
}
for pool, keys := range installed {
c.Ui.Output("")
c.Ui.Output(pool + ":")
var out []string
for key, num := range keys {
out = append(out, fmt.Sprintf(
"%s | [%d/%d]",
key, num[0], num[1]))
c.Ui.Output(fmt.Sprintf(" %s [%d/%d]", key, num[0], num[1]))
}
c.Ui.Output(columnize.SimpleFormat(out))
}
}

8
command/keyring_test.go
View file

@ -26,10 +26,10 @@ func TestKeyringCommandRun(t *testing.T) {
// The LAN and WAN keyrings were initialized with key1
out := listKeys(t, a1.addr)
if !strings.Contains(out, "dc1 (LAN):\n"+key1) {
if !strings.Contains(out, "dc1 (LAN):\n "+key1) {
t.Fatalf("bad: %#v", out)
}
if !strings.Contains(out, "WAN:\n"+key1) {
if !strings.Contains(out, "WAN:\n "+key1) {
t.Fatalf("bad: %#v", out)
}
if strings.Contains(out, key2) {
@ -53,10 +53,10 @@ func TestKeyringCommandRun(t *testing.T) {
// Only key2 is present now
out = listKeys(t, a1.addr)
if !strings.Contains(out, "dc1 (LAN):\n"+key2) {
if !strings.Contains(out, "dc1 (LAN):\n "+key2) {
t.Fatalf("bad: %#v", out)
}
if !strings.Contains(out, "WAN:\n"+key2) {
if !strings.Contains(out, "WAN:\n "+key2) {
t.Fatalf("bad: %#v", out)
}
if strings.Contains(out, key1) {