<j(< UdZddlmZddlZddlZddlmZddlmZddl m Z ddl m Z e e Zeejj!dd Z dd lmZej*Zd Z dd lmZeZded<d Zd$dZd%dZ gdZ!ded<hdZ"ded<ddddddddd Z#ded!<Gd"d#Z$y#e$rdZd ZYUwxYw#e$riZd ZYOwxYw)&uDBotStatusManager — 봇 상태 관리 단일 소스 모듈. dispatch.py, whisper-compile.py 에 분산되어 있던 봇 상태 관련 로직을 하나로 통합. Usage: from utils.bot_status import BotStatusManager mgr = BotStatusManager() busy = mgr.get_busy_bots() idle = mgr.get_idle_bots() avail = mgr.is_bot_available("bot-e") status = mgr.get_team_status("dev4-team") occ = mgr.get_bot_occupation() team = mgr.suggest_team("배너 이미지 디자인 작업") warn = mgr.validate_routing("dev1-team", "카피 마케팅 전략") ) annotationsN)Path)Optional)COMPOSITE_TRIGGER_KEYWORDS) get_loggerWORKSPACE_ROOTz/home/jay/workspace) ConfigManagerTF)build_team_to_bot_id_mapdict[str, str]_TEAM_TO_BOT_IDc tdz dz }|jsiS tj|j dS#tj t f$r$}tjd|icYd}~Sd}~wwxYw)u+config/constants.json 파일 직접 읽기.configconstants.jsonutf-8encodingconstants.json 읽기 실패: N) WORKSPACEexistsjsonloads read_textJSONDecodeErrorOSErrorloggerwarning)pathexcs A/home/jay/workspace/.worktrees/task-2551-dev6/utils/bot_status.py_load_constants_jsonr =ss x "2 2D ;;= zz$..'.:;;  ' *7u=> s$ABA=7B=Bc tr trtStr*tr$ tj d}|r t |S t}t |jdixs dddddddd d S#t $rY=wxYw) uM팀→봇 매핑을 반환. org_loader 우선, fallback으로 constants.json. team_to_botbot-bbot-cbot-dbot-ebot-fbot-gbot-hbot-iz dev1-teamz dev2-teamz dev3-teamz dev4-teamz dev5-teamz dev6-teamz dev7-teamz dev8-team) _ORG_LOADER_AVAILABLEr _CONFIG_AVAILABLE_cfg get_constantdict Exceptionr get)result constantss r_resolve_team_to_bot_idr5IsT &&}5FF|# %&I  mR0 1  6     s!A55 BB)r#r$r%r&r'r(r)r* list[str]ALL_BOTS>designcontent marketing consulting publishingzset[str]DYNAMIC_BOT_TEAMSr#r$r%r&r'r(r)r*r+_FALLBACK_TEAM_TO_BOTceZdZdZ ddd ddZddZddZddZddZdd Z dd Z ddd Z dd Z dd Z ddZddZddZ d ddZy)BotStatusManageru모든 봇의 현재 상태를 관리하는 단일 소스. task-timers.json 및 config/constants.json을 기반으로 봇 점유/유휴 상태, 팀 라우팅 추천, 라우팅 검증 기능을 제공합니다. N) task_timersc|xst|_|jdz dz |_|jdz dz |_||_y)Nmemoryztask-timers.jsonrr)r _workspace _timer_file_constants_file_injected_task_timers)selfworkspace_rootrAs r__init__zBotStatusManager.__init__sF )5I!%8!;>P!P%)__x%?BR%R5@"c|jjsiS tj|jj dS#tj t f$r$}tjd|icYd}~Sd}~wwxYw)uB인스턴스 workspace 기준 constants.json 파일 직접 읽기.rrrN) rFrrrrrrrr)rHrs r_load_constantsz BotStatusManager._load_constantssu##**,I ::d22<r5)rHr4s rr5z(BotStatusManager._resolve_team_to_bot_idsC ??i ',,.I mR89R=R R&((rKc |j}|jDcic]\}}||jddc}}Scc}}w)u8인스턴스 workspace 기준 봇→dev short id 매핑.-team)r5itemsreplace)rHr"tidbots r_resolve_bot_to_devz$BotStatusManager._resolve_bot_to_devsA224 >I>O>O>QR(#sS[["--RRRsAcl|j}|Dcgc]}|jddc}Scc}w)u2인스턴스 workspace 기준 dev short id 목록.rPrQ)r5rS)rHr"rTs r_resolve_dev_short_idsz'BotStatusManager._resolve_dev_short_idss/224 4?@S GR(@@@s1cn|j |jS|jjsiS tj|jj d}|j diS#tjtf$r$}tjd|icYd}~Sd}~wwxYw)utask-timers.json의 tasks 섹션 반환. 실패 시 빈 dict. 주입된 task_timers가 있으면 파일 읽기 없이 그것을 반환. Nrrtasksu task-timers.json 읽기 실패: ) rGrErrrrr2rrrr)rHdatars r_load_task_timersz"BotStatusManager._load_task_timerss  % % 1-- -&&(I ::d..88'8JKD88GR( ($$g.  NN=cUC DI sAA77B4B/)B4/B4ctr*tr$ tjd}|r t|S |j }|j diS#t$rY-wxYw)uconfig/constants.json의 logical_teams 섹션 반환. ConfigManager 우선, fallback으로 파일 직접 읽기. logical_teams)r-r.r/r0r1rMr2)rHr3r4s r_load_logical_teamsz$BotStatusManager._load_logical_teamsse  **?;<' ((* }}_b11   s!A AAc4|j}|j}i}|jD]b\}}|jddk7r|r||k(r#|jdd}||vr ||}||d||<|jdd} | s[||d|| <d|S)urunning 상태 태스크에서 점유된 봇 정보 반환. dev팀 running task → TEAM_TO_BOT_ID 매핑으로 봇 추출. 논리적 팀(design 등) running task → bot 필드 직접 사용. Args: exclude_task_id: 결과에서 제외할 task_id (자기 자신 제외용). Returns: {"bot-b": {"task_id": "...", "team_id": "..."}, ...} statusrunningteam_idrQ)task_idrcrU)r5r\rRr2) rHexclude_task_idr"rZbusyrdentryrcrU bot_fields r get_busy_botszBotStatusManager.get_busy_botss224 &&(*,#kkm KNGUyy"i/7o#= 99Y3G+%!'*(/GDS #YYub1I.5'"JY! K$ rKct|jj}tDcgc] }||vs| c}Scc}w)u전체 봇 목록에서 busy 봇을 제외한 유휴 봇 ID 목록 반환. Returns: ["bot-c", "bot-f", ...] (우선순위 순서 유지) )setrikeysr7)rHrfrUs r get_idle_botszBotStatusManager.get_idle_botss: 4%%',,./';3d?;;;s AAc&||jvS)u특정 봇이 현재 유휴 상태인지 확인. Args: bot_id: 확인할 봇 ID (예: "bot-e"). Returns: True이면 유휴, False이면 점유 중. )ri)rHbot_ids ris_bot_availablez!BotStatusManager.is_bot_available sT//111rKc^|j}|jD]-}|jddk(s|jd|k(s-y|j}|j|}|r:|j }|j dd}||vr||}d|dd |d d Sy ) uddev팀의 현재 상태 문자열 반환. - running task 있음 → "작업중" - 봇이 논리적 팀에 점유됨 → "봇점유({team}:{task_id})" - 그 외 → "유휴" Args: team_id: dev팀 ID (예: "dev4-team"). Returns: "작업중" | "봇점유(design:task-123)" | "유휴" rarbrcu 작업중rPrQu 봇점유(team:rd)u유휴)r\valuesr2r5get_bot_occupationrS) rHrcrZrgr"ro occupation dev_shortocc_infos rget_team_statusz BotStatusManager.get_team_statuss&&(\\^ #Eyy"i/EIIi4HG4S" # 224 ) 002J4IJ&%i0#HV$4#5Qx 7J6K1MMrKc|j}t|j}|j}i}|j D]\}}|j ddk7r|j dd}|j dd}|sB|j dd} | |vrY|j |} | sm||j d||d|| <|S) u논리적 팀이 물리 봇을 점유하는 경우를 탐지. dev팀 자체 작업은 제외하고, marketing/design/content 등 논리적 팀이 dev봇을 빌려 사용하는 경우만 반환합니다. Returns: {dev_short_id: {"team": team_id, "task_id": task_id, "bot_id": bot_id}} 예: {"dev4": {"team": "design", "task_id": "task-99", "bot_id": "bot-e"}} rarbrcrQrUrPrd)rrrdro)rVrkrXr\rRr2rS) rH bot_to_dev dev_short_idsrZrwrdrgrcro team_short dev_owners rrvz#BotStatusManager.get_bot_occupation4s--/ D779: &&(02 #kkm NGUyy"i/ 99Y3G))E2.F!"5J]*#v.I#$yyG<$) 9%# .rKc^|j}|syd}d}|jD]z\}}|dk(rtfdtDs$|j dg}|j dg}tfd|Dr]t fd|D} | |kDsw| }|}||dkDr|SdS) uv작업 설명에서 키워드 매칭으로 적합한 논리적 팀 추천. constants.json의 logical_teams 키워드를 사용하며 anti_keywords가 포함된 팀은 후보에서 제외합니다. Args: task_desc: 작업 설명 문자열. Returns: 추천 팀 ID (예: "design") 또는 None (매칭 없음). Nr compositec3&K|]}|v ywN).0trigger task_descs r z0BotStatusManager.suggest_team..usZG7i/Zkeywords anti_keywordsc3&K|]}|v ywrr)rakrs rrz0BotStatusManager.suggest_team..}s;r2?;rc3,K|] }|vsd yw)Nr)rkwrs rrz0BotStatusManager.suggest_team..s@bi@s )r_rRanyrr2sum) rHrr^ best_team best_scorercrrrscores ` r suggest_teamzBotStatusManager.suggest_team\s002 #'  ,224 $OGV+% Z?YZZ$ZZ B7H"(**_b"AM;];;@H@@Ez!" # - $0'Ny44rKc|tvry|j|}|y|rtjd|d|dy|j }|j |ij dd}d|d|d S) udev팀에 논리적 팀 소관 작업이 위임될 때 경고 메시지 반환. 논리적 팀(design, marketing 등)에 직접 위임된 경우는 검증 생략. Args: team_id: 위임 대상 팀 ID (예: "dev1-team"). task_desc: 작업 설명 문자열. override_routing: True이면 경고를 무시하고 None 반환. Returns: 경고 메시지 문자열 또는 None (문제 없음). Nz[routing-override] u에 u- 소관 작업 위임 (override_routing=True) descriptionrQu이 작업은 --team u이 적합합니다 (u<). 계속하려면 override_routing=True를 사용하세요.)r=rrrr_r2)rHrcroverride_routing suggestedr^rs rvalidate_routingz!BotStatusManager.validate_routings& ' '%%i0    NN0 i[Huv w002 #'' 26::="M #I;.CK=QH I rKr)rIzOptional[Path]rAzOptional[dict]returnNonerr0rr )rr6)re Optional[str]rdict[str, dict[str, str]])rostrrbool)rcrrr)rr)rrrr)F)rcrrrrrrr)__name__ __module__ __qualname____doc__rJrMr5rVrXr\r_rirmrprzrvrrrrKrr@r@s*. A'+ A& A$ A  A)S A  2("H< 2@&P+5b"' # # #  #  # rKr@rr)%r __future__rrospathlibrtypingrutils.composite_constantsr utils.loggerrrrenvironr2r config.loaderr _ConfigManager get_instancer.r-r1utils.org_loaderr _build_team_to_bot_id_mapr __annotations__r,r r5r7r=r>r@rrKrrs"# @# H   02GH I = &> & & (D"V&?&AO^A  < ) ]8\ )~ "g g s D"O!"s$B8/C8 CC CC