+ jHjra0t$Rt^RIHt^RIt^RIt^RIHt^RIH t ^RI H t ^RI H t ]P!]4t]!4tR]R&R R ltR R ltR RltRRltRRltR#)aQ``cron/bot_chat_pending``: Bot Chat outputs whose target owner was not running yet. ``defer`` parks one (a cross-profile target whose gateway is down or still starting), and the retired CLI lane left records of the same shape behind. Each still-``queued`` record is handed, under its own id, to the target profile's live owner through the canonical ``tools.bot_live_delivery.deliver_to_live_owner`` door (idempotent per id). Records are never deleted: they keep their final status as evidence, exactly as the old drain did. A ``claimed`` record was an uncertain CLI turn and is never resent. ) annotationsN)Path) make_user_dir)get_hermes_home)atomic_json_writez set[Path]_warnedc 0V^8dQhRRRRRRRRRR R R /#) keystrjobdictcontenthomer for_failureboolreturnNone)formats"9/home/ubuntu/.hermes/hermes-agent/cron/bot_chat_legacy.py __annotate__rs? k ks k k k4 k kRV kc p^RIp\4P4R, R, p\VRRRR7W` R2, pVP 4'gW\ T\ TRR Uu/uFqV9gK WV,bK upV\V4WEP4R 7RR R 7R#R#uupi) zYPark one never-admitted output under its delivery id; a later tick hands it to the owner.Ncronbot_chat_pendingTi)parentsexist_okmodez.jsonqueued)idstatusr rrrsequence fsync_dirr)r name) timerresolverexistsrr r time_ns) r r rrrr'rootpathks &&&&$ rdeferr.s   $ $ & /2D DD$t%@ E- D ;;==$8^)X^TWx)!V)^)XbiT lln!NY]di k )Xs ,B39 B3c V^8dQhRRRR/#)r r+rrzlist[tuple[Path, dict]]r)rs"rrr$sVV$V2Vrc.pVPR4Fp\P!VPRR74p\ V\ 4'g"\ R\V4P 24hTPR4R8XgKzTPY#34K \!VRR 7# \\ 3dBpT\9d,\PT4\PRY$4Rp?KRp?ii;i) z*.jsonz utf-8-sig)encodingzexpected a JSON object, got zAUnreadable legacy Bot Chat pending record %s kept as evidence: %sNr!rcZV^,PR^4V^,P3#)r")getr&)items&r_queued..2s 47;;z1+EtAw||*Tr)r )globjsonloads read_text isinstancer ValueErrortype__name__OSErrorraddloggererrorr4appendsorted)r+foundr,recordexcs& r_queuedrI$s E (# ZZ  DEFfd++ #?V @U@U?V!WXX, ::h 8 + LL$ ($ %T UU$ 7" D! `bfl   sAB22D6C??Dc V^8dQhRRRR/#)r rGr rr r)rs"rrr5strcJRUu.uFCp\VPV4\4'dVPV4'dKAVNKE ppV'dRRPV4 R2#\VPR4;'g/\4'gR#R#uupi)zQWhy *record* can never be handed off (empty when its required fields are usable).z*malformed legacy bot-chat record (missing z, z); not deliveredr zFmalformed legacy bot-chat record (job is not an object); not delivered)r rr)r<r4r joinr )rGr missings& r _malformedrO5s7O7s C#66fjjos7GO;DIIgB B c$V^8dQhRRRRRR/#)r r,rrGr rrr)rs"rrr@s!%%4%%$%rc ^RIHpHp^RIHp^RIHp^RIHpH p\V4;p'dVPRVR7R#\VR,4P4p \VPR 44p V R , P!4'gVPRR V 2R7R#V 'd1V!W%!V R , 44'gVPR RR7R#V!V 4p T fR#T!YT!TPR4;'g/TR,4TR,T 'dRMRR7p \5T \64'dT PR4MRpTPRRTR7R# \"dR#i;i \$dcp \&P)T\*9d\,P.M\,P0RY RR7\*P3T4Rp ? R#Rp ? ii;i)zKDecide one queued record in place; False leaves it queued for a later tick.)BOT_CHAT_POLICY_PLATFORMbot_chat_message)warning_notifications_enabled)load_user_config_effective)deliver_to_live_ownerfind_canonical_live_owner ambiguous)r!rCTrrzstate.dbz+bot-chat delivery target no longer exists: z config.yaml suppressedNFr rr diagnosticresult) delivery_idnotification_categoryz8Legacy Bot Chat pending record %s not handed off yet: %sexc_infor! transferred)r!rCreceipt_status)cron.scheduler_deliveryrRrSgateway.warning_notificationsrThermes_cli.config_effectiverUtools.bot_live_deliveryrVrWrOupdaterr(rr4is_filer= ExceptionrBlogrloggingDEBUGWARNINGrAr<r )r,rGrRrSrTrUrVrWreasonrrownerreceiptrHras&& r_disposerp@sRKFXF##v# [ 7 v  ' ' )Dvzz-01K :  & & ( ( [2]^b]c0d e0 / : $&@ AU&VXX \ 6* ' -d3E = +-fjj.?.E.E2viGXY"4LP[ aikG3=Wd2K2KX.QU ]$~ V #    JJw}}W__QSWgk  m KK   s7-E?<FF7 F? F F G>AG99G>cV^8dQhRR/#)r rrr)rs"rrrhs\\d\rc \4P4R, R, pVP4'gR#\V4FOwr\ W4'gK\ WRRR7\PR TPTR ,4KQ R# \ dcp\PT\9d\PM\PRYRR7\PT4Rp?KRp?ii;i) aAdmit queued legacy records to their live owner; an absent owner leaves them for a later tick. Each record is isolated: a malformed one is kept as ``ambiguous`` evidence and an unexpected failure leaves only that record queued, so one bad file never stops cron. rrNTr#r$z1Legacy Bot Chat pending record %s left queued: %sr^z'Legacy Bot Chat pending record %s -> %sr!)rr(is_dirrIrprrhrBrirrjrkrlrAinfor&)r+r,rGrHs rdrain_legacy_pendingruhs   $ $ & /2D DD ;;==  D)) dd G  =tyy&QYJZ[&   JJw}}W__JD`d  f KK    sB#B D *ADD )__conditional_annotations____doc__ __future__rr9rjpathlibrhermes_dir_aclrhermes_constantsrutilsr getLoggerr?rBsetr__annotations__r.rIrOrpru)rvs@rrs[# (,#   8 $U kV"%P\r