QjIUdZddlmZddlZddlZddlZddlmZmZddl m Z ddl m Z m Z mZmZmZdZdZeehZd ed <d Zd Zd ZdZdZdZeeefZdZdZdZe dZ edefedefedefiZ!eGddZ"d1dZ#d2dZ$d2dZ%d2dZ&dZ'de(ed d d!d" d3d#Z)d$de(ed% d4d&Z*e(ed' d5d(Z+de(ed) d6d*Z,e(ed' d7d+Z-d8d,Z.gd-Z/e0d.k(r%ddl1Z2e3e2jhe.d!d/0yy)9uutils.callback_collector_helper_integration — task-2646 helper 통합 wiring (v2). task-2644+1 ANU_CALLBACK_COLLECTOR_CONTROL_PLANE_CLEAN_REPLACEMENT spec (read-only 참조): memory/specs/system_anu_callback_collector_control_plane_spec_260524.md task md: memory/tasks/task-2644+1.md (sha256 b79d6f150d3f44cc0971824b94b62b348d452a5aa905d98ed5a8614d49e7e5dd) ★ 본 module 은 v2 control-plane 산출물들이 task-2646 helper 3종을 - utils.callback_registration.register_callback / verify_actual_owner - utils.callback_authority_validator.validate_authority - utils.callback_source_cross_checker.cross_check_sources 를 단일 진입점으로 사용하도록 강제하는 wiring layer. task md 11 필수 원칙 (1:1): 4. task-2646 helper/authority validator 기준 필수 5. ANU key actual owner 검증 필수 (등록 직후 actual schedule owner key == c119085addb0f8b7) 6. self-key callback 이면 즉시 FAIL (SELF_COLLECTOR_FORBIDDEN) 7. 4 source cross-check 필수 (schedule_history + cron-history + envelope + result artifact) 10. registration helper bypass 시 fail-closed helper 부재 시 fail-closed: HELPER_INTEGRATION_BYPASS state 로 강제 종료. ) annotationsN) dataclassfield)Path)AnyDictListOptionalSequencez.utils.callback_collector_helper_integration.v1c119085addb0f8b7 frozensetDEFAULT_ANU_KEYSzutils.callback_registrationz"utils.callback_authority_validatorz#utils.callback_source_cross_checkerz(_task_2646_helpers.callback_registrationz/_task_2646_helpers.callback_authority_validatorz0_task_2646_helpers.callback_source_cross_checkerHELPER_INTEGRATION_OKHELPER_INTEGRATION_BYPASSSELF_COLLECTOR_FORBIDDENz-/home/jay/workspace/.worktrees/task-2646-dev3zcallback_registration.pyzcallback_authority_validator.pyz callback_source_cross_checker.pycreZdZUded<ded<ded<ded<ded<ee Zded <d Zd ed <ddZy )IntegrationStatusstrschemabool availablestatez List[str]helpers_loadedhelpers_missing)default_factoryreasonsN Optional[str]fallback_path_usedc|j|j|jt|jt|j t|j |jdS)Nrrrrrrr)rrrlistrrrr)selfs B/home/jay/workspace/utils/callback_collector_helper_integration.pyto_jsonzIntegrationStatus.to_jsonKsRkkZZ"4#6#67#D$8$89DLL)"&"9"9  returnDict[str, Any]) __name__ __module__ __qualname____annotations__rr!rrr$r%r#rrAs< KO Jt4GY4(, ,  r%rc|tjvrtj|Stjj |t |}| |j ytjj|}|tj|< |j j||S#t$r"tjj|dwxYw)zLoad a helper module by absolute file path under an alias namespace. Returns the loaded module or None on failure. Registers under both the alias and the canonical helper name so callers using either work. N) sysmodules importlibutilspec_from_file_locationrloadermodule_from_spec exec_module Exceptionpop)alias file_pathspecmodules r#_load_from_filer=Ws   {{5!! >> 1 1%Y HD |t{{* ^^ , ,T 2FCKK ' M  t$ s B..+Cc g}g}g}d}tD])} tj||j|+|rt j rtt }g}t|D]}t|\}} t dz |z } | js'|j||jd| dR t| | } | '|j||jd| d| tj|<|j||}|}|rttd t |||d gz| Sttd t"|g|| S#t$r3}|j||jd|d|Yd}~d}~wwxYw#t$r3}|j||jd|d |Yd}~bd}~wwxYw)Nzprimary import z failed: utilszfallback file z missingz!fallback spec_from_file_location(z) returned Nonezfallback import z from file failed: FzHELPER_INTEGRATION_BYPASS: required task-2646 helpers are unavailable; registration must be considered fail-closed (task md ANCHOR-2 violation).r T)REQUIRED_HELPERSr1 import_moduleappendr7_FALLBACK_WORKTREEis_dirrr! _HELPER_FILESis_filer=r/r0rSCHEMAINTEGRATION_BYPASSINTEGRATION_OK) loadedmissingr fallback_usednameexc fallback_str still_missingfilenamer9 helper_filer<s r#_try_import_helpersrSlsFGG#'M E E  # #D ) MM$ E%,,.-. #% M TD+D1OHe,w6AK&&($$T* }HEF T( <>!((.NN%F{mSb#cd$* D! d# , ! T(  $!#0 -   ( Y E NN4 NN_THIcUC D D E0 T$$T*!1$9LSERSS Ts5&E4F5&F F"(FF G!(GGctS)z1Public probe used by hooks/adjudicator/runner v2.rSr-r%r#integration_statusrVs   r%ct}|S)zEagerly import helpers. Returns IntegrationStatus; raises only if truly unavailable (callers handle BYPASS as fail-closed).rU)statuss r#require_helpersrYs! "F Mr%ct}|jsd|fStjt}tjt }tjt }|||f|fS)N)rYrr1rAHELPER_REGISTRATIONHELPER_AUTHORITYHELPER_CROSS_CHECK)rXregauthcrosss r# _get_modulesrasb  F   V|  ! !"5 6C  " "#3 4D  # #$6 7E u v %%r%z/home/jay/workspaceTF)canonical_rootanu_keysrequire_envelope dispatch_pathdirect_cron_pathc ht\} } | (tdt| j| jdS| d} |t k(rtdt | jdgdS| jd||t t||||||||  } | j}| j|d<|S)uANU normal callback 등록 (helper integration 단일 진입점). Caller MUST pass executor_key == 본 봇의 self key. owner_key 는 항상 ANU_KEY 로 강제됨 (self-key 발사 금지). FAILrverdictrrVrruuexecutor_key == ANU_KEY: collector self-key registration is forbidden by task md 원칙 6 (SELF_COLLECTOR_FORBIDDEN).normal) kindtask_id executor_key owner_keychat_idpromptatrbrcrdrerfrV) rarGrHr$rANU_KEYrregister_callbackr)rmrnrprqrrrbrcrdrerfr0rXr^resultpayloads r#register_normal_callbackrws$#nOGV'"(.."2~~    !*Cw-"(.."2L   " " !G  %)#)# FnnG$*NN$4G ! Nr%ANU) observed_roleexpected_chat_idrcc:t\}}|(tdt|j|jdS|d}|j |j dd|j dd|j d|j|j d d |j d d |j d tt|j dd t|j dd|j dd|j d|j d|j dt|j dg|j d} |j| |||||} | j} |j| d<| S)uregister_normal_callback 의 결과를 입력으로 받아 actual owner 검증. 회장 원칙 5: 등록 직후 actual schedule owner key 가 ANU_KEY 인지 검증. rhrirrzutils.callback_registration.v1rjPASSrrlrkrmrorpprompt_utf8_bytesprompt_byte_classification OK_TARGETargvlaunch_decisionauthority_markerrregistered_at_iso)rrjrrlrmrorpr~rrrrrr)registration_resultobserved_owner_keyobserved_chat_idryrcrzrV) rarGrHr$rRegistrationResultget#STATE_DISPATCH_SUBMITTED_UNVERIFIEDrsrintr!verify_actual_owner) registration_payloadrrryrzrcr0rXr^rrverifiedrvs r# verify_ownerrs#nOGV'"(.."2~~    !*C  #''2RS$((F;"&&w0W0WX ! % %fh 7$((B7&**;@(,,Y;<2667JANO#7#;#; (+$ " % %f -,001BC-112DE)--i<=.223FG!  B$&&-)#) 'H G$*NN$4G ! Nr%)rcct\}}|(tdt|j|jdS|d}|j ||||}|j}|j|d<|S)Nrhri)envelope_collector_keyactual_owner_keyrnrcrV)rarGrHr$rvalidate_authority) rrrnrcr0rXr_rjrvs r#validate_callback_authorityr5s#nOGV'"(.."2~~    1:D%%5)! &G ooG$*NN$4G ! Nr%)cron_list_presentrcc t\}}|(tdt|j|jdS|d} | j |||||||} | j} |j| d<| S)Nrhri)cron_idschedule_history_recordscron_history_recordsenveloperesult_artifactrrcrV)rarGrHr$rcross_check_sources) rrrrrrrcr0rXr`rurvs r#cross_check_four_sourcesrQs#nOGV'"(.."2~~    AJE  & &!91'+'FnnG$*NN$4G ! Nr%ctt}t|j}|jstdt |j |dS|+|jdtdd|j |dS|jdxs|jd}||k(r3|jd|dtdt|j |dS|t|vr;|jd|d t|d tdd |j |dStd d |j ||dgzdS)u6SessionStart hook 직후 collector 가 호출하는 single contract check. Combines: helper availability + envelope presence + self-key forbidden gate + envelope.collector_key authority pre-check (envelope-only — actual owner verification still requires verify_owner after schedule lookup). rhriuenvelope is None — collector 의 7 단계 중 1 단계 (envelope parse) 불가; SAFE_DEGRADED_MODE 또는 HOLD_FOR_CHAIR 강제 (task md 원칙 11).ENVELOPE_MISSINGro collector_keyzenvelope owner_key=uA == executor_key — SELF_COLLECTOR_FORBIDDEN (task md 원칙 6).u ∉ anu_keys=uH — authority pre-check FAIL (verify_owner still required post-lookup).ENVELOPE_OWNER_NOT_ANUr|ENVELOPE_PRECHECK_PASSu_envelope owner_key ∈ anu_keys AND != executor_key; proceed to schedule lookup + verify_owner.)rrjrrVenvelope_owner_keyr) rVr!rrrGrHr$rBrrset)rrnrcrXrenvelope_owners r# validate_spawn_callback_contractrssu !Ffnn-G   '"(.."2    [ '"(.."2   \\+.O(,,2ON%!.!34; ; -"(.."2   S]*!.!3>$x.AQRV V -"(.."2   )$nn., 9   r%c~g}t}|jsE|jd|jd|jt d|d|j dStdd}|dd k7s|d d k7r|jd |td did}|d tk7r|jd|td tid}|ddk7r|jd|tdtdddd}|d tk7r|jd|tttd}|jddk7r|jd|tdgiddd}|jd dk7r|jd|t t|dk(|d |j dS)!Nz(helper integration unavailable: missing=z reasons=Fr)rokfailures tests_runrVabc)rrnrjrhrrz"spawn contract None envelope: got roz self-exec-keyzself-key envelope: got z other-keyr|zANU envelope passthrough: got zt-self0x10m)rmrnrprqrrrdzregister self-key: got )rrrnzauthority ANU/ANU: got zzz)rrrrrrCALLBACK_MISSINGzcross_check missing: got r)rVrrBrrrGr$rrrsrwrrrlen)rrXr1r2r3r4r5r6s r#selftestrsH  !F   6v7M7M6NO~~& (  "(.."2    *4e LB )}"W+1C"C "   B '{..1"67 %&   B  vviF"1"67 "!#  B vvg,,3B489(mq $nn.  r%)rGrsrrIrHrrrVrYrwrrrrr__main__r) ensure_asciiindent)r9rr:r)r'r)rmrrnrrprrqrrrrrbrrc Sequence[str]rdrrerrfrr'r()rr(rrrrryrrzrrcrr'r() rrrrrnrrcrr'r()rrrzList[Dict[str, Any]]rzDict[str, List[Dict[str, Any]]]rOptional[Dict[str, Any]]rrrzOptional[bool]rcrr'r()rrrnrrcrr'r(r&)5__doc__ __future__rr1importlib.utilr/ dataclassesrrpathlibrtypingrrr r r rGrsr rr,r[r\r]_ALIAS_REGISTRATION_ALIAS_AUTHORITY_ALIAS_CROSS_CHECKr@rIrHrrCrErr=rSrVrYratuplerwrrrrr__all__r)json_jsonprintdumpsr-r%r#rs.# (66 : ' 2)237:ADG')9;MN(05IJ46IJ8:JK;=OP      **>B! &"0#$45!"9 99 9  9 9999999B&*#$453(33 3  3 $ 333v$$45      F)-#$45 3:  '  . &L$$45 I&II I  IXM` & z +%++hjuQ ?@r%