Commit 1b266f0c authored by Vitaly Lipatov's avatar Vitaly Lipatov

gateway: include autoban schedule in transaction watch

parent 8ad4021d
...@@ -78,7 +78,7 @@ class AutoBanManager: ...@@ -78,7 +78,7 @@ class AutoBanManager:
for _ in range(3): for _ in range(3):
pipeline = self.r.pipeline() pipeline = self.r.pipeline()
try: try:
pipeline.watch(meta_key, self.PERMANENT_KEY) pipeline.watch(meta_key, self.PERMANENT_KEY, self.SCHEDULE_KEY)
now = int(time.time()) now = int(time.time())
existing = pipeline.hgetall(meta_key) existing = pipeline.hgetall(meta_key)
is_permanent = pipeline.sismember(self.PERMANENT_KEY, ip) is_permanent = pipeline.sismember(self.PERMANENT_KEY, ip)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment