+j6Q dZddlmZddlZddlZddlZddlZddlmZddl m Z m Z m Z ddl m Z mZmZddlmZmZdZd Zd Zd Zd Zd ZdZeefZefZdZdZdZdZdZ e e dZ!eGddZ"d-dZ#d.dZ$d/d0dZ%d1dZ&d2dZ'd3d4dZ(d5dZ)edd d6d Z* d7d!Z+ d8d"Z,d#Z-d9d$Z.d:d%Z/d;d&Z0 d3edddedddd' dd+Z3gd,Z4y)?udispatch.anu_pickup_reporter — task-2732 P0B_MINIMUM_PICKUP reporting path. driver(scan_once)가 result.json 을 수거·verdict 한 뒤, 그 verdict 를 **회장 chat(6937032012)** 에 ``PASS`` / ``HOLD`` / ``CALLBACK_MISSING`` 한 줄로 자동 보고한다. driver 는 수거·closeout·verdict 만 수행하고(launcher_fn=None, wake/callback launch 0), 이 모듈은 그 결과를 보고만 한다 — **깨우기/relay 0**. 설계 불변식(SPEC-ANCHOR): - ANCHOR-1: wake/callback launch 0. 이 모듈은 wake-launcher / cron prompt / ANU relay 를 호출하지 않는다. 보고는 **cokacdir --sendfile** (key 불요·agent wake 0)만 사용한다. - ANCHOR-2: verdict → 회장 PASS/HOLD/CALLBACK_MISSING. ANU/봇 key literal 노출 0 (sealed loader 는 보고 경로에 불필요 — sendfile 은 key 없이 동작; argv 에 key 가 실릴 경우를 대비한 redaction helper 만 제공). - canonical write 0: dedupe ledger·보고 임시파일은 memory/p0b_state/ (isolated state)에만 기록한다. canonical events(memory/events) 변형 0. reporting 매핑 (§4): - ``CLOSEOUT_DONE`` / ``VERDICT_AUTHORITATIVE`` → ``PASS`` (단, result.json callback contract 위반/부재 신호 시 → ``CALLBACK_MISSING`` 우선). - ``QUARANTINE`` (owner-proof FAIL: NOT_ANU/QUERY_FAILED 포함) → ``HOLD``. - result.json ``callback_schedule_created=true``(contract 위반) 또는 callback 부재 신호 → ``CALLBACK_MISSING``. - ``NOOP_*`` (disabled/not-target/not-ready/legacy/max-files-defer) → 보고 안 함. - 그 외(WAKE_BUILT/PICKUP_SKIP/FIRE_FAILED 등) → 보고 안 함(spec 매핑 밖). - 보고 1건당 1회 — task_id dedupe(ledger marker). ) annotationsN) dataclass)datetime timedeltatimezone)CallableListOptional) ANU_CHAT_ID send_reportz/home/jay/workspacePASSHOLDCALLBACK_MISSING CLOSEOUT_DONE QUARANTINE AUTHORITATIVEz$memory/p0b_state/reporter_sent.jsonlz memory/p0b_state/reporter_outboxz .result.jsonz***REDACTED***)z--key )hourscleZdZUded<ded<ded<dZded<dZd ed <dZd ed <d Zded <ddZy )ReportDecisionstrtask_id Optional[str]decisionverdictsha256FboolsentdedupedNerrorc|j|j|j|j|j|j |j dS)Nrrrrrr r!r#)selfs 3/home/jay/workspace/dispatch/anu_pickup_reporter.pyto_jsonzReportDecision.to_jsonTs=|| ||kkII||ZZ  )returndict) __name__ __module__ __qualname____annotations__rrr r!r&r'r%rrJs? L LFCD$GTE=  r'rc.t|ttfsgSg}d}|D]s}|r|jtd}t |}|j||t vrd}Dt D]'}|j|dzs|dztz|d<su|S)uargv list 에서 ``--key`` 다음 토큰을 마스킹한 사본을 반환(원본 불변). 로그/evidence 에 argv 를 남길 때 key literal 노출 0 을 보장하기 위한 helper.FT=) isinstancelisttupleappendREDACTEDr _REDACT_FLAGS startswith)argvout redact_nexttoksfls r% redact_argvr?as dT5M * CK  JJx K  H 1 K$ <<S) 3h1CG  Jr'ct|tsyt|jddryd|vrt|jdsyy)uresult.json 의 callback contract 위반/부재 신호 판정. - ``callback_schedule_created`` truthy → True (contract 위반: executor 가 callback 을 self-schedule. task-2731 contract 상 false 가 정상). - ``callback_present`` 이 명시적으로 False → True (callback 부재 신호). - 그 외(부재/판단 불가) → False (보수적: PASS 를 CALLBACK_MISSING 으로 오인 0). Fcallback_schedule_createdTcallback_present)r2r)rget) result_datas r%_callback_missingrE{sG k4 ( KOO7 ?@[(kooFX6Y1Z r'c|yt|j}|sy|jdry|tvrt |rt St S|tvrtSy)udriver verdict(+optional result.json) → 회장 보고 라벨 매핑. 반환: ``PASS`` / ``HOLD`` / ``CALLBACK_MISSING`` 또는 None(보고 안 함). NOOP_* 및 spec 매핑 밖 verdict(WAKE_BUILT/PICKUP_SKIP/FIRE_FAILED 등)는 None. NNOOP_) rstripr8_PASS_VERDICTSrEREPORT_CALLBACK_MISSING REPORT_PASS_HOLD_VERDICTS REPORT_HOLD)rrDvs r% map_reportrOs`  G A ||GN [ )* *N r'c|sytjjt|}|j t r|dt t  Sy)uM``.../task-2732.result.json`` → ``task-2732``. 부적합 시 빈 문자열.rN)ospathbasenamerendswith RESULT_SUFFIXlen)rRbases r%task_id_from_pathrXsE  77  CI &D }}]#)s=))** r'cNt|xsdj}|r|ddSdS)Nr -)rrH)rr=s r% _short_shar\s, FLb!A1Sb6Cr'c .|d|d|dt|S)uW회장 보고 한 줄: ``task-X: PASS|HOLD|CALLBACK_MISSING · · ``.z: u · )r\rrrrs r%build_report_liner_s%Yb $witJv4F3G HHr'cR|xs$tjj|tSN)rQrRjoinREPORTER_LEDGER_RELroot ledger_paths r% _ledger_pathrgs  A"'',,t-@AAr'rdct||}|rtjj|sy t |dd5}|D]Z}|j }|s t j|}t|ts=|jd|k(sRdddy dddy#ttf$rYxwxYw#1swYyxYw#t$rYywxYw)uVledger 에 동일 task_id 보고 기록이 있으면 True(보고 1건당 1회 dedupe).Frutf-8encodingrNT)rgrQrRisfileopenrHjsonloads ValueError TypeErrorr2r)rCOSError)rrerfledgerfhlineentrys r%already_reportedrxs$ ,F "''..0  &# 0 B zz| JJt,EeT*uyy/Cw/N     #I.   sjC B=B(-B=>B=B=C B=C (B:7B=9B::B==CC C CCct||}|j||t|xsdd} tjtj j |xsddt|dd5}|jtj|d d z|jtj|jd d d y #1swYy xYw#t$r} d | cYd } ~ Sd } ~ wwxYw)u보고 완료 1줄 append(durable: makedirs+fsync). key literal 미기록. 반환: 성공 시 None, 실패 시 에러 메시지(str). ★ 실패를 silently swallow 하지 않고 호출자(report_one)에 전달하여 ReportDecision.error 로 가시화한다. dedupe ledger 내구성 실패(디스크 IO)는 드물지만, 발생 시 다음 cycle 재전송(중복) 가능성을 명시적으로 드러낸다. (send-first 순서: 회장 보고 누락 회피 > 드문 중복 — 누락이 더 해롭다.)r)tsrrr.Texist_okarjrkF) ensure_ascii NuGdedupe ledger 미기록(durability) — 다음 cycle 재전송 가능: )rg isoformatrrQmakedirsrRdirnamernwriterodumpsflushfsyncfilenors) rrrrerfclockrtrecruexcs r%_mark_reportedrs$ ,Fg!fl#  C _ BGGOOF+2sTB &# 0 "B HHTZZ%84? @ HHJ HHRYY[ ! "  " _XY\X]^^_s=AC-;AC!C-!C*&C-*C-- D6D:DDc<|xs$tjj|t}t j dd|xsd}|dt tjdzd}tjj||} tj|dt|d d 5}|j|d z|jtj|jd d d |S#1swY|SxYw#t$rYy wxYw)u보고 한 줄을 isolated outbox 파일로 작성하고 경로 반환(실패 시 None). canonical events 0 touch — memory/p0b_state/reporter_outbox 하위에만 기록.z[^A-Za-z0-9._-]_taskr{iz .report.txtTr|wrjrkrN)rQrRrbREPORTER_OUTBOX_RELresubinttimerrnrrrrrs) rrvre outbox_dirodirsafefnamefpathrus r%_write_report_filers  @d,?@D 66$c7 3 =vDfAc$))+,-.k :E GGLLu %E D4( %w / "2 HHTD[ ! HHJ HHRYY[ ! "  " s1 %D0AD8 DD D D DDc  t|d5}|j}dddtjj d}t|tr|SdS#1swYAxYw#t t tf$rYywxYw)uYpath 를 JSON dict 로 적재. 실패/비-dict → None(listdir 없이 직접 시도용).rbNrj) rnreadrorpdecodersrqUnicodeDecodeErrorr2r))rRrurawdatas r%_try_load_json_dictrs{ $  '')C zz#**W-.dD)43t3    Z!3 4s' A+A,A+A($A++BBcp|siStjj|}tjj|ddd}|tjj||fD]}t |}||cS|dz} tj |5}d}|D]p} |t k\rne|dz }| jj|s/t tjj|| j}|e|ccdddSdddiS#1swYiSxYw#t$rYiSwxYw)uresult_path → result dict. 원위치 부재 시 processed 디렉토리에서 basename 매칭. 읽기/파싱 실패 시 {} 반환(보수적: callback 판정 불가 → PASS 보존). ★ (c) MEDIUM fix: processed dir 전체를 **무조건** ``os.listdir`` 하던 scan 을 제거. 1) 직접 후보(원위치 record_path · processed/)를 listdir 없이 먼저 시도 — 정상 경로에서 디렉토리 scan 0. 2) 직접 후보가 모두 부재할 때에만 충돌-회피 suffix(``.[-n]``) 변형을 ``os.scandir`` + ``PROCESSED_SCAN_LIMIT`` 상한 bounded scan 으로 탐색 (전체 무조건 scan·무제한 누적 폭주 회피).memory p0b_state processedNr{r) rQrRrSrbrscandirPROCESSED_SCAN_LIMITnamer8rs) record_pathrerWpdircrprefixitscannedents r%_default_result_loaderrs1  77  K (D 77<<h [ AD277<<d3 4"1%  K CZF  ZZ  $G $221 88&&v..rww||D#((/KLD'#  $ $ $ $ I $ I   I sHD(3D 5DD D(DD(D% D(%D(( D54D5c t||}|yt|dd}t|tsy|dk(S#t$rYywxYw)uMallowlist-only sendfile 로 회장 chat 에 보고 파일 전송. 성공 여부 bool. ★ wake 0: --sendfile 만 사용(cron prompt/agent wake/relay 0). key literal 0: sendfile 은 key 불요. send_report 는 shell=False·고정 argv·화이트리스트 검증. ★ (a) HIGH fix: send 성공은 **실제 전송 성공이 확인된 경우에만** True. - 예외 발생 → 실패(False). 다음 cycle 재시도(ledger 미기록). - 결과가 None 이거나 ``returncode`` 속성/값이 없으면(계약 위반·예기치 못한 반환) **성공 간주 0** → 실패(False). (이전: ``getattr(res, "returncode", 0)`` 가 None/속성부재를 0 으로 오인하여 미전송을 성공으로 기록하던 HIGH 결함을 차단.) - ``returncode == 0`` 이 명시적으로 확인된 경우에만 True.chat_idFN returncoder)r Exceptiongetattrr2r) file_pathrresrcs r%_default_senderr9sU)W5 { lD )B b#  7N s 5 AA)resender result_loaderrDrrfrrc x| xsd} t|xst|xsdj} ||xsfd} | |}t|xsdjs.t |t rt|j dxsd}t||} | %t| dt|t|xsdS| s&td| t|t|xsddSt| | r&t| | t|t|xsdd St| | t||}t| || }|&t| | t|t|xsdd S|xsfd} t||}|s&t| | t|t|xsddSt| | ||| }t| | t|t|xsdd |S#t$ri}YwxYw#t$r3}t| | t|t|xsdd|cYd}~Sd}~wwxYw)uC단일 verdict 를 매핑→dedupe→보고. ReportDecision 반환.c4tjtSra)rnowKSTr.r'r%zreport_one..bshll3/r'rNct|S)N)re)r)pres r%rzreport_one..gs-CAD-Qr'rr^u!task_id 미해석 — 보고 skip)rrrrr!rdT)rrrrr )reru보고 파일 작성 실패ct|S)Nr)r)fprs r%rzreport_one..sG Dr'usender 예외: u전송 실패(returncode!=0))rerfr)rrrrrr!)rXrrHrr2r)rCrOrrxr_rrr)r result_pathrrerrrDrrfrrrloaderrrvrsndokrmark_errs ` ` r% report_onerSs`  0/E ,NK4E20F0L0L0NGR#Q  -K v|  " " $K)F[__X.4"5';/Hgc'l%(2%68 8 b8S\%(2%6>ac cd Dg#g,%(2%6F F WhG f ED w4J OE }g#g,%(2%6>[] ]  EDCW #e*  g#g,%(2%6>\^ ^ gxd*5UDH 'Hc'l!$V\r!2X OOW K < Wg#g,%(2%6PSu>UW WWs0G+:G=+ G:9G:= H9(H4.H94H9c^t|tr|j|St||dS)u>DriverRecord(dataclass) 또는 dict 모두에서 field 추출.N)r2r)rCr)recordrs r% _record_fieldrs*&$zz$ 64 &&r'rerrrrfrrcg}|xsgD]R} t| d} t| dxsd} t| dxsd} |jt| | | ||||||| T|S)uscan_once 가 반환한 DriverRecord 목록을 순회하며 보고. 결정 목록 반환. 각 record: verdict + result_path. sha256 은 record(없으면 result.json)에서 추출. NOOP_*/매핑 밖 → 보고 안 함. PASS/HOLD/CALLBACK_MISSING → dedupe 후 1회 전송. rrrrr)rr5r) recordsrerrrrfrrr:rrrrs r%report_recordsrs !#C}" Y/#C7=2 sH-3 :   '#!   Jr')CANONICAL_ROOTrKrMrJVERDICT_AUTHORITATIVErcrrr6rrr?rOrXr_rxrr)r(z List[str])rDOptional[dict]r(rra)rDrr(r)rRrr(r)rrr(r)r) rrrrrrrrr(r)rerrfrr(r)rrrerrfrr(r) rrrrrrrerrfrr(r) rrrvrrerrrr(r)rRrr(r)rrrerr(r))rrrrr(r)rrrrrrrerrOptional[Callable]rrrDrrrrfrrrrrr(r)rr)rr3rerrrrrrrrfrrrrrr(zList[ReportDecision])5__doc__ __future__rrorQrr dataclassesrrrrtypingrr r dispatch.anu_terminal_relayr r rrKrMrJDRIVER_CLOSEOUT_DONEDRIVER_QUARANTINErrIrLrcrrUr6r7rrr?rErOrXr\r_rgrxrrrrrrrrr__all__r.r'r%rs|4# !22++A'  ,' ''(=>#%=8   yq!"     ,4"0 I B3A26"/;?._ -_9F_6#05B*4"L:CO !%(,"&!% $ $CO COCO CO  CO  CO&CO COCOCOCO COCON'!%(,!% $ $! ! !  ! & !  !!! !!H r'