Function TestIsStreamTruncationError

pkg/modelerrors/modelerrors_test.go:478–505

(t *testing.T)

}

func TestIsStreamTruncationError(t *testing.T) {
	t.Parallel()

	tests := []struct {
		name     string
		err      error
		expected bool
	}{
		{name: "nil error", err: nil, expected: false},
		{name: "unexpected end of JSON input", err: errors.New("unexpected end of JSON input"), expected: true},
		{name: "unexpected EOF", err: errors.New("unexpected EOF"), expected: true},
		{name: "mixed case", err: errors.New("Unexpected EOF"), expected: true},
		{name: "wrapped by stream layer", err: fmt.Errorf("error receiving from stream: %w", errors.New("unexpected end of JSON input")), expected: true},
		// Context teardown must NOT be claimed as an upstream truncation, even
		// if the message happens to mention EOF-ish text.
		{name: "context canceled", err: context.Canceled, expected: false},
		{name: "context deadline", err: context.DeadlineExceeded, expected: false},
		{name: "clean EOF is not a truncation signature", err: errors.New("EOF"), expected: false},
		{name: "unrelated error", err: errors.New("connection refused"), expected: false},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			t.Parallel()
			assert.Equal(t, tt.expected, IsStreamTruncationError(tt.err), "IsStreamTruncationError(%v)", tt.err)
		})
	}
}

func TestFormatError(t *testing.T) {
	t.Parallel()