+ iHjO a0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIH t ^RI H t H t H t Ht^RIHtHt^RIHt^RIHt]P,!]4t]P2!R4t]!R R R R ]04tR Rlt]P2!R4tRRRlltRRlt RRlt!RRlt"RRlt#] !]"]R7t$] !]#]RR7t%] !]"] R7t&] !]#] RR7t']&t(RRlt)R R!lt*R"t+R#R$lt,R%R&R'R(/t-R)R*lt.RR+R,llt/RR-R.llt0R/R0R1R2R3R /t1R4R5lt2R6R7lt30Rmt4R8R9lt5Rt6Rt7R:R;lt8R<R=lt9R>R?lt:.R@NRANRBNRCNRDNRENRFNRGNRHNRINRJNRKNRLNRMNRNNRONRPNRQNRRNRSNRTNRUNRVNRWNRXNRYNRZNR[NR\NR]NR^Nt;R_R`ltReRflt?RgRhlt@RiRjltARkRlltBRRmRnlltCRtDRoRpltERqRrltFRs]!RtRu04]!4RR3Rv]!4]!Rv04RR3Rw]!4]!Rx04RR3Ry]!4]!4RR33tGRz]HR{&]GUu/uF q^,VbK uptIR|R}R~utJtKtL]J]K]L3tM]!]M4tN]!]J04tO]!]J]K04tP]!4]!0Rm4R3]!]J04]!R04R3]N]!0Rm4R3]!]J]L04]!0Rm4R3]P]!0Rm4R33tQRz]HR&!RR]4tRRRltSRRltTRRltURRltVRRltWRRRR/RRlltXRRltYRRltZRRlt[RRlt\RRRllt]RRlt^RRRllt_Rt`]J]P2!R4]L]P2!R4]K]P2!R4/taRRltbRRltcRtdRRlteRRltfR#uupi)a+Message and tool-payload sanitization helpers (pure; documented in-place mutation). Walk OpenAI-format message lists and structured payloads, repairing or stripping characters that would crash ``json.dumps`` in the OpenAI SDK or be rejected upstream. ``run_agent`` re-exports them for old imports. ) annotationsN)partial)AnyCallableIterable NamedTuple)_INTERRUPTED_PLACEHOLDER hidden_interrupt_placeholder_row)DB_ROW_SNAPSHOT)_provider_model_keyz[\ud800-\udfff]contentname tool_callsrolec V^8dQhRRRR/#textstrreturn)formats"?/home/ubuntu/.hermes/hermes-agent/agent/message_sanitization.py __annotate__r s--s-s-c^VP4'dV#\PRV4#)zHReplace lone surrogate code points with U+FFFD; no-op when none present.u�)isascii _SURROGATE_REsubrs&r_sanitize_surrogatesr s' ||~~   Xt ,,rz[A-Za-z0-9_-]{1,64}c$V^8dQhRRRRRR/#)rr rfallbackrrr)rs"rrr/s! $ $3 $# $ $rc (\V\4'gV#\PV4'dV#\P !RR\P !RRVP 444P R4pVR,;'gT#)uCoerce a *replayed* tool/function name to ``^[A-Za-z0-9_-]{1,64}$``. Valid names are returned as-is (identity — prompt-cache safe); invalid runs collapse to ``_`` and the result is cut at 64; empty/all-invalid → ``fallback``. Deterministic, so the same stored name always renders the same bytes. Never apply to live tool definitions (schema names must match the dispatch registry).z_+_z[^A-Za-z0-9_-]:N@N) isinstancer_VALID_TOOL_NAME_RE fullmatchrerstrip)r r"coerceds&& rcoerce_tool_namer,/sp dC $$T** ffUC(93 !MNTTUXYG 3< # #8#rc V^8dQhRRRR/#rr)rs"rrr<sAA3A3ArcvVP4'dV#VPRRR7PR4#)uSDrop non-ASCII characters — last resort for ASCII-only system encodings (LANG=C).asciiignoreerrors)rencodedecoders&r_strip_non_asciir5<s0 ||~~ ;;wx; 0 7 7 @@rc(V^8dQhRRRRRRRR/#)r containerrkeyfixCallable[[str], str]rboolr)rs"rrrCs)c2F4rc\V\4'dVPV4MW,p\V\4'd V!V4MTpWC8XdR#W@V&R#)zGApply ``fix`` to ``container[key]`` if it is a str; True if it changed.FT)r&dictgetr)r7r8r9valuefixeds&&& r_fix_str_fieldrACsI",Y"="=IMM# 9>E$UC00CJeE ~cN rc$V^8dQhRRRRRR/#)rpayloadrr9r:rr;r)rs"rrrMs"   +? D rcRpV.pV'dVP4p\V\4'dVP4M"\V\4'd \ V4MRp\ V4F_wrg\V\ 4'dV\WFV4,pK0\V\\34'gKNVPV4Ka KV#)zHApply ``fix`` to every str inside nested dict/list ``payload`` in-place.Fr) popr&r=itemslist enumeraterrAappend)rCr9foundstacknoderFr8r?s&& r_sanitize_structurerMMs E IE yy{ *4 6 6 zZ^`dOeOeIdOkmu+JC%%%377ED$<00 U# & Lrc(V^8dQhRRRRRRRR/#)rmessagesrGr9r:deepr;rr)rs"rrr\s*   ,@ 4 TX rc^RIHpRpVEF0p\V\4'gKRpVP R4p\V\ 4'd-VUu.uFp\V\4'gKVR3NK! upMRp V eT MVR3.p V P VR34VP R4p \V \ 4'dT MR Fp \V \4'dV P R4MRp Y'd\V \4'dV R 3.M., p T \V \4'dV'dV R3.M.V R 3.,M., p K V FwrV\WV4,pK VP4Uu.uFpV^,\9gKVNK upFlwpp\V\4'dV\W_V4,pK1V'gK;\V\\ 34'gKYV\VV4,pKn V'gEKVPVR4R pEK3 V#uupiuupi) aApply ``fix`` to the string fields of every message dict in-place (content / part text, name, tool_call arguments, non-core top-level str fields). ``deep=True`` adds tool_call ids, function names, and NESTED non-core fields (``reasoning_details`` from byte-level models)._DB_PERSISTED_MARKERFr rNr rfunctionid argumentsTr) agent.context_compressorrSr&r=r>rGrIrArF_MESSAGE_CORE_KEYSrrMrE)rOr9rPrSrJmsg msg_foundr ppartsfieldsrtcfnr7r8kvr?s&&$ r_sanitize_messagesra\s> E#t$$  '')$IST[]aIbIbgEgAt1D!VgEhl+3 2B1C sFm$WW\* *:t < <*"DB'1"d';'; #B dz"d/C/CDzl KF PZ[]_cPdPdV ~22{:K9LLjl lFE%NI  < getattragent.conversation_looprh_sanitize_structure_non_ascii)rcrdrhs&& rsanitize_outbound_kwargsrnse#:. !!! >>' " .:g3F'RWY`bfJg3g G"9*W:M"NJw %j1"rc V^8dQhRRRR/#)rrawrrr)rs"rrrsssrc.pRp^pV\V48dW,pV'dDVR8Xd=V^,\V48d&VPWV^,4V^, pKcVR8XdV'*pTPV'd \V4^ 8dR\V4R 2MT4V^, pKRPV4#)zEscape literal control chars (0x00-0x1F) inside JSON string values as ``\uXXXX`` (for llama.cpp-style output mixing control chars with other malformations).F\"z\u04x)lenrIordjoin)rpout in_stringichs& r%_escape_invalid_chars_in_json_stringsr}sCI A c#h, V tAC(8 JJsQU| $ FA  9% I )B$SR &BO Q 773<ric V^8dQhRRRR/#)rrrrr;r)rs"rrrsCDrcl\P!V4R# \PdR#i;i)TF)jsonloadsJSONDecodeErrorrs&r _loads_okrs. 4   s 33{}[]c V^8dQhRRRR/#)rrprr str | Noner)rs"rrrs"O"O"O"Orc.p.pRp^\V4rTWE8dW,pV'd7VR8Xd&VPWV^,4V^, pKBVR8XdRpMVR8XdRpMV\9dVPV4MjVR9ddVRV49dV\VR ,,V8wd-VP\VP4,4KEVP4VPV4V^, pKV'dR#RP V4RP R \ V444,#) u4Close a JSON prefix's open braces/brackets in stack order, ignoring delimiters inside string values (``{"code": "}"}`` keeps one open brace, not a balanced document). A closer that does not match the stack top but does match a deeper opener gets the missing inner closers inserted BEFORE it: ``{"a": [{"b": 1}}`` → the model dropped the ``]`` and let the neighbouring ``}`` close in its place, so the counts balance and nothing can be appended. ``None`` when the text ends inside an unterminated string — that content is unrecoverable and must not be guessed. FrrrsTz}]c3<"TFp\V,xK R#5iN _JSON_CLOSERS).0os& r *_rebalance_json_closers..s"CU=#3#3UNruc3<"TFp\V,xK R#5irr)rr|s& rrrs!No-"3"3or)rvrIrrErxreversed)rpryrKrzr{nr|s& r_rebalance_json_closersrsCEI c#hq % V Tz 3Q<(QSy! 3YI = LL  4ZB"CU"CCb *b0 =56 IIK 2 Q 773<"''!Nhuo!NN NNrc$V^8dQhRRRRRR/#)rraw_argsr tool_namerr)rs"rrrs!77#7#77rc\V\4'dVP4MRpV'g\P RV4R#VR8Xd\P RV4R#\ P !\ P!VRR7RR7pW28wd\P R V4V# \ P\\3dMi;i\P!R R T4p\T4;'gTp\^24Fp\T4'gyTP!R 4'd&TP#R 4TP#R 48g?TP!R4'd&TP#R4TP#R48gM TRRpK \T4'd(\P RYR,TR,4T#\%T4pYd8wd9\T4'd(\P RYR,TR,4T#\P RYR\&4R#)zRepair malformed tool_call argument JSON (truncation, trailing commas, Python ``None``, control chars); ``"{}"`` if unrepairable so the request succeeds. Repairs log at WARNING.ruz*Sanitized empty tool_call arguments for %sz{}rez0Sanitized Python-None tool_call arguments for %sF)strict) separatorsz>Repaired unescaped control chars in tool_call arguments for %sz ,\s*([}\]])z\1rrrrNu8Repaired malformed tool_call arguments for %s: %s → %s:NPNuARepaired control-char-laced tool_call arguments for %s: %s → %suPUnrepairable tool_call arguments for %s — replaced with empty object (was: %s),:r)r&rr*loggerwarningrdumpsrr TypeError ValueErrorr)rrrangerendswithcountr}_FULL_ARGS_LOG_BOUND)rr raw_stripped reserialisedr@r$escapeds&& r_repair_tool_call_argumentsrs(2(C'@'@8>>#bL CYOvI9U zz$**\%"HU_`  ' NN[]f g  )Z 8    FF>5, 7E #E * 3 3eE 2Y U   ^^C U[[%5 C8H%Hs## C(85;;s;K(K cr  QS\kn^oqvwzq{| 4E:GIg.. OQZil\movwzo{  NNZ 5!56 s)A B55 CCc$V^8dQhRRRRRR/#)rrOrGfinal_responserrr;r)rs"rrr s"dCSWrcNV'd VR ,MRp\V\4'dVPR4R8wdR#\V\4'dTMRp^RIHpVP 4pV'd V\8XdV!V\44R #V!VRRRV/4R #) uYAppend a synthetic assistant turn when an interrupted tail is a tool result: a transcript ending on a raw ``tool`` message makes the next user message land as ``tool → user``, an alternation violation strict providers (Gemini, Claude) answer by hallucinating a continuation. Mutates in place; True if a closing turn was appended. Only the placeholder closes silently: with no real text (or just the bare interrupt placeholder) the row is hidden from the user — ``api_content`` carries the LLM-visible text (substituted at API-build time by ``substitute_api_content``), ``content=""`` + ``display_kind="hidden"`` keep it out of rendered transcripts, matching the ``_INTERRUPTED_PLACEHOLDER`` shape in ``turn_api_call.py``. A caller-supplied banner (truncation notices, partial-delivery text) stays visible: it is the turn's only user-facing explanation.NrtoolFru)append_message assistantr Tr) r&r=r>ragent.message_metadatarr*rr )rOrlastrrstrippeds&& rclose_interrupted_tool_sequencer s$8B<D dD ! !TXXf%5%?'<<>"D5zz|H x#;;x!A!CD  x&+y(!KL r max_tokenslengthendstop function_callc V^8dQhRRRR/#)rrprrr)rs"rrrHs 8 8 8 8rc\V\4'd V'gV#VP4p\P W4#)zFold a wire ``finish_reason`` to the lowercase OpenAI contract value. Non-string and empty values pass through unchanged (callers keep their ``or "stop"`` defaults and the Poolside int-reason path); contract values are returned byte-identical. )r&rlower_FINISH_REASON_ALIASESr>)rplowereds& rnormalize_finish_reasonrHs4 c3  s iikG ! % %g 77rc V^8dQhRRRR/#)rrOrGrintr)rs"rrrUs 2 2 2 2rc \V\4'd V'g^#\\P!VRR\ R7P R44# \\3d\RT44u#i;i)zExact serialized byte size of ``messages`` (HTTP 413 is a BYTE-size error the token estimator, pricing images flat, cannot score). Non-serializable values fall back to ``str()`` so a malformed message can never crash recovery.F) ensure_asciirdefaultutf-8c3J"TFp\\V44xK R#5ir)rvr)rms& rr,serialized_messages_bytes..^s113s1v;;s!#r) r&rGrvrrrr3rrsum)rOs&rserialized_messages_bytesrUsg h % %X24::hUz[^_ffgnopp z "211112s5A#A>=A>c V^8dQhRRRR/#)rrOrGrr;r)rs"rrrds!!$!4!rc^RIHp^RIHpRp.p\ V4EF$wrV\ V\ 4'dVPR4MRp\ V\4'gKGVUu.uF7p\ V\ 4'dVPR4\9dK5VNK9 p p\V 4\V48gKRpV 'dWR&VPVR4MVVPR4R 8XgVPR 4'dR VR&VPVR4MVPV4V!V4EK' \V4FpWK V#uupi) uRemove image content parts from all messages in-place (server rejected images). ``tool`` / ``tool_calls`` messages left empty get a placeholder, NOT deleted (deleting orphans the paired ``tool_call_id`` → HTTP 400); other now-empty messages are dropped. Rewritten messages lose their ``api_content`` sidecar (it carries the removed images): a caller rewriting a persisted row must not leave bytes that replay them next turn. The current callers pass per-call clones, where this is a no-op. rR)drop_stale_api_contentFr NtypeTrrru:[image content removed — server does not support images])rWrSagent.turn_contextrrHr&r=r>rG_IMAGE_PART_TYPESrvrErIr) rOrSrrJ to_deleter{rYr r[ new_partss & r_strip_images_from_messagesrds>9 EIH%(23(=(=#'')$4'4((  'l1 1d0C0Cf YjHjQQ l y>CL (E!*I,d3F*cggl.C.C!]I,d3  # "3 '!&"i  K! Lms '2EEc$V^8dQhRRRRRR/#)rrcr api_messagesrr;r)rs"rrrs& X XC Xs Xt Xrc\V4VP9dR#\V\4;'d \ V4#)aSend-path image strip for a model that rejected image content (see turn_recovery). Runs on the per-call ``api_messages`` copy in Hermes's own message format, BEFORE the provider-specific conversion: the part types this stripper knows are that format's, and a converted payload (Bedrock Converse ``{"image": ...}`` blocks carry no ``type``) would slip past it. History is never touched. Keyed on each rejecting (provider, model), so a model that accepts images gets them again. F)r _image_rejecting_modelsr&rGr)rcrs&&r strip_images_for_rejecting_modelrs55!)F)FF lD ) W W.I,.WWrc V^8dQhRRRR/#r error_bodyrrr;r)rs"rrrsFFCFDFrca\T;'gR4P4o\;QJd#V3Rl\4F 'gK R# R#!V3Rl\44#)zMReturn True when a provider error says image/multimodal input is unsupported.ruc3,<"TF qS9xK R#5irrrphrasebodys& rr6_looks_like_image_content_rejection..sE,D&~,DTF)rrany_IMAGE_REJECTION_PHRASESrrs&@r#_looks_like_image_content_rejectionrsI zR & & (D 3E,DE33E3E3E,DE EErc V^8dQhRRRR/#rr)rs"rrrsDDCDDDrca\T;'gR4P4o\;QJd#V3Rl\4F 'gK R# R#!V3Rl\44#)zXReturn True when the rejection is about a bad image payload, not the model's capability.ruc3,<"TF qS9xK R#5irrrs& rr6_looks_like_corrupt_image_rejection..C,B&~,BrTF)rrr_IMAGE_CORRUPT_PHRASESrs&@r#_looks_like_corrupt_image_rejectionrsI zR & & (D 3C,BC33C3C3C,BC CCrrr}r_sanitize_messages_non_ascii_sanitize_messages_surrogatesrmrir _sanitize_tools_non_asciirr5apply_reasoning_content_policyrcoalesce_tool_call_idr,deterministic_call_idmatches_reasoning_echo_familyneeds_reasoning_echo normalize_provider_tool_call_idsreapply_reasoning_echoreasoning_echo_familyreasoning_replay_route record_reasoning_field_rejectionrejected_reasoning_carriersroute_reasoning_carriersrnstale_thinking_reaches_wirertool_call_id_variantstool_result_id_variantsuniquify_tool_call_idsc$V^8dQhRRRRRR/#)rr^rr8rrr)rs"rrrs&KK#KCKCKrch\V\4'dVPV4#\WR4#)zHRead ``key`` from a tool-call entry that may be a dict or an SDK object.N)r&r=r>rk)r^r8s&&r _tc_fieldrs($R..266#;JGBT4JJrc(V^8dQhRRRRRRRR/#rr^rr8rr?rrer)rs"rrrs.TTT#TcTdTrcp\V\4'dVPW4R#\WV4R#r)r&r= __setitem__setattrr^r8r?s&&&r_tc_setrs#",R"6"6BNN3GBU>$++gi+"HISSUVYZ[ \\rc V^8dQhRRRR/#)rvaluesztuple[Any, ...]rfrozenset[str]r)rs"rrrs  _  rc \4pVFtp\V\4'dVP4MRpV'gK5VP V4VP RRVP R4444Kv \V4#)zEvery wire spelling of one tool-call identifier: Responses bridges may expose the pairing id and response-item id separately or as ``call_id|response_item_id``; all alias ONE call.ruc38"TFq'gK VxK R#5irr)rr[s& rr+_expand_tool_id_variants..sX'R!VWAA'Rs  c3@"TFqP4xK R#5ir)r*)rparts& rrr!s'RAQ AQs|)setr&rr*addupdatesplit frozenset)rvariantsrpr?s& r_expand_tool_id_variantsr+smH)#s33  5 LL  OOX'RSAQ'RX X  X rc V^8dQhRRRR/#)rr^rrrr)rs"rrr sllclnlrca\\;QJd.V3RlR4FNK 54#!V3RlR444#)z. s)jDiq)B*:*:Dis)call_idrUresponse_item_id)r+tuple)r^sfrrr s/ #EE)jDi)jE kkE)jDi)j$j kkrc V^8dQhRRRR/#)r tool_call_idrrrr)rs"rrrs55#5.5rc\V34#)z>Return all matching variants for a role=tool ``tool_call_id``.)r+)r5s&rrrs #\O 44rc V^8dQhRRRR/#)rr^rrrr)rs"rrrsccrc \VR4\VR43Ffp\V\4'dVP4MRpV'gK5VP R^4^,P4;'gTu# R#)zEffective call id of a tool_call entry (dict or object); ``""`` when none. Codex Responses carry ``call_id`` (authoritative pairing key), Chat Completions ``id`` only, and bridge ids may be ``call_id|response_item_id``.r1rUrur$)rr&rr*r()r^rpr?s& rrrsk"i()B*=>)#s33  5;;sA&q)//1::U :? rc$V^8dQhRRRRRR/#)rrrGtaken Iterable[str]rr)rs"rrrs!**t*M*4*rc aa\V4oT;'g.EFp\VR4;'g\VR4;'gRp\V\4'dVP 4MRpVP R^4^,oS'gKySS9dSP S4K\VV3Rl\^\S4^,444pSP V4\VR4p\TR\V\4'd&RV9dV RVP R^4^, 2MT4\VR4'd\VRV4\\TR4R4;'gR p\PR SYF4EK V# \d\PRS4EKi;i) uEnsure every tool call in one assistant turn has an id no other call in the session has. Some providers reuse one id across a batch, and some name every call ``call_0`` turn after turn; the pre-API sanitizer then keeps only the first call/result pair per id, strict providers reject duplicates, and the desktop binds a tool card to the wrong call. ``taken`` is the ids already in this session's history: they are never rewritten (prompt cache), so the incoming call is renamed instead. Collisions get a deterministic ``_d`` suffix (never uuid4 — cache-prefix stability). Mutates entries (SDK models / SimpleNamespace / dicts) in place. Blank ids are left for the deterministic fallback in ``build_assistant_message``. r1rUrur$c3N<"TFpS RV 2S9gKS RV 2xK R#5i)_dNr)rrcidseens& rr)uniquify_tool_call_ids..7s3b-D3%rRSQT ]aHamRsm-Ds%%z,Could not uniquify duplicate tool call id %srTr ?ziModel reused tool call id %s; renamed the duplicate to %s (tool=%s) to keep call/result pairing lossless.)r%rr&rr*r(r&nextrrvr Exceptionrr) rr:r^rpnew_idold_fn_namer?r@s && @@rrrsE DBI&CC)B*=CC'S11ciikriiQ"  d? HHSM bU1c$i!m-Dbb  B%C BJsTWDXDX]`dg]g#))C*;A*>)?@ms tY''Iv.Yr:6?FF3 !$f 3:   NNI3 O  s/A3F  !GGc V^8dQhRRRR/#)rrrGrr)rs"rrrMs$rc \T;'g.4^8dV#\;QJdRV4F 'dK RM RM !RV44'gV#\PR4VFpR Fp\ W4p\ V\ 4'gK&VP4PR4wrEpVP4pVP\4'gKu\P!VPRR44P4R,p\WR V V V 24K K V#) zRewrite known provider ids when a parallel batch would be rejected on replay. The digest is deterministic so persisted messages and prompt-cache prefixes remain stable. Composite Responses ids retain their response-item half. c3^"TF#p\V4P\4xK% R#5ir)r startswith_PROVIDER_TOOL_ID_PREFIXES)rr^s& rr3normalize_provider_tool_call_ids..Ws(eZdTV$R(334NOOZds+-FTzJNormalized provider-minted parallel tool-call ids for replay compatibilityr$r surrogatepassrr)rUr1)rvallrrrr&rr* partitionrKrLrrr3r_set_provider_tool_id)rr^r8r?primarysepitemdigests& rrrMs   :  q  3eZde333eZde e e NN_`%Cb&EeS))!&!8!8!= G$mmoG%%&@AA^^GNN7O$LMWWYZ]^F !"U6(3%v+F G% rc(V^8dQhRRRRRRRR/#r r)rs"rrrls(  c  C D rc\\\V4VR4\4'd2\\VRR4\4'dW P V&R#\ WV4R#)N provider_data)r&rkrpropertyr=rXrrs&&&rrQrQlsO'$r(C.99jQSUdfjIkmq>r>r %rkimiz kimi-codingzkimi-coding-cndeepseekmimoxiaomi missingnor3_REASONING_ECHO_RULESreasoning_content reasoningreasoning_details fireworks_REASONING_CARRIER_ROUTESc0]tRtRt$RtR]R&R]R&RtR#) ReasoningReplayRouteia ``pad``: must-echo tier (missing reasoning_content -> " "). ``carriers``: the reasoning keys an assistant wire copy carries; ``None`` outside chat_completions, where the native adapters own reasoning replay (only the must-echo pad is applied, details are untouched).r;padfrozenset | NonecarriersrN)__name__ __module__ __qualname____firstlineno____doc____annotations____static_attributes__rrrrfrfsa Irrfc ,V^8dQhRRRRRRRRRR/#) rfamilyrproviderrmodelbase_urlrr;r)rs"rrrs1  #  S TW \` rcaa a ^RIHo \V,wrErgpT;'gRP4o W9;'gT;'gRP4V9;'g\;QJdV 3RlV4F 'gK RM RM!V 3RlV44;'g=\;QJd VV 3RlV4F 'gK R# R#!VV 3RlV44#)zTrue when (provider, model, base_url) matches one echo-back family (families can overlap; membership is tested independently). Raises KeyError for an unknown family.base_url_host_matchesruc3,<"TF qS9xK R#5irr)rr model_lowers& rr0matches_reasoning_echo_family..s8Zck!ZrTFc36<"TFpS!SV4xK R#5irr)rhostrurxs& rrr{s!?xrwjn@UV^`d@e@erw)utilsrx_REASONING_ECHO_RULE_BY_FAMILYrr) rrrsrtrur$ raw_providerslowered_providers model_subshostsrxrzs &&&f @@rrrs,=[\b=c:A'U;;B%%'K! y yhnn"%;%;%=AR%R y y 38Z83338Z8 8 y y.s:$9DQ$9sc3T<"TFp\VSSS4'gKVxK R#5ir)r)rfrurtrss& rrrs#dHq(EaSXZb(cHs( (N)r_rC)rsrtrufamiliessfff rrrs$;$9:H dHdfj kkrc(V^8dQhRRRRRRRR/#)rrsrrtrurr;r)rs"rrrs.HH3HsHcHdHrc\WV4RJ#)zQTrue when the endpoint requires reasoning_content echo-back (the must-echo tier).N)r)rsrtrus&&&rrrs ( ;4 GGrc$V^8dQhRRRRRR/#)rrsrrurr)r)rs"rrrs!scircnaaa^RIHoT;'gRP4P4o\ VVV3Rl\ 4R4pVf2^RIHpS'dV!\S44'd\M\p\V9d(V'd \S4'dV\0,pV#)zSReasoning carriers the chat-completions route reads (before any runtime rejection).rwruc3<"TFUwrpSV9gE\;QJd VV3RlV4F 'gK RM RM!VV3RlV44'gKQVxKW R#5i)c36<"TFpS!SV4xK R#5irr)rhrurxs& rr5route_reasoning_carriers...s.a[`VW/DXq/Q/Q[`r~TFN)r)rc providersrrurxprovider_lowers& rr+route_reasoning_carriers..sG c&?"qU i '33.a[`.a333.a[`.a+a &?sA A A  A N)is_local_endpoint) rrxr*rrCrdagent.model_metadatarr_LOCAL_CARRIERS_DEFAULT_CARRIERSRD _profile_declares_native_details)rsrurirrxrs&f @@rrrs+nn"++-335N c&? c H :&.3DS]3S3S?Yj h+KN+[+[rd? Orc V^8dQhRRRR/#)rrrrr;r)rs"rrrsffSfTfrcZV'gR#^RIHp\\V!V4RR44#)z\A profile declaring ``native_reasoning_details_type`` consumes replayed details by contract.F)get_provider_profilenative_reasoning_details_typeN)rrr;rk)rrs& rrrs' . ,^<>]_cd eer echo_opt_inrejectedc4V^8dQhRRRRRRRRRRRR R R /#) rapi_moderrsrtrurr;rr;rrfr)rs"rrrsO B B B  B), B8; BMQ B B Brc\V4;'g \WV4pT;'gRR8wd \VR4#\W4\ V4, p\T;'d \ V9V4#)zReplay decision for one route. Deterministic in its inputs, so the wire prefix is byte-stable across turns and changes only on a route switch or a recorded rejection (``rejected``).chat_completionsN)r;rrfrr)RC)rrsrtrurrrgris&&&&$$ rrrsj {  N N3HXNC&&&+==#C..';i>QQH  6 6h AArc ,V^8dQhRRRRRRRRRR/#)rrrrsrtrurr;r)rs"rrrs1**#**S*TW*\`*rc>T;'gRR8Xd^RIHpV!W24'dR#V'g \WV4#\WW#4pVPf$T;'gRR8g;'d VP #\ VP\\0,4#)uTrue when stale assistant reasoning text is actually replayed on the wire for the route. The single wire-truth predicate the compaction TRIGGER estimator and the tail-budget walks must share: if they disagree, a reasoning-heavy session can look over-threshold to preflight yet fully tail-protected to the walk — an infinite compaction loop. ``codex_responses`` never reads the text keys (continuity rides the encrypted sidecar). A runtime rejection is not visible here; both sides then over-charge identically. ruanthropic_messages))native_anthropic_preserves_prior_thinkingTcodex_responses) agent.anthropic_thinking_policyrrrrirgr;rR)rrsrtrurroutes&&&& rrrs B//] 4X E E #HX>> "8u GE ~~B#44BBB "a( ))rc V^8dQhRRRR/#)rrOrrztuple[Any, tuple[str, ...]]r)rs"rrrs1/1/S1/=X1/rc2\V\4'gVR 3#^RIHp.p.pVFp\V\4'dVP R4R8wdVP V4KBRR/pR FpWd9gK WF,WV&K VP R4p\V\4'd V'dWuR&V!V4wrV 'dVPRR4VPRV 44VP V4K V\V43#) aReturn the native Anthropic wire shadow plus readable replay thinking out-of-band. Canonical history may retain storage-only reasoning alongside signed replay carriers. Native conversion prefers ordered anthropic_content_blocks over reasoning_details and never sends reasoning itself. The generic message estimator therefore receives only ordinary wire-shaped fields, while readable thinking is returned separately for the explicit Anthropic accounting seam. Opaque signature/data bytes are never priced. )assistant_replay_carrierrrr r` api_contentNc3"TF^pVPR4R8XgK\VPR4\4'gKBVR,'gKSVR,xK` R#5i)rthinkingN)r>r&r)rblocks& rr9native_anthropic_accounting_projection..1s\!  yy J. 3=eii >SUX3Y ^cdn^o^o E*   sA("A( A(A(r)r rr` cache_control) r&rGagent.anthropic_message_convertrr=r>rIrrEextendr3) rOr projectedreplayed_thinkingmessageshadowr8sidecarr$carriers & r&native_anthropic_accounting_projectionrs  h % %|HI#%'4((GKK,?;,N   W %  +&RC~%l S++m, gs # # '9 -g6   JJ*D 1  !  !   AB e-. ..rc V^8dQhRRRR/#)rrYr=rrr)rs"rrr:sDZrc\\3FFpVPV4p\V\4'gK,VP 4'gKDVu# R#)zUThe turn's reasoning text: a non-blank ``reasoning_content`` wins over ``reasoning``.N)rrr>r&rr*)rYr8r?s& r_replayable_reasoning_textr:s>Aw  eS ! !ekkmmL rc$V^8dQhRRRRRR/#)r source_msgr=api_msgrrer)rs"rrrCs!  D 4 D rc>VP\4VP\4r2\V\4'dT;'gRV\&R#\V\4'd*V'd"VPR4'g W1\&R#RV\&R#)a Native-adapter wires (``carriers=None``): the pre-replay contract, byte-for-byte. An explicit value is kept verbatim (legacy "" upgraded to " "); a tool-call turn holding only another provider's ``reasoning`` is padded instead of converted into a native thinking block. rN)r>rrr&r)rrexistingras&& r_apply_legacy_must_echo_padrCsf%..,jnnQ.?i(C  oo# Is # # *..:V:V  rc ,V^8dQhRRRRRRRRRR /#) rrr=rneeds_thinking_padr;rirhrrer)rs"rrrPs4""""""#""9=""IY"" ""rcVPR4R8wdR#\V4pVeTM!V'd\\04M \4pVfV'd \ W4M=\V9dVf V'dVeTMRV\&MVP \R4\ V9dVe WA\ &MVP \ R4Ve\V9dVP \R4;'gRUu.uFXp\V\4'gK\VPR4;'gR4PR4'gKVVNKZ ppV'd Wq\&R#R#R#R#uupi) aShape an assistant replay message's reasoning keys for the active route (mutates ``api_msg``). ``needs_thinking_pad`` is the must-echo flag; ``carriers`` the keys the route reads (``reasoning_replay_route``). ``carriers=None`` is a non-chat-completions wire: only the must-echo ``reasoning_content`` rides there and ``reasoning_details`` is left to the adapter. Keys the route does not read are removed, so a strict host never sees one (#45655, #70233). rrNrrruz.native_assistantr) r>rr)rrrErrr&r=rr)rrrrir effectivedprivates&&&& rrrPs2~~f, %j 1D$0J\y"bkbmI.#J8 yd.2D#.dC   BI~$*  At( 2&kk"d399r9O9Z4=P1155=..B/889LM19O !BK  !3OsE8E8:E8E8c V^8dQhRRRR/#)rrYr=rr3r)rs"rrrus==$=5=rcxa\;QJd.V3Rl\4FNK 5#!V3Rl\44#)c3F<"TFpSPV4xK R#5ir)r>)rr8rYs& rr#_reasoning_shape..vs<);#);s!)r3REASONING_CARRIERS)rYsfr_reasoning_shaperus' 5<);<5<5<);< <rrr)rrrichangedrbefores&&& rrryspG ;;v + - !'*   2w{{2 &w9KV#G,66  Nrz"(?.rrTFrrr)rrr_UNKNOWN_FIELD_PHRASESr)r&rGr=r>r_NAMED_FIELD_RESsearchr _ALL_CARRIERSrr)rrrYr8sentnamedrs&& @rrejected_reasoning_fieldsrs zR & & (D 3C,BC333C,BC C C{)3M4)H)H bP P c4  %(WWV_ %C Oaloeo Oa P  ! GDS$4S$9$@$@$FSSDE G { TbEk]G HH2wG HH  Hs$E%1E% E% E%+$E+E+c V^8dQhRRRR/#)rrcrrztuple[str, str, str]r)rs"rrrs  s '; rc ^RIHp\VRR4;'gRP4P 4T!\VRR4;'gR4;'gR\VRR4;'gRP43#)z``(provider, base_url host, model)``: one gateway serves models on different upstream lanes, so a rejection learned for one model must not strip carriers from its siblings.)base_url_hostnamersrururt)rrrkr*r)rcrs& rreasoning_route_keyrsw(  B ' - -2446<<>'%R8>>B?EE2  $ * *113 rreasoning_rejected_carriersc V^8dQhRRRR/#)rrcrrr)r)rs"rrrsAAsAyArcVPPR/4p\VRR4pV'Ed\VRR4V8wdW n\\VRR4RR4p\ V4'dV!V\ .4M.p\ V\4'dTMR Fp\ V\4'gK\V4^8XgK-\ V^,\4'gKLVP\VR,4\44PRV^,44K \VP\V4R 44#) zReasoning keys the active (provider, host, model) rejected in this session. Persisted in the session's ``model_config`` so a resumed process (``--resume``, a gateway restart) never re-learns a rejection with another 400. Loaded once per ``session_id``. _reasoning_rejecting_routes session_idN _reasoning_rejections_loaded_for _session_dbget_session_model_config_value:NNc3>"TFq\9gKVxK R#5ir)r)rr/s& rr.rejected_reasoning_carriers..sAlX^kYk!!Xs  r)__dict__ setdefaultrkrcallable_REJECTION_MODEL_CONFIG_KEYr&rGrvr3r%r'r)r>r)rcroutesrgetterstoredentrys& rrrs ^^ & &'Db IF d3Jzge%GNR\\1;. t<>^`deHPQWHXHX $?D^`)&$77VR?E%&&3u:?z%PQ(TX?Y?Y!!%b "2CE:AAAlUSTXAll@ VZZ 3E :B? @@rc(V^8dQhRRRRRRRR/#)rrcrrrrr)r)rs"rrrs*CSQTYbrc \VRR4R8wd \4#\W4p\\VRR4\VRR4\VRR44'dV\0,pV'g \4#V\ V4, pV'g \4#VP pVP\V4\44PV4\\VRR4R R4p\V4'dx\VR R4'de\VR R 4'gRT!VP\\VP44UUu.uFwrx.VO\V4NNK upp/4\V4#uuppi) aSRemember the reasoning keys this route rejected; returns the NEW ones (empty = no retry). The next ``build_api_request`` re-shapes ``api_messages`` without them for this (provider, host, model) for the rest of the session. A repeat rejection of an already recorded key returns empty, so recovery can never loop. History is never touched. rrrsrurtrurNpatch_session_model_configr_persist_disabledF)rkr)rrrrrrrr%r'rrrsortedrF) rcrrr]newrpatcherr8vs &&& rrrsWuj"459KK{ &z AFGE:r:GE7TVaghnhththvaw@xawW]WZAR3ARq ARaw@x"yz S>AysF )invalid_tool_call)rBr>image image_url input_image)z%only 'text' content type is supportedz#only text content type is supportedzimage_url is not supportedzimage content is not supportedzmultimodal is not supportedz#multimodal content is not supportedz!multimodal input is not supportedzvision is not supportedzvision input is not supportedzdoes not support imageszdoes not support image inputzdoes not support multimodalzdoes not support visionzmodel does not support imagezunexpected item type in contentzimage_url'. expectedz,unknown variant `image_url`, expected `text`z(unknown variant image_url, expected textz+no endpoints found that support image input)z8image data you provided does not represent a valid imagezfailed to decode image)rr)r)zchatcmpl-tool-)z api.kimi.comz moonshot.aiz moonshot.cn)r[)zapi.deepseek.com)r\)zapi.xiaomimimo.comzxiaomimimo.com)zstealth/missingno>groqmistralcerebras sambanova)z mistral.aizgroq.comz cerebras.aiz sambanova.aizhunyuan.cloud.tencent.com)z fireworks.ai>nouskilocode openrouter ai-gateway)z openrouter.aizkilo.aizai-gateway.vercel.shznousresearch.com>novitaminimax minimax-cntencent-tokenhub)z novita.aiztokenhub.tencentmaas.comz"tokenhub-intl.tencentcloudmaas.comz minimax.ioz minimaxi.com>customupstagelmstudio ollama-cloud)z ollama.comz upstage.ai) zextra inputs are not permittedzis unsupportedz no such fieldz unknown fieldzunrecognized request argumentzunrecognized fieldzunknown parameterzunexpected fieldzadditional propertz unknown key)g__conditional_annotations__rn __future__rrrloggingr) functoolsrtypingrrrr(agent.agent_runtime_helpers_placeholdersrr rr agent.vision_message_prepr getLoggerrjrcompilerr)rXr r'r,r5rArMrarirrmrrrnr}rrrrrrrrrrrrrrrr__all__rrrr+rrrrrLrrQr_rorrrrrrrrrdrfrrrrrrrrrrrrrrrrrrrr)rrs0@rr(s #  66o29   8 $ -.  6<YZ-jj!78 $A  J"))[ " $C Ed % '= ?Z " $6 8X  &  (?  AS    =  ?U ' )A CZ  A C`   !> @b  7 9Q ,K T] l 5 *Z1> 4 Y '78 99;Lz{i 5}F[\ Y[)XJ/