(||z } | jdz } | tkDs`td |d t| d d|d|d<|jd |d|d<|d z }|S)ustuck 상태 봇 확인 및 자동 복구 (워치독 로직) Args: data: bot-activity.json 데이터 Returns: 복구된 봇 수 botsrstatusidlesince processing< [WATCHDOG] u: processing → idle (timeout zm)r7) getrr%rr<itemsr@ total_secondsTIMEOUT_MINUTESr3intstrftime) rArCrecovered_countr%bot_namebot_datarDr4 since_timeelapsedelapsed_minutess r2check_and_recover_stuck_botsrXYs 88FB DO ,,x|| $C"jjl!(h/LL"-  \ ! &i0   "!//1B6 _ , ;xj0OPSTcPdOeegh i/5DL "8 ,.1ll;O.PDL "7 + q O-!0 c tjd}t|dd5}tj||ddddd|j ty #1swYxYw#t $r}td |Yd}~yd}~wwxYw) u+bot-activity.json 저장 (원자적 쓰기)z.tmpwr"r#Findent ensure_asciiNTu(ERROR: bot-activity.json 저장 실패: )BOT_ACTIVITY_FILE with_suffixr+jsondumpr;r.r3)rA temp_filer1es r2save_bot_activityrfs%11&9 )S7 3 =q IIdAae < =+, = = ?sCDs-#A)AA)A&"A)) B 2BB c tjsdiiSttdd5}tj|cdddS#1swYyxYw#tj t f$r}td|diicYd}~Sd}~wwxYw)ubot-activity.json 로드rCrr"r#Nu(ERROR: bot-activity.json 로드 실패: )r`existsr+rbloadJSONDecodeErrorr.r3)r1res r2load_bot_activityrls '')B<  #S7 ; q99Q<    ' *?sCD|s?AAA  A AAAB 0BB B rSc t}||jdivrytjtj j d}||d|d<tjjddttdd 5}tj||d d dddt|d |y#1swYxYw#t$r}td|d|Yd}~yd}~wwxYw)u6봇의 since 필드를 현재 UTC 시각으로 갱신.rCNr7rFTrr[r"r#r\Fr]u: since 갱신 → u ERROR: since 갱신 실패 (bot=): )rlrLrr%rr<rQr`r)r*r+rbrcr3 Exception)rSrAutc_nowr1res r2update_bot_sincerqsJ " 488FB/ / ,,x||,556JK*1V Xw'   &&td&C #S7 ; =q IIdAae < = z!4WI>? = = J7zQCHIIJs5CA0CC+CC  C C4C//C4teamc ttd}|jsytj|j d}|j dijD]5\}}|j d|dk(s|j dd k(s3|cS|j dijD]2\}}|j d|k(s|j dd k(s0|cS y#t$rYywxYw) u:task-timers.json에서 해당 팀의 활성 task_id 조회z/memory/task-timers.jsonNr"r#tasksteam_id-teamrDrunning) rrrirbloads read_textrLrMro)rr timer_filerAtask_id task_datas r2get_active_task_for_teamr}s  ^,,DEF   "zz*...@A"&((7B"7"="="?  GY}}Y'dV5>9immH>UYb>b #'((7B"7"="="?  GY}}Y'4/IMM(4Ky4X      s;"C9A"C9C9C9!;C9C92C96C99 DDctj|}|sygd}t|rBtdz }|j r&|j st fd|Ds|Sy)u,해당 봇의 팀 기반 .done 파일 찾기N)z.ackedz.clearz .notifiedz .escalatedz .processing.donec3VK|] }td|z j"yw)rN EVENTS_DIRri).0ext active_tasks r2 z!find_done_file..s*es U3%&@@HHJes&))rrLr}rri is_symlinkany)rSrrprocessed_exts done_filers @r2find_done_filersl   H %D SN*40KK=!66    ((*eVdee  rYchat_idcDtjjd}|s tdyd|d}||d}t dD]} t j ||d }|jd k(ry |jd k(r;t|jjd d}tj|wtd|jy#t j$r6}td|dzd|tjd|zYd}~d}~wwxYw)uB직접 Telegram Bot API 호출 (토큰 0, Claude 세션 미생성) ANU_BOT_TOKENu,WARN: ANU_BOT_TOKEN 미설정, 알림 스킵Fzhttps://api.telegram.org/botz /sendMessage)rtextr )rbtimeoutTiz Retry-AfterzWARN: Telegram API u&WARN: Telegram 전송 실패 (attempt rKrnr\N) osenvironrLr3rangerequestspost status_coderPheaderstimesleepRequestException) rr bot_tokenurlpayloadattemptresp retry_afterres r2send_telegram_notificationrs /I CD ( < @C!73G8 # #==7B?D3&3&!$,,"2"2=!"DE  ;' .t/?/?.@A B #  (( # A'A+cRSQTU V JJq'z " " #s%'C1A C;CD),DDr{c:t|dz }|jS)u*.done.notified 마커 파일 존재 확인z.done.notifiedr)r{ notified_files r2check_already_notifiedrs"G9N!;;M    !!rYc tjjddttd5}|j t t jdddy#1swYyxYw#t$rYywxYw)uPID 파일 작성Trr[N) PID_FILEr)r*r+r-r,rgetpidr.)r1s r2write_pid_filersg dT: (C  &A GGC $ % & & &    s.1A5-A) A5)A2.A52A55 BBcttd}|jr t|d5}|D]}|j }|s|j dr(d|vs-|j d\}}}|j j dj dtj|j < dddtjjdd }tjjd s0td tj tjd tt!dt#}i}|jdij%D]\} } | jdd|| <t!d|t'j&} t'j&} | | z t(k\r6t#} t+| }|dkDrt-| t!d|d| } t#} i}| jdij%D]\} } | jdd|| <|j%D]\} }|j| d}| dk(r|dk(s%|dk(s+t!| dt/| t1| }|r|j2}t5|rt!|dwt6j| | }d}|} t9j:|j=d}|i}d|vr |r|dnd|d<ttd|d}tA|||}t!|d | d!tC|| t!| d"|jE}t'jFtH#1swYxYw#t$rYwxYw#t8j>tf$rYwxYw#tJ$rt!d#YytL$r1}t!d$|t'jFtHYd}~d}~wwxYw)%u 메인 루프z /.env.keysrh#="'NCOKACDIR_CHAT_ID 6937032012ru[FATAL] ANU_BOT_TOKEN 환경변수가 설정되지 않았습니다. 해결: 'source /home/jay/workspace/.env.keys'를 실행하거나 start-activity-watcher.sh를 사용하세요.)filerKuactivity-watcher 시작rCrDrEu초기 상태 로드 완료: rrJu개 봇 복구 완료rrHu#: processing → idle 전환 감지u!: 이미 알림 전송됨, 스킵r"r#rurvz/memory/reports/z.mdu: 완료 감지 (bot=u, idle 전환)u/: idle 전환, .done 없음 (비정상 종료?)u activity-watcher 종료 (SIGINT)uERROR: 예외 발생: )'rrrir+strip startswith partitionrrr.rLprintsysstderrexitrr3rlrMrWATCHDOG_CHECK_INTERVALrXrfrqrstemrrrbrxryrk_format_notification_messagercopyr POLL_INTERVALKeyboardInterruptro)env_filer1r0key_valuer prev_activity prev_statusesrSrTlast_watchdog_check current_time curr_activity recovered curr_statuses curr_status prev_statusrr{rr done_datadone_file_path report_pathrres r2mainrs7~&j12H h$ VVD::G ::>>/ *  ~  *+&'MM+//;AACA("*,,x"@ hA0@A))+ J &99;L115LL 1 3 8G q=%m4 ;yk9N!OP&2#./MM&3&7&7&C&I&I&K I"(*2,,x*H h' I*7)<)<)>+ c%++//&A u$,.;&3H H:-P!QR%X.!/x 8I "+..2':(G94U)VW$0#3#3Hh#GD(,I-6N%,0JJ~7O7OY`7O7a,b  )0,. ( 9IM$u~SW ) 4*..1AAQRYQZZ]/^*_K&B7KYb&cG)G94I(Sa)bc6wH$z1`%abW+ c\*..0M JJ} %I G V V    Z%)$8$8'#B% $%,!  ; <  & 1!5 6 JJ} % % &s ON5 N5N5 A$N5O>CO1O1A&O1?%O$BO15N?:O OOO.+O1-O..O11QQ'P;;Q__main__)rN)7__doc__rbrrrrrrpathlibrr__file__resolver) _SCRIPTS_DIRr,pathinsert report_utilsrrrrLrr`rr(rrrrOr&_sysutils.org_loaderr _build_bot_team_maprdict__annotations__ ImportErrorr3r@rPrXboolrfrlrqr}rrrrr__name__rYr2rsm 22H~%%'.. |CHH$HHOOAs<()T 02GHN++KLM ^$N3 4 N++BCD >""<= > yq!"TYY& N+J+  +d+L$sC$J'&  #  $  4%t%%P D T  4 JsJtJ,33:&STD[$cd6"C"D"  u&p zFI   L s"AFF43F4