def __init__(self):
     super(MessageSenderWorker, self).__init__()
     self.redis_client = get_redis_client()
     self.handler = BaseHandler()
     self.handler.load_middleware()

from __future__ import absolute_import

from django.conf import settings
from zerver.lib.redis_utils import get_redis_client

import redis
import time
import logging

from itertools import izip

# Implement a rate-limiting scheme inspired by the one described here, but heavily modified
# http://blog.domaintools.com/2013/04/rate-limiting-with-redis/

client = get_redis_client()
rules = settings.RATE_LIMITING_RULES
def _rules_for_user(user):
    if user.rate_limits != "":
        return [[int(l) for l in limit.split(':')] for limit in user.rate_limits.split(',')]
    return rules

def redis_key(user, domain):
    """Return the redis keys for this user"""
    return ["ratelimit:%s:%s:%s:%s" % (type(user), user.id, domain, keytype) for keytype in ['list', 'zset', 'block']]

def max_api_calls(user):
    "Returns the API rate limit for the highest limit"
    return _rules_for_user(user)[-1][1]

def max_api_window(user):
    "Returns the API time window for the highest limit"

 def __init__(self) -> None:
     super().__init__()
     self.redis_client = get_redis_client()
     self.handler = BaseHandler()
     self.handler.load_middleware()