o vj3+@s ddlZddlZddlZddlmZmZddlmZddlmZddl m Z ddl m Z ddl mZddlmZeeZd"d ed ed efd dZ   d#dededBdeededBdededBd eeeffddZ d$dededededBd ef ddZ d%dededed efd d!ZdS)&N)datetimetimezone) EmailMessage)Any)settings)get_conversation_by_session_id)get_messages_by_conversation_id)get_session_by_idFdt_val time_onlyreturncCs|sdSt|tr z t|dd}Wn ty|YSwt|tr=|jdur1|jtjd}|r8| dS| dSt|S)NN/AZz+00:00)tzinfoz %H:%M:%S UTCz%Y-%m-%d %H:%M:%S UTC) isinstancestrr fromisoformatreplace Exceptionrrutcstrftime)r r r;/web/html/dev/chatbot/backend/app/services/email_service.py_format_time_strs      rvisitorsession conversationmessages agent_infoended_byended_atcCs|dd}|dd}|dpd}|dpd} d} d} |r4|dp+|dp+d } |d p2d } n |d r@|d } d } t|d pJ|d} t|pTttj} ddd|d|d|d| d| d| d| d| d|dddg}|s|dnN|D]K}t|d dd}|d d!}|d"vrd#}n|d$vr| dkrd%| d&nd'}n |d(krd)}n|}|d*d}|d+|d,|d-|d.qd. |}d/d0d1d2|d3d4|d3d5|d3d6| d3d7| d3d8| d3d9| d3d:| d3d;|d3dg}|s|d?n_|D]\}t|d dd}|d d!}|d"vr;d#}d@}dA}n|d$vrR| dkrKd%| d&nd'}dB}dC}nd)}dD}dE}|d*d d.dF}|dG|dH|dI|dJ|dK|dL q|dMd |}||fS)Nz^ Builds the formatted plain text and HTML email bodies for a chat session transcript. sessionIdUnknownsiteId ipAddresscountryNonenameagentIdzAssigned Agentemailr assignedAgentId createdAt connectedAtzChat Session Detailsz--------------------z- Session ID: z - Site ID: z- Visitor IP: z - Country: z- Assigned Agent: z- Agent Email: z- Chat Started At: z- Chat Ended At: z - Ended By: zConversation Transcriptz-----------------------z"(No messages in this conversation)T)r roleunknown)userrVisitor)agent assistantzAgent ()AgentsystemSystemcontent[z] z:  zSz

Chat Session Details

z?zPzM
Session ID:z
Site ID:zP
Visitor IP:zM
Country:zT
Assigned Agent:zQ
Agent Email:zU
Chat Started At:zS
Chat Ended At:zN
Ended By:z
z

Conversation Transcript

zf
zJ

(No messages in this conversation)

z#e0f2fez#38bdf8z#f1f5f9z#94a3b8z#fef3c7z#f59e0bz
z@
[z ] z-
z
z
) getrrnowrrappendlower capitalizejoinr)rrrrrr session_idsite_id ip_addressr% agent_name agent_emailstarted_at_str ended_at_strlinesmmsg_timer. sender_labelr8 text_body html_linesbg_color border_color html_bodyrrrbuild_transcript_email_content!s                     rQ recipientsubject text_content html_contentc Cstjstd|d|ddSt}||d<tj|d<||d<|||r/|j|dd zttjrat j tjtj d d }tj rLtj rL|tj tj ||Wd n1s[wYn4t jtjtj d d "}tjrs|tj rtj r|tj tj ||Wd n1swYtd |d|dWdSty}ztjd|d|ddWYd }~dSd }~ww)z:Synchronous SMTP sending worker executed in a thread pool.z>[EMAIL] No SMTP host configured. Logged transcript email for 'z' to 'z'.TSubjectFromTohtml)subtype )timeoutNz.[EMAIL] Successfully sent transcript email to z (r4z [EMAIL] Failed to send email to z via SMTP: exc_infoF)r smtp_hostloggerinforsmtp_from_email set_contentadd_alternative smtp_use_sslsmtplibSMTP_SSL smtp_port smtp_user smtp_passwordlogin send_messageSMTP smtp_use_tlsstarttlsrerror)rRrSrTrUmsgservererrr_send_smtp_syncsD      rtdbrAc s|durdSzt||IdH}|std|WdSt||IdH}|r+|dnd}|r@|dr@td|dWdS|drQtd |dWdSg}|r]t||IdH}d}|d }|rr|d d |iIdH}d |} tj p{d} t t j } t|||||| d\} } tjt| | | | dIdH}|r|dd|idd| diIdH|dd|idd| diIdH|WSty}ztjd|d|ddWYd}~dSd}~ww)aE Fetches the complete session conversation history and metadata from MongoDB, generates the formatted transcript, and emails it to the configured admin email. Prevents duplicate emails if already sent for this conversation. Gracefully catches failures without interrupting the chat termination flow. NFz0[EMAIL] Session not found for transcript email: conversationIdtranscriptEmailedz[EMAIL] Conversation z0 transcript already emailed. Skipping duplicate.Tz[EMAIL] Session r*agentsr(uChat Conversation — zalok.chaudhary2001@gmail.com)rrrrrr )rRrSrTrU conversationsz$set)rwtranscriptEmailedAtsessionsr!zA[EMAIL] Unexpected error generating/sending transcript email for z: r])r r`warningrr;rarfind_oneradmin_notification_emailrr<rrrQasyncio to_threadrt update_onerrp)rurArrconvconv_idrrassigned_agent_idrSrRr rLrP sent_successrsrrr"send_conversation_transcript_emailsp              r)F)NrN)N)r)rloggingrfrr email.messagertypingr app.configr(app.repositories.conversation_repositoryr#app.repositories.message_repositoryr#app.repositories.session_repositoryr getLogger__name__r`boolrrdictlisttuplerQrtrrrrrsh         { -