Function Test_makeStreamError

client_internal_test.go:140–184

(t *testing.T)

func (badReader) Read([]byte) (int, error) { return 0, fmt.Errorf("boom") }

func Test_makeStreamError(t *testing.T) {
	testCases := []struct {
		body     io.Reader
		expected error
		apiErr   APIError
	}{
		{
			body:     nil,
			expected: fmt.Errorf("invalid body"),
		},
		{
			body:     badReader{},
			expected: fmt.Errorf("boom"),
		},
		{
			body:     strings.NewReader(`{{`),
			expected: fmt.Errorf("unexpected error (status code 123)"),
		},
		{
			body:     strings.NewReader(`{"code":"A"}`),
			expected: fmt.Errorf("unexpected error (status code 123)"),
		},
		{
			body:     strings.NewReader(`{"code":1, "detail":"test", "duration": "1m2s", "exception": "boom", "status_code": 456, "exception_fields": {"foo":["bar"]}}`),
			expected: fmt.Errorf("test"),
			apiErr: APIError{
				Code:       1,
				Detail:     "test",
				Duration:   Duration{time.Minute + time.Second*2},
				Exception:  "boom",
				StatusCode: 123,
				ExceptionFields: map[string][]any{
					"foo": {"bar"},
				},
			},
		},
	}
	for _, tc := range testCases {
		err := (&Client{}).makeStreamError(123, nil, tc.body)
		assert.Equal(t, tc.expected.Error(), err.Error())
		if tc.apiErr.Code != 0 {
			assert.Equal(t, tc.apiErr, err)
		}
	}
}

type requester struct {
	code int