' j<dZddlmZmZmZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZmZmZmZmZmZmZmZmZdd lmZmZGd d eZGd d eZGddeZGddeZdedefdZde dee fdZ!de de fdZ"de de fdZ#de de fdZ$de de fdZ%de de fdZ&de de fdZ'de de fdZ(de de fdZ)de de fdZ*d S)!zaConversation history API endpoints. Provides endpoints for managing conversations and messages. )OptionalListAny)datetime) BaseModel)Request) JSONResponse)logger) create_conversationget_conversationsget_conversationupdate_conversation_titledelete_conversation save_message get_messagestoggle_bookmarkget_user_bookmarks)get_user_by_usernamedecode_access_tokenc.eZdZUdZdZeeed<dS)CreateConversationRequestz%Request to create a new conversation.zNew ChattitleN)__name__ __module__ __qualname____doc__rrstr__annotations__I/var/www/html/ai-enterprise-brain/backend/chanakya/conversation/router.pyrrs,//%E8C=%%%%%r rceZdZUdZeed<eed<dZeeed<dZeeed<dZ ee ed<dZ ee ed<dS) SaveMessageRequestzRequest to save a message.messagemessage_authorN message_type sql_querymetadataparent_message_id) rrrrrrr&rr'r(dictr)intrr r!r#r#$s~$$ LLL"&L(3-&&&#Ix}####Hhtn###'+x}+++++r r#ceZdZUdZeed<dS)UpdateTitleRequestz%Request to update conversation title.rN)rrrrrrrr r!r-r-.s// JJJJJr r-ceZdZUdZeed<dS)ToggleBookmarkRequestz0Request to set or clear a bookmark on a message. bookmarkedN)rrrrboolrrr r!r/r/3s$::r r/objreturnct|trd|DSt|tr d|DSt|tr|S|S)zFConvert datetime objects to ISO format strings for JSON serialization.c4i|]\}}|t|Srserialize_for_json).0keyvalues r! z&serialize_for_json..?s'MMM:3'..MMMr c,g|]}t|Srr6)r8items r! z&serialize_for_json..As!999T"4((999r ) isinstancer*itemslistr isoformat)r2s r!r7r7<s{#tMMMMMM C  99S9999 C " "}} Jr requestcK|jdd}tjd|r |ddndd|ds!tjd |dd dS|dd}tjd |dd dt|}|stjd dS|d }|stjddStjd|t|d{V}|rtjd|ntjd||S)zExtract and verify user from JWT token in Authorization header. Returns: User dict if valid token, None otherwise authorizationz"[CONV-AUTH] Authorization header: N2MISSINGz...zBearer z([CONV-AUTH] Invalid auth header format: z[CONV-AUTH] Extracted token: z[CONV-AUTH] Token decode failedsubz([CONV-AUTH] No username in token payloadz"[CONV-AUTH] Token valid for user: z$[CONV-AUTH] User found in database: z([CONV-AUTH] User not found in database: ) headersgetr debug startswithwarningreplacerr)rC auth_headertokenpayloadusernameusers r!get_current_user_from_tokenrVGs /%%or::K Li+6dk#2#6F6F[diiijjj  ! !) , ,T+crcBRTTUUUt    2 . .E L@ss@@@AAA!%((G 8999t{{5!!H ABBBt L@h@@AAA%h// / / / / / /D N FHFFGGGGL(LLMMM Kr cK t|d{V}|stddidS|d{V}td i|}|d}t ||j|d{V}tt |S#t$r-}tddt|id cYd}~Sd}~wwxYw) z0POST /conversations - Create a new conversation.NdetailAuthentication required status_codeid)user_idr created_byzFailed to create conversation: r) rVr jsonrr rr7 Exceptionr)rCrUbodyreqr^ conversationes r!create_conversation_handlerrgqsS 099999999 45  \\^^######'//$//t*0)         .|<<===     AQAA B          s#)BA&B C "CC C c xK t|d{V}|stddidS tdtdt |jdd }td t |jd d }n#ttf$rd \}}YnwxYw|d }t|||d{V}tt|S#t$r-}tddt|idcYd}~Sd}~wwxYw)zGET /conversations - Get paginated conversations for current user. Query params: limit (int, default 10): number of conversations per page offset (int, default 0): number to skip NrXz Authentication requiredrZr[rGlimit roffset)rkrr])r^rjrlzFailed to get conversations: r`) rVr maxminr+ query_paramsrL TypeError ValueErrorr r7rbr)rCrUrjrlr^resultrfs r!get_conversations_handlerrss 099999999 56   "3r3w';'?'?'L'L#M#MNNOOEC 4 8 81 E EFFGGFF:& " " "!ME666 "t*(fUUUUUUUUU.v66777     ?s1vv?? @          sA)DA:B*)D*CDC>D D9 "D4.D94D9c(K t|d{V}|stddidSt|jd}t |d{V}|stddidS|d }|d |krtdd id St |d{V}tt||d S#t$r-}tddt|idcYd}~Sd}~wwxYw)zFGET /conversations/{conversation_id} - Get conversation with messages.NrXrYrZr[conversation_idConversation not foundr]r^ Access denied)remessageszFailed to get conversation: r`) rVr r+ path_paramsrLr rr7rbr)rCrUrurer^rzrfs r!get_conversation_handlerr|s( 099999999 45  g1556GHHII.o>>>>>>>>  34  t*  "g - -?+  &o66666666.( 0 0          >c!ff>> ?          s/)CAC?&C&3C D$"D D DcK t|d{V}|stddidSt|jd}|d{V}t di|}|d}t||j|d{V}|stdd id Std d iS#t$r-}tdd t|idcYd}~Sd}~wwxYw)zGPUT /conversations/{conversation_id}/title - Update conversation title.NrXrYrZr[rur])rur updated_byrvrwsuccessTzFailed to update title: r`r) rVr r+r{rLrar-rrrbr)rCrUrurcrdr^updatedrfs r!!update_conversation_title_handlerrs$ 099999999 45  g1556GHHII\\^^###### ((4((t*1+)           34  Y-...     :#a&&:: ;          s))CBC5C C="C82C=8C=cK t|d{V}|stddidSt|jd}|d}t ||d{V}|stdd id Std d iS#t $r-}tdd t|idcYd}~Sd}~wwxYw)z@DELETE /conversations/{conversation_id} - Delete a conversation.NrXrYrZr[rur])ru deleted_byrvrwrTzFailed to delete conversation: r`)rVr r+r{rLrrbr)rCrUrur^deletedrfs r!delete_conversation_handlerr sd 099999999 45  g1556GHHIIt*++           34  Y-...     AQAA B          s))BAB B C$"C C Cc PK t|d{V}|stddidSt|jd}|d{V}t d i|}|d}t||j|j |j |j |j |j |d{V}tt|S#t$rA}t!j|tdd t%|id cYd}~Sd}~wwxYw) z@POST /conversations/{conversation_id}/messages - Save a message.NrXrYrZr[rur])rur%r$r&r'r(r)r_zFailed to save message: r`r)rVr r+r{rLrar#rr%r$r&r'r(r)r7rbr exceptionr)rCrUrurcrdr^r$rfs r!save_message_handlerr3s% 099999999 45  g1556GHHII\\^^###### ((4((t*$+-K)m\!3          .w77888     :#a&&:: ;          s#)CB+C D%$6D D% D%c K t|jd}tjd|t |d{V}|s*tjd|tddidStjd |d t|d{V}|s+tjd |d tdd idS|d}|d|kr-tjd|d|tddidSt|d{V}tjdt|d|t|D]q\}}t|d}tj d|dzd|dd|dd|d rtt|S#t$re} tjd t#| tj| tdd!t#| id"cYd} ~ Sd} ~ wwxYw)#zTGET /conversations/{conversation_id}/messages - Get all messages for a conversation.ruz)[GET-MSGS] Get messages for conversation Nz2[GET-MSGS] Authentication failed for conversation rXrYrZr[z[GET-MSGS] User authenticated: rTz[GET-MSGS] Conversation z not foundrvrwr]r^z"[GET-MSGS] Access denied for user z to conversation rxryu[GET-MSGS] ✅ Found z messages for conversation r(z[GET-MSGS] Message riz: r%z - r&z (metadata: )u[GET-MSGS] ❌ Error: zFailed to get messages: r`)r+r{rLr inforVrOr r rlen enumerater1rMr7rberrorrr) rCrurUrer^rzimsg has_metadatarfs r!get_messages_handlerr]sM0 g1556GHHII QQQRRR199999999  NaP_aa b b b45   Ldhhz6J6JLLMMM.o>>>>>>>>   NQoQQQ R R R34  t*  "g - - NkkkZikk l l l?+  &o66666666 gCMMggVegghhh)) L LFAs 3 344L LK1KK@P8Q8QKKVYV]V]^lVmVmKK|HKKK L L L L.x88999     6c!ff66777 :#a&&:: ;          s4A>H A+H /AH 0CH I8AI3-I83I8c0K t|d{V}|stddidSt|jd}t|jd}t |d{V}|stddid S|d |d krtdd id S|d{V}tdi|}t||j d{V}|stddid S|d|krtddid St|d |ddS#t$r-}tddt|idcYd}~Sd}~wwxYw)zEPATCH /conversations/{conversation_id}/messages/{message_id}/bookmarkNrXrYrZr[ru message_idrvrwr^r]rxryzMessage not foundr0)r]r0zFailed to toggle bookmark: r`r) rVr r+r{rLr rar/rr0rbr) rCrUrurrercrdrrrfs r!toggle_bookmark_handlerrs! 099999999 X+D ESVWWW Wg1556GHHII,00>>?? -o>>>>>>>>  W+C DRUVVV V  "d4j 0 0? ;MMM M\\^^#######++d++&z3>BBBBBBBB R+> ?SQQQ Q # $ 7 7+> ?SQQQ Q6$          s<)EA7E&$E AE!EE F("F FFc>K t|d{V}|stddidSt|dd{V}tt|S#t$r-}tddt |idcYd}~Sd}~wwxYw) zGET /users/me/bookmarksNrXrYrZr[r]zFailed to get bookmarks: r`)rVr rr7rbr)rCrU bookmarksrfs r!get_user_bookmarks_handlerrs  099999999 X+D ESVWWW W,T$Z88888888 .y99:::     ;3q66;; <          s")A%6A%% B/"BBBN)+rtypingrrrrpydanticrstarlette.requestsrstarlette.responsesr logurur &backend.chanakya.conversation.databaser r r rrrrrrbackend.chanakya.authrrrr#r-r/r7r*rVrgrsr|rrrrrrrr r!rsG '&&&&&&&&&&&&&&&,,,,,,                      LKKKKKKK&&&&& &&& ,,,,,,,, ICC#w#8D>####T w <    @! W! ! ! ! ! H* G* * * * * Z& W& & & & & R! w! <! ! ! ! P' ' L' ' ' ' T2 2 L2 2 2 2 r! 7! |! ! ! ! H g ,      r