dbb2000590
The test was failing if the terminal column width is <= 110. Addendum to #23113 Signed-off-by: Akihiro Suda <suda.akihiro@lab.ntt.co.jp>
108 lines
3.1 KiB
Go
108 lines
3.1 KiB
Go
package streamformatter
|
|
|
|
import (
|
|
"encoding/json"
|
|
"errors"
|
|
"reflect"
|
|
"strings"
|
|
"testing"
|
|
|
|
"github.com/docker/docker/pkg/jsonmessage"
|
|
)
|
|
|
|
func TestFormatStream(t *testing.T) {
|
|
sf := NewStreamFormatter()
|
|
res := sf.FormatStream("stream")
|
|
if string(res) != "stream"+"\r" {
|
|
t.Fatalf("%q", res)
|
|
}
|
|
}
|
|
|
|
func TestFormatJSONStatus(t *testing.T) {
|
|
sf := NewStreamFormatter()
|
|
res := sf.FormatStatus("ID", "%s%d", "a", 1)
|
|
if string(res) != "a1\r\n" {
|
|
t.Fatalf("%q", res)
|
|
}
|
|
}
|
|
|
|
func TestFormatSimpleError(t *testing.T) {
|
|
sf := NewStreamFormatter()
|
|
res := sf.FormatError(errors.New("Error for formatter"))
|
|
if string(res) != "Error: Error for formatter\r\n" {
|
|
t.Fatalf("%q", res)
|
|
}
|
|
}
|
|
|
|
func TestJSONFormatStream(t *testing.T) {
|
|
sf := NewJSONStreamFormatter()
|
|
res := sf.FormatStream("stream")
|
|
if string(res) != `{"stream":"stream"}`+"\r\n" {
|
|
t.Fatalf("%q", res)
|
|
}
|
|
}
|
|
|
|
func TestJSONFormatStatus(t *testing.T) {
|
|
sf := NewJSONStreamFormatter()
|
|
res := sf.FormatStatus("ID", "%s%d", "a", 1)
|
|
if string(res) != `{"status":"a1","id":"ID"}`+"\r\n" {
|
|
t.Fatalf("%q", res)
|
|
}
|
|
}
|
|
|
|
func TestJSONFormatSimpleError(t *testing.T) {
|
|
sf := NewJSONStreamFormatter()
|
|
res := sf.FormatError(errors.New("Error for formatter"))
|
|
if string(res) != `{"errorDetail":{"message":"Error for formatter"},"error":"Error for formatter"}`+"\r\n" {
|
|
t.Fatalf("%q", res)
|
|
}
|
|
}
|
|
|
|
func TestJSONFormatJSONError(t *testing.T) {
|
|
sf := NewJSONStreamFormatter()
|
|
err := &jsonmessage.JSONError{Code: 50, Message: "Json error"}
|
|
res := sf.FormatError(err)
|
|
if string(res) != `{"errorDetail":{"code":50,"message":"Json error"},"error":"Json error"}`+"\r\n" {
|
|
t.Fatalf("%q", res)
|
|
}
|
|
}
|
|
|
|
func TestJSONFormatProgress(t *testing.T) {
|
|
sf := NewJSONStreamFormatter()
|
|
progress := &jsonmessage.JSONProgress{
|
|
Current: 15,
|
|
Total: 30,
|
|
Start: 1,
|
|
}
|
|
res := sf.FormatProgress("id", "action", progress, nil)
|
|
msg := &jsonmessage.JSONMessage{}
|
|
if err := json.Unmarshal(res, msg); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if msg.ID != "id" {
|
|
t.Fatalf("ID must be 'id', got: %s", msg.ID)
|
|
}
|
|
if msg.Status != "action" {
|
|
t.Fatalf("Status must be 'action', got: %s", msg.Status)
|
|
}
|
|
|
|
// The progress will always be in the format of:
|
|
// [=========================> ] 15 B/30 B 404933h7m11s
|
|
// The last entry '404933h7m11s' is the timeLeftBox.
|
|
// However, the timeLeftBox field may change as progress.String() depends on time.Now().
|
|
// Therefore, we have to strip the timeLeftBox from the strings to do the comparison.
|
|
|
|
// Compare the progress strings before the timeLeftBox
|
|
expectedProgress := "[=========================> ] 15 B/30 B"
|
|
// if terminal column is <= 110, expectedProgressShort is expected.
|
|
expectedProgressShort := " 15 B/30 B"
|
|
if !(strings.HasPrefix(msg.ProgressMessage, expectedProgress) ||
|
|
strings.HasPrefix(msg.ProgressMessage, expectedProgressShort)) {
|
|
t.Fatalf("ProgressMessage without the timeLeftBox must be %s or %s, got: %s",
|
|
expectedProgress, expectedProgressShort, msg.ProgressMessage)
|
|
}
|
|
|
|
if !reflect.DeepEqual(msg.Progress, progress) {
|
|
t.Fatal("Original progress not equals progress from FormatProgress")
|
|
}
|
|
}
|