o i @s<dZddlZddlmZddlmZGdddZeZdS)zy ElevenLabs Connection Limiter Limits concurrent ElevenLabs WebSocket connections to prevent exceeding workspace limits. N)Optional)LogcseZdZUdZdZeded<eZ fddZ dde de d e fd d Zde d dfd d Zd efddZd efddZZS)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|jdurt||_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}|r<|j4IdH|jd7_d|j|<WdIdHWdS1IdHs7wYWdStjyUt d|j d|YdSt yr}zt d|d |WYd}~dSd}~ww) 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)selfrracquirederrrr!s4    z#ElevenLabsConnectionLimiter.acquirec st||jvr8|j|j4IdHtd|jd|_|j|=WdIdHdS1IdHs1wYdSdS)z Release a connection slot for a session. Args: session_id: Unique session identifier Nrr)rr releasermaxr )r rrrrr#Bs   .z#ElevenLabsConnectionLimiter.releasecCs|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_slotsTs z/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