yms-daemon/internal/containerengine/moby_test.go

package containerengine

import (
	"strings"
	"testing"
)

// TestDecodeImageLoadResponseConsumesCompleteSuccessStream 验证成功流中的多条消息能被完整消费且不产生错误。
func TestDecodeImageLoadResponseConsumesCompleteSuccessStream(t *testing.T) {
	t.Parallel()
	input := strings.NewReader("{\"stream\":\"Loaded image: repository:20260814-093609-d7ed70f0-v1.1.8.1\\n\"}\n" +
		"{\"stream\":\"Loaded image: repository:20260814-093609-d7ed70f0\\n\"}\n")
	if err := decodeImageLoadResponse(input); err != nil {
		t.Fatalf("decode successful load response: %v", err)
	}
}

// TestDecodeImageLoadResponseReturnsStreamError 验证包含错误详情字段的消息会被解析为对应错误返回。
func TestDecodeImageLoadResponseReturnsStreamError(t *testing.T) {
	t.Parallel()
	err := decodeImageLoadResponse(strings.NewReader(`{"errorDetail":{"code":500,"message":"load failed"}}`))
	if err == nil || err.Error() != "load failed" {
		t.Fatalf("unexpected load error: %v", err)
	}
}

// TestDecodeImageLoadResponseRejectsMalformedJSON 验证格式错误的 JSON 输入会返回解码错误。
func TestDecodeImageLoadResponseRejectsMalformedJSON(t *testing.T) {
	t.Parallel()
	err := decodeImageLoadResponse(strings.NewReader(`{"stream":`))
	if err == nil {
		t.Fatalf("expected malformed response error, got %v", err)
	}
}