j\UdZddlmZddlZddlZddlZddlZddlmZmZddl m Z ddl m Z gdZ ded <e Dcgc]!}ej|ej |f#c}Zd ed <ejd ej d fejdej dfejdej dfejdej dfgZd ed<e dZddZddZd d!dZd"dZddd d#dZdd d$dZycc}w)%uGutils/recoverable_block_classifier.py — recoverable merge block 분류기. task-2472 구현 3: RECOVERABLE_BLOCKED state 분류기. branch protection merge block을 FAILED(terminal)가 아니라 RECOVERABLE_BLOCKED로 올바르게 분류. 매칭 우선순위: merge_state_status > unresolved_threads > error_message regex. ) annotationsN)datetimetimezone)Path)Optional)z&base branch policy prohibits the merge!required_review_thread_resolutionzunresolved review threadrequired checks pending mergeStateStatus[\s:=\"]+BLOCKEDz!review thread resolution requiredz list[str]RECOVERABLE_PATTERNSzlist[tuple[re.Pattern, str]]_COMPILED_PATTERNSzbase branch policyBRANCH_PROTECTIONz\required_review_thread_resolution|unresolved review thread|review thread resolution requiredUNRESOLVED_THREADr REQUIRED_CHECKS_PENDINGr MERGE_STATE_BLOCKED_PATTERN_CATEGORIESz8memory/orchestration-audit/recoverable-merge-block.jsonlcftjtjj dS)Nz%Y-%m-%dT%H:%M:%SZ)rnowrutcstrftime9/home/jay/workspace/utils/recoverable_block_classifier.py_now_isor6s! << % . ./C DDrctj|dd}tj|j dj S)NTF) sort_keys ensure_asciiutf-8)jsondumpshashlibsha256encode hexdigest)record serializeds r_evidence_hash_strr&:s7FdGJ >>*++G4 5 ? ? AArc\|xs)ttjjddS)NWORKSPACE_ROOTz/home/jay/workspace)rosenvironget workspaces r_workspace_rootr.?s#  URZZ^^,<>STUUrctD]S\}}|j|sd}tD]+\}}|j|s|j|s)|}nd||fcSy)ujerror_message에서 recoverable 패턴 매칭. Returns (recoverable, category, matched_pattern). UNKNOWNT)Fr0N)r searchr) error_messagepatternpat_strcategorycat_patcat_names r_classify_by_patternr8Csp /+ >>- ( H%8 !>>'*gnn].K'H 7* *+ "r)merge_state_statusunresolved_threadsc|Bt|jj}|dk(rdddddS|dvr d d dd |d dS|bt|d kDrT|ddDcgc]/}t |t r|j ddn t|1}}ddddt|d|ddS|rt|\}}}|r d||d|ddSd d dddScc}w)u'merge block 원인 분류. 매칭 우선순위 (task-2472 명세): 1. merge_state_status == "BLOCKED" → MERGE_STATE_BLOCKED (recoverable) 2. unresolved_threads 비어있지 않음 → UNRESOLVED_THREAD (recoverable) 3. error_message regex 매칭 Parameters ---------- error_message: merge 실패 메시지 (gh pr merge 출력 등). merge_state_status: GitHub mergeStateStatus 값 ("BLOCKED", "MERGEABLE", "BEHIND" 등). unresolved_threads: unresolved thread 목록 (있으면 UNRESOLVED_THREAD로 분류). Returns ------- dict { "recoverable": bool, "category": str, # BRANCH_PROTECTION | UNRESOLVED_THREAD | ... "matched_pattern": str | None, "reason": str, } NBLOCKEDTrzmergeStateStatus=BLOCKEDucmergeStateStatus=BLOCKED → RECOVERABLE_BLOCKED (branch protection 또는 thread 미해결 상태)) recoverabler5matched_patternreason)r0DIRTYFr0zmergeStateStatus=u → non-recoverable FAILEDrid?rr:zunresolved thread u-건 존재 → RECOVERABLE_BLOCKED (threads: )u0error_message에서 recoverable 패턴 매칭: ''u=알 수 없는 merge 실패 원인 → non-recoverable FAILED)strupperstriplen isinstancedictr+r8) r2r9r: status_uppert thread_idsr=r5matcheds rclassify_merge_blockrPYsSB%-.446<<> 9 $#1%=   1 1$%#'-l^;VW  %#.@*AA*E(+ !+1d 3AEE$ Q ?   +3$S);%<$=>'L+   )=m)L& Xw #$#*LWIUVW  Q  5 s4Cr,c Xt}||||||||jdd|d } t| } i| d| i} t|} | tz } | j j ddtj| dd z}tjt| tjtjztjzd } tj||j!d tj"|| S#tj"|wxYw) u recoverable merge block audit 기록. memory/orchestration-audit/recoverable-merge-block.jsonl 에 line append. 필수 필드 10개: task_id, pr_number, actor, input_state, output_state, classification, error_message, reason, timestamp, evidence_hash r?) task_id pr_numberactor input_state output_stateclassificationr2r? timestamp evidence_hashT)parentsexist_okF)r ir)rr+r&r.AUDIT_JSONL_RELparentmkdirrrr)openrFO_WRONLYO_APPENDO_CREATwriter"close)rSrTrXrUrVrWr2r-rY base_recordev_hashr$ work_roottargetlinefds rrecord_block_auditrms" I"$(& $$Xr2 K!-G 6 6_g 6F *I  (F MMt4 ::f5 1D 8D VbkkBKK7"**De LB T[[)*  M  s %DD))returnrF)r$rKrnrF)N)r-Optional[Path]rnr)r2rFrnztuple[bool, str, Optional[str]])r2rFr9z Optional[str]r:zOptional[list]rnrK)rSrFrTintrXrKrUrFrVrFrWrFr2rFr-rornr)__doc__ __future__rr rr)rerrpathlibrtypingrr __annotations__compile IGNORECASEr rr^rr&r.r8rPrm)ps0rrzs# '#i"4 RZZ2==!1%40RZZ%r}}57JKRZZoqsq~q~BUVRZZ*BMM: