3j")dZddlmZddlZddlmZmZddlmZddl m Z m Z ddl m Z mZddlmZmZmZmZd Zd Zd Zd Zd ZeedhZedGddZddZ ddZddddddd ddZy)uanu_v3.collector_artifact_lookup — canonical-root, registry-first lookup. task-2553+44/+46 (구현목표 B fail-safe + 구현목표 C integration). Standalone, read-only, pure stdlib. The normal / fallback / dead-man collector verdict pipeline: 1. registry-first (§3.B): consult the durable callback_4tuple ledger. A COMPLETED record => NORMAL_COLLECTOR_COMPLETED even if the one-shot cron + spawn session are gone (regression 8/9). 2. canonical-root artifact re-check (§3.C): if the ledger is absent / incomplete, look for result/collector-result/.done UNDER THE CANONICAL ROOT (not the autoset cwd) via artifact_root_resolver. An autoset-cwd false-miss must NEVER alone yield RESULT_MISSING (regression 10/11). 3. schedule_history + stale fail-safe (§3.B): only when the canonical root has nothing AND schedule_history shows nothing for this chat_id AND the dispatch is stale -> RESULT_MISSING / BOT_STALE candidate (regression 12). Chat isolation enforced (chat_id). Layer A / NO-CRON (9-R.1): ZERO write, ZERO cron register/remove, ZERO dispatch, ZERO merge, ZERO ``cokacdir``/``subprocess`` exec. Pure stat/read classification. ) annotationsN) dataclassfield)Path)ListOptional)RESOLVER_SCHEMA resolve_roots)NORMAL_CALLBACK_COMPLETEDTRACK_MISMATCHCallback4TupleRegistrydefault_ledger_pathz#anu_v3.collector_artifact_lookup.v1NORMAL_COLLECTOR_COMPLETEDRESULT_PRESENTRESULT_MISSING BOT_STALEDISPATCH_NOT_RECEIVEDT)frozenceZdZUded<ded<ded<ded<ded<ded<ded <ded <ded <ded <ded <ded<ded<eeZded<ddZy)CollectorLookupResultstrschematask_idverdictregistry_verdictcanonical_root events_dirboolresult_present_canonical"collector_result_present_canonicaldone_present_canonicalautoset_cwd_rootautoset_only_miss_blockedschedule_history_seendispatch_stale)default_factoryz List[str]reasonscX|j|j|j|j|j|j |j |j|j|j|j|j|jtt|jdS)N)rrrrrrrr r!r"r#r$r%resolver_schemar')rrrrrrrr r!r"r#r$r%r listr')selfs 7/home/jay/workspace/anu_v3/collector_artifact_lookup.pyto_jsonzCollectorLookupResult.to_jsonHskk|||| $ 5 5"11//(,(E(E77&*&A&A $ 5 5)-)G)G%)%?%?"11.DLL)#  N)returndict)__name__ __module__ __qualname____annotations__rr*r'r-r.r,rr7s` K L LO""(,,  ##t4GY4 r.rcB |jS#t$rYywxYw)NF)is_fileOSError)ps r,_isfiler:^s%yy{ s  c |jsyt|jd}t |}|D]t} |j dd}|j D]K}|j}|s tj|}t |jd|k(sJyvy#t$rYywxYw#t$rYwxYw#tj$rYwxYw)zRead-only: is there ANY history line for this chat_id? Chat isolation: lines whose ``chat_id`` differs are skipped and never cited (shared cross-chat folder).Fz*.logzutf-8ignore)encodingerrorschat_idT) is_dirr*globr8r read_text splitlinesstripjsonloadsJSONDecodeErrorget)schedule_history_dirr?logswantlogtextrawrecs r,_schedule_history_seen_for_chatrPes#**,(--g67 w=B> C  C C&%C&F)expected_dispatch_idexpected_dispatch_cron_id autoset_cwdr%result_basenamerIcVt||}t|j} g} tt |j } | j ||||} | tk(r| jd|xs|d} | | z }| |dz }| |dz }| |dz }t|}t|}t|xs t|}|j }|r| jd| tk(rt}n| tk(rt}| jd n|r&t}| jd |jd n|s|rt}| jd | d ntt|j |}|s|rt"}| jdn|rt$nd}| jdt't(||| |j |j||||j*|||| St't(||| |j |j||||j*|d|| S)aURegistry-first, canonical-root-re-check collector classification. ``result_basename`` overrides the default ``.result.json`` (the +44/+46 result is ``task-2553+44_46.result.json``; +39 is ``task-2553+39.result.json``). ``schedule_history_dir`` overrides the default shared history dir (hermetic regression 12). )rSrI)rrQexpected_chat_idrRusdurable ledger identity mismatch (task/dispatch/chat) -> TRACK_MISMATCH; unrelated-task callback not cited (§3.B).z .result.jsonz.collector-result.jsonz.donez .done.ackedu|autoset/current cwd has no memory/events; canonical root re-checked FIRST before any missing verdict (§3.C, regression 11).uqdurable ledger COMPLETED record present — normal callback completed survives one-shot cron auto-delete (§3.B).z canonical u present (§3.C re-check).z!canonical artifact present under u< (§3.C); autoset-cwd false-miss overridden (regression 10).ucanonical root absent + no schedule_history for chat + stale dispatch -> RESULT_MISSING / BOT_STALE candidate (§3.B, regression 12).PENDING_FAILSAFEuzcanonical artifact absent but schedule_history/registry inconclusive — fail-safe defer, no false RESULT_MISSING (§3.B).)rrrrrrrr r!r"r#r$r%r'F)r rrr rrclassifyr appendr:autoset_events_dir_presentr rnamerrPrIrrr LOOKUP_SCHEMAr")rr?rQrRrSr%rTrIrootsrr'ledger reg_verdictbaseresult_p collector_pdone_p done_acked_presult_presentcollector_present done_presentr#rsh_seens r,rXrXs$ 6J Ee&&'JG$E001F//1 "; "K n$ L  6 6DD H'*@AAK WIU+ +F7); 77LX&N ,6?;gl&;L %*$D$D D   n$  1 1, D  ,))**D E  < / |rts.# (!6 :!!  $-n>U-V#W  $# # # L), L+//3"& %)+/E EE( E - E  EE#E)EEr.