i ddlZddlZddlmZddlmZddlmZddlm Z ej e Z de fdZdde de dzd e dzd e dzfd Zde d ed defdZdS)N)text)Literal) get_async_db) HTTPExceptionquestioncK t4d{V}ttj}|t d||dd{V|d{Vdddd{Vn#1d{VswxYwY|S#t$r(}t d|Yd}~dSd}~wwxYw)Nz@INSERT INTO conversations (id, first_message) VALUES (:id, :msg))idmsgzError creating conversation: ) rstruuiduuid4executercommit Exceptionlogerror)rdbconversation_ides =/var/www/html/ls-ibe-bot-apis/app/utils/store_conversation.pycreate_conversationr%s>>       R!$*,,//O**WXX&x88        ))++                                    5!55666ttttts;B$A'B?B$ BB$BB$$ C.CCranswer customer_idc<K |st|d{V}g}|r|||d|d|r|||d|dt|dkr|St4d{V}t d}|||d{V|d{Vdddd{Vn#1d{VswxYwY|S#t$r(}t d|Yd}~dSd}~wwxYw)Nhuman)rmessagerolerairz INSERT INTO messages (conversation_id, message, role, customer_id) VALUES (:conversation_id, :message, :role, :customer_id) zError saving conversation: ) rappendlenrrrrrrr)rrrrmessagesrqueryrs rsave_conversationr#7s' B$7$A$AAAAAAAO   OO#2#*       OO#2!*     x==A  " ">>       RE **UH-- - - - - - - -))++                                    333444tttttsCA%C)*C)>ACC) C  C)#C $C)) D3DDfeedback)updownreturnc^Kt4d{V}|tdd|id{V}|st dd|tdd|id{V}|}|st dd|d }|td ||d d{V|d{V dddd{Vd S#1d{VswxYwYdS) z Update feedback directly in `messages` table. - feedback: "up" -> 1, "down" -> 0 - Targets latest AI message in the conversation - Raises HTTPException if conversation or message not found Nz SELECT id FROM conversations WHERE id = :conversation_id AND is_deleted = 0 LIMIT 1; rizConversation not found) status_codedetailz SELECT id FROM messages WHERE conversation_id = :conversation_id AND role = 'ai' ORDER BY created_at DESC LIMIT 1; zNo AI message foundrz~ UPDATE messages SET feedback = :feedback WHERE id = :message_id; )r$ message_idT)rrrfetchonerr)rr$r conv_result msg_resultmsg_rowr+s rsave_conversation_feedbackr0bsK~~///////JJ    0         ##%% RC8PQQQ Q::    0         %%'' OC8MNNN NQZ jj    %(     iikk_//////////////////////////////sC2D D&)D&)NNN)r logging sqlalchemyrtypingrapp.models.connectionrapp.exceptions.httpr getLogger__name__rr rr#boolr0rr;s ......------:g!!$((S(C$J(WZ]aWa(wz~BxB((((V::l#: ::::::r: