@@ -25,7 +25,6 @@ import (
2525 "strconv"
2626 "time"
2727
28- "github.com/deploymenttheory/go-api-http-client/logger"
2928 "go.uber.org/zap"
3029)
3130
@@ -57,7 +56,7 @@ func CalculateBackoff(retry int) time.Duration {
5756
5857// ParseRateLimitHeaders parses common rate limit headers and adjusts behavior accordingly.
5958// It handles both Retry-After (in seconds or HTTP-date format) and X-RateLimit-Reset headers.
60- func ParseRateLimitHeaders (resp * http.Response , log logger. Logger ) time.Duration {
59+ func ParseRateLimitHeaders (resp * http.Response , logger * zap. SugaredLogger ) time.Duration {
6160 // Check for the Retry-After header in seconds
6261 if retryAfter := resp .Header .Get ("Retry-After" ); retryAfter != "" {
6362 if waitSeconds , err := strconv .Atoi (retryAfter ); err == nil {
@@ -66,7 +65,7 @@ func ParseRateLimitHeaders(resp *http.Response, log logger.Logger) time.Duration
6665 // Handle HTTP-date format in Retry-After
6766 return time .Until (retryAfterDate )
6867 } else {
69- log .Debug ("Unable to parse Retry-After header" , zap .String ("value" , retryAfter ), zap .Error (err ))
68+ logger .Debug ("Unable to parse Retry-After header" , zap .String ("value" , retryAfter ), zap .Error (err ))
7069 }
7170 }
7271
@@ -79,7 +78,7 @@ func ParseRateLimitHeaders(resp *http.Response, log logger.Logger) time.Duration
7978 const skewBuffer = 5 * time .Second
8079 return time .Until (resetTime ) + skewBuffer
8180 } else {
82- log .Debug ("Unable to parse X-RateLimit-Reset header" , zap .String ("value" , resetTimeStr ), zap .Error (err ))
81+ logger .Debug ("Unable to parse X-RateLimit-Reset header" , zap .String ("value" , resetTimeStr ), zap .Error (err ))
8382 }
8483 }
8584 }
0 commit comments