+ iHj a0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RI t ^RI H t ^RI H t HtHtHtHtHtHtHt^RIHtHt^RIHt^RIHt]P8!]4tRR R R R R R R/R RlltRRlt R s!RRlt"Rt#RRlt$RRlt%RRlt&RRlt']PP!R]PR4t*]PP!R4t+Rt,]PP!R], R2]PR4t-R R!lt.]PP!R"4t/R#t00Rmt1R&R'0t20Rmt3R%R$0t4R(t50Rmt60Rmt7^@t80Rmt90Rmt:R*R+lt;R,R-ltR2R3lt?RR4R5llt@R6R7ltAR8R9ltBR:R;ltCR<R=ltDR>R?ltER@RAltFRRCRDlltGRERB/RFRGlltHRHRI/RJRKlltIRLRMltJRNROltKRPRQltLRRRSltMRRTRUlltNRRVRWlltORXR)/RYRZlltPR[RR\R/R]R^lltQ]R!R_R`04tSRRaRblltTRcR/RdRelltURfR/RgRhlltVRcR/RiRjlltW!RkRl4tXRmR/RnRolltYRmR/RpRqlltZRR R R RrRsRcRRfRRtR /RuRvllt[!RwRx]4t\RyRzlt]R{R|lt^R}R~lt_RRRR/RRllt`!RR]4taRRltbRRltcRRltdRRlteRRltfR]bR]cR]dR]dR]e/tgR]hR&R R RR /RRlltiRRltjRRR3RRR3R];]kP3R$RR3RR]m3RR]n3RR]n3.RR4ORRR3N5toR]hR&0RmR]o4mtpRRltqRR R R RR /RRlltrRRRlltsRRlttRRltuRRltvRRltwRRRlltx!RR4tyRRRRRRs/RRlltzR#)zCodex Responses API adapter: stateless format conversion and normalization for the OpenAI Responses API (OpenAI Codex, xAI, GitHub Models and other compatible endpoints).) annotationsN)SimpleNamespace)AnyCallableDictIteratorList NamedTupleOptional TypeGuard)coerce_tool_namedeterministic_call_id)DEFAULT_AGENT_IDENTITY)normalize_route_base_urlis_xai_responsesFis_github_responsesis_codex_backendbase_urlc ,V^8dQhRRRRRRRRRR/#) rboolrrr Optional[str]returnstr)formats"B/home/ubuntu/.hermes/hermes-agent/agent/codex_responses_adapter.py __annotate__rs=FFF<@F\`FF FcVR3VR3VR33FwrEV'gKVu# V'gR#R\\V4P44 2#)zStable identifier for the endpoint that mints ``reasoning.encrypted_content``. Blobs are sealed to their issuer (HTTP 400 ``invalid_encrypted_content``), so stamping lets replay drop foreign blobs after a model switch. xai_responsesgithub_responses codex_backendotherother:)rrstrip)rrrrflagkinds$$$$ r_classify_responses_issuerr(sk )/:=PRd`` issuer stamp. Items stamped before canonicalisation carry the raw ``agent.base_url`` (trailing slash / host case) and must still replay on the same endpoint.r$N)r) isinstancer startswithr(len)r's&r_canonical_issuer_kindr.'s:$!:!:)4H 3GHH Krc V^8dQhRRRR/#rmodelrrrr)rs"rrr3sPPP Prct^RIHp\T!T;'gR44P4;'gR#)zCanonical Responses wire model stamped on encrypted reasoning: blobs are sealed to the issuing model too, so a same-endpoint model switch must not replay them (HTTP 400).)"strip_codex_context_variant_suffixN)agent.model_metadatar3rr%)r1r3s& r_wire_model_identityr63s0H 1%++2> ? E E G O O4Orc V^8dQhRRRR/#r0r)rs"rrrCsss3s=srca\T;'gR4P4P4o\V3Rl\4R4#)zd``_OPENAI_ALL_TURNS_FAMILIES`` entry ``model`` belongs to (``gpt-6.1-sol`` -> ``gpt-6``), else None.r4c3<"TF7pSV8Xg*SPVR,VR,34'gK3VxK9 R#5i)-.N)r,).0fnames& r *openai_reasoning_family..Fs9k6q$!)tXY\_X_abehahWiGj6s 0A AN)rr%lowernext_OPENAI_ALL_TURNS_FAMILIES)r1r>s&@ropenai_reasoning_familyrDCs: u{{  ! ! # ) ) +D k6kmq rrrc V^8dQhRRRR/#)r issuer_kindrrrr)rs"rrrIsstrc^RIHp\V\4;'d?VP R4;'d&V!V\ R4R4P 4R8H#)base_url_hostnamer$Nzapi.openai.com)utilsrJr+rr,r-rA)rFrJs& r_is_openai_api_issuerrLIsW' k3 '  K,B,B8,L  +c(mn56<<>BRRrc(V^8dQhRRRRRRRR/#)rrFr item_modelr current_modelrrr)rs"rrrQs0wwmwwUbwgkwrcVe VeW8XdR#\V4pVRJ;'d"V\V48H;'d \V4#)zeExact model everywhere; same all_turns family on api.openai.com, which accepts sibling-variant blobs.NT)rDrL)rFrNrOfamilys&&& r_model_can_read_blobrRQsL 2j6Q $] 3F   v v&,CJ,O"O v vTijuTvvrc(V^8dQhRRRRRRRR/#)rmessagesrrFr issuer_modelrintr)rs"rrrYs,#0@MrcaaRVV3Rllp^p\V\4'dTM.Fp\V\4'd(VPR4R8XdVPR4MRp\V\4'd V'gKbVUu.uFqs!V4'dKVNK ppV\ V4\ V4, , pV'dWR&KVP R4K V#uupi)aFirst ``invalid_encrypted_content`` rung: drop the items the failing request REPLAYED without an exact issuer+model stamp (unstamped legacy blobs, sibling-variant blobs). Items another issuer or model minted were never sent (``_replay_reasoning_items`` skips them) and stay in history for a switch back. Consumes its own precondition (a second call removes nothing), so recovery cannot loop. Rebinds the filtered list, never mutates a shared one; returns the number of items removed.c V^8dQhRRRR/#)ritemrrrr)rs"rr6strip_unverified_reasoning_items..__annotate__aspp#p$prc <\V\4'dVPR4R8XdR#\VPR44VPR4r!VS8Xd VS8XdR#VRJ;'gVS8H;'d\ SVS4#)type compactionF _issuer_kind _issuer_modelN)r+dictgetr.rR)rYr'r1rFrUs& runverified_but_sent=strip_unverified_reasoning_items..unverified_but_sentas$%%&)9\)I,TXXn-EFQ`Hae ; 5L#8 33 3oo9Mk[`bn9oorrole assistantcodex_reasoning_itemsN)r+listr`rar-pop) rTrFrUrbremovedmsgitemsikepts &dd r strip_unverified_reasoning_itemsrnYsppG%h55x2=4>sD4I4IcggV\oalNl/0rv%&&e  ?5a(;A(>5?3u:D )) +/' ( GG+ ,> N @s C2#C2z)(?:^|[\s>|])to=functions\.[A-Za-z_][\w.]*z(?:^|\n)\s*\{\s*"cmd"\s*:\s*"(?:\\.|[^"\\])*"(?:\s*,\s*"[A-Za-z_][\w-]*"\s*:\s*(?:"(?:\\.|[^"\\])*"|true|false|null|-?\d+(?:\.\d+)?))*\s*\}\s*$zcreat(?:e|ing)|writ(?:e|ing)|runn?(?:ing)?|execut(?:e|ing)|check(?:ing)?|verif(?:y|ying)|updat(?:e|ing)|install(?:ing)?|edit(?:ing)?|mak(?:e|ing)u^(?:(?:next|first|then|okay|ok|alright)\b[\s,—–-]*)?(?:sure,\s*)?(?:now\s+)?(?:let\s+me\s+|i(?:'|’)?ll\s+|i\s+will\s+|i(?:'|’)?m\s+|i\s+am\s+)?(?:z)\bc V^8dQhRRRR/#)rtextrrrr)rs"rrrs____rcd\PV4'dR#\PV4pV'gR#VRVP4P 4P 4p\ V4;'d4\ \PVR,P 444#)zhTrue when assistant text carries a tool call the model failed to emit as a structured ``function_call``.TFN)_TOOL_CALL_LEAK_PATTERNsearch_SHELL_JSON_LEAK_PATTERNstartr% splitlinesr_SHELL_JSON_LEAK_LEADIN_PATTERN)rpmatchlead_ins& r_leaked_tool_call_textr{s%%d++ $ + +D 1E >EKKM"((*557G = ^ ^T"A"H"HQSIZIZI\"]^^rz7<\|(start|end|channel|message|constrain|return|call)\|>u｜rp output_text image_url input_imagez'[Assistant image omitted during replay] completedc V^8dQhRRRR/#rvaluerrzTypeGuard[str]r)rs"rrrs::S:^:rcd\V\4;'d\VP44#N)r+rrr%rs&r _nonblankrs" eS ! 9 9d5;;=&99rc V^8dQhRRRR/#rr)rs"rrrs2222rcH\V\4;'d \V4#r)r+rrrs&r _nonempty_strrs eS ! 1 1d5k1rc V^8dQhRRRR/#)rrrrrr)rs"rrrs////rc$VfR#\V4#)Nr4rrs&r _str_or_emptyrs2.CJ.rc V^8dQhRRRR/#)rrrrrr)rs"rrrsEE#E-Ercn\V\4'dVP4P4#R#r)r+rr%rArs&r_lower_or_noners($.uc$:$:5;;=   DDrc V^8dQhRRRR/#)rrrrrgr)rs"rrrs44C4D4rc6\V\4'dV#.#rr+rgrs&r_as_listrsud++533rc(V^8dQhRRRRRRRR/#)robjrr>rdefaultrr)rs"rrrs.SSS3SSSrch\V\4'dVPV4#\WV4#)zMRead ``name`` from a dict or an attribute-style (SDK/SimpleNamespace) object.)r+r`ragetattr)rr>rs&&&r_fieldrs(&sD113774=Rws'7RRrc V^8dQhRRRR/#)rpartdict[str, Any]rrr)rs"rrrs77^77rc\VPR4;'gR4P4P4#)r\r4)rrar%rA)rs&r _part_typers0 txx%%2 & , , . 4 4 66rc V^8dQhRRRR/#)rrdrrr)rs"rrrsBBBBrcVR8XdR#R#)rer| input_textrrds&r_text_type_forrs K/=A\Arc V^8dQhRRRR/#)r argumentsrrrr)rs"rrrs%%%%rc\V\4'd\P!VRR7pM!\V\4'g \ V4pVP 4;'gR#)zBNormalize replayed tool-call arguments to a non-empty JSON string.F ensure_ascii{})r+r`jsondumpsrr%)rs&r_coerce_argumentsrsJ)T""JJyu=  3 ' ' N ??  $ $$rc V^8dQhRRRR/#)rrprrr)rs"rrrs++S+S+rc<aS'dRS9gRS9dS#SP4'gM\;QJd%R\S44F 'gK RM RM!R\S444'g&\P R\ R\ R2S4#\ S4UUu.uF$wr\P!V4R8wgK"VNK& pppR PV3R lV44p.^re\PV4FjpW7P4,W7P4^, ,^,rVSWhR\ VP^4 \ R2., pT pKl R PV4SVR ,#uuppi) zCKeep Harmony source readable without emitting reserved wire tokens.<|c3d"TF&qR8gK \P!V4R8HxK( R#5i)CfN) unicodedatacategory)r<chars& rr?-_neutralize_harmony_tokens..s*!7@t6M* T"d*ys0!0TFz\1>rr4c36<"TFpSV,xK R#5irr)r<rlrps& rr?rs?,>q477,>sN)isasciianyset_HARMONY_CONTROL_TOKEN_REsub_FULLWIDTH_PIPE enumeraterrjoinfinditerrvendgroup) rprlroriginal_positions visible_textresultcursorryrvrs f r_neutralize_harmony_tokensrsc 3d?co  ||~~SS!7:4y!SSS!7:4y!),,/1B"_DUUV-WY]^^,5T?a?k>R>RSW>X\`>`!!?a77?,>??LF*33LA' 68J99;YZ?8[^_8_s4%?*;EKKN;KOK\\]'^__B 776?T&'] **bs /FFc V^8dQhRRRR/#rrrrr)rs"rrrsrc\V\4'd \V4#\V\\34'dVUu.uFp\ V4NK up#\V\ 4'dt\;QJdRV4F 'gK RM RM !RV44'd \R4hVP4UUu/uFwr!V\ V4bK upp#V#uupiuuppi)uNeutralize JSON-like values (tuples → lists). A reserved token in an object *key* is rejected, not rewritten — renaming could desync a tool schema from the executor contract.c3n"TF+p\V\4;'d\V4V8gxK- R#5ir)r+rrr<keys& rr?0_neutralize_harmony_structure..s0`Z_SVz#s#NN(B3(G3(NNZ_s55TFzaReserved Harmony tokens in a JSON object key cannot be neutralized without changing its contract.) r+rrrgtuple_neutralize_harmony_structurer`r ValueErrorrk)rrYrs& rrrs%)%00%$''@EF-d3FF% 3`Z_`333`Z_` ` `= KP++-X-YS2488-XX LGYs C$C)c V^8dQhRRRR/#)rcontentrgrzIterator[tuple[str, Any]]r)rs"rrr s $ $ $*C $rc#L"VFp\V\4'dV'd RV3xK)\V\4'gKA\V4pV\9d0\ VP R44'dRVR,3xKV\9gKRV3xK R#5i)zHYield ``("text", str)`` / ``("image", part)`` for recognized chat parts.rpimageN)r+rr`r_TEXT_PART_TYPESrra_IMAGE_PART_TYPES)rrptypes& r_iter_content_partsr s} dC T$,  d # #t$E((]488F;K-L-Ld6l**++tm#s#B$B$A B$ B$userc(V^8dQhRRRRRRRR/#) rrrrdrkeep_empty_urlrrOptional[dict[str, Any]]r)rs"rrrs*N#SW\trcVR8Xd RRR\/#VPR4VPR4rC\V\4'd#VPR4VPRV4rC\ V4'g V'gR#\ T;'gR 4p^R IHpHpV!V4pVR 8XdV!V4pVeTRrsVe RR RR V R2/#RRRV/p \V4'dVP4V R&V #)uResponses image part from a chat/Responses image part (``image_url`` may be a str or ``{url, detail}``). Assistant → text placeholder (an assistant ``input_image`` 400s every replay); user → ``input_image``, None for an empty url unless ``keep_empty_url``; an inline SVG is rasterized to PNG when a rasterizer is installed, any other unsupported inline subtype (or an SVG with no rasterizer) → text placeholder.rer\r|rpr}detailurlNr4)rasterize_svg_data_url#unsupported_inline_image_media_typez image/svg+xmlrz[image omitted: z! is not a supported image format]r~) _ASSISTANT_IMAGE_PLACEHOLDERrar+r`rrtools.vision_tools_image_preprrrr%) rrdrrrrrmimepng_url image_parts &&$ r_input_image_partrs  { v/KLL((;'();#tggencggh&?V   n ciiR.Ci .s 3D )-    f0@Fg.hii"(-c!JJ%||~ 8 rrdc$V^8dQhRRRRRR/#)rrrrdrrlist[dict[str, Any]]r)rs"rrr5s"cCMarc|\V4F@p\V\4'gK\V4;p\9gK3\ RV R24h \ V4p.p\\V44FGwrgVR8XdVPRVRV/4K#\WqRR7;pfK6VPV4KI V#)urChat-style multimodal content → Responses API input parts ([] if not a list). Text is ``input_text`` (user) / ``output_text`` (assistant) — the API rejects the wrong type per role; ``input_image`` is only legal on user messages (see :func:`_input_image_part`). Unsupported video parts fail closed instead of silently turning a video request into a text-only request.z!Codex Responses does not support z% input; use a video-capable provider.rpr\Fr) rr+r`r_VIDEO_PART_TYPESrrrappendr)rrdrr text_type convertedr'payloads&$ r _chat_content_to_responses_partsr5s ! dD ! ! 40@'@uEV&V3E7:_` " t$I&(I,Xg->?  6>   fiA B'eLLd Y   T " @ rsep c$V^8dQhRRRRRR/#)rrrrrrr)rs"rrrIs& O OS O# O Orc\V\4'g \V4#\\ V44pVUUu.uFwr4VR8XgKVNK ppp\ V4\ V4, pV'dRT RV^8wdRMR R2MRpRP RWqP V4P4344# \dR#i;iuuppi) uFlatten message content to plain text: text parts joined with ``sep`` (``" "`` for logs; ``"\n"`` for memory providers feeding regexes), images → ``[N image(s)]`` marker, ``""`` for None, ``str(content)`` for other scalars.r4rp[z images]rc38"TFq'gK VxK R#5irr)r<bits& rr?2_summarize_user_message_for_log..UsN#FC#CC#Fs  )r+rgr Exceptionrr-rr%)rrpartsr'r text_bits image_countnotes&$ r_summarize_user_message_for_logrIs gt $ $  ) ) $W- .E.3Fe]Ttv~eIFe*s9~-KHSQ{m6)9#r!B! DY[D 88ND((9*=*C*C*E#FN NN   Gs C C C CCc V^8dQhRRRR/#rcall_idrrr)rs"rrrZs``c`c`rc\V4\8:dV#R\P!VP RRR74P 4R, 2#)zKeep ``call_id`` within the API's 64-char cap (the codex app-server namespaces MCP call ids past it). The surrogate is a pure function of the original so a ``function_call`` and its ``function_call_output`` agree.call_utf-8replace)errors:N N)r-_MAX_RESPONSES_ITEM_ID_LENGTHhashlibsha256encode hexdigest)rs&r_clamp_responses_call_idrZsI 7|44 7>>'..."KLVVXY\]^ __rc V^8dQhRRRR/#)rresponse_item_idrrrr)rs"rrrbsrc\V\4'd4VPR4'd\V4^8d RVR, 2#R#)uMap an ``fc_…`` item id to its canonical ``call_``. Both sides of a replayed pair must derive the SAME call_id, or an oversized pair clamps to two surrogates.fc_r :NNN)r+rr,r-)rs&r_canonical_call_id_from_fcrbsI"C((-=-H-H-O-OTWXhTilmTm'+,-- rc V^8dQhRRRR/#)rraw_idrrz#tuple[Optional[str], Optional[str]]r)rs"rrrjsGGSG-PGrcB\V\4'dVP4MRpRV9dIVPR^4wr#VP4;'gRVP4;'gR3#V'gR#VP R4'dRV3#VR3#)z8Split a stored tool id into (call_id, response_item_id).r4rNr)NN)r+rr%splitr,)rrrrs& r_split_responses_tool_idrjs(55FLLN2E e|$)KKQ$7!}}&&$(8(>(>(@(H(HDHH !,,U33D%=F%Frc4V^8dQhRRRRRRRRRRR R R R/#) r raw_call_idr raw_item_idfn_namerrindexrVcanonicalize_fcrrr)rs"rrrusD   #& 14 AD MP fj  rc\V4wrg\V4'dTMTp\V4'gV'd \V4p\V4'g \W#V4pVP 4#)zPick a non-blank call_id: explicit -> embedded in ``call|fc`` id -> (replay only) canonical ``call_`` -> deterministic hash of name/arguments/index.)rrrr r%) r!r"r#rr$r%embedded_call_idembedded_response_item_idrs &&&&&$ r_resolve_call_idr)us` 3K;2W/&{33k9IG W  /,-FG W  'EB ==?rc$V^8dQhRRRRRR/#)rrrrrrr)rs"rrrs' G G G} G`c Grc,\V\4'd6VP4PR4'dVP4#T;'gRP4p\P !RRV4pW#3FzpVPR4'g5VPR4'gK3\ V4\ R48gKNVPR4'dVu#RV\ R4R 2u# V'd RVR, 2#T;'g=\T;'gR4;'g \P!4PpR\P!VPR44P4R, 2#) zCBuild a valid Responses `function_call.id` (must start with `fc_`).rr4z[^A-Za-z0-9_-]r N:N0Nr :NN)r+rr%r,rerr-uuiduuid4hexrsha1rr)rrsource sanitized candidateseeds&& r"_derive_responses_function_call_idr7sH"C((-=-C-C-E-P-PQV-W-W%%''mm " " $F("f5I(    & &9+?+?+H+HSQZ^^abi^jMj ) 4 4U ; ;9 a3yQTU\Q]Q^G_F`Aa a)Ys^$%%  D DS)//R0 D DDJJL4D4DD dkk'23==?DE FFrc V^8dQhRRRR/#)rtoolsOptional[list[dict[str, Any]]]rr)rs"rrrs  : Fd rcT;'g.Uu.uF-p\V\4'dVPR/4M/NK/ ppVUu.uFp\VPR44'gK%RRRVR,RVPRR4R\VPR4\4'dVPR4MRRVPRRR R //4/NK ppT;'gR #uupiuupi) zIConvert chat-completions tool schemas to Responses function-tool schemas.functionr>r\ descriptionr4strictF parametersobject propertiesN)r+r`rarr)r9rYfnsfnrs& r_responses_toolsrDsRWR]R][]R] ^R]$z$'='=488J #2 ER]C ^  B266&>2  J6 M266-Y[C\ *RVVH5Et*L*LbffX&RW "&&,PR/ST      _s3C."C3/A1C3rc$V^8dQhRRRRRR/#)rrrrrrr)rs"rrrs'GGsGGVYGrc\V\4'd?VP4P4P RR4P RR4MRpV\ 9dV#T#)zNormalize a replayed assistant message status, modulo case/hyphen spelling, so incomplete Codex continuation turns are not falsely marked completed.r:_rN)r+rr%rAr _RESPONSE_MESSAGE_STATUSES)rrstatuss&$ r#_normalize_responses_message_statusrJsXKUUZ\_J`J`U[[] " * *3 4 < %+@ @EYYW Krcurrent_issuer_kindc ,V^8dQhRRRRRRRRR R/#) rrawrrrrrr\rrr)rs"rrrs6 "6PT&rcVPR4VPR4rTV'*;'d4\V4;'d!\VP44\8*pV'd/VR8Xd(VP4P R4'gRp\ T\VPR44V'dVP4MR\V4'dVP4R7#RR7#) uReplayable assistant ``message`` item from a stored one. ``id`` is kept only when short enough and never for GitHub Copilot (ids bind to a backend connection; stale → 401); ``phase`` is preserved per OpenAI's cache guidance. The ChatGPT Codex backend additionally rejects ids that do not begin with ``msg`` (foreign Responses issuers mint short UUIDs), so those are dropped there while other issuers' policies are unchanged.rPrLr"rjFrINrIrKrL)rarr-r%rr,rTrJ)r^rrr\rKrLkeep_ids&&$$ r_assistant_message_itemrbsWWT]CGGG$4U%%vv)G*<vvW]]_AUYvAvG&/9'--/B\B\]bBcBc ;CGGH%% %+.%ER%'%LP%%rc .p\VPR44EFZp\V\4'dVPR4'gK3VPR4pV'dWq9gVPR4R8Xd V'gKr\ VPR44pVPR4p VRJ;'dVRJ;'dW8gp \ W)V4'*p V 'g V 'd)\ 'g\PR WW#4R sEKTPVP4U U u/uFwrV R 9gKWbK up p 4V'gEKIVPV4EK] V#uup p i) aReplay persisted encrypted reasoning/compaction items for one assistant turn. Skips duplicate ids, ``compaction`` checkpoints unless THIS request carries ``context_management`` (else a persisted checkpoint erases pre-checkpoint history on a model that cannot decrypt it), and items stamped by another issuer or model (HTTP 400). Items without a model stamp (legacy or unstamped) replay on a matching issuer. ``id`` (store=False lookups 404) and the Hermes provenance fields are stripped.rfencrypted_contentrPr\r]r^r_NuDropping reasoning item minted by %s/%s while calling %s/%s — encrypted_content is sealed to its issuer and model. This happens when a session switches model mid-conversation.T)rPr^r_) rrar+r`r.rR_CROSS_ISSUER_WARN_EMITTEDloggerwarningrrkadd)rjrer\rcrfreplayedrirK item_issuerrNforeign_issuer foreign_modelrRrSs&$$$$ r_replay_reasoning_itemsrrs@&(Hsww6782t$$0C)D)D &&, 0bffVn 6T]w ,RVVN-CD VVO, ,D8{{[PT=T{{YdY{ 11DRfgg ]--s-@ .2* "((*i*$!Ah8h*ij 7   g &394 Ojs = E> E> c(V^8dQhRRRRRRRR/#) rrjrrrr\rrrr)rs"rrrs, 15LYrc .p\VPR44;'ge\;QJd4R\VPR444F 'gK RM) RM%!R\VPR4444p\VPR44EFTp\ V\ 4'd-VPR4R8XdVPR 4R 8XgKH\VPR 44Uu.uFwp\ V\ 4'gK\ VPR4;'gR 4P4\9gKXRR R\VPRR 44/NKy ppV'gKV'dDVPR4'd-VP4UU u/uFwrVR8wgKWbK ppp VP\WWWR74EKW V#uupiuup pi)uzReplay exact assistant message items (id/phase) for prefix-cache hits. A ``msg_*`` id minted in the same response as a ``reasoning`` item is bound to that item's ``rs_*`` id, which ``_replay_reasoning_items`` always strips (store=False). Replaying the message id alone is a deterministic HTTP 400 ("provided without its required 'reasoning' item", #97427/#97442), so the message id is dropped whenever its turn carried encrypted reasoning — replayed, suppressed, foreign-issuer or trimmed by the transport (``codex_reasoning_trimmed``) — and the message goes out as content/status/phase only. Reasoning-free turns keep their id. codex_reasoning_trimmedc3t"TF.p\V\4;'dVPR4xK0 R#5i)rhN)r+r`ra)r<rns& rr?(_replay_message_items..s1JGq 2t<<(;!<.D.D"*E*K*K*MQc*c QV]FM$((62:N,O P9  7"x||D'9'9-5^^-=K-=TQdDAD-=K OO37J = O Ls$G>$G>G>!#G> HHc>]tRtRtRtRRltRRltRRltR tR #) _WireCallIdsiu8Per-request wire ids for replayed tool pairs. Stored call ids are minted per turn (``terminal:0``, ``terminal:1``…), so the same id recurs on later turns of one session. Replayed verbatim, strict Responses validators reject the whole request with 400 "Duplicate function_call_output for call_id" and every retry of the turn fails identically (#102629, #111231). Every occurrence past the first gets a ``_dup`` wire id; the matching tool output pops the id its ``function_call`` was given, in call order, so pairs stay intact and the stored history is untouched. cV^8dQhRR/#)rrNoner)rs"rr_WireCallIds.__annotate__'s//$/rc "/Vn/VnR#r)_seen_queue)selfs&r__init___WireCallIds.__init__'s%' ,. rc V^8dQhRRRR/#rr)rs"rrr+src \V4pVPPV^4pV^,VPV&V^8XdTM\V RV 24pVPP V.4P V4V#)rH_dup)rrrar setdefaultr)rrbasenwires&& rfor_call_WireCallIds.for_call+st'0 JJNN4 #q5 4Avt#;tfDrrrrPTr%r\ function_callrCfallback) rrar+r`rr-r)rrrrr r) rjrrrmtcrCr#rr$rs &$$ r_replay_tool_call_itemsr9s&(Hsww|,-"d##  VVJ #VVF^RVVK-F!! c(m+"266)#4bffTlGSQZ^]btxy O Xx((1C[\cCd $WtN%O"G W  --BC ?y)9::&,,.G W   779%L,-HRZ9,GMM2`cdpdvdvtv`wL3;8&&w/AYZaAbL +Y hP\ ] ^^rreplay_encrypted_reasoningTrfc8V^8dQhRRRRRRRRRRR RR RR R/#) rrTrrrrrr\rrcrfrr)rs"rrrcshvHvH"vH9=vH\`vH $vHBOvH(vHMQvH vHrc 4aaaa.o.o\4p\4pVR8HoRVV3Rllp VEFp \V \4'gKV P R4p V R8XdV !\ WR7V 4KIV R9dKRV P R R 4p \ WR 7p \V 4o\V \4'dR PV3R lV 44M \V 4pR VV3RllpV R8Xd&T !\Y!T ;'gT44.V 4KV'g.M \WVWVR7pV !VV 4\WVR7pV !VV 4RpV'g/T ;'g%VP4'dTM V'dR MRp\V \!S4VRJ,VR7pVeEVR 8Xd V'g6VR 8XdRMTpV !\RV!V4V P R44.V 4V !VV 4EK V'gS#^RIHpV!SSR7#)u/ Convert internal chat-style messages to Responses input items. ``is_xai_responses``: signature compatibility only (xAI DOES replay encrypted reasoning). ``replay_encrypted_reasoning``: per-session kill switch, threaded False by ``AIAgent._disable_codex_reasoning_replay`` after a repeat ``invalid_encrypted_content`` 400. ``is_github_responses``: drops ``id`` from replayed message items (Copilot 401s on stale ids). ``current_issuer_kind`` / ``current_issuer_model``: provenance guard; items stamped by another issuer or model drop. Legacy items carrying only an endpoint stamp replay on a matching issuer. ``native_compaction_eligible``: THIS request carries ``context_management``; gates both replaying ``compaction`` checkpoints and ``prune_pre_checkpoint_items``. Checkpoints persist across model swaps / compression flips / resume, so without the gate one checkpoint would erase pre-checkpoint history on a model that cannot decrypt it (lossless: local history is never truncated). Earlier (PR #26644, May 2026) we believed xAI's OAuth/SuperGrok ``/v1/responses`` surface rejected replayed ``encrypted_content`` reasoning items minted by prior turns, and we stripped them. That decision was wrong — xAI explicitly relies on Hermes threading encrypted reasoning back across turns for cross-turn coherence (the whole point of their partnership integration). We now replay encrypted reasoning on every Responses transport (xAI, native Codex, custom relays) and let xAI tell us explicitly if a specific surface ever rejects a payload. The Copilot backend (api.githubcopilot.com/responses) binds these ids to a specific backend "connection" — credential-pool rotation, a gateway restart, or routine load-balancer churn between turns all invalidate it — and rejects a stale id with HTTP 401 "input item ID does not belong to this connection" even for short ids (see #32716). ``phase``/ ``status``/``content`` are still replayed; only ``id`` is unsafe to reuse across a Copilot connection. ``native_compaction_eligible`` mirrors, for THIS request, the decision made by ``native_compaction.native_compaction_context_management`` — it is True only when that gate returned a payload, i.e. when the request actually carries ``context_management``. It controls two things that must never outlive the gate: replaying ``type: "compaction"`` checkpoint items, and restructuring the wire around them (``prune_pre_checkpoint_items``). Checkpoints are persisted in the ``codex_reasoning_items`` sidecar and survive a mid-session model swap, a ``compression.enabled: false`` flip, the rejection kill switch and a resumed session; without this flag a single captured checkpoint would keep deleting every pre-checkpoint item from every later request, on a model that cannot decrypt the blob (#85914). Default False = pre-feature wire, which is also correct for every caller that never sends ``context_management`` (auxiliary/compression client, ad-hoc ``convert_messages``). Dropping the checkpoint costs nothing: Hermes' local history is never truncated by native compaction, so the full conversation is still on the wire. r"c$V^8dQhRRRRRR/#)r new_itemsrrjrrrr)rs"rr7_chat_messages_to_responses_input..__annotate__s"44,4>4d4rcn<SPV4SPV.\V4,4R#r)extendr-)rrj item_sourcesrks&&remit/_chat_messages_to_responses_input..emits( YSEC N23rrdtool)rrrerr4rc3T<"TFqR,S8XgKVR,xK R#5i)r\rpNr)r<prs& rr?4_chat_messages_to_responses_input..s"O}!& Y8NIAfII}s((c V^8dQhRRRR/#rr)rs"rrrs q q q qrcR<S'd\V\4'dRSRV/.#T#r\rp)r+r)rrtyped_text_onlys&r wire_content7_chat_messages_to_responses_input..wire_contents+;JzZ_adOeOeVY67 pkp pr)rer\rcrfryN)rrrrL)prune_pre_checkpoint_items)r>rre)rrr+r`rarrrrgrrr[rrr}r%rr-agent.native_compactionr)rTrrrr\rcrfrerrrjrdr content_parts content_textrreasoning_items message_itemsr tool_itemsfollowerrrrkrrs&$$$$$$ @@@@r!_chat_messages_to_responses_inputrcsT#%E 46LM~H *_ #C;S A  , , '')R(8L "4( '4(( GGO}O O.;G.D  q q 6> $T< 8U8U+VWXZ] ^ $>"D[ BU!5E  _c"- Na  ]C $ss9K9K9M9MYhSUnrH,Sc%jH\`L`>altu  RJ&"ns(H $[,x2H#''RYJZ[\^a b ZSp & B %e, GGrc:]tRtRt$RtR]R&R]R&R]R&RtR#) ResponsesRouteFlagsiuWhich special Responses-API route an agent is talking to. Single owner of the codex/xai/github predicates — every site must call :func:`classify_responses_route`. Every site that needs these flags (request kwargs build, preflight estimation, silent- reject hints) must call :func:`classify_responses_route` instead of re-implementing the string comparisons inline — inline copies drift (backend-identity class: #22548/#70893/#59561/#72468). rrrrrN)rrrrr__annotations__rrrrrrsrrc V^8dQhRRRR/#)ragentrrrr)rs"rrrsC,?rca^RIHp\VRR4p\\VRR4;'gR4p\\VRR4;'gR4P 4;'g V!V4o\\VRR4;'gT4P 4pRV3R llp\ VR 8H;'gV!R 4;'dR V9VR9;'gSR 8HV!R4;'g V!R4R7#)zClassify the agent's Responses route from provider + base URL. Host checks are exact-host-or-subdomain, never substring (``evil.com/models.github.ai`` is not GitHub).rIproviderNrr4_base_url_hostname_base_url_lowerc V^8dQhRRRR/#)rdomainrrrr)rs"rr.classify_responses_route..__annotate__sEEEErcN<SV8H;'gSPRV,4#)r;)endswith)rhostnames&r_host_is*classify_responses_route.._host_iss%6!DDX%6%6sV|%DDrz openai-codexz chatgpt.comz/backend-api/codexzapi.x.aizmodels.github.aizgithubcopilot.com)rrr>xai xai-oauth)rKrJrrrAr)rrJrrrArrs& @rclassify_responses_routers(uj$/H75*b177R8H75"6;AArBHHJiiN_`hNiH 0"5AA B H H JEEE !^3rr8O8q8qThlqTq!%99SSX=S$%78YYHEXC?c$V^8dQhRRRRRR/#)rrrrTrrrr)rs"rrrs$,, ,., ,rc@\W4pVfR#^RIHpV!V4#)zEWhether the current route would replay a persisted native checkpoint.F)has_compaction_checkpoint)rrr)rrTrkrs&& r+has_replayable_native_compaction_checkpointrs$ +5 ;E }A $U ++r system_promptr4r9c ,V^8dQhRRRRRRRRR R /#) rrrrTrrrr9r:rz Optional[int]r)rs"rrr#s;`` `.`BE`Sq``rcX\W4pVfR#^RIHpT!YB;'gRVR7#)aEstimate tokens for the checkpoint-pruned Responses payload (the full transcript overstates a natively compacted session and fires local compression needlessly). None when native compaction is not proven eligible or conversion fails. Automatic preflight previously counted the full durable transcript. On a natively compacted Codex session that overstates the wire by several times and fires local compression against history the main request will never send (#96155). N)estimate_request_tokens_roughr4)rr9)rr5r)rrTrr9rkrs&&$$ r*estimate_native_responses_preflight_tokensr#s/ +5 ;E }B (>Q>QrY^ __rc@]tRtRt$R]R&R]R&R]R&R]R&R tR #) _PreflightCtxi6zCallable[[str], str] sanitize_textrsanitize_harmony_tokensrrseen_idsrN)rrrrrrrrrrr6s''!!Mrrc(V^8dQhRRRRRRRR/#rrYridxrVctxrrr)rs"rrr=s)  >  - Tb rcZVPR4VPR4rC\V4'g\RV R24h\V4'g\RV R24hRRRVP4R\ VRR7R VP \ VPR R 444/#) rr>Codex Responses input[z#] function_call is missing call_id.z ] function_call is missing name.r\rrCrrr)rarrr%r rr)rYrrrr>s&&& r_preflight_function_callr =sHHY'&)9T W  1#6YZ[[ T??1#6VWXXGMMOVEUVZeiEjS&&'8+t9T'UV rc(V^8dQhRRRRRRRR/#rr)rs"rrrIs/``.`s``[i`rc VPR4p\V4'g\RV R24hVPRR4p\V\4'd.pVFp\V\ 4'dVPR4MRpVR8XdN\ VPR44'd.VPRRRVPVR,4/4KVR 8XgK\ VPR 44'gKVP\VR R 74K T;'gRpMVP\V44pRR RVP4RV/#)rr z*] function_call_output is missing call_id.rr4r\Nrrpr~r}Frr) rarrr+rgr`rrrrrr%) rYrrrrrZrrrs &&& r_preflight_function_call_outputr Is'hhy!G W  1#6`abb XXh #F&$(*D(24(>(>DHHV$DE $txx7G)H)H fc>O>OPTU[P\>]^_-'M$((;:O,P,P0eLM  $MMr ((v)>? *Iw}}R^ __rc(V^8dQhRRRRRRRR/#) rrYrrrVrrrrr)rs"rrr]s)~CmPhrcVPR4p\V4'gR#VR,R8XdRRRV/#VPR4p\V4'd.WBP9dR#VPPV4\ VPR44pRRRTRVP 'd \ V4/#T/#)z]``reasoning`` / ``compaction`` items: opaque, issuer-sealed; forward only API-defined fields.rhNr\r]rPsummary reasoning)rarrrlrrr)rYrr encryptedrKrs&&& r_preflight_encryptedr]s,-I  # # F||# &99EEhhtnGW ll " !txx *+G 0)S=X=X=X09 ^e rc(V^8dQhRRRRRRRR/#rr)rs"rrrqs.jj^j#jMjnjrcaSPR4pSPR4R8H;'dS\V\4;'d;\;QJdV3RlR4F 'gK RM RM!V3RlR44pV'g \ SW4#.p\ V4Fwrg\V\ 4'g\RV RV R24hVPR 4pV\9d\RV RV R V: R 24hVPR R R VP\VPR R444/4K V'g\RV R24h\SWRPR7#)rrdrec3,<"TF qS9xK R#5irr)r<rrYs& rr?%_preflight_message..xs8'7t '7sTFr z] message content[] must be an object.r\] has unsupported type r;r|rpr4z3] message item must contain at least one text part.)r)rPrI)rar+rgr_preflight_role_messagerr`rrzrrrrbr) rYrrris_replayed_assistantnormalized_contentpart_idxr part_types f&& r_preflight_messagerqschhy!G K' 9 9Jw,E 9 9 C8'78CCC8'78 8 !&tS66#G,$%%5cU:LXJVjkl lHHV$ . .(-?zI`aj`mmno  !!6=&#BSBSTabfbjbjkqsubvTwBx"yz- 1#6ijkk "4);QhQh iirc(V^8dQhRRRRRRRR/#rr)rs"rrrs/BB.BsBBSaBrc VPR4pVR9d'\RV RVPR4: RV: R24hVPRR4p\V\4'g4\ W2P \ V44VPR 44#\V4p.p\V4EF;wrx\V\4'd1V'd'VPRVR VP V4/4KJKL\V\4'g\RV R V R 24h\V4;p \9dfVPR R4p \V \4'dT M\T ;'gR4p VPRVR VP V 4/4KV \9d VP\WR R74EK\RV R V RVPR4: R24h \ W6VPR 44#)zY``user``/``assistant`` role message, typed or untyped; string content or Responses parts.rdr z#] has unsupported item shape (type=r\z, role=z).rr4rLrpz ].content[z] must be an object or string.Trrr;>rre)rarr+rgr[rrrrrrr`rrrr) rYrrrdrr validatedrrrrps &&& rrrs 88F D (($SE)LTXXV\M]L``ghlgooq r  hhy"%G gt $ $!$(9(9-:P(QSWS[S[\cSdeet$I&(I#G, dC   &)VS=N=Nt=T!UVD$''5cU*XJNlmn n!$''e,< <88FB'D%dC004c$**"oD   fi9J9J49PQ R ' '   .t$O P(ZzAXY]YaYabhYiXllmn - dtxx/@ AArrrrr]rOz2dict[str, Callable[..., Optional[dict[str, Any]]]]_PREFLIGHT_ITEM_HANDLERSrc(V^8dQhRRRRRRRR/#)r raw_itemsrrrrrrr)rs"rrrs,,0SWrc\V\4'g \R4hV'd\MRp\ W2V\ 44p.p\ V4Fwrg\V\4'g\RV R24hVPR4p\V\4'd\PV4MRp T ;'g\!WvV4p V fKVPV 4K V#)z4Codex Responses input must be a list of input items.cV#rr)rps&r._preflight_codex_input_items..s]arr rr\N) r+rgrrrrrr`rarr#rr) r%rrrr normalizedrrY item_typehandlernormalized_items &$$ r_preflight_codex_input_itemsr.s i & &OPP2I.PaM  @SUXUZ [C')Jy) $%%5cU:NOP PHHV$ =G SV=W=W*..y9]a"==&==t#N  &   o .* rc$V^8dQhRRRRRR/#)rrrrrVrrr)rs"rrrs!#CNrc J\V\4'g\RV R24hVPR4pV\9d \V4#VR8wd#\RV RVPR4: R24hVPR4VPR4rC\ V4R3\V\4R 33FwrVV'dK\RV R V R24h RRRVP 4R \VPR R 44R \VPR R44RV/#)zCodex Responses tools[rr\r<rr;r>r?z a valid namezvalid parametersz ] is missing r=r4r>F) r+r`rra_RESPONSES_BUILTIN_TOOL_TYPESrr%rr)rr tool_typer>r?okwhats&& r_preflight_toolr5s" dD ! !1#6JKLL I11DzJ1#6MdhhW]N^Maabcddxx',)?*o~6JPT9UWi8jkr5cU-vQOP Pl  FDJJL-txxXegiOjAk$txx%01< rc"\V\4#r)r+r`rSs&rr(r(s Jq$/rincludec"\V\4#rrr7s&rr(r(s *Q-r service_tiercH\V\4;'d \V4#r)r+r`rr7s&rr(r(sz!T*66tAw6rmax_output_tokenscH\V\\34;'dV^8#rr+rVfloatr7s&rr(r(sJq3,$?$I$IAE$Irtimeoutc\V\\34;'d=\V\4'*;'d ^Tu;8;'d\R48#u#)rHinf)r+rVr?rr7s&rr(r(sH*Qe 5jjjD>Q:QjjVWZ[VjVj^cdi^jVjjVjjr temperaturec.\V\\34#rr>r7s&rr(r(sjS%L9rc#."TF pVRR3xK R#5i)c VRJ#rrr7s&rr(.s rNrrs& rr?r?sgC %t,gscontext_managementcH\V\4;'d \V4#r)r+rgrr7s&rr(r(sZ4%8%D%DT!W%DrzMtuple[tuple[str, Callable[[Any], bool], Optional[Callable[[Any], Any]]], ...]_PREFLIGHT_OPTIONAL_FIELDSc#,"TF wpq!xK R#5irr)r<rrGs& rr?r?s65ic1ac5sc$V^8dQhRRRRRR/#)r api_kwargsrrrrrr)rs"rrrs"~C>>&*>IM>!>>rcaa\S\4'g \R4h\V3RlR44;p'd\RRP V4 R24hSP R4p\ V4'g \R4h\SP R44P4;'g\pV'd \V4p\SP R4W#R 7pRVP4RVRVR R /pSP R 4p V ea\V \4'g \R 4h\V 4U U u.uFwr\W4NK p p p V'd \V 4MT VR &SP R R 4R Jd \R4h\ F;wrpSP V 4pV!V4'gK'V'd V!V4MTW&K= \#SR4;'g/p\$;QJdRV4F 'dK R M RM !RV44'g \R4hVP'4U Uu/uF&wp pVfK V P4\)V4bK( pp pV'dVVR&\#SR4pV'd\V4VR&SP R4pV'gRS9d \R4hV'dVeVRJd \R4hRVR&\)SP R4;'gR4P+4P-R4pV'd4VP R 4'd^RIHpV!VR ,4wVR &p\4V'dR0M \74,o\V3RlS44;p'd\RRP V4 R24hV#uup p iuupp i \2dLvi;i)z'Codex Responses request must be a dict.c38<"TFqS9gK VxK R#5irr)r<rrMs& rr?._preflight_codex_api_kwargs..sd(JYcNc(J r1 instructionsinputz3Codex Responses request missing required field(s): z, r;z;Codex Responses request 'model' must be a non-empty string.)rrstoreFr9z=Codex Responses request 'tools' must be a list when provided.z6Codex Responses contract requires 'store' to be false. extra_headersc38"TFp\V4xK R#5ir)rrs& rr?rTs7#y~~sTzGCodex Responses request 'extra_headers' keys must be non-empty strings. extra_bodystreamzKCodex Responses stream flag is only allowed in fallback streaming requests.z/Codex Responses 'stream' must be true when set.r4)strip_slash_enumc38<"TFqS9gK VxK R#5irr)r<r allowed_keyss& rr?rT4sQ:CL9PCC:rUz2Codex Responses request has unsupported field(s): )r1rVrW)zgrok-z x-ai/grok-)r+r`rsortedrrarrr%rrr.rgrr5rrJrOallrkrrAr,tools.schema_sanitizerr]r_PREFLIGHT_ALLOWED_KEYSr)rMrPrrmissingr1rV input_itemsr*r9rrnormalized_toolsracceptcoercerrYnormalized_headersr[r\ is_xai_modelr]rG unexpectedr_sf$$$ @r_preflight_codex_api_kwargsrlsn j$ ' 'BCCd(JdddwdNtyyY`OaNbbcdee NN7 #E U  VWW !?@FFHbbLbL1,? .w5HK  g{T[]b"J NN7 #E %&&\] ]HQRWHXYHX93OD6HXYQh;.>sOhdgdFD99h)rrr)rrnrselectedrps&& r _text_chunksrw;sa!)%jMWTSY[_E`diEiHjOhO gOTS`aeSfDDO ggk gsAAA#A#c V^8dQhRRRR/#rrYrrrr)rs"rrrAs # ## ## #rc4.p\\VR44F_p\VR4pVR8Xd \VR4MV\9d \VR4MRp\V4'gKNVP V4Ka RP V4P 4#)aAssistant text from a Responses message output item. A ``refusal`` part carries the model's explanation in ``refusal`` instead of ``text``; it is message text too, otherwise a refusal-only turn reads as an empty response (sibling of chat_completions ``message.refusal``).rr\refusalrpNr4)rrrzrrrr%)rYchunksrrrps& r_extract_responses_message_textr}AsFi01tV$*/9*: "`` for a ``response.error`` payload (dict or object), else whichever is present, else ``str(error_obj)``, else a status-based default.c V^8dQhRRRR/#)rr>rrr)rs"rr-_format_responses_error..__annotate__XsMMCMCMrc<\SV4p\V\4'g V'd\V4P4#R#)r4)rr+rr%)r>rrs& rfield&_format_responses_error..fieldXs5y$'%/s%;%;us5z!L"LrcoderOz: zResponses API returned status ''r)rrrcode_str message_strsf& r_format_responses_errorrUseMM"&M5+;kK2k]++  } }( } }s9~}Jijyizz{H|}rc(V^8dQhRRRRRRRR/#) rrYrr+rr$rVrrr)rs"rrrcs(  c c # / rc ~\VRR4;'gRp\YR8XdRMRR4p\V\4'g\P!VRR7p\VR R 4p\ \VR R 4WSWBRR 7p\ T\V\4'dTMR 4p\WfVR \W4R7R7#)zPBuild a chat-style tool_call from a ``function_call``/``custom_tool_call`` item.r>r4rrrWrFrrPNrrr<)r>r)rPrrr\r<)rr+rrrr)r7r)rYr+r$r#rr"rfc_ids&&& r_response_tool_callrcsdFB'--2G/-IkwX\]I i % %JJyu= $d+KwtY={U^w|}G .wzR]_bGcGc im nE  e* gC rc ,V^8dQhRRRRRRRRRR /#) rrYrr+rrFrrUrrr)rs"rrrrs4 ,9IVrc&\VRR4p\V4'gR#RVRV/pV'dW%R&V'dW5R&VR8wdV#\VRR4p\V\4'd0VP R4'd\ P R V4R#\V4'dWeR&\VR R4p\V\4'd;R V4pVU u.uF!p \V \4'gKRR R V /NK# up VR &V#uup i)z``{type, encrypted_content[, _issuer_kind, _issuer_model]}`` for replay, or None without a blob. Reasoning items also carry ``id`` + ``summary`` (required by the API on replay); transient ``rs_tmp_`` skip.rhNr\r^r_rrPrs_tmp_z@Skipping transient Codex reasoning item during normalization: %src3<"TFp\VRR4xK R#5irqrrrss& rr?*_capture_encrypted_item..sAvt,,ru summary_textrp)rrr+rr,rjrrg) rYr+rFrUrr|rKrtextsrps &&&& r_capture_encrypted_itemrrs 148I  # # & 3F RH#. $0!KdD$'G'3G$6$6y$A$A WY`aW dIt,G'4  AARWqRW$[efjlo[pEERWq Ors D< DcB]tRtRtRtRRltR RRlltRR ltR tR#) _OutputScanizMAccumulated view of one Responses ``output`` list (phase 1 of normalization).c V^8dQhRRRR/#)rrrrrr)rs"rr_OutputScan.__annotate__sbb b$brc ...uVnVnVn..uVnVnV\ 9VnVR9VnR;Vn;Vn Vn R#)queuedFN>r in_progress) rreasoning_partsrreasoning_items_rawmessage_items_raw_INCOMPLETE_STATUSEShas_incomplete_items saw_streaming_or_item_incompletesaw_commentary_phasesaw_final_answer_phasesaw_reasoning_item)rrs&&rr_OutputScan.__init__s`DFBAD0$/;=r8 $"8$37K$K!0?C\0\-\aa!aD$?$BYrNc(V^8dQhRRRRRRRR/#)rrz list[Any]rFrrUrrr)rs"rrrs0cc9c=cP]cimcrc  VEF`p\VRR4p\\VRR44pV\9dV\9dRVnRVnVR8XdVP WF4KeVR 9dVR8Xd6RVn\V4pV'dVPPV4\WEW#4pVeOVPPV4VR8Xd*\PR\VR,44EKEKEK VR 8XgVR 8XgEKV\9gEK(VP P\#WE\VP 444EKc R#) r\NrITrOrr]z?Native Responses compaction item captured (%d chars encrypted).rhcustom_tool_callr>rr])rrr_SERVER_SIDE_TOOL_CALL_TYPESrr_messagerrrrrrrjinfor-rr) rrrFrUrYr+ item_statusreasoning_textr|s &&&& rscan_OutputScan.scans=Dfd3I(x)FGK22yHd7d,0)8<5I% d099 +.2D+%Ft%LN%,,33NC34K^',,33H= L0 ]_bckldA`B1( 00Y/5QVai}V}&&':4CPTP_P_L`'ab1rc$V^8dQhRRRRRR/#)rrYrrrrrr)rs"rrrs!  S }  rc  \\VRR44pVR9pVP;'gTVnVP;'gVR9Vn\ V4pV'gR#V'd VP M VP PV4\VRR4pVPP\RRRV/.\V4\V\4'dTMRVR74R#) rLNrPr\r|rpr`>analysisrU>finalrV) rrrrr}rrrrrTrJr+r)rrYrnormalized_phaseis_commentary_phase message_textrKs&&& rr_OutputScan._messages)'$*FG.2LL$($=$=$T$TAT!&*&A&A&r&rEUYrEr#6t<  "5  $:L:LTTUab$d+ %%mmV\ : ;DghsDt)'377GTIY'  r) rrrrrrrrrrr) rrrrrrrrrrrrrrsWbc6  rrrFrUrecover_leaked_tool_callc ,V^8dQhRRRRRRRRRR /#) rresponserrFrrUrrrztuple[Any, str]r)rs"rrrs=[,[,[,#0[,GT[,"[,[,rc  \\VRR44p\\\VRR4RR4;'gR4P 4P 4pVR8H;'dVR8Hp\VRR4p\ V\4'd V'g\VR R4p\ V\4'dVP 4MRpV'd1R p \PV \V44\R VR 7.p MV'd.p M \R 4h\R RRV R7.;Vn pVR9d!\\\VRR4V44h\V4p V P!WqV4V P"V P$rRP'V P(4P 4pV'gZV P*'gV P,'g6\VR R4p\ V\4'dVP 4MTp\/T;'d%T;'dV '*;'d \1V44pV'd \P3RVR,4RpVR8XdV'gV 'gV 'dRP'V 4pVP5R4pVR8wd;VV\R4,RP7R^4^,P 4MRpV'dB\P3R\V44TpVRVP 4pV'dV.M.p \YV 'd RP'V 4P 4MRRRV P8;'gRV'dRMV P:;'gRR7pV P8;'gT ;'gV P<;'dV'*pVR8H;'dVR9pV 'dRpVV3#V'dRpVV3#V'gYV P>'gGV P@'gV P,'dV P*'dV'dV'gRpVV3#RpVV3#) a}Normalize a Responses API object to ``(assistant_message, finish_reason)``. ``issuer_kind`` / ``issuer_model`` are stamped onto captured reasoning items for provenance replay drops. ``recover_leaked_tool_call=False`` is for callers with no continuation (aux): tool-call-shaped text is then kept as ordinary content and judged by the same phase/completion gates as any other answer.rINincomplete_detailsreasonr4 incompletecontent_filterrr|z`Codex response has empty output but output_text is present (%d chars); synthesizing output item.rz&Responses API returned no output itemsrOrer)r\rdrIrerrorrzCodex response contains leaked tool-call text in assistant content (no structured function_call items). Treating as incomplete so the continuation path can re-elicit a proper tool call. Leaked snippet: %r:Ni,Nr z z z zxAI response delivered its final answer inside the reasoning channel ( delimiter); promoting %d chars to assistant content.)rrrreasoning_contentreasoning_detailsrfrxrstop>failed cancelledrr)r"r r!)!rrrrr%rAr+rgrjrr-r RuntimeErrorrrrrrrrrrrrr{rkrfindrrrrrr)rrFrUrrincomplete_reason"response_incomplete_content_filterrout_textrjrrrr final_textleaked_tool_call_textjoined_reasoningmarkersalvagedreasoning_prefixassistant_messagereasoning_only trusted_final finish_reasons&$$$ r_normalize_codex_responsers%WXx%FGOF785I4#PRZ\^_eecefllnttv)8L)H)r)rM^brMr& Xx .F fd # #68]D9'1(C'@'@8>>#b tC LLc(m ,"1}8"T!UG /GGH H a b$  &11278Wd3SUdeff  'DIIf<0"&//43G3G4--.446J 4666d>W>W>W8]B7)3Hc)B)BX^^% ! iiZii NiiG]^hGi !",T"2  o%jP_!;;7!'' 5gmqsgs#FS->$>$?@FF}VWXYZ[aacy{  NNSTWX`Ta "J/8>>@ 4D/0"O':I&++o.446t$"66>>$$9D@V@V@^@^Z^ ..\\/\\TE\E\ppfpbpN;&tt;>t+t$  m ++ ,(  m ++   0 0 0  & & &$*C*C*CTMhMhMh =$  m ++ m ++r)zgpt-5.4zgpt-5.5zgpt-5.6zgpt-6>rprr|>video video_url input_video>rrr>rrr> web_search file_search local_shellcode_interpreterimage_generationweb_search_previewcomputer_use_preview>mcp_call computer_callweb_search_callfile_search_calllocal_shell_callcode_interpreter_callimage_generation_callr)r) tool_choiceparallel_tool_callsprompt_cache_keyprompt_cache_retention>rWr1rXr9r[rVrY){__conditional_annotations__r __future__rrrloggingr.rr/rnrtypingrrrrrr r r agent.message_sanitizationr r agent.prompt_builderrhermes_cli.route_identityr getLoggerrrjr(r.rir6rCrDrLrRrncompile IGNORECASErsru _ACTION_VERBSrxr{rrrrrrzrrrHrr1rrrrrrrrrrrrrrrrrrrr)r7rDrJrT frozensetrYr[rbrrr}rrrrrrrrrrr r rrrr#rr.r5rr%rVr?rJrcrOrlrwr}rrrrrr)rs@rrs[#   !WWWN7>   8 $F %FCHFchF"F"#PHs w<**%QSUS`S`a ::je "$**RR_Q``ceMM#_JJ'ab8 -09#V,H?G!#!  :2/E4S 7B%+,& $>&( O O"`G  G"  GkGLPim!,!?@)-$%*.%P\`B//:QU,_RV_(vH@EvHchvH'+vHRVvH+/vHTYvHr * "<,`HJ`tx`&J `((j4BD-/EGf%|5I9VhPL 38Z_&*/6-t4Y * 6=I3Ojlqr95AmgmDdKmi$656 >-2>PU>$)>Fh #d ~ 84 4 n[,37[,W[[,%)[,[,r