+ jHjb@Ba0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI H t ^RI Ht^RIHtHtHtHt^RIHt^RIHtHt^RIHt^R IHt]P<!]4t Rt!R ]"R &] PF!4PHt%]PL!4t'](!4t)R ]"R &R1t*Rt+Rt,RRlt-R2RRllt.RRlt/RRlt0RRlt1] RRl4t2RR/RR llt3R!R"lt4R#R$lt5RR/R%R&llt6R'R(lt7R)^/R*R+llt8R,R-lt9RRR.R/R/R0llt:R#)3aProfile-local durable handoff for cron delivery through live gateway adapters. A restart-safe cron worker executes outside the gateway cgroup. It cannot own relay/E2EE adapter objects, so it queues the final send here. A gateway claims each row at most once. If that gateway dies after claiming, the outcome is marked unknown and never retried: losing a delivery is safer than duplicating a possibly-completed send. ) annotationsN)contextmanager)Path)AnyCallableIteratorOptional)redact_sensitive_text)_owner_is_live_process_start_time)get_hermes_home)nowOptional[Path] DELIVERY_DBzset[str]_ACTIVE_DELIVERIES suppressedigr@c V^8dQhRRRR/#connsqlite3.ConnectionreturnNone)formats"8/home/ubuntu/.hermes/hermes-agent/cron/delivery_queue.py __annotate__r's# # #5# $# c&VPR4\^\\44p\VPR4P 4^,4pW!, pV^8d)VPRV34VPRV34R#R#)zBRedact terminal payloads and retain only bounded outcome metadata.zUPDATE deliveries SET job_json='{}', content='' WHERE status IN ('delivered','failed','unknown','suppressed') AND (job_json != '{}' OR content != '')z]SELECT COUNT(*) FROM deliveries WHERE status IN ('delivered','failed','unknown','suppressed')aINSERT OR IGNORE INTO delivery_tombstones (execution_id, terminal_status, finished_at) SELECT execution_id, status, finished_at FROM deliveries WHERE status IN ('delivered','failed','unknown','suppressed') ORDER BY julianday(finished_at), finished_at, julianday(created_at), created_at, execution_id LIMIT ?aeDELETE FROM deliveries WHERE execution_id IN ( SELECT execution_id FROM deliveries WHERE status IN ('delivered','failed','unknown','suppressed') ORDER BY julianday(finished_at), finished_at, julianday(created_at), created_at, execution_id LIMIT ? )N)executemaxintMAX_TERMINAL_DELIVERIESfetchone)rkeepterminal_countexcesss& r_prune_terminal_unlockedr''sLL 8 q#-. /D  L  (*Q N  "F z  I   I rc V^8dQhRRRR/#)rhomerrrr)rs"rrrMs55^5t5rc\e\#Ve \V4M \4pVP4R, R, #)zMThe queue file of ``home`` (the active home when None); a test override wins.cronz deliveries.db)rrr resolve)r)roots& r queue_pathr.Ms7)4:/@D <<>F "_ 44rcV^8dQhRR/#)rrrr)rs"rrrUstrc\4#N)r.rrr_pathr2Us <rc V^8dQhRRRR/#rr)rs"rrrYs////D/rcx^RIHpRFpVPRV34P4pV'gK.RV^,9gK>VPR4VPRV RV R24VPV^,P R R 44VPR V R V R24VPR V R24VPR4K VPR4VPR4V!VRRR4R# \ d%TPR4TPR4hi;i))add_column_if_missing deliveriesz;SELECT sql FROM sqlite_master WHERE type='table' AND name=?z 'suppressed'z"SAVEPOINT notification_dispositionz ALTER TABLE z RENAME TO _oldz 'unknown'z'unknown','suppressed'z INSERT INTO z SELECT * FROM z DROP TABLE z RELEASE notification_dispositionz$ROLLBACK TO notification_dispositiona/CREATE TABLE IF NOT EXISTS deliveries ( execution_id TEXT PRIMARY KEY, job_json TEXT NOT NULL, content TEXT NOT NULL, for_failure INTEGER NOT NULL DEFAULT 0, status TEXT NOT NULL CHECK(status IN ('pending','delivering','delivered','failed','unknown','suppressed')), owner_process_id TEXT, owner_pid INTEGER, owner_started_at INTEGER, created_at TEXT NOT NULL, finished_at TEXT, error TEXT )a CREATE TABLE IF NOT EXISTS delivery_tombstones ( execution_id TEXT PRIMARY KEY, terminal_status TEXT NOT NULL CHECK(terminal_status IN ('delivered','failed','unknown','suppressed')), finished_at TEXT ) for_failurez&for_failure INTEGER NOT NULL DEFAULT 0N)r7delivery_tombstones)hermes_cli.sqlite_utilr6rr#replace BaseException)rr6tablerows& r_initialize_schemar@Ys-<7llX[`Zbclln 3>Q/ LL= >  |E7+eWDIJ SV^^K9QRS |E7/%MN {5'67 ?@7 LL   LL  lM0;!  CD ?@ s A>D  /D9cV^8dQhRR/#)rrrr)rs"rrrs  $ rc^RIHp\4pV!VRR\R7pVP R4V# \ dT#i;i)r5)open_dbzcron/deliveries.dbT)db_labelsynchronous_full initializei)r;rCr2r@chmodOSError)rCpathrs r_connectrJsQ/ 7D 4"6Zl mD  5 K   K s5 AAcV^8dQhRR/#)rrzIterator[sqlite3.Connection]r)rs"rrrs2rc #"^RIHp\;_uu_4V!\44;_uu_4pVxRRR4RRR4R# +'giL;i +'giR#;i5i)r5) transactionN)r;rM_lockrJ)rMrs r _transactionrOs8 3  HJ''4 (''s1A.AA A A. A A A+ % A.r9Fc ,V^8dQhRRRRRRRRRR/#) r execution_idstrjobdictcontentr9boolrr)rs"rrrs:&&& &&  &  &rc h\4;_uu_4pVPR4VPR\V434P4pVe*R\V4RVR,RVR,/uuRRR4#VPR\V4\P !VR R R 7\V4\ \V44\4P434VPR \V434P4pRRR4\X4# +'giL;i) z@Persist one idempotent delivery request before the worker waits.zBEGIN IMMEDIATEzQSELECT terminal_status, finished_at FROM delivery_tombstones WHERE execution_id=?NrQstatusterminal_status finished_atzINSERT OR IGNORE INTO deliveries (execution_id, job_json, content, for_failure, status, created_at) VALUES (?, ?, ?, ?, 'pending', ?)FT) ensure_ascii sort_keys-SELECT * FROM deliveries WHERE execution_id=?) rOrrRr#jsondumpsr!rV _hermes_now isoformatrT)rQrSrUr9r tombstoner?s&&&$ renqueuercs  4 &'LL #     (*   L 1)$56y7   4L! 3UdCG D%& '')   ll ;c,>O=Q (* 7 < 9= sAD!O=Q (*  ?9  LL <     (*   .1)-.y/   s9B.*B.. B> cV^8dQhRR/#)rrrer)rs"rrrsNrc d\P!4p\V4p\4;_uu_4pVP R4P 4pVf RRR4R#VP R\ WVR,34pVP^8wd RRR4R#VP RVR,34P 4p\PVR,4RRR4\X4p\P!VPR44VR&V# +'giLE;i)z@Atomically claim one pending send before touching the transport.z{SELECT execution_id FROM deliveries WHERE status='pending' ORDER BY julianday(created_at), created_at, execution_id LIMIT 1NzUPDATE deliveries SET status='delivering', owner_process_id=?, owner_pid=?, owner_started_at=? WHERE execution_id=? AND status='pending'rQr]job_jsonrS)osgetpidr rOrr# _PROCESS_IDrowcountraddrTr^loadspop)pidstartedrr?curclaimedresults r claim_nextrxs ))+C!#&G 4ll O  (*  ; ll <#N(; <   <<1   ,, ;c.>Q=S (*  s>23' (']FJJvzz*56F5M M- s%D"2DAD D/ c(V^8dQhRRRRRRRR/#)rrQrRrg Optional[str]rrVrr)rs"rrrs)#DUYrc V'dRM V'dRMRpV'd\\V4RRR7MRp\4;_uu_4pVPRV\ 4P 4VV\ \P!434p\V4RRR4XP^8H# +'giL;i)failedr deliveredT)forceredact_url_credentialsNzUPDATE deliveries SET status=?, finished_at=?, error=? WHERE execution_id=? AND status='delivering' AND owner_process_id=? AND owner_pid=?) r rRrOrr`rarnrlrmr'ro)rQrgrrX safe_errorrrus&$$ r_finishrsXJLKF  c%jTR  4ll ; '')     !&  <<1  s AB22 C cV^8dQhRR/#)rrr!r)rs"rrrs++3+rc l.p\4;_uu_4pVPR4P4pVEFpVR,\8HpV'd7\;_uu_4VR,\ 9d RRR4KHRRR4M+\ \VR,4VR,4'dK}V'dRMRpVPR \4P4VVR,34pVP'gKTP\P!VR ,;'gR 4PR 4VR,34EK \V4RRR4^R IHpVF wrV!W4K \%V4# +'giL;i +'giLG;i)aFence dead delivery owners as unknown; never replay uncertain sends. The firer settled long ago against a ``queued`` row, so each fenced row's outcome is written back here (job ``delivery_failed`` + error, ledger ``failed``) instead of leaving the run at ``delivery_queued`` forever.zvSELECT execution_id, job_json, owner_process_id, owner_pid, owner_started_at FROM deliveries WHERE status='delivering'owner_process_idrQN owner_pidowner_started_atzRGateway finished delivery but could not persist its outcome; send was not retried.zLGateway exited during delivery; send outcome is unknown and was not retried.z~UPDATE deliveries SET status='unknown', finished_at=?, error=? WHERE execution_id=? AND status='delivering'rkz{}idsettle_quietly)rOrfetchallrnrNrr r!r`raroappendr^rqgetr'cron.delivery_outcomerlen) fencedrrowsr? same_processrgrurjob_idrQs rrecover_abandonedrsj /1F 4|| 8  (* C12kALU>*.@@ U@U C $4 5s;M7NOO (d  ,,C M++-'C||| tzz#j/*A*ATBFFtLcR`Nabc34 !&? @5 &v,!' v;9U s=A F#!F 5 F#;F#*%"&s5z~~6\']"^``@s5z~~d3S5HI"**3~+>?Q +", %U! 79--.b6 7"**3~+>?saD=,(EA&FF= E  E?E:5F:E??F F G$G  G GGc V^8dQhRRRR/#)rrQrRrr)rs"rrrgs)<)r}r) r`rarOrrRr#loggerwarningr')rQr uncertain_errorrr?s& r_terminalize_wait_timeoutrgs  - ! ! #C  4ll @     (*  ?s8} 9 NN3     ? 3|#4 5 ll G     (*  !&+ , {< 8}33 s7|::3x=/: ;;5 sAD! AD!! D1 timeoutc 0V^8dQhRRRRRRRRRR R R /#) rrQrRrSrTrUr9rVrzOptional[float]rrzr)rs"rrrsD;;; ;;  ;  ;;rct\WW#R7pVR,\9d?VR,R9dR#\VPR4;'g RVR, 24#Vf\M \ RV4p\ P!4V,p\ P!4V8d|\V4pV'dQVR,\9d?VR,R9dR#\VPR4;'g RVR, 24#\ P!R4K\V4;'gR#) zFQueue delivery and wait for a gateway's terminal at-most-once outcome.)r9rXNrgrgg?>r}r) rc _TERMINALrRr%DEFAULT_DELIVERY_WAIT_TIMEOUT_SECONDSr time monotonicrhsleepr) rQrSrUr9rqueued wait_timeoutdeadliner?s &&&$$ renqueue_and_waitrs\ IF h9$h'+FFt C JJw  A AYvh/?.@#AM  29-c#wFW~~,.H .. X %& 3x=I-x=,GG4 S ??iH $?N  3 $\ 2 : :d:r)r}r|unknownrr1);__conditional_annotations____doc__ __future__rr^loggingrlsqlite3 threadingruuid contextlibrpathlibrtypingrrrr agent.redactr cron.executionsr r hermes_constantsr hermes_timer r` getLoggerrrr__annotations__uuid4hexrnRLockrNsetrrr"rr'r.r2r@rJrOrcrhrxrrrrr)rs@rrs#   %44.?,*   8 $" ^"jjl "uH$ < (-%# L5/d &  &R,:52+\FH>)