(d&dZ?d'd(dZ@d&dZAd&dZBd&dZCd&dZDd)dZEd*dZFe2d k(r6ejd!ej"ejeFyy)+u멀티모델 봇 통합 프로세스. 3개 봇(잼민이/코덱스/클로디)을 하나의 프로세스에서 실행하며, 공유 DiscussionManager를 통해 봇 간 토론을 지원합니다. ) annotationsN)AnyCallable Coroutine)replace_thinking_messagesend_thinking_message split_message)CODE_ANALYSIS_PROMPT_PREFIX)handle_message) BOT_PERSONASConversationMemory)DiscussionManager) call_claude call_codex call_gemini)InlineKeyboardButtonInlineKeyboardMarkupMessageUpdate) ApplicationCallbackQueryHandlerCommandHandler ContextTypesMessageHandlerfilters) HTTPXRequest)CLAUDE_BOT_TOKENCODEX_BOT_TOKENGEMINI_BOT_TOKENz$/home/jay/workspace/memory/groupchat) storage_basezHdict[str, tuple[Application, Callable[[str], Coroutine[Any, Any, str]]]]bot_appscK tj|d{y7#t$r }tj d|Yd}~yd}~wwxYww)u(롤링 서머리 생성 (에러 안전).Nu1롤링 서머리 생성 실패 (비치명적): %s)memorygenerate_rolling_summary Exceptionloggerwarning)chat_idexcs Q/home/jay/workspace/.worktrees/task-2057-dev2/services/multimodel-bot/main_bot.py_generate_rolling_summary_safer+)sCQ--g666 QJCPPQs6A$"$A$ A AAA  AchKtj|d}|sydjd|D}tjj |d}|rd|nd}d|d |d } t |d d {}|S7#t $r%}tjd|d|cYd }~Sd }~wwxYww)u6전체 대화 내용을 분석하여 합의문 생성.2limitu토론 내용이 없습니다. c3RK|]}|jd|j!yw): N)sendertext).0ms r* z,generate_consensus_report..7s#!LaQXXJb"9!Ls%'u [이전 요약] u>아래 토론 대화를 분석하여 합의문을 작성해줘. 반드시 아래 형식을 따라줘: 📋 토론 합의문 [주제]: (토론 주제 한 줄 요약) [참여]: 잼민이(Gemini), 코덱스(GPT), 클로디(Claude) ✅ 합의사항: 1. ... 2. ... ⚠️ 미합의: 1. ... 📌 다음 단계: 1. ... z z <)timeoutNu합의문 생성 실패: %su합의문 생성 실패: ) r# get_contextjoin_rolling_summariesgetrr%r&r')r(messagesconversation_textrollingrolling_sectionpromptreportr)s r*generate_consensus_reportrE1s!!'!4H / !L8!LL''++GR8G;B-gY7O       &1"6266 7 14c:*3%001sHA%B2(B8A?9B>B2?B B/ B*$B/%B2*B//B2cDK t|d{}tjD]A\}\}} t|}|D]'}|jj ||d{)ntjD])\}\}} t|j||d{ntjj|dy77l#t $rYwxYw7;#t $rYmwxYw#t $r }tjd|Yd}~yd}~wwxYww)uG토론 종료 시 합의문 생성 후 그룹챗에 전송 + 아누 DM.Nr(r4u1합의문 생성/전송 실패 (비치명적): %s) rEr!itemsr bot send_messager%_send_insight_to_ownerr#r=popr&r')r(rD bot_usernameapp_partspartr)s r*_generate_consensus_report_saferRXs)Q099&.nn&6  "L(3 %f-!KD''..wT.JJJK  '/nn&6  "L(3 ,SWWgvFFF  !!%%gt4): K   G   QJCPPQsD C4C!C40C%C&C, C4 C%'C#(C%,#C4D C4C C C4C  C4#C%% C1.C40C11C44 D=DD DD c ZKt4d{tjtjd{tj |s(tj |d dddd{y|tvr>tjd|tj |d dddd{yt|\}} t|j|d{}tj||tj|j}|dk(r+tj!|}t#||d{} nI|dk(r4tj%|rt&|z}t)|d d{} n||d{} t+|j||| d{t-j.|ij/d |} tj1|| | d tj3|} | rtj4j/|} | rN| j6d kDr?| j6d zd k(r-| j8d k(rtj:t=|tj:t?| || |n4tj |dtj:tA|dddd{y777w747 77t7f7I#tB$r} tjd||| dtj |dtjE |jjG|d| d{7n#tB$rYnwxYwYd} ~ d} ~ wwxYw7#1d{7swYyxYww)uS다음 턴 봇이 맥락 기반 프롬프트로 응답하도록 트리거합니다.NFu알 수 없는 봇 username: %s)phasecodex_view_bot)modelclaude_view_botT) code_analysisname)is_botru6trigger_next_bot_response 오류 (bot=%s, chat=%d): %sexc_infou-❌ 응답 중 오류가 발생했습니다: rG)$ _turn_lockasynciosleepdm TURN_DELAYis_discussion_activeset_chain_runningr!r&errorrrIr#format_contextget_current_phasevalueget_codex_modelris_code_analysis_moder rrr r> add_messageon_bot_response_states round_countbot_response_count create_taskr+trigger_next_bot_responserRr%stop_discussionrJ)next_bot_usernamer(previous_messageprevious_bot_namerNcall_fnthinking_msg_idcontext_prompt codex_modelresultbot_name next_nextstatees r*rqrqusaNNmmBMM***&&w/  % 0  NNN H , LL:NN&~66+377G_fU U U$''(92>BB6K\]H   w&  F**+<=I w/U..2u7H7H17LPQ7QV[VnVnrsVs''(Fw(OP##-!) $$We4##$CG$LMyNNN*NN"LMO6 V6  LLH!    % 0     gg**#HL+   }NNNNsA N+K%N+'NK(0N) N+4K+5N+:5N/ N+:K.;N+ N L&K1'A#L K4 8LK7LK:L4K=5DL N+N N+(N+N+.N+1L4L7L:L=L N AN #M81M42M87N 8 NN NN N NNN+N(N N($N+cK|j |jy|jj} tj |d{}|jj |d{t |j||d{y7G7&7 #t$r`}tjd||d |jj d|d{7n#t$rYnwxYwYd}~yYd}~yd}~wwxYww)uk/정리 커맨드 핸들러. 대화 요약(insight)을 생성하여 그룹챗에 전송 + 아누 DM 전송.Nu+handle_cleanup_command 오류 (chat=%d): %sTr\u-❌ 정리 중 오류가 발생했습니다: ) effective_chateffective_messageidr#generate_insight reply_textrKrIr%r&re)updatecontextr( insight_textr~s r*handle_cleanup_commandrs $(@(@(H##&&G #44W== &&11,???%W[['<HHH >? I  BGQY] ^ **558efgeh6ij j j     ks0DB B "B.B/B BBDBBB D"C=  &&112deee F44m! LLL =33!3< = fMsEB#A: B#B B#4B!5B#:BB#BB#!B#cKd}||z}||z}|||}t||zdz |z}g} |D]x} | jdd} | jdd} | jdddd } | jd d }d | d | d| }| jt|d|gzg}|dkDr"|jtdd|dz ||dz kr"|jtdd|dz|r| j|t | }d|dzd|d}|r(t |dr|j ||d{y|j||d{y7!7w)u)InlineKeyboard 페이지를 표시한다.rdater8 topic_taggeneralsummaryNfilenameunknown[]  — mem: callback_dataru ◀ 이전mempage:u 다음 ▶u📚 대화 메모리 (/u 페이지) edit_text reply_markup)lenr>appendrrhasattrrr)message summariesredit page_sizestartend page_items total_pagesbuttonssrtopicrrbtn_text nav_buttonsrr4s r*rrsI 9 E ) C5%Jy>I-1i?K02G ZuuVR k9-%% 2&s+55Y/tfBugU7)4,XtH:EVWXY Z/1K ax/ hW[^_W_V`Labc kAo/ hW[^_W_V`Labc{#'0L $TAXJa }K HD -<@@@  L AAA AAs$EE.E* E.$E,%E.,E.c K|j}|y|jd{|jxsd}t|jt sy|j}|j drLt|jdd} tjd}t|||d d{y|j d r|jddd}tj}||jd d{yd dlm} | ||dz } | j%s|jd|d{y t'j(| j+d} d| j-ddd| j-ddd| j-dddddj/| j-dgddj/| j-dgddj/| j-dgd| j-d dg} t1t3d!d"#gg} |jd$j/| | %d{yy7T#t$rtjd}YwxYw777X78#t4$r'}|jd&|d{7Yd}~yd}~wwxYww)'uInlineKeyboard 콜백 처리.Nr8r:rr-r.rT)rrru/요약 디렉토리를 찾을 수 없습니다.r)Pathz.jsonu#파일을 찾을 수 없습니다: utf-8encodingu📄 rrrru 🏷 주제: z, key_topicsu ✅ 결정: key_decisionsu 📋 액션: action_itemsu 🤝 합의: consensus_levelu◀ 목록으로z mempage:0rr0ru파일 읽기 오류: )callback_queryanswerdata isinstancerr startswithintsplitr#rrrr_summaries_dirrpathlibrexistsjsonloads read_textr>r<rrr%)rrqueryrmsgrrr summaries_dirr file_path summary_datalines back_buttonr)s r*handle_memory_callbackrs  ! !E } ,,. :: D emmW -==C z"4::c?1%& A"88r8BM ]DIII  ::c1%a(--/  -- QR R R  'XJe*<< !--"EhZ PQ Q Q  @::i&9&97&9&KLL ((45U<;K;KKY[;\:]^  B/ ,*:*:<*L MNOtyy)9)9/2)NOPQ ,*:*:>2*N OPQ 0 01BB GHI E/1EFXhs1t0u/vwK-- % 0{-K K K; !% A"77a7@M AI S R" L @--"8 >? ? ? @s#K I9A)K I<&K 8J"9AK J%AK J(K DJ-2J+3J-7K <JK JK %K (K +J-- K6K KKK KK c K|j |jy|jrdj|jnd}|s$|jj dd{yt j }||js$|jj dd{yg}t|jdD]} tj|jd}dj|jd ddj|jd gdj|jd gg}|j|jvr|j||s(|jj d |d d{yd |dt#|dg}|ddD]U} | jdd} | jdd} | jd ddd} |jd| d| d| W|jj dj|d{y77#t $rYwxYw77w)uG/기억 <키워드> 커맨드 핸들러. 요약에서 키워드 검색.N r8u사용법: /기억 <키워드>u#🔍 검색 결과가 없습니다.*.jsonrrrrru🔍 'u*'에 대한 검색 결과가 없습니다.u' 검색 결과 (u건):rrrr9u• [rr2r0)rrargsr<rr#rrsortedglobrrrr>lowerrr%r) rrkeywordrresultsfpr searchablerrrrrs r*handle_search_memory_commandrSsX $(@(@(H(/ chhw||$"G &&112RSSS))+MM$8$8$:&&112WXXXG]''12 ::bllGl<=DHHY+HHTXXlB78HHTXXor:;J}}*"2"2"44t$ &&11F7)Cm2nooogY/G ~U C DE RS\9uuVR k9-%% 2&s+ uTF"UG2gY78 9  " " - -dii.> ???K T Y"    p@siA#I6%I&A I6/I0$I6B8I" &I63I24B"I6I4I6I6" I/+I6.I//I64I6cpK|j |jy|jrdj|jnd}|s$|jj dd{y|jj } t j||d{}|jj |d{y7^7*7 #t$r`}tjd||d |jj d|d{7n#t$rYnwxYwYd}~yYd}~yd}~wwxYww) u./스마트검색 <질문> 커맨드 핸들러.Nrr8u$사용법: /스마트검색 <질문>u0handle_smart_search_command 오류 (chat=%d): %sTr\u2스마트검색 중 오류가 발생했습니다: ) rrrr<rrr# smart_searchr%r&re)rrrr(rzr~s r*handle_smart_search_commandrs $(@(@(H&-llCHHW\\ "E &&112XYYY##&&G**5'::&&11&999 Z ;9  GRS^b c **558jkljm6no o o     psA#D6%C&D6C C"C >C?C D6C C D3D.-!DDDD. D!D. D!!D.$ D6.D33D6c XK|j |jytj}||j s$|jj dd{yddlm}|t}t|jdD]} tj|jd}|jd|jdd }|jd d }|jd d dd} |jdd} d|jvr|jj!dddn |j} ||j#d| d| d| d|s$|jj dd{ydg} t|j'dddD]*}| j#|d| j)||,|jj dj+| d{y7#t$$rYwxYw77w)u</목차 커맨드 핸들러. 날짜별 요약 목록 표시.Nu&📋 저장된 목차가 없습니다.r) defaultdictrrrr rrrr8(r exploratoryrOrz - r2z ()u📋 대화 목차T)reverserr0)rrr#rrr collectionsrlistrrrrrr>stemrrr%keysextendr<) rrrrentriesrrrrr consensus entry_namers r*handle_index_commandrs $(@(@(H))+MM$8$8$:&&112Z[[['$/$5G]''12  ::bllGl<=D88FBGGCRL1DHH[)4Ehhy"-cr2G!2MBI58BGG^sA.q1J DM 4 |2gYb 1!M N  &&112Z[[[ ! "Ew||~t4Ra8$ vQZ  WT]#$  " " - -dii.> ???9 \     \@sVAH* H!4H*CH*"H* H& BH* H(H* H#H*"H##H*(H*cK ddlm}d|d}dt|z }|t||kDr|d|n|z}|j||d{y7#t$r }t j d|Yd}~yd}~wwxYww) u<insight 결과를 OWNER_USER_ID에게 DM으로 전송한다.r) OWNER_USER_IDu'📋 그룹챗 정리 완료 (chat_id: z) iNrGu*아누 DM 전송 실패 (비치명적): %s)configrrrJr%r&r')rIr(rrheadermax_lenr4r)s r*rKrKs J(:7)5IV$3|3Dw3Nhw/T`a}4@@@ JCSIIJsABAA A ABA A=A83B8A==Bc <Ktdddd}tjjtj |j }tjjtj |j }tjjtj |j }|tftd<|tftd<|tftd<|||fD]}t|jd<d}d }d }d tfd t fd t"fdt$fdt&fg}|||fD]:}|D]3\} } |j)t+t-j.| | 5<|j)t+t,j0t,j2z||j)t+t,j0t,j2z||j)t+t,j0t,j2z||||fD] }|j)t5t6"|||fD]g}|j9d{|j;d{|j<Jd|j<j?d{it@jCd tEjFjId{|||fD]`}|j<"|j<jOd{|jOd{|jQd{by7777s#tJtLf$rYwxYw7T7>7(#|||fD]c}|j<#|j<jOd{7|jOd{7|jQd{7ewxYww)u'3개 봇 통합 프로세스 진입점.rr9)connect_timeout read_timeout write_timeout pool_timeoutgemini_view_botrUrWrqcNKt||ttd{y7wN)rar#) gemini_handlerar#rrs r* wrap_geminizmain..wrap_geminiFG6BBB %#%cNKt||ttd{y7wr) codex_handlerar#rs r* wrap_codexzmain..wrap_codexs67r&AAArcNKt||ttd{y7wr) claude_handlerar#rs r* wrap_claudezmain..wrap_clauderru^/정리u ^/메모리u^/기억u^/목차u^/스마트검색Nu<Application.updater가 None입니다 (polling 모드 필요)u&3봇 통합 프로세스 시작 완료))rrbuildertokenrrequestbuildrrrr!rrrqbot_datarrrrr add_handlerrrRegexTEXTCOMMANDrr initializerupdater start_pollingr&infor_EventwaitKeyboardInterrupt SystemExitstopshutdown) tg_request gemini_app codex_app claude_apprNrr rkorean_commandspatternhandlers r*mainr)sbrQSbdeJ$$&,,-=>FFzRXXZJ##%++O<DDZPVVXI$$&,,-=>FFzRXXZJ$.{";H "+Z!8H #-{";H Iz2N4M 01NCBC ,- ./ 23 *+ :; OIz2M / M GW OON7==+A7K L MM>',,'//9I*I;WX .8H)H*UV>',,'//9I*I;WXIz2F ,-CDEFIz2*nniik{{&f(ff&kk''))) *  KK89 !mmo""$$$ :6 !C{{&kk&&(((((*  ,,.  ! ) % z *   )   :6 !C{{&kk&&(((((*  ,,.  !sJ P N  P$N %4PN P6%NNN 1PN&P)N(*PN*P P PNN# N,"N##N,&P(P*P,2PO! P7O: 8PP PP__main__z4%(asctime)s - %(name)s - %(levelname)s - %(message)s)formatlevel)r(rreturnNone)r(rr-str) rsr/r(rrtr/rur/r-r.)rrrzContextTypes.DEFAULT_TYPEr-r.)rF) rrrrrrrboolr-r.)rIrr(rrr/r-r.)r-r.)J__doc__ __future__rr_rloggingtypingrrr bot_utilsrrr claude_botr r r  codex_botr conversation_memoryr r discussion_managerrengine_v2.bot_apirrr gemini_botrtelegramrrrr telegram.extrrrrrrtelegram.requestrrrrr getLogger__name__r&Lockr^rar#r!__annotations__r+rErRrqrrrrrrrrKr) basicConfigINFOrunr*rHsT # ++TT264@0BB6PPqq)FF   8 $ W\\^  )O PVX RWQ$1NQ:UU UU U  Up.M& BF6@r,@^.#@L JB!J zGEllGKK rG