߲jZUdZddlZddlZddlZddlZddlmZmZmZddl m Z m Z m Z m Z mZmZmZddlmZddlmZmZej,eZej2dZdeed efd Zd ed eefd Zd ed dfdZdeeefded dfdZ dZ!dZ"dZ#dZ$e%ddhZ&dZ'ge"e#e$Dcic] }e'|| c}Z(de(e!<deeefd e)fdZ*deeefd e)fdZ+ddfde,eeefd e-ed!fd"eegefd#eeegefd e-e,eeefeeefff d$Z.d e)fd%Z/deeefd&e)d e)fd'Z0d e)fd(Z1 dVdedeeefd&e)d*e)d e-eeeefff d+Z2e3Z4e3ee5d,<d-edeeefd e-ee)ffd.Z6d/Z7ej2d0d1jqd2e7Dd3Z9d-ed4ed eefd5Z:d4ed e)fd6Z;d-ed4ed e)fd7ZdWd;edZ?dXd?ed-eed4ed ee-fd@Z@deeefd e)fdAZAdBee,eeefd e)fdCZBdeeefd e)fdDZCdBe,eeefd e,eeeffdEZDdFed e)fdGZEdHed eeFfdIZGd-edeeefdJedKe)dLe)d&e)dMe)d eeeffdNZHGdOdPeZIddQlJmKZKeKdReIddSlmLZLddTlmMZMddUlmNZNycc}w)YuOpenAI Responses API (Codex) transport. Owns format conversion/normalization on top of agent/codex_responses_adapter.py — NOT client lifecycle, streaming, or the _run_codex_stream() call path. N)AnyCallableOptional)CODEX_ASTRA_EFFORTSCODEX_LEGACY_EFFORTSXAI_GROK46_EFFORTSXAI_LEGACY_EFFORTS clamp_effortis_astra_modelcodex_supported_efforts)ProviderTransport)NormalizedResponseToolCallz^(cron_.+)_\d{8}_\d{6}$ session_idreturnctt|xsd}tj|}|r|jdS|S)zBNormalize a physical session_id into a stable logical cache scope.)str_CRON_SESSION_ID_REmatchgroup)rsidrs ;/home/ubuntu/.hermes/hermes-agent/agent/transports/codex.py_cache_scope_from_session_idrs6 jB C  % %c *E"5;;q>++valuec|dnt|j}|syt|dkr|Sdtj|j ddj ddzS) zOReturn a provider-safe (<=64 char) cache key without changing session identity.Nr@pck_utf-8replaceerrors)rstriplenhashlibsha256encode hexdigest)rkeys r_bounded_prompt_cache_keyr-&sc "3u:#3#3#5C c(b.3ufw~~cjjYbj>c/d/n/n/pqtrt/u&uur containerct|tr.d|vr)t|d}|r||d<y|jddyyy)zCBound (or drop, when empty) an in-place ``prompt_cache_key`` entry.prompt_cache_keyN) isinstancedictr-pop)r.boundeds r_bound_prompt_cache_key_fieldr5.sJ)T"'9Y'F+I6H,IJ ,3I( ) MM,d 3 (G"rkwargsheadersc |jd}t|tr<|jDcic] \}}|s | t |t |"c}}ni}|j |||d<ycc}}w)zeMerge ``headers`` into a str-coerced copy of ``kwargs['extra_headers']`` (SDK kwarg -> HTTP headers). extra_headersN)getr1r2itemsrupdate)r6r7existingkvmergeds r_merge_extra_headersrA8sgzz/*HU_`hjnUo)9 QAQ1=c!fc!fn QuwF MM'$F?Rs A7A7A7hermes_web_search) web_search search_files)rCrD fetch_url people_searchfinance_search) tool_searchapi.openai.comz chatgpt.comhermes_rCparamsc ddlm}||jdy ddlm}|t |jdxsdjdk(S#t$rYGwxYw#t$rYy wxYw) zRTrue for opencode-zen/go providers, ``opencode-*`` families, or opencode.ai hosts.r)opencode_provider_familyproviderTbase_url_hostnamebase_urlrz opencode.aiF)hermes_cli.modelsrMr: ExceptionutilsrPrlower)rKrMrPs r_is_opencode_responses_backendrVcs > #FJJz$: ; G H+ VZZ %;%Ar!BCIIK}\\    s"A:A, A)(A), A87A8c ddlm}|t|jdxsdj dk(S#t $rYywxYw)z>True for Perplexity's Responses-compatible Agent API endpoint.rrOrQrzapi.perplexity.aiF)rTrPrr:rUrS)rKrPs r _is_perplexity_responses_backendrXtsI+ VZZ %;%Ar!BCIIKObbb s:= A A c$|jdSNname)r:ts rr^squuV}rci|d|iSrZ)r]aliass rr^r^s;Oa;O;Orresponse_toolsreserved_names.name_ofrenamecg}i}|Dchc]$}t|ts||s||&}}|D]}t|tr||nd}||vr|j|3t|x} } d} | |vr| d| | dz} } | |vr|j | ||| <|j||| ||fScc}w)a+Alias provider-reserved function names on the wire; returns ``(tools, {alias: original_name})``. An alias already taken by a real tool gets a ``_2``/``_3`` suffix. ``name_of``/``rename`` adapt the tool shape (Responses ``{name}`` by default; chat_completions passes ``function.name``). N_r)r1r2append_RESERVED_TOOL_ALIAS_PREFIXadd) rbrcrdre rewritten alias_maptooltakenr[baserasuffixs r_alias_reserved_toolsrr~s')I "I'5 btD$9OT[\`TaWT] bE b . *4 6wt}D ~ %   T " 56tf==uun#fAfX. 6Eun % %e,- . i  csCC Cc ddlm}|}|t|dddk(Sddlm}|xsdj j dk(S#t$rYywxYw) u True when xAI Responses should use Grok's native ``web_search`` built-in. Web-search registry first, then the legacy ``_get_search_backend`` probe; fails closed to native (True). Delegates to the web-search registry's provider resolution (which reads ``web.search_backend`` / ``web.backend`` from config) and checks whether the resolved provider is xAI. On any resolution failure, returns True (fail-closed to native — preserves the #48108 incomplete-hang fix rather than risk reintroducing it). rget_active_search_providerNr[xai_get_search_backendrTagent.web_search_registryrugetattrtools.web_toolsrxr&rUrSrurNrxs r_xai_prefers_native_web_searchr~sf H-/  8VT2e; ;7#%+224::<EE A/A AAis_xai_responsesc|s|jddury ddlm}|t|jdxsdj t vS#t $rYywxYw)zaTrue when the Responses endpoint owns the ``tool_search`` namespace (xAI, OpenAI, ChatGPT Codex).is_codex_backendTrrOrQrF)r:rTrPrrU_OPENAI_RESPONSES_HOSTSrS)rKrrPs r_reserves_tool_searchrs`6::&89TA+ VZZ %;%Ar!BCIIKOfff s=A A"!A"c ddlm}|}|t|dddk(Sddlm}|xsdj j dk(S#t$rYywxYw) aTrue when the active web-search backend selects OpenAI's server-side ``web_search``. Same contract as :func:`_xai_prefers_native_web_search` with one deliberate difference: it fails CLOSED (False). A resolution failure must leave the client-side Hermes tool in place rather than swap in a built-in the endpoint might reject. Only consulted for the Codex backend (``chatgpt.com/backend-api/codex``); a custom OpenAI-compatible endpoint does not implement the server-side tool. rrtNr[z openai-nativerwrFryr}s r!_openai_prefers_native_web_searchrsf H-/  8VT2oE E7#%+224::<OO rFrc i}dtdtfd |rl|rjt fd|DrVtr |Dcgc] } |r |c}ddigz}n,|Dcgc]} |r i|dtin|}}d|t<|r?|r=t fd|Dr)t r|Dcgc] } |r |c}ddigz}|r/t |r$t|t\}}|j||r/t|r$t|t\}}|j||r0t||r$t|t\}}|j|||fScc}wcc}wcc}w) uApply provider-reserved tool-name aliasing; returns ``(tools, {alias: original})`` for THIS request. xAI: a client ``web_search`` collides with Grok's native search — native mode swaps it 1:1 for the built-in, client mode keeps Hermes dispatch under an alias. OpenAI Codex: the Responses endpoint carries the same collision, so the backend selection drives the same 1:1 swap (``web.search_backend: openai-native``). r]rcNt|txr|jddk(S)Nr[rCr1r2r:r\s ris_client_web_searchz/_alias_wire_tools..is_client_web_searchs!!T"DquuV} 'DDrc3.K|] }|ywNr`.0r]rs r z$_alias_wire_tools..2cq3G3J2ctyperCr[c3.K|] }|ywrr`rs rrz$_alias_wire_tools..rr)rboolanyr~_XAI_CLIENT_WEB_SEARCH_ALIASrrVrr_OPENCODE_RESERVED_TOOL_NAMESr<rX_PERPLEXITY_RESERVED_TOOL_NAMESr_XAI_RESERVED_TOOL_NAMES) rbrKrr wire_aliasesr] _oc_aliases _pplx_aliases _xai_aliasesrs @r_alias_wire_toolsrs$&LEEENs2cTb2c/c ) +)7WA?STU?VaW\bdp[qZrrNhvbc?STU?V;1;f:;\]]N:FL5 6 Ns2cTb2c/c , .)7WA?STU?VaW\bdp[qZrrN8@&;NLi&j# K(:6B(=nNm(n% M*/8HI'<^Me'f$ L) < ''QXXs EEE ( E%6E%_UNPROJECTABLE_DISABLE_WARNEDmodelcd\}}|jd}|r.?s+Ss5z'')//1V;Ss46ureasoning_effort: none cannot be sent for %s — its route accepts only %s, so the model's default effort stays on (an omitted reasoning field does not disable it).z, c32K|]}t|ywr)rrs rrz%_resolve_reasoning..Fs CU Csr)r:r1r2agent.model_metadatarrr _is_openai_api_origin_profile_declared_efforts_codex_efforts_for_routerrrkloggerwarningjoinr ) rrKreasoning_effortreasoning_enabledrr supportedrQrdeclaredhas_nones r_resolve_reasoningrsr+9''zz"45J'7>    *e 3 %   ! !( +/9  zz$e,:+;@  SSSE)FF ) - -e 4 NN\tyy C CC  #u44u44 () 46G GGr) z gpt-5.5-prozgpt-5.5zgpt-5.4zgpt-5.2zgpt-5.1-codex-maxzgpt-5.1-codex-minizgpt-5.1-chat-latestz gpt-5.1-codexzgpt-5.1z gpt-5-codexzgpt-5zgpt-4.1z(?:^|[./:])(?:|c#FK|]}tj|ywr)reescape)rr[s rrrRsY4ryyYs!z)(?:-\d{4}-\d{2}-\d{2})?$rQcddlm}|t|xsdj}|dk(ry|j d}t |dk(xr$|ddk(xrt |d xr |d d d d gk(}|sy t|xsdjjjdd}tj|rdSd S)zAReturn ``24h`` for supported hosts/models (Bedrock Mantle, Meta).rrOrz api.meta.ai24h.zbedrock-mantlerrgNapiawsrh-) rTrPrrUsplitr'rr&r"_EXTENDED_PROMPT_CACHE_MODEL_REsearch)rrQrPhostnamepartsis_bedrock_mantle normalizeds r+_default_prompt_cache_retention_for_requestrWs' X^!45;;=H=  NN3 EE a{E!H8H,H{TRWXYRZ^{`efgfh`insuzm{`{ U[b!'')//199#sCJ3:::F5PDPrcZddlm}|t|xsdjdk(S)z`Exact host, so a Responses-compatible proxy or a lookalike subdomain keeps the generic contract.rrOrrI)rTrPrrU)rQrPs rrrls(' SR0 1 7 7 9=M MMrc2t|xr t|S)z'Astra on the canonical API origin only.)r r)rrQs r#_is_official_openai_responses_routerss % D%:8%DDrrc|s't|rddlm}|t|xsdryt |r|st ||st Stt|xsdS)aEffort vocabulary for a Responses route; ``()`` when the model takes no ``reasoning`` field at all. Keeps Astra's new vocabulary off unrelated Responses-compatible endpoints, and sends nothing for the chat-era OpenAI families (gpt-4o, gpt-4.1, ...) on api.openai.com, which 400 on any ``reasoning`` key (#76255). Only the exact OpenAI origin is judged: a relay serving those ids may translate. r)openai_model_rejects_reasoningrr`)rrrrr rrr )rrQrrs rrrxsU  5h ?G )#ekr*: ;e?xP## "3u{#3 44rct||sy|jd}t|trQt |jdxsdj j }|rt|tnd|d<dD]}|j|d|jd}t|tr0|Dcgc] }dt |j vs|"c}|d<yycc}w) aAstra's official-API contract, applied AFTER ``request_overrides`` so an override can't put a rejected field back on the wire: ``reasoning.effort`` is ``low..max`` only (``none``/``minimal`` 400), sampling and logprob knobs are rejected, and cache lifetime is fixed server-side (``prompt_cache_options.ttl`` accepts only its ``30m`` default, so nothing is sent for it and the pre-5.6 ``prompt_cache_retention`` knob is dropped).N reasoningrrlow) temperaturetop_p top_logprobslogprobsprompt_cache_retentionincludelogprob) rr:r1r2rr&rUr rr3list)r6rrQr requestedr,ritems r_sanitize_astra_request_kwargsrs /uh ? ;'I)T" h/526<<>DDF NWl96IJ]b (] 3jj#G'4 .5\d#d)//J[9[T\y!\s > C+C+ instructionstoolsscope_idc|s|syd}|r.td|Dd}tj|ddd }|d |xsdd |}d tj|j d d j ddzS)u``pck_`` of (scope_id, instructions, name-sorted tools), or None if nothing static. Routing hint only; ``scope_id`` keeps unrelated sessions off one bucket. ``scope_id`` (pass ``_cache_scope_from_session_id(session_id)``) keeps unrelated sessions — independent conversations, main vs. child/subagent, sibling children — from concentrating onto the same bucket merely because their static prefix matches (see #78941), while still letting recurring cron fires of one job share a stable key across their timestamped session_ids (the original #51395/#52295 fix this built on). Sorting tools by name keeps the hash insertion-order independent. Nrc3BK|]}t|ts|ywr)r1r2)rr]s rrz%_content_cache_key..s 51At!4Q 5scdt|jdxs|jdxsdS)Nr[rr)rr:r\s rr^z$_content_cache_key..s+SvImZ[Z_Z_`fZgImkmEnr)r,TF),:) sort_keys ensure_ascii separatorsr r!r"r#r%)sortedjsondumpsr(r)r*r+)rrr tools_part sorted_toolscontents r_content_cache_keyrs J  5 5;n ZZ 5]gh  $|1r2$zlCG GNN7>>')>#LMWWYZ][]^ ^^rrNc ddlm}t|xsdjj }d}|r9ddlm}|t|}|r ||k7r||}||j|}|!|r||nd} | | j|nd}|dSt|S#t$r } tjd| Yd} ~ yd} ~ wwxYw)avProvider-profile-declared reasoning-effort vocabulary, or None (fail-open). Resolves by endpoint host first, then by provider name: a ``custom:`` entry pointed at a host with a registered profile must follow that host's vocabulary, not the generic custom declaration. Lazy import: provider plugins import this transport during registry discovery. r)get_provider_profilerN)_infer_provider_from_urlz*profile-declared efforts lookup failed: %s) providersrrr&rUrrsupported_reasoning_effortsrSrdebugtuple) rNrrQrr[rrinferredinferred_profileprofileexcs rrrs28>r"((*002  E/H >HH,#7#A #//KKERH  48*40dGELEXw::5A^bH#48x8  A3GsBB"" C +CC cddlm}t|jdxsdj j dk(ry|t|jdxsddS) u\True for Microsoft Foundry's Responses API (provider id, else host match — not substring).rbase_url_host_matchesrNr azure-foundryTrQservices.ai.azure.comrTrrr:r&rU)rKrs r_is_azure_foundry_responsesrsV+ 6::j ! 'R(..0668OK VZZ %;%Ar!BD[ \\rmessagescddlmmddtdtdtffd t t |xsdD]}t |tr|jd nd}|d k(r,|d k(r!|jd }|sy |zR|dk7ry tfd|jdxsgDcSy )a^True when ``messages`` end on a tool-result run issued by the preceding assistant turn. Azure Foundry rejects only this post-tool shape when encrypted reasoning is replayed, so only the *trailing* messages are checked (a whole-history scan would make suppression sticky). Call ids resolve like ``_chat_messages_to_responses_input``. r)_canonical_call_id_from_fc_split_responses_tool_idNrawexplicitrcr|\}}|r|hn t}t|tr/|jr|j |j|s?t|tr/|jr|j |j|}|r|j ||Sr)setr1rr&rk)r r embedded_call_iditem_idids canonicalrr s r _pair_idsz'_is_post_tool_replay.._pair_idss$}t|tr,|jd|jdz@yw)idcall_idNr)rcallrtrailings rrz'_is_post_tool_replay..s@ $% y$)1DE E sAA tool_callsr) agent.codex_responses_adapterrr rr reversedr1r2r:r)rmsgrrrrr rs @@@@r_is_post_tool_replayr sc s c S uHB' ",S$"7swwvT 8   6>CGGN34C OH  ;   -3    $ rcddlm}t|jdxsdj j dk(ryt|jdxsd}||dxs ||d S) zTrue for any Azure-hosted Responses endpoint: the ``azure-foundry`` provider, a resource-level ``*.openai.azure.com`` host, or the project-scoped ``*.services.ai.azure.com`` gateway.rrrNrrTrQzopenai.azure.comrr)rKrrQs r_is_azure_responsesr"sl, 6::j ! 'R(..0668OK6::j)/R0H += > zBWX`byBzzrcg}d}t|D]}t|tr%|jddk(r|jdnd}t|trqt d|Dr_|r[|Dcgc]*}t|ts|jddk(s)|,}}t|d }|r||d<n|j dd }|j||j|Scc}w) aCopy of ``messages`` keeping ``codex_reasoning_items`` only on the newest assistant row that has any. Foundry rejects a request that replays encrypted reasoning from more than one prior response (HTTP 400 "Conflicting authenticated continuation identities", #105369). ``compaction`` checkpoints stay everywhere. A trimmed row is marked ``codex_reasoning_trimmed`` so the converter still drops its ``msg_*`` id (#97427).Frrcodex_reasoning_itemsNc3hK|]*}t|txr|jddk7,yw)r compactionNr)ris rrz)_newest_reasoning_only..s.*pef:a+>+`155=T`C`+`*ps02rr&T)codex_reasoning_trimmed) rr1r2r:rrr3rireverse)rout newest_keptrr;r' checkpointss r_newest_reasoning_onlyr-s !#CK! 4>sD4IcggV\oalNl/0rv eT "s*pjo*p'p*/iQ:a3F155QW=\hKhqi i3=3>C/0GG34K 3 KKM Jjs2C0C0C0context_managementc<t|txr t|S)zTrue only when the caller's eligibility gate produced a non-empty payload. Every native-compaction wire effect hangs off this predicate, so a persisted checkpoint cannot keep reshaping requests after the gate closes. )r1rr)r.s r_native_compaction_activer0*s ($ / LD9K4LLrtimeoutct|ttfr:t|ts*dt|cxkrtdkr t|Syy)zNFinite positive number -> float; anything else (None, bool, str, inf) -> None.rinfN)r1intfloatr)r1s r_coerce_timeoutr63sG'C<(GT1JqSXY`SaOpdijodpOpW~Pq rrrreplay_encrypted_reasoningis_github_responsesc|rdgng}i}|r|rddlm} ||d<| |rd|i|d<|S|r,|r|jd|d|d<|S|dd |d<||d<|S|s|sg|d<|d k(rdd i|d<|S) u``reasoning`` / ``include`` request fields for the endpoint family. xAI 400s on ``reasoning.effort`` outside its allowlist; GitHub Models takes a verbatim ``github_reasoning_extra`` and never ``include``. A disabled ask resolved to ``effort="none"`` is sent as ``{"effort": "none"}`` — the wire has no other way to switch a reasoning model's default effort off (#75227). zreasoning.encrypted_contentr)grok_supports_reasoning_effortrrrgithub_reasoning_extraauto)rsummaryr)rr:r:) rrKrrr7rr8rfieldsr:s r_reasoning_fieldsr?:s2L,-QSGF#G#y )% 0#+V"4F;  M  zz23?&,-E&F{# M .4"GF;  'F9  M !)9y V #+V"4F;  Mrc neZdZUdZdddddZdZeeed<dZ eeed<dZ ee eefed<e d efd Z d e eefd efd Zd ee eefd efdZdeee eefd efdZ dded ee eefdeee eefd e eeffdZded efdZded efdZdddddedededed e f dZy)ResponsesApiTransportz)Transport for api_mode='codex_responses'.stoplength) completed incompletefailed cancelledN_last_issuer_kind_last_issuer_model_last_wire_aliasesrcy)Ncodex_responsesr`)selfs rapi_modezResponsesApiTransport.api_modegs rrKcddlm}||jddu|jddu|jddu|jd|_|jS) z_Classify the current Responses endpoint from transport params (stashed for normalize_response).r)_classify_responses_issuerrTr8rrQ)rr8rrQ)rrPr:rH)rMrKrPs r_resolve_issuer_kindz*ResponsesApiTransport._resolve_issuer_kindksbL!;#ZZ(:;tC & +@ AT I#ZZ(:;tCZZ + "  %%%rrc @ddlm}m}||jd|_|||jddu|jddut |jdd|j ||jt|jd S) z:Convert OpenAI chat messages to Responses API input items.r)!_chat_messages_to_responses_input_wire_model_identityrrTr8r7r.)rr8r7current_issuer_kindcurrent_issuer_modelnative_compaction_eligible)rrSrTr:rIrrQr0)rMrr6rSrTs rconvert_messagesz&ResponsesApiTransport.convert_messageswsi"6vzz'7J"K0 vzz2D'E'M & +@ AT I'+FJJ7SUY,Z'[ $ 9 9& A!%!8!8'@L`Aa'b   rrcddlm}||S)zBConvert OpenAI tool schemas to Responses API function definitions.r)_responses_tools)rrZ)rMrrZs r convert_toolsz#ResponsesApiTransport.convert_toolssB&&rrc nddlm}|jdd}|}|sM|rK|djddk(r4t|djdxsdj }|dd }|xs|}|jd d u}|jd d u} |jd d u} t |jdd xrt |xr t| } | rt|r t|}|jd} t| } t||\}}t|j||| | \}|_ddlm}|jdxsi}||jd|}|||j#|| || |jd| | |dd}|r||d<d|d<d |d<| r| |d<|jd}t%|jdxs|}t'|||xs|}|s | s|r||d<t)||jd}|r|j+d||j-t/||||| | ||jd }|r | sd!|i|d"<|r|j-|||d<t1|||jdt3|| r4dd#lm}||r|jd$d%k(s|j7d$d t9|jd&|jd&}|||d&<n|j7d&d | rc|r t|nd |jdxs t;|d'}|j=Dcic] \}}|s || }}}|r&t?|fi|n|jd(|d(|d)<| rf|rdt?|fid*|i|jd+}tA|tBr tC|ni|d+<|d+j+d|jd|t3|jd+|Scc}}w),uCBuild Responses API kwargs (calls convert_messages/convert_tools internally). params: instructions, reasoning_config ({effort, enabled}), session_id (transcript id; Codex header; cache-scope fallback), cache_scope_id (rotation-stable scope for the cache key / xAI conv header), max_tokens, timeout, request_overrides, provider, base_url, is_github_responses, is_codex_backend, is_xai_responses, github_reasoning_extra, context_management, replay_encrypted_reasoning. params: instructions: str — system prompt (extracted from messages[0] if not given) reasoning_config: dict | None — {effort, enabled} session_id: str | None — transcript/session id; drives the Codex ``session_id`` header, and is the cache-scope fallback when no ``cache_scope_id`` is given cache_scope_id: str | None — rotation-stable logical scope id (compression-lineage root; see agent/prompt_cache_scope.py). Preferred over session_id when deriving the prompt_cache_key content hash and the xAI x-grok-conv-id header; the Codex x-client-request-id header mirrors the resulting body key. Keeps the cache warm across context-compression session rotation (#79017) max_tokens: int | None — max_output_tokens timeout: float | None — per-request timeout forwarded to the SDK request_overrides: dict | None — extra kwargs merged in provider: str | None — provider name for backend-specific logic base_url: str | None — endpoint URL base_url_hostname: str | None — hostname for backend detection is_github_responses: bool — Copilot/GitHub models backend is_codex_backend: bool — chatgpt.com/backend-api/codex is_xai_responses: bool — xAI/Grok backend github_reasoning_extra: dict | None — Copilot reasoning params r)DEFAULT_AGENT_IDENTITYrrrrrrNr8Trrr7r.)"strip_codex_context_variant_suffixrequest_overridesrrQ)rr8r7rQrr.rF)rrinputstorerr< tool_choiceparallel_tool_callsrcache_scope_idr0r)rrr7rr8text_verbosity verbositytextr service_tierpriorityr1)rzx-client-request-id max_tokensmax_output_tokenszx-grok-conv-id extra_body)"agent.prompt_builderr]r:rr&rrr r"r-r0rrr[rJrr^rXrrr setdefaultr<r?rr5rr3r6r-r;rAr1r2) rMrrrrKr]rpayload_messagesr8rrr7r.native_compaction_activerrrb_strip_ctx_variantr_ wire_modelr6r _cache_scope cache_keycache_retentionrerr1r7r>r?existing_extra_bodys r build_kwargsz"ResponsesApiTransport.build_kwargss{2 @zz."5 #Xa[__V-D-Px{y9?R@FFHL'| #='= $jj)>?4G!::&89TA!::&89TA%)&**5QSW*X%Y& ' / Z4HIY4Z_ " &*=f*E56FG #ZZ(<=#<=O#P .@.O++2C   u %v/?AQ3 // b"JJ':;Ar'(9(=(=gu(MN  (** 3CYl+EPVPZPZ[ePf!1FX`j+    ,F7O$*F= !,0F( ) #+=F' (ZZ - 4FJJ?O4P4^T^_ &|^\RbVb "+; )2F% &EeVZZXbMcd    6 H ' 6"2:F6N  MM+ ,(F7O&vufjj6LM%f-  >%e,N1Kz1Y >40"&**Y 98M"NO   'F9  JJy$ ' 2F& '   L, K]_h@i j%fjj&>? />s 2 P1=P1responsec ddlm}|||jdxs |j|jdxs |j\}}d}|r|j rg}|j }|j D]}dD cic]} t|| ds| t|| } } t|d} | r|jjn t|d d } |tj| | } n | |vr|| } |jtt|d r |jn| xsd| | r|jjn t|d d | xsddD cic]} |rt|| dr| t|| d!} } t!|r |j"nd||xsd|r t|ddndd| xsdScc} wcc} w)z=Normalize Codex Responses API response to NormalizedResponse.r)_normalize_codex_response issuer_kind issuer_model)r{r|N)rresponse_item_idfunctionr[rr argumentsz{})rr[r provider_data)r$codex_message_itemsreasoning_detailsrBr)rr finish_reasonrusager)rrzr:rHrIrrJr{hasattrr~r[_LEGACY_ALIAS_FALLBACKrirrrrr) rMrxr6rzrrrrmtcr,rhas_fnr[s rnormalize_responsez(ResponsesApiTransport.normalize_response(sK6 &**]";"Ut?U?UN3Nt7N7N ]  3>>J//Inn 5T!.1X_`bdgimXnCS))! !!Z0+1r{{''wr627N$155dDADY&$T?D!!( 'D 1ruu D7=bkk3372{\`Ca"/"74# &] wsC. c4( (  "#&CKKDZWdWnhn9B*?*E*E*G*M*M*OSc*ccrF allow_streamr8sanitize_harmony_tokens api_kwargsrr8rctddlm}|||||}t|t|jd|S)zValidate and sanitize Codex API kwargs before the call. ``sanitize_harmony_tokens`` is for the ChatGPT Codex backend only (rejects literal Harmony tokens). r)_preflight_codex_api_kwargsrrl)rrr5r:)rMrrr8rrrs rpreflight_kwargsz&ResponsesApiTransport.preflight_kwargsbs> N0 \GZ$;  &j1%jnn\&BCrr)__name__ __module__ __qualname____doc___STOP_REASON_MAPrHrr__annotations__rIrJr2propertyrNrrQrrXr[rwrrrrrr`rrrArA[s3&,8vdjk(,x}+(, ,37c3h07 !#!! &4S> &c &  d38n)=  C  '8Dc3h,@#A'c'cg[[$(c3h$8[AI$tTWY\T\~J^A_[ c3h[z( 3( =O( Td#d$d"8=Z_(-04SW!% rrA)register_transportrL)Dict)List)Tuple)F)rr)Orr(rloggingrtypingrrragent.reasoning_effortrrrr r r r agent.transports.baser agent.transports.typesrr getLoggerrrcompilerrrr-r5r2rArrrr frozensetrrjrrrVrXrrrrr~rrrr rrr_EXTENDED_PROMPT_CACHE_MODELSrrrrrrrrrrr r"r-r0r5r6r?rAagent.transportsrrrr)r[s0rrsx   **4?   8 $ !bjj!;<,Xc],s,vSvXc]v4S4T4%c3h%C%D% 3!?#,#%5}$EF' n/m2QmTlm ##D6*D08D344S>d"T#s(^&=*O c3h( :?S/ tfck "  dC[$& '  4S#X c3h /0  80 $sCx. D T 42ch:(:(!%c3h:(CG:([_:( 3S#X :(|+.%s3x/2Hc2H4S>2HeCI>N2Hj! #-"**chhY;XYYZ[  # QsQcQhWZmQ*NCNDNEsEcEdE UZ5C535T5^cdgildl^m5&]4S>]#]QT]Y]]&_S_$tCH~:N1O_[^_hpqthu_099HSM9S9\dej\k9<]S#X]4](8Dc3h,@#A(d(V{S#X{4{T$sCx.%9d4S>>R.M#M$MSXe_ S#X36AEcg15 #s(^BW-Wv0$&;<Ks.J=