Skip to content

Commit aa7572b

Browse files
authored
Update http client unexpected response messages (#895)
1 parent 2873e64 commit aa7572b

File tree

2 files changed

+15
-9
lines changed

2 files changed

+15
-9
lines changed

cli/cmd/errors.go

Lines changed: 12 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@ package cmd
1919
import (
2020
"fmt"
2121
"net/url"
22+
"strings"
2223

2324
"github.com/cortexlabs/cortex/pkg/lib/errors"
2425
s "github.com/cortexlabs/cortex/pkg/lib/strings"
@@ -134,24 +135,29 @@ func ErrorOperatorSocketRead(err error) error {
134135
})
135136
}
136137

137-
func ErrorResponseUnknown(body string) error {
138+
func ErrorResponseUnknown(body string, statusCode int) error {
139+
msg := body
140+
if strings.TrimSpace(body) == "" {
141+
msg = fmt.Sprintf("empty response (status code %d)", statusCode)
142+
}
143+
138144
return errors.WithStack(&errors.Error{
139145
Kind: ErrResponseUnknown,
140-
Message: body,
146+
Message: msg,
141147
})
142148
}
143149

144-
func ErrorOperatorResponseUnknown(body string) error {
150+
func ErrorOperatorResponseUnknown(body string, statusCode int) error {
145151
return errors.WithStack(&errors.Error{
146152
Kind: ErrOperatorResponseUnknown,
147-
Message: body,
153+
Message: fmt.Sprintf("unexpected response from operator (status code %d): %s", statusCode, body),
148154
})
149155
}
150156

151-
func ErrorOperatorStreamResponseUnknown(body string) error {
157+
func ErrorOperatorStreamResponseUnknown(body string, statusCode int) error {
152158
return errors.WithStack(&errors.Error{
153159
Kind: ErrOperatorStreamResponseUnknown,
154-
Message: body,
160+
Message: fmt.Sprintf("unexpected response from operator (status code %d): %s", statusCode, body),
155161
})
156162
}
157163

cli/cmd/lib_http_client.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -218,7 +218,7 @@ func StreamLogs(apiName string) error {
218218
var output schema.ErrorResponse
219219
err = json.Unmarshal(bodyBytes, &output)
220220
if err != nil || output.Message == "" {
221-
return ErrorOperatorStreamResponseUnknown(string(bodyBytes))
221+
return ErrorOperatorStreamResponseUnknown(string(bodyBytes), response.StatusCode)
222222
}
223223
return errors.WithStack(&errors.Error{
224224
Kind: output.Kind,
@@ -311,7 +311,7 @@ func (client *OperatorClient) MakeRequest(request *http.Request) ([]byte, error)
311311
var output schema.ErrorResponse
312312
err = json.Unmarshal(bodyBytes, &output)
313313
if err != nil || output.Message == "" {
314-
return nil, ErrorOperatorResponseUnknown(string(bodyBytes))
314+
return nil, ErrorOperatorResponseUnknown(string(bodyBytes), response.StatusCode)
315315
}
316316

317317
return nil, errors.WithStack(&errors.Error{
@@ -340,7 +340,7 @@ func (client *GenericClient) MakeRequest(request *http.Request) ([]byte, error)
340340
if err != nil {
341341
return nil, errors.Wrap(err, _errStrRead)
342342
}
343-
return nil, ErrorResponseUnknown(string(bodyBytes))
343+
return nil, ErrorResponseUnknown(string(bodyBytes), response.StatusCode)
344344
}
345345

346346
bodyBytes, err := ioutil.ReadAll(response.Body)

0 commit comments

Comments
 (0)