U Hi @s<dZddlZddlmZddlmZGdddZeZdS)zy ElevenLabs Connection Limiter Limits concurrent ElevenLabs WebSocket connections to prevent exceeding workspace limits. N)Optional)LogcszeZdZUdZdZeded<eZ fddZ de e e ddd Ze dd d d Zed ddZed ddZZS)ElevenLabsConnectionLimitera8 Singleton connection limiter for ElevenLabs WebSocket connections. Limits concurrent connections to prevent exceeding workspace subscription limits. Workspace limit: 6 (base) or 14 (with bursting enabled) Agent limit: 14 concurrent calls Recommended limit: 14 (matches agent limit) N _instancecsD|jdkr>t||_d|j_td|j_d|j_i|j_|jS)Nr) rsuper__new__max_connectionsasyncio Semaphore semaphoreactive_connectionsconnection_map)cls __class__K/var/www/html/live_calls/homebook/services/elevenlabs_connection_limiter.pyrs z#ElevenLabsConnectionLimiter.__new__@) session_idtimeoutreturnc sz\tj|j|dIdH}|rX|j4IdH|jd7_d|j|<W5QIdHRXWdStjk rt d|j d|YdSt k r}z t d|d |WYdSd}~XYnXdS) a! Acquire a connection slot for a session. Args: session_id: Unique session identifier timeout: Maximum time to wait for a slot (seconds) Returns: True if slot acquired, False if timeout or limit reached )rNTu,⚠️ ElevenLabs connection limit reached (z(). Timeout waiting for slot for session Fu(❌ Error acquiring connection slot for z: ) r wait_forr acquire_lockr r TimeoutErrorrwarningr Exceptionerror)selfrrZacquirederrrr!s$  z#ElevenLabsConnectionLimiter.acquire)rrc sR||jkrN|j|j4IdH td|jd|_|j|=W5QIdHRXdS)z Release a connection slot for a session. Args: session_id: Unique session identifier Nrr)rr releasermaxr )r rrrrr"Bs   z#ElevenLabsConnectionLimiter.release)rcCs|jS)z)Get current number of active connections.)r r rrrget_active_countPsz,ElevenLabsConnectionLimiter.get_active_countcCs |j|jS)z)Get number of available connection slots.)r r r$rrrget_available_slotsTsz/ElevenLabsConnectionLimiter.get_available_slots)r)__name__ __module__ __qualname____doc__rr__annotations__r Lockrrstrfloatboolrr"intr%r& __classcell__rrrrr s  !r)r*r typingrservices.log_utilsrrelevenlabs_limiterrrrrs   O