8#jX UdZddlmZddlZddlZddlZddlZddlmZmZddl m Z ddl m Z m Z mZddlmZmZdZd Zd Zd Zd Zd ZdZdZdZd+dZd,dZedededededediZded<edededededed iZded!< d-d"Z d.d#Z! d/d$Z"d0d%Z#d1d&Z$ d2 d3d'Z% d2 d4d(Z&d5d6d)Z'e(d*k(r e)e'y)7uscripts/harness/v36/terminal_state_callback.py task-2724 TERMINAL_STATE_CALLBACK_CONTRACT — EXIT trap terminal-state 판정 + ANU callback 등록. CLI: python3 terminal_state_callback.py emit --task-id --events-dir --workspace --done-file ★ ANU owner key: DEFAULT_ANU_KEYS[0] (sealed import — 리터럴 금지). ★ TERMINAL_CALLBACK_ENABLED default off — 이 모듈은 호출될 때만 동작. ★ fail-open: 예외는 모두 내부 흡수, 항상 exit 0. ) annotationsN)datetimetimezone)Path)CallableListOptional)DEFAULT_ANU_KEYSlaunch_callbackNORMAL_SUCCESSFINISH_BLOCKED_EXTERNAL_DIRTYFINISH_BLOCKED_SCOPE_VIOLATIONFINISH_BLOCKED_GIT_GATE QC_FAILEDUNKNOWN_FINISH_FAILUREterminal_state_envelope_v1 6937032012z+5mc tjdd|ddgddd}|jj}|r|SdS#t$rYywxYw) Ngitz-Cz rev-parseHEADT capture_outputtexttimeoutunknown) subprocessrunstdoutstrip Exception) workspaceresultshas ^/home/jay/workspace/.worktrees/task-2729+7-dev1/scripts/harness/v36/terminal_state_callback.py _get_head_shar&/s] D)[& 9dB mm!!#s(y( s;AA A  A c. t|}|d}t|j|}|rMt|dd5}t j |}dddj dd}|r t|Sy#1swY)xYw#t$rYywxYw)Nz.dispatched-*.jsonutf-8encoding schedule_idr) rsortedglobopenjsonloadgetstrr!) events_dirtask_ideventspatternmatchesfdatasids r%_get_attempt_idr=?s  j!I/0W-. gbkG4 $yy| $((="-C3x  $ $    s(9E266~yQ +% %  >95  ;  $ $    s).DDBDD D DDc|t|jr td|gfSt|}||dz }|jrtdt |gfS||dz }|jrt dt |gfS||dz }|jrt dt |gfS||dz }|jrC t|d5}|j} d d d d  vsd | vrt dt |gfS ||d z } | jr\ t| d5}|jjj} d d d  d k(rtdt | gfS tdgfS#1swYxYw#t$rYwxYw#1swYFxYw#t$rY;wxYw)z2Returns (terminal_state, success, evidence_paths).Tz.external-dirty-blocker.jsonFz.scope-violation.jsonz.git-gate-blocker.jsonrBr)r*NGIT_GATE uncommittedz .qc-resultFAIL)rrGr r r4rrr0readr!r upperrr) r5r6 done_filer7 ext_dirty scope_violgit_gatecallback_causer:content qc_resultqc_texts r%_determine_terminal_staterYs Iti[00 * FG9$@AAI,ec)n5EEEWI%:;;J-us:6GGG7)#9::H&H >> )=>>N nw7 #1&&( #W$ (@.N8K7LLL)A G9J//I i'2 3a&&(..*002 3&  %#i.)999! "5" ,,' # #    3 3   sT FF'"F$ F/1-F#F/F F F F #F,(F// F;:F;c idtd|d|d|d|dt|jd|d|d |d dd |d d ddd| d| dddtjt j jS)Nschemar6 attempt_idrHsuccess done_createdrCrEhead_sha pr_numberevidence_pathscollector_roleANUowner_key_sealedTcallback_registered dedupe_key emitted_byz3finish-task EXIT trap -> terminal_state_callback.pyts)ENVELOPE_SCHEMArrGrnowrutc isoformat r6r\rHr]rQrCrEr_rarerfs r%_build_enveloperns / 7  j  .   7   Y..0     {  H  T  .  %  D  2  j  K! " hll8<<(224# c.d|dd|dddtdtd|d d |d d |d d|dg}dj|}t|j ddkDr-|dd}|j d |d dj|}|S)u9envelope-only prompt (key=value lines, §5.6 compliance).ztask_id=r6zcollector_role=rbzcallback_kind=normalzchat_id=zat=zcanonical_root=z-source_attribution=terminal_state_envelope_v1zsummary=terminal_state=rHz attempt=r\z success=r] r)i<N) _ANU_CHAT_ID _CALLBACK_ATjoinlenencodeappend)envelopecanonical_rootlinesprompts r% _build_promptr}s 8I&'( (#3456  <.! l^ .)* 7 !(+;">$t$ KKroc t||dz }|jrytjj dd}t t td}|hddd|tjtjjd } t|d d 5} tj| | d dddy t#||} t%d|||t&| t(|} | j*rdd| j,|tjtjjd} t|d d 5} tj| | d dddy |r|dd dt/| j*|tjtjjd} t|d d 5} tj|| d dddy ||nt0} || j*}ddt/| j*|j2tjtjjd}t|d d 5} tj|| d dddy#1swYy xYw#t $rYy wxYw#1swYy xYw#t $rYy wxYw#1swYy xYw#t $rYy wxYw#1swYyxYw#t $r}dd||tjtjjd} t|d d 5} tj| | d dddn #1swYnxYwn#t $rYnwxYwYd}~y d}~wwxYw)usReturns True if successfully registered. Updates envelope in-place. canonical_root: 상위(emit)에서 전달받은 workspace — 하드코딩 금지(회장 9-1/9-3). runner: 실제 등록 backend 주입점. None 이면 _default_callback_runner(실제 cokacdir). dry_run: True 면 실제 등록 backend 호출 0 (테스트/스모크 — 회장 9-7/9-8). z".terminal-callback-registered.jsonTCOKACDIR_KEY_SELFzexecutor-self-unknownNNOT_REGISTERED NO_OWNER_KEYu<DEFAULT_ANU_KEYS empty — fail-closed, no cron registration)statusrDdetailr6rhwr)r*F) ensure_asciinormal)kindr6 executor_key owner_keychat_idr|atrzz fail-closed)rrDverdictr6rhDRY_RUNu'dry_run — no actual cron registration)r registeredrDargv_lenr6rh REGISTERED)rrdr returncoderhzcron subprocess error: )rrDr6rh)rrGosenvironr3nextiterr rrjrrkrlr0r1dumpr!r}r rsrtrrrvrr)r5r6ryrzrunnerdry_runregistered_markerrrno_ownerr:r|decisionnot_reg dry_result run_backendr# reg_resultexcs r%_register_callbackrsSZ(gY6X+YY!::>>"57NOLT*+T2I&$T,,x||,668   'w? ;1 (AE: ; 8^ 4F ! % H}}'#'',,x||,668   'w? :1 '159 :?HMM*,,x||,668   'w? =1 *ae< =#.&4LKX]]+" $HMM* ++,,x||,668  #S7 ; 9q IIj!% 8 9E ;   8 :    =    9  '/u5,,x||,668    'w? :1 '159 : : :    sJ$J =J;J1 J%"J19K K K 4A4K'(KK' JJJ J"!J"%J.*J1.J11 J=<J=K K K KKK$ K'$K'' N09M;*M'8M M'M# M'&M;' M30M;2M33M;;Nc Rt|}|jdd||dz }||dz } tjt |tj tj ztjzd} tj| |jryt|||\} } } | tk(rxt||} t|}t||| \}}|d| d| }t!|| | d||||| d| }t|d d 5}t#j$||dd dddyt||} t|}t||| \}}|d| d| }t!|| | d||||| d| }t|d d 5}t#j$||dd dddt'||||||}||d<t|d d 5}t#j$||dd dddy#t$rYywxYw#1swYyxYw#1swYkxYw#1swYyxYw)uCore emit: 판정 → envelope → callback 등록. workspace: canonical_root 로 하류(_register_callback/_build_prompt) passthrough. runner/dry_run: 실제 cron 등록 backend 주입/우회 (테스트·스모크 경로). T)parentsexist_okz.terminal-state.jsonz.terminal-emit-lockiN:Frmrr)r*)rindent)rzrrre)rmkdirrr0r4O_CREATO_EXCLO_WRONLYcloseOSErrorrGrYr r=r&rJrnr1rr)r6r5r"rQrrr7 envelope_path lock_pathlock_fdrH_successrar\r_rCrErfryr:rs r%emitrsx* F LLL-y(<==MG9$788I''#i."**ryy*@2;;*NPUV  0IGY0,NHn '$Z9  +3JX{y*Q~.>? "!)#) %!  -w 7 A1 IIha @ A!W5JY'H/ G^TE;9Aj\>*:;J %%! H mS7 3=q (AE!<=$JR[djt{|J'1H "# mS7 3=q (AE!<==M B A6====s6A%G6H HH6 HHHHH&c tjdd}|jdd}|jd}|j dd |j d d |j d d |j d d |j d dd|j |}|j dk(rBt|j|j|j|j|jy#t$rYywxYw)Nzterminal_state_callback.pyz)task-2724 terminal state callback emitter)prog descriptioncmdT)destrequiredrz --task-id)rz --events-dirz --workspacez --done-filez --dry-run store_trueF)rFdefault)r6r5r"rQrr)argparseArgumentParseradd_subparsers add_parser add_argument parse_argsrrr6r5r"rQrr!)rparsersubepargss r%mainrs ((-C ###> ^^F #  d3 6  5  5  L%H  & 88v   ??....       sC=D D  D __main__)r"r4returnr4)r5r4r6r4rr4)r5r4r6r4rHr4rztuple[str, str])r5r4r6r4rQr4rztuple[str, bool, list])r6r4r\r4rHr4r]boolrQr4rCr4rEr4r_r4ralistrerrfr4rr>)ryr>rzr4rr4)rr)NF)r5r4r6r4ryr>rzr4rOptional[Callable]rrrr)r6r4r5r4r"r4rQr4rrrrrNone)N)rzOptional[List[str]]rint)*__doc__ __future__rrr1rrrrpathlibrtypingrrr (dispatch.normal_fallback_callback_helperr r r r rrrrrirsrtr&r=r?__annotations__r@rJrYrnr}rrrr__name__ SystemExitror%rs{ # '++ " ?!A3  1/   *-!#H"$D8 #C (!#I"$D@ *: d!3661-1- 1-1- 1-p       L<L"& rr rr r  r  r r|"& ^= ^=^=^= ^=  ^=  ^= ^=J : z TV ro