+ jHjWRt^RIHt^RIt^RIt^RIt^RIHtHtH t ^RI H t ^RI Ht]P!R4t!RR4tR#) zFallback delivery for GatewayStreamConsumer: continuation sends after edits stop working, chunking, cursor cleanup, commentary and silence retraction.) annotationsN)AnyCallableOptional)BasePlatformAdapter)ensure_closed_code_fenceszgateway.stream_consumerc]tRt^tRtRR/RRlltRRltRR lt]] 3R R ll4t R R lt RRlt RRlt RRltRR/RRlltRRlt]RRl4tRRltRRltR R!ltR"R#ltR$R%ltR&R'ltR(R)ltR*tR#)+StreamFallbackMixinzUNon-streaming delivery paths used once progressive edits fail or the turn ends oddly.finalFc(V^8dQhRRRRRRRR/#)textstr reply_to_id Optional[str]r boolreturn)formats"E/home/ubuntu/.hermes/hermes-agent/gateway/stream_consumer_fallback.py __annotate__ StreamFallbackMixin.__annotate__s*#M%)6Cc `"VPV4pVP4'gV#VPPVPWVP W3'*R7R7GRjxL pVP 'dVP'g RVnV#\VP4Vn VPV4RVn Wn VP4\VP4#L \d#p\ P#RT4TuRp?#Rp?ii;i5i)zISend a new chunk threaded to ``reply_to_id``; returns the new message_id.)r expect_editschat_idcontentreply_tometadataNFTzStream send chunk error: %s)_clean_for_displaystripadaptersendr_metadata_for_sendsuccess message_id_edit_supportedr _message_id_track_preview_ids_from_result _already_sent_last_sent_text_notify_new_message Exceptionloggererror)selfr rr resultes&&&$ r_send_new_chunk#StreamFallbackMixin._send_new_chunks&&t,zz||  <<,, d00u90U-WWFNNNv'8'8'8',$"""6#4#45D   / / 7!%D #'  $ $ &v(() )W  LL6 :  s`*D.AC>-C<.C>C>C>D.AC>;D.<C>> D+ D& D+!D.&D++D.cV^8dQhRR/#)r rrr)rs"rrr+s///rc $VP;'gRpVPP'dOVPVPP4'd$VR\ VPP4)pVP V4#)z>Return the visible text already shown in the streamed message.N)r+cfgcursorendswithlenr )r0prefixs& r_visible_prefix#StreamFallbackMixin._visible_prefix+sf%%++ 88???vtxx??2c$((//223F&&v..rc V^8dQhRRRR/#r final_textrrr)rs"rrr2sSSrc VP;'gVP4pV'dVPV4'd\V4pV\V48d~W,P 4'gbW^, ,P 4'g?\ VP R^V4VP R^V44pV^8d V^,pWRP4#V#)zAReturn only the part of final_text the user has not already seen.  N)_fallback_prefixr= startswithr;isspacemaxrfindlstrip)r0rAr<cutboundarys&& r_continuation_text&StreamFallbackMixin._continuation_text2s&&@@$*>*>*@ j++F33f+CS_$Z_-D-D-F-Fz`aZaObOjOjOlOl$$S!S1$$T1c2q="Q,Cd#**, ,rc(V^8dQhRRRRRRRR/# r r rlimitintlen_fnzCallable[[str], int]rz list[str]r)rs"rrrJs*;;;S;:N; );rc &^RIHpV!WVRRR7#)zOSplit text for fallback sends: newline-preferred, fence-balanced across chunks.)split_text_fence_awareFT)prefer_paragraphsbalance_fences)gateway.platforms.helpersrU)r rQrSrUs&&& r_split_text_chunks&StreamFallbackMixin._split_text_chunksIs E%d6U59; ;rc(V^8dQhRRRRRRRR/#rPr)rs"rrrQs*   S BV "+ rc \VPRR4p\V4'gVPWV4#\ VP\ 4'd V!WVR7pMV!W4p\ V\ \34'd;\;QJdRV4F 'dK RM RM !RV44'gVPWV4#\ V4#)zSplit via the adapter's canonical truncate_message (platform-specific rules); non-base test doubles / legacy adapters keep the two-argument call shape.truncate_messageNrSc3B"TFp\V\4xK R#5i)N) isinstancer).0cs& r ;StreamFallbackMixin._truncate_for_stream..\s;_X^STJq#AHHHc V^8dQhRRRR/#)r rArrrr)rs"rrrs--c-m-rc 6"VP4pVP4'dW8Xd\VPRR4RJduVP V4GRjxL pVR8XdR#RVnRVnRVnVR 9VnVR8XdVPV4R#VR8Xd RVn R#RVn R#VP4'd W8wdV#VP'dVP'dVPP'dVPP!VPP4'dVPR\#VPP4)p\$P&!\(4;_uu_4VP+VPVR 7GRjxL pVP,'dW@n RRR4RVnVP/VR 7R#ELLB +'giL0;i5i) zFallback entered but the visible prefix already covers ``final_text``: returns the continuation to send (the whole final when the prefix is from a *previous* segment) or None when the turn is settled here.%RESEND_FINAL_ON_EMPTY_STREAM_FALLBACKFTN deliveredr7 ambiguouspreviewr&rrw>rr)r=r!rer"_send_empty_fallback_finalr*rEr_final_content_delivered_record_turn_final_payload_delivery_ambiguous_final_response_sentr(r+r8r9r:r; contextlibsuppressr- _edit_messager%r)r0rAvisibledelivery clean_textr1s&& rr|1StreamFallbackMixin._fallback_when_nothing_unseens&&(     :#8DLL*QSXY]aa!<>>+5(0" ""*"5II<c0/sbAHHA4HH.HH4HAH !HHHH$HH H HcV^8dQhRR/#)r rz tuple[Callable[[str], int], int]r)rs"rrrs " "&F "rc \VPRR4p\p\VP\4'deVPP pVPP VP4pVPPVP4pW!3#W!3# \d#p\PRT4Rp?Y!3#Rp?ii;i)uQ(len_fn, raw_limit) for fallback chunking — per-chat cap/unit on base adapters.MAX_MESSAGE_LENGTHz$per-chat limit resolution failed: %sN) rer"r;r`rgmessage_len_fnmax_message_length_for_chatrmessage_len_fn_for_chatr-r.debug)r0rrr2s& rr}(StreamFallbackMixin._fallback_len_budgetsDLL*>E (+ dll$8 9 9ll11G H LLDDT\\R ,,>>t||L!!w!! H CQGG!! HsA B%% C0C  CrNc V^8dQhRRRR/#)r rrrtr)rs"rrrsssrc 2"\VPVVPRR7R7pVeW4R&Rp\^4FpVPP !R /VBGRjxL p\ VRR4'dV#VPV4pV'gVfV#\ VRR4p\V\4'dVPR 4'dV#\PW'4\P!V4GRjxL K V#LL 5i) zadapter.send(final metadata) with ONE bounded flood retry; returns the last SendResult. Exceptions propagate (callers decide whether a raise is "ambiguous").Tr rrrNrr%F raw_responsepartial_overflowr)dictrr$ranger"r#re_fallback_flood_retry_delayr`getr.rasynciosleep) r0rrtrkwargsr1attempt retry_delayraws &$$$ rr*StreamFallbackMixin._send_with_flood_retrys dllG#66T6BD  !): QxG<<,,6v66Fvy%00 ::6BK+-  &.$7C#t$$1C)D)D  LL 0-- , , ,  7 -s1A D"D#2DAD1DD DDc V^8dQhRRRR/#r@r)rs"rrrs##3#3#rc "VPRR7pVPWPRR7GRjxL p\TR R 4'g5TPT4'dR #TP T4'dR#R#\TR R4pTPY%R RR7GRjxL \4Tn T;'gRTn RTn TP4TPT4TnYnRTnR TnTP)4R#L \d<p\P RT4TP T4'dRMRuRp?#Rp?ii;iL5i)zCommit a completed answer after Telegram finalization fails: "delivered", "failed" (gateway may retry), "ambiguous" (a timeout may have landed) or "preview" (flood control; the complete preview is authoritative).T) segment_onlyz=Flood control on empty fallback final send; retrying in %.1fsrsNz$Empty fallback final send failed: %srfailedr%Frr&zEmpty fallback)skipruretry_on_false __no_edit__r7r)_stale_preview_idsrr~r-r.r _send_failure_may_have_deliveredre_is_flood_errorrset_segment_preview_message_idsr(r*r_display_payload_delivered_final_textr+rErr,)r0rA stale_idsr1excnew_message_ids&& rr.StreamFallbackMixin._send_empty_fallback_finalsm +++>  [66"-F-FY7[[F vy%00##F++ "&"G"G"O"O; ]U] ] t<##IJZ37$9 9 9,/E))::]! ""$&*%:%::%F") "380   "9[ [ LL? E"&"G"G"L"L;RZ Z [ 9sbE+ D DD )E+%E+>(E+&E)'E+AE+D E&+0E!E&E+!E&&E+c V^8dQhRRRR/#)r result_or_excrrrr)rs"rrrsOOOOrc \VRR4RJdR#\\VRR4;'gT4P4pVPPP4pRV9;'gRV9;'gRV9#)z>Return True for timeout failures where retrying may duplicate. retryableNTFr/timeoutz timed out)rerlower __class____name__)rr/names& rr4StreamFallbackMixin._send_failure_may_have_delivereds{ =+t 4 <GM7D9JJ]KQQS&&//557E!NN[E%9NNY$=NNrc V^8dQhRRRR/#)r r1rrz float | Noner)rs"rrr$s  # , rc VPV4'gR#\\VRR4;'gR4pW P 8d\ PRV4R#\RV4# \\3dRpLIi;i)zCReturn a bounded retry delay for a fallback send, if safe to retry.N retry_afterg@zCFlood control requests %.1fs; leaving final delivery to the gatewayg) rfloatre TypeError ValueError!_max_fallback_flood_retry_secondsr.rrH)r0r1delays&& rr/StreamFallbackMixin._fallback_flood_retry_delay$s##F++ '&->EE#FE 99 9 LL^ 3 :& E sA/A//BBcV^8dQhRR/#)r rrr)rs"rrr2sYYYrc \VRR4;'gRP4pRV9;'gRV9;'gRV9#)zFCheck if a SendResult failure is due to flood control / rate limiting.r/r7floodz retry afterrate)rer)r0r1 err_lowers&& rr#StreamFallbackMixin._is_flood_error2sFVWb177R>>@ )#XX} 'AXXVyEXXrcV^8dQhRR/#r rrpr)rs"rrr7sBB4Brc "\VRR4'dR#VP'gVP4GRjxL VP;'gVP 4pVP pV'd4VP V4'dV\V4RP4pVPV4pVP4'gR#VP'd\VP4M/pRVR&VPPVPW#R7GRjxL pVP 'd RVnR#R#ELL$ \$d"p\&P)RT4Rp?R#Rp?ii;i5i)zxBefore a segment reset, send the unseen tail as a new message (and best-effort strip the stuck cursor from the partial).rrFNT _interim_sendrz"Segment-break tail flush error: %s)rer{_try_strip_cursorrEr= _accumulatedrFr;rJr r!rrr"r#rr%r*r-r.r/)r0rtail_mdr1r2s& r#_flush_segment_tail_on_edit_failure7StreamFallbackMixin._flush_segment_tail_on_edit_failure7s5 4+U 3 3 (((((* * *''AA4+?+?+A   tw//G &--/D&&t,zz||  B)-$t}}%BC#'C <<,,T\\4,^^F~~~%)" +_ B LL=q A A Bsv'FFEF$F:FAFFE)AE/E0EE FE F!E=7F=FFcV^8dQhRR/#rr)rs"rrrOs...rc "VP4pVP4'dVP4'gR#\P!\ 4;_uu_4VP VPVR7GRjxL p\VRR4'dWn RRR4R#L' +'giR#;i5i)zEBest-effort edit removing a stuck cursor when entering fallback mode.Nrr%F) r=_has_real_previewr!rrr-rr(rer+)r0r<r1s& rr%StreamFallbackMixin._try_strip_cursorOs%%'%%''v||~~    + +--9I9ISY-ZZFvy%00'-$, +Z, + +s4> !c  LL4a 8 sM*E,D=B'D=-D;.D=6D=:E,;D== E)E$E,$E))E,cV^8dQhRR/#)r rrRr)rs"rrrzsCrc \VPRR4p\VP\4'd`VPP VP 4pVPP4p\V\4'd W18dV#V# \ d!p\PRT4Rp?LaRp?ii;i \ d#p\PRT4RpRp?LvRp?ii;i)zPer-chat length budget (``message_len_fn`` units) before overflow splits; rich adapters may raise it via ``streaming_overflow_limit`` so a reply that fits one rich message isn't fragmented at the edit limit.rrz&max_message_length_for_chat failed: %sNz)streaming_overflow_limit check failed: %s) rer"r`rgrrr-r.rstreaming_overflow_limitrR)r0baser2caps& r_raw_message_limit&StreamFallbackMixin._raw_message_limitzst||%94@ dll$8 9 9 J||?? M ll;;=#s##    J EqII J  H!L s/%BC C$B??C C4C//C4cV^8dQhRR/#rr)rs"rrrs^^^rc "VP'dVPR4GRjxL VPVP4RR7GRjxL \ 4VnRVnR;Vn;VnVn RVn VP4\PRVP4R#LLj5i)zRetract any streamed preview when the final reply is a bare silence marker. Flags stay False so the gateway's whole-response filter owns what goes out next: "" for a machinery turn, the visible fallback for a human one.z-Silence-marker native stream close failed: %sNzSilence-marker)rur7Fz8Suppressed streamed intentional-silence marker (chat=%s))_native_stream_opened_close_empty_native_bubblerrr_preview_message_idsr(r_stream_ledgerr+r*_clear_turn_final_flagsr.infor)r0s&r_suppress_silence_marker,StreamFallbackMixin._suppress_silence_markers  % % %112ab b b##D$;$;$=EU#VVV$'E!IKKKD/$2F" $$& NPTP\P\] cVs"'B?B;(B?B=A)B?=B?)rr*rrr'r{rErrrr+r(rrr)r __module__ __qualname____firstlineno____doc__r3r=rM staticmethodr;rYrmrr|r}rrrrrrrrrr__static_attributes__rrrr r s_,1./.QT;; B9H-^ "UY,#JOO Y B0.B,^^rr )r __future__rrrloggingtypingrrrgateway.platforms.baserrggateway.stream_consumer_fencesr getLoggerr.r rrrr sDN#**ND   4 5N^N^r