fix: retry trakt requests when needed

pkg/client/trakt.go

@@ -306,6 +306,13 @@ func (tc *TraktClient) doRequest(requestFields requestFields) (*http.Response, e
 			tc.logger.Warn(message)
 			time.Sleep(duration)
 			continue
+		case http.StatusRequestTimeout, http.StatusBadGateway, http.StatusServiceUnavailable, http.StatusGatewayTimeout:
+			response.Body.Close()
+			duration := time.Second
+			message := fmt.Sprintf("unexpected status code %d, waiting for %s then retrying http request %s %s", response.StatusCode, duration, response.Request.Method, response.Request.URL)
+			tc.logger.Warn(message)
+			time.Sleep(duration)
+			continue
 		default:
 			response.Body.Close()
 			return nil, &ApiError{

pkg/client/trakt_test.go

@@ -177,6 +177,25 @@ func TestTraktClient_doRequest(t *testing.T) {
 				assertions.Contains(err.Error(), "reached max retry attempts")
 			},
 		},
+		{
+			name: "handle retryable status",
+			args: args{
+				requestFields: dummyRequestFields,
+			},
+			requirements: func(requirements *require.Assertions) *httptest.Server {
+				handler := func(w http.ResponseWriter, r *http.Request) {
+					requirements.Equal(dummyRequestFields.Method, r.Method)
+					requirements.Equal(dummyRequestFields.Endpoint, r.URL.Path)
+					w.WriteHeader(http.StatusBadGateway)
+				}
+				return httptest.NewServer(http.HandlerFunc(handler))
+			},
+			assertions: func(assertions *assert.Assertions, res *http.Response, err error) {
+				assertions.Nil(res)
+				assertions.Error(err)
+				assertions.Contains(err.Error(), "reached max retry attempts")
+			},
+		},
 		{
 			name: "handle unexpected status code",
 			args: args{