+
jHj r R t ^ RIHt ^ RIt^ RIHtHt ^ RIHt ]P ! R4 t
! R R4 t R# )ay Think-block filtering for GatewayStreamConsumer.
Some models emit inline ... blocks in content. The agent strips
them from the final response, but intermediate edits go out before that, so this
mirrors the CLI's _stream_delta state machine; tag primitives are shared with
``agent/think_scrubber.py`` so the progressive display matches the post-stream scrubber.) annotationsN)THINK_CLOSE_TAGSTHINK_OPEN_TAGS)StreamingThinkScrubberzgateway.stream_consumerc h ] tR t^tRt]t]tR R lt R R lt
R R lt ] R R l4 t
R
R ltR tR
# )StreamThinkFilterMixinz9Progressive -tag suppression over streamed deltas.c $ V ^8 d QhRRRRRR/# ) bufstridxintreturnbool )formats "B/home/ubuntu/.hermes/hermes-agent/gateway/stream_consumer_think.py __annotate__#StreamThinkFilterMixin.__annotate__ s! 5 5c 5 5 5 c
( V P ' * ;' g V P P R4 pV^ 8X d V# VRV pVP R4 pVR8X d T;' d VP 4 R8H # WE^, R P 4 R8H # )zTag at ``idx`` starts a block: start of text, or newline + optional whitespace.
Prose that merely *mentions* a tag must not trigger.
N ) _accumulatedendswithrfindstrip)selfr
r acc_boundary precedinglast_nls &&& r _at_block_boundary)StreamThinkFilterMixin._at_block_boundary s
,,,PP0A0A0J0J40P !8 I //$' b= ;;IOO$5$; ;1 &,,."44r c $ V ^8 d QhRRRRRR/# )r r
r lower_bufr ztuple[int, int]r )r s "r r r & s! " "c "c "o "r c
R^ rCV P Fj pVP 4 p^ pVP Wg4 ;pR8w g K/ V P W4 ' d VR8X g W8 d
T\ V4 rCKa V^, pKW W43# )zG(index, length) of the earliest block-boundary opening tag, or (-1, 0).r )_OPEN_THINK_TAGSlowerfindr" len) r r
r% best_idxbest_lentag tag_lower search_startr s &&& r _earliest_open_tag)StreamThinkFilterMixin._earliest_open_tag& s} (((C I L#..AA3bH**344 2~ -0#c(( "Qw ) !!r c V ^8 d QhRRRR/# )r textr r Noner )r s "r r r 4 s & &3 &4 &r c
V P V, pRV n V' EdI VP 4 pV P ' dy \ P ! W P
4 w rEV' d RV n W$V, R pKi \
R V P
4 4 p\ V4 V8 d W&) R MTV n R# V P W#4 w rEV' d) V P VRV 4 RV n W$V, R pK \ P ! W P 4 pV' d" V P VRV) 4 W') R V n R# V P V P V4 4 R# R# )zAppend a delta to the buffer, discarding think blocks.
Partial tags at buffer boundaries are held in ``_think_buffer`` until
enough characters arrive to decide.
r FNc 3 8 " T F p\ V4 x K R # 5i)N)r* ).0ts & r @StreamThinkFilterMixin._filter_and_accumulate..G s !I2HQ#a&&2Hs T)
_think_bufferr( _in_think_block _Scrubber_find_first_tag_CLOSE_THINK_TAGSmaxr* r0 _append_accumulated_max_partial_suffixr' _strip_orphan_close_tags)r r3 r
r% r+ r, max_tag held_backs && r _filter_and_accumulate-StreamThinkFilterMixin._filter_and_accumulate4 sN 4' c I###%.%>%>sDZDZ%["+0D( 1 23C "!I$2H2H!I IG;>s8g;MXY SVD&%)%<%r[ s6 \ # B D 4 5S$ S$r