~i)HUdZddlmZddlZddlZddlZddlmZmZddlm Z ddl m Z e ejjddZed z d z d z Zd Zd ed<GddeZddZddZddZddddd ddZddd ddZy) uXGitHub merge_queue 진입 클라이언트. admin override / force merge / bypass 차단.) annotationsN)datetimetimezone)Path)AnyWORKSPACE_ROOTz/home/jay/workspacememoryzorchestration-auditzmerge-queue.jsonl)z--adminzadmin overridez force-mergebypassztuple[str, ...]ADMIN_FLAG_KEYWORDSceZdZdZy)MergeQueueErroruAmerge queue 진입 실패 또는 admin override 차단 시 raise.N)__name__ __module__ __qualname____doc__I/home/jay/workspace/.worktrees/task-2481-dev4/utils/merge_queue_client.pyr r sKrr cftjtjj dS)Nz%Y-%m-%dT%H:%M:%SZ)rnowrutcstrftimerrr_nowrs! << % . ./C DDrc 4tj|fddd|S)u기본 subprocess.run 래퍼.T)capture_outputtext) subprocessrun)cmdkwargss r_default_runnerr!s >># Hd H HHrc|sy|D]<}|j}tD]!}|j|vsd|d|dccS>y)uargs에 admin override 흔적이 있으면 사유 string 반환, 없으면 None. ADMIN_FLAG_KEYWORDS 중 하나라도 args 내 문자열에 포함되면 차단. Nu"admin override 키워드 감지: 'z ' (keyword='z'))lowerr )argsarg arg_lowerkws rdetect_admin_override_attemptr(s` TIIK % TBxxzY&;C5 RDPRSS TT rTF) bot_tokenno_admin_overridedry_runrunnerc ||t}|s tdtjj ddk(}|rtjj dnd}|rtjj dnd}i}|r||d<|r|} d} d } d } d } g}n |d d dt |ddgditj|}|j dk7r,td|d|jddj tj|jxsd}|j dxsij dd } |j dd } |j dd } |j dd } |j dd } |j dxsg}|r tj|}dd lm}m}|| s!t#|| d d!d"| |#td$| d%dd&lm}|}g}|D]n}|j dxsij dd }|j dd }|j'd'k(sN |||r||vr^|j)|p|s!t#|| d d!d(| |#td)|d*|d}| r;| j'd+vr)t#|| |d!d,| | || | - td)|d.| d/| r;| j'd0vr)t#|| |d!d1| | || | - td)|d2| d3|r0t#|| |d!d4| d5| | - t+|| |d!d4| d5| | d6 }|d!d4|d7Sd d d8t |d9d:d;g}||d| | - td?|d|jddjd@}t#|| |d!|| d>| | - t+|| |d!|| | | dA }|d!||d7S#tj$r}td||d}~wwxYw#t$rYnwxYw#t$rYr3BLOCKED_PR_STATE_) rHr=rIrJrKrLr+r@merge_state_statusz state='u' (OPEN 필요)>UNKNOWNr4BLOCKED_MERGEABLE_z mergeable='u' (MERGEABLE 필요)DRY_RUNT tsrHr=rIrJrKrLr+r@rQ)rHrJrK audit_entrymergez--mergez--autoz--delete-branchxFAILEDFugh pr merge 실패 (PR #ENQUEUED) rVrHr=rIrJrKrLr@rQ)r!r osenvirongetstr returncodestderrstripjsonloadsstdoutJSONDecodeError Exceptionutils.bot_pr_authorrDrE _append_auditrMupperappendr)rHr)r*r+r, _test_modereviews_override_rawauthor_overrideenv_with_token pr_authorpr_stater@rQrLlatest_reviewsprocpr_dataexcrDrErMallowed_humanshuman_approved_reviewsreviewreviewer_loginr?rIrW merge_cmd merge_procrKs r enqueue_prr|-sc$~   i   34;JLV2::>>*GH\`FPbjjnn%ABVZO&(N%.z"#  $/1dFC N\ 02::00   ??a !))C DE8J8P8P8R7ST  Tjj!45G[[*0b55grB ;;w+KK R0 $[[);R@;;|R0 _5; !ZZ(<=N F  # B&>w %i[1: ;  23N  **X.4"99'2F 7B' ;;=J & ">2!nN&J&--n=  " B&Aw yk*3 4  &a(HHNN$H4 H(9(&Dw4F  yk(? K  Y__&.FF H(:9+&Fw4F  yki[@T U   Hit4F  &yI I) T":L  # &    dGS^8.I ,rzz ,^ ,J ! Hgu4F  &ykZ5F5Ftu5M5S5S5U4V W  GI'50B f9  g6H K"  i## T!$CC5"IJPS S T   B  sB?#O4'P P.P.4PPP P+*P+. P;:P;r6)r@rQc tjjddt|||||||||d } tj dd5} | j t j| dd zd d d y #1swYy xYw) u,audit jsonl에 merge queue 이벤트 기록.T)parentsexist_okrUazutf-8)encodingF) ensure_ascii N)MERGE_QUEUE_LOGparentmkdirropenwritercdumps) rHr=rIrJrKrLr+r@rQrecordfs rriris   =f0 F   cG  4?  66=>???s *BB )returnr_)rz list[str]r rrzsubprocess.CompletedProcess)r$zlist[str] | Noner str | None) rHintr)rr*boolr+rrzdict[str, Any])rHrr=r_rIr_rJr_rKr_rLr_r+rr@r_rQr_rNone)r __future__rrcr\rrrpathlibrtypingrr]r^ WORKSPACErr __annotations__rgr rr!r(r|rirrrrs1^" '  02GH I h&)>>ATT']_]LiLEI $!"  UUU U  UUB ?? ? ?  ?  ????? ?r