rclone/backend/putio/error.go

63 lines
1.7 KiB
Go
Raw Normal View History

2019-10-12 12:29:02 +00:00
package putio
import (
"context"
2019-10-12 12:29:02 +00:00
"fmt"
"net/http"
"strconv"
"time"
2019-10-12 12:29:02 +00:00
"github.com/putdotio/go-putio/putio"
"github.com/rclone/rclone/fs/fserrors"
"github.com/rclone/rclone/lib/pacer"
2019-10-12 12:29:02 +00:00
)
func checkStatusCode(resp *http.Response, expected int) error {
if resp.StatusCode != expected {
return &statusCodeError{response: resp}
}
return nil
}
type statusCodeError struct {
response *http.Response
}
func (e *statusCodeError) Error() string {
return fmt.Sprintf("unexpected status code (%d) response while doing %s to %s", e.response.StatusCode, e.response.Request.Method, e.response.Request.URL.String())
}
// This method is called from fserrors.ShouldRetry() to determine if an error should be retried.
// Some errors (e.g. 429 Too Many Requests) are handled before this step, so they are not included here.
2019-10-12 12:29:02 +00:00
func (e *statusCodeError) Temporary() bool {
return e.response.StatusCode >= 500
2019-10-12 12:29:02 +00:00
}
// shouldRetry returns a boolean as to whether this err deserves to be
// retried. It returns the err as a convenience
func shouldRetry(ctx context.Context, err error) (bool, error) {
if fserrors.ContextError(ctx, &err) {
return false, err
}
2019-10-12 12:29:02 +00:00
if err == nil {
return false, nil
}
if perr, ok := err.(*putio.ErrorResponse); ok {
err = &statusCodeError{response: perr.Response}
}
if scerr, ok := err.(*statusCodeError); ok && scerr.response.StatusCode == 429 {
delay := defaultRateLimitSleep
header := scerr.response.Header.Get("x-ratelimit-reset")
if header != "" {
if resetTime, cerr := strconv.ParseInt(header, 10, 64); cerr == nil {
delay = time.Until(time.Unix(resetTime+1, 0))
}
}
return true, pacer.RetryAfterError(scerr, delay)
}
2019-10-12 12:29:02 +00:00
if fserrors.ShouldRetry(err) {
return true, err
}
return false, err
}