Class: Lita::Timing::RateLimit

Inherits:
Object
  • Object
show all
Defined in:
lib/lita/timing/rate_limit.rb

Instance Method Summary collapse

Constructor Details

#initialize(name, redis) ⇒ RateLimit

Returns a new instance of RateLimit.



4
5
6
7
 
# 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

Instance Method Details

#last_time ⇒ Object 



18
19
20
21
 
# 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, &block) ⇒ Object 



9
10
11
12
13
14
15
16
 
# 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