mirror of
https://github.com/samsonjs/rack-attack.git
synced 2026-04-27 15:07:41 +00:00
Merge pull request #421 from cristiangreco/cristian/redis-cache-store-failsafe
Failsafe on Redis error replies in RedisCacheStoreProxy.
This commit is contained in:
commit
dc305e0782
1 changed files with 22 additions and 6 deletions
|
|
@ -15,17 +15,33 @@ module Rack
|
||||||
#
|
#
|
||||||
# So in order to workaround this we use RedisCacheStore#write (which sets expiration) to initialize
|
# 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.
|
# the counter. After that we continue using the original RedisCacheStore#increment.
|
||||||
if options[:expires_in] && !read(name)
|
rescuing do
|
||||||
write(name, amount, options)
|
if options[:expires_in] && !read(name)
|
||||||
|
write(name, amount, options)
|
||||||
|
|
||||||
amount
|
amount
|
||||||
else
|
else
|
||||||
super
|
super
|
||||||
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
def read(*_args)
|
||||||
|
rescuing { super }
|
||||||
|
end
|
||||||
|
|
||||||
def write(name, value, options = {})
|
def write(name, value, options = {})
|
||||||
super(name, value, options.merge!(raw: true))
|
rescuing do
|
||||||
|
super(name, value, options.merge!(raw: true))
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
|
def rescuing
|
||||||
|
yield
|
||||||
|
rescue Redis::BaseError
|
||||||
|
nil
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue