class ZaloAPI::Middleware::Request::Retry
Faraday middleware to handle HTTP Status 429 (rate limiting) / 503 (maintenance) @private
Constants
- DEFAULT_RETRY_AFTER
- ERROR_CODES
Public Class Methods
new(app, options = {})
click to toggle source
Calls superclass method
# File lib/zalo_api/middleware/request/retry.rb, line 12 def initialize(app, options = {}) super(app) @logger = options[:logger] end
Public Instance Methods
call(env)
click to toggle source
# File lib/zalo_api/middleware/request/retry.rb, line 17 def call(env) original_env = env.dup response = @app.call(env) if ERROR_CODES.include?(response.env[:status]) seconds_left = (response.env[:response_headers][:retry_after] || DEFAULT_RETRY_AFTER).to_i @logger.warn "You have been rate limited. Retrying in #{seconds_left} seconds..." if @logger seconds_left.times do |i| sleep 1 time_left = seconds_left - i @logger.warn "#{time_left}..." if time_left > 0 && time_left % 5 == 0 && @logger end @logger.warn "" if @logger @app.call(original_env) else response end end