o i+@sUdZddlZddlZddlmZddlmZmZmZm Z ddl m Z ddl m Z e eZGdddZdae eed <d efd d Zdd dZdS)a Rate limiting for Veena3 TTS API. Implements sliding window rate limiting with in-memory storage. Supports optional Redis backend for distributed rate limiting. Usage: from veena3modal.api.rate_limiter import get_rate_limiter limiter = get_rate_limiter() allowed, remaining, reset_after = limiter.check(api_key_hash) if not allowed: return 429 response with Retry-After header N) defaultdict)DictListTupleOptional)Lock) get_loggerc @seZdZdZ   ddededefddZd ed eeee ffd d Z d e d dfddZ dddZ dedede d e eeffddZd ed dfddZdS) RateLimitera? In-memory sliding window rate limiter. Thread-safe implementation with automatic cleanup of old entries. Attributes: requests_per_minute: Maximum requests allowed per window window_seconds: Window size in seconds (default: 60) enabled: Whether rate limiting is active <Trequests_per_minutewindow_secondsenabledcCs8||_||_||_tt|_t|_t|_ d|_ dS)z Initialize rate limiter. Args: requests_per_minute: Max requests per window window_seconds: Window size in seconds enabled: If False, all requests are allowed r N) r r r rlist _requestsr_locktime _last_cleanup_cleanup_interval)selfr r r r7/home/ubuntu/veenaModal/veena3modal/api/rate_limiter.py__init__'s   zRateLimiter.__init__keyreturncs|js d|jdfSt}||j|jkfdd|j|D|j|<t|j|}||jkrU|j|r=t|j|n|}||j|}ddtd|fWdS|j| ||j|d}||j |j krt| ||_ d|dfWdS1swYdS) a Check if request is allowed under rate limit. Args: key: Unique identifier (API key hash, user ID, IP) Returns: Tuple of (allowed, remaining, reset_after_seconds) - allowed: True if request should proceed - remaining: Number of requests remaining in window - reset_after: Seconds until window resets (only meaningful if blocked) Tgcg|]}|kr|qSrr.0ts window_startrr Ts z%RateLimiter.check..FrN) r r rr rrlenminmaxappendrr _do_cleanup)rrnow current_countoldest_in_window reset_after remainingrrrcheck?s*      $zRateLimiter.checkrNcsZg}|jD]\}}fdd|D}|s||q||j|<q|D]}|j|=q$dS)z%Remove entries older than the window.crrrrrrrr qsz+RateLimiter._do_cleanup..N)ritemsr%)rrkeys_to_remover timestampsvalidrrrr&ls   zRateLimiter._do_cleanupcCsHt}||j}|j||WddS1swYdS)zZ Manual cleanup trigger for testing. Removes all expired entries. N)rr rr&)rr'rrrrcleanupzs   "zRateLimiter.cleanupallowedr+r*cCs6t|jttd|d}|stt|d|d<|S)a' Get rate limit headers for HTTP response. Args: allowed: Whether request was allowed remaining: Remaining requests in window reset_after: Seconds until reset Returns: Dict of header name -> value r)zX-RateLimit-LimitzX-RateLimit-Remainingr!z Retry-After)strr r$int)rr2r+r*headersrrr get_headerss  zRateLimiter.get_headerscCsN|j||jvr|j|=WddSWddS1s wYdS)z0Reset rate limit for a specific key (admin use).N)rr)rrrrrresets   "zRateLimiter.reset)r r TrN)__name__ __module__ __qualname____doc__r4boolrr3rfloatr,r&r1rr6r7rrrrr s2  -    r _rate_limiterrcCsTtdur(ttjdd}tjdddk}t||datjd||ddtS) a Get the singleton rate limiter instance. Configuration via environment variables: - RATE_LIMIT_REQUESTS_PER_MINUTE: Max requests (default: 60) - RATE_LIMIT_ENABLED: "true"/"false" (default: true) Returns: Configured RateLimiter instance NRATE_LIMIT_REQUESTS_PER_MINUTE60RATE_LIMIT_ENABLEDtruer r rate_limiter_initialized)extra) r?r4osenvirongetlowerr loggerinforDrrrget_rate_limiters rMcCsdadS)z"Reset the singleton (for testing).N)r?rrrrreset_rate_limitersrNr8)r<rrG collectionsrtypingrrrr threadingrveena3modal.shared.loggingrr9rKr r?__annotations__rMrNrrrrs   !