Skip to content

Commit

Permalink
command: Display state ID in PreApply+PostApply (#12261)
Browse files Browse the repository at this point in the history
  • Loading branch information
radeksimko authored Mar 1, 2017
1 parent 185c3df commit 2e2b868
Show file tree
Hide file tree
Showing 2 changed files with 125 additions and 8 deletions.
63 changes: 55 additions & 8 deletions command/hook_ui.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@ import (
)

const periodicUiTimer = 10 * time.Second
const maxIdLen = 20

type UiHook struct {
terraform.NilHook
Expand Down Expand Up @@ -128,19 +129,25 @@ func (h *UiHook) PreApply(
attrString = "\n " + attrString
}

var stateIdSuffix string
if s.ID != "" {
stateIdSuffix = fmt.Sprintf(" (ID: %s)", truncateId(s.ID, maxIdLen))
}

h.ui.Output(h.Colorize.Color(fmt.Sprintf(
"[reset][bold]%s: %s[reset]%s",
"[reset][bold]%s: %s%s[reset]%s",
id,
operation,
stateIdSuffix,
attrString)))

// Set a timer to show an operation is still happening
time.AfterFunc(periodicUiTimer, func() { h.stillApplying(id) })
time.AfterFunc(periodicUiTimer, func() { h.stillApplying(id, s.ID) })

return terraform.HookActionContinue, nil
}

func (h *UiHook) stillApplying(id string) {
func (h *UiHook) stillApplying(id, stateId string) {
// Grab the operation. We defer the lock here to avoid the "still..."
// message showing up after a completion message.
h.l.Lock()
Expand All @@ -164,15 +171,21 @@ func (h *UiHook) stillApplying(id string) {
return
}

var stateIdSuffix string
if stateId != "" {
stateIdSuffix = fmt.Sprintf("ID: %s, ", truncateId(stateId, maxIdLen))
}

h.ui.Output(h.Colorize.Color(fmt.Sprintf(
"[reset][bold]%s: %s (%s elapsed)[reset]",
"[reset][bold]%s: %s (%s%s elapsed)[reset]",
id,
msg,
stateIdSuffix,
time.Now().Round(time.Second).Sub(state.Start),
)))

// Reschedule
time.AfterFunc(periodicUiTimer, func() { h.stillApplying(id) })
time.AfterFunc(periodicUiTimer, func() { h.stillApplying(id, stateId) })
}

func (h *UiHook) PostApply(
Expand All @@ -186,6 +199,11 @@ func (h *UiHook) PostApply(
delete(h.resources, id)
h.l.Unlock()

var stateIdSuffix string
if s.ID != "" {
stateIdSuffix = fmt.Sprintf(" (ID: %s)", truncateId(s.ID, maxIdLen))
}

var msg string
switch state.Op {
case uiResourceModify:
Expand All @@ -204,8 +222,8 @@ func (h *UiHook) PostApply(
}

h.ui.Output(h.Colorize.Color(fmt.Sprintf(
"[reset][bold]%s: %s[reset]",
id, msg)))
"[reset][bold]%s: %s%s[reset]",
id, msg, stateIdSuffix)))

return terraform.HookActionContinue, nil
}
Expand Down Expand Up @@ -258,7 +276,7 @@ func (h *UiHook) PreRefresh(
// Data resources refresh before they have ids, whereas managed
// resources are only refreshed when they have ids.
if s.ID != "" {
stateIdSuffix = fmt.Sprintf(" (ID: %s)", s.ID)
stateIdSuffix = fmt.Sprintf(" (ID: %s)", truncateId(s.ID, maxIdLen))
}

h.ui.Output(h.Colorize.Color(fmt.Sprintf(
Expand Down Expand Up @@ -336,3 +354,32 @@ func dropCR(data []byte) []byte {
}
return data
}

func truncateId(id string, maxLen int) string {
totalLength := len(id)
if totalLength <= maxLen {
return id
}
if maxLen < 5 {
// We don't shorten to less than 5 chars
// as that would be pointless with ... (3 chars)
maxLen = 5
}

dots := "..."
partLen := maxLen / 2

leftIdx := partLen - 1
leftPart := id[0:leftIdx]

rightIdx := totalLength - partLen - 1

overlap := maxLen - (partLen*2 + len(dots))
if overlap < 0 {
rightIdx -= overlap
}

rightPart := id[rightIdx:]

return leftPart + dots + rightPart
}
70 changes: 70 additions & 0 deletions command/hook_ui_test.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,70 @@
package command

import (
"fmt"
"testing"
)

func TestTruncateId(t *testing.T) {
testCases := []struct {
Input string
Expected string
MaxLen int
}{
{
Input: "Hello world",
Expected: "H...d",
MaxLen: 3,
},
{
Input: "Hello world",
Expected: "H...d",
MaxLen: 5,
},
{
Input: "Hello world",
Expected: "He...d",
MaxLen: 6,
},
{
Input: "Hello world",
Expected: "He...ld",
MaxLen: 7,
},
{
Input: "Hello world",
Expected: "Hel...ld",
MaxLen: 8,
},
{
Input: "Hello world",
Expected: "Hel...rld",
MaxLen: 9,
},
{
Input: "Hello world",
Expected: "Hell...rld",
MaxLen: 10,
},
{
Input: "Hello world",
Expected: "Hello world",
MaxLen: 11,
},
{
Input: "Hello world",
Expected: "Hello world",
MaxLen: 12,
},
}
for i, tc := range testCases {
testName := fmt.Sprintf("%d", i)
t.Run(testName, func(t *testing.T) {
out := truncateId(tc.Input, tc.MaxLen)
if out != tc.Expected {
t.Fatalf("Expected %q to be shortened to %d as %q (given: %q)",
tc.Input, tc.MaxLen, tc.Expected, out)
}
})
}
}

0 comments on commit 2e2b868

Please sign in to comment.