o y i2{@sxddlZddlZddlmZmZmZddlmZddlm Z GdddZ GdddZ Gd d d Z Gd d d Z dS) N)OptionalDictAny)Config)Logc@seZdZdZededefddZedeee fdefddZ edeee fdefd d Z edeee fde efd d Z edeee fde efd dZdS)OpenAIEventHandleraU Interprets and processes events received from the OpenAI Realtime API. - Determines which events should be logged. - Identifies and extracts audio deltas, speech start events, and item IDs from event payloads. Used by higher-level services to make sense of incoming OpenAI events and route them appropriately. event_typereturncCs |tjvS)z(Check if an event type should be logged.)rZLOG_EVENT_TYPES)rr services/openai_service.pyshould_log_event z#OpenAIEventHandler.should_log_eventeventcCs|ddko d|vS)z-Check if event is an audio delta from OpenAI.typezresponse.output_audio.deltadeltagetrr r r is_audio_delta_eventsz'OpenAIEventHandler.is_audio_delta_eventcCs|ddkS)z1Check if event indicates user speech has started.rz!input_audio_buffer.speech_startedrrr r r is_speech_started_eventsz*OpenAIEventHandler.is_speech_started_eventcCst|r |dSdS)z&Extract audio delta from OpenAI event.rN)rrrrr r r extract_audio_delta"s  z&OpenAIEventHandler.extract_audio_deltacCs |dS)z"Extract item ID from OpenAI event.item_idrrr r r extract_item_id)r z"OpenAIEventHandler.extract_item_idN)__name__ __module__ __qualname____doc__ staticmethodstrboolr rrrrrrrr r r r rs  $rc@sveZdZdZeddededededeeeff dd Zedd edeeeffd d Z edeeeffd dZ dS)OpenAISessionManageraY Configures and initializes OpenAI Realtime API sessions. - Generates session update messages specifying model, audio formats, and system instructions. - Creates the initial conversation item (for AI-first greetings) and triggers responses. Ensures consistent and correct session setup for all OpenAI interactions. N business_idknowledge_contextcustom_system_messageconversation_contextr cCs|r|}n tjjtjtjd}|r|r|d|d|d7}|r(|d|d7}ddtjd gd d id d id dd d iid|ddddddddigdddddddddddddddgddgd d!}|S)"a Create a session update message for OpenAI Realtime API. Args: business_id: Business ID for context knowledge_context: Additional context from knowledge base custom_system_message: Custom system message for bot configuration conversation_context: Conversation context to prevent repetition Returns: Dictionary containing session configuration ) COMPANY_NAMEAGENT_PHONE_NUMBERz\ IMPORTANT: Use the following business-specific information when answering questions about z: z When customers ask about services, features, or company information, prioritize this context over general knowledge. Be specific and detailed when discussing the company's offerings.z CONVERSATION CONTEXT: zb Use this context to avoid repeating the same responses and to provide varied, helpful responses.zsession.updateZrealtimeaudiorz audio/pcmuZ server_vad)formatZturn_detectionr()inputoutputfunctionend_callz]Politely end the phone call when the caller says goodbye or requests to end the conversation.objectreasonstringz-Brief reason for ending, e.g., user said bye.)r description)rZ propertiesrequired)rnamer0Z parameterstransfer_to_agentz[Transfer the call to a human agent when the caller requests to speak with a human or agent.z/Reason for transfer, e.g., user requested agentz+Phone number to transfer to in E.164 format)r. agent_phoner4)rZmodelZoutput_modalitiesr' instructionsZtools)rsession)rZSYSTEM_MESSAGEr(r%r&Z OPENAI_MODEL)r!r"r#r$Zsystem_messager6r r r create_session_update9sX   -z*OpenAISessionManager.create_session_update company_namecCs8|r |dkr d|d}nd}dddd|d gd d S) a Create an initial conversation item for AI-first interactions. Args: company_name: Dynamic company name for personalized greeting Returns: Dictionary containing initial conversation setup zMcube Telecom pvt Limitedzdedededdfd d Zd?d eddfd d Zdeee fddfddZ deee fde fddZ deee fde eee ffddZdeee fde fddZdeee fde fddZdeee fde fddZdeddfddZdeddfd d!Zd"eddfd#d$Zdeee fde fd%d&Zd@d'd(Zde fd)d*Zd+e eddfd,d-Zd@d.d/Zd@d0d1Zdeee fde eee ffd2d3Zdeee fde fd4d5Zd6ed7ed8eddfd9d:Zd8e ed;ed7e ede fd✅ Database transfer status updated successfully for session u📊 Transfer number: u=⚠️ Failed to update database transfer status for session z)Database error updating transfer status: zFDatabase update skipped - database disabled or session not initializedz)Error updating database transfer status: )rrrrrrcrrrrrZDATABASE_ENABLEDZ db_session_idr!Z_db_update_lockZdatabase_serviceZupdate_transfer_statusrfrr}rrr) r_rcrrrrr6rZdb_errorrrr r r rsJ  8 z.OpenAIService._update_database_transfer_statusr>c sfz|dd|idIdHWdSty2}ztd|d|_d|_WYd}~dSd}~ww)zSend a final assistant response (audio) with the provided text before hangup. Uses response.create with inline instructions so the model speaks immediately without tool calls. rEr5)rrnNz"Failed to queue goodbye response: TF)rbr}rrrZr[)r_rcr>rr r r rsz$OpenAIService._send_goodbye_responsecCs|jr|jsdS|d}|dkrdS|dkr{|jsZ|dp i}|dp'gD]/}t|trW|ddkrW|d d krW|d pCgD]}t|trV|dd krVdSqDq(dS|dp`i}|dpggD]}t|trz|d |jkrzdSqhdS)zOReturn True if we should finalize hangup after the goodbye audio has completed.Frzresponse.output_audio.doneTrmrnr*r:r@Z assistantrAZ output_audiorv)rZr[rr\rprq)r_rrrrsrCcr r r should_finalize_on_event+s*  &z&OpenAIService.should_finalize_on_eventc s$d|_d|_d|_|ztdttdddt ttddIdHWn t y2Ynwt r{z)ddl m }|tjtj}t|jd d}|r_td d |i||jd d Wnt yz}ztd|WYd}~nd}~wwz |jddIdHWdSt yYdSw)zWAfter goodbye audio is finished, clear/close and optionally complete the call via REST.FNzGrace sleep before hangup: ZEND_CALL_GRACE_SECONDSg?sr)Clientcall_sidzCompleting call via Twilio RESTZcallSidZ completed)statusz$Optional Twilio REST hangup failed: zassistant completed)r.)rZr[r\_cancel_goodbye_watchdogrrfgetattrrasynciosleepr}Zhas_twilio_credentialsZ twilio.restrZTWILIO_ACCOUNT_SIDZTWILIO_AUTH_TOKENrrZcallsupdaterZclose_twilio_connection)r_rcrZclientrrr r r finalize_goodbyeEs:   zOpenAIService.finalize_goodbyecCs|jS)zFReturn True if a farewell has been queued and we await its completion.)rZr^r r r is_goodbye_pendingasz OpenAIService.is_goodbye_pendingrcCs,|jrd|_|r|js||_|dSdS)zVMark that we've begun receiving audio for the goodbye message and capture its item_id.TN)rZr[r\r)r_rr r r mark_goodbye_audio_heardes   z&OpenAIService.mark_goodbye_audio_heardcsTzttddfdd}t|_WdSty)d_YdSw)zLStart a watchdog that finalizes the call if no goodbye audio starts in time.ZEND_CALL_WATCHDOG_SECONDScs`z$tIdHjr js#tdIdHWdSWdSWdSty/YdSw)Nz3Goodbye audio not detected in time; finalizing call)rrrZr[rrfrr}r rcr_Ztimeoutr r _watchts   z5OpenAIService._start_goodbye_watchdog.._watchN)rrrrZ create_taskr]r})r_rcrr rr rns   z%OpenAIService._start_goodbye_watchdogcCs$|jr |js |jd|_dSrG)r]ZdoneZcancelr^r r r rs  z&OpenAIService._cancel_goodbye_watchdogcCs*|j|sdS|j||j|dS)z Extract relevant data from OpenAI audio response. Args: event: OpenAI event data Returns: Dictionary with audio delta and item ID, or None N)rr)rXrrrrir r r extract_audio_response_datas   z)OpenAIService.extract_audio_response_datacCs |j|S)z Check if event indicates user speech started (interruption). Args: event: OpenAI event data Returns: True if speech started )rXrrir r r is_speech_starteds zOpenAIService.is_speech_startedrQrMrKcsj|j||}tjr$td|d|d|dtd|d|d|j||}||IdHdS)a] Handle conversation interruption by truncating the current response. Args: connection_manager: WebSocket connection manager current_timestamp: Current media timestamp response_start_timestamp: When the response started last_assistant_item: ID of the item to truncate z)Calculating elapsed time for truncation: z - z = mszTruncating item with ID: z, Truncated at: N)rWrRrZSHOW_TIMING_MATHprintrJrb)r_rcrQrMrKZ elapsed_timeZtruncate_eventr r r handle_interruptionsz!OpenAIService.handle_interruptionrLcCs|j|||S)rN)rWrP)r_rKrLrMr r r should_process_interruptionsz)OpenAIService.should_process_interruption)NNNrG)r N)!rrrrr`rrdrgrrrjrrtrrrrrrrrrrrrrrrrrSrrTrr r r r rUsP   &&*'+  &  rU)rartypingrrrZconfigrZservices.log_utilsrrr rHrUr r r r s  'E