js) dZddlmZddlZddlZddlZddlmZmZmZddl m Z ddl m Z m Z mZmZddlmZdZd Zd Zd Zd Zd ZdZdZddZef ddZ d ddZ ddddd ddZddZd dZdd d!dZ y)"uutils.canonical_root_resolver — ANU collector canonical-root resolver. task-2636 — callback collector canonical-root resolver (Core hardening). Spec: memory/specs/system_callback_collector_canonical_root_spec_260523.md sha256: 6f0b04810cc458ea4cb12f3c1c9c511d14b1439917b7ef4f1ef91982e32d92c1 회장 verbatim (task md §3): CANONICAL_ROOT_RESOLUTION_ORDER: 1. envelope.canonical_root (explicit override) 2. CANONICAL_ROOT_DEFAULT = "/home/jay/workspace" 3. ★ cwd-based lookup 사용 금지 (primary path 에서 0) PATH_RESOLUTION_RULE: absolute_path → 그대로 사용 (canonical_root 무시) relative_path → os.path.join(canonical_root_resolved, relative_path) empty_or_none → MISSING classification CONTEXT_MISMATCH_DETECTION: if os.getcwd() != canonical_root_resolved: log CALLBACK_COLLECTOR_CONTEXT_MISMATCH event proceed with canonical_root_resolved (do not use cwd) ANCHOR-1 (spec §14): envelope.canonical_root 우선 · default /home/jay/workspace · cwd-based primary lookup 코드 경로 0. ANCHOR-2: cwd != canonical_root 시 CALLBACK_COLLECTOR_CONTEXT_MISMATCH 기록 + canonical_root 사용 (cwd 결정 권한 0). ) annotationsN)datetime timedeltatimezone)Path)AnyDictListOptional)CANONICAL_ROOT_DEFAULTz utils.canonical_root_resolver.v1z&callback_collector_context_mismatch.v1z7memory/events/callback_collector_context_mismatch.jsonlPROCEED_WITH_CANONICAL_ROOTFOUNDMISSING_PATH_FIELDMISSING_BOTH_PATHS NOT_FOUNDctjtjj tt dj dS)z?KST ISO timestamp (asia/seoul = UTC+9). Avoid tz-DB dependency. )hoursz%Y-%m-%dT%H:%M:%S+09:00)rnowrutc astimezonerstrftimeN/home/jay/workspace/.worktrees/task-2644-dev1/utils/canonical_root_resolver.py _now_iso_kstr7s<  X\\"-- YQ' ( (, -rct|ts/tjj |st d||S|j d}|r`t|ts!tdt|jtjj |st d||Stjj |st d||S)u(Return the canonical root path for an envelope (spec §3, §5.1). Resolution order: 1. ``envelope.canonical_root`` — explicit override (must be absolute) 2. ``default`` — fallback CANONICAL_ROOT_DEFAULT (must be absolute) ★ cwd is never consulted (spec ANCHOR-1). z.canonical_root default must be absolute path: canonical_rootz)envelope.canonical_root must be str, got z/envelope.canonical_root must be absolute path: ) isinstancedictospathisabs ValueErrorgetstr TypeErrortype__name__)envelopedefaultexplicits rresolve_canonical_rootr-@s h %ww}}W%@ L ||,-H(C(;DN>rT)log_root write_eventclockc @t|}|tj}tjj |tjj |k(r d||dt dS|r!t jjddnd}|r|r|n t}t||t|tr|jdnd|t|tr|jdnd|t||t d }t||d |||t dS) uDetect cwd vs canonical_root mismatch (spec §3, §6). If mismatch → append a `CALLBACK_COLLECTOR_CONTEXT_MISMATCH` event record at ``/memory/events/callback_collector_context_mismatch.jsonl`` and return decision=PROCEED_WITH_CANONICAL_ROOT. Returns: { "mismatch": bool, "cwd": str, "canonical_root": str, "recorded_event_id": Optional[str], "decision": "PROCEED_WITH_CANONICAL_ROOT", } NF)mismatchcwdrrecorded_event_iddecisiontask_idr) schemaevent_idts_kstr>r:canonical_root_envelopecanonical_root_resolved delta_pathsr<)r5T)r-r!getcwdr"r0MISMATCH_DECISIONuuiduuid4hexrMISMATCH_EVENT_SCHEMArr r% _delta_paths_append_mismatch_event) r* current_cwdr5r6r7rr@tsrecords rdetect_context_mismatchrPs.,H5Niik  ww $(8(8(HH,!%)   )4tzz|$HUW<>+ 2Resolved paths that would differ if cwd had been used instead.) result_path report_path) rr r%r&r!r"r#appendr0r1)r*routfieldr3s rrKrKsC h % /Lll5! c3 C c0B JJrww'' ^S(IJ KL JrcL |r t|ntt}|tz }|jj dd|j dd5}|j tj|dddzd d d y #1swYy xYw#t$rYy wxYw) uAppend a single JSONL record to the mismatch event log. ``log_root`` overrides /home/jay/workspace as the parent of memory/events (so regression tests can use tmp_path without touching the live tree). Gemini medium 대응(round-1): I/O 실패는 diagnostic 이므로 graceful — collector 동작은 PROCEED_WITH_CANONICAL_ROOT 로 계속 (read-only fs/permissions/full disk 등). T)parentsexist_okazutf-8)encodingF) ensure_ascii sort_keys N) rr MISMATCH_EVENT_LOG_RELparentmkdiropenwritejsondumpsOSError)rOr5baselog_pathfhs rrLrLs  !)tH~t4J/K00dT: ]]3] 1 TR HHTZZUdKdR S T T T    s0AB+B B BBB B#"B#) fs_existsc*t|ts ddgtdS|j|}||dk(r ddgtdS||ntj j }t|}g}t|||}|r$|j|||r d||tdStj j|sF|tk7r=t||t}|r)||k7r$|j|||r d||tdSd|r|dnd|tdS)uApply COLLECTOR_LOOKUP_ORDER (spec §3) and report the outcome. Lookup order: 1. canonical_root (from envelope or default) + path_field 2. fallback CANONICAL_ROOT_DEFAULT + path_field (if differs) 3. absolute passthrough (handled implicitly by resolve_path) Returns: { "found": bool, "resolved_path": str, "lookup_attempts": [paths tried], "classification": one of FOUND / MISSING_PATH_FIELD / NOT_FOUND, } Fr/)found resolved_pathlookup_attemptsclassification)rTr)rr CLASS_MISSING_PATH_FIELDr%r!r"existsr-r4rT CLASS_FOUNDr#r CLASS_NOT_FOUND) r*r2rjr3rq primary_rootattemptsprimaryfallbacks r find_artifactrxs6* h %!6   ,,z "C {cRi!6   $/YRWW^^F)(3LH8Z MG '?!(#+"-   77== ,2H"H j1G  G+ OOH %h!%-'/&1 (0!b#)  r)returnr&)r*rr+r&ryr&)N)r*rr2r&r Optional[str]ryr&) r*rrMrzr5rzr6boolr7 Optional[Any]ryDict[str, Any])r*rrr&ryz List[str])rOr}r5rzryNone)r*rr2r&rjr|ryr})!__doc__ __future__rrdr!rGrrrpathlibrtypingrr r r utils.callback_envelope_schemar RESOLVER_SCHEMArJr_rFrrrpCLASS_MISSING_BOTH_PATHSrsrr-r4rPrKrLrxrrrrsC8# 22,,B4@R1 //*## # #R%)???"? ?F"&<# <<< <  <  <<~  2 $ JJJ J  Jr