+ jHjRt^RIt^RIHt^RIHtHtHt]R4tRt Rt Rt ] !4t ] 3RltR ] /R ltRR ltR tR tRtRtRtRtRtRRltRtRtRtRtR#)zYAuthority-local async serialization; file locks cover only short synchronous mailbox I/O.N)asynccontextmanager)_locked_read_writec"\VRR4pVf\P!4;qnT;_uu_4GRjxL \VRR4pVf\ 4;q n\P !4pVPV4R5xVPV4^RI H pV!V4RRR4GRjxL R#L TPT4^RI H pT!T4i;iL, +GRjxL 'giR#;i5i)_bot_mailbox_lockN_bot_mailbox_operations)persist_work_count) getattrasyncioLockrsetr current_taskadddiscardgateway.session_runtime_workersr ) authoritylockactivetaskr s& @/home/ubuntu/.hermes/hermes-agent/gateway/session_bot_mailbox.py mailbox_lockrs 914 8D |-4\\^;*tt$=tD >9< >F6##% 4 *  NN4 J y )tt NN4 J y )tttsd;DCDAC( CC(. D9C&:D!C##C(&D(D .C1/ D :D < DcT"\P!\P!V.VO5!4pRp\P!V4GRjxL pVeVhV#L \Pd%pTP 4'dhTpRp?K^Rp?i\ d TeThhi;i5i)zYKeep the caller's mailbox ownership until its physical I/O ends, even after cancellation.N)r create_task to_threadshieldCancelledError cancelled Exception) operationargspendingrresultexcs&* r _mailbox_ior$s!!'"3"3I"E"EFGI  ">>'22F$M3%%   ""I $  sF0B(A A AB(AB%0B B( B% B%%B(c\V4;_uu_4pV\W! R2, 43uuRRR4# +'giR#;i).jsonN)rr)homekeyroots&& r _read_receiptr*0s/ $U4E-/00 s 5 A c>"\\W4GRjxL #L5iN)r$r*r'r(s&&r read_receiptr.5s]D6 66 6 caa\V4;_uu_4pVSR, R2, p\V4oV\Jd,S;'g/PR4V8wd RRR4R#SeSPR4'd^RIHpR p\ ;QJd VV3RlV4F 'gK RM RM!VV3RlV44'g\SPR R 4SPR R 48wg5SPR 4'd&SR ,SPR 48wd V!R 4h/S;'g/CSCpVS8wd \WG4RRR4R# +'giR#;i) delivery_idr&statusNF principal_id)RuntimeStoreErrorc3j<"TF(pSPV4SPV48gxK* R#5ir,)get).0r(currentrecords& r !_write_receipt..Es'J6CGKK$ 376s03Tnotification_categoryr" admission_idadmission_conflict) profile_home session_idr3messageauthor)rr _UNCHECKEDr6hermes_state_runtimer4anyr) r'r9expectr)pathr4fieldsmergedr8s &f& @r_write_receiptrJ<s  $ ./u55+  #B(;(;H(E(O   7;;~#>#> >XFJ6JJ6JJJ{{#:HETkmuIvv N338OSYS]S]^lSm8m'(<==.W]].v. W  4  s51EE*E(E0E=E .E<E E0 rFc@"\\WV4GRjxL #L5ir,)r$rJ)r'r9rFs&&$r write_receiptrLOs^T6B BB Bs c ^RIHp\V4;_uu_4pV\V!W1443uuRRR4# +'giR#;i)) _scan_recordsN)gateway.session_botrOrlist)r'pinsrOr)s&& r_scan_receiptsrSSs.1 $T-344 s 8 A c,\V4;_uu_4pW! R2, p\V4pVeIVPR4R8Xd3VPR4'gVP4RRR4R#RRR4R# +'giR#;i)r&Nr2 ambiguousr=TF)rrr6unlink)r'r(r)rGr8s&& r _withdraw_pinrWYsp $Um#+  7;;x#8K#GPWP[P[\jPkPk KKM   sABB7B B c>"\\W4GRjxL #L5i)zDrop a pre-admission pin the FIFO definitely refused (nothing committed), only while it is still that pin, so the same-id retry admits instead of answering ``unknown_execution``.N)r$rWr-s&&r withdraw_pinrYcs]D6 66 6r/c\V4;_uu_4pW! R2, p\V4pVe5VPR4R8wgVPR4'gRV9d RRR4R#VP4UUu/uFwrVV\9gKWVbK pppRVR&\ W74VuuRRR4#uuppi +'giR#;i)r&Nr2rUr=ownerqueued)rrr6items _PIN_FIELDSr)r'r(r)rGr8kvtickets&& r _requeue_pinrbms $Um#+ Ow{{84 Cw{{SaGbGb')  $+==?K?41a{6J$!$?K#xt  L s0ACC.CB: B: C:C C c>"\\W4GRjxL #L5i)aRestore the queued legacy ticket a pre-admission pin was laid over (nothing committed), only while it is still that pin: its id, message, sequence and created_at are kept, so ``_migrate`` admits it once in its FIFO place. Returns the ticket, or None when the pin is gone or changed.N)r$rbr-s&&r requeue_pinrdzs\45 55 5r/c B^RIHp\V4;_uu_4pW1 R2, p\V4pVeOVP R4R8Xd9VP R4'g"VP RRR R VR 7\ WE4RRR4R# +'giR#;i) rN) AGENT_BLOCKEDr&Nr2rUr=failedTzBot Chat delivery was refused)r2refusedreplyerrorreason)tools.bot_failure_reasonsrfrrr6updater)r'r(rfr)rGr8s&& r _refuse_pinros7 $Um#+  7;;x#8K#GPWP[P[\jPkPk NN(DJi"/  1 4 ! sAB "!B  B c>"\\W4GRjxL #L5i)zSettle a pre-admission pin the FIFO definitely refused for good (nothing committed) as a terminal ``failed`` receipt, only while it is still that pin: never re-sent, nothing unknown.N)r$ror-s&&r refuse_pinrqs[$4 44 4r/c>"\\W4GRjxL #L5i)zZBulk scan; an owner scan passes ``pins`` to collect pre-admission pins instead of warning.N)r$rS)r'rRs&&r scan_receiptsrss^T8 88 8r/c\VRR4pVf /;q0nVR,R9dVPVR,R4R#WR,3W2R,&R#)_bot_receipt_indexNr2r1r@>rgsettledr)r rupop)rr'r9indexs&&& rremember_receiptrysW I3T :E }/11, h== &'.(,\.B'C]#$ca\VRR4oSf\4;oVnSPV4V3RlpVP V4R#)_bot_receipt_tasksNc<SPV4VP4'gUVP4pVe?^RIpVP \ 4P R\V4P 4R#R#R#)Nz!Bot receipt projection failed: %s)rr exceptionlogging getLogger__name__warningtype)finishedrkrtaskss& rdone track_receipt_task..donesh h!!##&&(E !!(+334WY]^cYdYmYmn!$rz)r r r|radd_done_callback)rrrrs&& @rtrack_receipt_taskrsG I3T :E }/2u4 , IIdOo 4 rzc\\VRR4pVf/;q n\4Vn\ \VR/4P 44F[wpwrEWQ8wdKW29d:W#,P 4'gVPPV4KO\WV4K] R#)zXRe-arm paused receipts from owner publication, without making external pollers dial RPC._bot_receipt_refreshesNru) r rr _bot_receipt_dirtyrQr]rr_start_refresh)rr@r!r(r'r[s&& rwake_bot_receiptsrsi!94@G5772'*u $"796JB#O#U#U#WX]d    >',"3"3"5"5  ( ( , ,S 1 9C 0 Yrzcaaaa^RIHoVVVV3Rlp\P!V!44pVSPS&VV3RlpVP V4\ SV4R#)rN)refresh_receiptc<"SPPS4S!SSS4GRjxL SSP9gSSP9gKRR#L*5i)TN)rrru)rr'r(rsrrefresh_until_current-_start_refresh..refresh_until_currentsR  ( ( 0 0 5!)T37 7 7)666#YEaEa:a 8s*AA#AAc<SPPS4VJd:SPPSR4SPP S4R#R#r,)rr6rwrr)rrr(s&rr_start_refresh..donesL  + + / / 4 @  , , 0 0d ;  ( ( 0 0 5 ArzN)rPrr rrrr)rr'r(rrrrsfff @rrrsU3   46 7D,0I$$S)6 4 y$'rzr,)r?r@r3operator)__doc__r contextlibrtools.bot_live_deliveryrrrrr$r*r.objectrCrJrLrSrWrYr^rbrdrorqrsryrrrrzrrs_*::**$*1 7X )3&C C5 7I  6"5 9 D ! 1(rz