+ iHj#%a0t$Rt^RIHt^RIt^RIHt.R OtR tR] R&] ;QJd.R ]4FNK 5M !R ]44t R] R&] ;QJd.R ]4FNK 5M !R ]44t R] R&!R R4t R#)aStateful scrubber for reasoning/thinking blocks in streamed assistant text. The regex ``_strip_think_blocks`` is correct for a complete string but, run per-delta, erases an opening ```` that arrives alone, so downstream state machines leak reasoning. This class holds partial tags at delta boundaries until resolved; ``flush()`` releases held-back prose that was not a tag; ``reset()`` at the top of each turn. An open tag only starts a block at a block boundary (stream start / after a newline / whitespace-only line so far), so prose that *mentions* ```` is not suppressed; closed pairs are always suppressed (intentional). ) annotationsN)TupleTHINK_CLOSE_TAGSTHINK_OPEN_TAGSTHINK_TAG_NAMESStreamingThinkScrubbertuple[str, ...]c#J"TFpRVP4 R2xK R#5i)<>Nlower.0names& 9/home/ubuntu/.hermes/hermes-agent/agent/think_scrubber.py rs(Y1TZZ\N!)<!#c#J"TFpRVP4 R2xK R#5i)?rc]tRt^t$Rt]tR]R&]t R]R&]] ,t R]R&] !R] 44t R]R&] P!R R PR ] 44,R ,] P 4tR RltRRltRRltRRltRRltRRlt]RRl4tRRltRRltRR lt]R!R"l4t]R#R$l4tR%t R&#)'ruYStateful scrubber for streaming reasoning/thinking blocks. State: ``_in_block`` (inside an open block; text discarded), ``_buf`` (held-back partial-tag tail), ``_last_emitted_ended_newline`` (True iff the last emission ended with ``\n`` or nothing was emitted yet — decides whether an open tag at buffer position 0 sits at a block boundary). r _OPEN_TAGS _CLOSE_TAGS _ALL_TAGSc# 8"TFp\V4xK R#5iN)len)rtags& rr StreamingThinkScrubber.+s: CHH sint _MAX_TAG_LENz(?:|c# N"TFp\P!V4xK R#5ir)reescape)rts& rrr.s;{!1{s#%z )[ \t\n\r]*cV^8dQhRR/#returnNone)formats"r __annotate__#StreamingThinkScrubber.__annotate__1s$c &VP4R#r)resetselfs&r__init__StreamingThinkScrubber.__init__1s  r/cV^8dQhRR/#r'r+)r,s"rr-r.4s##t#r/c >RVnRVnRVnRVnR#)z4Reset all state. Call at the top of every new turn.FTN) _in_block_buf_last_emitted_ended_newline last_hiddenr2s&rr1StreamingThinkScrubber.reset4s $ 15( "r/c$V^8dQhRRRRRR/#)r(out list[str]textstrr)r*r+)r,s"rr-r.<s&CCC#C$Cr/c VPV4pV'd*VPV4VPR4VnR#R#)zVAppend visible prose to *out* (orphan close tags stripped) and track the newline flag. N)_strip_orphan_close_tagsappendendswithr;)r3r?rAs&&&r_emitStreamingThinkScrubber._emit<s7,,T2  JJt /3}}T/BD , r/c V^8dQhRRRR/#r(rArBr)r+)r,s"rr-r.Cs----r/c  RVnV'gR#VPV,pRVn.p.pV'EdVP'dyVPW P4wrVVR8Xd-VP VP W P44EM9VP VRV4W%V,RpRVnKVPV4pVPW#4wrVeVR8XgV^,V8:dzVPW2RV^,4VP W"PRV^,4^,VPRV^,V^,44W'^,RpEKIVR8wd*VPW2RV4RVnW(V ,RpEKyVPW0P W P44RPV4VnRPV4#)z_Feed one delta; return the scrubbed visible portion ("" when it is all reasoning or held back).r8NFr r T)r<r:r9_find_first_tagrrF _hold_partial_find_earliest_closed_pair_find_open_at_boundaryrHindexrindexrjoin) r3rAbufr?hidden close_idx close_lenpairopen_idxopen_lens && rfeedStreamingThinkScrubber.feedCsii$ c~~~'+';';CAQAQ'R$ ?MM$"4"4S:J:J"KL c*9o.i/01!& 2237D!%!_`aq'(m2~ 3IX/!%X-./ JJs..sNNC D 776?wws|r/c$V^8dQhRRRRRR/#)r(rUrBtagsrr)r+)r,s"rr-r.rs!,,,O,,r/c lVPW4pV'dW)RMRVnV'dVRV)#T#)zPMove a trailing partial-tag prefix of *buf* into ``_buf``; return the remainder.Nr8)_max_partial_suffixr:)r3rUr_helds&&& rrO$StreamingThinkScrubber._hold_partialrs8''2#'CKR "s6TE{++r/cV^8dQhRR/#)r(r)rBr+)r,s"rr-r.xs C Cs Cr/c VP'dRM VPpRVnRVnRVnV'dVPV4#R#)unEnd-of-stream flush: inside an unterminated block the held-back content is discarded (leaking partial reasoning is worse than a truncated answer), otherwise the tail is emitted verbatim. Always resets the boundary flag — intra-turn retries flush then stream again without ``reset()``, and a stale False flag made the new stream's opening ```` look mid-line.r8FT)r9r:r;rE)r3tails& rflushStreamingThinkScrubber.flushxsE ^^^r +/(6:t,,T2BBr/c$V^8dQhRRRRRR/#)r(rUrBr_rr)tuple[int, int]r+)r,s"rr-r.s!..S..O.r/c VP4pVUu.uF)q2PV4;pR8wgKV\V43NK+ ppV'd \V4#R#uupi)zOReturn (earliest_index, tag_length) over *tags* (case-insensitive), or (-1, 0).rMrM)r findrmin)rUr_ buf_lowerridxhitss&& rrN&StreamingThinkScrubber._find_first_tagsXIIK +/V4C>>#;N4NCSU3Uc#h4V s4y-g-Ws AAcV^8dQhRR/#)r(rUrBr+)r,s"rr-r.s - -c -r/c nVP4p.p\VPVP4FkwrEVP V4pVR8wd"VP WV\ V4,4MRpVR8wgKIVP Wg\ V4,34Km V'd \V4#R#)zg(start_idx, end_idx) of the earliest ``...`` pair (non-greedy, case-insensitive), else None.NrM)r ziprrrnrrFro)r3rUrppairsopen_tag close_tagrZrWs&& rrP1StreamingThinkScrubber._find_earliest_closed_pairsIIK #&t8H8H#I H ~~h/HOW[]~ yS]2JKceIB hC N(BCD $J #s5z,,r/c$V^8dQhRRRRRR/#)r(rUrBalready_emittedr@r)rjr+)r,s"rr-r.s! . .# . .o .r/c TVP4p.pVPFrpVPV4pVR8wd3VPWV4'gVPWV^,4pK9VR8wgKVVP V\ V434Kt V'd \ V4#R#)zCReturn the earliest block-boundary open-tag (idx, len), or (-1, 0).rMrl)r rrn_is_block_boundaryrFrro)r3rUr|rprrrrqs&&& rrQ-StreamingThinkScrubber._find_open_at_boundarysIIK ??C..%C)D$;$;Co$V$VnnS'2by S#c(O, # !s4y-g-r/c(V^8dQhRRRRRRRR/#) r(rUrBrqrr|r@r)boolr+)r,s"rr-r.s/ d dc d di dTX dr/c V'dVR,PR4M VPpV^8XdV#VRVpVPR4pVR8XdTMR;'dWV^,RP4R8H#)a True iff *idx* is a block boundary: position 0 after a newline-terminated (or no) prior emission, or any position whose preceding text on the current line is whitespace-only (when no newline precedes it in *buf*, the prior emission must also have ended with a newline).rDNTr8rM)rGr;rfindstrip)r3rUrqr| prior_newline precedinglast_nls&&&& rr~)StreamingThinkScrubber._is_block_boundarysz?N+44T:SWSsSs !8 I //$'!(B DcciRS >U>[>[>]ac>ccr/c$V^8dQhRRRRRR/#)r(rUrBr_rr)rr+)r,s"rr-r.s!cSr/c 2aaVP4p\\\V4VP^, 4^R4FOoVS)Ro\ ;QJd VV3RlV4F 'gK RM RM!VV3RlV44'gKMSu# ^#)zfLongest buf-suffix that is a strict prefix of any tag (full matches are real tags, handled elsewhere).Nc3r<"TF,p\V4S8;'dVPS4xK. R#5ir)r startswith)rrisuffixs& rr=StreamingThinkScrubber._max_partial_suffix..s-Kds3s8a<::CNN6$::ds77TFrM)r rangerorr any)clsrUr_rprrs&&& @@rra*StreamingThinkScrubber._max_partial_suffixsrIIK s3y>3+;+;a+?@!RHArs^FsKdKsssKdKKKIr/c V^8dQhRRRR/#rKr+)r,s"rr-r.sLLCLCLr/c LRV9dVPPRV4#T#)zPRemove close tags with no matching open (always noise) plus trailing whitespace.rr8)_ORPHAN_CLOSE_REsub)rrAs&&rrE/StreamingThinkScrubber._strip_orphan_close_tagss(6:T\s##''D1KtKr/)r:r9r;r<N)!__name__ __module__ __qualname____firstlineno____doc__rr__annotations__rrrmaxr r#compilerT IGNORECASErr4r1rHr\rOrg staticmethodrNrPrQr~ classmethodrarE__static_attributes__r+r/rrrs#2J1#3K3!+k!9I9: ::L#:zz ;{;;;nLbmm#C-^, C.. - . dLLr/)rrrr) thinkthinking reasoningthoughtREASONING_SCRATCHPADu思考u反思u推理u推敲)__conditional_annotations__r __future__rr#typingr__all__rrtuplerrr)rs@rrs#  ^$$)5(Y(Y55(Y(Y#YY$)E)[?)[EE)[?)[$[/[\L\Lr/