o y i>+@sndZddlZddlZddlZddlmZddlmZmZmZm Z ddl m Z e e ZGdddZeZdS)zk Conversation Summary Service for Voice Bot Handles conversation summarization and sending to external API N)datetime)DictListOptionalAny)Configc@seZdZdZddZdeeefdefddZde edefd d Z d ed edeeefde fd dZ deeeffddZ dS)ConversationSummaryServicez9Manages conversation summarization and API communication.cCsBtj|_tj|_tj|_|jrtd|jdStddS)Nz4Conversation Summary Service initialized - API URL: z%Conversation Summary Service disabled) rZSUMMARY_API_ENABLEDenabledZSUMMARY_API_URLapi_urlZSUMMARY_API_TIMEOUTtimeoutloggerinfo)selfr(services/conversation_summary_service.py__init__s z#ConversationSummaryService.__init__ session_datareturnc CszQ|dd}|dd}|dd}|dd}|dg}|dg}|d t}t|trGz t|d d }Wnt}Y|d } d d|d|d|d| d|ddtd ddg } |st|r%| dg} |D].} t| t r| d| dt| } | dd}| d| |dq}| dt| ddq}|D].} t| t r| d| dt| } | dd}| d| |dq| dt| ddqz | j ddd WnYt | d!D]2\}} | d"dkrd#nd$}t | dd%kr| dd&d%d'n| d} | |d(|d)| qn| d*| dd+d,||d-d.|dd/t |t |dd0d1d2d3g d4| WStyt}ztd5|d6t|WYd&}~Sd&}~ww)7z Create a conversation summary from session data. Args: session_data: Dictionary containing conversation data Returns: Formatted conversation summary string business_idUnknowncall_id phone_number call_durationr user_messages bot_messagescall_start_timeZz+00:00z%Y-%m-%d %H:%M:%Sz=== CALL TRANSFER SUMMARY ===z Business ID: z Call ID: zPhone Number: zCall Start Time: zCall Duration: z secondszTransfer Time: z=== CONVERSATION SUMMARY ===zConversation Flow:contentmessage timestampuser)typerr ZbotcSs |ddS)Nr r)get)xrrrrs zHConversationSummaryService.create_conversation_summary..)keyr"ZUSERZBOTN...z. [z] z(No detailed conversation data available.z=== KEY POINTS ===z- Customer called regarding: z,- Customer requested transfer to human agentz'- Call was handled by AI assistant for z- Total messages exchanged: z=== NEXT STEPS ===z%- Continue conversation with customerz4- Address any unresolved issues from AI conversationz?- Provide personalized assistance based on conversation context z%Error creating conversation summary: zError creating summary: )r#rnow isinstancestrZ fromisoformatreplacestrftimeappenddictsort enumeratelenextend_extract_topicjoin Exceptionr error)rrrrrrrrrZstart_time_strZ summary_partsZ all_messagesmsgrr iZmsg_typeerrrcreate_conversation_summarys                   .   z6ConversationSummaryService.create_conversation_summaryrc CszH|sWdS|D]=}t|tr|d|dt|}nt|}t|dkrE|dd}t|dkr@|ddd WS|WSqWdSYdS) z*Extract the main topic from user messages.zGeneral inquiryrr .r2Nr))r,r1r#r-r4stripsplit)rrr:rZfirst_sentencerrrr6s    z)ConversationSummaryService._extract_topicrrc s|js tddSz`||}|||tdd}td|d|jtj |j|ddi|j d }|j d krOtd |td |j Wd St d|t d|j t d|j WdStjjyt d|YdStjjyt d|YdStjjy}zt d|dt|WYd}~dSd}~wty}zt d|dt|WYd}~dSd}~ww)a Send conversation summary to external API. Args: business_id: Business ID call_id: Call ID session_data: Session data for summary creation Returns: True if successful, False otherwise z$Conversation summary API is disabledFzUser requested human agent)ZbidZcallidZconversation_summaryr Ztransfer_reasonz&Sending conversation summary for call z to z Content-Typezapplication/json)jsonZheadersr r(z0Successfully sent conversation summary for call zAPI Response: Tz-Failed to send conversation summary for call z Status Code: z Response: z.Timeout sending conversation summary for call z7Connection error sending conversation summary for call z4Request error sending conversation summary for call z: Nz7Unexpected error sending conversation summary for call )r r r r=rr+Z isoformatr requestsZpostr Z status_codetextr9 exceptionsZTimeoutConnectionErrorZRequestExceptionr-r8)rrrrZsummaryZpayloadZresponser<rrrsend_conversation_summarysT     z4ConversationSummaryService.send_conversation_summaryc Csz+|j|j|j|jrtt|jnd|jt|dgt|dg|j |j |j d WSt y^}z't d|t|ddt|ddt|d ddtggdd WYd }~Sd }~ww) z Extract summary data from a call session. Args: session: CallSession instance Returns: Dictionary with session data for summary rrr) rrrrrrrconversation_countagent_iddidz'Error extracting session summary data: rrrr)rrrrrrrrIN)rrrrintrr+Z total_secondsgetattrrIrJrKr8r r9)rZsessionr<rrrget_session_summary_datas2       z3ConversationSummaryService.get_session_summary_dataN)__name__ __module__ __qualname____doc__rrr-rr=rr6boolrHrNrrrrrs v">r)rRrDrCZloggingrtypingrrrrZconfigrZ getLoggerrOr rZconversation_summary_servicerrrrs