forked from cloudfoundry/cli
-
Notifications
You must be signed in to change notification settings - Fork 0
/
ui.go
480 lines (400 loc) · 14.3 KB
/
ui.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
// Package ui will provide hooks into STDOUT, STDERR and STDIN. It will also
// handle translation as necessary.
//
// This package is explicitly designed for the CF CLI and is *not* to be used
// by any package outside of the commands package.
package ui
import (
"fmt"
"io"
"os"
"strings"
"sync"
"time"
"code.cloudfoundry.org/cli/command/translatableerror"
"code.cloudfoundry.org/cli/util/configv3"
"github.com/fatih/color"
"github.com/lunixbochs/vtclean"
runewidth "github.com/mattn/go-runewidth"
"github.com/vito/go-interact/interact"
)
// LogTimestampFormat is the timestamp formatting for log lines.
const LogTimestampFormat = "2006-01-02T15:04:05.00-0700"
// DefaultTableSpacePadding is the default space padding in tables.
const DefaultTableSpacePadding = 3
//go:generate counterfeiter . Config
// Config is the UI configuration.
type Config interface {
// ColorEnabled enables or disabled color
ColorEnabled() configv3.ColorSetting
// Locale is the language to translate the output to
Locale() string
// IsTTY returns true when the ui has a TTY
IsTTY() bool
// TerminalWidth returns the width of the terminal
TerminalWidth() int
}
//go:generate counterfeiter . LogMessage
// LogMessage is a log response representing one to many joined lines of a log
// message.
type LogMessage interface {
Message() string
Type() string
Timestamp() time.Time
SourceType() string
SourceInstance() string
}
// UI is interface to interact with the user
type UI struct {
// In is the input buffer
In io.Reader
// Out is the output buffer
Out io.Writer
// OutForInteration is the output buffer when working with go-interact. When
// working with Windows, color.Output does not work with TTY detection. So
// real STDOUT is required or go-interact will not properly work.
OutForInteration io.Writer
// Err is the error buffer
Err io.Writer
colorEnabled configv3.ColorSetting
translate TranslateFunc
terminalLock *sync.Mutex
fileLock *sync.Mutex
IsTTY bool
TerminalWidth int
TimezoneLocation *time.Location
}
// NewUI will return a UI object where Out is set to STDOUT, In is set to
// STDIN, and Err is set to STDERR
func NewUI(config Config) (*UI, error) {
translateFunc, err := GetTranslationFunc(config)
if err != nil {
return nil, err
}
location := time.Now().Location()
return &UI{
In: os.Stdin,
Out: color.Output,
OutForInteration: os.Stdout,
Err: os.Stderr,
colorEnabled: config.ColorEnabled(),
translate: translateFunc,
terminalLock: &sync.Mutex{},
fileLock: &sync.Mutex{},
IsTTY: config.IsTTY(),
TerminalWidth: config.TerminalWidth(),
TimezoneLocation: location,
}, nil
}
// NewTestUI will return a UI object where Out, In, and Err are customizable,
// and colors are disabled
func NewTestUI(in io.Reader, out io.Writer, err io.Writer) *UI {
translationFunc, translateErr := generateTranslationFunc([]byte("[]"))
if translateErr != nil {
panic(translateErr)
}
return &UI{
In: in,
Out: out,
OutForInteration: out,
Err: err,
colorEnabled: configv3.ColorDisabled,
translate: translationFunc,
terminalLock: &sync.Mutex{},
fileLock: &sync.Mutex{},
TimezoneLocation: time.UTC,
}
}
func (ui *UI) GetIn() io.Reader {
return ui.In
}
func (ui *UI) GetOut() io.Writer {
return ui.Out
}
func (ui *UI) GetErr() io.Writer {
return ui.Err
}
// DisplayBoolPrompt outputs the prompt and waits for user input. It only
// allows for a boolean response. A default boolean response can be set with
// defaultResponse.
func (ui *UI) DisplayBoolPrompt(defaultResponse bool, template string, templateValues ...map[string]interface{}) (bool, error) {
ui.terminalLock.Lock()
defer ui.terminalLock.Unlock()
response := defaultResponse
interactivePrompt := interact.NewInteraction(ui.TranslateText(template, templateValues...))
interactivePrompt.Input = ui.In
interactivePrompt.Output = ui.OutForInteration
err := interactivePrompt.Resolve(&response)
return response, err
}
// DisplayPasswordPrompt outputs the prompt and waits for user input. Hides
// user's response from the screen.
func (ui *UI) DisplayPasswordPrompt(template string, templateValues ...map[string]interface{}) (string, error) {
ui.terminalLock.Lock()
defer ui.terminalLock.Unlock()
var password interact.Password
interactivePrompt := interact.NewInteraction(ui.TranslateText(template, templateValues...))
interactivePrompt.Input = ui.In
interactivePrompt.Output = ui.OutForInteration
err := interactivePrompt.Resolve(interact.Required(&password))
return string(password), err
}
// DisplayError outputs the translated error message to ui.Err if the error
// satisfies TranslatableError, otherwise it outputs the original error message
// to ui.Err. It also outputs "FAILED" in bold red to ui.Out.
func (ui *UI) DisplayError(err error) {
var errMsg string
if translatableError, ok := err.(translatableerror.TranslatableError); ok {
errMsg = translatableError.Translate(ui.translate)
} else {
errMsg = err.Error()
}
fmt.Fprintf(ui.Err, "%s\n", errMsg)
ui.terminalLock.Lock()
defer ui.terminalLock.Unlock()
fmt.Fprintf(ui.Out, "%s\n", ui.modifyColor(ui.TranslateText("FAILED"), color.New(color.FgRed, color.Bold)))
}
// DisplayHeader translates the header, bolds and adds the default color to the
// header, and outputs the result to ui.Out.
func (ui *UI) DisplayHeader(text string) {
ui.terminalLock.Lock()
defer ui.terminalLock.Unlock()
fmt.Fprintf(ui.Out, "%s\n", ui.modifyColor(ui.TranslateText(text), color.New(color.Bold)))
}
// DisplayKeyValueTable outputs a matrix of strings as a table to UI.Out.
// Prefix will be prepended to each row and padding adds the specified number
// of spaces between columns. The final columns may wrap to multiple lines but
// will still be confined to the last column. Wrapping will occur on word
// boundaries.
func (ui *UI) DisplayKeyValueTable(prefix string, table [][]string, padding int) {
rows := len(table)
if rows == 0 {
return
}
columns := len(table[0])
if columns < 2 || !ui.IsTTY {
ui.DisplayNonWrappingTable(prefix, table, padding)
return
}
ui.displayWrappingTableWithWidth(prefix, table, padding)
}
// DisplayLogMessage formats and outputs a given log message.
func (ui *UI) DisplayLogMessage(message LogMessage, displayHeader bool) {
ui.terminalLock.Lock()
defer ui.terminalLock.Unlock()
var header string
if displayHeader {
time := message.Timestamp().In(ui.TimezoneLocation).Format(LogTimestampFormat)
header = fmt.Sprintf("%s [%s/%s] %s ",
time,
message.SourceType(),
message.SourceInstance(),
message.Type(),
)
}
for _, line := range strings.Split(message.Message(), "\n") {
logLine := fmt.Sprintf("%s%s", header, strings.TrimRight(line, "\r\n"))
if message.Type() == "ERR" {
logLine = ui.modifyColor(logLine, color.New(color.FgRed))
}
fmt.Fprintf(ui.Out, " %s\n", logLine)
}
}
// DisplayNewline outputs a newline to UI.Out.
func (ui *UI) DisplayNewline() {
ui.terminalLock.Lock()
defer ui.terminalLock.Unlock()
fmt.Fprintf(ui.Out, "\n")
}
// DisplayNonWrappingTable outputs a matrix of strings as a table to UI.Out. Prefix will
// be prepended to each row and padding adds the specified number of spaces
// between columns.
func (ui *UI) DisplayNonWrappingTable(prefix string, table [][]string, padding int) {
ui.terminalLock.Lock()
defer ui.terminalLock.Unlock()
if len(table) == 0 {
return
}
var columnPadding []int
rows := len(table)
columns := len(table[0])
for col := 0; col < columns; col++ {
var max int
for row := 0; row < rows; row++ {
if strLen := wordSize(table[row][col]); max < strLen {
max = strLen
}
}
columnPadding = append(columnPadding, max+padding)
}
for row := 0; row < rows; row++ {
fmt.Fprintf(ui.Out, prefix)
for col := 0; col < columns; col++ {
data := table[row][col]
var addedPadding int
if col+1 != columns {
addedPadding = columnPadding[col] - wordSize(data)
}
fmt.Fprintf(ui.Out, "%s%s", data, strings.Repeat(" ", addedPadding))
}
fmt.Fprintf(ui.Out, "\n")
}
}
// DisplayOK outputs a bold green translated "OK" to UI.Out.
func (ui *UI) DisplayOK() {
ui.terminalLock.Lock()
defer ui.terminalLock.Unlock()
fmt.Fprintf(ui.Out, "%s\n", ui.modifyColor(ui.TranslateText("OK"), color.New(color.FgGreen, color.Bold)))
}
func (ui *UI) DisplayTableWithHeader(prefix string, table [][]string, padding int) {
if len(table) == 0 {
return
}
for i, str := range table[0] {
table[0][i] = ui.modifyColor(str, color.New(color.Bold))
}
ui.DisplayNonWrappingTable(prefix, table, padding)
}
// DisplayText translates the template, substitutes in templateValues, and
// outputs the result to ui.Out. Only the first map in templateValues is used.
func (ui *UI) DisplayText(template string, templateValues ...map[string]interface{}) {
ui.terminalLock.Lock()
defer ui.terminalLock.Unlock()
fmt.Fprintf(ui.Out, "%s\n", ui.TranslateText(template, templateValues...))
}
// DisplayTextWithFlavor translates the template, bolds and adds cyan color to
// templateValues, substitutes templateValues into the template, and outputs
// the result to ui.Out. Only the first map in templateValues is used.
func (ui *UI) DisplayTextWithFlavor(template string, templateValues ...map[string]interface{}) {
ui.terminalLock.Lock()
defer ui.terminalLock.Unlock()
firstTemplateValues := getFirstSet(templateValues)
for key, value := range firstTemplateValues {
firstTemplateValues[key] = ui.modifyColor(fmt.Sprint(value), color.New(color.FgCyan, color.Bold))
}
fmt.Fprintf(ui.Out, "%s\n", ui.TranslateText(template, firstTemplateValues))
}
// DisplayTextWithBold translates the template, bolds the templateValues,
// substitutes templateValues into the template, and outputs
// the result to ui.Out. Only the first map in templateValues is used.
func (ui *UI) DisplayTextWithBold(template string, templateValues ...map[string]interface{}) {
ui.terminalLock.Lock()
defer ui.terminalLock.Unlock()
firstTemplateValues := getFirstSet(templateValues)
for key, value := range firstTemplateValues {
firstTemplateValues[key] = ui.modifyColor(fmt.Sprint(value), color.New(color.Bold))
}
fmt.Fprintf(ui.Out, "%s\n", ui.TranslateText(template, firstTemplateValues))
}
// DisplayWarning translates the warning, substitutes in templateValues, and
// outputs to ui.Err. Only the first map in templateValues is used.
func (ui *UI) DisplayWarning(template string, templateValues ...map[string]interface{}) {
fmt.Fprintf(ui.Err, "%s\n", ui.TranslateText(template, templateValues...))
}
// DisplayWarnings translates the warnings and outputs to ui.Err.
func (ui *UI) DisplayWarnings(warnings []string) {
for _, warning := range warnings {
fmt.Fprintf(ui.Err, "%s\n", ui.TranslateText(warning))
}
}
// RequestLoggerFileWriter returns a RequestLoggerFileWriter that cannot
// overwrite another RequestLoggerFileWriter.
func (ui *UI) RequestLoggerFileWriter(filePaths []string) *RequestLoggerFileWriter {
return newRequestLoggerFileWriter(ui, ui.fileLock, filePaths)
}
// RequestLoggerTerminalDisplay returns a RequestLoggerTerminalDisplay that
// cannot overwrite another RequestLoggerTerminalDisplay or the current
// display.
func (ui *UI) RequestLoggerTerminalDisplay() *RequestLoggerTerminalDisplay {
return newRequestLoggerTerminalDisplay(ui, ui.terminalLock)
}
// TranslateText passes the template through an internationalization function
// to translate it to a pre-configured language, and returns the template with
// templateValues substituted in. Only the first map in templateValues is used.
func (ui *UI) TranslateText(template string, templateValues ...map[string]interface{}) string {
return ui.translate(template, getFirstSet(templateValues))
}
// UserFriendlyDate converts the time to UTC and then formats it to ISO8601.
func (ui *UI) UserFriendlyDate(input time.Time) string {
return input.Local().Format("Mon 02 Jan 15:04:05 MST 2006")
}
func (ui *UI) Writer() io.Writer {
return ui.Out
}
func (ui *UI) displayWrappingTableWithWidth(prefix string, table [][]string, padding int) {
ui.terminalLock.Lock()
defer ui.terminalLock.Unlock()
var columnPadding []int
rows := len(table)
columns := len(table[0])
for col := 0; col < columns-1; col++ {
var max int
for row := 0; row < rows; row++ {
if strLen := runewidth.StringWidth(table[row][col]); max < strLen {
max = strLen
}
}
columnPadding = append(columnPadding, max+padding)
}
spilloverPadding := len(prefix) + sum(columnPadding)
lastColumnWidth := ui.TerminalWidth - spilloverPadding
for row := 0; row < rows; row++ {
fmt.Fprintf(ui.Out, prefix)
// for all columns except last, add cell value and padding
for col := 0; col < columns-1; col++ {
var addedPadding int
if col+1 != columns {
addedPadding = columnPadding[col] - runewidth.StringWidth(table[row][col])
}
fmt.Fprintf(ui.Out, "%s%s", table[row][col], strings.Repeat(" ", addedPadding))
}
// for last column, add each word individually. If the added word would make the column exceed terminal width, create a new line and add padding
words := strings.Split(table[row][columns-1], " ")
currentWidth := 0
for _, word := range words {
wordWidth := runewidth.StringWidth(word)
if currentWidth == 0 {
currentWidth = wordWidth
fmt.Fprintf(ui.Out, "%s", word)
} else if wordWidth+1+currentWidth > lastColumnWidth {
fmt.Fprintf(ui.Out, "\n%s%s", strings.Repeat(" ", spilloverPadding), word)
currentWidth = wordWidth
} else {
fmt.Fprintf(ui.Out, " %s", word)
currentWidth += wordWidth + 1
}
}
fmt.Fprintf(ui.Out, "\n")
}
}
// getFirstSet returns the first map if 1 or more maps are provided. Otherwise
// it returns the empty map.
func getFirstSet(list []map[string]interface{}) map[string]interface{} {
if list == nil || len(list) == 0 {
return map[string]interface{}{}
}
return list[0]
}
func (ui *UI) modifyColor(text string, colorPrinter *color.Color) string {
if len(text) == 0 {
return text
}
switch ui.colorEnabled {
case configv3.ColorEnabled:
colorPrinter.EnableColor()
case configv3.ColorDisabled:
colorPrinter.DisableColor()
}
return colorPrinter.SprintFunc()(text)
}
func sum(intSlice []int) int {
sum := 0
for _, i := range intSlice {
sum += i
}
return sum
}
func wordSize(str string) int {
cleanStr := vtclean.Clean(str, false)
return runewidth.StringWidth(cleanStr)
}