PL jSdZ ddlZn #e$rYnwxYwddlZddlZddlZddlZddlZddl Z ddl Z ddl Z e j e ZddlZddlZddlZddlZddlZddlZddlZddlZddlmZddlZddlZddlmZmZmZm Z ddl!m"Z"m#Z#m$Z$ddl%m%Z%ddl&m'Z'ddl(m)Z)dd l*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1dd l2m3Z3dd l4m5Z5dd l6m7Z7m8Z8e)Z9e'e:j;d z Z<e5e9e<Z=e=re=D]Z>e?de>ne?dddl@mAZAmBZBmCZCmDZDddlEmFZFmGZGmHZHddlEmIZJmKZLmMZMmNZNddlOmPZPmQZQddlRmSZTddlUmVZVddlWmXZXmYZYmZZZddl[m\Z\ddl]m^Z^ddl_m`Z`maZaddlbmcZcmdZdmeZemfZfmgZgmhZhmiZimjZjddlkmlZlmmZmmnZnmoZompZpmqZqmrZrmsZsmtZtmuZuddlvmwZwddlxmyZyddlzm{Z{dd lbm|Z|m}Z}m~Z~mZmZmZmZmZdd!lmZmZdd"lmZmZmZmZdd#lmZmZmZmZmZdd$lmZmZmZmZmZdd%lmZmZdd&lmZmZmZdd'lmZmZmZmZmZmZmZmZmZmZmZdd(lmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZdd)lmZmZmZmZmZdd*lmZd+ZejZd,Zd-efd.Zddd/d0edzd1edzd-efd2Zd-efd3ZGd4d5eզZGd6d7Z dIded1ed?ed@edAedBedCedDedEedFefdGZe dHkrddlZeje٦dSdS)Jao AI Agent Runner with Tool Calling This module provides a clean, standalone agent that can execute AI models with tool calling capabilities. It handles the conversation loop, tool execution, and response management. Features: - Automatic tool calling loop until completion - Configurable model parameters - Error handling and recovery - Message history management - Support for multiple model providers Usage: from run_agent import AIAgent agent = AIAgent(base_url="http://localhost:30000/v1", model="claude-opus-4-20250514") response = agent.run_conversation("Tell me about the latest Python updates") N)SimpleNamespace)ListDictAnyOptional)urlparseparse_qs urlunparse)datetime)Path)get_hermes_home)OpenAI _OpenAIProxy_load_openai_cls _SafeWriter_install_safe_stdio_get_proxy_from_env_get_proxy_for_base_url)IterationBudget)load_hermes_dotenv)get_provider_request_timeoutget_provider_stale_timeoutz.env) hermes_home project_envz$Loaded environment variables from %sz7No .env file found. Using system environment variables.)get_tool_definitionsget_toolset_for_toolhandle_function_callcheck_toolset_requirements) cleanup_vmget_active_envis_persistent_env)set_approval_callbackset_sudo_password_callback_get_approval_callback_get_sudo_password_callback)maybe_persist_tool_resultenforce_turn_budget) set_interrupt)cleanup_browser)StreamingContextScrubberbuild_memory_context_blocksanitize_context)StreamingThinkScrubber)jittered_backoff)classify_api_errorFailoverReason)DEFAULT_AGENT_IDENTITYPLATFORM_HINTSMEMORY_GUIDANCESESSION_SEARCH_GUIDANCESKILLS_GUIDANCEHERMES_AGENT_HELP_GUIDANCEKANBAN_GUIDANCEbuild_nous_subscription_prompt) fetch_model_metadataestimate_tokens_roughestimate_messages_tokens_roughestimate_request_tokens_roughget_next_probe_tierparse_context_limit_from_error(parse_available_output_tokens_from_errorsave_context_lengthis_local_endpointquery_ollama_num_ctx)ContextCompressor)SubdirectoryHintTracker)apply_anthropic_cache_control)build_skills_system_promptbuild_context_files_promptbuild_environment_hints load_soul_mdTOOL_USE_ENFORCEMENT_GUIDANCETOOL_USE_ENFORCEMENT_MODELS!GOOGLE_MODEL_OPERATIONAL_GUIDANCEOPENAI_MODEL_EXECUTION_GUIDANCE)estimate_usage_costnormalize_usage)"_derive_responses_function_call_id_deterministic_call_id_split_responses_tool_id_summarize_user_message_for_log) KawaiiSpinnerbuild_tool_previewget_cute_tool_message_detect_tool_failureget_tool_emoji)ToolCallGuardrailConfigToolCallGuardrailControllerToolGuardrailDecisionappend_toolguard_guidancetoolguard_synthetic_result)FILE_MUTATING_TOOL_NAMESfile_mutation_result_landed)convert_scratchpad_to_thinkhas_incomplete_scratchpadsave_trajectory) _SURROGATE_RE_sanitize_surrogates_sanitize_structure_surrogates_sanitize_messages_surrogates%_escape_invalid_chars_in_json_strings_repair_tool_call_arguments_strip_non_ascii_sanitize_messages_non_ascii_sanitize_tools_non_ascii_strip_images_from_messages_sanitize_structure_non_ascii)_NEVER_PARALLEL_TOOLS_PARALLEL_SAFE_TOOLS_PATH_SCOPED_TOOLS_DESTRUCTIVE_PATTERNS_REDIRECT_OVERWRITE_is_destructive_command_should_parallelize_tool_batch_extract_parallel_scope_path_paths_overlap_is_multimodal_tool_result_multimodal_text_summary!_append_subdir_hint_to_multimodal_extract_file_mutation_targets_extract_error_preview_trajectory_normalize_msg)atomic_json_writebase_url_host_matchesbase_url_hostnameenv_var_enablednormalize_proxy_url)cfg_getz0.14.1returncddlm}dd|iS)zGReturn the User-Agent RouterMint needs to avoid Cloudflare 1010 blocks.r) __version__ User-Agentz HermesAgent/) hermes_clir)_HERMES_VERSIONs -/home/kuhnn/.hermes/hermes-agent/run_agent.py_routermint_headersrs.999999 6_66 )providerbase_urlrrc|dS|sdS|dks$t|pddrdSt|dkS)u?Decide whether to wait for credential-pool rotation instead of falling back. The existing pool-rotation path requires the pool to (1) exist and (2) have at least one entry not currently in exhaustion cooldown. But rotation is only meaningful when the pool has more than one entry. With a single-credential pool (common for Gemini OAuth, Vertex service accounts, and any "one personal key" configuration), the primary entry just 429'd and there is nothing to rotate to. Waiting for the pool cooldown to expire means retrying against the same exhausted quota — the daily-quota 429 will recur immediately, and the retry budget is burned. Additionally, Google CloudCode / Gemini CLI rate limits are ACCOUNT-level throttles — even a multi-entry pool shares the same quota window, so rotation won't recover. Skip straight to the fallback for those (#13636). In those cases we must fall back to the configured ``fallback_model`` instead. Returns True only when rotation has somewhere to go. See issues #11314 and #13636. NFgoogle-gemini-clicloudcode-pa://) has_availablestr startswithlenentries)poolrrs r!_pool_may_recover_from_rate_limitrsu0 |u     u&&&#hn"*=*=*H*HIZ*[*[&u t||~~   ""rcddl}dtd|d|d}|d|dd S) z8Return default HTTP headers required by Qwen Portal API.rNz QwenCode/z (z; )enablez qwen-oauth)rzX-DashScope-CacheControlzX-DashScope-UserAgentzX-DashScope-AuthType)platform_QWEN_CODE_VERSIONsystemlowermachine)_plat_uas r_qwen_portal_headersrsf X( X XELLNN,@,@,B,B X Xemmoo X X XC$,!$ ,   rc feZdZdZdddddedeedeedeeddf fd ZxZS) _StreamErrorEventaSynthesized provider error surfaced from a Responses ``error`` SSE frame. Some Codex-style Responses backends (xAI for subscription/quota failures, custom relays under malformed-tool-call conditions) emit a standalone ``type=error`` frame instead of routing the failure through ``response.failed`` or returning an HTTP 4xx. The fallback streaming path raises this exception so ``_summarize_api_error`` and ``_extract_api_error_context`` see a familiar ``.body`` / ``.status_code`` shape and the entitlement detector can match the underlying provider message ("do not have an active Grok subscription", etc.). N)codeparam status_codemessagerrrrct|||_||_||_||_d|||ddi|_dS)Nerror)rrrtype)super__init__rrrrbody)selfrrrr __class__s rrz_StreamErrorEvent.__init__-sb !!!   & " %  r) __name__ __module__ __qualname____doc__rrintr __classcell__)rs@rrrs  "##%)     sm  }  c]             rrc}|eZdZdZdZedefdZejdeddfdZ dmdededededede edzdede edzdede de de ede ede de de d ed!e d"ed#e ed$e ed%e ed&ed'e d(ed)ee d*ed+ed,ed-ed.ed/ed0ed1ed2ed3ed4ed5ed6e d7eeefd8ed9eeefd:e eeefd;eded?ed@edAedBedCe dDe dEe dFedGdHdIeeefdJe dKe dLe dMe dNe f|dOZdPZdndQZdRZdodSee ddfdTZdpdUZdVZd dWdXe fdYZde fdZZde fd[Zd\eddfd]Zd\eddfd^Zd_d`lmZ e!deeeffdaZ"dbeeefdceddfddZ#e!dee$defdfZ%dee$de fdgZ&ddhdiedee$dje dke dle dbeeeefddfdmZ'ddhdee$dje dke dle dbeeeefddf dnZ(doedpe$ddfdqZ)deeeffdrZ*dndsZ+dndtZ,dodede fduZ-dodede fdvZ.dodede fdwZ/de fdxZ0de1e e ffdyZ2dze e3eefde fd{Z4de fd|Z5ddddd}deedeedeedeede1e e ff d~Z6e!dede fdZ7e!dddedeede fdZ8de de3fdZ9dede fdZ:dedefdZ;e!dede fdZdededze eeefde fdZ?deefdZ@deddfdZAd_dlBmCZCmDZDmEZEe!de ede ede efdZF dqde ede de ddfdZGddddddeedeedeedeedeeeff dZHdze eddfdZIdodze ede efdZJdze eddfdZKdze ede fdZLdodze ede efdZMdze ede efdZNdefdZOdze eeefdede de eeeffdZPdze eeefdede fdZQe!deeeefdee de fdZRe!deeSdefdZTdeedeefdZUdedefdZVe!deeSdeeeffdZWdedeeeeffdZXdddeeefdedeeeSdeeYfdZZe!dedefdZ[dodze eeeffdZ\dod\eddfdZ]dndZ^dede fdZ_deefdZ`dedeeefdede ddf d„Zade fdÄZbe!deeeeeffdefdńZcdze de ddfdDŽZddeddfdɄZedceddfdʄZfd˄Zgdceddfd̄Zhde3fd̈́Zidodze ddfd΄Zjdodze ddfdτZkdedede ddfdӄZldndԄZmdndՄZnde eeefddfdׄZoede fd؄ZpdodedeeeffdڄZqdodedefdۄZre!defd܄Zse!defd݄ZteuhdޣZve!dze eeefde eeeffd߄Zwe!deeefde fdZxe!dze eeefde eeeffdZye!de de fdZze!de de fdZ{dededzfdZ|dZ}e!drdedede defdZ~e!dede1eeeeffdZ dodedeedefdZdefdZdefdZdejfdZe!dede fdZe!dsdedefdZde3dede defdZe!dede fdZdedede ddfdZdede fdZdedefdZde fdZe!de3de fdZde de3fdZdddedee3defdZdededdfdZdtde3dedefdZdode3defdZddWdXe de fd ZddWdXe de fd Zde fd Zde fd Zdeddfd ZdndZddddee de deedeeeefde1e e ff dZde fdZde3fdZdndZde3fdZdndZdeddfdZe!dedefdZdede fdZdeeefddfdZdeddfdZdeddfdZdeddfdZde fd Zdd!de3defd"Zdodd#de fd$Zde fd%Zd&eSd'e d(e de fd)Ze!dede fd*Ze!d+ede1eeeYffd,Zd+ed-edefd.Zde fd/Zded-edefd0Zdodefd1Zd2e de fd3Zd2e de fd4Zdededefd5Zd2e de fd6Zde fd7Zde fd8Zd2e de fd9Zdze ddfd:Zd2e de3fd;Zde fd<Zde efd=Zdeefd>Zde3dzfd?Zdede3fd@Zde fdAZde fdBZde fdCZde fdDZĐdEe3dFe3ddfdGZe!dFe3de3fdHZe!dddIdze d*ede fdJZde fdKZddLddMdze dedNe dedOede1f dPZɐdQeddfdRZːdQedefdSZdedTe3dUede def dVZ͐dQedefdWZΐdrdze dXedYe ddfdZZϐdTe3defd[Z dud\edTe3dXedeedze d]e defd^Ze!dvd`ededaedefdbZҐdrdze dXedYe ddfdcZӐdrdze dXedYe ddfddZdze dYe defdeZ dwdedede eeefdedfeedgeedeeeffdhZ֐dod\edfeedefdiZd djdededze eeefdXedke deeeff dlZdS(xAIAgentz AI Agent with tool calling capabilities. This class manages the conversation flow, tool execution, and response handling for AI models that support function calling. z[hermes-agent: tool call arguments were corrupted in this session and have been dropped to keep the conversation alive. See issue #15236.]rc|jSN) _base_urlrs rrzAIAgent.base_urlSs ~rvalueNcv||_|r|nd|_t||_dS)Nr)rr_base_url_lowerr_base_url_hostnamerrs rrzAIAgent.base_urlWs805=u{{}}}2"3E":":rrZ?Fd rapi_keyrapi_mode acp_commandacp_argscommandargsmodelmax_iterations tool_delayenabled_toolsetsdisabled_toolsetssave_trajectoriesverbose_logging quiet_modeephemeral_system_promptlog_prefix_chars log_prefixproviders_allowedproviders_ignoredproviders_order provider_sortprovider_require_parametersprovider_data_collectionopenrouter_min_coding_score session_idtool_progress_callbacktool_start_callbacktool_complete_callbackthinking_callbackreasoning_callbackclarify_callback step_callbackstream_delta_callbackinterim_assistant_callbacktool_gen_callbackstatus_callback max_tokensreasoning_config service_tierrequest_overridesprefill_messagesruser_id user_namechat_id chat_name chat_type thread_idgateway_session_keyskip_context_filesload_soul_identity skip_memoryparent_session_iditeration_budgetrfallback_modelcheckpoints_enabledcheckpoint_max_snapshotscheckpoint_max_total_size_mbcheckpoint_max_file_size_mbpass_session_idcAddlm}A|A|fid|d|d|d|d|d|d |d |d | d | d | d| d| d|d|d|d|d|d|d|d|d|d|d|d|d|d|d|d|d |d!|d"| d#|!d$|"d%|#d&|$d'|%d(|&d)|'d*|(d+|)d,|*d-|+d.|,d/|-d0|.d1|/d2|0d3|1d4|2d5|3d6|4d7|5d8|6d9|7d:|8d;|9d<|:d=|;d>|<d?|=d@|>dA|?dB|@dCS)Du2Forwarder — see ``agent.agent_init.init_agent``.r) init_agentrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr session_dbrrrcredential_poolrrrrrN)agent.agent_initr)Brrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr rrrrrrsB rrzAIAgent.__init__]sH 0///// B B B XB GB X B X B $ B XB GB B %B *>B "zB .-B 0/B 0/B ,O!B ""z#B $%<$;%B &.-'B ("z)B *0/+B ,0/-B .,O/B 0(-1B 2)D(C3B 4&>%=5B 6)D(C7B 8"z9B :$:#9;B <!4 3=B >$:#9?B @0/AB B 21CB D.-EB F(-GB H#8"7IB J(B'AKB L0/MB N,OOB P"zQB R.-SB T&UB V0/WB X.-YB ZX[B \G]B ^ i_B `GaB b icB d ieB f igB h!4 3iB j 21kB l 21mB n$ oB p"zqB r0/sB t.-uB v*>wB x,OyB z!4 3{B |&>%=}B ~*F)EB @)D(CAB B,OCB B B B rc|j|jS ddlm}||_|jS#t$r'}tddYd}~dSd}~wwxYw)aiReturn a SessionDB for recall, lazily creating it if an entrypoint forgot. Most frontends pass ``session_db`` into ``AIAgent`` explicitly, but recall is important enough that a missing constructor argument should degrade by opening the default state DB instead of making the advertised ``session_search`` tool unusable. Nr) SessionDBz SessionDB unavailable for recallTexc_info) _session_db hermes_stater  Exceptionloggerdebug)rr excs r_get_session_db_for_recallz"AIAgent._get_session_db_for_recalls   '# #  . . . . . .(y{{D # #    LL;dL K K K44444 s, AAAc Z|js|jsdS |j|j|jpt jdd|j|j |j d|j d|_dS#t$r&}td|Yd}~dSd}~wwxYw)zDCreate session DB row on first use. Disables _session_db on failure.NHERMES_SESSION_SOURCEcli)rsourcer model_config system_promptrrTz5Session DB creation failed (will retry next turn): %s)_session_db_createdrcreate_sessionrrosenvirongetr_session_init_model_config_cached_system_prompt_parent_session_idrrwarning)res r_ensure_db_sessionzAIAgent._ensure_db_sessions  # 4+;  F    + +?}V 7NPU(V(Vj!<"8"&"9 ,   (,D $ $ $    NNG          sA&A:: B*B%%B*c$d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_ d|_ d|_ d|_ t|dr"|jr|jdSdSdS)aReset all session-scoped token counters to 0 for a fresh session. This method encapsulates the reset logic for all session-level metrics including: - Token usage counters (input, output, total, prompt, completion) - Cache read/write tokens - API call count - Reasoning tokens - Estimated cost tracking - Context compressor internal counters The method safely handles optional attributes (e.g., context compressor) using ``hasattr`` checks. This keeps the counter reset logic DRY and maintainable in one place rather than scattering it across multiple methods. rgunknownnonecontext_compressorN)session_total_tokenssession_input_tokenssession_output_tokenssession_prompt_tokenssession_completion_tokenssession_cache_read_tokenssession_cache_write_tokenssession_reasoning_tokenssession_api_callssession_estimated_cost_usdsession_cost_statussession_cost_source_user_turn_counthasattrr*on_session_resetrs rreset_session_statezAIAgent.reset_session_states&%&!$%!%&"%&")*&)*&*+'()%!"*-'#, #) !" 4- . . 743J 7  # 4 4 6 6 6 6 6 7 7 7 7rconfig_context_lengthc 2|jpddkrdS ddlm}ddlm}|t|dd}t|pd|}||j |j t|dd|}|rSt|d d}|B| |j ||j t|dd|j|j dSdSdS#t$r&}td |Yd}~dSd}~wwxYw) zT Preload the LM Studio model with at least Hermes' minimum context. rlmstudioNr)MINIMUM_CONTEXT_LENGTH)ensure_lmstudio_model_loaded_config_context_lengthrr*)rcontext_lengthrrrrzLM Studio preload skipped: %s)rstripragent.model_metadatar>hermes_cli.modelsr?getattrmaxrr update_modelrrrr)rr;r>r? target_ctx loaded_ctxccerrs r_ensure_lmstudio_runtime_loadedz'AIAgent._ensure_lmstudio_runtime_loaded6s~ M R & & ( ( . . 0 0J > > F ? C C C C C C F F F F F F$,(/6NPT(U(U%27a9OPPJ55 DM74B+G+GJ  T#7>>>OO"j'1!% 'i <  ? ? ? LL8# > > > > > > > > > ?sB+C&& D0DDc.ddlm}|||||||S)u?Forwarder — see ``agent.agent_runtime_helpers.switch_model``.r) switch_model)agent.agent_runtime_helpersrN)r new_model new_providerrrrrNs rrNzAIAgent.switch_modelWs.<<<<<<|D)\7HhWWWrcd |jpt}||i|dS#ttf$rYdSwxYw)a3Print that silently handles broken pipes / closed stdout. In headless environments (systemd, Docker, nohup) stdout may become unavailable mid-session. A raw ``print()`` raises ``OSError`` which can crash cron jobs and lose completed work. Internally routes through ``self._print_fn`` (default: builtin ``print``) so callers such as the CLI can inject a renderer that handles ANSI escape sequences properly (e.g. prompt_toolkit's ``print_formatted_text(ANSI(...))``) without touching this method. N) _print_fnprintOSError ValueError)rrkwargsfns r _safe_printzAIAgent._safe_print\sU (5B B      $    DD s //forcer[ct|ddrdS|st|ddrdS|s|r |jsdS|j|i|dS)ueVerbose print — suppressed when actively streaming tokens. Pass ``force=True`` for error/warning messages that should always be shown even during streaming playback (TTS or display). During tool execution (``_executing_tools`` is True), printing is allowed even with stream consumers registered because no tokens are being streamed at that point. After the main response has been delivered and the remaining tool calls are post-response housekeeping (``_mute_post_response``), all non-forced output is suppressed. ``suppress_status_output`` is a stricter CLI automation mode used by parseable single-query flows such as ``hermes chat -q``. In that mode, all status/diagnostic prints routed through ``_vprint`` are suppressed so stdout stays machine-readable. suppress_status_outputFN_mute_post_response)rE_has_stream_consumers_executing_toolsrY)rr[rrWs r_vprintzAIAgent._vprintns& 415 9 9  F 'S  F$)&)))))rc|jdSttdd}|dS t|S#t t tf$rYdSwxYw)aReturn True when quiet-mode spinner output has a safe sink. In headless/stdio-protocol environments, a raw spinner with no custom ``_print_fn`` falls back to ``sys.stdout`` and can corrupt protocol streams such as ACP JSON-RPC. Allow quiet spinners only when either: - output is explicitly rerouted via ``_print_fn``; or - stdout is a real TTY. NTstdoutF)rSrEsysboolisattyAttributeErrorrVrU)rstreams r_should_start_quiet_spinnerz#AIAgent._should_start_quiet_spinnersp > %4h-- >5  (( ( G4   55 s AA! A!cJ|jo|j ot|dddkS)aZReturn True when quiet-mode tool summaries should print directly. Quiet mode is used by both the interactive CLI and embedded/library callers. The CLI may still want compact progress hints when no callback owns rendering. Embedded/library callers, on the other hand, expect quiet mode to be truly silent. rrr)rrrErs r _should_emit_quiet_tool_messagesz(AIAgent._should_emit_quiet_tool_messagess5 O 7// 7j"--6 rrc ||j|dn#t$rYnwxYw|jrF |d|dS#t$r tddYdSwxYwdS)uEmit a lifecycle status message to both CLI and gateway channels. CLI users see the message via ``_vprint(force=True)`` so it is always visible regardless of verbose/quiet mode. Gateway consumers receive it through ``status_callback("lifecycle", ...)``. This helper never raises — exceptions are swallowed so it cannot interrupt the retry/fallback logic. TrZ lifecyclez%status_callback error in _emit_statusr Nrarrrrrrrs r _emit_statuszAIAgent._emit_statuss  LLDO6W66dL C C C C    D    U U$$['::::: U U U Dt TTTTTT U U U # 00A&A=<A=c ||j|dn#t$rYnwxYw|jrF |d|dS#t$r tddYdSwxYwdS)a+Emit a user-visible warning through the same status plumbing. Unlike debug logs, these warnings are meant for degraded side paths such as auxiliary compression or memory flushes where the main turn can continue but the user needs to know something important failed. TrZwarnz&status_callback error in _emit_warningr Nrnros r _emit_warningzAIAgent._emit_warnings  LLDO6W66dL C C C C    D    V V$$VW55555 V V V EPT UUUUUU V V Vrqr)STREAM_DIAG_HEADERSc"ddlm}|S)u9Forwarder — see ``agent.stream_diag.stream_diag_init``.rstream_diag_init)agent.stream_diagrxrws r_stream_diag_initzAIAgent._stream_diag_inits% 766666!!!rdiag http_responsec,ddlm}||||dS)uEForwarder — see ``agent.stream_diag.stream_diag_capture_response``.r)stream_diag_capture_responseN)ryr~)rr{r|r~s r_stream_diag_capture_responsez%AIAgent._stream_diag_capture_responses2 CBBBBB$$T4?????rrc$ddlm}||S)u@Forwarder — see ``agent.stream_diag.flatten_exception_chain``.r)flatten_exception_chain)ryr)rrs r_flatten_exception_chainz AIAgent._flatten_exception_chains' >=====&&u---rct|dddkrdSt|tsdSt|ttjfrdSt |}d|vS)aReturn True for malformed provider streaming data from SDK parsers. Some Anthropic-compatible streaming providers can send a malformed event-stream frame. The Anthropic SDK surfaces that as a plain ``ValueError`` such as ``expected ident at line 1 column 149``. That is provider wire-format trouble, not local request validation, so it should follow the same retry path as a truncated JSON body. rNanthropic_messagesFexpected ident at line) rE isinstancerVUnicodeEncodeErrorjsonJSONDecodeErrorrrBr)rrrs r_is_provider_stream_parse_errorz'AIAgent._is_provider_stream_parse_errors 4T * *.B B B5%,, 5 e0$2FG H H 5e**""$$**,,'722r)r{kindattempt max_attempts mid_tool_callc 6ddlm}||||||||dS)u9Forwarder — see ``agent.stream_diag.log_stream_retry``.r)log_stream_retry)rrrrrr{N)ryr)rrrrrrr{rs r_log_stream_retryzAIAgent._log_stream_retrysJ 766666 t5'%]      rc4ddlm}|||||||dS)u9Forwarder — see ``agent.stream_diag.emit_stream_drop``.r)emit_stream_drop)rrrrr{N)ryr)rrrrrr{rs r_emit_stream_dropzAIAgent._emit_stream_drop sH 766666 w\'d      rtaskrcL ||}n#t$rt|}YnwxYw|p |jj}t |dkr|dddz}|d|d|dS)z4Surface a compact warning for failed auxiliary work.N...u⚠ Auxiliary z failed: ) _summarize_api_errorrrrrrBrrstriprt)rrrdetails r_emit_auxiliary_failurezAIAgent._emit_auxiliary_failures ..s33FF   XXFFF 2CM299;; v;;  DSD\((**U2F CDCC6CCDDDDDs 44c t|ddpdt|ddpdt|ddpdt|ddpdt|ddpddS)zBReturn the live main runtime for session-scoped auxiliary routing.rrrrrr)rrrrr)rErs r_current_main_runtimezAIAgent._current_main_runtime$swT7B//52j"55;j"55;tY339rj"55;    rc(ddlm}||dS)uYForwarder — see ``agent.conversation_compression.check_compression_model_feasibility``.r)#check_compression_model_feasibilityN)agent.conversation_compressionr)rrs r$_check_compression_model_feasibilityz,AIAgent._check_compression_model_feasibility.s+VVVVVV++D11111rc(ddlm}||dS)uPForwarder — see ``agent.conversation_compression.replay_compression_warning``.r)replay_compression_warningN)rr)rrs r_replay_compression_warningz#AIAgent._replay_compression_warning3s+MMMMMM""4(((((rc|t|}n/t|ddptt|dd}|dkS)z8Return True when a base URL targets OpenAI's native API.Nrrrzapi.openai.comrrErrhostnames r_is_direct_openai_urlzAIAgent._is_direct_openai_url8s[  (22HHt%92>>BS/44CCH+++rcx|"t|}nt|ddpd}d|vS)uReturn True when a base URL targets Azure OpenAI. Azure OpenAI exposes an OpenAI-compatible endpoint at ``{resource}.openai.azure.com/openai/v1`` that accepts the standard ``openai`` Python client. Unlike api.openai.com it does NOT support the Responses API — gpt-5.x models are served on the regular ``/chat/completions`` path — so routing decisions must treat Azure separately from direct OpenAI. Nrrzopenai.azure.com)rrrE)rrurls r_is_azure_openai_urlzAIAgent._is_azure_openai_urlBsE  h--%%''CC$ 1266<"C!S((rc|t|}n/t|ddptt|dd}|dkS)zKReturn True when a base URL targets GitHub Copilot's OpenAI-compatible API.Nrrrapi.githubcopilot.comrrs r_is_github_copilot_urlzAIAgent._is_github_copilot_urlRs[  (22HHt%92>>BS/44CCH222rct|j|j}||Stt jddS)aResolve the effective per-call request timeout in seconds. Priority: 1. ``providers..models..timeout_seconds`` (per-model override) 2. ``providers..request_timeout_seconds`` (provider-wide) 3. ``HERMES_API_TIMEOUT`` env var (legacy escape hatch) 4. 1800.0s default Used by OpenAI-wire chat completions (streaming and non-streaming) so the per-provider config knob wins over the 1800s default. Without this helper, the hardcoded ``HERMES_API_TIMEOUT`` fallback would always be passed as a per-call ``timeout=`` kwarg, overriding the client-level timeout the AIAgent.__init__ path configured. NHERMES_API_TIMEOUTg @)rrrfloatrgetenv)rcfgs r_resolved_api_call_timeoutz"AIAgent._resolved_api_call_timeout\s<+4=$*EE ?JRY3V<<===rct|j|j}||dfStjd}|t |dfSdS)a9Resolve the base non-stream stale timeout and whether it is implicit. Priority: 1. ``providers..models..stale_timeout_seconds`` 2. ``providers..stale_timeout_seconds`` 3. ``HERMES_API_CALL_STALE_TIMEOUT`` env var 4. 300.0s default Returns ``(timeout_seconds, uses_implicit_default)`` so the caller can preserve legacy behaviors that only apply when the user has *not* explicitly configured a stale timeout, such as auto-disabling the detector for local endpoints. NFHERMES_API_CALL_STALE_TIMEOUT)gr@T)rrrrrr)rr env_timeouts r%_resolved_api_call_stale_timeout_basez-AIAgent._resolved_api_call_stale_timeout_basepsT) CC ?: i ?@@  "%%u, ,{rmessagesc<|\}}t|ddp|jpd}|r |rt|rt dSt d|Ddz}|dkrt |dS|d krt |d S|S) z@Compute the effective non-stream stale timeout for this request.rNrinfc3NK|] }tt|V!dSr)rr).0vs r z.s.77SVV777777rig@iPg |@)rrErrArsumrF)rr stale_baseuses_implicit_defaultr est_tokenss r!_compute_non_stream_stale_timeoutz)AIAgent._compute_non_stream_stale_timeouts,0,V,V,X,X) )4d33Jt}J  X 2CH2M2M << 77h777771<   z5)) )   z5)) )rc,t|jdS)z1Return True when the base URL targets OpenRouter. openrouter.air~rrs r_is_openrouter_urlzAIAgent._is_openrouter_urls$T%9?KKKrrrrrc.ddlm}||||||S)uPForwarder — see ``agent.agent_runtime_helpers.anthropic_prompt_cache_policy``.r)anthropic_prompt_cache_policyr)rOr)rrrrrrs r_anthropic_prompt_cache_policyz&AIAgent._anthropic_prompt_cache_policys5 NMMMMM,,THxbjrwxxxxrc|}d|vr|ddd}|dS)a>Return True for models that require the Responses API path. GPT-5.x models are rejected on /v1/chat/completions by both OpenAI and OpenRouter (error: ``unsupported_api_for_model``). Detect these so the correct api_mode is set regardless of which provider is serving the model. /rzgpt-5)rrsplitr)rms r_model_requires_responses_apiz%AIAgent._model_requires_responses_apisD KKMM !88a  $A||G$$$rrc|pd}|dkrdS|dkr" ddlm}||S#t$rYnwxYwt |S)zCReturn True when this provider/model pair should use Responses API.rnousFcopilotr)!_should_use_copilot_responses_api)rBrrDrrrr)rrnormalized_providerrs r&_provider_model_requires_responses_apiz.AIAgent._provider_model_requires_responses_apis (~24466<<>> & ( (5 ) + + OOOOOO88???    44U;;;sA AAc|s(|s|rd|iSd|iS)avReturn the correct max tokens kwarg for the current provider. OpenAI's newer models (gpt-4o, o-series, gpt-5+) require 'max_completion_tokens'. Azure OpenAI also requires 'max_completion_tokens' for gpt-5.x models served via the OpenAI-compatible endpoint. OpenRouter, local models, and older OpenAI models use 'max_tokens'. max_completion_tokensr)rrrrs r_max_tokens_paramzAIAgent._max_tokens_paramsT  % % ' ' 44+D+D+F+F 4$JeJeJgJg 4+U3 3e$$rcontentcv|sdS||}t|S)a Check if content has actual text after any reasoning/thinking blocks. This detects cases where the model only outputs reasoning but no actual response, which indicates an incomplete generation that should be retried. Must stay in sync with _strip_think_blocks() tag variants. Args: content: The assistant message content to check Returns: True if there's meaningful content after think blocks, False otherwise F)_strip_think_blocksrerB)rrcleaneds r_has_content_after_think_blockz&AIAgent._has_content_after_think_blocks> 5**733GMMOO$$$rc&ddlm}|||S)uEForwarder — see ``agent.agent_runtime_helpers.strip_think_blocks``.r)strip_think_blocks)rOr)rrrs rrzAIAgent._strip_think_blockss'BBBBBB!!$000rc||sdS|}|sdS|drdS|ddvS)zCHeuristic: does visible assistant text look intentionally finished?Fz```Tru$.!?:)"']}。！？：）】」』》)rendswith)rstrippeds r_has_natural_response_endingz$AIAgent._has_natural_response_endingsX 5>>## 5   U # # 4|FFFrc|jpd}|jpd}d|vr|dkrdSd|jvs d|jvrdSt |jot |jS)zHDetect the narrow backend family affected by Ollama/GLM stop misreports.rglmzaiFollamaz:11434T)rrrrrerrA)r model_lowerprovider_lowers r_is_ollama_glm_backendzAIAgent._is_ollama_glm_backendsz'R..00 --24466  # #%(?(?5 t+ + +x4;O/O/O4DMF&7 &F&FGGGr finish_reasonc|dks |jdkrdS|sdStd|pgDsdS|t|ddrdSt|dd}t |t sdS||}|sdSt|dkstj d |sdS| | S) zIDetect conservative stop->length misreports for Ollama-hosted GLM models.stopchat_completionsFc3rK|]2}t|to|ddkV3dS)roletoolN)rdictr )rmsgs rrz:AIAgent._should_treat_stop_as_truncated..sT   sD ! ! ?cggfoo&?      rN tool_callsrrz\s) rranyrErrrrBrresearchr)rrassistant_messagerr visible_texts r_should_treat_stop_as_truncatedz'AIAgent._should_treat_stop_as_truncated s& F " "dm7I&I&I5**,, 5   B      5  $0A>@@  5 |  r ! !5,)G)G !544\BBBBr user_messageassistant_contentc*ddlm}|||||S)uTForwarder — see ``agent.agent_runtime_helpers.looks_like_codex_intermediate_ack``.r)!looks_like_codex_intermediate_ack)rOr)rrrrrs r"_looks_like_codex_intermediate_ackz*AIAgent._looks_like_codex_intermediate_ack)s0 RQQQQQ00|EVX`aaarc&ddlm}|||S)uDForwarder — see ``agent.agent_runtime_helpers.extract_reasoning``.r)extract_reasoning)rOr )rrr s r_extract_reasoningzAIAgent._extract_reasoning3s(AAAAAA  '8999rtask_idc&ddlm}|||S)uKForwarder — see ``agent.chat_completion_helpers.cleanup_task_resources``.r)cleanup_task_resources)agent.chat_completion_helpersr )rr r s r_cleanup_task_resourceszAIAgent._cleanup_task_resources8s'HHHHHH%%dG444r)_MEMORY_REVIEW_PROMPT_SKILL_REVIEW_PROMPT_COMBINED_REVIEW_PROMPTreview_messagesprior_snapshotc&ddlm}|||S)uRForwarder — see ``agent.background_review.summarize_background_review_actions``.r)#summarize_background_review_actions)agent.background_reviewr)rrrs r$_summarize_background_review_actionsz,AIAgent._summarize_background_review_actionsFs* POOOOO22?NSSSrmessages_snapshot review_memory review_skillscddlm}|||||\}}tj|dd}|dS)u^Spawn the background memory/skill review thread. Thin wrapper — the heavy lifting lives in ``agent.background_review.spawn_background_review_thread`` which returns the thread target. ``threading.Thread`` is constructed here so existing tests that patch ``run_agent.threading.Thread`` keep working. r)spawn_background_review_thread)rrTz bg-review)targetdaemonnameN)rr threadingThreadstart)rrrrrr_promptts r_spawn_background_reviewz AIAgent._spawn_background_reviewOsh KJJJJJ88  ''      F4k J J J  r write_originexecution_contextr  tool_call_idr(r)r*c.ddlm}||||||S)uJForwarder — see ``agent.background_review.build_memory_write_metadata``.r)build_memory_write_metadatar')rr,)rr(r)r r*r,s r_build_memory_write_metadataz$AIAgent._build_memory_write_metadatags@ HGGGGG** %/%     rct|dd}t|dd}||dSd|cxkrt|krAndS||}t|tr"|ddkr ||d<dSdSdSdS)aRewrite the current-turn user message before persistence/return. Some call paths need an API-only user-message variant without letting that synthetic text leak into persisted transcripts or resumed session history. When an override is configured for the active turn, mutate the in-memory messages list in place so both persistence and returned history stay clean. _persist_user_message_idxN_persist_user_message_overriderruserr)rErrrr )rridxoverriders r$_apply_persist_user_message_overridez,AIAgent._apply_persist_user_message_overrideysd7>>4!A4HH  s{ F  # # # #c(mm # # # # # #3-C#t$$ *F)B)B!)I $ # * *)B)Brconversation_historyc||||||_|||||dS)zSave session state to both JSON log and SQLite on any exit path. Ensures conversations are never lost, even on errors or early returns. N))_drop_trailing_empty_response_scaffoldingr4_session_messages_save_session_log_flush_messages_to_session_db)rrr5s r_persist_sessionzAIAgent._persist_sessionse 66x@@@ 11(;;;!) x((( **85IJJJJJrcd}|rt|dtr|dds|ddri|d}|rQt|dtr6|ddN|ddi|sdS|rt|dtro|dddkrP||r:t|dtr|dddkP|rkt|dtrR|ddd kr5|dd r|dSdSdSdSdS) uRemove private empty-response retry/failure scaffolding from transcript tails. Also rewinds past any trailing tool-result / assistant(tool_calls) pair that the failed iteration left hanging. Without this, the tail ends at a raw ``tool`` message and the next user turn lands as ``...tool, user, user`` — a protocol-invalid sequence that most providers silently reject (returns empty content), causing the empty-retry loop to fire forever. See #. Fr_empty_recovery_synthetic_empty_terminal_sentinelTNrr assistantr)rrr pop)rrdropped_scaffoldings rr7z1AIAgent._drop_trailing_empty_response_scaffoldings$  '8B<.. '   !<== ' B<##$>?? ' LLNNN"&   '8B<.. '   !<== ' B<##$>?? '"#  F  8B<..    ((F22 LLNNN  8B<..    ((F22  8B<..    ((K77   ..8 LLNNNNN     8777rc&ddlm}|||S)uJForwarder — see ``agent.agent_runtime_helpers.repair_message_sequence``.r)repair_message_sequence)rOrC)rrrCs r_repair_message_sequencez AIAgent._repair_message_sequences'GGGGGG&&tX666rc|jsdS|| |js||rt |nd}t ||j}||dD]}|dd}|d}t|rt|}nt|trg}|D]} t| trP| ddkr7| t| ddgt| tr,| dd vr| d |rd |nd}d} t!|d r3t|jtr|jrd |jD} n0t|d tr|d } |j|j|||d| |d|d|dkr|dnd|dkr|dnd|dkr|dnd|dkr|dnd|dkr|dnd t ||_dS#t($r&} t*d| Yd} ~ dSd} ~ wwxYw)u%Persist any un-flushed messages to the SQLite session store. Uses _last_flushed_db_idx to track which messages have already been written, so repeated calls (from multiple exit paths) only write truly new messages — preventing the duplicate-write bug (#860). Nrrr(rrtextr>image image_url input_imagez [screenshot] rc@g|]}|jj|jjdS))r  arguments)functionr rLrtcs r z9AIAgent._flush_messages_to_session_db..s:'''"$!1 @UVV'''r tool_namer*rr? reasoningreasoning_contentreasoning_detailscodex_reasoning_itemscodex_message_items) rrrrQrr*rrRrSrTrUrVz$Session DB append_message failed: %s)rr4rr&rrF_last_flushed_db_idxr rwrxrlistrappendrjoinr8rappend_messagerrrr$) rrr5 start_idx flush_fromrrr_txtptool_calls_datar%s rr:z%AIAgent._flush_messages_to_session_dbs~  F 11(;;;/ F+ *'')))5IP0111qIY(ABBJ ,& & wwvy11''),,.g66 @6w??GG..@D$88%a..8155==F3J3J KKAEE&",=,=(>(>????'4008QUU6]]Fk5k5k KK77715?diiooo4G"&3 --8*S^T2R2R8WZWe8''"%.'''OO  5 5t<<8&),&7O //##!ggk22.!$!8!8"%''/":":6:k6I6Icggk222tFJkFYFYcgg.A&B&B&B_cFJkFYFYcgg.A&B&B&B_cNRVaNaNa#''2I*J*J*JgkJNR]J]J]0E(F(F(Fcg0    ),H D % % % F F F NNA1 E E E E E E E E E FsK+L L=L88L=c|sgSd}tt|dz ddD]%}||ddkr|}n&||S|d|S)a Get messages up to (but not including) the last assistant turn. This is used when we need to "roll back" to the last successful point in the conversation, typically when the final assistant message is incomplete or malformed. Args: messages: Full message list Returns: Messages up to the last complete assistant turn (ending with user/tool message) Nrrrr?)rangerr copy)rrlast_assistant_idxis r"_get_messages_up_to_last_assistantz*AIAgent._get_messages_up_to_last_assistant s I"s8}}q("b11  A{v&&+55%&"6  %==?? "+++,,rc$ddlm}||S)uJForwarder — see ``agent.system_prompt.format_tools_for_system_message``.r)format_tools_for_system_message)agent.system_promptrh)rrhs r _format_tools_for_system_messagez(AIAgent._format_tools_for_system_message*s%GGGGGG..t444r user_query completedc*ddlm}|||||S)uOForwarder — see ``agent.agent_runtime_helpers.convert_to_trajectory_format``.r)convert_to_trajectory_format)rOrn)rrrkrlrns r_convert_to_trajectory_formatz%AIAgent._convert_to_trajectory_format/s+LLLLLL++D(J RRRrcr|jsdS||||}t||j|dS)a Save conversation trajectory to JSONL file. Args: messages (List[Dict]): Complete message history user_query (str): Original user query completed (bool): Whether the conversation completed successfully N)rro_save_trajectory_to_filer)rrrkrl trajectorys r_save_trajectoryzAIAgent._save_trajectory4sE%  F77*iXX  TZCCCCCr error_contextrc|dvrdSt|tsdSt|dpd}t|dpd}|d|}|sdSd|vrdSd |vrd |vrdSd |vrd |vrdSdS) a.Detect subscription/entitlement 403s that masquerade as auth failures. Returned True only when the body text matches a known entitlement shape AND the status is 401/403. Refreshing an OAuth token cannot fix an unsubscribed account, so callers should surface the error instead of looping the credential pool. Current matches: * xAI OAuth: "do not have an active Grok subscription" / "out of available resources" / "does not have permission" + "grok" Extend here for new providers as we discover them (Anthropic's Claude Max OAuth entitlement errors look distinct enough today that the existing 1M-context-beta branch handles them; revisit if other subscription tiers start producing the same loop signature). >NFrrreason z'do not have an active grok subscriptionTzout of available resourcesgrokzdoes not have permission)rrrr rrB)rtrrrxhaystacks r_is_entitlement_failurezAIAgent._is_entitlement_failureCs* . . .5-.. 5m'' 228b99??AA]&&x006B77==??((((~~ 5 4 @ @4 '8 3 3(8J8J4 % 1 1f6H6H4urcXt|}t|tr#d|vr d|ddSd|vsd|vrt jd|tj}|r'|dnd }t jd |}|r'|dnd}t|d d}g}|r| d || ||r| d |d |St|dd}t|trt| dtr)| di dn| d} | r)t|d d}|rd |dnd} | | ddSt|d d}|rd |dnd} | |ddS)zExtract a human-readable one-liner from an API error. Handles Cloudflare HTML error pages (502, 503, etc.) by pulling the tag instead of dumping raw HTML. Falls back to a truncated str(error) for everything else. r��z'Malformed provider streaming response: Ni,��z <!DOCTYPE<htmlz<title[^>]*>([^<]+)rz!HTML error page (title not found)z2Cloudflare Ray ID:\s*]*>([^<]+)rzHTTP zRay u — rrr: rr)rrrVrrr IGNORECASEgrouprBrErYrZrr ) rrawrtitlerayray_idrpartsrrprefixs rrzAIAgent._summarize_api_erroris^%jj uj ) ) I(CIIKK77HS#YHH H #  C 8#r}MMA*+TAGGAJJ$$&&&1TE)QSVWWC-0:SYYq\\'')))dF!%==KE 4 2[22333 LL    . _F__---<<&& &ufd++ dD ! ! .:DTXXgEVEVX\:]:]v$((7B''++I666cgckcklucvcvC .%e]DAA 4?G00000R -#dsd)---e]D99 ,7?(((((R%#dsd)%%%rkeycb|sdSt|dkrdS|ddd|ddS)N z***rr)r)rrs r_mask_api_key_for_logszAIAgent._mask_api_key_for_logssG 4 s88r>>5bqb'((c"##h(((r error_msgc|sdS|dsd|vrdSd|}t |dkr |dddz}|S) a Clean up error messages for user display, removing HTML content and truncating. Args: error_msg: Raw error message from API or exception Returns: Clean, user-friendly error message z Unknown errorz)z\n\1z ()\n+z\1\n)r`rsubrB)rs r_clean_session_contentzAIAgent._clean_session_contentsS N-g66&'7;;&)7G<<}}rc <|p|j}|sdS g}|D]r}|ddkrB|dr-t|}||d|d<||s|jr tj|j d}|dt|dg}|t|kr%tj d |t|dSn#t$rYnwxYw|j|j|j|j|jt)j|jpd |jpgt||d }t1|j|d t2 dS#t$r/}|jrtjd|Yd}~dSYd}~dSd}~wwxYw)a Save the full raw session to a JSON file. Stores every message exactly as the agent sees it: user messages, assistant messages (with reasoning, finish_reason, tool_calls), tool responses (with tool_call_id, tool_name), and injected system messages (compression summaries, todo snapshots, etc.). REASONING_SCRATCHPAD tags are converted to blocks for consistency. Overwritten after each turn so it always reflects the latest state. Nrr?rutf-8encoding message_countrzHSkipping session log overwrite: existing has %d messages, current has %dr) rrrr session_start last_updatedrtoolsrr)indentdefaultzFailed to save session log: )r8r rrrYsession_log_fileexistsrloads read_textrloggingrrrrrrr isoformatr nowr"rr}rrr$)rrrrexistingexisting_countentryr%s rr9zAIAgent._save_session_logs5t5  F0 DG $ $776??k11cggi6H6H1s))C%)%@%@Y%P%PC Ns#### $++--  #z$*?*I*ISZ*I*[*[\\H%-\\/3x||T^`bGcGcCdCd%e%eN%G 44 f*CLL 5 !D#o M M!%!3!=!=!?!? (  8 8 : :!%!;!Ar)r!$W#  E %        D D D# D Bq B BCCCCCCCCC D D D D D D Ds>BG" BD=<G"= E G" E  BG"" H,HHcd|_||_|jtd|jd|_nd|_t |dd}t |dd}|Q|O|5t |}dddn #1swxYwY|D]#} td|#t$rY wxYw|j5t |j }dddn #1swxYwY|D]J} | |#t$r%}t d|Yd}~Cd}~wwxYw|j s?td|r!t|dkrd |ddd n |rd |d nd zdSdS) a Request the agent to interrupt its current tool-calling loop. Call this from another thread (e.g., input handler, message receiver) to gracefully stop the agent and process a new message. Also signals long-running tool executions (e.g. terminal commands) to terminate early, so the agent can respond immediately. Args: message: Optional new message that triggered the interrupt. If provided, the agent will include this in its response context. Example (CLI): # In a separate input thread: if user_typed_something: agent.interrupt(user_input) Example (Messaging): # When new message arrives for active session: if session_has_running_agent: running_agent.interrupt(new_message.text) TNF_tool_worker_threads_tool_worker_threads_lockz0Failed to propagate interrupt to child agent: %su ⚡ Interrupt requested(z: 'z...''r)_interrupt_requested_interrupt_message_execution_thread_id_set_interrupt _interrupt_thread_signal_pendingrErXr_active_children_lock_active_children interruptrrrrTr) rr_tracker _tracker_lock _worker_tids_wtid children_copychildr%s rrzAIAgent.interrupt%s0%)!")  $ 0 4!: ; ; ;49D 1 1 59D 14!7>>&A4HH  M$= . .#H~~  . . . . . . . . . . . . . . .%  "4//// D ' 8 8 !677M 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8" T TE T(((( T T T OQRSSSSSSSS T V -W2TY\]dYeYehjYjYj1Iwss|1I1I1I1IELqTqAv}qAqAqAqARTU V V V V V V VsN"A>>BBB B,+B,6CCC'C== D,D''D,cd|_d|_d|_|jt d|jt |dd}t |dd}|Q|O|5t |}dddn #1swxYwY|D]#} t d|#t$rY wxYwt |dd}|$|5d|_ddddS#1swxYwYdSdS)zMClear any pending interrupt request and the per-thread tool interrupt signal.FNrr_pending_steer_lock) rrrrrrErXr_pending_steer)rrrrr _steer_locks rclear_interruptzAIAgent.clear_interruptis$)!"&05-  $ 0 5$"; < < <4!7>>&A4HH  M$= . .#H~~  . . . . . . . . . . . . . . .%  "5%0000 D d$94@@  " + +&*# + + + + + + + + + + + + + + + + + + # "s6A66A:=A:B B$#B$<CCCrFcB|r|sdS|}t|dd}|$t|dd}|r|dz|zn||_dS|5|jr|jdz|z|_n||_dddn #1swxYwYdS)a Inject a user message into the next tool result without interrupting. Unlike interrupt(), this does NOT stop the current tool call. The text is stashed and the agent loop appends it to the LAST tool result's content once the current tool batch finishes. The model sees the steer as part of the tool output on its next iteration. Thread-safe: callable from gateway/CLI/TUI threads. Multiple calls before the drain point concatenate with newlines. Args: text: The user text to inject. Empty strings are ignored. Returns: True if the steer was accepted, False if the text was empty. FrNrrJT)rBrEr)rrFr_lockrs rsteerz AIAgent.steers$ 4::<< 5**,,3T:: =t%5t<0noofffalse) load_configdisplayfile_mutation_verifierT) rrr rBrhermes_cli.configrrrrre)r_osenv _load_config_cfg_displays r_file_mutation_verifier_enabledz'AIAgent._file_mutation_verifier_enableds     +//"ABBCyy{{((**2MMM IIIIII#|~~+    .8t.D.DNtxx ***$H(D)) D.F(.R.RHLL)ABBCCC    D ts7AC AC A-*C,A--A)C C%$C%failedc  |sdSdt|dg}d}|D]\}}|dkrn|dpd}|dpd}|r|d |d |d |n|d |d |d |d z }t||z }|dkr|d|dd|S)a Render the per-turn failed-mutation dict as a user-facing footer. Displays up to 10 paths with their first error preview, then a count of any additional failures. Returns an empty string when the dict is empty so callers can concatenate unconditionally. ru⚠️ File-mutation verifier: z file(s) were NOT modified this turn despite any wording above that may suggest otherwise. Run `git status` or `read_file` to confirm.rrrrpatch • u — [z] z] failedru • … and z morerJ)ritemsr rBrYrZ)rlinesshownrinforr remainings r$_format_file_mutation_failure_footerz,AIAgent._format_file_mutation_failure_footersN 2 &6{{ & & &   ,,..  JD${{xx006B==??G88F##.wD B CdCC$CC'CCDDDD @d@@$@@@AAA QJEEKK%' q== LL:)::: ; ; ;yyr num_tool_msgsc(ddlm}||||S)uVForwarder — see ``agent.agent_runtime_helpers.apply_pending_steer_to_tool_results``.r)#apply_pending_steer_to_tool_results)rOr)rrrrs r$_apply_pending_steer_to_tool_resultsz,AIAgent._apply_pending_steer_to_tool_results s)SSSSSS224=QQQrdesccDtj|_||_dS)zAUpdate the last-activity timestamp and description (thread-safe).N)time_last_activity_ts_last_activity_desc)rrs r_touch_activityzAIAgent._touch_activity%s!%#'   rc|dSt|dd}|sdS ddlm}|||j}| ||_dSdS#t $rYdSwxYw)zParse x-ratelimit-* headers from an HTTP response and cache the state. Called after each streaming API call. The httpx Response object is available on the OpenAI SDK Stream via ``stream.response``. Nheadersr)parse_rate_limit_headersr)rEagent.rate_limit_trackerr r_rate_limit_stater)rr|r r rs r_capture_rate_limitszAIAgent._capture_rate_limits*s  F-D99  F  I I I I I I,,Wt}MMME ).&&&!     DD s!A A Ac|jS)z1Return the last captured RateLimitState, or None.)r rs rget_rate_limit_statezAIAgent.get_rate_limit_state=s %%rc||dSt|dd}|sdS |d}|sdS|dkr2|xjdz c_td|jdStd|dS#t$rYdSwxYw)zRead X-OpenRouter-Cache-Status from response headers and log it. Increments ``_or_cache_hits`` on HIT so callers can report savings. Nr zx-openrouter-cache-statusHITrz)OpenRouter response cache HIT (total: %d)zOpenRouter response cache %s)rEr upper_or_cache_hitsrrrr)rr|r statuss r_check_openrouter_cache_statusz&AIAgent._check_openrouter_cache_statusAs  F-D99  F [[!<==F ||~~&&##q(## GI\]]]]] ;V\\^^LLLLL    DD sB-AB->-B-- B;:B;c tj|jz }|j|jt|d|j|j|j|jj|jj dS)zReturn a snapshot of the agent's current activity for diagnostics. Called by the gateway timeout handler to report what the agent was doing when it was killed, and by the periodic "still working" notifications. r)last_activity_tslast_activity_descseconds_since_activity current_toolapi_call_countr budget_used budget_max) rrrround _current_tool_api_call_countrrused max_total)relapseds rget_activity_summaryzAIAgent.get_activity_summaryWsc )++ 66 $ 6"&":&+GQ&7&7 ."2"105/9   rch|jrY |j|pgn#t$rYnwxYw |jn#t$rYnwxYwt |dr?|jr: |j|jpd|pgdS#t$rYdSwxYwdSdS)uCShut down the memory provider and context engine — call at actual session boundaries. This calls on_session_end() then shutdown_all() on the memory manager, and on_session_end() on the context engine. NOT called per-turn — only at CLI exit, /reset, gateway session expiry, etc. r*rN)_memory_manageron_session_endr shutdown_allr8r*rrrs rshutdown_memory_providerz AIAgent.shutdown_memory_provideris!    $33HNCCCC     $113333     4- . . 43J  '66O)rN         s/& 33A AA9$B B-,B-c|jr. |j|pgn#t$rYnwxYwt|dr?|jr: |j|jpd|pgdS#t$rYdSwxYwdSdS)uTrigger end-of-session extraction without tearing providers down. Called when session_id rotates (e.g. /new, context compression); providers keep their state and continue running under the old session_id — they just flush pending extraction now.r*rN)r'r(rr8r*rr*s rcommit_memory_sessionzAIAgent.commit_memory_sessions    $33HNCCCC     4- . . 43J  '66O)rN         s& 33$A44 BBoriginal_user_messagefinal_response interruptedc|rdS|jr|r|sdS |j|||jpd|j||jpddS#t$rYdSwxYw)usMirror a completed turn into external memory providers. Called at the end of ``run_conversation`` with the cleaned user message (``original_user_message``) and the finalised assistant response. The external memory backend gets both ``sync_all`` (to persist the exchange) and ``queue_prefetch_all`` (to start warming context for the next turn) in one shot. Uses ``original_user_message`` rather than ``user_message`` because the latter may carry injected skill content that bloats or breaks provider queries. Interrupted turns are skipped entirely (#15218). A partial assistant output, an aborted tool chain, or a mid-stream reset is not durable conversational truth — mirroring it into an external memory backend pollutes future recall with state the user never saw completed. The prefetch is gated on the same flag: the user's next message is almost certainly a retry of the same intent, and a prefetch keyed on the interrupted turn would fire against stale context. Normal completed turns still sync as before. The whole body is wrapped in ``try/except Exception`` because external memory providers are strictly best-effort — a misconfigured or offline backend must not block the user from seeing their response. Nr)r)r'sync_allrqueue_prefetch_allr)rr.r/r0s r_sync_external_memory_for_turnz&AIAgent._sync_external_memory_for_turnsB   F$  rr6s rr<z AIAgent.closes9$ d339r  ? ? ? ? ? ?  % %g % 6 6 6 6    D   w        D   G $ $ $ $    D  + . . 566%++--- . . . . . . . . . . . . . . ."  KKMMMM D      D  T8T22F!))&t)TTT" "!    DD s2 ??A A A $A44 BBC< .C: C<C  C< C C<C+*C<+ C85C<7C88C<< D D  2E EEhistorycd}t|D]}|ddkr|dd}d|vr7 tj|}d|vr%t |dt r |d}nv#tjtf$rYwxYw|rP|j |d |j s-| |j d t|d tddS) a Recover todo state from conversation history. The gateway creates a fresh AIAgent per message, so the in-memory TodoStore is empty. We scan the history for the most recent todo tool response and replay it to reconstruct the state. Nrrrrz"todos"todosF)mergeu📋 Restored z todo item(s) from history)reversedr rrrrXr TypeError _todo_storewriterrarrr)rrDlast_todo_responserrdatas r_hydrate_todo_storezAIAgent._hydrate_todo_store5s6"G$$  Cwwv&((ggi,,G'' z'**d??z$w-'F'F?)-g&E()4      t   " "#5U " C C C? t rrsCU?V?Vrrrsssus ;BB! B!c|jS)z)Check if an interrupt has been requested.)rrs ris_interruptedzAIAgent.is_interruptedUs ((rsystem_messagec(ddlm}|||S)uDForwarder — see ``agent.system_prompt.build_system_prompt_parts``.r)build_system_prompt_partsrQ)rirS)rrQrSs r_build_system_prompt_partsz"AIAgent._build_system_prompt_partscs*AAAAAA((nMMMMrc(ddlm}|||S)u>Forwarder — see ``agent.system_prompt.build_system_prompt``.r)build_system_promptrT)rirW)rrQrWs r_build_system_promptzAIAgent._build_system_prompths*;;;;;;""4GGGGrct|tr.|ddp|ddpdSt|ddpt|ddpdS)z8Extract call ID from a tool_call entry (dict or object).call_idridrrr rE)rOs r_get_tool_call_id_staticz AIAgent._get_tool_call_id_staticmsk b$   C66)R((BBFF4,<,<B Br9b))HWRr-B-BHbHrct|trD|d}t|tr|ddpdSdSt|dd}t|ddpdS)abExtract function name from a tool_call entry (dict or object). Gemini's OpenAI-compatibility endpoint requires every `role: tool` message to carry the matching function name. OpenAI/Anthropic/ollama tolerate its absence, so the field is best-effort: callers fall back to "" and the message still works elsewhere. rMr rNr\)rOrXs r_get_tool_call_name_staticz"AIAgent._get_tool_call_name_staticts b$    ##B"d## 0vvfb))/R/2 RT * *r62&&,",r>rr1rrMr? developerc$ddlm}||S)uHForwarder — see ``agent.agent_runtime_helpers.sanitize_api_messages``.r)sanitize_api_messages)rOrb)rrbs r_sanitize_api_messageszAIAgent._sanitize_api_messagess( FEEEEE$$X...rrcft|tr|ddkrdS|drdS|d}t|tr|rdSnt|t r|D]}t|ts|rdS|d}|dvr7|dkrC|dd }t|tr|rdSdSn ||d krdS|d p|d }t|tr|rd S|d}t|t r|rd SdS)umReturn True if ``msg`` is an assistant turn whose only payload is reasoning. "Thinking-only" means the model emitted reasoning (``reasoning`` or ``reasoning_content``) but no visible text and no tool_calls. When sent back to providers that convert reasoning into thinking blocks (native Anthropic, OpenRouter Anthropic, third-party Anthropic-compatible gateways), the resulting message has only thinking blocks — which Anthropic rejects with HTTP 400 "The final block in an assistant message cannot be `thinking`." Symmetric with Claude Code's ``filterOrphanedThinkingOnlyMessages`` (src/utils/messages.ts). We drop the whole turn from the API copy rather than fabricating stub text — the message log (UI transcript) keeps the reasoning block; only the wire copy is cleaned. rr?Frrr>thinkingredacted_thinkingrFrNrSrRTrT)rrr rrBrX)rrblockbtyperFrRrds r_is_thinking_only_assistantz#AIAgent._is_thinking_only_assistants"#t$$ ;(F(F5 77<  5'')$$ gs # # }} u   & &    !%..%$uu &))===F?? 99VR00D!$,,%%$uuuu  W]]5GG/00HCGGK4H4H i % % )//*;*; 4 WW( ) ) b$   B 4urc$ddlm}||S)uUForwarder — see ``agent.agent_runtime_helpers.drop_thinking_only_and_merge_users``.r)"drop_thinking_only_and_merge_users)rOrl)rrls r#_drop_thinking_only_and_merge_usersz+AIAgent._drop_thinking_only_and_merge_userss( SRRRRR11(;;;rrcDddlm}|}td|D}||kr|Sd}g}|D]H}|jjdkr!||kr|||dz }3||It d||z ||S)ajTruncate excess delegate_task calls to max_concurrent_children. The delegate_tool caps the task list inside a single call, but the model can emit multiple separate delegate_task tool_calls in one turn. This truncates the excess, preserving all non-delegate calls. Returns the original list if no truncation was needed. r)_get_max_concurrent_childrenc3:K|]}|jjdkdVdS) delegate_taskrN)rMr rNs rrz3AIAgent._cap_delegate_task_calls..s1[[2r{7G?7Z7ZQ7Z7Z7Z7Z[[rrqrzUTruncated %d excess delegate_task call(s) to enforce max_concurrent_children=%d limit)tools.delegate_toolrorrMr rYrr$)rro max_childrendelegate_countkept_delegates truncatedrOs r_cap_delegate_task_callsz AIAgent._cap_delegate_task_callss EDDDDD3355 [[[[[[[ \ ) )   % %B{?22!L00$$R((("a'N  $$$$ / \ )<   rcLt}g}|D]n}|jj|jjf}||vr+||||It d|jjot|t|kr|n|S)zRemove duplicate (tool_name, arguments) pairs within a single turn. Only the first occurrence of each unique pair is kept. Returns the original list if no duplicates were found. zRemoved duplicate tool call: %s) setrMr rLaddrYrr$r)rseenuniquerOrs r_deduplicate_tool_callszAIAgent._deduplicate_tool_callssEE T TB;#R[%:;C$  b!!!!@"+BRSSSSVs:66vvJFrc&ddlm}|||S)uCForwarder — see ``agent.agent_runtime_helpers.repair_tool_call``.r)repair_tool_call)rOr)rrQrs r_repair_tool_callzAIAgent._repair_tool_calls'@@@@@@i000rc(ddlm}||dS)uCForwarder — see ``agent.system_prompt.invalidate_system_prompt``.r)invalidate_system_promptN)rir)rrs r_invalidate_system_promptz!AIAgent._invalidate_system_prompt s+@@@@@@  &&&&&rfn_namerLindexc$t|||S)uGenerate a deterministic call_id from tool call content. Used as a fallback when the API doesn't provide a call_id. Deterministic IDs prevent cache invalidation — random UUIDs would make every API call's prefix unique, breaking OpenAI's prompt cache. )_codex_deterministic_call_id)rrLrs rrQzAIAgent._deterministic_call_id s,GYFFFrraw_idc t|S)z8Split a stored tool id into (call_id, response_item_id).)_codex_split_responses_tool_id)rs rrRz AIAgent._split_responses_tool_id s.f555rrZresponse_item_idc"t||S)zCBuild a valid Responses `function_call.id` (must start with `fc_`).)(_codex_derive_responses_function_call_id)rrZrs rrPz*AIAgent._derive_responses_function_call_id s 8AQRRRrcJtj}|jd|jS)N:)r!current_threadr ident)rthreads r_thread_identityzAIAgent._thread_identity s()+++.. ...rct|dd}t|dd}t|dd}d|d|d|d|S) Nrr(rrzthread=z provider=z base_url=z model=)rEr)rrrrs r_client_log_contextzAIAgent._client_log_context! s}4Y774Y77gy11 1d++-- 1 1 1 1  1 1). 1 1 rc`t|dd}|tj}||_|S)N _client_lock)rEr!RLockr)rlocks r_openai_client_lockzAIAgent._openai_client_lock* s2t^T22 <?$$D $D  rr6cddlm}t||rdSt|dd}|-t |r |rdSnt |rdSt|dd}|t t|ddSdS)aCheck if an OpenAI client is closed. Handles both property and method forms of is_closed: - httpx.Client.is_closed is a bool property - openai.OpenAI.is_closed is a method returning bool Prior bug: getattr(client, "is_closed", False) returned the bound method, which is always truthy, causing unnecessary client recreation on every call. rMockF is_closedNT_client) unittest.mockrrrEcallablere)r6ris_closed_attr http_clients r_is_openai_client_closedz AIAgent._is_openai_client_closed1 s '&&&&& fd # # 5 d;;  %'' !>## 4 n%% tfi66  " [%@@AA Aurc ddl}ddl}|j|jdfg}t |drg||j|jdf||j|jdf||j|j dfn2t |dr"||j|j dft|}| | || S#t$rYdSwxYw) Nrr TCP_KEEPIDLEr TCP_KEEPALIVE)socket_options) transportproxy)httpxsocket SOL_SOCKET SO_KEEPALIVEr8rY IPPROTO_TCPr TCP_KEEPINTVL TCP_KEEPCNTrrClient HTTPTransportr)r_httpx_socket _sock_opts_proxys r_build_keepalive_http_clientz$AIAgent._build_keepalive_http_clientO sF  " " " " $ $ $ $"-w/CQGHJw// T!!7#68Lb"QRRR!!7#68Mr"RSSS!!7#68KQ"OPPPP/22 T!!7#68Mr"RSSS -X66F== ..j.II!    44 sC:C== D  D  client_kwargsr9c,ddlm}|||||S)uGForwarder — see ``agent.agent_runtime_helpers.create_openai_client``.r)create_openai_clientr8)rOr)rrrxr9rs r_create_openai_clientzAIAgent._create_openai_clienth s.DDDDDD##D-vVVVVrc$ddlm}||S)uJForwarder — see ``agent.agent_runtime_helpers.force_close_tcp_sockets``.r)force_close_tcp_sockets)rOr)r6rs r_force_close_tcp_socketsz AIAgent._force_close_tcp_socketsm s( HGGGGG&&v...rcR|dS||} |td||||dS#t $r;}td||||Yd}~dSd}~wwxYw)Nz F44V<<   LLNNN KKN((**          LLH((**           sAA!! B&+0B!!B&c|5t|dd} ||j|d}nR#t$rE}t d|||Yd}~ddddSd}~wwxYw||_dddn #1swxYwY| |d|ddS)Nr6Tr8z7Failed to rebuild shared OpenAI client (%s) %s error=%sFzreplace:) rrEr_client_kwargsrrr$rr6r=)rrx old_client new_clientrs r_replace_primary_openai_clientz&AIAgent._replace_primary_openai_client sU  % % ' ' % % x66J !778KTZcg7hh    M,,..  uuu % % % % % % % % %DK % % % % % % % % % % % % % % % !!*5H5H5HQU!VVVts:B+AB+ B/B?B+B B++B/2B/c|5t|dd}|#||s|cdddSdddn #1swxYwYtd|||d|std|5|jcdddS#1swxYwYdS)Nr6zCDetected closed shared OpenAI client; recreating before use (%s) %szrecreate_closed:rxz'Failed to recreate closed OpenAI client) rrErrr$rr RuntimeErrorr6)rrxr6s r_ensure_primary_openai_clientz%AIAgent._ensure_primary_openai_client s  % % ' '  T8T22F!$*G*G*O*O!                         Q   $ $ & &   22:UV:U:U2VV JHII I  % % ' '  ;                  s#*AAA C!!C%(C%c$ddlm}||S)uKForwarder — see ``agent.agent_runtime_helpers.cleanup_dead_connections``.r)cleanup_dead_connections)rOr)rrs r_cleanup_dead_connectionsz!AIAgent._cleanup_dead_connections s%HHHHHH''---rct|tsdSg}|d}t|tr|||d}t|tr||dt dt ffd tfd|DS)zHReturn True when the outbound request still contains native image parts.Frinputrrc"t|trH|d}|dvrdStfd|DSt|t rtfd|DSdS)Nr>rHrITc3.K|]}|VdSrrr_contains_images rrzPAIAgent._api_kwargs_have_image_parts.._contains_image.. s-FF!??1--FFFFFFrc3.K|]}|VdSrrrs rrzPAIAgent._api_kwargs_have_image_parts.._contains_image.. s-==!??1--======rF)rrr rvaluesrX)rptypers rrz=AIAgent._api_kwargs_have_image_parts.._contains_image s%&& G &))8884FFFFu||~~FFFFFF%&& >====u======5rc3.K|]}|VdSrr)ritemrs rrz7AIAgent._api_kwargs_have_image_parts.. s-@@T??4((@@@@@@r)rrr rXextendrrer)r candidatesrresponse_inputrs @r_api_kwargs_have_image_partsz$AIAgent._api_kwargs_have_image_parts s*d++ 5 >>*-- h % % (   h ' ' '$00 nd + + .   n - - - 3 4      @@@@Z@@@@@@r is_visionc(ddlm}|d|S)Nr)copilot_request_headersT) is_agent_turnr)hermes_cli.copilot_authr)rrrs r_copilot_headers_for_requestz$AIAgent._copilot_headers_for_request s*CCCCCC&&TYOOOOr)rcddlm}||}t||r|S|5t |j}dddn #1swxYwYd|d<tt| dddr0| |pir| d |d <| ||d S) Nrrr max_retriesrrrT)rdefault_headersFr8) rrrrrrrr~rr rrr)rrxrrprimary_clientrequest_kwargss r_create_request_openai_clientz%AIAgent._create_request_openai_client sH&&&&&&;;6;JJ nd + + "! !  % % ' ' 7 7!$"566N 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7)*}% !#n&8&8R&H&H"I"IKb c c b11*2BCC b150Q0Q\`0Q0a0aN, -)).PU)VVVsA$$A(+A(c6|||ddS)NFr8)r=)rr6rxs r_close_request_openai_clientz$AIAgent._close_request_openai_client s# !!&!FFFFFron_first_deltac*ddlm}|||||S)u;Forwarder — see ``agent.codex_runtime.run_codex_stream``.r)run_codex_stream)agent.codex_runtimer)rrr6rrs r_run_codex_streamzAIAgent._run_codex_stream s+888888j&.IIIrc(ddlm}||||S)uKForwarder — see ``agent.codex_runtime.run_codex_create_stream_fallback``.r) run_codex_create_stream_fallback)rr)rrr6rs r!_run_codex_create_stream_fallbackz)AIAgent._run_codex_create_stream_fallback s)HHHHHH//j&IIIrTc|jdks |jdvrdS |jdkrddlm}|d}nddlm}|d}n9#t $r,}t d |j|Yd}~dSd}~wwxYwt| d pd  }t|j pd  }|r*|r(||kr"t d |jdS |jdkrddlm}|| }nddlm}|| }n9#t $r,}t d|j|Yd}~dSd}~wwxYw| d } | d} t| tr| sdSt| tr| sdS| |_ | d|_|j |jd <|j|jd<||jdsdSdS)Ncodex_responses> xai-oauth openai-codexFrr)!resolve_codex_runtime_credentials)refresh_if_expiring)%resolve_xai_oauth_runtime_credentialsz%s singleton read failed: %srrz%s singleton tokens differ from the active api_key; skipping singleton force-refresh to avoid silent account swap. Reactive credential rotation should go through the pool.) force_refreshz %s credential refresh failed: %srr_credential_refreshrT)rrhermes_cli.authrrrrrrr rBrrrrrr) rr[r singleton_nowrr singleton_key active_keycredsrrs r%_try_refresh_codex_client_credentialsz-AIAgent._try_refresh_codex_client_credentials s =- - -Fc1c1c5 }..MMMMMM A A(-!!! RQQQQQ E E(-!!!     LL7 L L L55555 M--i88>B??EEGG +,,2244  Z MZ,G,G LLK     5 }..MMMMMM99NNNQQQQQQ==ERRR    LL;T]C P P P55555 ))I&&99Z(('3'' w}} 5(C(( 0@0@ 5}}  ((//44 )-I&*.-J'22T]:_:_:_2`` 5ts/0A A?!A::A? 0D>> E4!E//E4c |jdks |jdkrdS ddlm}|t dt t jddtt jd d | }n3#t$r&}t d |Yd}~dSd}~wwxYw| d }| d}t|tr|sdSt|tr|sdS||_|d|_|j|jd <|j|jd<|jdd|dsdSdS)NrrFr) resolve_nous_runtime_credentials<HERMES_NOUS_MIN_KEY_TTL_SECONDS1800HERMES_NOUS_TIMEOUT_SECONDS15)min_key_ttl_secondstimeout_seconds force_mintz"Nous credential refresh failed: %srrrrnous_credential_refreshrT)rrrrrFrrrrrrrr rrrBrrrrr@r)rr[rrrrrs r$_try_refresh_nous_client_credentialsz,AIAgent._try_refresh_nous_client_credentialsB s =. . .$-62I2I5  H H H H H H44$'C :[]c0d0d,e,e$f$f %bi0Mt&T&T U U EE     LL=s C C C55555 ))I&&99Z(('3'' w}} 5(C(( 0@0@ 5}}  ((//44 )-I&*.-J'  1488822:S2TT 5tsA"A== B-B((B-c0|jdkrdS ddlm}|\}}n3#t$r&}td|Yd}~dSd}~wwxYwt |tr|sdS|}||_ |j |j d<|j |j d<| t|j pd | d sdStd |d S)a]Refresh Copilot credentials and rebuild the shared OpenAI client. Copilot tokens may remain the same string across refreshes (`gh auth token` returns a stable OAuth token in many setups). We still rebuild the client on 401 so retries recover from stale auth/client state without requiring a session restart. rFr)resolve_copilot_tokenz%Copilot credential refresh failed: %sNrrrcopilot_credential_refreshrz%Copilot credentials refreshed from %sT)rrrrrrrrrBrrr"_apply_client_headers_for_base_urlrr)rr new_token token_sourcers r'_try_refresh_copilot_client_credentialsz/AIAgent._try_refresh_copilot_client_credentialse s= =I % %5  E E E E E E&;&;&=&= #I||    LL@# F F F55555 )S)) 1B1B 5OO%%   )-I&*.-J' //DM4GR0H0HIII22:V2WW 5 ;\JJJts# AAAc:|jdkst|dsdS|jdkrdSt|ddpd}d|vrdS dd lm}m}|}n3#t$r&}t d |Yd}~dSd}~wwxYwt|tr| sdS| }||j krdS |jn#t$rYnwxYw ||t|ddt!|j|j |_n3#t$r&}td |Yd}~dSd}~wwxYw||_ dd lm}|jdkr ||nd|_dS)Nr_anthropic_api_keyF anthropic_anthropic_base_urlrz azure.comr)resolve_anthropic_tokenbuild_anthropic_clientz'Anthropic credential refresh failed: %stimeoutz?Failed to rebuild Anthropic client after credential refresh: %s)_is_oauth_tokenT)rr8rrEagent.anthropic_adapterrrrrrrrrBr_anthropic_clientr<rrr$r _is_anthropic_oauth)r_baserrrrr s r)_try_refresh_anthropic_client_credentialsz1AIAgent._try_refresh_anthropic_client_credentials s+ =0 0 0FZ8[8[ 05 =K ' '53R88>B %  5  _ _ _ _ _ _ _ _//11II    LLBC H H H55555 )S)) 1B1B 5OO%% / / /5   " ( ( * * * *    D  %;%;3T::4T]DJOO&&&D " "     NN\^a b b b55555 #, <;;;;;AER]A]A]??9#=#=#=ch tsBA B"BBC22 C?>C?:D>> E.E))E.cddlm}m}m}t |dr||jd<dSt |drt ||jd<dSt |dr|||jd<dSt |drt|jd<dSt |drdd lm }||jd<dSt |d rd d i|jd<dSt |d rt|jd<dSt |dr4ddlm }||j dd|jd<dSd} ddl m}||j} | r| jrt | j}n#t"$rYnwxYw|r ||jd<dS|jdddS)Nr)_AI_GATEWAY_HEADERSbuild_nvidia_nim_headersbuild_or_headersrrai-gateway.vercel.shzintegrate.api.nvidia.comzapi.routermint.comr)copilot_default_headers api.kimi.comrzclaude-code/0.1.0portal.qwen.aiz chatgpt.com)_codex_cloudflare_headersrr)get_provider_profile)agent.auxiliary_clientr'r(r)r~rrrrDr+rr.r  providersr/rrrr@) rrr'r(r)r+r. _ph_headers_gpf2_ph2s rrz*AIAgent._apply_client_headers_for_base_url s          !? ; ;" A5E5E5G5GD  1 2 2 2 "8-C D D A59:M5N5ND  1 2 2 2 "8-G H H A5M5Mh5W5WD  1 2 2 2 "8-A B B A5H5J5JD  1 2 2 2 "8-D E E A A A A A A A5L5L5N5ND  1 2 2 2 "8^ < < A6BDW5XD  1 2 2 2 "8-= > > A5I5K5KD  1 2 2 2 "8] ; ; A H H H H H H5N5N#'' 26666D  1 2 2 2 K CCCCCCuT]++=D0="&t';"<"|S4Q4Qc ++C000Wc )-I&*.-J' // >>> ++3H+IIIIIs A:: BB)classified_reasonrthas_retried_429r=c.ddlm}||||||S)uOForwarder — see ``agent.agent_runtime_helpers.recover_with_credential_pool``.r)recover_with_credential_pool)rr>r=rt)rOr@)rrr>r=rtr@s r_recover_with_credential_poolz%AIAgent._recover_with_credential_pool sJ MLLLLL++Dk[jP`mnnn nrc|j}|dS|jdks1tt|dddrdS|S)zEWhether a rate-limit retry should wait for same-provider credentials.NFrrrr)_credential_poolrrrErr)rrs r'_credential_pool_may_recover_rate_limitz/AIAgent._credential_pool_may_recover_rate_limit sf$ <5 M0 0 074R0011<<=NOO 1 5!!###rcn|jdkr||jjjdi|S)Nrr)rr%r"rcreate)rrs r_anthropic_messages_createz"AIAgent._anthropic_messages_create sA =0 0 0  : : < < <5t%.5CC CCCrcNtt|dd}t|dddkr+ddlm}t|dd pd }|||_dSdd lm}||jt|d dt|j|j | |_dS) u)Rebuild the Anthropic client after an interrupt or stale call. Handles both direct Anthropic and Bedrock-hosted Anthropic models correctly — rebuilding with the Bedrock SDK when provider is bedrock, rather than always falling back to build_anthropic_client() which requires a direct Anthropic API key. Honors ``self._oauth_1m_beta_disabled`` (set by the reactive recovery path when an OAuth subscription rejects the 1M-context beta) so the rebuilt client carries the reduced beta set. _oauth_1m_beta_disabledFrNbedrockr)build_anthropic_bedrock_client_bedrock_regionz us-east-1)rr)rdrop_context_1m_beta) rerEr!rKr"rrrrr)r_drop_1mrKregionrs r_rebuild_anthropic_clientz!AIAgent._rebuild_anthropic_client$ s&?GGHH 4T * *i 7 7 N N N N N NT#4kBBQkF%C%CF%K%KD " " " F F F F F F%;%;'3T::4T]DJOO%- &&&D " " "rc&ddlm}|||S)uKForwarder — see ``agent.chat_completion_helpers.interruptible_api_call``.r)interruptible_api_call)rrR)rrrRs r_interruptible_api_callzAIAgent._interruptible_api_call> s'HHHHHH%%dJ777rcDt|dd}||}|rxt|dd}|||}|rNd|j|jfD}|D]} ||#t $rYwxYw||t|dd}|d|}|rNd|j|jfD}|D]} ||#t $rYwxYw||d|_dS)zDReset tracking for text delivered during the current model response._stream_think_scrubberN_stream_context_scrubbercg|]}||Srrrcbs rrPz;AIAgent._reset_stream_delivery_tracking..W s t t tegesesesesrcg|]}||SrrrXs rrPz;AIAgent._reset_stream_delivery_tracking..e spppBacaoRaoaoaorr)rEflushfeedr_stream_callbackr_record_streamed_assistant_text _current_streamed_assistant_text)rthink_scrubber think_tail ctx_scrubber callbacksrYscrubbertails r_reset_stream_delivery_trackingz'AIAgent._reset_stream_delivery_trackingE s!'?FF  %'--//J E 't-GNN +!-!2!2:!>!>JE t tt/I4K`.a t t tI'!!!BzNNNN(!!! D!88DDD4!;TBB  >>##D ;pp4+EtG\*]ppp #B4$44T:::02---s$1 A== B  B ( C44 DDcnt|tr|rt|dd|z|_dSdSdS)zCAccumulate visible assistant text emitted through stream callbacks.r_rN)rrrEr_)rrFs rr^z'AIAgent._record_streamed_assistant_textn sR dC  T @"EEL  1 1 1    rct|tsdStjdd|S)Nrz\s+ry)rrrrrB)rFs r_normalize_interim_visible_textz'AIAgent._normalize_interim_visible_textu s9$$$ 2vfc4((..000rc |||pd}|sdS||t|ddpd}t|o||kS)NrFr_)rirrEre)rrvisible_contentstreameds r_interim_content_was_streamedz%AIAgent._interim_content_was_streamed{ s>>  $ $W] 3 3   577  $ $WT3UWY%Z%Z%`^` a a  H~~=(o"==r assistant_msgct|dd}|t|tsdS|d}||pd}|r|dkrdS||} |||dS#t$r t dd YdSwxYw) zESurface a real mid-turn assistant commentary message to the UI layer.rNrrz(empty))already_streamedz interim_assistant_callback errorTr ) rErrr rrBrmrrr)rrnrYrvisiblerps r_emit_interim_assistant_messagez'AIAgent._emit_interim_assistant_message s T7 > > :Z t<<: F##I..**7=b99??AA 'Y.. F==gFF L Bw)9 : : : : : : L L L LL;dL K K K K K K Ls B&CCct|ddr%|r#|rd|_d|z}d}nd}t|trt|dd}|||pd}n||pd}t|dd}|||}nt|}|s&t|d ds|d }|sdSd |j |j fD}d}|D] } ||d}#t$rYwxYw|r| |dSdS) z;Fire all registered stream delta callbacks (display + TTS)._stream_needs_breakF TrUNrrVr_rJcg|]}||SrrrXs rrPz.AIAgent._fire_stream_delta.. shhhBY[YgRYgYgYgr) rErBrtrrr\rr,lstriprr]rr^)rrFprepended_breakr`rdrc deliveredrYs r_fire_stream_deltazAIAgent._fire_stream_delta s 4. 6 6 $4 $DJJLL $',D $D=D"OO#O dC  )%T+CTJJN)%**4:266// ;;t%?FFH#}}T**(--" )78",, ){{4((  Fhh4#=t?T"Uhhh    B 4       7  0 0 6 6 6 6 6 7 7s D!! D.-D.cV|j}| ||dS#t$rYdSwxYwdS)z&Fire reasoning callback if registered.N)rr)rrFrYs r_fire_reasoning_deltazAIAgent._fire_reasoning_delta sN  $ > 4     >  &&cV|j}| ||dS#t$rYdSwxYwdS)aNotify display layer that the model is generating tool call arguments. Fires once per tool name when the streaming response begins producing tool_call / tool_use tokens. Gives the TUI a chance to show a spinner or status line so the user isn't staring at a frozen screen while a large tool payload (e.g. a 45 KB write_file) is being generated. N)rr)rrQrYs r_fire_tool_gen_startedzAIAgent._fire_tool_gen_started sP # > 9      >r}c:|jdupt|ddduS)z4Return True if any streaming consumer is registered.Nr])rrErs rr_zAIAgent._has_stream_consumers s/  &d 2 Ct/66dB rrc*ddlm}||||S)uUForwarder — see ``agent.chat_completion_helpers.interruptible_streaming_api_call``.r) interruptible_streaming_api_callr)rr)rrrrs r!_interruptible_streaming_api_callz)AIAgent._interruptible_streaming_api_call s0 SRRRRR//jQ_````rzFailoverReason | Nonec&ddlm}|||S)uJForwarder — see ``agent.chat_completion_helpers.try_activate_fallback``.r)try_activate_fallback)rr)rrxrs r_try_activate_fallbackzAIAgent._try_activate_fallback s'GGGGGG$$T6222rc$ddlm}||S)uJForwarder — see ``agent.agent_runtime_helpers.restore_primary_runtime``.r)restore_primary_runtime)rOr)rrs r_restore_primary_runtimez AIAgent._restore_primary_runtime s%GGGGGG&&t,,,r api_error retry_countrc,ddlm}|||||S)uPForwarder — see ``agent.agent_runtime_helpers.try_recover_primary_transport``.r)try_recover_primary_transport)rr)rOr)rrrrrs r_try_recover_primary_transportz&AIAgent._try_recover_primary_transport s2 NMMMMM,,T9+cnoooorct|tsdS|D]1}t|tr|ddvrdS2dS)NFr>rHrIT)rrXrr )rparts r_content_has_image_partsz AIAgent._content_has_image_parts s^'4(( 5  D$%% $((6*:*:>Z*Z*ZtturrHct|pdd\}}}d}|drZ|tddddd}|dr|}d d d d d d |d }tjd|d} |5| tj |dddn #1swxYwYn:#t$r- tj|jn#t $rYnwxYwwxYwt#|j}t||fS)Nr, image/jpegdata:;rrzimage/z.pngz.gifz.webpz.jpg)z image/pngz image/gifz image/webprz image/jpganthropic_image_F)rsuffixdelete)r partitionrrrrBr tempfileNamedTemporaryFilerKbase64 b64decoderrunlinkr rUr ) rHheader_rMmime mime_partrtmprs r _materialize_data_url_for_visionz(AIAgent._materialize_data_url_for_vision sio2..88==4   W % % !s7||}}-33C;;A>DDFFI##H-- ! !    #dF   )1CF[`aaa  2 2 &*400111 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2     #(####      CH~~4yy$sTD(D8 DDD D D ED54E5 E?EEErcDtjt|pdd}|j|}|r|Sddd|d}d}t|pd}d}|dr||\}}d} d d l m } tj | || } t| trtj| ni} | d pd} n#t"$r} d | } Yd} ~ nd} ~ wwxYw|r:|r& |nS#t($rYnGwxYwnB#|r:|r' |w#t($rYwwxYwwwxYw| sd} d|d| d}|r-t|pdds |d|dz }||j|<|S)Nrrr?z tool result)r?rr1zDescribe everything visible in this image in thorough detail. Include any text, code, UI, data, objects, people, layout, colors, and any other notable visual information.rr)vision_analyze_tool)rH user_promptanalysiszImage analysis failed: zImage analysis failed.z[The z- attached an image. Here's what it contains: ]z@ [If you need a closer look, use vision_analyze with image_url: )hashlibsha256rencode hexdigest_anthropic_image_fallback_cacher rrtools.vision_toolsrasynciorunrrrrBrrrrU)rrHr cache_keycached role_labelanalysis_prompt vision_source cleanup_path descriptionr result_jsonrr%notes r&_describe_image_for_anthropic_fallbackz.AIAgent._describe_image_for_anthropic_fallback* sN3yB#7#7#>#>w#G#GHHRRTT 599)DD  M%!   #dF     8  IO,, '+  # #G , , _*.*O*OP]*^*^ 'M<   > > > > > >!+##mYYYK1;;0L0LTTZ ,,,RTF!::j117R>>@@KK 8 8 87A77KKKKKK 8  3 3 5 5  ''))))D  3 3 5 5  ''))))D    32K_z__Q\___  Y_"!5!5!@!@!I!I  dTaddd D;?,Y7 sgA9D?>F? E EFEF2F FFG0GG GGGGc ddlm}t|ddpd}t|ddpd}|r|sdS|||}|dSt |jS#t $rYdSwxYw)aReturn True if the active provider+model reports native vision. Used to decide whether to strip image content parts from API-bound messages (for non-vision models) or let the provider adapter handle them natively (for vision-capable models). r)get_model_capabilitiesrrrF)agent.models_devrrErBresupports_visionr)rrrrcapss r_model_supports_visionzAIAgent._model_supports_vision] s  ? ? ? ? ? ?j"55;BBDDHT7B//52<<>>E 5 u))(E::D|u,-- -   55 sAA<A<(A<< B  B c||s|Sg}g}|D]}t|tr<|r'||Tt|t sj|d}|dvrOt|ddpd}|r|||dvr|di}t|t r|ddnt|pd} | r*||| |n|dkt|ddpd}|r||d d |D} d d |D} | r | r| d | S| r| S| r| Sd S)Nr>rF input_textrFr>rHrIrHrz:[An image was attached but no image source was available.]ruc3K|]}||V dSrr)rrs rrz8AIAgent._preprocess_anthropic_content.. s'BBdTBTBBBBBBrrJc3K|]}||V dSrr)rrFs rrz8AIAgent._preprocess_anthropic_content.. s'??D$?4??????rzI[A multimodal message was converted to text for Anthropic compatibility.]) rrrrBrYrr rrZ) rrr text_parts image_notesrrrF image_datarHrrs r_preprocess_anthropic_contentz%AIAgent._preprocess_anthropic_contentq sy,,W55 N " !#  ( (D$$$ ::<<4%%djjll333dD)) HHV$$E...488FB//5266<<>>,%%d+++444!XXk266 9CJPT9U9UpJNN5"555[^_i_omo[p[p e&&t'R'RS\^b'c'cdddd&&'cdddtxx++1r2288::D (!!$'''BBkBBBBBHHJJ??J?????EEGG  +f +**&** *  M  MZZrc|p|j}t|dd}| i}||_||}|ddlm}||}|||<|S)zReturn the cached transport for the given (or current) api_mode. Lazy-initializes on first call per api_mode. Returns None if no transport is registered for the mode. _transport_cacheNr) get_transport)rrErr agent.transportsr)rrmodecacher%rs r_get_transportzAIAgent._get_transport sw (4=0$77 =E$)D ! IIdOO 9 6 6 6 6 6 6 d##AE$Kr api_messagesc jtfd|Ds|Sr|Stj|}|D]g}t |t s|dt|ddpd|d<h|S)Nc3K|]A}t|to'|dVBdSrNrrrr rrrs rrz>AIAgent._prepare_anthropic_messages_for_api.. `   sD ! ! Wd&C&CCGGIDVDV&W&W      rrrr1 rrrcdeepcopyrrrr rrr transformedrs` r#_prepare_anthropic_messages_for_apiz+AIAgent._prepare_anthropic_messages_for_api s    #         & & ( (  mL11   Cc4(( !?? ""CGGFF++5v66C NNrc jtfd|Ds|Sr|Stj|}|D]g}t |t s|dt|ddpd|d<h|S)aStrip native image parts when the active model lacks vision. Runs on the chat.completions / codex_responses paths. Vision-capable models pass through unchanged (provider and any downstream translator handle the image parts natively). Non-vision models get each image replaced by a cached vision_analyze text description so the turn doesn't fail with "model does not support image input". c3K|]A}t|to'|dVBdSrrrs rrzAAIAgent._prepare_messages_for_non_vision_model.. rrrrr1rrs` r&_prepare_messages_for_non_vision_modelz.AIAgent._prepare_messages_for_non_vision_model s    #         & & ( (  mL11   Cc4((  "?? ""CGGFF++5v66C NNrcVt|s|S|dpg}||s|S|r|St |}|dkrt jd|dStd||j |j |S)aReturn the tool message content that is safe for the active model. Multimodal tool results normally unwrap to OpenAI-style content parts so vision-capable models can inspect screenshots. Text-only providers must not receive those image parts, because a rejected tool result becomes part of the canonical history and can make the next user turn fail before the agent has a chance to recover. r computer_usezcomputer_use returned screenshot/image content, but the active model/provider does not support image input. Switch to a vision-capable model for desktop computer use, or use browser tools for browser tasks.)r text_summaryzWTool %s returned image content for non-vision model %s/%s; falling back to text summary) rwr rrrxrdumpsrr$rr)rrQrrrs r%_tool_result_content_for_active_modelz-AIAgent._tool_result_content_for_active_model s*&11 M**Y''-2,,W55 N  & & ( ( N*622  & &:/ !(   +  M J    rc$ddlm}||S)uXForwarder — see ``agent.conversation_compression.try_shrink_image_parts_in_messages``.r)"try_shrink_image_parts_in_messages)rr)rrrs r#_try_shrink_image_parts_in_messagesz+AIAgent._try_shrink_image_parts_in_messages s%UUUUUU11,???rct|ddpddvrdSt|ddpd}d|vpd|vpd|vpd |vp d |vpd |vpd |vS) aTrue when using an anthropic-compatible endpoint that preserves dots in model names. Alibaba/DashScope keeps dots (e.g. qwen3.5-plus). MiniMax keeps dots (e.g. MiniMax-M2.7). Xiaomi MiMo keeps dots (e.g. mimo-v2.5, mimo-v2.5-pro). OpenCode Go/Zen keeps dots for non-Claude models (e.g. minimax-m2.5-free). ZAI/Zhipu keeps dots (e.g. glm-4.7, glm-5.1). AWS Bedrock uses dotted inference-profile IDs (e.g. ``global.anthropic.claude-opus-4-7``, ``us.anthropic.claude-sonnet-4-5-20250929-v1:0``) and rejects the hyphenated form with ``HTTP 400 The provided model identifier is invalid``. Regression for #11976; mirrors the opencode-go fix for #5211 (commit f77be22c), which extended this same allowlist.rr> minimax-cn opencode-go opencode-zenrxiaomialibabarJminimaxTr dashscopealiyuncsrzopencode.ai/zen/z bigmodel.cnxiaomimimo.comzbedrock-runtime.)rEr)rbases r_anthropic_preserve_dotsz AIAgent._anthropic_preserve_dots s D*b ) ) /R 6 6 8 8=   4j"--3::<< 4  *T! *D  *"T) *$  *  4'  *"T) rc,t|jdS)z2Return True when the base URL targets Qwen Portal.r-rrs r_is_qwen_portalzAIAgent._is_qwen_portal: s$T%9;KLLLrctj|}|s|S|D]}t|ts|d}t|t r d|dg|d<Lt|t rfg}|D]Z}t|t r|d|d0t|tr||[|r||d<|D]}t|tro|ddkrV|d}t|t r*|r(t|dtr ddi|dd <n|S) NrrFrrFrrrr ephemeral cache_control)rcrrrr rrXrY)rrpreparedrrnormalized_partsrs r_qwen_prepare_chat_messagesz#AIAgent._qwen_prepare_chat_messages> s=.. O 6 6Cc4(( ggi((G'3'' 6+17"C"C!DIGT** 6$& #66D!$,,6(//0N0NOOOO#D$//6(//555#6%5C N  C#t$$ H)D)D''),,gt,,IIZPR UY=Z=ZI4:K3HGBK0rc|sdS|D]}t|ts|d}t|tr d|dg|d<Lt|trfg}|D]Z}t|tr|d|d0t|tr||[|r||d<|D]}t|trp|ddkrW|d}t|tr*|r(t|dtr dd i|dd <dSdS) u<In-place variant — mutates an already-copied message list.NrrFrrrrrrr)rrr rrXrY)rrrrrrs r#_qwen_prepare_chat_messages_inplacez+AIAgent._qwen_prepare_chat_messages_inplace_ s  F 6 6Cc4(( ggi((G'3'' 6+17"C"C!DIGT** 6#% #66D!$,,6(//0N0NOOOO#D$//6(//555#6%5C N  C#t$$ H)D)D''),,gt,,IIZPR UY=Z=ZI4:K3HGBK0   rc&ddlm}|||S)uEForwarder — see ``agent.chat_completion_helpers.build_api_kwargs``.r)build_api_kwargs)rr)rrrs r_build_api_kwargszAIAgent._build_api_kwargs{ s'BBBBBBl333rcvt|jdrdSt|jdrdSt|jdst|jdr5 ddlm}t ||jS#t $rYdSwxYw|jpd  d kr-| }td |DSd |jvrdSd |jvrdS|jpd d}tfd|DS)a3Return True when reasoning extra_body is safe to send for this route/model. OpenRouter forwards unknown extra_body fields to upstream providers. Some providers/routes reject `reasoning` with 400s, so gate it to known reasoning-capable model families and direct Nous Portal. znousresearch.comTr*zmodels.github.airrgithub_model_reasoning_effortsFrr=c3&K|] }|o|dkV dS)rNr)ropts rrz9AIAgent._supports_reasoning_extra_body.. s+<<s+se|<<<<<. s1SS5##F++SSSSSSr) r~rrDrrerrrrBr"_lmstudio_reasoning_options_cachedr)rroptsreasoning_model_prefixesrs @r_supports_reasoning_extra_bodyz&AIAgent._supports_reasoning_extra_body s !!57I J J 4 !57M N N 4 !$"68J K K $T%9;RSS  LLLLLL::4:FFGGG   uu  M R & & ( ( . . 0 0J > >::<> B  B c ddl}t|dd}| ix}|_|j|jf}||}|$|\}}|s||z dkr|S ddlm}||j|jt|dd}n#t$rg}YnwxYw||f||<|S)aProbe LM Studio's published reasoning ``allowed_options`` once per (model, base_url). The list (e.g. ``["off","on"]`` or ``["off","minimal","low"]``) is needed both for the supports-reasoning gate and for clamping the emitted ``reasoning_effort`` so toggle-style models don't 400 on ``high``. Cache is keyed on (model, base_url) so ``/model`` swaps and base-URL changes don't reuse a stale list. Non-empty results are cached permanently (model capabilities don't change). Empty results (transient probe failure OR genuinely non-reasoning model) are cached with a 60-second TTL to avoid an HTTP round-trip on every turn while still retrying reasonably soon. rN_lm_reasoning_opts_cacher) lmstudio_model_reasoning_optionsrr) rrErrrr  monotonicrDrr)r_timerrrr tsrs rr z*AIAgent._lmstudio_reasoning_options_cached s  8$?? =46 6ED1z4=)3  HD" ))B."44   J J J J J J33 DM74B+G+GDD   DDD EOO--.c  s+,B B'&B'cTddlm}||j|S)aResolve a safe top-level ``reasoning_effort`` for LM Studio. The iteration-limit summary path calls ``chat.completions.create()`` directly, bypassing the transport. Share the helper so the two paths can't drift on effort resolution and clamping. r)resolve_lmstudio_effort)agent.lmstudio_reasoningrrr )rrs r*_resolve_lmstudio_summary_reasoning_effortz2AIAgent._resolve_lmstudio_summary_reasoning_effort sA EDDDDD&&  !  3 3 5 5   rc ddlm}n#t$rYdSwxYw||j}|sdS|jrt |jt rk|jddurdSt|jdd }nd}|dkrd |vrd }n ||vr|d krd |vrd }nd|vrd}n|d}d|iS) zDFormat reasoning payload for GitHub Models/OpenAI-compatible routes.rrNenabledFeffortmediumxhighhighminimallow) rDrrrrrrr rrBr)rrsupported_effortsrequested_efforts r#_github_models_reasoning_extra_bodyz+AIAgent._github_models_reasoning_extra_body sZ  H H H H H H H   44 ;:4:FF  4   (Z0Et%L%L ($((33u<<t"%))(H==  eggeegg   (  w & &65F+F+F%   %6 6 69,,:K1K1K#(  ...#+  #4Q#7 *++s  c(ddlm}||||S)uLForwarder — see ``agent.chat_completion_helpers.build_assistant_message``.r)build_assistant_message)rr%)rrrr%s r_build_assistant_messagez AIAgent._build_assistant_message s*IIIIII&&t-> NNNrcz|p'|p|S)a=Return True when the active provider enforces reasoning_content echo-back. DeepSeek v4 thinking and Kimi / Moonshot thinking both reject replays of assistant tool-call messages that omit ``reasoning_content`` (refs #15250, #17400). Xiaomi MiMo thinking mode has the same requirement. )_needs_deepseek_tool_reasoning_needs_kimi_tool_reasoning_needs_mimo_tool_reasoningrs r_needs_thinking_reasoning_padz%AIAgent._needs_thinking_reasoning_pads@  / / 1 1 1..00 1..00 rc|jdvp>t|jdp)t|jdpt|jdS)aReturn True when the current provider is Kimi / Moonshot thinking mode. Kimi ``/coding`` and Moonshot thinking mode both require ``reasoning_content`` on every assistant tool-call message; omitting it causes the next replay to fail with HTTP 400. Detection is host-driven, not model-name-driven: aggregators like OpenRouter that re-export Kimi/Moonshot models speak their own protocol and reject ``reasoning_content`` echoes. We only enable the kimi-reasoning replay when the request actually targets a kimi/moonshot endpoint or the dedicated kimi-coding provider. > kimi-codingkimi-coding-cnr,z moonshot.aiz moonshot.cn)rr~rrs rr)z"AIAgent._needs_kimi_tool_reasoning sU M> > C$T]NCC C$T]MBB C%T]MBB  rc|jpd}|jpd}|dkpd|vpt|jdS)aReturn True when the current provider is DeepSeek thinking mode. DeepSeek V4 thinking mode requires ``reasoning_content`` on every assistant tool-call turn; omitting it causes HTTP 400 when the message is replayed in a subsequent API request (#15250). rdeepseekzapi.deepseek.comrrrr~rrrrs rr(z&AIAgent._needs_deepseek_tool_reasoning!seM'R..00!r((**  " HU" H$T]4FGG rc|jpd}|jpd}|dkp-d|vp)t|jdpt|jdS)aMReturn True when the current provider is Xiaomi MiMo thinking mode. MiMo thinking mode requires ``reasoning_content`` on every assistant tool-call message when replaying history; omitting it causes HTTP 400. Refs: https://platform.xiaomimimo.com/docs/zh-CN/usage-guide/passing-back-reasoning_content rrmimozapi.xiaomimimo.comrr1r2s rr*z"AIAgent._needs_mimo_tool_reasoning0s|M'R..00!r((**   F F$T]4HII F%T]4DEE  r source_msgapi_msgc(ddlm}||||S)uQForwarder — see ``agent.agent_runtime_helpers.copy_reasoning_content_for_api``.r)copy_reasoning_content_for_api)rOr8)rr5r6r8s r_copy_reasoning_content_for_apiz'AIAgent._copy_reasoning_content_for_api@s)NNNNNN--dJHHHrc|d}t|ts|Sddhfd|D|d<|S)uStrip Codex Responses API fields from tool_calls for strict providers. Providers like Mistral, Fireworks, and other strict OpenAI-compatible APIs validate the Chat Completions schema and reject unknown fields (call_id, response_item_id) with 400 or 422 errors. These fields are preserved in the internal message history — this method only modifies the outgoing API copy. Creates new tool_call dicts rather than mutating in-place, so the original messages list retains call_id/response_item_id for Codex Responses API compatibility (e.g. if the session falls back to a Codex provider later). Fields stripped: call_id, response_item_id rrZrc~g|]9}t|tr fd|Dn|:S)c$i|] \}}|v || Srr)rkr _STRIP_KEYSs r zJAIAgent._sanitize_tool_calls_for_strict_api...[s) A A AdaA[,@,@Q,@,@,@r)rrr)rrOr>s rrPz?AIAgent._sanitize_tool_calls_for_strict_api..Zs_! ! ! "d## , A A A Abhhjj A A A A)+! ! ! r)r rrX)r6rr>s @r#_sanitize_tool_calls_for_strict_apiz+AIAgent._sanitize_tool_calls_for_strict_apiEsn"[[.. *d++ N "45 ! ! ! ! !! ! !   rrrc*ddlm}||||S)uOForwarder — see ``agent.agent_runtime_helpers.sanitize_tool_call_arguments``.r)sanitize_tool_call_argumentsrA)rOrC)rrrrCs r_sanitize_tool_call_argumentsz%AIAgent._sanitize_tool_call_argumentsas0 MLLLLL++HVPZ[[[[rc|jdkS)aDetermine if tool_calls need sanitization for strict APIs. Codex Responses API uses fields like call_id and response_item_id that are not part of the standard Chat Completions schema. These fields must be stripped when calling any other API to avoid validation errors (400 Bad Request). Returns: bool: True if sanitization is needed (non-Codex API), False otherwise. r)rrs r_should_sanitize_tool_callsz#AIAgent._should_sanitize_tool_callsls} 111rr approx_tokensr  focus_topicrHrIc0ddlm}|||||||S)uFForwarder — see ``agent.conversation_compression.compress_context``.r)compress_contextrG)rrK)rrrQrHr rIrKs r_compress_contextzAIAgent._compress_contextys<CCCCCC (N'k    rdecisionc8|jr|j ||_dSdSdS)z?Record the first guardrail decision that should stop this turn.N) should_halt_tool_guardrail_halt_decisionrrMs r_set_tool_guardrail_haltz AIAgent._set_tool_guardrail_halts3   :D$F$N19D . . . : :$N$Nrc@|jpd}d|d|jd|jdS)Nza toolzI stopped retrying z) because it hit the tool-call guardrail (z) after z repeated non-progressing attempts. The last tool result explains the blocker; the next step is to change strategy instead of repeating the same call.)rQrcount)rrMrs r#_toolguard_controlled_halt_responsez+AIAgent._toolguard_controlled_halt_responsesP!-X E$ E E  E E'/~ E E E r function_argsfunction_resultc|j||||}|jdvrt||}|jr|||S)N)r>haltrs)_tool_guardrails after_callactionr\rOrR)rrQrVrWrrMs r_append_guardrail_observationz%AIAgent._append_guardrail_observationsq(33    4   ?. . .7RRO   4  ) )( 3 3 3rcJ||t|Sr)rRr]rQs r_guardrail_block_resultzAIAgent._guardrail_block_results$ %%h///)(333reffective_task_idrc|j}d|_ t|s|||||d|_S|||||d|_S#d|_wxYw)a=Execute tool calls from the assistant message and append results to messages. Dispatches to concurrent execution only for batches that look independent: read-only tools may always share the parallel path, while file reads/writes may do so only when their target paths do not overlap. TF)rr`rt_execute_tool_calls_sequential_execute_tool_calls_concurrent)rrrr`rrs r_execute_tool_callszAIAgent._execute_tool_callss'1 !% *1*== ::%x1BN%*D ! ! 66!8->%*D ! !ED ! ) ) ) )s&AA A&c fddlm}||d|d|d|d|d|d|d |d | S) zSingle call site for delegate_task dispatch. New DELEGATE_TASK_SCHEMA fields only need to be added here to reach all invocation paths (concurrent, sequential, inline). r)rqgoalcontexttoolsetstasksrrrr) rfrgrhrirrrr parent_agent)rrrqr )rrV_delegate_tasks r_dispatch_delegate_taskzAIAgent._dispatch_delegate_tasks HGGGGG~""6**!%%i00"&&z22##G,,(,,-=>>%))-88"&&z22""6**    r function_namepre_tool_block_checkedc 0ddlm}||||||||S)u>Forwarder — see ``agent.agent_runtime_helpers.invoke_tool``.r) invoke_tool)rOrp)rrmrVr`r*rrnrps r _invoke_toolzAIAgent._invoke_toolsC <;;;;;{4 ?PR^`hkABB Br labelrcddl}ddl}|dj}t d|t |z }g}|dD]\}t ||kr||+|||dd} | | p|g]d|z |} ||| S) aFWord-wrap verbose tool output to fit the terminal width. Splits *text* on existing newlines and wraps each line individually, preserving intentional line breaks (e.g. pretty-printed JSON). Returns a ready-to-print string with *label* on the first line and continuation lines indented. rN)xrrJTF)widthbreak_long_wordsbreak_on_hyphens) shutiltextwrapget_terminal_sizecolumnsrFrrrYwraprrZ) rsrFr_shutil_twcols wrap_width out_linesraw_linewrappedrs r _wrap_verbosezAIAgent._wrap_verboses !   ((33;TCKK/00 !  4(( 8 8H8}} **  ****((8:4849#;;  !6XJ7777v ##I..'%''''rc,ddlm}||||||S)uHForwarder — see ``agent.tool_executor.execute_tool_calls_concurrent``.r)execute_tool_calls_concurrent)agent.tool_executorr)rrrr`rrs rrcz&AIAgent._execute_tool_calls_concurrent0EEEEEE,,T3DhPacqrrrrc,ddlm}||||||S)uHForwarder — see ``agent.tool_executor.execute_tool_calls_sequential``.r)execute_tool_calls_sequential)rr)rrrr`rrs rrbz&AIAgent._execute_tool_calls_sequentialrrc(ddlm}||||S)uJForwarder — see ``agent.chat_completion_helpers.handle_max_iterations``.r)handle_max_iterations)rr)rrrrs r_handle_max_iterationszAIAgent._handle_max_iterationss)GGGGGG$$T8^DDDrstream_callbackpersist_user_messagec 0ddlm}||||||||S)u?Forwarder — see ``agent.conversation_loop.run_conversation``.rrun_conversation)agent.conversation_loopr)rrrQr5r rrrs rrzAIAgent.run_conversationsD =<<<<<lNDXZacruIJJ Jrc@|||}|dS)a Simple chat interface that returns just the final response. Args: message (str): User message stream_callback: Optional callback invoked with each text delta during streaming. Returns: str: Final assistant response )rr/r)rrrrs rchatz AIAgent.chat s(&&w&PP&''r)should_review_memoryrc0ddlm}|||||||S)uDForwarder — see ``agent.codex_runtime.run_codex_app_server_turn``.r)run_codex_app_server_turn)rr.rr`r)rr)rrr.rr`rrs r_run_codex_app_server_turnz"AIAgent._run_codex_app_server_turnsQ BAAAAA((L`uAI]nEYZZZ Zr)@NNNNNNNNrrrNNFFFNrrNNNNFNNNNNNNNNNNNNNNNNNNNNNNNNNNFFFNNNNNFrrrF)rNr)rrr)FF)r)r)NN)NNF)rr)NNNNN)rrrr&_TOOL_CALL_ARGUMENTS_CORRUPTION_MARKERpropertyrrsetterrXrrrrerrrrrrr&r:rLrNrYrarirkrprtryru_STREAM_DIAG_HEADERS staticmethodrzr BaseExceptionrrrrrrrrrrrrtuplerrrrrrrrrrrrrrr rrrrrrr&r-r4r;r7rDr:rfrjrorsr|rrrrrrr rrr9rrrrrrrrrrrrr%r+r-r4r;r<rNrPrUrXr]r_ frozenset_VALID_API_ROLESrcrjrmrwr}rrrQrRrPrrr!rrrrrrr=rrrrrrrrrrrrr%rr<r0rArDrGrPrSrfr^rirmrrrzr|rr_rrrrrrrrrrrrrrrrrrrrr rr#r&r+r)r(r*r9r@rDrFrLr[rRrUr]r_rdrlrqrrcrbrrrrrrrrrFs% O+ #X_;c;d;;;_;%)!% &*'+"' % '+ #'+'+%)!,1(,7;+/(,+/&*'+%)"&*./3&*$(+/ ,015#'#(#(!!%.2)-$)(*,/+- %CG G G G  G  G  G s)d"G G 3i$G G G G s)G  9G  G !G "#G $"%%G &'G ()G * 9+G , 9-G .c/G 01G 2&*3G 4#&5G 6&.e_7G 89G :!);G <&=G >!)?G @$AG B%CG D#EG F GG H (IG J%-KG L$MG N"OG PQG RsCx.SG TUG V S>WG XtCH~.YG Z[G \]G ^_G `aG bcG deG fgG h!iG j!kG l!mG noG rsG t,uG vS#XwG z"{G |#&}G ~'*G @&)AG BCG G G G R&,%7%7%7N??Xc]?^b????BXXXX $,1***D****6T&  $     UCUDUUUU(VSVTVVVV&NMMMMM"tCH~"""\" @cN@36@ @@@@. .#...\. 3]3t33334*.           tCH~&      0*.          tCH~&      EC Em E E E E E tCH~    2222 )))) ,,c,T,,,,))S)D)))) 33s3d3333>E>>>>(uUD[7I0 $tCH~:N SX    LDLLLL#'"&"&# y y y3- y3- y 3- y } y tTz  y y y y %S %T % % %\ %#'<<<<3-<  <<<\<* %s %t % % % %%c%d%%%%.13131111  Gc Gd G G G\ GHHHHH$( CCC4. C  CCCC>bbbtCH~& b  bbbb:x}:::: 5s5t5555 TdTT T cTTT\T$# :   6'++/!%&*    sm $C=  #  sm   c3h    $*T$Z*D****$ K Kd K4PT: K K K K3$t*3QU3333j7d77777 9F9Fd4j9FX\]aXb9F9F9F9Fv-4:-$t*---->5#5555 Sd4S>6JSX[ShlSquvz{~AD|DwErFSSSS Dd38n)= D3 D[_ D D D D#S#X/#c]# ###\#J+&I+&#+&+&+&\+&Z)(3-)HSM))))cc40)0S#X000\0 CHTRUWZRZ^D\*&* T T TcN T T  " T $ T T T T\@D@D$tCH~*>@D@D@D@DDBVBVBVBVBVBVBVH++++B"#"$""""Hhsm %&%&38n%& %&  %&  %&%&%&%&N6 T#tCH~:M5N SV   \ >RTRRURZ^RRRR (C(D(((( #$&&&&CD, d    $6dd2/ #/ /  /  ////b----^6666p4S#X+?D@))))X)NNNSRUXNNNN HH3H#HHHH IIII\I -#---\- !y!a!a!abb/d38n)=/$tCQTH~BV///\/ 3c3h3D333\3j<tCH~&< d38n <<<\<Td\<GDGTGGG\G"1313:1111 ''' GGGGCGPSGGG\G66x}hsm7S1T666\6+/SSS#3-S SSSS/#//// S    Y_\:sC\0W4WCWQUWZ]WWWW /////\/ 33QU0"ss .4.... AA$AAA\A4PP$PPPP Z^WWWsWQUWbeWWWW4G3G3G4GGGGJJDJ#JV^JJJJ JJDJ#JJJJ FJHHHdHdHHHHTEI!!!T!T!!!!F!!!!!F141111f)A3)A4)A)A)A)AVJJJJF7;26 n n nc] n n $N3 n  S#X/ n tTz  n n n n $ $ $ $ $DTDDDD 48$8888'3'3'3'3RCD1c1c111\1 >S >T > > > > LT#s(^ LPT L L L L37s37t37373737j#$       t    ?Caaaa3;aaaa33-D3PT3333-$---- p"p47pFIp pppp#$\CE#xPT~BUABBBB((S((S(s(((\(0ss$scfsx{sEIssss ss$scfsx{sEIssss EtESESEEEE#59.2.2 J J J J#4S>2 J  J "(+ J'sm J c3h J J J J ( (C ((82D (PS ( ( ( (*&+ Z Z Z Z # Z tCH~& Z  Z# Z c3h Z Z Z Z Z ZrrrrFrqueryrr max_turnsrr list_toolsr save_sampleverboserc  tdtd|rddlm} m} ddlm}m}tdtdtdtd |}g}g}g}|D]_\}}||}|rM||f}|d vr||0|d vr||J||`td |D]X\}}|d rd |d nd}td|dd|dtd|Ytd|D]p\}}|drd |dnd}td|dd|dtd|td|dqtd|D]9\}}td|dd|dtd|d:td| }|D]b\}}|drdnd}td |d!|d"|d|ds+td#d |d$c| }td%t|d&t|D]'}t|}td'|d(|d)(td*td+td,td-td.td td/td0td td1td2td td3td4d5Sd5}d5}|r1d6| d7D}td8||r1d9| d7D}td:||r-td;td<td= t|||||||| | > } n*#t$r}!td?|!Yd5}!~!d5Sd5}!~!wwxYw|d@}"n|}"tdA|"tdB| |"}#tdBtdCtdtdD|#dEtdF|#dGtdHt|#dI|#dJr3tdKtdLt|#dJ| rt#t%jd5dM}$dN|$dO}%| |#dI|"|#dE}&|&t+j||#dE|"dP} t1|%dQdRS5}'|'t5j|dTdUVd5d5d5n #1swxYwYtdW|%n)#t8$r}!tdX|!Yd5}!~!nd5}!~!wwxYwtdYd5S)Za Main function for running the agent directly. Args: query (str): Natural language query for the agent. Defaults to Python 3.13 example. model (str): Model name to use (OpenRouter format: provider/model). Defaults to anthropic/claude-sonnet-4.6. api_key (str): API key for authentication. Uses OPENROUTER_API_KEY env var if not provided. base_url (str): Base URL for the model API. Defaults to https://openrouter.ai/api/v1 max_turns (int): Maximum number of API call iterations. Defaults to 10. enabled_toolsets (str): Comma-separated list of toolsets to enable. Supports predefined toolsets (e.g., "research", "development", "safe"). Multiple toolsets can be combined: "web,vision" disabled_toolsets (str): Comma-separated list of toolsets to disable (e.g., "terminal") list_tools (bool): Just list available tools and exit save_trajectories (bool): Save conversation trajectories to JSONL files (appends to trajectory_samples.jsonl). Defaults to False. save_sample (bool): Save a single trajectory sample to a UUID-named JSONL file for inspection. Defaults to False. verbose (bool): Enable verbose logging for debugging. Defaults to False. log_prefix_chars (int): Number of characters to show in log previews for tool calls/responses. Defaults to 20. Toolset Examples: - "research": Web search, extract, crawl + vision tools u🤖 AI Agent with Tool Callingz2==================================================r)get_all_tool_namesget_available_toolsets)get_all_toolsetsget_toolset_infou 📋 Available Tools & Toolsets:z2--------------------------------------------------u' 🎯 Predefined Toolsets (New System):z(---------------------------------------->webvisioncreativeterminalrR>rresearch full_stack developmentcontent_creationu 📌 Basic Toolsets:resolved_toolsz, r)rr z - rz Tools: u5 📂 Composite Toolsets (built from other toolsets):includesz Includes: z Total tools: tool_countu! 🎭 Scenario-Specific Toolsets:20u3 📦 Legacy Toolsets (for backward compatibility): availableu✅u❌z ryrz Requirements: requirementsu 🔧 Individual Tools (z available):u 📌 z (from ru 💡 Usage Examples:z # Use predefined toolsetszR python run_agent.py --enabled_toolsets=research --query='search for Python news'zN python run_agent.py --enabled_toolsets=development --query='debug this code'zP python run_agent.py --enabled_toolsets=safe --query='analyze without terminal'z # Combine multiple toolsetszM python run_agent.py --enabled_toolsets=web,vision --query='analyze website'z # Disable toolsetszQ python run_agent.py --disabled_toolsets=terminal --query='no command execution'z& # Run with trajectory saving enabledzF python run_agent.py --save_trajectories --query='your question here'Nc6g|]}|SrrBrr%s rrPzmain..s P P Pq P P Prru🎯 Enabled toolsets: c6g|]}|Srrrs rrPzmain..s !R!R!R!''))!R!R!Rru🚫 Disabled toolsets: u💾 Trajectory saving: ENABLEDu: - Successful conversations → trajectory_samples.jsonlu7 - Failed conversations → failed_trajectories.jsonl) rrrrrrrrru ❌ Failed to initialize agent: zTell me about the latest developments in Python 3.13 and what new features developers should know about. Please search for current information and try it out.u 📝 User Query: z3 ==================================================u📋 CONVERSATION SUMMARYu✅ Completed: rlu📞 API Calls: api_callsu💬 Messages: rr/u 🎯 FINAL RESPONSE:z------------------------------rsample_z.json) conversations timestamprrlrwrrFr) ensure_asciiru" 💾 Sample trajectory saved to: u ⚠️ Failed to save sample: u 👋 Agent execution completed!)rT model_toolsrrrhrrrrYrZrsortedrrrrrruuiduuid4ror rropenrKrrr)(rrrrrrrrrrrrrrrr all_toolsetsbasic_toolsetscomposite_toolsetsscenario_toolsetsr toolsetrr tools_str includes_strlegacy_toolsetsr all_toolsrQenabled_toolsets_listdisabled_toolsets_listagentr%rkr sample_idsample_filenamerrfs( rmainr(sH +,,, (OOOPJJJJJJJJ???????? 0111 h 8999 h'')) )//11 4 4MD'##D))D 4t QQQ"))%0000fff&--e4444%,,U333 &'''( - -JD$=ABR=S_ $'7"8999Y_I <4<<z:JV499T*%5666PVL <4<< > > $ NL499T.5I+J+JLLMMM'&((  F#i..FFFGGG ** : :I*955G 8I88g888 9 9 9 9 &''' +,,, bccc ^___ `aaa d  -... ]^^^ d  $%%% abbb d  6777 VWWW!!A P P4D4J4J34O4O P P P ?(=??@@@C!R!R5F5L5LS5Q5Q!R!R!R A)?AABBBI /000 JKKK GHHH$24/#-      444555  } b    , , ,--- / # #J / /F / %&&& (OOO 1F;/ 1 1222 2VK0 2 2333 5Cz 233 5 5666 ( &''' h f%&''': %%bqb) 4I44488 :   ;   (!1133 ,    :osW=== I 5uQGGGHHH I I I I I I I I I I I I I I I III J J J J : : : 8Q88 9 9 9 9 9 9 9 9 : -.....sTR!! S+SS Z2+Z Z2ZZ2ZZ22 [<[[__main__) NrNrrNNFFFFr)rhermes_bootstrapModuleNotFoundErrorrrconcurrent.futures concurrent contextvarsrcrrr getLoggerrrrrandomrsslrdrrr!typesrurllib.requesturllibrtypingrrrr urllib.parserr r r pathlibr hermes_constantsr agent.process_bootstraprrrrrrragent.iteration_budgetrhermes_cli.env_loaderrhermes_cli.timeoutsrr _hermes_home__file__parent _project_env_loaded_env_paths _env_pathrrrrrrtools.terminal_toolrr r!r"_set_approval_callbackr#_set_sudo_password_callbackr$r%tools.tool_result_storager&r'tools.interruptr(rtools.browser_toolr)agent.memory_managerr*r+r,agent.think_scrubberr-agent.retry_utilsr.agent.error_classifierr/r0agent.prompt_builderr1r2r3r4r5r6r7r8rCr9r:r;r<r=r>r?r@rArBagent.context_compressorrCagent.subdirectory_hintsrDagent.prompt_cachingrErFrGrHrIrJrKrLrMagent.usage_pricingrNrOagent.codex_responses_adapterrPrrQrrRrrS agent.displayrTrU_build_tool_previewrV_get_cute_tool_message_implrWrX_get_tool_emojiagent.tool_guardrailsrYrZr[r\r] agent.tool_result_classificationr^rr_agent.trajectoryr`rarbrqagent.message_sanitizationrcrdrerfrgrhrirjrkrlrmagent.tool_dispatch_helpersrnrorprqrrrsrtrurvrwrxryrzr{r|utilsr}r~rrrrr_MAX_TOOL_WORKERSEvent_openrouter_prewarm_donerrrrrerrrrrrrfireFirerrrrs# .     D       8 $ $  !!!!!! ,,,,,,,,,,,,7777777777,,,,,,322222544444   tH~~$v- &&<\ZZZK&GG  :IFFFFG KKIJJJ NMMMMMMMMM UTTTTTTT;;;;;;......hggggggggg777777......EEEEEEEE766666<<<<<<>>>>>>DDDDDDDD                            "tsssssssssssss%%%%%% +9?,,T%) # # #Tz #47$J #  # # # #F d    $ $ $ $ $ $ $ $ N`7Z`7Z`7Z`7Z`7Z`7Z`7Z`7ZFo !#S/S/ S/ S/S/ S/  S/  S/S/S/S/S/S/S/S/S/S/l zKKK DIdOOOOOs