class Lita::Timing::RateLimit

Public Class Methods

new(name, redis) click to toggle source
# File lib/lita/timing/rate_limit.rb, line 4
def initialize(name, redis)
  @name, @redis = name, redis
  @mutex = Timing::Mutex.new("#{name}-lock", redis)
end

Public Instance Methods

last_time() click to toggle source
# File lib/lita/timing/rate_limit.rb, line 18
def last_time
  value = @redis.get(@name)
  value ? Time.at(value.to_i).utc : nil
end
once_every(seconds) { || ... } click to toggle source
# File lib/lita/timing/rate_limit.rb, line 9
def once_every(seconds, &block)
  @mutex.syncronise do
    if last_time.nil? || last_time + seconds < Time.now
      yield
      @redis.set(@name, Time.now.to_i, ex: seconds * 2)
    end
  end
end