Class: Rack::Attack::StoreProxy::RedisCacheStoreProxy

Inherits:
BaseProxy
  • Object
show all
Defined in:
lib/rack/attack/store_proxy/redis_cache_store_proxy.rb

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from BaseProxy

inherited, lookup, proxies

Class Method Details

.handle?(store) ⇒ Boolean

Returns:

  • (Boolean) 


9
10
11
 
# File 'lib/rack/attack/store_proxy/redis_cache_store_proxy.rb', line 9

def self.handle?(store)
  store.class.name == "ActiveSupport::Cache::RedisCacheStore"
end

Instance Method Details

#delete_matched(matcher, options = nil) ⇒ Object 



37
38
39
 
# File 'lib/rack/attack/store_proxy/redis_cache_store_proxy.rb', line 37

def delete_matched(matcher, options = nil)
  super(matcher.source, options)
end

#increment(name, amount = 1, **options) ⇒ Object 



14
15
16
17
18
19
20
21
22
23
24
25
26
 
# File 'lib/rack/attack/store_proxy/redis_cache_store_proxy.rb', line 14

def increment(name, amount = 1, **options)
  # RedisCacheStore#increment ignores options[:expires_in] in versions prior to 6.
  #
  # So in order to workaround this we use RedisCacheStore#write (which sets expiration) to initialize
  # the counter. After that we continue using the original RedisCacheStore#increment.
  if options[:expires_in] && !read(name)
    write(name, amount, options)

    amount
  else
    super
  end
end

#read(name, options = {}) ⇒ Object 



29
30
31
 
# File 'lib/rack/attack/store_proxy/redis_cache_store_proxy.rb', line 29

def read(name, options = {})
  super(name, options.merge!(raw: true))
end

#write(name, value, options = {}) ⇒ Object 



33
34
35
 
# File 'lib/rack/attack/store_proxy/redis_cache_store_proxy.rb', line 33

def write(name, value, options = {})
  super(name, value, options.merge!(raw: true))
end