mirror of
				https://github.com/avatao-content/baseimage-tutorial-framework
				synced 2025-11-04 06:12:54 +00:00 
			
		
		
		
	Refactor RateLimiter to allow proper subclassing
This commit is contained in:
		@@ -1,25 +1,33 @@
 | 
			
		||||
# Copyright (C) 2018 Avatao.com Innovative Learning Kft.
 | 
			
		||||
# All Rights Reserved. See LICENSE file for details.
 | 
			
		||||
 | 
			
		||||
from functools import wraps
 | 
			
		||||
from functools import wraps, partial
 | 
			
		||||
from time import time, sleep
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
class RateLimiter:
 | 
			
		||||
    def __init__(self, rate_per_second):
 | 
			
		||||
    def __init__(self, rate_per_second, action=sleep):
 | 
			
		||||
        self.min_interval = 1 / float(rate_per_second)
 | 
			
		||||
        self.action = action
 | 
			
		||||
        self.fun = None
 | 
			
		||||
        self.last_call = time()
 | 
			
		||||
 | 
			
		||||
    def __call__(self, fun):
 | 
			
		||||
        @wraps(fun)
 | 
			
		||||
        def wrapper(*args, **kwargs):
 | 
			
		||||
            self._limit_rate()
 | 
			
		||||
            fun(*args, **kwargs)
 | 
			
		||||
            self.fun = partial(fun, *args, **kwargs)
 | 
			
		||||
            limit_seconds = self._limit_rate()
 | 
			
		||||
            if limit_seconds:
 | 
			
		||||
                self.action(limit_seconds)
 | 
			
		||||
                return
 | 
			
		||||
            self.fun()
 | 
			
		||||
        return wrapper
 | 
			
		||||
 | 
			
		||||
    def _limit_rate(self):
 | 
			
		||||
        since_last_call = time() - self.last_call
 | 
			
		||||
        to_next_call = self.min_interval - since_last_call
 | 
			
		||||
        seconds_since_last_call = time() - self.last_call
 | 
			
		||||
        seconds_to_next_call = self.min_interval - seconds_since_last_call
 | 
			
		||||
        self.last_call = time()
 | 
			
		||||
        if to_next_call > 0:
 | 
			
		||||
            sleep(to_next_call)
 | 
			
		||||
 | 
			
		||||
        if seconds_to_next_call > 0:
 | 
			
		||||
            return seconds_to_next_call
 | 
			
		||||
        return 0
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user