U ɳ`iX8@shdZddlZddlmZmZddlmZddlmZddl m Z ddl m Z Gdd d Z e d d ZdS) z~ FIXED Call Manager for Handling Multiple Concurrent Calls Manages call sessions with proper concurrency limits and isolation N)DictOptional) WebSocket)Log) CallSession)Configc@seZdZdZdedddZeeee dddZ ed d d d Z eee d d dZ edddZ edddZeeefdddZd dddZed d ddZd S) CallManagerz Manages multiple concurrent call sessions with proper isolation. Each call gets its own completely isolated session. 2max_concurrent_callscCs6||_i|_t||_t|_td|dS)Nz1Call Manager initialized - Max concurrent calls: ) r active_sessionsasyncio SemaphoreZcall_semaphoreLock session_lockrinfo)selfr r:/var/www/html/live_calls/homebook/services/call_manager.py__init__s   zCallManager.__init__) session_id websocketreturnc szt|j|jkrDtd|jd||jdddIdHWdSt||}|IdHsrtd|WdS|j 4IdH||j|<W5QIdHRXt d|d t|jd |jd |WSt k r@}zZt |}d |ksd |krtd|dWY(dStd|d|WYdSW5d}~XYn@t k r~}z td|d|WYdSd}~XYnXdS)z Create a new isolated call session with proper error handling. Returns None if max concurrent calls reached or if creation fails. u"❌ Max concurrent calls reached (z). Rejecting session iz.Service overloaded - too many concurrent calls)codereasonNu!❌ Failed to initialize session u✅ Created call session (Active: /)different loopattached to a different loopu7⚠️ Event loop mismatch during session creation for z - retrying...u(❌ Runtime error creating call session : u ❌ Error creating call session )lenr r rwarningcloser initializeerrorrr RuntimeErrorstr Exception)rrrsessione error_msgrrrcreate_call_sessions. & zCallManager.create_call_sessionN)rrc sd}zttd||j4IdHV||jkrP|j|}td|n(td|dW5QIdHRWdSW5QIdHRX|rxz"|IdHtd|Wntk r}zHt|}d|ksd|krt d |d nt d |d |W5d}~XYn:t k rP}zt d |d |W5d}~XYnXtd|dt |jd|j dWnzt k r}zZt|}d|ksd|krt d|dn&t d|d |ddl}|W5d}~XYnXdS)zBRemove and cleanup a call session with proper event loop handling.Nu'🔄 Attempting to remove call session u!🧹 Calling cleanup for session zSession z( already removed (likely race condition)u#✅ Cleanup successful for session rr.⚠️ Event loop mismatch during cleanup for z& - resources will be garbage collectedu-❌ Runtime error during cleanup for session r u%❌ Error during cleanup for session u🗑️ Removed call session rrru1⚠️ Event loop mismatch when removing session z - session removed from trackingu ❌ Error removing call session r)rrrr popdebugcleanupr&r'r"r%r(r!r traceback print_exc)rrr) cleanup_errorr+r*r1rrrremove_call_sessions:  &(*zCallManager.remove_call_sessioncCs |j|S)zGet an active call session.)r get)rrrrr get_sessionszCallManager.get_session)rcCs t|jS)zGet number of active sessions.)r!r rrrrget_active_sessions_countsz%CallManager.get_active_sessions_countcCs>t|j|jt|j|jd|jt|jt|jdS)z&Get system-wide status for monitoring.d)r r Zutilization_percentZavailable_slotsZ session_ids)r!r r listkeysr7rrrget_system_statuss  zCallManager.get_system_statuscCsdd|jDS)z"Get status of all active sessions.cSsi|]\}}||qSr) get_status).0rr)rrr sz4CallManager.get_session_statuses..)r itemsr7rrrget_session_statusessz CallManager.get_session_statusesc szt|j}td|dg}|jD]\}}||||q,|rtj|ddiIdH}dd|D}t|t|}|rt d|d t|d ntd |d |j Wn<t k r}zt d ||j W5d}~XYnXdS)zFCleanup all active sessions (for shutdown) with proper error handling.u🧹 Cleaning up z active sessionsreturn_exceptionsTNcSsg|]}t|tr|qSr) isinstancer()r>rrrr s z4CallManager.cleanup_all_sessions..u⚠️ Cleanup completed: z succeeded, z failedu✅ All z! sessions cleaned up successfullyu ❌ Error cleaning up sessions: ) r!r rrr@append_safe_cleanup_sessionr gatherr"clearr(r%) rZ session_countZ cleanup_tasksrr)resultserrorsZ successesr*rrrcleanup_all_sessions s" z CallManager.cleanup_all_sessionsc sz|IdHWntk rb}z2t|}d|kss    -