+ jHj!`Rt^RIHt^RIt^RIHtHt]!0R$m4t] !] !R]444t Rt ]!RR04t ]!] 0] m4t]!] 0] m4t^@tRR ltR R ltR R ltRRltRRltRRltRRltRRltRRltRRltRRltR%RRlltR R!ltR"R#ltR#)&zGateway response filtering helpers. These decide whether a completed agent turn should be delivered to the chat, not what should be persisted in conversation history. ) annotationsN)AnyOptionalc#V"TFqPR4'gKVxK! R#5i)[N startswith).0ms& =/home/ubuntu/.hermes/hermes-agent/gateway/response_filters.py r s G1\\#5F111s) )internal_notificationprocess_completeasync_delegation_completec V^8dQhRRRR/#textstrreturn)formats"r __annotate__r/s22s2s2cxRPVP4P4P44#) )joinstripuppersplitrs&r _canonical_silence_candidater!/s) 88DJJL&&(..0 11rc V^8dQhRRRR/#)rchrrboolr)rs"r rr3sGGSGTGrcfVR9;'d&\P!V4PR4#)z[]P) unicodedatacategoryr)r#s&r _is_edge_punctuationr)3s* T> F Fk2226AA#FFrc V^8dQhRRRR/#rr)rs"r rr8s######rc^\V4r!W8d#\W,4'd V^, pK(W!8d*\W^, ,4'd V^,pK/WVP4#)z^Strip stray edge punctuation (``.NO_REPLY``, ``*NO_REPLY*``) without erasing marker structure.)lenr)r)rstartends& r _strip_edge_silence_punctuationr/8sZCI3 +.t{;;   +.t!G}== q c? ""rc V^8dQhRRRR/#)rrrrztuple[str, ...]r)rs"r rrBsAAAArc\V\4'dVP4MRp^\V4u;8d\8:gR#R#\ V4pW!8XdV3MW3p\ ;QJd.RV4FNK 5#!RV44#)zUCanonical forms of a short marker-sized response; ``()`` when not a candidate at all.c38"TFp\V4xK R#5iN)r!)r fs& r r 0_canonical_silence_candidates..Is@%Q-a00%r) isinstancerrr,_MARKER_LENGTH_CAPr/tuple)rstripped depunctuatedformss& r _canonical_silence_candidatesr>Bsy)$44tzz|"H s8} 2 2 2  3 28.Rsa9`A//9`sTFanyr>)rAs&r is_intentional_silence_responserJLs; 3a9VW_9`a33a3a3a9VW_9`a aarc V^8dQhRRRR/#r@r)rs"r rrUsSTrc\V\4'dVP4MRpV'gR#VP4Uu.uFq"P4'gKVNK ppVP 4P \ 4;'gU\;QJd,RW^,VR,34F 'gK R# R#!RW^,VR,344#uupi)aLoose silence matcher for autonomous lanes (cron, webhook). Models reliably bracket ``[SILENT]`` with a short note, so unlike the interactive EXACT rule this also suppresses when a marker sits on its own first/last line or the bracketed sentinel opens the response (``[SILENT] No changes detected``). A token buried mid-sentence is still delivered. Shares :data:`LIVE_GATEWAY_SILENT_MARKERS` so the two sets cannot drift. r2Fc38"TFp\V4xK R#5ir4)rJrEs& r r 1is_autonomous_silence_response..esJ4Sq'**4Sr7T)r8rr splitlinesrr_BRACKETED_SILENCE_MARKERSrI)rAr;lnliness& r is_autonomous_silence_responserTUs$.h#<#/B88:RR/E > >>  & &'A B  ccJ5=Qxr4SJccccJ5=Qxr4SJG ?s C(!C(c$V^8dQhRRRRRR/#)r agent_resultz dict | NonerArrr$r)rs"r rrjs'{{k{S{UY{rc\V\4;'d*VPR4'*;'d \V4#)zBSilence markers suppress delivery only for successful agent turns.failed)r8dictgetrJ)rVrAs&&r #is_intentional_silence_agent_resultr[js4 lD ) z z,2B2B82L.L z zQpqyQzzrc V^8dQhRRRR/#)reventrrz str | Noner)rs"r rros#*rc^RIHpV!V4PR4;p'dV#\VRR4'd%\ V4'dVP R,#\VRR4'g\VRR4'd\ #R#)aSThe persisted user-row kind for a gateway turn: only self-injected events are machinery. A scheduled heartbeat prompt is self-injected too (``_heartbeat_session_id`` is stamped only by the gateway poller, never inferred from inbound text), but it deliberately stays non-internal so authorization and the emergency stop still apply to it. admission_displaykindinternalF display_kind_heartbeat_session_idN)gateway.session_displayr`rZgetattr_producer_cardmetadata"INTERNAL_NOTIFICATION_DISPLAY_KIND)r]r`ras& r display_kind_for_eventrjosw: '++F33t3 uj%((^E-B-B~~n--uj%((GE;RTX,Y,Y11 rc V^8dQhRRRR/#rr]rrrYr)rs"r rrs#$rc\VRR4;'g/pVPR4p\VRR4'dKVPR4\9d1\V\4'dVP 4'dRV/#/#)rhN display_textrbFrc)rfrZPRODUCER_NOTICE_DISPLAY_KINDSr8rr)r]rhrs& r rgrgsmuj$/552H << 'Dz5))hll>.JNk.k4%%$**,,%% Irc V^8dQhRRRR/#rlr)rs"r rrsXXcXdXrct^RIHpV!V4PR4p/\V4CV'dRV/C#/C#)z``{"display_text": ...}`` for an internal event whose producer named an async-result card, plus the ``title_preview`` (titler-only) a canonical admission committed for this exact event.r_ title_preview)rer`rZrg)r]r`previews& r display_metadata_for_eventrtsA:&**?;G WnU# Wg'(B WWSU WWrc V^8dQhRRRR/#)rrcrrr$r)rs"r rrs33C3D3rcV\9#)a@Only a machinery turn may vanish on a bare silence marker; a human turn gets a visible fallback. The caller passes the current turn's persisted display kind instead of inferring it from the transcript: the inbound user row is not persisted yet, and a previous internal row must never authorize silence on a human turn. )MACHINERY_DISPLAY_KINDS)rcs&r is_machinery_display_kindrxs 2 22rc$V^8dQhRRRRRR/#)rrcrreply_expectedOptional[bool]rr$r)rs"r rrs'NN#N~NQUNrc0\V4;'gVRJ#)zIWhether a successful bare silence marker may remain silent for this turn.F)rx)rcrzs&&r silence_allowedr}s $\ 2 M Mn6MMrc V^8dQhRRRR/#)rrzr{rrYr)rs"r rrsPPNPtPrcVf/#RV/#)zThe persisted user row's ``reply_expected`` key, only when the adapter knew; crash recovery reads it back to judge a silence marker as the live turn did.rzr)rzs&r reply_expected_metadatars '2O.>-OOrc V^8dQhRRRR/#)rrrrr$r)rs"r rrs  C D rc\;QJd%R\V44F 'gK R# R#!R\V444#)auTrue while streamed ``text`` could still resolve to a silence marker. A buffer whose canonical form is a non-empty *prefix* of a marker (``"NO"`` on the way to ``"NO_REPLY"``, or an exact marker not yet terminated by stream-end) is held back so a raw marker is never shown and then retracted. Divergence from every marker, or exceeding the cap, resumes normal streaming. c3a"TFQoS;'dC\;QJd#V3Rl\4F 'gK RM RM!V3Rl\44xKS R#5i)c3D<"TFqPS4xK R#5ir4r)r markerrFs& r r 6is_partial_silence_marker...sQ5P6##A&&5Ps TFN)rIrDrEs&@r r ,is_partial_silence_marker..s@4A QQccQ5PQcccQ5PQQQ4s A AA$ATFrHr s&r is_partial_silence_markerrsI 3.t43333.t4 r>SILENTNO_REPLY沉默静默[沉默][静默]NO REPLY[SILENT]r4)__doc__ __future__rr'typingrr frozensetrDr:sortedrQrirorwPRODUCER_CARD_KINDSr9r!r)r/r>rJrTr[rjrgrtrxr}rrrrr rs # ()# G1 GG &="!*+=?Z*[ \#%G$hJg$hi !C dFc de2G #Ab*{ $X3N P r