-
Notifications
You must be signed in to change notification settings - Fork 731
/
requester.rb
54 lines (44 loc) · 1.69 KB
/
requester.rb
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
# Copyright (C) 2012-2023 Zammad Foundation, https://zammad-foundation.org/
module Sequencer::Unit::Import::Freshdesk::Requester
def request(api_path:, params: nil)
10.times do |iteration|
response = perform_request(
api_path: api_path,
params: params,
)
return response if response.is_a? Net::HTTPOK
handle_error response, iteration
rescue Net::HTTPClientError, OpenSSL::SSL::SSLError => e
handle_exception e, iteration
end
nil
end
def handle_error(response, iteration)
sleep_for = 10
case response
when Net::HTTPTooManyRequests
sleep_for = response.header['retry-after'].to_i + 10
logger.info "Rate limit: #{response.header.to_hash} (429 Too Many Requests). Sleeping #{sleep_for} seconds and retry (##{iteration + 1}/10)."
else
logger.info "Unknown response: #{response.inspect}. Sleeping 10 seconds and retry (##{iteration + 1}/10)."
end
sleep sleep_for
end
def handle_exception(e, iteration)
logger.error e
logger.info "Sleeping 10 seconds after #{e.class.name} and retry (##{iteration + 1}/10)."
sleep 10
end
def perform_request(api_path:, params: nil)
uri = URI("#{Setting.get('import_freshdesk_endpoint')}/#{api_path}")
uri.query = URI.encode_www_form(params) if params.present?
headers = { 'Content-Type' => 'application/json' }
Net::HTTP.start(uri.host, uri.port, use_ssl: true, read_timeout: 600) do |http|
# for those special moments...
# http.set_debug_output($stdout)
request = Net::HTTP::Get.new(uri, headers)
request.basic_auth(Setting.get('import_freshdesk_endpoint_key'), 'X')
return http.request(request)
end
end
end