a %ik @sdZddlmZddlmZmZddlmZddlmZGdddZeej dd Z eej d d Z e ed d d Ze ed ddZdS)z\ Rate limiting for expensive operations. Uses token bucket algorithm to prevent API abuse. ) defaultdict)datetime timedelta)Dict)configc@sNeZdZdZeedddZeedddZeeddd Z ed d d Z d S) RateLimiterz Token bucket rate limiter. Usage: limiter = RateLimiter(max_requests=60, window_seconds=3600) if limiter.is_allowed('user_123'): # Allow request else: # Reject (rate limited)  max_requestswindow_secondscCs ||_t|d|_tt|_dS)z Initialize rate limiter. Args: max_requests: Maximum requests allowed in window window_seconds: Time window in seconds )secondsN)r rwindowrlistrequests)selfr r r-/var/www/lichun.app/lichun/ws/rate_limiter.py__init__s zRateLimiter.__init__) identifierreturncsjt}||jfdd|j|D|j|<t|j||jkrVtd|dS|j||dS)z Check if request is allowed. Args: identifier: User ID or other identifier Returns: True if allowed, False if rate limited csg|]}|kr|qSrr.0Zreq_timecutoffrr 3sz*RateLimiter.is_allowed..zRate limit exceeded for FT)rnowr rlenr printappendrrrrrr is_allowed%s    zRateLimiter.is_allowedcsJt}||jfdd|j|D|j|<td|jt|j|S)z Get remaining requests in current window. Args: identifier: User ID or other identifier Returns: Number of requests remaining csg|]}|kr|qSrrrrrrrOsz-RateLimiter.get_remaining..r)rrr rmaxr rrrrr get_remainingAs    zRateLimiter.get_remaining)rcCs||jvr|j|=dS)zReset rate limit for identifierN)r)rrrrrresetVs zRateLimiter.resetN) __name__ __module__ __qualname____doc__intrstrboolrr!r"rrrrr s   rir<)user_idrcCs0t|s,t|}td|d|dSdS)z Check if user can make OpenAI request. Args: user_id: User ID Returns: True if allowed, False if rate limited zOpenAI rate limit exceeded for z . Remaining: FT)openai_limiterrr!r)r+ remainingrrrcheck_openai_rate_limiths  r.cCs t|std|dSdS)z Check if user can send WebSocket message. Args: user_id: User ID Returns: True if allowed, False if rate limited z"WebSocket rate limit exceeded for FT)websocket_limiterrr)r+rrrcheck_websocket_rate_limitys r0N)r& collectionsrrrtypingrrrOPENAI_MAX_REQUESTS_PER_HOURr,!WEBSOCKET_MAX_MESSAGES_PER_MINUTEr/r(r)r.r0rrrrs   P