o 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@seZdZdZddefddZdededee fd d Z dedd fd d Z dedee fddZ defddZ defddZdeeeffddZdddZdedd fddZd 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 Semaphorecall_semaphoreLock session_lockrinfo)selfr r:/var/www/html/live_calls/homebook/services/call_manager.py__init__s   zCallManager.__init__ session_id websocketreturnc szpt|j|jkr#td|jd||jdddIdHWdSt||}|IdHs:td|WdS|j 4IdH||j|<WdIdHn 1IdHsWwYt d|d t|jd |jd |WSt y}z.t |}d |vsd |vrtd|dWYd}~dStd|d|WYd}~dSd}~wt y}ztd|d|WYd}~dSd}~ww)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_sessions8  (&zCallManager.create_call_sessionNc s(d}ztd||j4IdH5||jvr(|j|}td|ntd|d WdIdHWdSWdIdHn 1IdHsNwY|rz|IdHtd|WnPty}z(t|}d|vszd|vrt d |d n t d |d |WYd}~n!d}~wt y}zt d |d |WYd}~nd}~wwtd|dt |jd|j dWdSWdSt y}z7t|}d|vsd|vrt d|dnt d|d |ddl}|WYd}~dSWYd}~dSd}~ww)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_sessionsR  (  ",zCallManager.remove_call_sessioncCs |j|S)zGet an active call session.)r get)rrrrr get_sessions zCallManager.get_sessioncCs t|jS)zGet number of active sessions.)r!r rrrrget_active_sessions_counts z%CallManager.get_active_sessions_countcCs>t|j|jt|j|jd|jt|jt|jdS)z&Get system-wide status for monitoring.d)r r utilization_percentavailable_slots 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 szat|j}td|dg}|jD] \}}||||q|r[tj|ddiIdH}dd|D}t|t|}|rRt d|d t|d n td |d |j WdSt y}zt d ||j WYd}~dSd}~ww)zFCleanup all active sessions (for shutdown) with proper error handling.u🧹 Cleaning up z active sessionsreturn_exceptionsTNcSsg|] }t|tr|qSr) isinstancer()rArrrr sz4CallManager.cleanup_all_sessions..u⚠️ Cleanup completed: z succeeded, z failedu✅ All z! sessions cleaned up successfullyu ❌ Error cleaning up sessions: ) r!r rrrCappend_safe_cleanup_sessionr gatherr"clearr(r%) r session_count cleanup_tasksrr)resultserrors successesr*rrrcleanup_all_sessions s( z CallManager.cleanup_all_sessionsc sz |IdHWdSty5}zt|}d|vsd|vr)td|dnWYd}~dSd}~wtyL}z td|d|d}~ww)z8Safely cleanup a session with event loop error handling.Nrrr-z - allowing garbage collectionu❌ Error cleaning up session r )r0r&r'rr"r(r%)rr)rr*r+rrrrJ+sz!CallManager._safe_cleanup_session)r )rN)__name__ __module__ __qualname____doc__intrr'rrrr,r4r6r8rr?rDrRrJrrrrrs), rr )r )rVr typingrrfastapirservices.log_utilsrservices.call_sessionrconfigrr call_managerrrrrs    -