ݦj{&RdZddlmZddlmZmZddlmZmZm Z dZ hdZ dZ dZ d Zd Zd ZGd d eZGddeZGddeZGddeZedGddZddZd dZ d!dZde edd d"dZy)#uPR Open Watcher Auto-Wrapper — task-2643 Track C (dry-run only · live 호출 0). 목적: PR open 직후 ANU 본체가 `gh pr view` 폴링 욕구를 갖지 않도록, PR 생성 + watcher_contract_v1 자동 발급 + watcher dispatch 등록을 한 함수로 묶는다. 본 모듈은 **dry-run 만 수행**한다 (회장 verbatim): - live `gh pr create` 호출 0 - live `cokacdir --cron` 호출 0 - 모든 외부 효과는 mock callable 로 주입받는다 (regression test 친화). 호출 사이트가 ANU 본체일 때: - watcher_owner 가 ANU 본체 식별자면 즉시 fail (owner 위장 차단). - collector_role 이 "ANU" 가 아니면 fail (collector_role 위장 차단). - 위 검사 통과 시 contract 생성 + (mock) dispatch → schedule_id 반환. bzaona6au 사건 (PR #145) 재현 fixture 를 fixture 폴더에서 동일 wrapper 로 재현하여 fail-closed 동작을 박제한다. ) annotations) dataclassfield)AnyCallableOptionalc119085addb0f8b7>ANUanuANU_MAINanu_main ANU_SESSION anu_sessionr ) MERGE_READYCHAIR_REQUIREDGEMINI_EXTERNAL_TRIGGER_STALECI_FAILED_NON_REMEDIABLE LOOP_BOUNDARY)delivery_outcome miss_causeroot_cause_tagscanonical_rootregistration_statusi zanu.watcher_contract.v1ceZdZdZy)PrOpenWatcherWrapperErroru공통 베이스.N__name__ __module__ __qualname____doc__N/home/jay/workspace/.worktrees/task-2643-dev6/utils/pr_open_watcher_wrapper.pyrrEsr"rceZdZdZy)OwnerImpersonationErroru3owner 가 ANU 본체 식별자로 위장한 경우.Nrr!r"r#r%r%Is=r"r%ceZdZdZy)CollectorRoleViolationErroru6collector_role 위장 (anu_watcher / anu_polling 등).Nrr!r"r#r'r'Ms@r"r'ceZdZdZy)LiveCallViolationErroruRdry_run=True 인데 live mock 이 실제 호출을 시도한 경우 (mock 가드).Nrr!r"r#r)r)Qs\r"r)T)frozenceZdZUded<ded<ded<ded<ded<d Zd ed <d Zded <dZded<dZded<ee Z ded<y) WrapperResultint pr_numberstrhead_shawatcher_schedule_id watcher_ownerdict[str, Any]contractTbooldry_runrlive_calls_emittedNz Optional[str]rejection_reasonrejection_detail)default_factoryz list[str]notes) rrr__annotations__r6r7r8r9rlistr;r!r"r#r,r,ZsXNMGT&*m*&*m*T2E92r"r,c|r|js td|jtvrtd|dy)Nzowner must be non-empty stringzowner='u?' is an ANU self-identifier — ANU 본체 위장 폴링 차단)stripr%ANU_SELF_IDENTIFIERS)owners r#_validate_owner_not_anurBmsG  %&FGG {{},,%eW[ \  -r"c@|tk7rtd|dty)Nzcollector_role='u' 위장 폴링. ALLOWED=)ALLOWED_COLLECTOR_ROLEr')collector_roles r#_validate_collector_rolerFvs1//)~..GH^Ga b  0r"c tt|||tt|dtttdd|t d|d S)NANU_NORMAL_CALLBACK)type owner_key envelope_axesDEDUPE_ON_PR_HEAD_SHAT) schematask_idr.r0terminal_states ttl_secondscallback_targetduplicate_policyrArEcallback_only_reportingwatcher_owner_kind)CONTRACT_SCHEMA_IDr=DEFAULT_TERMINAL_STATES ANU_OWNER_KEYDEFAULT_ENVELOPE_AXESrDrNr.r0rArPrTs r#_build_contractrZ}sK% 78")&!"78 40#'0! r"dev_bot)rTrErPr6c d| dur tdt|t|||||d} t| ts!t dt | jt| d} t| d} t| dk7rt d t| t|| | ||| }| |d }t|ts!t d t |jt|d }|s t ddd| ddd| d|ddg}t| | |||dddd| S)uaPR open + watcher dispatch 를 묶어 ANU 가 직접 polling 할 욕구를 없앤다. Args: task_id: 발사 주체 task id (예: task-2643). branch: PR head branch name. title: PR title. body: PR body. owner: watcher 발사 주체 (dev bot name 또는 cron-watcher-*). watcher_owner_kind: "dev_bot" | "cron_watcher". collector_role: callback collector role. "ANU" 만 허용. ttl_seconds: watcher TTL (sec). gh_pr_create: gh pr create 호출자 (regression 에선 mock). 반환: {"pr_number": int, "head_sha": str (40hex)} watcher_dispatch: watcher dispatch 호출자 (regression 에선 mock). 반환: {"schedule_id": str} dry_run: True 면 mock 만 호출. False (live) 는 본 task 범위에서 호출 0. Returns: WrapperResult. FuLdry_run=False is forbidden in task-2643 scope (live `gh pr create` 호출 0)T)branchtitlebodyr6z#gh_pr_create must return dict, got r.r0(z'head_sha must be 40 hex chars, got len=rY)r4r6z'watcher_dispatch must return dict, got schedule_idz+watcher_dispatch returned empty schedule_idz?PR open + watcher dispatch completed in dry-run (live calls=0).zwatcher contract head_sha=Nz pr=#z ttl=zs.uGANU 본체는 본 PR 의 CI/Gemini 를 직접 polling 하지 않는다.r) r.r0r1r2r4r6r7r8r9r;) r)rBrF isinstancedictrrIrr-r/lenrZr,)rNr]r^r_rArTrErP gh_pr_createwatcher_dispatchr6 pr_resultr.r0r4dispatch_resultrar;s r#open_pr_and_dispatch_watcherrjsD%$ Z  E"^,F%dDQI i &'1$y/2J2J1K L  Ik*+I9Z()H 8}'5c(m_ E  - H'$GO ot ,'5d?6K6T6T5U V  om45K '(UVV J $Xbq\N% {% }TVW Q E '  r"N)rAr/returnNone)rEr/rkrl)rNr/r.r-r0r/rAr/rPr-rTr/rkr3)rNr/r]r/r^r/r_r/rAr/rTr/rEr/rPr-rfCallable[..., dict[str, Any]]rgrmr6r5rkr,)r __future__r dataclassesrrtypingrrrrWr@rDrVrXDEFAULT_TTL_SECONDSrU Exceptionrr%r'r)r,rBrFrZrjr!r"r#rss&#(** # . >7>A";A]6] $ 3 3 3$         P(0*^ ^ ^  ^  ^  ^^^^0^4^^^r"