class RProxy::CheckSnapshotService
Public Class Methods
new(redis, config)
click to toggle source
# File lib/r_proxy/check_snapshot_service.rb, line 4 def initialize(redis, config) @redis = redis @snapshot_expire_in = 15 * 60 @usage_threshold = config.usage_threshold @cb_url = config.callback_url @logger = config.logger end
Public Instance Methods
call(user, pass, result)
click to toggle source
# File lib/r_proxy/check_snapshot_service.rb, line 12 def call(user, pass, result) return if user.nil? || pass.nil? || result.nil? s_key = "proxy:#{user}-#{pass}:snapshot" snapshot_value = @redis.get(s_key) if snapshot_value.nil? || snapshot_value.empty? @redis.setex(s_key, @snapshot_expire_in, result) else tmp = snapshot_value.to_i - result.to_i if tmp >= @usage_threshold begin connection = RProxy::CallbackService.call(@cb_url, user, pass, tmp) connection.assign_logger(@logger) @redis.setex(s_key, @snapshot_expire_in, result) rescue => e @logger.error("callback service: @id:#{s_key}, #{e.message}") if @logger end end end end