j]IdZddlmZddlZddlmZddlmZmZm Z m Z dZ dZ dZ d Zd Zd Zd ZGd deeZeZGddeeZGddeeZeej0j2ej4j2hZeej8j2ej:j2ej<j2hZedeDZ edeDZ!edeDZ"e Z#GddeeZ$ede$DZ%d$dZ&d%dZ'd%dZ(d&dZ)d&dZ*d'dZ+dZ,d(d Z-d)d!Z.d*d"Z/d+d#Z0y),u[utils.callback_envelope_schema — normal completion callback envelope schema. task-2635 — normal callback registration enforcement (Core hardening). task-2635+1 — status schema 5축 분리 정정 (회장 PARTIAL_PASS_WITH_REQUIRED_FIX). Spec: memory/specs/system_normal_callback_registration_implementation_spec_260523.md sha256: 0fbd1dad1e110c49474dfbdf13a21fb3bdd9c7f094128004dba8472840bb832d 회장 verbatim (task-2635 §1): 3. result.json 에 ``normal_callback_registration_status`` 필수화 4. status enum 정의 (5값) 5. ``NOT_REGISTERED`` / ``SENDFILE_ONLY`` 는 완료 성공으로 보지 않도록 fail-closed 회장 verbatim (task-2635+1 §1): 단일 ``registration_status`` 필드 의미가 흔들리므로 5축으로 분리한다. registration_intent · registration_attempted · registration_result_status · callback_delivery_status · collector_receipt_status ANCHOR-2 (task-2635+1): status schema 5축 분리 — 단일 필드 의미 흔들림 차단. ANCHOR-3 (task-2635+1): 모순 조합 (schedule_id 존재 + NOT_REGISTERED 등) regression FAIL 단언. ) annotationsN)Enum)AnyDictListTuplez!utils.callback_envelope_schema.v2z!utils.callback_envelope_schema.v1z/home/jay/workspacei<i i c119085addb0f8b7c$eZdZdZdZdZdZdZdZy)RegistrationResultStatusutask-2635+1 §1 정본 — 시도 결과 enum (5값). fail-closed 동작: REGISTERED / SKIPPED_WITH_EXPLICIT_REASON → 완료 성공 NOT_REGISTERED / SENDFILE_ONLY / REGISTER_FAILED → 완료 실패 REGISTEREDNOT_REGISTEREDREGISTER_FAILED SENDFILE_ONLYSKIPPED_WITH_EXPLICIT_REASONN) __name__ __module__ __qualname____doc__r r rrrR/home/jay/workspace/.worktrees/task-2729-p2-dev6/utils/callback_envelope_schema.pyr r 0s#J%N'O#M#A rr c eZdZdZdZdZdZdZy)CallbackDeliveryStatusu<task-2635+1 §1 — 봇→cokacdir→ANU 전달 단계 enum.PENDING DELIVERED UNDELIVEREDNOT_APPLICABLEN)rrrrrrrrrrrrrGsFGIK%Nrrc eZdZdZdZdZdZdZy)CollectorReceiptStatusu5task-2635+1 §1 — ANU collector 수령 단계 enum. UNCONFIRMEDRECEIVED TIMED_OUTrN)rrrrr r!r"rrrrrrQs?KHI%Nrrc#4K|]}|jywNvalue.0ss r r*jsJAJc#4K|]}|jywr$r%r's rr*r*ks!Ja!''!Jr+c#4K|]}|jywr$r%r's rr*r*ls IQ Ir+ceZdZdZdZdZdZy)DeliveryMethodanu_cron_callback sendfile_onlybothnoneN)rrrANU_CRON_CALLBACKrBOTHNONErrrr/r/ts+#M D Drr/c#4K|]}|jywr$r%)r(ms rr*r*{s AQ Ar+c|tjjSt|tr |jSt |j }|stjjS|S)uCoerce input to a string enum value (axis-3), defaulting → NOT_REGISTERED. spec §2 마지막 줄 — 미명시 시 자동 NOT_REGISTERED. )r r r& isinstancestrstrip) raw_statustexts rnormalize_statusr?~s_ '66<<<*67 z? "D '66<<< Krc|tjjSt|tr |jSt |j }|stjjS|S)uDAxis-4 normalizer. Missing → NOT_APPLICABLE (fail-closed default).)rrr&r:r;r<rawr>s rnormalize_delivery_statusrCX {%44:::#-.yy s8>> D %44::: Krc|tjjSt|tr |jSt |j }|stjjS|S)uDAxis-5 normalizer. Missing → NOT_APPLICABLE (fail-closed default).)rrr&r:r;r<rAs rnormalize_receipt_statusrFrDrc$t|tvS)ufail-closed 분기 단일 함수 (spec §3.2). True iff registration_result_status ∈ {REGISTERED, SKIPPED_WITH_EXPLICIT_REASON}. Unknown / missing → False (fail-closed default). )r?SUCCESS_STATUSES)statuss ris_success_statusrJs F #'7 77rc:t|}|tvry|tvS)z?True iff status forces executor exit != 0 + fallback no-cancel.T)r?FAIL_CLOSED_STATUSESALL_RESULT_STATUSES)rInorms ris_fail_closed_statusrOs$ F #D ## * **rcfddl}|j|dd}t|jdS)zFReturn the UTF-8 byte length of the canonical envelope representation.rNFT) ensure_ascii sort_keyszutf-8)jsondumpslenencode)envelope_jsonpayloads renvelope_utf8_byte_countrZs-kk($kGG w~~g& ''r) task_id executor_name result_path report_pathattempted_callback_registrationregistration_statusregistration_result_statusregistration_intentregistration_attemptedcallback_delivery_statuscollector_receipt_statusdelivery_methodcrd|vrt|jdSt|jdS)zRead axis-3 from an envelope, preferring the new field but accepting the legacy ``registration_status`` for backward-compat callers.rar`)r?get)rWs r _axis_3_valueris6$x/ -I JKK HLL)>? @@rcRt|tsdgSg}t|}t|j d}t |j d}|j d}t |j d|j d}t |j d}|tjjk(r|r|jd|tjjk(r|s|jd|sK|tjjtjjfvr|jd |d |tjjk(r|d ur|jd |tjjk(r2|tjjk7r|jd |d|t j"jk(r2|tjjk7r|jd|d|S)utask-2635+1 §7 — 6 모순 조합 단언. Returns the human-readable mismatches. Each contradiction in this list is a hard FAIL — the envelope is internally inconsistent and the executor must not exit-0 on it. 1. NOT_REGISTERED + cron_schedule_id != None (registered yet unregistered) 2. REGISTERED + cron_schedule_id == None (no proof of registration) 3. attempted=False + result in (REGISTERED, REGISTER_FAILED) (impossible) 4. SENDFILE_ONLY + attempted_callback_registration=True (channel mismatch) 5. delivery=DELIVERED + result != REGISTERED (delivered nothing) 6. receipt=RECEIVED + delivery != DELIVERED (received air) envelope is not a dictrdrecron_schedule_idrcr_zbNOT_REGISTERED + cron_schedule_id present (envelope claims unregistered but carries a schedule id)zXREGISTERED + cron_schedule_id missing (claims registered but no schedule id to prove it)z>>; G )44:::; A  ++11 0066$ J6*U@ @  *88>>>  $ M  *44::: .99?? ?PQWPZ[9 9  )22888 .88>> >Mh\ZB B rc.g}t|tsddgfStD]}||vs|jd||j d|j d}|Qt |}|t vr'|jd|dtt dn|tjjk(r"|j d s|jd |tjjk(r"|j d s|jd |tjjk(r"|j d s|jd|tjjk(r=|j dtjjk7r|jd|j d}|8t|}|t vr%|jd|dtt d|j d}|8t#|}|t$vr%|jd|dtt$d|j d} | -| t&vr%|jd| dtt&dd|vr|j d} | t| t(s(|jdt+| j,nH| s|jdn4t.j0j3| s|jd| d|j5t7||j d} |j d} | 1| /t | t | k7r|jd| d| d|j d} |j d}| 1|/t9| t9|k7r|jd | d!|dt;|}|t<kDr|jd"|d#t<d$| |fS)%uReturn (ok, errors). Spec §3.2 + task-2635+1 §7. Checks include all 5-axis fields, REQUIRED_ENVELOPE_KEYS, enum range, cross-axis contradictions, and the UTF-8 byte budget. Frkzrequired key missing: rar`z$registration_result_status invalid: z (expected one of )rluYcron_schedule_id required when registration_result_status == REGISTERED (task-2635+1 §2) error_messageuVerror_message required when registration_result_status == REGISTER_FAILED (spec §4.2)explicit_skip_reasonujexplicit_skip_reason required when registration_result_status == SKIPPED_WITH_EXPLICIT_REASON (spec §4.2)rfzndelivery_method must be 'sendfile_only' when registration_result_status == SENDFILE_ONLY (ANCHOR-3 separation)rdz"callback_delivery_status invalid: rez"collector_receipt_status invalid: zdelivery_method invalid: canonical_rootz-canonical_root must be str when present: got u=canonical_root must be non-empty when present (task-2636 §4)z&canonical_root must be absolute path: u (task-2636 §4)z(registration_status alias drift: legacy=z vs registration_result_status=z (must agree)rcr_z5axis-2 attempted alias drift: registration_attempted=z$ vs attempted_callback_registration=zenvelope UTF-8 byte size z > hard limit u (spec §3.1))r:rmREQUIRED_ENVELOPE_KEYSrorhr?rMsortedr r r&rrrr/rCALL_DELIVERY_STATUSESrFALL_RECEIPT_STATUSESALL_DELIVERY_METHODSr;typerospathisabsextendrwrnrZENVELOPE_BYTE_LIMIT)rWerrorskeyrIrN delivery_axisnorm_d receipt_axisnorm_rrfr|legacynew new_attemptedlegacy_attempted byte_counts rvalidate_enveloper2s: F h %/000%: h  MM23%8 9: \\6 EZ8[ \F ' * * MM6vj@R-./q2  /::@@@||$67MM7/??EEE||O4MM7/LLRRR||$:;MM' /==CCC<< 12n6R6R6X6XXMM\ LL!;R'R ''::L*+,A / 8#!&67  %nc2 CN+4457$ & ww}}^4MM@),,<>  MM.x89\\/ 0F ,,3 4C co2B62JN^_bNc2c 6vjA**-  ? LL!9:M||$EF!  (  4(8#9 9 CMCTU//?.B- Q *(3J'' ' |>"#= 2 J rct|tsyt|}|tjj k7ryt |jdS)u8High-level predicate: was a real normal callback registered? True iff registration_result_status == REGISTERED **and** cron_schedule_id present. SKIPPED_WITH_EXPLICIT_REASON is treated as success for fail-closed gating but is NOT a real callback firing — this predicate distinguishes the two. Frl)r:rmrir r r&rnrh)rWrNs ris_callback_completersH h %  "D '22888  /0 11r)r=objectreturnr;)rBrrr;)rIrrrn)rWrrint)rWzDict[str, Any]rr;)rWrrz List[str])rWrrzTuple[bool, List[str]])rWrrrn)1r __future__rrenumrtypingrrrrSCHEMA SCHEMA_V1CANONICAL_ROOT_DEFAULTrENVELOPE_WARN_LOWERENVELOPE_WARN_UPPERANU_CALLBACK_KEYr;r NormalCallbackRegistrationStatusrr frozensetr r&rrHr rrrLrMrr ALL_STATUSESr/rr?rCrFrJrOrZr}rirwrrrrrrs.# )) , / /& BsD B&$< &S$&&S$& ++11 ==CC! //55 ..44 0066 J1IJJ!!J3I!JJ I2H II# S$! A. AA   8+(  AVrE P 2r