class Network
Public Class Methods
new(server_secret, api, backoff_mult = 10)
click to toggle source
Calls superclass method
# File lib/network.rb, line 8 def initialize(server_secret, api, backoff_mult = 10) super() unless api.end_with?('/') api += '/' end @server_secret = server_secret @api = api @last_sync_time = 0 @backoff_multiplier = backoff_mult end
Public Instance Methods
check_gate(user, gate_name)
click to toggle source
# File lib/network.rb, line 40 def check_gate(user, gate_name) begin request_body = JSON.generate({'user' => user&.serialize(false), 'gateName' => gate_name}) response = post_helper('check_gate', request_body) return JSON.parse(response.body) unless response.nil? false rescue return false end end
download_config_specs()
click to toggle source
# File lib/network.rb, line 62 def download_config_specs begin response = post_helper('download_config_specs', JSON.generate({'sinceTime' => @last_sync_time})) return nil unless !response.nil? json_body = JSON.parse(response.body) @last_sync_time = json_body['time'] return json_body rescue return nil end end
get_config(user, dynamic_config_name)
click to toggle source
# File lib/network.rb, line 51 def get_config(user, dynamic_config_name) begin request_body = JSON.generate({'user' => user&.serialize(false), 'configName' => dynamic_config_name}) response = post_helper('get_config', request_body) return JSON.parse(response.body) unless response.nil? nil rescue return nil end end
poll_for_changes(callback)
click to toggle source
# File lib/network.rb, line 74 def poll_for_changes(callback) Thread.new do loop do sleep 10 specs = download_config_specs unless specs.nil? callback.call(specs) end end end end
post_helper(endpoint, body, retries = 0, backoff = 1)
click to toggle source
# File lib/network.rb, line 19 def post_helper(endpoint, body, retries = 0, backoff = 1) http = HTTP.headers( {"STATSIG-API-KEY" => @server_secret, "STATSIG-CLIENT-TIME" => (Time.now.to_f * 1000).to_s, "Content-Type" => "application/json; charset=UTF-8" }).accept(:json) begin res = http.post(@api + endpoint, body: body) rescue ## network error retry return nil unless retries > 0 sleep backoff return post_helper(endpoint, body, retries - 1, backoff * @backoff_multiplier) end return res unless !res.status.success? return nil unless retries > 0 && $retry_codes.include?(res.code) ## status code retry sleep backoff post_helper(endpoint, body, retries - 1, backoff * @backoff_multiplier) end
post_logs(events, statsig_metadata)
click to toggle source
# File lib/network.rb, line 86 def post_logs(events, statsig_metadata) begin json_body = JSON.generate({'events' => events, 'statsigMetadata' => statsig_metadata}) post_helper('log_event', json_body, retries: 5) rescue end end