o kj. @sUddlmZmZddlmZmZddlmZmZmZiZ ee ee effe d<hdZ de de fdd Z dde d e d e d Bdd fd dZde dedd fddZd e dedd fddZdde de dd fddZd S))datetimetimezone)DictAny)active_sessionsbroadcast_to_agentsnotify_visitor_socket active_calls>IDLEENDEDRINGINGACCEPTEDREJECTED CONNECTED CONNECTINGCALL_REQUESTED session_idreturncCst|}|r |ddSdS)zGReturns the current video call state for a session, defaulting to IDLE.stater )r get)rcallr=/web/html/dev/chatbot/backend/app/services/video_signaling.pyget_call_states rNragent_idcCsJ|tvrdSttj}|dvrt|ddS||||dt|<dS)z/Updates the in-memory video call state machine.N)r r r) sessionIdragentId updatedAt) VALID_STATESrnowrutc isoformatr pop)rrrnow_isorrrset_call_statesr$payloadc s*|d}|s dStd|d|td|t|}|r'|dnd}|r0|dnd}|r:|dks:|skd d lm}d d lm}|}|durk|||IdH} | rk| d}| d}|rk||d<||d<td ||dkrtd |d|dt|d|ddIdHdS|std |dt|d|ddIdHdSt|} |dvr| dvrt|d|ddIdHdSt |d|d||r|dnd|r|dnd|dp|ddd } td!|td"|td#|t | |gd$IdHdS|d%vr5t |d&|d'||d(p|dd)} td*|t | |gd$IdHdS|dkrUt |d+d||d,d-d} t | |gd$IdHdS|d.krwd.||d/d0d1} td2|t | |gd$IdHdS|d3krt |d4d3|dd5} t | |gd$IdHdSdS)6z Handles WebRTC signaling messages dispatched from a visitor WebSocket. Validates session state and forwards payloads to the assigned agent. typeNz1[VIDEO DEBUG] visitor video event received: type=z , sessionId=z[VIDEO DEBUG] sessionId=statusassignedAgentIdIN_CHATr get_databaseget_session_by_idz[VIDEO DEBUG] assignedAgentId=z [VIDEO DEBUG] Rejected call for z : status is z (not IN_CHAT)video_call_rejectedz3Video calling requires an active chat with an agentr&rreasonz: no assigned agentz!No agent assigned to this sessionvideo_call_requested webrtc_offer)rr r rrz#A video call is already in progressrr2siteIduseroffersdpvisitor)r&rr4r6r7senderz-[VIDEO] visitor request received for session z[VIDEO] assigned agent = z$[VIDEO] forwarding request to agent target_agent_idsvideo_call_accepted webrtc_answerr r?answerr&rr@z#[VIDEO] forwarding answer to agent rr0zVisitor declined the video callwebrtc_ice_candidate candidateagentr&rrCtargetz*[VIDEO] forwarding ICE candidate to agent video_call_endedr r&rendedBy) rprintr app.databaser+#app.repositories.session_repositoryr-rrr$r) rr%msg_typesession status_valassigned_agent_idr+r-db db_session current_stateforward_payloadrrrhandle_visitor_signaling-s                rUc s,|d}|d}tdtd|td|td||r(|s*dSt|}|r6|dnd}|sbd d lm}d d lm}|}|durb|||IdH} | rb| d}|rb||d<td |d |d|rq|dnd|r||krtd|d|ddS|dvrt|d|d||dp|ddd} t|| IdHdS|dvrt|d|d||dp|dd} t|| IdHdS|d krt|d!d ||d"d#d$} t|| IdHdS|d%krd%||d&d'd(} t|| IdHdS|d)krt|d*d)|dd+} t|| IdHdS|d,vr|d-p-|d.} | rd d/l m } d d0l m } d d1l m}d d lm}|}|rU|d2d3nd3}| |||IdH}|d4}| |||d| |d5IdH}t|d6||d7| d8IdH|d6||||d7| d9IdHdSdSdS):z Handles WebRTC signaling messages dispatched from an agent WebSocket. Validates agent assignment and forwards payloads to the visitor WebSocket. r&rz,[VIDEO][TRACE][BACKEND] received agent eventz[VIDEO][TRACE][BACKEND] type = z$[VIDEO][TRACE][BACKEND] sessionId = z"[VIDEO][TRACE][BACKEND] agentId = Nr(rr*r,z/[VIDEO][TRACE][BACKEND] session doc: sessionId=z, assignedAgentId=z , status=r'nonez8[VIDEO][TRACE][BACKEND] Security check failed: assigned=z , sender=z - droppingr1rr2r7r8rD)r&rr7r:r=r r?r@rAr.rr0zAgent declined the video callr/rBrCr9rErGr rH) agent_messagemessage chat_messagerXcontent)get_or_create_conversation)create_message)rr4r5conversationId)conversation_idrrolerZrrW messageId)r&rr`rX)r&rr4r(r`rX)rrJrrKr+rLr-r$r(app.repositories.conversation_repositoryr[#app.repositories.message_repositoryr\app.services.presencer)rr%rMrrNrPr+r-rQrRrTrZr[r\rsite_id conversationr^msg_docrrrhandle_agent_signalings      (              rg chat_endedr0csv|tvr9t|d}|r|dnd}d||d}t||IdH|r0t||gdIdHdSt|IdHdSdS)zV Cleans up any active video call for a session when chat ends or disconnects. NrrGr/r;)r r"rrr)rr0 call_infor end_eventrrrterminate_video_calls rk)N)rh)rrtypingrrrcrrrr str__annotations__rrr$dictrUrgrkrrrrs  rr