iR ddZddlZddlZddlZddlZddlZddlZddlZej e Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlZddlmZddlZddlZddlmZmZmZmZddlmZm Z m!Z!ddl"m#Z#ddl$Z$ddl%m%Z%ddl&m'Z'dd l(m)Z)dd l*m+Z+dd l,m-Z-m.Z.e)Z/e'e0j1d z Z2e+e/e2 Z3e3re3D]Z4e 5de4ne 5dddl6m7Z7m8Z8m9Z9m:Z:ddl;mZ>ddl?m@Z@mAZAddlBmCZDddlEmFZFddlGmHZHmIZIddlJmKZKddlLmMZMmNZNddlOmPZPmQZQmRZRmSZSmTZTmUZUddlVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_m`Z`ddlambZbddlcmdZdddlemfZfddlOmgZgmhZhmiZimjZjmkZkmlZlmmZmmnZnddlompZpmqZqddlrmsZtmuZvmwZxmyZydd lzm{Z{m|Z}m~ZmZmZdd!lmZmZmZdd"lmZmZmZmZmZGd#d$Zd%eefd&Zd'eed%eefd(Zdcd)ZGd*d+Zed,hZehd-Zehd.Zd/Zejd0ejZejd1Zd2ed%efd3Zd%efd4Zd5ed6ed%e'dzfd7Zd8e'd9e'd%efd:Zejd;Zded%efd?Zd@ed%efdAZdBed%efdCZdddEed5ed%efdFZded%efdKZdLZd%efdMZd%efdNZd%efdOZGdPdQZ dedVedWedXed'edYedZed[ed\ed]ed^ed_ed`efdaZe dbkre$jedSdS)fao 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)OpenAI)datetime)Path)get_hermes_home)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)maybe_persist_tool_resultenforce_turn_budget) set_interrupt)cleanup_browser)build_memory_context_blocksanitize_context)jittered_backoff)classify_api_errorFailoverReason)DEFAULT_AGENT_IDENTITYPLATFORM_HINTSMEMORY_GUIDANCESESSION_SEARCH_GUIDANCESKILLS_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)convert_scratchpad_to_thinkhas_incomplete_scratchpadsave_trajectory)atomic_json_writebase_url_host_matchesbase_url_hostnameenv_var_enablednormalize_proxy_urlc:eZdZdZdZdZdZdZdZdZ dZ d S) _SafeWriterupTransparent stdio wrapper that catches OSError/ValueError from broken pipes. When hermes-agent runs as a systemd service, Docker container, or headless daemon, the stdout/stderr pipe can become unavailable (idle timeout, buffer exhaustion, socket reset). Any print() call then raises ``OSError: [Errno 5] Input/output error``, which can crash agent setup or run_conversation() — especially via double-fault when an except handler also tries to print. Additionally, when subagents run in ThreadPoolExecutor threads, the shared stdout handle can close between thread teardown and cleanup, raising ``ValueError: I/O operation on closed file`` instead of OSError. This wrapper delegates all writes to the underlying stream and silently catches both OSError and ValueError. It is transparent when the wrapped stream is healthy. )_innerc>t|d|dS)NrT)object __setattr__)selfinners +/home/div/.hermes/hermes-agent/run_agent.py__init__z_SafeWriter.__init__s 4511111c |j|S#ttf$r)t |t rt |ndcYSwxYwNr)rTwriteOSError ValueError isinstancestrlen)rXdatas rZr_z_SafeWriter.writesb =;$$T** *$ = = = *4 5 5<3t9991 < < < =s7AAcj |jdS#ttf$rYdSwxYwN)rTflushr`rarXs rZrhz_SafeWriter.flushsH  K       $    DD s 22c4|jSrg)rTfilenoris rZrkz_SafeWriter.filenos{!!###r\cf |jS#ttf$rYdSwxYw)NF)rTisattyr`raris rZrmz_SafeWriter.isattysB ;%%'' '$   55 s 00c,t|j|Srg)getattrrT)rXnames rZ __getattr__z_SafeWriter.__getattr__st{D)))r\N) __name__ __module__ __qualname____doc__ __slots__r[r_rhrkrmrqr\rZrSrS|s$I222===  $$$ *****r\rSreturncdD]G}tj|d}|rt |cSHdS)zRead proxy URL from environment variables. Checks HTTPS_PROXY, HTTP_PROXY, ALL_PROXY (and lowercase variants) in order. Returns the first valid proxy URL found, or None if no proxy is configured. ) HTTPS_PROXY HTTP_PROXY ALL_PROXY https_proxy http_proxy all_proxyN)osenvirongetstriprQ)keyvalues rZ_get_proxy_from_envrsZ :.. sB''--//  .&u-- - - - . 4r\base_urlct}|r|s|St|}|s|S tj|rdSn#t $rYnwxYw|S)zFReturn an env-configured proxy unless NO_PROXY excludes this base URL.N)rrOurllibrequestproxy_bypass_environment Exception)rproxyhosts rZ_get_proxy_for_base_urlrs  ! !E  X & &D   > 2 24 8 8 4        LsA AAcdD]R}tt|d}|8t|ts#t t|t|SdS)zHWrap stdout/stderr so best-effort console output cannot crash the agent.)stdoutstderrN)rosysrbrSsetattr) stream_namestreams rZ_install_safe_stdiors\+;; k400  j&E&E  Ck&&9&9 : : :;;r\cjeZdZdZdefdZdefdZd dZe defdZ e defd Z dS) IterationBudgetuaThread-safe iteration counter for an agent. Each agent (parent or subagent) gets its own ``IterationBudget``. The parent's budget is capped at ``max_iterations`` (default 90). Each subagent gets an independent budget capped at ``delegation.max_iterations`` (default 50) — this means total iterations across parent + subagents can exceed the parent's cap. Users control the per-subagent limit via ``delegation.max_iterations`` in config.yaml. ``execute_code`` (programmatic tool calling) iterations are refunded via :meth:`refund` so they don't eat into the budget. max_totalcR||_d|_tj|_dSr^)r_used threadingLock_lock)rXrs rZr[zIterationBudget.__init__s#" ^%% r\rxc|j5|j|jkr ddddS|xjdz c_ ddddS#1swxYwYdS)z7Try to consume one iteration. Returns True if allowed.NFT)rrrris rZconsumezIterationBudget.consumes Z  zT^++         JJ!OJJ                   sAAA  A Nc||j5|jdkr|xjdzc_ddddS#1swxYwYdS)z6Give back one iteration (e.g. for execute_code turns).rrN)rrris rZrefundzIterationBudget.refunds Z  zA~~ a                   s 155c|jSrg)rris rZusedzIterationBudget.useds zr\c~|j5td|j|jz cdddS#1swxYwYdSr^)rmaxrrris rZ remainingzIterationBudget.remainings Z 7 7q$.4:566 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7s 266rxN) rrrsrtruintr[boolrrpropertyrrrwr\rZrrs  &#&&&&     cX73777X777r\rclarify> read_file skill_view web_search skills_list web_extract ha_get_state search_filessession_searchvision_analyzeha_list_entitiesha_list_services>patchr write_filez(?:^|\s|&&|\|\||;|`)(?: rm\s|rmdir\s| cp\s|install\s| mv\s| sed\s+-i| truncate\s| dd\s| shred\s| git\s+(?:reset|clean|checkout)\s )z[^>]>[^>]|^>[^>]cmdc~|sdSt|rdSt|rdSdS)zJHeuristic: does this terminal command look like it modifies/deletes files?FT)_DESTRUCTIVE_PATTERNSsearch_REDIRECT_OVERWRITE)rs rZ_is_destructive_commandr-sJ u##C((t!!#&&t 5r\c t|dkrdSd|D}td|DrdSg}|D]}|jj} t j|jj}n:#t$r-tj d||jjddYdSwxYwt|ts+tj d|t|j dS|tvrIt||dStfd |DrdS||t"vrdS d S) z?Return True when a tool-call batch is safe to run concurrently.rFc&g|]}|jjSrwfunctionrp.0tcs rZ z2_should_parallelize_tool_batch..=s888r"+"888r\c3(K|] }|tvVdSrg)_NEVER_PARALLEL_TOOLS)rrps rZ z1_should_parallelize_tool_batch..>s( @ @T4( ( @ @ @ @ @ @r\u@Could not parse args for %s — defaulting to sequential; raw=%sNu6Non-dict args for %s (%s) — defaulting to sequentialc38K|]}t|VdSrg)_paths_overlap)rexisting scoped_paths rZrz1_should_parallelize_tool_batch..Ys-XXX>+x88XXXXXXr\T)rdanyrrpjsonloads argumentsrloggingdebugrbdicttyperr_PATH_SCOPED_TOOLS_extract_parallel_scope_pathappend_PARALLEL_SAFE_TOOLS) tool_calls tool_namesreserved_paths tool_call tool_name function_argsrs @rZ_should_parallelize_tool_batchr8s :!u88Z888J @ @Z @ @ @@@u!#N &+   Jy'9'CDDMM    MR",TcT2    555  -..  MH]##,    55 * * *6y-PPK"uuXXXXXXXXX uu  ! !+ . . .  0 0 055 1 4sA112B('B(rrc|tvrdS|d}t|tr|sdSt |}|r9t tj t|St tj tt j |z S)z8Return the normalized file target for path-scoped tools.Npath) rrrbrcrr expanduser is_absoluterrabspathcwd)rrraw_pathexpandeds rZrrds***t  ((H h $ $HNN,<,<tH~~((**H4BGOOCMM22333 DHJJ$9 : :;; < < >>r\z[\ud800-\udfff]textcpt|rtd|S|S)zReplace lone surrogate code points with U+FFFD (replacement character). Surrogates are invalid in UTF-8 and will crash ``json.dumps()`` inside the OpenAI SDK. This is a fast no-op when the text contains no surrogates. �) _SURROGATE_RErsubrs rZ_sanitize_surrogatesrs5 D!!1  4000 Kr\payloadc0dfd|S)uuReplace surrogate code points in nested dict/list payloads in-place. Mirror of ``_sanitize_structure_non_ascii`` but for surrogate recovery. Used to scrub nested structured fields (e.g. ``reasoning_details`` — an array of dicts with ``summary``/``text`` strings) that flat per-field checks don't reach. Returns True if any surrogates were replaced. Fct|tr|D]|\}}t|tr;t|r td|||<dUt|ttfr |}dSt|trt|D]~\}}t|tr;t|r td|||<dUt|ttfr |}dSdS)NrT) rbritemsrcrrrlist enumerate)noderridx_walkfounds rZrz-_sanitize_structure_surrogates.._walksQ dD ! ! !"jjll ! ! UeS))!$++E22%$1$5$5h$F$FS $d|44!E%LLL  ! !d # # !'oo ! ! UeS))!$++E22%$1$5$5h$F$FS $d|44!E%LLL ! ! ! !r\rwrrrs @@rZ_sanitize_structure_surrogatesr s= E!!!!!!& E'NNN Lr\messagescpd}|D]}t|ts|d}t|tr;t|r!td||d<d}nt|tr~|D]{}t|trd|d}t|tr:t|r td||d<d}||d}t|tr:t|r td||d<d}|d}t|trs|D]o}t|ts|d} t| tr:t| r td| |d<d}|d } t| tr| d} t| tr:t| r td| | d<d}| d } t| tr:t| r td| | d <d}q|D]\} }| d vr t|tr;t|r td||| <d}Zt|ttfrt|rd}|S) aSanitize surrogate characters from all string content in a messages list. Walks message dicts in-place. Returns True if any surrogates were found and replaced, False otherwise. Covers content/text, name, tool call metadata/arguments, AND any additional string or nested structured fields (``reasoning``, ``reasoning_content``, ``reasoning_details``, etc.) so retries don't fail on a non-content field. Byte-level reasoning models (xiaomi/mimo, kimi, glm) can emit lone surrogates in reasoning output that flow through to ``api_messages["reasoning_content"]`` on the next turn and crash json.dumps inside the OpenAI SDK. FcontentrTrrpridrr>rproler r) rbrrrcrrrrrr )r rmsgr partrrprrtc_idfnfn_namefn_argsrrs rZ_sanitize_messages_surrogatesrsw E3!3!#t$$  '')$$ gs # # % (<(Repaired unescaped control chars in tool_call arguments for %sz ,\s*([}\]])z\1{}[]r2Nu8Repaired malformed tool_call arguments for %s: %s → %sPuARepaired control-char-laced tool_call arguments for %s: %s → %suPUnrepairable tool_call arguments for %s — replaced with empty object (was: %s))rbrcrloggerwarningrrdumpsJSONDecodeError TypeErrorrarercountrangeendswithr$) r&r raw_strippedparsed reserialisedfixed open_curly open_bracket_escapeds rZ_repair_tool_call_argumentsrG$s(2(C'@'@H8>>###bL CYOOOtvI9UUUt  L777z&Z@@@ < ' ' NNP     )Z 8      E F>5% 0 0ES!!EKK$4$44J;;s##ekk#&6&66LA~~ z!!a |## 2YY    Ju    E#   ~~c"" u{{3'7'7%++c:J:J'J'Jcrc $$ S)9)9EKK> e   Jw    NNS<,gcrcl   N   )Z 8      NN /<$ 4sL/AB>>CC<FB'H?>H?AJJJAK55LLcV|dddS)zRemove non-ASCII characters, replacing with closest ASCII equivalent or removing. Used as a last resort when the system encoding is ASCII and can't handle any non-ASCII characters (e.g. LANG=C on Chromebooks). asciiignore)errors)encodedecoders rZ_strip_non_asciirNs( ;;wx; 0 0 7 7 @ @@r\cRd}|D] }t|ts|d}t|trt |}||kr||d<d}nut|t r`|D]]}t|trF|d}t|trt |}||kr||d<d}^|d}t|trt |}||kr||d<d}|d}t|t r|D]} t| trq| di} t| trF| d} t| trt | }|| kr|| d<d}|D];\} } | d vr t| trt | }|| kr||| <d}<"|S) aStrip non-ASCII characters from all string content in a messages list. This is a last-resort recovery for systems with ASCII-only encoding (LANG=C, Chromebooks, minimal containers). Returns True if any non-ASCII content was found and sanitized. Fr Trrprrr>rprr r)rbrrrcrNrr)r rrr  sanitizedrrrprrrrrrs rZ_sanitize_messages_non_asciirQs] E/!/!#t$$  '')$$ gs # # )(11IG##!*I  & & ) ) )dD)))88F++D!$,,)$4T$:$: $,,+4DL$(Ewwv dC  (..ID  'F WW\** j$ ' ' - - -b$''- B//B!"d++-"$&&"5"5%gs33-(8(A(AI(G332;;(,))++ ! !JC???%%% !,U33 %%(CH E ! Lr\toolsc t|S)z7Strip non-ASCII characters from tool payloads in-place.)_sanitize_structure_non_ascii)rRs rZ_sanitize_tools_non_asciirUs ( / //r\c0dfd|S)zCStrip non-ASCII characters from nested dict/list payloads in-place.Fc&t|tru|D]^\}}t|trt |}||kr|||<d7t|tt fr |_dSt|t rnt |D]`\}}t|trt |}||kr|||<d7t|tt fr |_dSdS)NT)rbrrrcrNrr)rrrrPrrrs rZrz,_sanitize_structure_non_ascii.._walks5 dD ! ! !"jjll ! ! UeS))! 0 7 7I E))$-S $d|44!E%LLL ! !d # # !'oo ! ! UeS))! 0 7 7I E))$-S $d|44!E%LLL ! ! ! !r\rwrs @@rZrTrTs; E!!!!!!* E'NNN Lr\z0.14.1cddlm}dd|iS)zGReturn the User-Agent RouterMint needs to avoid Cloudflare 1010 blocks.r) __version__ User-Agentz HermesAgent/) hermes_clirY)_HERMES_VERSIONs rZ_routermint_headersr]s.999999 6_66 r\c|dS|sdSt|dkS)uHDecide 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. In that case we must fall back to the configured ``fallback_model`` instead. Returns True only when rotation has somewhere to go. See issue #11314. NFr) has_availablerdentries)pools rZ!_pool_may_recover_from_rate_limitrbsB$ |u     u t||~~   ""r\cddl}dtd|d|d}|d|dd S) z8Return default HTTP headers required by Qwen Portal API.rNz QwenCode/ (z; )enablez qwen-oauth)rZzX-DashScope-CacheControlzX-DashScope-UserAgentzX-DashScope-AuthType)platform_QWEN_CODE_VERSIONsystemlowermachine)_plat_uas rZ_qwen_portal_headersrnsf X( X XELLNN,@,@,B,B X Xemmoo X X XC$,!$ ,   r\cu:eZdZdZdZedefdZejdeddfdZ d2dededededede edzdede edzdede de de ede ede de de dede d ed!e ed"e ed#e ed$ed%e d&ed'ed(ed)ed*ed+ed,ed-ed.ed/ed0ed1ed2ed3e d4eeefd5ed6eeefd7e eeefd8ed9ed:ed;eded?ed@e dAe dBedCdDdEeeefdFe dGe dHe ftdIZdJZd3dKZdLZd dMdNe fdOZde fdPZde fdQZdReddfdSZdReddfdTZdUedVeddfdWZdeeeffdXZd4dYZd4dZZd5dede fd[Zd5dede fd\Z de fd]Z!de"e e ffd^Z#d_e e$eefde fd`Z%de fdaZ&dddddbde'ede'ede'ede'ede"e e ff dcZ(e)dede fddZ*e)ddedede'ede fdfZ+de de$fdgZ,dhede fdiZ-dhedefdjZ.e)dhede fdkZ/de fdlZ0 d5dmed_e'e de fdnZ1doedped_e eeefde fdqZ2de'efdrZ3dseddfdtZ4duZ5dvZ6dwZ7e)dxe edye ede efdzZ8 d6d{e ed|e d}e ddfd~Z9dddddde'ede'edse'ede'edeeeff dZ:d_e eddfdZ;d5d_e ede efdZ<d5d_e ede efdZ=d_e ede efdZ>defdZ?d_e eeefdede de eeeffdZ@d_e eeefdede fdZAe)deBdefdZCde'ede'efdZDdedefdZEe)deBdeeeffdZFdede'eeeffdZGdddeeefdede'eBde'eHfdZIe)dhedefdZJd5d_e eeeffdZKd5dReddfdZLd4dZMdede fdZNde'efdZOd_e de ddfdZPdeddfdZQdeddfdZRdZSde$fdZTd5d_e ddfdZUd5d_e ddfdZVdedede ddfdZWd4dZXd4dZYde eeefddfdZZede fdZ[d5dedefdZ\e)defdZ]e^hdZ_e)d_e eeefde eeeffdZ`e)de de fdZae)de de fdZbdededzfdZcdZde)d7dedede defdĄZee)dede"e'ee'effdƄZf d5dede'edefdɄZgdefdʄZhdefd˄Zidejjkfd̄Zle)dede fd΄Zme)d8dedefdτZnde$dede defd҄Zoe)dede fdӄZpdedede ddfdԄZqdede fdՄZrdedefdքZsde fdׄZtdedefd؄ZudededdfdلZvd9de$dedefdۄZwd5de$defd܄ZxddMdNe de fdބZyddMdNe de fd߄Zzde fdZ{de fdZ|deddfdZ}d4dZ~dddde'e de de'ede'eeefde"e e ff dZde$fdZd4dZde$fdZd4dZdeddfdZe)dedefdZdhede fdZdeeefddfdZdeddfdZdeddfdZdeddfdZde fdZddde$defdZd5ddde fdZde fdZe^hdZdeBde de de fdZe)dhede fdZe)dede"ee'eHffdZdededefdZdhededefdZd5defdZde de fd Zde fd Zde fd Zde de fd Zd_e ddfd Zde de$fdZde fdZde$dzfdZdmede$fdZde fdZde fdZde$de$ddfdZe)de$de$fdZe)dddd_e d'ede fdZde fdZddddd_e dede dsedede"f dZd7d_e d ed!e ddfd"Zd#e$defd$Z d9d%ed#e$d ede'ed_e def d&Ze)d:d(eded)edefd*Zd7d_e d ed!e ddfd+Zd7d_e d ed!e ddfd,Zd_e d!e defd-Z d;doedede eeefdsed.e'ed/e'edeeeffd0Zd5dRed.e'edefd1ZdS(<AIAgentz 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.]rxc|jSrg) _base_urlris rZrzAIAgent.base_url7s ~r\rNcv||_|r|nd|_t||_dSNr)rrrj_base_url_lowerrO_base_url_hostnamerXrs rZrzAIAgent.base_url;s805=u{{}}}2"3E":":r\rZ?Fdr3rapi_keyproviderapi_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_collection 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_messagesrguser_id user_namechat_id chat_name chat_type thread_idgateway_session_keyskip_context_files skip_memoryparent_session_iditeration_budgetrfallback_modelcheckpoints_enabledcheckpoint_max_snapshotspass_session_idc=nGt| |_| |_|7pt| |_| |_||_||_||_||_ |+|_ |,|_ |-|_ |.|_ |/|_|0|_|1|_|2|_d|_d|_|3|_|<|_|9|_||_|r|dnd|_|pd|_t5|t6r:|r&|nd}=|=pd|_|p||_tA|p|pg|_!|dvr ||_"n |jdkrd|_"n|jdkrd|_"n|=#|j#dkrd |j$vrd|_"d|_n|=|j#d krd|_"d|_n|jd ks |=|j#d krd |_"d |_n~|j$%d&drd |_"nI|jdks/|j#'drtQ|j$drd|_"nd|_" |)n#tT$rYnwxYw ddl+m,}>m-}?|j|>vr|?|j|j|_n#tT$rYnwxYw||j"dkr|jdkrt7|jpd'dst7|jpd'dsy|.se|/s!|0|j|jr0d|_"tc|dr|j23|jdks|4r)tkj6dd7||_8||_9||_:d |_;||_<||_=| |_>|!|_?|"|_@|#|_A|%|_B|$|_Cd |_Dd |_Ed|_Fd|_Gd |_HtkjI|_Jd|_KtkjL|_Mt|_OtkjL|_Pd|_Qg|_RtkjL|_S||_T||_U||_V||_W||_X||_Y| |_Z| |_[|&|_\|'|_]|(|_^t|)pi|_`|*pg|_ad |_b|c\|_d|_ed!|_f dd"lgmh}@|@id#ipi}A|Aid$d!}B|Bd%vr|B|_fn#tT$rYnwxYwd |_jd |_ktjl|_md&|_nd|_od|_pd|_qdd'lrms}Cmt}D|Ct(|jr%|Dtwd)n=|jr6d*D]3}Etjy|Eztj{4d|_|d |_}d|_~d|_d|_i|_d|_d |_t |j|j}F|j"d krdd+lm}Gm}H|jdk}I|Irdd,lm}Jtjd-|pd}K|Kr|Kd.nd/}L|L|_|J|L|_d0|_||_d |_d0|_d|_i|_|jst%d1|jd2|Ld3n|jd k}M|Mr|p |Hpdn|pd}N|N|_|N|_||_dd4lm}O|Mr |O|Nnd |_|G|N||F5|_d|_i|_|jsUt%d1|jd6|Nr:t)|Nd7kr&t%d8|Ndd9d:|Nd;dn|j"dkrVtjd-|pd}K|Kr|Kd.nd/|_d|_ dd"lgmh}P|Pidiidr`|Qd=|Qd>d?|_|Qid@r|Qd@|jdA<|QidBr|QdB|jdB<n#tT$rYnwxYwd|_i|_|js.|jrdCnd}Rt%d1|jdD|j|Rd3nw|rj|rgt-|}S|Sjr\t1|SdE}TdFt5|SjD}U||T|UdG}Vn||dH}V|F|F|VdI<|jdkr|j|VdJ<|j!|VdK<|}WtQ|WdLr dMdNdOdP|VdQ<ntQ|WdRrt9|VdQ<ntQ|WdSrddTlm}X|X|VdQ<ntQ|WdUr dVdWi|VdQ<nutQ|WdXrt?|VdQ<nQtQ|WdrddYlm}Y|Y||VdQ<n+ddZlm}Z|Z|jpd[|jd\\}[}\|[R|[jt7|[jdH}V|F|F|VdI<tc|[d]r|[jrt|[j|VdQ<n|jpd}]|]ru|]d^vrq|]d_}^ dd`lm}_|_i|]}`|`r|`jr |`jd}^n#tT$rYnwxYwtQda|]db|^dctQdd|V|_t7|Vided}atQ|adLrgdf|jpdvrJ|VidQpi}b|bidgd}cdh}d|d|cvr|cr |cdi|d|bdg<n|d|bdg<|b|VdQ<|Vidjd|_|Vide|j|_ ||Vdkdl|_|jst%d1|j|rt%dm||Vidjdn}e|erA|edokr;t)|ed7kr't%dp|edd9d:|ed;dn t%dq|er |eddrndndsn%#tT$r}ftQdt|fd}f~fwwxYwt5|8t@rdu|8D|_nOt5|8tr3|8idvr|8idwr |8g|_ng|_d|_d |_|jr |jdnd|_|jr|jst)|jd.kr1|jd}gt%dx|gdwdy|gdvd3nLt%dzt)|jd{d|d}|jDzt_| | |j~|_t|_|jrd|jD|_te|j}h|jst%dt)|jdd|h| r&t%dd| | r&t%dd| n|jst%d|jrI|jsBtg}id|iD}j|jrt%d|j|jr|jst%d|j rM|jsFt)|j dkr|j ddd:zn|j }kt%d|kd|jdrD|js=|jer|jd krd}ln |jerd}lnd}lt%d|ld|jfdtij|_|r||_nG|jd}mtsjjdd}n|md|n|_ty}o|odz |_|jdd|jd|jdz |_g|_d|_d|_d|_ddlm}p|p|:|;|_|5|_|6|_d|_|jr |j|j|j p tjidd|j|j|'|&dd|jn2#tT$r%}ftd|fYd}f~fnd}f~fwwxYwddlm}q|q|_ dd"lgmh}r|r}sn#tT$ri}sYnwxYwd|_d|_d |_d |_d|_d|_d|_|4s |sidi}t|tidd |_|tidd |_t|tidd|_|js|jrYddlm}u|u|tidd|tidd|_|jn#tT$rYnwxYwd|_|4s |tr|tidvdnd}v|vrddlm}wddlm}x|w|_|x|v}y|yr.|yr|j|y|jjr9|j|+pdt7tydd}z|jr8 |j|j}{|{r|{|zd<n#tT$rYnwxYw|j r |j |zd<|j r |j |zd<|j r |j |zd<|jr |j|zd<|jr |j|zd<|jr |j|zd<|jr |j|zd< ddlm}|||}}|}|zd<d|zd<n#tT$rYnwxYw|jjdi|ztwd|vn"td|vd|_n9#tT$r,}~td|~d|_Yd}~~~nd}~~~wwxYw|jr|jd|jD}|jD]o}|idd}|r||vrd|dÜ}|j||r/|j|||pd|_ |sidi}t|idd|_n#tT$rYnwxYw|sidi}t5|tsi}|idd[|_ |iddɦ}t|}|d.krd.}n#ttf$rd}YnwxYw||_|sidi}t5|tsi}t|idd̦}t7|idddv}t|iddЦ}t|iddr} |sidiidi}n#tT$ri}YnwxYwt5|tr|idӦ}nd}|- t|}n#ttf$rd}YnwxYw||_|sidwi}t5|tr|idӦ}nd}|i t|}nW#ttf$rAtd|t%d|d֝tjצd}YnwxYw||_ ddlgm}||s}n<#tT$r/|sid٦}t5|t@sg}YnwxYw||r ddlgm}||j|j|ۦ}|rt|}n#tT$rd}YnwxYw|i|jr|j%dnd}|D]B}t5|ts|idepd%d}|r||kr|idi}t5|tr|i|ji}t5|tr|idӦ}| t|}|dkrtnc#ttf$rMtd|j|t%d|jd|dtjצYnwxYwnDd}d} t5|str|sidini}|iddpd}n#tT$rYnwxYw|dkr ddlm}||}n2#tT$r%}td|Yd}~nd}~wwxYw|1 ddlm}|}|r |j|kr|}n#tT$rYnwxYw|td||||_ddlm}||j|jt|djd||j|}|j|j||jt|djd|j|js twd|jnJt|j|d||d|j|jt|djd||j|j" |_||_ddlm}t|jdd}|r-||kr'td|jd|did|did|dzd t|_tc|dr|jr|j|jD]n}d|dÜ}|j||idd}|r5|j||j|otc|dr|jr |j|jt7ty|j pd|jt|jddn2#tT$r%}td|Yd}~nd}~wwxYwttjdpd|_ d|_ d|_ d|_ d|_ d|_d|_d|_d|_d|_d|_d|_d|_dn|_d|_d}t5|tr|id}|L t||_n4#ttf$rtd|YnwxYw|j|jr}t1|jrh t3|j|j|jpd}|r|dkr||_n2#tT$r%}td|Yd}~nd}~wwxYw|jr(|js!twd|j|jsl|rHt%d|jjdidt|dzd|jjdid3n"t%d|jjdidd|_||j}|j|j|j|j"t|djdt|j|jd|jet|dw|jt|de|jt|djdt|dv|j|j|jd|_|j"d kr2|j|j|j|jddSdS(a Initialize the AI Agent. Args: base_url (str): Base URL for the model API (optional) api_key (str): API key for authentication (optional, uses env var if not provided) provider (str): Provider identifier (optional; used for telemetry/routing hints) api_mode (str): API mode override: "chat_completions" or "codex_responses" model (str): Model name to use (default: "anthropic/claude-opus-4.6") max_iterations (int): Maximum number of tool calling iterations (default: 90) tool_delay (float): Delay between tool calls in seconds (default: 1.0) enabled_toolsets (List[str]): Only enable tools from these toolsets (optional) disabled_toolsets (List[str]): Disable tools from these toolsets (optional) save_trajectories (bool): Whether to save conversation trajectories to JSONL files (default: False) verbose_logging (bool): Enable verbose logging for debugging (default: False) quiet_mode (bool): Suppress progress output for clean CLI experience (default: False) ephemeral_system_prompt (str): System prompt used during agent execution but NOT saved to trajectories (optional) log_prefix_chars (int): Number of characters to show in log previews for tool calls/responses (default: 100) log_prefix (str): Prefix to add to all log messages for identification in parallel processing (default: "") providers_allowed (List[str]): OpenRouter providers to allow (optional) providers_ignored (List[str]): OpenRouter providers to ignore (optional) providers_order (List[str]): OpenRouter providers to try in order (optional) provider_sort (str): Sort providers by price/throughput/latency (optional) session_id (str): Pre-generated session ID for logging (optional, auto-generated if not provided) tool_progress_callback (callable): Callback function(tool_name, args_preview) for progress notifications clarify_callback (callable): Callback function(question, choices) -> str for interactive user questions. Provided by the platform layer (CLI or gateway). If None, the clarify tool returns an error. max_tokens (int): Maximum tokens for model responses (optional, uses model default if not set) reasoning_config (Dict): OpenRouter reasoning configuration override (e.g. {"effort": "none"} to disable thinking). If None, defaults to {"enabled": True, "effort": "medium"} for OpenRouter. Set to disable/customize reasoning. prefill_messages (List[Dict]): Messages to prepend to conversation history as prefilled context. Useful for injecting a few-shot example or priming the model's response style. Example: [{"role": "user", "content": "Hi!"}, {"role": "assistant", "content": "Hello!"}] NOTE: Anthropic Sonnet 4.6+ and Opus 4.6+ reject a conversation that ends on an assistant-role message (400 error). For those models use structured outputs or output_config.format instead of a trailing-assistant prefill. platform (str): The interface platform the user is on (e.g. "cli", "telegram", "discord", "whatsapp"). Used to inject platform-specific formatting hints into the system prompt. skip_context_files (bool): If True, skip auto-injection of SOUL.md, AGENTS.md, and .cursorrules into the system prompt. Use this for batch processing and data generation to avoid polluting trajectories with user-specific persona or project instructions. N r>codex_responsesbedrock_conversechat_completionsanthropic_messages openai-codexrxai chatgpt.com/backend-api/codexapi.x.ai anthropicapi.anthropic.comr/ /anthropicbedrockbedrock-runtime. amazonaws.comrrr)_AGGREGATOR_PROVIDERSnormalize_model_for_provider copilot-acp acp://copilotz acp+tcp://r|_transport_cache openrouterctSrg)r*rwr\rZz"AIAgent.__init__..(s 355r\TtargetdaemonF5m) load_configprompt_caching cache_ttl)r1h initializing) setup_loggingsetup_verbose_logging)rz=Verbose logging enabled (third-party library logs suppressed))rR run_agenttrajectory_compressorcronr[)build_anthropic_clientresolve_anthropic_tokenbuild_anthropic_bedrock_clientzbedrock-runtime\.([a-z0-9-]+)\.r us-east-1zaws-sdku&🤖 AI Agent initialized with model: z& (AWS Bedrock + AnthropicBedrock SDK, re_is_oauth_tokentimeoutz (Anthropic native) u🔑 Using token: r... guardrailguardrail_identifierguardrail_version)guardrailIdentifierguardrailVersionstream_processing_modestreamProcessingModetracez + Guardrailsz (AWS Bedrock, )queryc&i|]\}}||dSrrwrkvs rZ z$AIAgent.__init__...s/%%%$(Aq1Q4%%%r\)r{r default_queryr{rrrr openrouter.aiz%https://hermes-agent.nousresearch.comz Hermes Agentzproductivity,cli-agent)z HTTP-RefererzX-OpenRouter-TitlezX-OpenRouter-Categoriesdefault_headersapi.routermint.comapi.githubcopilot.comcopilot_default_headers api.kimi.comrZclaude-code/0.1.0portal.qwen.ai_codex_cloudflare_headersresolve_provider_clientauto)r raw_codex_default_headers)rrcustom_API_KEY)PROVIDER_REGISTRYz Provider 'z:' is set in config.yaml but no API key was found. Set the zM environment variable, or switch to a different provider with `hermes model`.zxNo LLM provider configured. Run `hermes model` to select a provider, or run `hermes setup` for first-time configuration.rclaudezx-anthropic-betaz&fine-grained-tool-streaming-2025-05-14r,r{ agent_initreasonsharedu🔗 Using custom base URL: nonez dummy-keyu🔑 Using API key: u;⚠️ Warning: API key appears invalid or missing (got: 'z...')z$Failed to initialize OpenAI client: cg|]C}t|t|d,|dA|DS)r|rrbrrrfs rZrz$AIAgent.__init__..s^$$$a&&$+,55+<+<$ABw$$$$r\r|ru🔄 Fallback model: rdu🔄 Fallback chain (z providers):  → c3>K|]}|dd|ddVdS)rrdr|reNrwrs rZrz#AIAgent.__init__..s;"c"caj#D#DAjM#D#D#D"c"c"c"c"c"cr\)rrrc*h|]}|ddSrrw)rtools rZ z#AIAgent.__init__..s"$U$U$U$T*%5f%=$U$U$Ur\u🛠️ Loaded z tools: , u ✅ Enabled toolsets: u ❌ Disabled toolsets: u@🛠️ No tools loaded (all tools filtered out or unavailable)cg|] \}}|| Srwrw)rrp availables rZrz$AIAgent.__init__..s"^^^_T9T]^D^^^r\u=⚠️ Some tools may not work due to missing requirements: u📝 Trajectory saving enabled<u🔒 Ephemeral system prompt: 'z' (not saved to trajectories)znative AnthropiczAnthropic-compatible endpointzClaude via OpenRouteru💾 Prompt caching: ENABLED (z TTL) %Y%m%d_%H%M%SrEsessions)parentsexist_oksession_.jsonassistant_tool foreground)CheckpointManager)enabled max_snapshotsHERMES_SESSION_SOURCEcli)rrr)rsourcer model_configrrzESession DB create_session failed (session_search still available): %s) TodoStore memorymemory_enableduser_profile_enablednudge_interval) MemoryStorememory_char_limitiuser_char_limiti_)r7r8) MemoryManager)load_memory_providerprimary)rrgr agent_context session_titlerrrrrrr)get_active_profile_nameagent_identityhermesagent_workspacezMemory provider '%s' activatedz/Memory provider '%s' not found or not availablez&Memory provider plugin init failed: %sch|]@}t|t|didASrrrts rZrz#AIAgent.__init__..sT$$$a&&$j"%%))&11$$$r\rpr)rrskillscreation_nudge_intervalagenttool_use_enforcementapi_max_retries compression thresholdg?r*)true1yes target_ratio皙?protect_last_n auxiliarycontext_lengthuInvalid model.context_length in config.yaml: %r — must be a plain integer (e.g. 256000, not '256K'). Falling back to auto-detection.u2 ⚠ Invalid model.context_length in config.yaml: zf Must be a plain integer (e.g. 256000, not '256K'). Falling back to auto-detected context window. )file)get_compatible_custom_providerscustom_providers)"get_custom_provider_context_length)rrrWmodelsuInvalid context_length for model %r in custom_providers: %r — must be a positive integer (e.g. 256000, not '256K'). Falling back to auto-detection.u& ⚠ Invalid context_length for model z in custom_providers: zi Must be a positive integer (e.g. 256000, not '256K'). Falling back to auto-detected context window. compressorcontextengine)load_context_enginez4Context engine load from plugins/context_engine/: %s)get_plugin_context_engineuEContext engine '%s' not found — falling back to built-in compressorget_model_context_length)rr{config_context_lengthr|rWrrTrr{r|zUsing context engine: %s) rthreshold_percentprotect_first_nrRsummary_target_ratiosummary_model_overriderrr{rar|r})MINIMUM_CONTEXT_LENGTHzModel  has a context window of $ tokens, which is below the minimum z9 required by Hermes Agent. Choose a model with at least zBK context, or set model.context_length in config.yaml to override.context_compressor)rrgrrTz#Context engine on_session_start: %s TERMINAL_CWD) working_dirunknownollama_num_ctxz'Invalid ollama_num_ctx config value: %r)r{z#Ollama num_ctx detection failed: %szAOllama num_ctx: will request %d tokens (model max from /api/show)u📊 Context limit: z tokens (compress at rzz% = z# tokens (auto-compression disabled)rr|rr}r{ client_kwargsuse_prompt_cachinguse_native_cache_layoutcompressor_modelcompressor_base_urlcompressor_api_keycompressor_providercompressor_context_lengthcompressor_threshold_tokensanthropic_api_keyanthropic_base_urlis_anthropic_oauthrw( rrrrrrrrrrrg_user_id _user_name_chat_id _chat_name _chat_type _thread_id_gateway_session_key _print_fnbackground_review_callbackrr_credential_poolrrrrbrcrrjr|r~rrr}rvrurstripr> startswithrN_get_transportrhermes_cli.model_normalizerr_is_azure_openai_url_is_direct_openai_url&_provider_model_requires_responses_apihasattrrclear_is_openrouter_urlrThreadstartrrrsuppress_status_outputrrrrrrrr_executing_tools_interrupt_requested_interrupt_message_execution_thread_id _interrupt_thread_signal_pendingRLock _client_lock_pending_steerr_pending_steer_lockset_tool_worker_threads_tool_worker_threads_lock_delegate_depth_active_children_active_children_lockrrrrrrrrrrrrrr_force_ascii_payload_anthropic_prompt_cache_policy_use_prompt_caching_use_native_cache_layout _cache_ttlhermes_cli.configrr_budget_exhausted_injected_budget_grace_calltime_last_activity_ts_last_activity_desc _current_tool_api_call_count_rate_limit_statehermes_loggingrr _hermes_homer6infor getLoggersetLevelERROR_stream_callback_stream_needs_break _current_streamed_assistant_text_persist_user_message_idx_persist_user_message_override_anthropic_image_fallback_cache_anthropic_client_is_anthropic_oauthragent.anthropic_adapterrrrr;rgroup_bedrock_region_anthropic_api_key_anthropic_base_urlr{client_client_kwargsprintrrd_bedrock_guardrail_configrrr _replacer rr]hermes_cli.modelsrrnagent.auxiliary_clientrrrupperhermes_cli.authr api_key_env_vars RuntimeError_create_openai_client_fallback_chain_fallback_index_fallback_activated_fallback_modelrrrRvalid_tool_namessortedrr now session_startrstrftimeuuiduuid4hexrlogs_dirmkdirsession_log_file_session_messages_memory_write_origin_memory_write_context_cached_system_prompttools.checkpoint_managerr)_checkpoint_mgr _session_db_parent_session_id_last_flushed_db_idxcreate_sessionrrr7tools.todo_toolr0 _todo_store&_aux_compression_context_length_config _memory_store_memory_enabled_user_profile_enabled_memory_nudge_interval_turns_since_memory_iters_since_skillrtools.memory_toolr6load_from_disk_memory_manageragent.memory_managerr9plugins.memoryr: is_available add_provider providersget_session_titlehermes_cli.profilesr>initialize_allrget_all_tool_schemasradd_skill_nudge_interval_tool_use_enforcementr:ra_api_max_retriesfloatrr_config_context_lengthrVrXplugins.context_enginer]hermes_cli.pluginsr^rprkagent.model_metadatar`ro update_modelr4compression_enabledrg_context_engine_tool_namesget_tool_schemason_session_startr5getenv_subdirectory_hints_user_turn_countsession_prompt_tokenssession_completion_tokenssession_total_tokenssession_api_callssession_input_tokenssession_output_tokenssession_cache_read_tokenssession_cache_write_tokenssession_reasoning_tokenssession_estimated_cost_usdsession_cost_statussession_cost_source_ollama_num_ctxr2r3rTthreshold_tokens_compression_warning$_check_compression_model_feasibility_primary_runtimeupdate)rXrr{r|r}r~rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrgrrrrrrrrr session_dbrrrcredential_poolrrr provider_namerr _load_pc_cfg_pc_cfg_ttlrr quiet_logger_provider_timeoutrr_is_bedrock_anthropicr _region_match _br_region_is_native_anthropic effective_key_is_oat _load_br_cfg_gr _gr_label _parsed_url _clean_url _query_paramsrreffective_baserrr_routed_clientrE _explicit _env_hintr _pcfg_effective_baseheaders existing_beta _FINE_GRAINEDkey_usedefbr requirements missing_reqsprompt_previewr. timestamp_str short_uuidrr)r0_load_agent_config _agent_cfg mem_configr6_mem_provider_name_MemoryManager _load_mem_mp _init_kwargs_str>_profile_mpe_existing_tool_names_schema_tname_wrapped skills_config_agent_section_raw_api_retries _api_retries_compression_cfgcompression_thresholdr compression_target_ratiocompression_protect_last_aux_cfg_aux_context_config _model_cfgrrV_custom_providersrX_cp_ctx_resolved_target _cp_entry_cp_url _cp_models _cp_model_cfg_cp_ctx_parsed_selected_engine _engine_name_ctx_cfgr] _ce_load_errr^ _candidater`_plugin_ctx_lenrg_ctx_ce_err_ollama_num_ctx_override _detectedexc_ccs rZr[zAIAgent.__init__As,R  ,!1 SON4S4S$!2.$'>$   # ###$7! *.'"4. / 0.8@Z****b B 4>x4M4MlRZR`R`RbRbl((..000hl %+ &1'X3344 h h h$DMM ]n , ,-DMM ]e # #-DMM#  #} 4 4$(<<<-DM*DMM#)@J)N)N-DM!DMM ]k ) )m.CH_cvHvHv0DM'DMM  ! ( ( - - 6 6| D D /1DMM ]i ' '  # . ./A B B(%d&:OLL( /DMM.DM     ! ! ! !    D           }$99999$*dmTT     D    !333 .. +,,2244??PP/ +,,2244?? MM/--/// **,, / >>J!]? /.DMt/00 .%++--- =L ( (D,C,C,E,E (  55   eggg&<##6 &<#&+#!2"4 0*%:"*D'.!2 !&%*!"&04!05-%O--.2#,>#3#3 /2ee!)2)9)9& ! "%.^%5%5""3!2.*+F((@%!1!2% 0(!%&7&=2!>!> 0 6B$)!  / / 1 1 @ $"?  E E E E E E"lnn(()92>>D"G;;{D11D|##"&    D +0'"' )- (6 )-$%>B HGGGGGGG ,////   L ! ! # # # KKW X X X X L %LLL%l33< !$' _RRRRRR " *LhnZ\ ] ] 7DU]00333+ '1$)G)G )S)S&*3'+3(+0(( " &(#DC4:CCuCCCDDD (,} 'C$Pd y!K,C,C,E,E!Kkrkxvx , *7'+3(ONNNNNEY+d77=+A+A+A_d()?)? xar)s)s)s&" &(#_b4:bbbccc$_]););b)@)@]=!3D]]WYWZWZI[]]^^^ ]0 0 0I&H(.VXYYM=J#[=#6#6q#9#9#9P[D -1D * IIIIII"lnn((B77;;KLL77122Osww?R7S7SO/23I/J,/0C,D66D2ww788oQTUmQn67MNwww''OBEg,6w?    DK"$D ? ~/3/MUOOSU |tz||Z^Zn|py|||}}}X 8X  'x00 $ O!+K,@,@r,@,J,J!K!KJ%%,4[5F,G,G,M,M,O,O%%%M$+$.)6%%MM 18X$N$NM$0/@M),=M11/3/?M),,0MM&)!)(IIZ(O.<3K88M"344 +>;OPPZ7J7L7LM"344*>;RSS ZIIIIII7N7N7P7PM"344*>>JJZ$&98M"344+>;KLLZ7K7M7MM"344*>=IIZPPPPPP7P7PQX7Y7YM"34KJJJJJ$;$;M+V4:%O%O%O!!-#1#9$'(?$@$@%%M)43D i0~/ABBa~Gfa;?@_;`;` &78 "&!4" ; ; = = C C E EI Y6V%V%V(1'8'8$B$B$B !IIIIII$5$9$9)$D$DE$F)?F,1,B1,E (!!! D!*```2;``` ') #0D "-"3"3J"C"CDDJJLLO$_oFF ?8X\XbXhfhWoWoWqWqKqKq'++,=>>D" ' ,> C C H  55$D9F6X6X6X6X 2336C 237>M"34(,,Y;;DL)--j$-HHDM O"88|dh8ii  JO4:OOPPPIGXGGHHH,00FCCHJH $;$;H PR@R@RUXbqb\UUhrssmUUVVVVImu]B\dehfheh\i\i|BIIIJJJ O O O"#M!#M#MNNN O nd + + &$$)$$$D  - - &.2D2DZ2P2P &UcUgUghoUpUp &$2#3D #%D  #( :>:NXt3A66TX   e e4'((A--)!,NbkNNR ^NNNOOOOVc$2F.G.GVVVll"c"cdNb"c"c"cccdeee*-/    !$ : V$U$U$*$U$U$UD ! 566J? WYTZYY$))JBWBWYYZZZ$USdii@P6Q6QSSTTT$WUtyyAR7S7SUUVVV V T U U U : fdo f577L^^ 8J8J8L8L^^^L fdVbddeee  ! 4$/ 4 2 3 3 3  ' c cJMdNjJkJknpJpJpT9#2#>FFvzwSN aNaaa b b b  # UDO U, 1+1M1M+. 180 S6SST_SSS T T T&\^^  >(DOO!.77HHM)"1"-J!.====DO&'' #j0  D4888 $ 0Q4?0Q0Q0Q Q8:$4!%1"59" ?>>>>>00'2    &"3$%!     //#=ZBJNN;RTY,Z,Z**.*=,<&0"" !&*&=0       []^  .-----$9;;  K K K K K K++--JJ   JJJ  7;3"$%*"&(##$ "#  '^^Hb99 '1~~6F'N'N$-7^^+;+;D(#)$677C?s//11?,99#>>>+5,4*./(0(9E+./@/@+A+A-6 ((  +%%&*&6&H&H&Y&Y#&!HDGL$A#,%%% $% =D6:mL3?H8<L5=D6:mL3?H8<L5?H8<L5?H8<L54\BFB[L)>?!SSSSSS'>'>'@'@H=EL)9:>FL):;;(!!! D!;,;KKlKKK $DFXYYYY %VXjkkk/3, , , ,GNNN'+$$$$$$ ,   5DJ$:$$$$$  /DDFF 5 5 VR00f(<<<$.GDD !!(+++5)--f555(,,V444&(" &NN8R88M),]->->?XZ\-]-])^)^D & &    D  $44.$// N%3%7%78NPV%W%W" -112CQGG /00La :&   LLL  , &>>-<<*D11 "!  %&6&:&:;&M&M N N!"2"6"6y$"G"GHHNNPPThh#()9)=)=nd)S)S#T#T #&'7';';&>##z* + + +&*### +6I3 ^^GR00 j$ ' ' *%/^^4D%E%E " "%) " ! - .),-C)D)D&&z* . . .6+  IJ`III  *.&&& . '=# ' I I I I I I ? ? K K   ' ' ' */A B B /66 '$&! ' " ).? ) (PPPPPP#E#E*!]%6$$$ $C-01A-B-B* ( ( (#'    ( &-7;}L$-..s333"!2I%i66! (}}Z88>BFFsKKG7g#5#5%.]]8R%@%@ %j$77*,6NN4:r,J,JM)->>**7*;*;OPTP]>^>^ ' I0T]TXT`Tfdfggg 5Q+4D( I I I BCHHHHHHHH I     KKS$     |" |~T-D-S~~~loqFGJqJmKmK~~QUQhQy~~~~zT-D-Szzzz{{{ %)! 11333 %Z   tY33!$"566"&":'+'D!(Wdj A A#*3 DM#J#J")#y""="=#*3 DM#J#J),);+.+?#! ! & =0 0 0  ! ( (%)%<&*&>&*&>**      1 0s$I99 JJ ,J77 KK2AW:: XX6Cf99 gg=1q// q<;q<C y z*y==zK*AAM M AM8MAM3M3AM8NAN"N" AN1N0AN1O(CASS ASSASS B/AZ<V&AV7V6AZ<V7 AWWAZ<WAWWA:AZ<X?AYYAZ<Y AY'Y$AZ<Y&AY'Y'AAZ<Z< A[2["A[-[-A[2^%?A_%_% A_2_1A_2`>.Aa-a-AbbAbe *Af f AffAfg AggAg6g5Ag6iAiiAAj+j*Aj+j6Akk6AllAll 0Al<l< Am m Am p4AqqAAr3r2Ar3r?AAtt AttAttAt.t. Aut8AuuAuu#Avv AvvAvA B@)@) BA@3BAABAD'BD>D>.BE/E.BE/F4BG G BG;GBG6G6BG;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. rrnrorrkN)rrrrrrrrrrrrrrrkon_session_resetris rZreset_session_statezAIAgent.reset_session_states&%&!$%!%&"%&")*&)*&*+'()%!"*-'#, #) !" 4- . . 743J 7  # 4 4 6 6 6 6 6 7 7 7 7r\cr ddlm}|s |||}|dkr1|dvr-t|tr|rt jdd|}|j}|j}||_||_|p|j|_||_ t|dr|j |r||_ |dkrddlm} m} m} |d k} | r|p|j p | pdn |p|j pd} | |_ | |_|pt'|d d |_| | |jt+|j|j |_| r | | nd |_d |_i|_nq|p|j } |p|j}| |d|_t+|j|j}| ||jd<|t7|jdd|_|||j||\|_|_t|dr|jrddl m!}d } ddl"m#}m$}|}||}n#tJ$rd }YnwxYw||j|j|j |jt'|dd |}|j&|j||jt'|dd|j|j d |_'t|dr|jr|jnd }|j|j|j|j t'|ddt7|j|j|j|rt'|d|jn|j|rt'|d|jn|j|rt'|ddnd|rt'|d|jn|j|r|j(nd|r|j)ndd|_*|dkr-|j*+|j|j|jdd |_,d|_-|pd./|pd./tat'|d gpg}rrkrfd!|D}||_1|r|dnd |_2tgj4d"||||d S)#a]Switch the model/provider in-place for a live agent. Called by the /model command handlers (CLI and gateway) after ``model_switch.switch_model()`` has resolved credentials and validated the model. This method performs the actual runtime swap: rebuilding clients, updating caching flags, and refreshing the context compressor. The implementation mirrors ``_try_activate_fallback()`` for the client-swap logic but also updates ``_primary_runtime`` so the change persists across turns (unlike fallback which is turn-scoped). r)determine_api_moder) opencode-zen opencode-goz/v1/?$rrrrrrrNrFrr switch_modelTrr|rr}rrkr_)rrVr)rr{r|rarWr{)rrTrr{r|r}rrr|rqr{rcg|]C}|dpdhvA|DS)r|r)rrrj)rentrynew_normold_norms rZrz(AIAgent.switch_model..s]IIj))/R6688>>@@S[H\\\\\\r\z+Model switched in-place: %s (%s) -> %s (%s))5hermes_cli.providersr{rbrcr;rrr|rr}rrrr{rrrrrrorrrrrrrrrrrrkrr`rrrVrr rrTrr!r"rrrrjrrrrr)rX new_model new_providerr{rr}r{ old_model old_providerrrrr.r/r7 _sm_timeoutr`_sm_custom_providersrrV_sm_cfgnew_context_lengthrvfallback_chainrrs @@rZrzAIAgent.switch_model&sW <;;;;; B)),AAH , , , ???8S))@@viX66HJ }  $  1DM   4+ , , *  ! ' ' ) ) )  #"DL + + +          $0;#> \pVWW W8O8O8Q8QWUWw~xUCGCOxUSUM(DL&3D #'/']74AVX\3]3]D $%;%;t74T]DJOO&&&D "J^'h}'E'E'EchD $DK"$D  #3t|M%6N(*##D 7t}djQQK&1<#I.44T())%5DK  / /%! 0   @ $"? 4- . . 43J  E E E E E E$(  ,ZZZZZZZZ%+--'F'Fw'O'O$$ , , ,'+$$$ ,!9!9  &-d4Ld&S&S!5 """   # 0 0j1i44 1   &*"*17K)L)LrQUQhrd%%nrZ   tY33!$"566"&":'+'DEH XWdj A A AdjNQ#d73 DM#J#J#JW[WdAD"L'#y""="="="NQ#d73 DM#J#J#JW[Wd?B)I););CF+M3+?+?A! !  + + +  ! ( (%)%<&*&>&*&>**   $)  !&B--//5577 &B--//5577gd,=rBBHbII   X%9%9#1N .4BL~a00 9 |Y      sH<< I  I cd |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)rrr`ra)rXrkwargsrs rZ _safe_printzAIAgent._safe_printsU (5B B      $    DD s //forcerct|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. rFN_mute_post_response)ro_has_stream_consumersrr)rXrrrs rZ_vprintzAIAgent._vprints& 415 9 9  F 'S  F$)&)))))r\c|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. NTrF)rrorrrmAttributeErrorrar`)rXrs rZ_should_start_quiet_spinnerz#AIAgent._should_start_quiet_spinner sp > %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. rgrr-)rrroris rZ _should_emit_quiet_tool_messagesz(AIAgent._should_emit_quiet_tool_messages s5 O 7// 7j"--6 r\messagec ||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. Tr lifecyclez%status_callback error in _emit_statusexc_infoNrrrrr6rrXrs rZ _emit_statuszAIAgent._emit_status( s  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. Trwarnz&status_callback error in _emit_warningrNrrs rZ _emit_warningzAIAgent._emit_warning< s  LLDO6W66dL C C C C    D    V V$$VW55555 V V V EPT UUUUUU V V VrtaskrucL ||}n#t$rt|}YnwxYw|p |jj}t |dkr|dddz}|d|d|dS)z4Surface a compact warning for failed auxiliary work.Nru⚠ Auxiliary z failed: ) _summarize_api_errorrrc __class__rrrrdrr)rXrrudetails rZ_emit_auxiliary_failurezAIAgent._emit_auxiliary_failureM s ..s33FF   XXFFF 2CM299;; v;;  DSD\((**U2F CDCC6CCDDDDDs 44c t|ddpdt|ddpdt|ddpdt|ddpdt|ddpddS)zBReturn the live main runtime for session-scoped auxiliary routing.rrr|rr{r})rr|rr{r})roris rZ_current_main_runtimezAIAgent._current_main_runtimeX swT7B//52j"55;j"55;tY339rj"55;    r\c |jsdS ddlm}ddlm}m}|d|\}}||s:d}||_||t ddStt|d d }tt|d d }||||t|d dt|d d } | r'| |kr!td|d| dd|dd|dzd |jj} | | kr| } | } | |j_|jj} | r| | z |j_| rt%| | z dznd}d|d| dd| dd| dd| dd|d }||_||t d|| | | dSdS#t$rt&$r&}td |Yd}~dSd}~wwxYw)!aWarn at session start if the auxiliary compression model's context window is smaller than the main model's compression threshold. When the auxiliary model cannot fit the content that needs summarising, compression will either fail outright (the LLM call errors) or produce a severely truncated summary. Called during ``__init__`` so CLI users see the warning immediately (via ``_vprint``). The gateway sets ``status_callback`` *after* construction, so ``_replay_compression_warning()`` re-sends the stored warning through the callback on the first ``run_conversation()`` call. Nr)get_text_auxiliary_client)rgr`rK) main_runtimeu⚠ No auxiliary LLM provider configured — context compression will drop middle turns without a summary. Run `hermes setup` or set OPENROUTER_API_KEY.uLNo auxiliary LLM provider for compression — summaries will be unavailable.rrr{rr|)rr{rar|zAuxiliary compression model rhr,rizE required by Hermes Agent. Choose a compression model with at least rjzK context (set auxiliary.compression.model in config.yaml), or set auxiliary.compression.context_length to override the detected value if it is wrong.rzr3u⚠ Compression model (z ) context is z8 tokens, but the main model's compression threshold was z2 tokens. Auto-lowered this session's threshold to u tokens so compression can run. To make this permanent, edit config.yaml — either: 1. Use a larger compression model: auxiliary: compression: model: 2. Lower the compression threshold: compression: threshold: 0.02duAuxiliary compression model %s has %d token context, below the main model's compression threshold of %d tokens — auto-lowered session threshold to %d to keep compression working.z4Compression feasibility check failed (non-fatal): %s)r rrrrgr`rrrr6r7rcrorarkrrTrcrrr)rXrrgr`r aux_modelr aux_base_url aux_api_key aux_contextrL old_threshold new_thresholdmain_ctxsafe_pctrus rZr z,AIAgent._check_compression_model_feasibilityb ss'  Fo  H H H H H H         !: 9!7799!!! FI~Y~D -0)!!#&&&5wvz2>>??Lgfi<<==K22%#&-d4\^b&c&c z266 K {-CCC 6966!,L665M66.5 666   /@IY&&!* + ;H'8 2A%0+=CKR3 h 6#=>>>PR K < <%I < <6CR < <.6; < <-0)!!#&&&0!!     O'&b        LLF          sA,F;9D>F;;G5G00G5ct|dd}|r1|jr, |d|dS#t$rYdSwxYwdSdS)uRe-send the compression warning through ``status_callback``. During ``__init__`` the gateway's ``status_callback`` is not yet wired, so ``_emit_status`` only reaches ``_vprint`` (CLI). This method is called once at the start of the first ``run_conversation()`` — by then the gateway has set the callback, so every platform (Telegram, Discord, Slack, etc.) receives the warning. rNr)rorr)rXrs rZ_replay_compression_warningz#AIAgent._replay_compression_warning sd2D99  4'  $$[#66666        s4 AAc|t|}n/t|ddptt|dd}|dkS)z8Return True when a base URL targets OpenAI's native API.Nrvrruzapi.openai.com)rOro)rXrhostnames rZrzAIAgent._is_direct_openai_url s[  (22HHt%92>>BS/44CCH+++r\cx|"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. Nrurzopenai.azure.com)rcrjro)rXrurls rZrzAIAgent._is_azure_openai_url sE  h--%%''CC$ 1266<"C!S((r\ct|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_TIMEOUT @)rr|rrrr)rXcfgs rZ_resolved_api_call_timeoutz"AIAgent._resolved_api_call_timeout s<+4=$*EE ?JRY3V<<===r\ct|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)r@T)rr|rrrr)rXr env_timeouts rZ%_resolved_api_call_stale_timeout_basez-AIAgent._resolved_api_call_stale_timeout_base" sT) CC ?: i ?@@  "%%u, ,{r\r c<|\}}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.rrNrinfc3NK|] }tt|V!dSrgrdrcrrs rZrz.A s.77SVV777777r\順g@Pg |@)rrorr2rsumr)rXr  stale_baseuses_implicit_defaultr est_tokenss rZ!_compute_non_stream_stale_timeoutz)AIAgent._compute_non_stream_stale_timeout: s,0,V,V,X,X) )4d33Jt}J  X 2CH2M2M << 77h777771<   z5)) )   z5)) )r\c,t|jdS)z1Return True when the base URL targets OpenRouter.rrNruris rZrzAIAgent._is_openrouter_urlH s$T%9?KKKr\rc||n|jpd}||n|jpd}||n|jpd}||n|jpd}|} |} |} d| v} t |d} |dk}|o|dkpt |dk}|rdS| r| rd S|r| rdSd | v}| d v}|r|rd Sd S) uDecide whether to apply Anthropic prompt caching and which layout to use. Returns ``(should_cache, use_native_layout)``: * ``should_cache`` — inject ``cache_control`` breakpoints for this request (applies to OpenRouter Claude, native Anthropic, and third-party gateways that speak the native Anthropic protocol). * ``use_native_layout`` — place markers on the *inner* content blocks (native Anthropic accepts and requires this layout); when False markers go on the message envelope (OpenRouter and OpenAI-wire proxies expect the looser layout). Third-party providers using the native Anthropic transport (``api_mode == 'anthropic_messages'`` + Claude-named model) get caching with the native layout so they benefit from the same cost reduction as direct Anthropic callers, provided their gateway implements the Anthropic cache_control contract (MiniMax, Zhipu GLM, LiteLLM's Anthropic proxy mode all do). Qwen / Alibaba-family models on OpenCode, OpenCode Go, and direct Alibaba (DashScope) also honour Anthropic-style ``cache_control`` markers on OpenAI-wire chat completions. Upstream pi-mono #3392 / pi #3393 documented this for opencode-go Qwen. Without markers these providers serve zero cache hits, re-billing the full prompt on every turn. Nrr rrrr)TTTFqwen>alibabaopencoder}r|FF)r|rr}rrjrNrO)rXr|rr}r eff_provider eff_base_url eff_api_mode eff_model base_lower model_lowerprovider_lower is_claude is_openrouteris_anthropic_wireis_native_anthropic model_is_qwenprovider_is_alibaba_familys rZrz&AIAgent._anthropic_prompt_cache_policyL sJB%-$8dmRPR #+#7xxdm>Qr #+#7xxdm>Qr #/UUTZFB !'')) oo'' %++-- + -lOLL (,@@  h,f0A,0O0OSf0f   :  Y ;   :+- %38 & " & - ;|r\c|}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. rrr4zgpt-5)rjrsplitr)rms rZ_model_requires_responses_apiz%AIAgent._model_requires_responses_api sD KKMM !88a  $A||G$$$r\rc|pd}|dkr" ddlm}||S#t$rYnwxYwt |S)zCReturn True when this provider/model pair should use Responses API.rcopilotr)!_should_use_copilot_responses_api)rrjrrrrpr)rr|normalized_providerrs rZrz.AIAgent._provider_model_requires_responses_api s (~24466<<>> ) + + OOOOOO88???    44U;;;sA A Acb|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)rrrws rZ_max_tokens_paramzAIAgent._max_tokens_param sA  % % ' ' 44+D+D+F+F 4+U3 3e$$r\r cv|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_blocksrr)rXr cleaneds rZ_has_content_after_think_blockz&AIAgent._has_content_after_think_block s> 5**733GMMOO$$$r\c|sdStjdd|tjtjz}tjdd|tjtjz}tjdd|tjtjz}tjdd|tjtjz}tjdd|tjtjz}dD]8}tjd |d |d d|tjtjz}9tjd d|tjtjz}tjd d|tjtjz}tjdd|tj}tjdd|tj}|S)uRemove reasoning/thinking blocks from content, returning only visible text. Handles four cases: 1. Closed tag pairs (``…``) — the common path when the provider emits complete reasoning blocks. 2. Unterminated open tag at a block boundary (start of text or after a newline) — e.g. MiniMax M2.7 / NIM endpoints where the closing tag is dropped. Everything from the open tag to end of string is stripped. The block-boundary check mirrors ``gateway/stream_consumer.py``'s filter so models that mention ```` in prose aren't over-stripped. 3. Stray orphan open/close tags that slip through. 4. Tag variants: ````, ````, ````, ````, ```` (Gemma 4), all case-insensitive. Additionally strips standalone tool-call XML blocks that some open models (notably Gemma variants on OpenRouter) emit inside assistant content instead of via the structured ``tool_calls`` field: * ``…`` * ``…`` * ``…`` * ``…`` * ``…`` * ``…`` (Gemma style) Ported from openclaw/openclaw#67318. The ```` variant is boundary-gated (only strips when the tag sits at start-of-line or after punctuation and carries a ``name="..."`` attribute) so prose mentions like "Use in JavaScript" are preserved. rz.*?flagsz.*?z.*?z0.*?z.*?)rr tool_result function_callfunction_calls]*>.*?zd(?:(?<=^)|(?<=[\n\r.!?:]))[ \t]*]*\bname\s*=[^>]*>(?:(?:(?!).)*)zS(?:^|\n)[ \t]*<(?:think|thinking|reasoning|thought|REASONING_SCRATCHPAD)\b[^>]*>.*$z@\s*zP\s*)r;rDOTALL IGNORECASE)rXr _tc_names rZrzAIAgent._strip_think_blocks s> 2&.G29r}C\]]]&4b'UWUbIbccc&6G29WYWdKdeee&LbRYacajmomzaz{{{&2BrySUS`G`aaa=  Hf7X77H777i"-/ GG& 4  )bm+    & b  )bm+    & O  -    & _  -     r\c||sdS|}|sdS|drdS|ddvS)zCHeuristic: does visible assistant text look intentionally finished?Fz```Tr4u$.!?:)"']}。！？：）】」』》)rr>)r strippeds rZ_has_natural_response_endingz$AIAgent._has_natural_response_ending9 sX 5>>## 5   U # # 4|FFFr\c|jpd}|jpd}d|vr|dkrdSd|jvs d|jvrdSt |jot |jS)zHDetect the narrow backend family affected by Ollama/GLM stop misreports.rglmzaiFollamaz:11434T)rrjr|rurrr2)rXrrs rZ_is_ollama_glm_backendzAIAgent._is_ollama_glm_backendE sz'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.stoprFc3rK|]2}t|to|ddkV3dSrrNrrrs rZrz:AIAgent._should_treat_stop_as_truncated..Z sT   sD ! ! ?cggfoo&?      r\Nrr rz\s) r}rrrorbrcrrrdr;rr )rXrassistant_messager r  visible_texts rZ_should_treat_stop_as_truncatedz'AIAgent._should_treat_stop_as_truncatedO s& F " "dm7I&I&I5**,, 5   B      5  $0A>@@  5 |  r ! !5,)G)G !544\BBBBr\ user_messageassistant_contentcF td|DrdS||pd sdSt dkrdSt t jd }|sdSd}d}|pd t fd|Dpd vpd v}t fd |D}t fd |D} |s| o|S) zNDetect a planning/ack message that should continue instead of ending the turn.c3rK|]2}t|to|ddkV3dSrrrs rZrz=AIAgent._looks_like_codex_intermediate_ack..u s@WWsz#t$$BF)BWWWWWWr\Friu@\b(i['’]ll|i will|let me|i can do that|i can help with that)\b)z look intozlook atinspectscancheckanalyzreviewexplorereadopenruntestfixrrfind walkthroughz report back summarize) directoryzcurrent directoryz current dirrrepo repositorycodebaseprojectfolder filesystemz file treefilesrc3 K|]}|vV dSrgrw)rmarker user_texts rZrz=AIAgent._looks_like_codex_intermediate_ack.. s(DD)#DDDDDDr\z~/rc3 K|]}|vV dSrgrwrr7assistant_texts rZrz=AIAgent._looks_like_codex_intermediate_ack.. s('^'^V.(@'^'^'^'^'^'^r\c3 K|]}|vV dSrgrwr:s rZrz=AIAgent._looks_like_codex_intermediate_ack.. s9* * )/Fn $* * * * * * r\)rrrrjrdrr;r) rXrrr has_future_ackaction_markersworkspace_markersuser_targets_workspaceassistant_mentions_actionassistant_targets_workspacer;r8s @@rZ"_looks_like_codex_intermediate_ackz*AIAgent._looks_like_codex_intermediate_ackn s WWhWWW W W 5112C2IrJJPPRRXXZZ 5 ~   % %5 IY[i j j   5 *  "'R..006688 DDDD2CDDD D D y  i  %('^'^'^'^~'^'^'^$^$^!&)* * * * 3D* * * ' ' #'E*EdKddr\c~g}t|dr!|jr||jt|dr*|jr#|j|vr||jt|dr|jr|jD]}t |t ro|dp>|dp)|dp|d}|r||vr||t|dd}|st |trk|rid }|D]d}tj tj z}tj ||| D]1} | } | r| |vr|| 2e|rd |SdS) ay Extract reasoning/thinking content from an assistant message. OpenRouter and various providers can return reasoning in multiple formats: 1. message.reasoning - Direct reasoning field (DeepSeek, Qwen, etc.) 2. message.reasoning_content - Alternative field (Moonshot AI, Novita, etc.) 3. message.reasoning_details - Array of {type, summary, ...} objects (OpenRouter unified) Args: assistant_message: The assistant message object from the API response Returns: Combined reasoning text, or None if no reasoning found reasoningreasoning_contentreasoning_detailssummarythinkingr rN)(.*?)z(.*?)z(.*?)z(.*?)z2(.*?)r )rrErrFrGrbrrrorcr;rr findallrr) rXrreasoning_partsrrHr inline_patternspatternrblockrs rZ_extract_reasoningzAIAgent._extract_reasoning s" $k 2 2 @7H7R @  " "#4#> ? ? ? $&9 : : L?P?b L 2/II&&'8'JKKK $&9 : : 8?P?b 8+= 8 8fd++ 8 9--.!::j11.!::i00."::f--  87/#A#A'..w777 +Y== 8:gs#;#; 8 8O+ 8 8 BM1ZFFF88E#kkmmG87/#A#A'..w7778  0;;// /tr\task_idc t|r |jrtjd|dnt |n8#t $r+}|jrtjd|d|Yd}~nd}~wwxYw t|dS#t $r2}|jr tjd|d|Yd}~dSYd}~dSd}~wwxYw)aHClean up VM and browser resources for a given task. Skips ``cleanup_vm`` when the active terminal environment is marked persistent (``persistent_filesystem=True``) so that long-lived sandbox containers survive between turns. The idle reaper in ``terminal_tool._cleanup_inactive_envs`` still tears them down once ``terminal.lifetime_seconds`` is exceeded. Non-persistent backends are torn down per-turn as before to prevent resource leakage (the original intent of this hook for the Morph backend, see commit fbd3a2fd). z0Skipping per-turn cleanup_vm for persistent env z; idle reaper will handle it.zFailed to cleanup VM for task : Nz#Failed to cleanup browser for task )rrrrrrr7r)rXrRrAs rZ_cleanup_task_resourceszAIAgent._cleanup_task_resources sU Q )) $'M77777 7### Q Q Q# Q O O OA O OPPP Q V G $ $ $ $ $ V V V# V Tg T TQR T TUUUUUUUUU V V V V V V Vs/>A A6 !A11A6:B C!CCuReview the conversation above and consider saving to memory if appropriate. Focus on: 1. Has the user revealed things about themselves — their persona, desires, preferences, or personal details worth remembering? 2. Has the user expressed expectations about how you should behave, their work style, or ways they want you to operate? If something stands out, save it using the memory tool. If nothing is worth saving, just say 'Nothing to save.' and stop.uReview the conversation above and consider whether a skill should be saved or updated. Work in this order — do not skip steps: 1. SURVEY the existing skill landscape first. Call skills_list to see what you have. If anything looks potentially relevant, skill_view it before deciding. You are looking for the CLASS of task that just happened, not the exact task. Example: a successful Tauri build is in the class "desktop app build troubleshooting", not "fix my specific Tauri error today". 2. THINK CLASS-FIRST. What general pattern of task did the user just complete? What conditions will trigger this pattern again? Describe the class in one sentence before looking at what to save. 3. PREFER GENERALIZING AN EXISTING SKILL over creating a new one. If a skill already covers the class — even partially — update it (skill_manage patch) with the new insight. Broaden its "when to use" trigger if needed. 4. ONLY CREATE A NEW SKILL when no existing skill reasonably covers the class. When you create one, name and scope it at the class level ("react-i18n-setup", not "add-i18n-to-my-dashboard-app"). The trigger section must describe the class of situations, not this one session. 5. If you notice two existing skills that overlap, note it in your response so a future review can consolidate them. Do not consolidate now unless the overlap is obvious and low-risk. Only act when something is genuinely worth saving. If nothing stands out, just say 'Nothing to save.' and stop.uReview the conversation above and consider two things: **Memory**: Has the user revealed things about themselves — their persona, desires, preferences, or personal details? Has the user expressed expectations about how you should behave, their work style, or ways they want you to operate? If so, save using the memory tool. **Skills**: Was a non-trivial approach used to complete a task that required trial and error, changing course due to experiential findings, or a different method or outcome than the user expected? If so, work in this order: a. SURVEY existing skills first (skills_list, then skill_view on candidates). b. Identify the CLASS of task, not the specific task ("desktop app build troubleshooting", not "fix my Tauri error"). c. PREFER UPDATING/GENERALIZING an existing skill that covers the class. d. ONLY CREATE A NEW SKILL if no existing one covers the class. Scope at the class level, not this one session. e. If you notice overlapping skills during the survey, note it so a future review can consolidate them. Only act if there's something genuinely worth saving. If nothing stands out, just say 'Nothing to save.' and stop.review_messagesprior_snapshotc>t}t}|pgD]}t|tr|ddkr1|d}|r||^|d}t|t r||g}|pgD]V}t|tr|ddkr2|d}|r||vrN|s/|d} t| t r| |vr t j|dd} n#t jtf$rYwxYwt| tr| ds| dd} | d d} d | vr| | Id | vr| | vd | vs| rBd | vr,| dkrdn | dkrdn| } | | dd| vr,| dkrdn | dkrdn| } | | dd| vsd| vr*| dkrdn | dkrdn| } | | dX|S)aSBuild the human-facing action summary for a background review pass. Walks the review agent's session messages and collects "successful tool action" descriptions to surface to the user (e.g. "Memory updated"). Tool messages already present in ``prior_snapshot`` are skipped so we don't re-surface stale results from the prior conversation that the review agent inherited via ``conversation_history`` (issue #14944). Matching is by ``tool_call_id`` when available, with a content-equality fallback for tool messages that lack one. rr tool_call_idr r(successrrrcreatedupdatedaddedrr2Memoryuserz User profilez updatedz Entry addedremovedreplaced) rrbrrrrcrrr9r:rjr)rVrWexisting_tool_call_idsexisting_tool_contentspriortcidr actionsr content_strrerrlabels rZ$_summarize_background_review_actionsz,AIAgent._summarize_background_review_actionsS sk "%!$#)r 8 8EeT** eii.?.?6.I.I99^,,D 8&**40000))I..gs++8*..w777"(b 3 3Cc4(( CGGFOOv,E,E77>**D  666 !ggi00 k3//KCY4Y4Y z#'')T":":;;()4    dD)) )1D1D hhy"--GXXh++FGMMOO++w''''gmmoo--w''''GMMOO+++5GMMOO;S;S$*h$6$6fX^N^N^NNdj%1112222'))$*h$6$6fX^N^N^NNdj%1112222gmmoo--w}}1N1N$*h$6$6fX^N^N^NNdj%111222s(E..FFmessages_snapshot review_memory review_skillscddl}|r |rjn|rjnjfd}|j|dd}|dS)aSpawn a background thread to review the conversation for memory/skill saves. Creates a full AIAgent fork with the same model, tools, and context as the main session. The review prompt is appended as the next user turn in the forked conversation. Writes directly to the shared memory/skill stores. Never modifies the main conversation history or produces user-visible output. rNcddl}d} ttjd5}||5||5 }t jdd j j | dpd| dpd| dpdt dd j }d |_d |_ j|_ j|_ j|_d|_d|_|  dddn #1swxYwYdddn #1swxYwYdddn #1swxYwY t|d g}|rnd t0|} d| j}|r |d|n#t8$rYnwxYwnH#t8$r;}t:d| d|Yd}~nd}~wwxYw|N | n#t8$rYnwxYw |!dS#t8$rYdSwxYwdS#|L | n#t8$rYnwxYw |!w#t8$rYwwxYwwxYw)NrwrTr}rr{r) rrrrgr|r}rr{r$rbackground_review)rconversation_historyru · u 💾 u💾 z)Background memory/skill review failed: %szbackground review)" contextlibr'rdevnullredirect_stdoutredirect_stderrrrprrgr|rrorrrrrrrrrun_conversationrirrfromkeysrrrr6r7rshutdown_memory_providerclose) rr review_agent_devnull_parent_runtimerfrH_bg_cbrArjpromptrXs rZ _run_reviewz5AIAgent._spawn_background_review.._run_review sw    LO "*c**#h//99##//99##'+&@&@&B&BO#*"j'(#'!%!%!0!4!4Z!@!@!HD!0!4!4Z!@!@!HD / 3 3I > > F$(/6H$(O(O*./ $ $ $L9LL59LL6151CL.373GL09=9SL6:;L79:L6 11%+->2A#############################################VCCL*=rBB% !$kk$--*@*@AAG$$%8w%8%8999!=I>J J&%J&+K;/KK; KK;KK;K*)K;* K74K;6K77K;Tz bg-review)rrrp)r_COMBINED_REVIEW_PROMPT_MEMORY_REVIEW_PROMPT_SKILL_REVIEW_PROMPTrr)rXrjrkrlrrrDr~s`` @rZ_spawn_background_reviewz AIAgent._spawn_background_review s   /] /1FF  //FF.FR R R R R R R h I K; O O O  r\) write_originexecution_contextrRrYrrrYc|pt|dd|pt|dd|jpd|jpd|jptjdddd }|r||d <|r||d <d |DS) z?Build provenance metadata for external memory-provider mirrors.rr'rr(rr,r-r2)rrrrrgrrRrYc"i|] \}}|dv || S)rtrwrs rZrz8AIAgent._build_memory_write_metadata.. s(IIIAQj5H5H15H5H5Hr\)rorrrgrrrr)rXrrrRrYmetadatas rZ_build_memory_write_metadataz$AIAgent._build_memory_write_metadata s)cGD:PRb,c,c!H4!8,GG//R!%!8!>B W8OQV)W)W! $ $   *")HY   4'3H^ $II!1!1IIIIr\ct|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. rNrrrr_r )rordrbrr)rXr roverriders rZ$_apply_persist_user_message_overridez,AIAgent._apply_persist_user_message_override sd7>>4!A4HH  s{ F  # # # #c(mm # # # # # #3-C#t$$ *F)B)B!)I $ # * *)B)Br\rqc||||_|||||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)rr_save_session_log_flush_messages_to_session_db)rXr rqs rZ_persist_sessionzAIAgent._persist_session, sQ 11(;;;!) x((( **85IJJJJJr\c|jsdS|| |j|j|jpd|j|rt |nd}t||j}||dD]}| dd}| d}d}t|dr3t|j tr|j rd |j D}n0t| dtr|d}|j|j||| d || d | d |d kr| dnd|d kr| dnd|d kr| dnd|d kr| dnd|d kr| 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). Nr-)r.rrrror rc@g|]}|jj|jjdS)rpr)rrprrs rZrz9AIAgent._flush_messages_to_session_db..P s:'''"$!1 @UVV'''r\rrYr assistantrErFrGcodex_reasoning_itemscodex_message_items) rrr rrrYrrErFrGrrz$Session DB append_message failed: %s)rrensure_sessionrrgrrdrrrrrbrrappend_messagerr6r7) rXr rq start_idx flush_fromrrr tool_calls_datarAs rZrz%AIAgent._flush_messages_to_session_db6 s  F 11(;;;& F   + +}-j ,    6JP0111qIY(ABBJ ,  wwvy11''),,"&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 FsHH&& I0IIc|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) Nrr4rr)r=rdrcopy)rXr last_assistant_idxr!s rZ"_get_messages_up_to_last_assistantz*AIAgent._get_messages_up_to_last_assistanth s I"s8}}q("b11  A{v&&+55%&"6  %==?? "+++,,r\c|jsdSg}|jD]T}|d}|d|dd|didd}||Utj|d S) z Format tool definitions for the system message in the trajectory format. Returns: str: JSON string representation of tool definitions z[]rrp descriptionr parametersN)rprrrequiredF ensure_ascii)rRrrrr8)rXformatted_toolsrfuncformatted_tools rZ _format_tools_for_system_messagez(AIAgent._format_tools_for_system_message sz 4J 3 3D #DV #xx r::"hh|R88 N  " "> 2 2 2 2z/>>>>r\ user_query completedcg}d|d}|d|d|d|dd}|t|kr||}|ddkrd |vr-|d r$d }|d r&|d r d |d d }|dr5|dr|t |ddzz }|d D]} | rt | ts t | ddtr tj | ddn | dd} nB#tj $r0tj d| ddddi} YnwxYw| dd| d} |dtj| ddz }d|vrd|z}|d|dg} |dz} | t|kr8|| ddkr%|| }d}|d} |d rtj |}n#tj t"f$rYnwxYwt| }|t|d kr|d |ddnd!}|tj|d"d ||d#dz }|d$z }| || dz } | t|kr|| ddk%| r0|dd| d| dz }nd }|d r&|d r d |d d }|dpd }|t |z }d|vrd|z}|d|dn*|dd%kr|d|dd|dz }|t|k|S)&ay Convert internal message format to trajectory format for saving. Args: messages (List[Dict]): Internal message history user_query (str): Original user query completed (bool): Whether the conversation completed successfully Returns: List[Dict]: Messages in trajectory format aYou are a function calling AI model. You are provided with function signatures within XML tags. You may call one or more functions to assist with the user query. If available tools are not relevant in assisting with user query, just respond in natural conversational language. Don't make assumptions about what values to plug into functions. After calling & executing the functions, you will be provided with function results within XML tags. Here are the available tools: a For each function call return a JSON object, with the following pydantic model json schema for each: {'title': 'FunctionCall', 'type': 'object', 'properties': {'name': {'title': 'Name', 'type': 'string'}, 'arguments': {'title': 'Arguments', 'type': 'object'}}, 'required': ['name', 'arguments']} Each function call should be enclosed within XML tags. Example: {'name': ,'arguments': } ri)fromrhumanrrrrrrEz z r  rrz2Unexpected invalid JSON in trajectory conversion: Nrzrprz Frz z gptrz )r/r1rorY)rYrpr z r_)rrrdrrrJrbrrcrrr9rr7r8rrrr)rXr rr trajectory system_msgr!rr rrtool_call_jsontool_responsesjtool_msg tool_response tool_content tool_indexr raw_contents rZ_convert_to_trajectory_formatz%AIAgent._convert_to_trajectory_format s!  f ==?? f f f             #h--1+C6{k))3&&3|+<&!Gww{++MK0@0F0F0H0HM"Lc+.>"L"L"Lwwy))Vc)n.B.B.D.DV #>s9~#N#NQU#UU&)%6tt (U 9d0K0KUX+Zdenoyez|GfHJM[N[N)v 9Z3H3U(V(V(VT]^hTijuTvII#3+++$O-LajkuavxCbDEIFIEIbJ-L-LMMM(*III +%.j$9&$A)2** #s4:n[`3a3a3a#s#s#ss!//"7'"A%% %!(!1!1'' &(NAAc(mm++ F0Cv0M0M#+A;(; (0 ': !+1133>>zJJH/3z,/G/G $ 4nE!!! D!&)%8%8  *CL0A,B,BBB -j9*EfMM!*" &,4LL,L,L$-'355). */*/*// &)== &--m<<<Q5c(mm++ F0Cv0M0M:&""))$*%)YY~%>%>++E !Gww{++MK0@0F0F0H0HM"Lc+.>"L"L"L#&i."6BK:;GGGG!//"7'"A%% %!('' V&&!!# ^## FAi#h--ls%.AE>> tag instead of dumping raw HTML. Falls back to a truncated str(error) for everything else. z ]*>([^<]+)rz!HTML error page (title not found)z2Cloudflare Ray ID:\s*]*>([^<]+)N status_codezHTTP zRay u — bodyrrrTr,) rcr;rr rrrorrrbrr) rrrtitlerayray_idrrrrprefixs rZrzAIAgent._summarize_api_errorSs %jj #  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)%%%r\rcb|sdSt|dkrdS|ddd|ddS)Nrz***rrrrd)rXrs rZ_mask_api_key_for_logszAIAgent._mask_api_key_for_logs{sG 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> 3$*LLNN!kk),,P >O 6:W#<#<&5 # G # #e****,,K 7%0#%6 " W $ $kk),,2G'3'' V i(Z\cegerss  V!+"3"3A"6"677E0;0A0A!0D0D0J0J0L0LPT0T0TefnnZ_G*.)++*?GJ'' " Z !!I !V.2ikkE)//RSBTBT>GG*&II%$I%rc|dSt|dd}|sdSddlm}t||j|j}||}|dd|j|d<|j|d<|S) zLToken buckets for ``post_api_request`` plugins (no raw ``response`` object).Nusager)asdictr|r} raw_usage prompt_tokens total_tokens) ro dataclassesrr@r|r}poprr)rXrrrcurHs rZ#_usage_summary_for_api_request_hookz+AIAgent._usage_summary_for_api_request_hooks  4Hgt44  4&&&&&& Y W W W&** K&&&#%#3 "$/r\)r api_kwargsrc  tj|}|ddd|D}d} t |jdd}n2#t $r%}td|Yd}~nd}~wwxYwtj |j |d|j d|jdkrd nd d ||d d |dd}|t#|jt'|d}dD]} t || d} | | || <t |dd} | | |d<t |dd} | R t | dd|d<| j|d<n2#t $r%}td|Yd}~nd}~wwxYw||d<tj d} |jd|j d| dz }|t1j|ddt&d !||jd"|t9d#r*t;t1j|ddt&|S#t $r)}|jrt?j d$|Yd}~dSd}~wwxYw)%a Dump a debug-friendly HTTP request record for the active inference API. Captures the request body from api_kwargs (excluding transport-only keys like timeout). Intended for debugging provider-side 4xx failures where retries are not useful. rNci|] \}}||| Srgrwrs rZrz3AIAgent._dump_api_request_debug..sCCCTQQ]Aq]]]r\r{z,Could not extract API key for debug dump: %sPOSTrrz /responsesz/chat/completionszBearer zapplication/json) Authorizationz Content-Type)methodrr=r) timestamprrr)rr)r request_idrparamrrrrresponse_status response_textz,Could not extract error response details: %srz%Y%m%d_%H%M%S_%f request_dump_rEr&Fr)rindentdefaultutf-8encodingu$🧾 Request debug dump written to: HERMES_DUMP_REQUEST_STDOUTz*Failed to dump API request debug payload: )!rdeepcopyrrrorrr6rr r isoformatrrrr}rrrrrcrrr write_textrr8rrrPrrrr7)rXrrrrr{rA dump_payload error_info attr_name attr_value body_attr response_objr dump_file dump_errors rZ_dump_api_request_debugzAIAgent._dump_api_request_debugsB =,,D HHY % % %CCTZZ\\CCCDG P!$+y$?? P P P KQOOOOOOOO P&\^^5577"o $"m22377GZkIkIkrEGG)Y43N3Nw3W3W)Y)Y(:  ! , ,L  KK0"5zz.. "X;;I!( 4!@!@J!-0: 9-#E6488 ()2Jv&&uj$?? +X8? m]a8b8b #456B6G ?33$XXX %SUVWWWWWWWWX)3 W% //0BCCI (Z(Z(Z)(Z(Z(ZZI   )z\n\1z ()\n+z\1\n)rJr;rr)r s rZ_clean_session_contentzAIAgent._clean_session_content?sS N-g66&'7;;&)7G<<}}r\c <|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. Nrrr rr message_countr zHSkipping session log overwrite: existing has %d messages, current has %dr) rrrrgr last_updated system_promptrRrr r)rrzFailed to save session log: )rrrr rrexistsrr read_textrdrrrrrrrgrrr rrrRrMrcrr7)rXr rrrexisting_countrrAs rZrzAIAgent._save_session_logIs5t5  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) TNFrrz0Failed to propagate interrupt to child agent: %su ⚡ Interrupt requested(z: 'z...''r)rrr_set_interruptrrorrrr interruptr6rrrrd) rXr_tracker _tracker_lock _worker_tids_wtid children_copychildrAs rZrzAIAgent.interrupts0%)!")  $ 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.FNrrr) rrrrrrorrr)rXrrrr _steer_locks rZclear_interruptzAIAgent.clear_interrupts$)!"&05-  $ 0 5$"; < < <4!7>>&A4HH  M$= . .#H~~  . . . . . . . . . . . . . . .%  "5%0000 D d$94@@  " + +&*# + + + + + + + + + + + + + + + + + + # "s6A66A:=A:B B$#B$<CCCrcB|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. FrNrrT)rror)rXrrrrs rZsteerz AIAgent.steers$ 4::<< 5**,,3T:: =t%5t<>E 99*9.2.AD.H:.U++.8+ 999999999999999 #4)94@@HP&`x$'C'CV`# F3z33#J/33IrBB*C00 H P3CK./// vv}}GGHHH28$Y// P P P5E2Ov2O2O$Y/// P/?.GHZ  + G  OO tt Z3)>)>B G     s%;"C))C-0C-AFF54F5desccDtj|_||_dS)zAUpdate the last-activity timestamp and description (thread-safe).N)rrr)rXr2s rZ_touch_activityzAIAgent._touch_activitycs!%#'   r\ http_responsec|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``. Nr=r)parse_rate_limit_headersr)roagent.rate_limit_trackerr7r|rr)rXr5r=r7states rZ_capture_rate_limitszAIAgent._capture_rate_limitshs  F-D99  F  I I I I I I,,Wt}MMME ).&&&!     DD s!A A Ac|jS)z1Return the last captured RateLimitState, or None.)rris rZget_rate_limit_statezAIAgent.get_rate_limit_state{s %%r\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) rrrroundrrrrrr)rXelapseds rZget_activity_summaryzAIAgent.get_activity_summarysc )++ 66 $ 6"&":&+GQ&7&7 ."2"105/9   r\ch|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. rkrN)ron_session_endr shutdown_allrrkrrXr s rZrxz AIAgent.shutdown_memory_providers!    $33HNCCCC     $113333     4- . . 43J  '66O)rN         s/& 33A AA9$B B-,B-ct|jsdS |j|pgdS#t$rYdSwxYw)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.N)rrIrrKs rZcommit_memory_sessionzAIAgent.commit_memory_sessions\ #  F   / /B ? ? ? ? ?    DD s ) 77original_user_messagefinal_response interruptedc|rdS|jr|r|sdS |j|||j|dS#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. N)rsync_allqueue_prefetch_allr)rXrNrOrPs rZ_sync_external_memory_for_turnz&AIAgent._sync_external_memory_for_turnsB   F$  t;jdpd}t?||}|r||ddl m!}|}d|"d}j#rj$r |dj$z }jr |djz }j%r |dj%z }||j%d krQd!jvr j&d!d"nj}|d#|d$jd%tO}|r||j(pd )}|tTvr |tT|d&d'|DS)(a; Assemble the full system prompt from all layers. Called once per session (cached on self._cached_system_prompt) and only rebuilt after context compression events. This ensures the system prompt is stable across all turns in a session, maximizing prefix cache hits. FTr2r skill_manager)rMalwaysrOon)falsenevernooffrc3nK|]/}t|t|vV0dSrg)rbrcrjrprs rZrz/AIAgent._build_system_prompt..sA__1JWXZ]L^L^_aggii;6______r\c3 K|]}|vV dSrgrwrts rZrz/AIAgent._build_system_prompt..s(TT1a;.TTTTTTr\geminigemmarcodexNr_c3*K|] }|jvVdSrg)r)rrprXs rZrz/AIAgent._build_system_prompt..s+wwtt'<<wwwwwwr\)rrrlch|]}||Srwrw)rtoolsets rZrz/AIAgent._build_system_prompt..s0 r\c34K|]}t|VdSrg)r)rrs rZrz/AIAgent._build_system_prompt..s<  8A(33      r\)available_toolsavailable_toolsetsrl)r skip_soulr)rzConversation started: z%A, %B %d, %Y %I:%M %pz Session ID: z Model: z Provider: rrr4z#You are powered by the model named z. The exact model ID is zt. When asked what model you are, always answer based on this information, not on any model name returned by the API.rKc3fK|],}||V-dSrgrrrus rZrz/AIAgent._build_system_prompt..s7HHaggiiH17799HHHHHHr\)+rr:r$rrr&r'r(rr)rrbrcrjrrrr<r;r=r>rrformat_for_system_promptrrbuild_system_promptrr7rrr8 hermes_timerrrrr|rr9rgrr%)rXrj _soul_loaded _soul_content prompt_parts tool_guidancenous_subscription_prompt_enforce_inject _model_lower mem_block user_block_ext_mem_blockhas_skills_toolsavail_toolsets skills_prompt _context_cwdcontext_files_prompt _hermes_nowrtimestamp_line _model_short _env_hints platform_keyrs` @rZ_build_system_promptzAIAgent._build_system_promptxso$ & $(NNM $ - #  423L t, , ,   1 1 1 t4 4 4  !8 9 9 9 T2 2 2   1 1 1  9    7 7 8 8 8#A$BW#X#X # :    8 9 9 9   I1HG4Jx$=$=(..BRBRVuBuBuU""z(C'@'@"X^^EUEUYxExExHd++ U#z/R6688 _________ $z/R6688 TTTT8STTTTT I##$ABBB $ 0b7799 |++w,/F/F ''(IJJJL((G|,C,C ''(GHHH  %    / / /   4# 3 .GGQQ 3 '' 222) 4!/HHPP 4 '' 333    !%!5!I!I!K!K!8 ''777    wwwwIvwwwww    EIEZ   N7 $ 5#1MM M  /    . . .& : 9^44<L#= L$:$:$: # :##$8999222222kmmZ#,,?W2X2XZZ   ADO A @t@@ @N : 7 6$*66 6N = = l>>)->>>   -..  ,    + + + +2244::<< > ) )   | < = = ={{HHlHHHHHHs80L)) L65L6ct|tr|ddpdSt|ddpdS)z8Extract call ID from a tool_call entry (dict or object).r r)rbrrro)rs rZ_get_tool_call_id_staticz AIAgent._get_tool_call_id_static#sF b$   *66$##)r )r4$$**r\>rr_rirr developercH g}|D]V}|d}|tjvrtd|A||W|}t }|D]f}|ddkrK|dpgD]3}t|}|r||4gt }|D]G}|ddkr,|d}|r||H||z r6 fd|D}tdt ||z }|rg} |D]}| ||ddkrQ|dpgD]9}t|}||vr| dd |d :| }td t||S) u Fix orphaned tool_call / tool_result pairs before every LLM call. Runs unconditionally — not gated on whether the context compressor is present — so orphans from session loading or manual message manipulation are always caught. rz9Pre-call sanitizer: dropping message with invalid role %rrrrrYctg|]4}|ddkr|dv2|5SrrrYr)rrorphaned_resultss rZrz2AIAgent._sanitize_api_messages..SsOf //AEE.4I4IM]4]4]4]4]4]r\z6Pre-call sanitizer: removed %d orphaned tool result(s)u2[Result unavailable — see context summary above]rr rYz0Pre-call sanitizer: added %d stub tool result(s)) rrp_VALID_API_ROLESr6rrrrrrd) r filteredrrsurviving_call_idsrcidresult_call_idsmissing_resultspatchedrs @rZ_sanitize_api_messageszAIAgent._sanitize_api_messages,s ! !C776??D7333 O OOC "%%% 4 4Cwwv+--'',//5244B!::2>>C4*..s333"uu - -Cwwv&((ggn---#'',,,+-??  #H LLH$%%    ->  ,.G  s###776??k11!ggl339r%>>rBB/11#NN(.+_03,, H LLBO$$   r\rcDddlm}|}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_taskrNrrs rZrz3AIAgent._cap_delegate_task_calls..~s1[[2r{7G?7Z7ZQ7Z7Z7Z7Z[[r\rrzUTruncated %d excess delegate_task call(s) to enforce max_concurrent_children=%d limit)tools.delegate_toolrrrrprr6r7)rr max_childrendelegate_countkept_delegates truncatedrs rZ_cap_delegate_task_callsz AIAgent._cap_delegate_task_callsrs EDDDDD3355 [[[[[[[ \ ) )   % %B{?22!L00$$R((("a'N  $$$$ / \ )<   r\cLt}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) rrrprrrr6r7rd)rseenuniquerrs rZ_deduplicate_tool_callszAIAgent._deduplicate_tool_callssEE T TB;#R[%:;C$  b!!!!@"+BRSSSSVs:66vvJFr\rcddlddlm}|sdSdtdtfd}dtdtffd }dtdtdzfd}|}||jvr|S||}||jvr|S|||||h}t d D]x} t} |D]`} || } | rQ| | | || | || a|| z}y|D]} | r | |jvr| cS|||jd d } | r| dSdS) aAttempt to repair a mismatched tool name before aborting. Models sometimes emit variants of a tool name that differ only in casing, separators, or class-like suffixes. Normalize aggressively before falling back to fuzzy match: 1. Lowercase direct match. 2. Lowercase + hyphens/spaces -> underscores. 3. CamelCase -> snake_case (TodoTool -> todo_tool). 4. Strip trailing ``_tool`` / ``-tool`` / ``tool`` suffix that Claude-style models sometimes tack on (TodoTool_tool -> TodoTool -> Todo -> todo). Applied twice so double-tacked suffixes like ``TodoTool_tool`` reduce all the way. 5. Fuzzy match (difflib, cutoff=0.7). See #14784 for the original reports (TodoTool_tool, Patch_tool, BrowserClick_tool were all returning "Unknown tool" before). Returns the repaired name if found in valid_tool_names, else None. rN)get_close_matchessrxcz|ddddS)N-rEr)rjreplace)rs rZ_normz(AIAgent._repair_tool_call.._norms07799$$S#..66sC@@ @r\cLjdd|S)Nz(?._camel_snakes&26,c155;;== =r\c|}dD]D}||r-|dt| dcSEdS)N)_toolz-toolrz_-)rjr>rdr)rlcsuffixs rZ_strip_tool_suffixz5AIAgent._repair_tool_call.._strip_tool_suffixsgB4 : :;;v&&:^F |^,33D99999:4r\rrgffffff?)r"cutoff) r;difflibrrcrjrr=rr)rXrrrrrlowered normalizedcandsrEextracr matchesr;s @rZ_repair_tool_callzAIAgent._repair_tool_calls*  ------ 4 AS AS A A A A >C >C > > > > > > # #*    //## d+ + +NU9%% . . . %gz<< ;R;RSq  A!eeE 6 6--a006IIh'''IIeeHoo...IIll844555 UNEE  A Q$///$#GT-BaPSTTT  1: tr\cXd|_|jr|jdSdS)z Invalidate the cached system prompt, forcing a rebuild on the next turn. Called after context compression events. Also reloads memory from disk so the rebuilt prompt captures any writes from this session. N)rrrris rZ_invalidate_system_promptz!AIAgent._invalidate_system_prompts<&*"   0   - - / / / / / 0 0r\rrrindexc$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)rrrs rZrBzAIAgent._deterministic_call_ids,GYFFFr\raw_idc t|S)z8Split a stored tool id into (call_id, response_item_id).)_codex_split_responses_tool_id)rs rZrCz AIAgent._split_responses_tool_ids.f555r\call_idresponse_item_idc"t||S)zCBuild a valid Responses `function_call.id` (must start with `fc_`).)(_codex_derive_responses_function_call_id)rXrrs rZrAz*AIAgent._derive_responses_function_call_ids 8AQRRRr\cJtj}|jd|jS)Nr-)rcurrent_threadrpident)rXthreads rZ_thread_identityzAIAgent._thread_identity s()+++.. ...r\ct|dd}t|dd}t|dd}d|d|d|d|S) Nr|rorrzthread= provider=z base_url=z model=)ror)rXr|rrs rZ_client_log_contextzAIAgent._client_log_contexts}4Y774Y77gy11 1d++-- 1 1 1 1  1 1). 1 1 r\c`t|dd}|tj}||_|S)Nr)rorrr)rXlocks rZ_openai_client_lockzAIAgent._openai_client_locks2t^T22 <?$$D $D  r\rcddlm}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.mockrrbrocallabler)rris_closed_attr http_clients rZ_is_openai_client_closedz AIAgent._is_openai_client_closed!s '&&&&& fd # # 5 d;;  %'' !>## 4 n%% tfi66  " [%@@AA Aur\c ddl}ddl}|j|jdfg}t |drg||j|jdf||j|jdf||j|j dfn2t |dr"||j|j dft|}| | || S#t$rYdSwxYw) Nrr TCP_KEEPIDLEr1rJ TCP_KEEPALIVE)socket_options) transportr)httpxsocket SOL_SOCKET SO_KEEPALIVErr IPPROTO_TCPr TCP_KEEPINTVL TCP_KEEPCNTrrClient HTTPTransportr)r_httpx_socket _sock_opts_proxys rZ_build_keepalive_http_clientz$AIAgent._build_keepalive_http_client?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 rrrcddlm}m}t|}|||d|jdks6t |dddr?ddlm }|di|}t d||| |S|jd ks6t |ddd r]dd l m}d |D} |di| }t d ||| |S|jdkrddlm} m} t |ddpd} | | rwd|D} d| vr|| } | | | d<| di| }t d||| |Sd|vr0||dd} | | |d<t)di|}t d||| |S)Nr)_validate_base_url_validate_proxy_env_urlsrrrr)CopilotACPClientz-Copilot ACP client created (%s, shared=%s) %szgoogle-gemini-clizcloudcode-pa://)GeminiCloudCodeClientc"i|] \}}|dv || S)>r{rr project_idrrwrs rZrz1AIAgent._create_openai_client..ts4A[[[1[[[r\z:Gemini Cloud Code Assist client created (%s, shared=%s) %srw)GeminiNativeClientis_native_gemini_base_urlc"i|] \}}|dv || S)>r{rrrrrwrs rZrz1AIAgent._create_openai_client..s4!Q```q```r\rz/Gemini native client created (%s, shared=%s) %sz(OpenAI client created (%s, shared=%s) %srw)rr r rrr|rcragent.copilot_acp_clientr r6rragent.gemini_cloudcode_adapterr ragent.gemini_native_adapterrrrr )rXrrrrr r r rr  safe_kwargsrrrkeepalive_https rZrzAIAgent._create_openai_clientXs:WWWWWWWW]++   """=,,Z88999 =M ) )S1B1B:r1R1R-S-S-^-^_n-o-o ) A A A A A A%%66 66F KK?((**     M =/ / /3}7H7HUW7X7X3Y3Y3d3dev3w3w / L L L L L L!.!4!4!6!6K+*99[99F KKL((**     M =H $ $ a a a a a a a a=,,Z<<BCCH((22 %2%8%8%:%: ! 33%)%F%Fx%P%PN%15C M2++::k:: E,,..   $  - -!>>}?P?PQ[]_?`?`aaN)/= m,((-(( 6    $ $ & &     r\cddl}d} t|dd}|dSt|dd}|dSt|dd}|dSt|ddpt|ddpg}t|D]}t|ddpt|dd}|'t|d d} | $t|d d} | t| d d} | a | |jn#t $rYnwxYw | n#t $rYnwxYw|d z }n2#t$r%} t d | Yd} ~ nd} ~ wwxYw|S) a Force-close underlying TCP sockets to prevent CLOSE-WAIT accumulation. When a provider drops a connection mid-stream, httpx's ``client.close()`` performs a graceful shutdown which leaves sockets in CLOSE-WAIT until the OS times them out (often minutes). This method walks the httpx transport pool and issues ``socket.shutdown(SHUT_RDWR)`` + ``socket.close()`` to force an immediate TCP RST, freeing the file descriptors. Returns the number of sockets force-closed. rNr _transport_pool _connections_network_stream_stream_sockrrz'Force-close TCP sockets sweep error: %s) rrorshutdown SHUT_RDWRr`ryrr6r) rrclosedrrra connectionsconnrsockrus rZ_force_close_tcp_socketsz AIAgent._force_close_tcp_socketss !   ) I!&)T::K"q \4@@I q9gt44D|qnd334$//  [))  D"3T::6tY55>vw55<"68T::D'&tWd;;<MM'"34444DJJLLLLD! - . I I I LLBC H H H H H H H H I spD4D4D4BD4C76D47 DD4DD4DD4 D*'D4)D** D44 E#>EE#cR|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)NrTrz7Failed to rebuild shared OpenAI client (%s) %s error=%sFzreplace:) rrorrrr6r7rrrX)rXr old_client new_clientrus rZ_replace_primary_openai_clientz&AIAgent._replace_primary_openai_clientsU  % % ' ' % % 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)NrzCDetected closed shared OpenAI client; recreating before use (%s) %szrecreate_closed:rz'Failed to recreate closed OpenAI client) rrorr6r7rr*rr)rXrrs rZ_ensure_primary_openai_clientz%AIAgent._ensure_primary_openai_clients  % % ' '  T8T22F!$*G*G*O*O!                         Q   $ $ & &   22:UV:U:U2VV JHII I  % % ' '  ;                  s#*AAA C!!C%(C%c,t|dd}|dS t|dd}|dSt|dd}|dSt|dd}|dSt|ddpt|ddpg}d}t|D]}t|d dpt|d d}|(t|d d} | $t|d d} | t| d d} | bddl} | d| d | j| jz} | dkr|d z }n #t$rYnt$r|d z }YnwxYw | d#t$rYwxYw# | dw#t$rYwwxYwxYw|dkr3t d|| ddSn2#t$r%} t d| Yd} ~ nd} ~ wwxYwdS)aYDetect and clean up dead TCP connections on the primary client. Inspects the httpx connection pool for sockets in unhealthy states (CLOSE-WAIT, errors). If any are found, force-closes all sockets and rebuilds the primary client from scratch. Returns True if dead connections were found and cleaned up. rNFrrrrrrrrrrr\Tu@Found %d dead connection(s) in client pool — rebuilding clientdead_connection_cleanupr,zDead connection check error: %s)rorr setblockingrecvMSG_PEEK MSG_DONTWAITBlockingIOErrorr`r6r7r*rr) rXrrrrar! dead_countr"rr#rrerus rZ_cleanup_dead_connectionsz!AIAgent._cleanup_dead_connections'sx.. >57 A!&)T::K"u \4@@I u9gt44D|und334$//  J[))  D"3T::6tY55>vw55<"68T::D'&tWd;;<(((( $$U+++99Q(87;O(OPPDs{{"a &D$$$!OJJJ$((...."((...."A~~V33;T3UUUt  A A A LL:C @ @ @ @ @ @ @ @ AusG"G"G"BG"2AD65E=6 EE=EE=EE=E-,G"- E:7G"9E::G"=F%?FF% F" F%!F" "F%%:G"" H,H  Hcddlm}||}t||r|S|5t |j}dddn #1swxYwY|||dS)Nrrr,Fr)rrr-rbrrrr)rXrrprimary_clientrequest_kwargss rZ_create_request_openai_clientz%AIAgent._create_request_openai_clientms&&&&&&;;6;JJ nd + + "! !  % % ' ' 7 7!$"566N 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7)).PU)VVVsA$$A(+A(c6|||ddS)NFr)rX)rXrrs rZ_close_request_openai_clientz$AIAgent._close_request_openai_clientws# !!&!FFFFFr\on_first_deltac  ddl}|p|d}d}d}d}g|_t|dzD]N} |jrt dg} |jjd(i|5} | D]} |d|jrnzt| d d } d | vs| d krit| d d }|r|j ||r9|s7|s d}|r |n#t$rYnwxYw| |d| vrd}d| vr-d | vr)t| d d }|r| || dkr*t| dd}|| || dvrt| dd}|rt|ddnd}|rt|ddnd}td| ||t!d|jD|| }t|dd}t'|t(r|s| r=t)| |_tdt/| n|jr|s~d |j}t3dddt3d|g g|_td!t/|jt/||cdddcS#1swxYwY#|j|j|jt:f$r}| |kr$r}tA|}d%|v}|rA| |kr;td&| dz|dz|Yd}~|rKtd'||||$cYd}~cSd}~wwxYwdS))zJExecute one streaming Responses API request and return the final response.rNcodex_stream_directr,rFz+Agent interrupted before Codex stream retryreceiving stream responserrzoutput_text.deltaresponse.output_text.deltadeltaTrrEresponse.output_item.doneitem)response.incompleteresponse.failedrstatusincomplete_detailszkCodex Responses stream received terminal event %s (status=%s, incomplete_details=%s, streamed_chars=%d). %sc34K|]}t|VdSrgrrs rZrz,AIAgent._run_codex_stream..s(#T#TqCFF#T#T#T#T#T#Tr\outputz;Codex stream: backfilled %d output items from stream eventsrrr output_textr*rrrGr z?Codex stream: synthesized output from %d text deltas (%d chars)zNCodex Responses stream transport failed (attempt %s/%s); retrying. %s error=%szYCodex Responses stream transport failed; falling back to create(stream=True). %s error=%s)rresponse.completedzGResponses stream closed before completion (attempt %s/%s); retrying. %szYResponses stream did not emit response.completed; falling back to create(stream=True). %srw)!rr-_codex_streamed_text_partsr=rInterruptedError responsesrr4rorr_fire_stream_delta_fire_reasoning_deltar6r7rrget_final_responserbrrJrrdrrRemoteProtocolError ReadTimeout ConnectErrorConnectionError!_run_codex_create_stream_fallbackrrc)rXrrr=r active_clientmax_stream_retrieshas_tool_callsfirst_delta_firedattemptcollected_output_itemsrevent event_type delta_textreasoning_text done_itemresp_objrGrHrO_out assembledruerr_textmissing_completeds rZ_run_codex_streamzAIAgent._run_codex_streamzsNb$"D"DLa"D"b"b !13'/!344o o G( V&'TUUU+- "k 3],3AAjAAH*V!'..,,-HIII4"!E%,UFB%?%? .*<< Nj@j@j)0)D)DJ)S $ ? F Fz R R R)D.D'8!18<$5'5%1)1,:N,<,<,<, J J J (+FFF(/vt(D(DI(4 6 = =i H H H'+UUU'.uj$'G'GHJR%\WXx%F%F%FX\Fbj1tCWY]1^1^1^pt."NN!\ *F4F ##T#TD4S#T#T#T T T $ 8 8 : : &,%>%>%@%@N#>8TBBD!$--d1489O4P4PN1"LL ] #$: ; ;"< ^ (*0O(P(PI5D%.%0'2)8mR[)\)\)\(] 6665N1 #LL a #D$C D Dc)nn*QH*H*H*H*H*H*H*H*H*H*H*H*H*H*H*H*H*H*H*R.0BFDWYhi ` ` `///LLh! *Q.0022 HHHH o,,.. ==jQ^=__________   s88$8H$D!$3E)E)ELLa! *Q.0022  HHHH$dLLs0022 AA*UbAcccccccccc# }o o sL(*A7L" C-,L- C: 7L9C: :HL L(L L("L #L((R rFrMrErz1Codex fallback stream: backfilled %d output itemsrrrrKr*rLz D D D55555 ))I&&99Z(('3'' w}} 5(C(( 0@0@ 5}}  ((//44 )-I&*.-J'22:T2UU 5ts- AAAc |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)NrnousFr) resolve_nous_runtime_credentialsrHERMES_NOUS_MIN_KEY_TTL_SECONDS1800HERMES_NOUS_TIMEOUT_SECONDS15)min_key_ttl_secondstimeout_seconds force_mintz"Nous credential refresh failed: %sr{rrrnous_credential_refreshr,T)r}r|rr~rrrrrrr6rrrbrcrr{rrrrr*)rXrr~rzrur{rs rZ$_try_refresh_nous_client_credentialsz,AIAgent._try_refresh_nous_client_credentialsbs =. . .$-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: %sNr{rrcopilot_credential_refreshr,z%Copilot credentials refreshed from %sT)r|hermes_cli.copilot_authrrr6rrbrcrr{rr"_apply_client_headers_for_base_urlr*r)rXr new_token token_sourcerus rZ'_try_refresh_copilot_client_credentialsz/AIAgent._try_refresh_copilot_client_credentialss= =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)NrrFrrrz azure.comr)rrz'Anthropic credential refresh failed: %srz?Failed to rebuild Anthropic client after credential refresh: %srT)r}rr|rorrrrr6rrbrcrrrryrrr7rr)rX_baserrrrurs rZ)_try_refresh_anthropic_client_credentialsz1AIAgent._try_refresh_anthropic_client_credentialss+ =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}t|drt ||jd<dSt|drt ||jd<dSt|drt |jd<dSt|drddlm}||jd<dSt|d rd d i|jd<dSt|d rt|jd<dSt|d r4ddlm }||j dd|jd<dS|j dddS)Nr)_AI_GATEWAY_HEADERS _OR_HEADERSrrai-gateway.vercel.shrrrrrZrrrrr{r) rrrrNrrr]rrrnrrr)rXrrrrrs rZrz*AIAgent._apply_client_headers_for_base_urlsKKKKKKKK ? ; ; =59+5F5FD  1 2 2 2 "8-C D D =59:M5N5ND  1 2 2 2 "8-A B B =5H5J5JD  1 2 2 2 "8-D E E = A A A A A A5L5L5N5ND  1 2 2 2 "8^ < < =6BDW5XD  1 2 2 2 "8-= > > =5I5K5KD  1 2 2 2 "8] ; ; = H H H H H H5N5N#'' 26666D  1 2 2 2   # #$5t < < < < |S4Q4Qc ++C000Wc )-I&*.-J' // >>> ++3H+IIIIIs A:: BB)classified_reason error_contextrhas_retried_429rrc |j}|d|fS|}|6|dkr tj}n#|dkr tj}n|dvr tj}|tjkre||nd}|||}|Bt d|t|dd | |d Sd|fS|tjkrg|sd S||nd}|||}|Bt d |t|dd | |d Sd S|tjkr| } | Et d t| dd | | d|fS||nd}|||}|Bt d|t|dd | |d Sd|fS)aAttempt credential recovery via pool rotation. Returns (recovered, has_retried_429). On rate limits: first occurrence retries same credential (sets flag True). second consecutive failure rotates to next credential. On billing exhaustion: immediately rotates. On auth failures: attempts token refresh before rotating. `classified_reason` lets the recovery path honor the structured error classifier instead of relying only on raw HTTP codes. This matters for providers that surface billing/rate-limit/auth conditions under a different status code, such as Anthropic returning HTTP 400 for "out of extra usage". NFi)i)rru4Credential %s (billing) — rotated to pool entry %sr r%r)FTu7Credential %s (rate limit) — rotated to pool entry %su1Credential auth failure — refreshed pool entry Tru@Credential %s (auth refresh failed) — rotated to pool entry %s) rr#billing rate_limitauthmark_exhausted_and_rotater6rrortry_refresh_current) rXrrrrraeffective_reason rotate_status next_entry refresheds rZ_recover_with_credential_poolz%AIAgent._recover_with_credential_poolsx,$ </) ),  #c!!#1#9  ###1#<   **#1#6 ~5 5 5+6+BKKM77Man7ooJ% J!Jc22 %%j111"{/) ) ~8 8 8" #"{+6+BKKM77Man7ooJ% M!Jc22 %%j111"{; ~2 2 20022I$ oPWXacgilPmPmooppp%%i000_,,,7+BKKM77Man7ooJ% V!Jc22 %%j111"{o%%r\cn|jdkr||jjjdi|S)Nrrw)r}rrr rp)rXrs rZ_anthropic_messages_createz"AIAgent._anthropic_messages_createfsA =0 0 0  : : < < <5t%.5CC CCCr\ct|dddkr+ddlm}t|ddpd}|||_dSddlm}||jt|d dt |j|j |_dS) uYRebuild 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. r|Nrrrrrrrr) rorrrrrrr|r)rXrregionrs rZ_rebuild_anthropic_clientz!AIAgent._rebuild_anthropic_clientks 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 " " "r\c  ddd ddi  fd}dg}tj}dt j|d}|d }|r|d |d z }|d zd kr._calls) a=$5556:6X6X`v6X6w6w)(3)-)?)?"4X>'.t5Ld'S'S*@**F:&& ]&:::)-)H)H)T)TF:&&]&888  (^^,@+NNFNN#94@@@88@@F'6v'D'D'D'D $54\BB>55f===  *E)D\)R)RF:&&6:6X6X`y6X6z6z)(3)`)>x)H)M)Y)`)n)ncm)n)nF:& $ $ $"#w $"7!:!:8!D!D!-55nM_5`````.-"7!:!:8!D!D!-55nM_5````.sUCE CE  C?#C::C??A E F E$EFE$$F1G r z&waiting for non-streaming API responseTrr333333?rrrzz$waiting for non-streaming response (z s elapsed)c3NK|] }tt|V!dSrgrrs rZrz2AIAgent._interruptible_api_call...SSqs3q66{{SSSSSSr\rzjNon-streaming API call stale for %.0fs (threshold %.0fs). model=%s context=~%s tokens. Killing connection.rror,%⚠️ No response from provider for zs (non-streaming, model: z). Aborting call.rstale_call_killr,z&stale non-streaming call killed after r@rrz'Non-streaming API call timed out after zs with no response (threshold: s)interrupt_abortz!Agent interrupted during API call)rrrr4rrris_aliverrrr6r7rr}rryrr<r TimeoutErrorrrO) rXrr_stale_timeout _call_startrD _poll_count_elapsed_est_ctxrcrrrs `` @@rZ_interruptible_api_callzAIAgent._interruptible_api_calls.#T22!)4 0* a* a* a* a* a* a* a* ad?? NN:r * *  ikk  EFFF  E$ 7 7 7   jjll@ L FF3F    1 KS A%%9;;4$$T3x==TTT y{{[0H.((SSJNN:r4R4RSSSSSWXXGnNN7I668  !!&CMM&&.8nnWi.P.P&&& }(<<<.44666668888266x@@> ==bIZ=[[[ D$$MS]]MMMs###'?*vj/A/I&2P#h--PP8;N8K8KPPP''F7O( L }(<<<.44666668888)>)B)B8)L)L)5 ==nUf=ggg D&'JKKKAjjll@ LB '? &/ !j!!s&A'H// H<;H<A'L// L<;L<cd|_dS)zDReset tracking for text delivered during the current model response.rN)rris rZ_reset_stream_delivery_trackingz'AIAgent._reset_stream_delivery_trackings02---r\cnt|tr|rt|dd|z|_dSdSdS)zCAccumulate visible assistant text emitted through stream callbacks.rrN)rbrcror)rXrs rZ_record_streamed_assistant_textz'AIAgent._record_streamed_assistant_textsR dC  T @"EEL  1 1 1    r\ct|tsdStjdd|S)Nrz\s+r)rbrcr;rrrs rZ_normalize_interim_visible_textz'AIAgent._normalize_interim_visible_texts9$$$ 2vfc4((..000r\c |||pd}|sdS||t|ddpd}t|o||kS)NrFr)rrror)rXr visible_contentstreameds rZ_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.rNr r(empty))already_streamedz interim_assistant_callback errorTr) rorbrrrrrrr6r)rXrcbr visiblers rZ_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 |r d|_d|z}d|j|jfD}d}|D] } ||d}#t $rYwxYw|r||dSdS)z;Fire all registered stream delta callbacks (display + TTS).rFrKcg|]}||Srgrw)rrs rZrz.AIAgent._fire_stream_delta..GshhhBY[YgRYgYgYgr\TN)rorrrrrr)rXr callbacks deliveredrs rZrQzAIAgent._fire_stream_delta>s 4. 6 6 !4 !DJJLL !',D $D=Dhh4#=t?T"Uhhh    B 4       7  0 0 6 6 6 6 6 7 7s A!! A.-A.cV|j}| ||dS#t$rYdSwxYwdS)z&Fire reasoning callback if registered.N)rr)rXrrs rZrRzAIAgent._fire_reasoning_deltaRsN  $ > 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)rXrrs rZ_fire_tool_gen_startedzAIAgent._fire_tool_gen_started[sP # > 9      >rc:|jdupt|ddduS)z4Return True if any streaming consumer is registered.Nr)rroris rZrzAIAgent._has_stream_consumersjs/  &d 2 Ct/66dB r\r=c  jdkr0_ d_S#d_wxYwjdkrdddddiddifdfd }tj|d }||r@|d jrtd|@dddSddgdddiddiddidtj ifdfdfdfd}ttj dd}|dkrKjrDtjr0td}t djn`t%ddgDdz}|dkrt)|d }n|d!krt)|d"}n|}tj|d }|tj } d#} |ru|d tj } | | z | kr3| } t+| dz } d$| d%tj dz } | |krIt%d&dgDdz}t d'| |d(d)|d*d+t+| d,d(d)d-|d*d. d}||d/0n#t4$rYnwxYw d10n#t4$rYnwxYwtj d<d2t+| d3jr jd4kr.jn.d}||d50n#t4$rYnwxYwtd6|uddrtt?d7d8pd8 pd}tCd9pg}|rd:|dd;}tE|d;kr|d|d?}|pd8|z} #|n#t4$rYnwxYwt d@|tE|pd8dn1t dAtE|pd8dtIdB|ddC}tIdDt?d(d)tIdE|dFGgdHSddS)IuStreaming variant of _interruptible_api_call for real-time token delivery. Handles all three api_modes: - chat_completions: stream=True on OpenAI-compatible endpoints - anthropic_messages: client.messages.stream() via Anthropic SDK - codex_responses: delegates to _run_codex_stream (already streaming) Fires stream_delta_callback and _stream_callback for each text token. Tool-call turns suppress the callback — only text-only final responses stream to the consumer. Returns a SimpleNamespace that mimics the non-streaming response shape so the rest of the agent loop is unchanged. Falls back to _interruptible_api_call on provider errors indicating streaming is not supported. rNrrdoneFrOcfds%r%dd< dS#t$rYdSwxYwdSdSNrTrr\r=srZ _fire_firstz>AIAgent._interruptible_streaming_api_call.._fire_firstsq(0^04%f-&((((($   ,,c ddlm}m}m}m} dd} dd||} |jd i }n)#t$r}||r ||d}~wwxYw fd} fd} fd} ||r|nd| j sj r| ndfd  d <dS#t$r} | d <Yd} ~ dSd} ~ wwxYw)Nr)rrrstream_converse_with_callbacksrrrcP|dd<dS)NTrO)rQ)rrdeltas_were_sentrXs rZ_on_textzRAIAgent._interruptible_streaming_api_call.._bedrock_call.._on_texts3# //55526(///r\cF|dSrg)r)rprrXs rZ_on_toolzRAIAgent._interruptible_streaming_api_call.._bedrock_call.._on_tools(# 33D99999r\cF|dSrg)rR)rrrXs rZ _on_reasoningzWAIAgent._interruptible_streaming_api_call.._bedrock_call.._on_reasonings(# 22488888r\cjSrgrhrisrZrzRAIAgent._interruptible_streaming_api_call.._bedrock_call..s 43Lr\) on_text_delta on_tool_starton_reasoning_deltaon_interrupt_checkrrrw) rrrrrrconverse_streamrrrr)rrrrrrrrrrrrArrrrrXs rZ _bedrock_callz@AIAgent._interruptible_streaming_api_call.._bedrock_calls(( (^^,@+NNFNN#94@@@88@@F'=v'='K'K 'K'K $54\BB>55f=== 7777777 ::::::999999*H)G$262L2L2N2N&XhhTX&.<@._fire_first_deltasq$V,  ,0!&)"N$$$$$ DD     rc ` ddl}t,j,j}||n!t t jdd}||}nft t jdd}|dkr>,jr7t,jr#|}t d,j|i'dd di| d ||d d }, d *d<tj )d<,d*djjjd3i|},t'|ddg}i}t)}i} i} d} d} d} g}d}|D]}tj )d<,d,jrnq|js=t/|dr|jr|j} t/|dr|jr|j}||jdj}t/|dr|jr|j} t'|ddpt'|dd}|r4||&,||r|jr||j|s*&,|jd(d<nM,jrF ,|j,|jn#t@$rYnwxYw|r|j!r|j!D]}|j"|j"nd}|j#pd}|| vr|| |<|r)|| vr%|| |krtI|ddz}|| |<|r|| |<| |}||vr|j#pddddddd ||<||}|j#r |j#|d!<|j%rM|j%j&r|j%j&|dd"<|j%j'r |dd#xx|j%j'z cc<t'|d$d}|,t/|d%r|j(pi)d$}|)t/|d&r|*}||d$<|dd"}|rS||vrO|+|&,,|+d'||jdj-r|jdj-} t/|dr|jr|j}d.|pd}d}d(}|rg}t_|D]}||}|dd#}|dd"pd)} |rZ|0rF tcj2|n0#tbj3$rti|| }!|!d*kr|!}nd}YnwxYw|tk|d!|d+|)d$tk|dd"|,| pd-}"|rd.}"d.|pd}#tk| |||#/}$tkd|$|"0}%tkd1tmtoj8z| |%g|2S)4z#Stream a chat completions response.rNrrHERMES_STREAM_READ_TIMEOUT^@uDLocal provider detected (%s) — stream read timeout raised to %.0fsT include_usage>@)connectr&r_ra)rstream_optionsrchat_completion_stream_requestr,rrDz)waiting for provider response (streaming)rrr@rrrFrErOrr4)rrrr)r rr extra_contentr rprr model_extra model_dumprFr%r(r)r rrrrlengthrr rrFrrrzstream-r rchoicesrrw)9rrr|rrrrrr2r6rTimeoutr:rr4rrrpr:rorrr"rrrBrrRr rQrrrrrr rrrprrrrrrrrrrrrr9rGrrcrr)-r_provider_timeout_cfg _base_timeout_stream_read_timeout stream_kwargsr content_partstool_calls_acctool_gen_notified_last_id_at_idx_active_slot_by_idxr model_namerrM usage_objchunkrBrbtc_deltaraw_idxdelta_idnew_slotrrrrp full_contentmock_tool_callshas_truncated_tool_argsrrrrepairedeffective_finish_reasonfull_reasoning mock_message mock_choicerrrlast_chunk_timerrrXs- rZ_call_chat_completionszIAIAgent._interruptible_streaming_api_call.._call_chat_completionss " " " "%APTPZ$[$[ !)4&%29%96BBCC %0'<$$',RY7SUZ-[-['\'\$ (500T]0GXY]YfGgGg0+8(LL^ ';  #2D"9!>> -' *   M/3.P.P7/Q// !( + $(9;;OC  !L M M ML*849EL]]}]]F  % %gfj$&G&G H H H"$M#%N%(UU  %'O(*  MJD$&OI{ ,{ ,'+y{{$$$%@AAA,E}ug..15;1%*[ ug..05;0$)K  a(.5'**-u{-!&J")0CT!J!J!ogV[]hjnNoNo!?#**>:::%%'''..~>>>%U]%!((777)%))+++// >>>26(// 5%% $ : :5= I I I $ D DU] S S S S#,%%% $%?FU-?F$)$4>F>F42'F'F'F'JH;C/8#@7?OG41':n44&.k&7R(257b,I,I15 33N3/ !/s 3#;6*2+E$K#, ^'05 S=E > >(BSB] ] > > > '/4 H H =WX}-M-M=%-%9%?R$D$D_$U$UE ,&ul;;;(-(8(8(:(:5:E/2$Z08 FC/@$@$@-11#666--/// 77===##78??EEE=#1C$)M!$4$BM5'**,u{, % I77=119TL"O&+ # "$!.11C',B ":{ ;I ":v 6 =#I ?Y__%6%6?? Jy1111#3???(C9i'X'XH'4//,4 ;? 7?$**?d8Z&(ff_&=&=!0!#J!7&/""" ,,,'4&=v #& 3*2'WW_55=N*$*"0 L *$5K #s4:<<000 $   s$4L  LLV&&*WWcdd}tj d<jjjdi 5}|D]O}tj d<djrnt |dd}|dkr]t |dd}|rIt |dddkr4d }t |d d}|r ||d krt |d d}|rt |dd}|d kr;t |dd}|r&|s$ |d d<|dkr2t |dd} | r  | Q| cdddS#1swxYwYdS)a8Stream an Anthropic Messages API response. Fires delta callbacks for real-time token delivery, but returns the native Anthropic Message object from get_final_message() so the rest of the agent loop (validation, tool extraction, etc.) works unchanged. FrDr@rNcontent_block_start content_blocktool_useTrpcontent_block_deltarB text_deltarrrOthinking_deltarIrw) rrr rr4rrorrQrRget_final_message) has_tool_userr_r`rPrrB delta_typer thinking_textrrrr<rXs rZ_call_anthropiczBAIAgent._interruptible_streaming_api_call.._call_anthropicsc!L$(9;;OC 7'07EE*EE* 2#&N&NE,09;;OC((()DEEE0!(!=!=J!%::: ' E E GWUFD%A%AZ%O%O+/L(/vt(D(DI(G 1 1 3 3 3 $ ; ;I F F F#'<<< 'w = = N)0)E)EJ)\99'.ufb'A'A#'!C !C$5$5$7$7$7$($;$;D$A$A$A>B$4U$;!+/?!?!?07z20N0N #0!N$5$5$7$7$7$($>$>}$M$M$M//11U* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2sE'F%%F),F)c  ddl}ttjdd} t |dzD]}jrt d jdkr"d<n d< d}| |d dSdS#t$r)}t||j |j|jf}t||j|jt$f}d rkt' d }d }|sg|seddlm} t|| rOt-|dds>t/|d} t3fd| D}|p|p|} |o| o||k} | sWt4d||d<Yd}~ d}| |d dSdSt4d|dz|dzt;|j| dn#t$rYnwxYw  n#t$rYnwxYwgd <d d <d d<!dt;|jd|dzd|dzd"d|dzd|dzdt;|j d} |  | d dd< #d n#t$rYnwxYw!dYd}~Jd }|sg|seddlm} t|| rOt-|dds>t/|d}t3fd |D}|s|s|r\||krt4d!|dz|dzt;|j|!d"t;|jd|dzd|dzd"d|dzd|dzd#t;|j d} |  | d$ dd< #d% n#t$rYnwxYw!dYd}~܉!d&|dzd't4d(|dz|nbt/|}d)|vod*|v}|rd+_$%d,t4d-||d<Yd}~ d}| |d dSdSd}~wwxYw  d}| |d dSdS# d}| |d wwxYw).NrHERMES_STREAM_RETRIESrrz%Agent interrupted before stream retryrrrstream_request_completer,rOrF)APIErrorr) connection lostconnection resetconnection closedzconnection terminated network errornetwork connection terminatedz peer closedz broken pipezupstream connect errorc3 K|]}|vV dSrgrw)rphrase_err_lower_previews rZrzKAIAgent._interruptible_streaming_api_call.._call..WsEC&C&,2)/2D(DC&C&C&C&C&C&r\z9Streaming failed after partial delivery, not retrying: %srzStreaming attempt %s/%s died mid tool-call (%s: %s) after user-visible text; retrying silently to avoid losing the action. Preamble will re-stream.u9 ⚠ Connection dropped mid tool-call; reconnecting… ru)⚠️ Connection dropped mid tool-call (u). Reconnecting… (attempt rrez stream retry z mid tool-call after stream_mid_tool_retry_cleanup"stream_mid_tool_retry_pool_cleanupu 🔄 Reconnected — resuming…c3 K|]}|vV dSrgrw)rrU_err_lower_sses rZrzKAIAgent._interruptible_streaming_api_call.._call..s<7"7"(.%+n$<7"7"7"7"7"7"r\zJStreaming attempt %s/%s failed (%s: %s), retrying with fresh connection...u'⚠️ Connection to provider dropped (z after stream_retry_cleanupstream_retry_pool_cleanupu(❌ Connection to provider failed after uM attempts. The provider may be experiencing issues — try again in a moment.z5Streaming exhausted %s retries on transient error: %srz not supportedTu ⚠ Streaming is not supported for this model/provider. Switching to non-streaming. To avoid this delay, set display.streaming: false in config.yaml z$Streaming failed before delivery: %s)&rrrrr=rrOr}rrr<rrbrUConnectTimeout PoolTimeoutrVrTrWropenairMrorcrjrr6r7rrrrrQrrr4r*_disable_streamingr)r_max_stream_retries_stream_attemptrrA _is_timeout _is_conn_err_partial_tool_in_flight_is_sse_conn_err_preview _APIError_SSE_PREVIEW_PHRASES _is_transient_can_silent_retrystale_is_sse_conn_err_SSE_CONN_PHRASES _err_lower_is_stream_unsupportedrVrZrIr=rr\rrrXs @@rZrz8AIAgent._interruptible_streaming_api_call.._calls " " " ""%bi0G&K&K"L"L z h',-@1-D'E'EuuO0X./VWWWl=,@@@ JJLLL1@1B1BF:..1G1G1I1IF:.P"7!:!:8!D!D!-55nMf5ggggg.-Q%eee&0 2F4I6K]^'' (2 3V5OQ`a(( ,E2g%6: & +? @ @7738=4#.&|& H H H H H H#-a#;#;!&GA}^bDcDc!&9F#786;,U38=-f5 --!]$(GG$4!]!],;a,?!]!]BUXYBY!]!]!] !00!J!0C!J!JFY\]F]!J!J7;Aww7G!J!J%:$=$=h$G$GE$0 $ A A$)2Q!B!"!"!"CG 5h ?% $ C C+O!D!"!"!"!"$-%%% $% --.PQQQ$HHHH,1(*"<"DDDDDD)!Y77"=Z^@_@_"14Q 5" 1477"7"7"7"2C7"7"7"4"4" 0 'B,B:JB /1DDD & %H$3a$7$7!$;$(GG$4$% !"!"!"!% 1 1%a(,Q(8%a%a0?!0C%a%aFY\]F]%a%a%a!"!"!" !% 4 4%@Oa4G%@%@J]`aJa%@%@-1!WW-=%@%@!"!"!" )>(A(A((K(K#(#4$($E$E(-6L%F%&%&%&GK$9($C!)$($G$G/J%H%&%&%&%&(1!)!)!)$(D!) $ 1 12T U U U ( --!9#6#:!9!9!9 #NN W 3a 7 ! *-QJ (J 6!B$3z$A3 6":> 7 $ 0 0%7!"!"!" #KK F !+,w!6!:!:8!D!D!-55nMf5ggggg.-Qe!un"7!:!:8!D!D!-55nMf5ggggg.-"7!:!:8!D!D!-55nMf5gggg.s+X.:CX. W8D W3X.6W3 IW3 I,)W3+I,,W30JW3 JW3JB2W3MW3 M)&W3(M))W3X.EW3S.-W3. S;8W3:S;;W3X.B#W3<X.3W88X..1YHERMES_STREAM_STALE_TIMEOUTgf@ru>Local provider detected (%s) — stale stream timeout disabledc3NK|] }tt|V!dSrgrrs rZrz.&s.RRac#a&&kkRRRRRRr\r rrrrgn@rzwaiting for stream response (zs, no chunks yet)c3NK|] }tt|V!dSrgrrs rZrz.Jrr\uqStream stale for %.0fs (threshold %.0fs) — no chunks received. model=%s context=~%s tokens. Killing connection.rror,rz s (model: z , context: ~z tokens). Reconnecting...stale_stream_killr,stale_stream_pool_cleanupzstale stream detected after zs, reconnectingrstream_interrupt_abortz+Agent interrupted during streaming API callrrrrrJz, +z moreu$ ⚠ Stream stalled mid tool-call (zH); the action was not executed. Ask me to retry if you want to continue.z[Partial stream dropped tool call(s) %s after %s chars of text; surfaced warning to user: %szPartial stream delivered before error; returning stub response with %s chars of recovered content to prevent duplicate messages: %srrzpartial-stream-stubrrr r!)%r}rrrrrrrrrOrrrrrr2r6rrrrrr4r7rr<rr*rryrrorrrdrQr)rXrr=rrDr_stream_stale_timeout_base_stream_stale_timeout _est_tokens_last_heartbeat_HEARTBEAT_INTERVAL_hb_now _waiting_secs_stale_elapsedrrr _partial_text_partial_names _name_str_warn _stub_msgrIr=rrrr\r<rrs``` @@@@@@@@@rZ!_interruptible_streaming_api_callz)AIAgent._interruptible_streaming_api_callqs$ =- - - *8D & 233J??-1**T*1111 =. . ."&66F!'  %u~       ) () () () () () () () () (V dCCCA GGIII**,, Xs###,X*+VWWW**,, Xg*Wo%*% %"TLL!)4 0#UO!5> ,      z z z z z z z z z z z x7 27 27 27 27 27 27 27 27 2r h h h h h h h h h h hB&+295RTY+Z+Z%[%[" & . .4= .EVW[WdEeEe .$)%LL ! LLY[_[h i i i iRR:>>*b3Q3QRRRRRVWWKW$$(+,F(N(N%%v%%(+,F(N(N%%(B%  E$ 7 7 7  )++"jjllC V FF3F   ikkG(,???") #Goc.B$B C C $$TMTTT"Y[[?3+??N 555SSJNN:r4R4RSSSSSWXXG"$9NN7I668  !!'C)B)B8)L)L)5 ==nUm=nnn D&'TUUUGjjllC VH '? &&> D"DbIIOR%''!"!"&fjj1E&F&F&L"!M!M! $ .!*< = =I>**Q..!%I3~+>+>+B%I%I%II D%DDD &3%8bE$AM//6666$NN@&M,?R(@(@&/ NN1M/R00w ,$m&* ',!$;;,& / !j!!sR< A&.O O"!O"&O== P  P A'R99 SS#V99 WWzFailoverReason | Nonec  |tjtjfvrtt |dd}t |ddpd}|jpidpd}|r|r!||krtj dz|_ |j t|jkrdS|j|j }|xj dz c_ |dpd}|dpd}|r|s|S dd lm}|d pdpd } |d pdpd } | sT|d pd} | r)t%j| dpd } | r(t)| dr| st%jdpd } |||d| | \} } | )t+jd||S ddlm}|||}n#t2$rYnwxYwd}t5| j}||}|dkrd}n|dks:|ddrd}nq|rd}nl||rd}nT| ||rd}n:|dks2tC|"drt)|drd}|j#}||_#||_$||_||_%tM|d r|j'(d|_)tU||}|dkrdd!l+m,}m-}m.}|dkr| j/p |pdn| j/pd}||_/||_0||_1|||j1|"|_2|dkr ||nd|_3d |_4i|_5n}| j/|_/| |_4t | d#d }|st | d$d }| j/|d%|rd$tm|ini|_5| ||j5d&<|7d'(|8||||)\|_9|_:tM|d*r}|j;rvdd+l|j#||jt |d d|j$.|?d/|d0|t+j@d1|||dS#t2$r4}t+jAd2|||cYd }~Sd }~wwxYw)3uSwitch to the next fallback model/provider in the chain. Called when the current model is failing after retries. Swaps the OpenAI client, model slug, and provider in-place so the retry loop can continue with the new backend. Advances through the chain on each call; returns False when exhausted. Uses the centralized provider router (resolve_provider_client) for auth resolution and client construction — no duplicated provider→key mappings. rFr|rrrrrrrNr{key_envz ollama.comOLLAMA_API_KEYT)rrexplicit_base_urlexplicit_api_keyz.Fallback to %s failed: provider not configured)rrrrrrrrrrrrrrr~r_custom_headersrrrfallback_timeout_applyr,rrkr_r)rr{r|rarbu5🔄 Primary model failed — switching to fallback: z via u"Fallback activated: %s → %s (%s)z"Failed to activate fallback %s: %s)Br#rrrrorrjr!rr monotonic_rate_limited_untilrrdr_try_activate_fallbackrrrrrNrr7rrrrcrrrr>rrrOrrr|r}rrrrrrrrrr{rrrrrrrr*rrrrkrr`r rrr)rXrfallback_already_activecurrent_providerprimary_providerrB fb_providerfb_modelrfb_base_url_hintfb_api_key_hint fb_key_env fb_client_resolved_fb_modelr fb_api_mode fb_base_url _fb_is_azurer _fb_timeoutrrrr/ fb_headersr`fb_context_lengthrAs rZrzAIAgent._try_activate_fallbacks n/1GH H H'+749NPU+V+V&W&W # 'j" = = CJJLLRRTT !%!6!<" A A* M M SQSZZ\\bbdd + A1A AFVZjFjFj+/>+;+;b+@(  3t';#<#< < <5  !$"6 7 !vvj))/R6688>>@@ FF7OO)r0022 1( 1..00 0 ] 1 F F F F F F!#z 2 2 8b??AAIT !vvi006B==??G4O" P ffY//52<<>> P&(i B&?&?&E&E&G&G&O4O  F$9:JL$Y$Y Fbq F"$),<"="="E,C,C8t"2!0-2-2-2 )I) D!!!22444 SSSSSS77+NN    -Ki011K44[AALn,,/  ++{/A/A#/F/F/L/L/N/N/W/WXd/e/e+2  11 ++K88 1/ <<$= 10  ))!+..99:LMM*)+GG*1  I!DJ'DM'DM'DMt/00 .%++---'+D $ 7{HMMK222ttttttttttZeitZtZt!2!U6M6M6O6O!USU|E|M|SQS , *7'+6()?)?!4#;[***&NY\gMgMg??=+I+I+Imr(" &(## )0 ' %Y0A4HH !M!(4Et!L!LJ(0 +''AKR)4 +;+;<! L L L..00 0 0 0 0 0 0 1sDDX0KX K XKL6X Y)Y;YYcz|jsdSt|ddtjkrdS|j} |d|_|d|_|d|_|d|_t|dr|j |d |_ t|d |_|d |_|d |jd ko |jdk|_|jd krlddlm}|d|_|d|_||d|dt-|j|j|_|d|_d|_n0|t|d dd|_|j}||d|d|d|d|dd|_d|_t=jd|j|jdS#t@$r }t=j!d|Yd}~dSd}~wwxYw) aRestore the primary runtime at the start of a new turn. In long-lived CLI sessions a single AIAgent instance spans multiple turns. Without restoration, one transient failure pins the session to the fallback provider for every subsequent turn. Calling this at the top of ``run_conversation()`` makes fallback turn-scoped. The gateway caches agents across messages (``_agent_cache`` in ``gateway/run.py``), so this restoration IS needed there too. Frrrr|rr}rr{rrrsrtrrrr|r}rr~Nrestore_primaryTrruryrvrwrxrbz.Primary runtime restored for new turn: %s (%s)z%Failed to restore primary runtime: %s)"rrorrr!rr|rr}rrrr{rrrrrrrrrrrrrrrkr rrrrr7)rXrtrccrAs rZ_restore_primary_runtimez AIAgent._restore_primary_runtime~s' 5 4. 2 2T^5E5E E E5  "9 GDJzNDMzNDMzNDMt/00 .%++---i=DL"&r/':";";D ')*>'?D $-/FF) !55V$-;:V--D ) } 444JJJJJJ*,-@*A'+-.B+C()?)?*+R0D-E8 SS***&,..B+C(" "88O,--,9 (B OO+,!"=>12/012    (-D $#$D L@ DM   4    OCQ G G G55555 sGH H:H55H:>r^rUrVr]APITimeoutErrorAPIConnectionErrorrT api_error retry_count max_retriesc |jrdSt|j}||jvrdS|rdS|jpd}|dvrdS t|dd/ | |j ddn#t$rYnwxYw|j }t|d |_|d |_|d |_|d |_|d |_t%|dr|j|d|_|jdkrlddlm}|d|_|d|_||d|dt5|j|j|_|d|_d|_ n0|t|d dd|_ t=d|zd}||j d|d|jd|ddtCj"|dS#t$r } tGj$d| Yd} ~ dSd} ~ wwxYw)uAttempt one extra primary-provider recovery cycle for transient transport failures. After ``max_retries`` exhaust, rebuild the primary client (clearing stale connection pools) and give it one more attempt before falling back. This is most useful for direct endpoints (custom, Z.AI, Anthropic, OpenAI, local models) where a TCP-level hiccup does not mean the provider is down. Skipped for proxy/aggregator providers (OpenRouter, Nous) which already manage connection pools and retries server-side — if our retries through them are exhausted, one more rebuilt client won't help. Fr)r}z nous-researchrNprimary_recoveryTrrrrr|rr}rr{rrrr|r}rr~rJru🔁 Transient z on u — rebuilt client, waiting z"s before one last primary attempt.rz%Primary transport recovery failed: %s)%rrrr_TRANSIENT_TRANSPORT_ERRORSrr|rrjrorXrrr!rrrrr}rrrr{rrrrrrrrrrrrsleeprr7) rXrrr error_typerrr wait_timerAs rZ_try_recover_primary_transportz&AIAgent._try_recover_primary_transports  # 5)__- T= = =5  " " $ $ 5--24466<<>> 6 6 650 tXt,,8-- ,>t.!D&B"&r/':";";D GDJzNDMzNDMzNDMt/00 .%++---i=DL} 444JJJJJJ*,-@*A'+-.B+C()?)?*+R0D-E8 SS***&,..B+C(" "88O,---9 A OQ//I LL?YY:YY4=YY+4YYY     Jy ! ! !4    OCQ G G G55555 s=3H;B#"H;# B0-H;/B00F H;; I%I  I%ct|tsdS|D]1}t|tr|ddvrdS2dS)NFr> image_url input_imageT)rbrrr)r rs rZ_content_has_image_partsz AIAgent._content_has_image_parts%s^'4(( 5  D$%% $((6*:*:>Z*Z*Zttur\rcft|pdd\}}}d}|drZ|tddddd}|dr|}d d d d d d |d }tjd|d}|5| tj |dddn #1swxYwYt|j }t||fS)Nrr, image/jpegdata:;rrzimage/z.pngz.gifz.webpz.jpg)z image/pngz image/gifz image/webprz image/jpganthropic_image_F)rrdelete)rc partitionrrdrrrtempfileNamedTemporaryFiler_base64 b64decoder rp) rheaderrEremime mime_partrtmprs rZ _materialize_data_url_for_visionz(AIAgent._materialize_data_url_for_vision.sqio2..88==4   W % % !s7||}}-33C;;A>DDFFI##H-- ! !    #dF   )1CF[`aaa  . . IIf&t,, - - - . . . . . . . . . . . . . . .CH~~4yy$s(DD DrcDtjt|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)Nrrrz tool result)rrr_zDescribe 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)r user_promptanalysiszImage analysis failed: zImage analysis failed.z[The z- attached an image. Here's what it contains: r2z@ [If you need a closer look, use vision_analyze with image_url: )hashlibsha256rcrL hexdigestrrrrtools.vision_toolsrasyncior(rbrrrrrunlinkr`)rXrr cache_keycached role_labelanalysis_prompt vision_source cleanup_pathrr result_jsonrrAnotes rZ&_describe_image_for_anthropic_fallbackz.AIAgent._describe_image_for_anthropic_fallbackCsN3yB#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||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>r input_textrr>rrrrz:[An image was attached but no image source was available.]rKc3K|]}||V dSrgrw)rrs rZrz8AIAgent._preprocess_anthropic_content..s'BBdTBTBBBBBBr\rc3K|]}||V dSrgrw)rrs rZrz8AIAgent._preprocess_anthropic_content..s'??D$?4??????r\zI[A multimodal message was converted to text for Anthropic compatibility.]) rrbrcrrrrrr) rXr r text_parts image_notesrptyper image_datarrrs rZ_preprocess_anthropic_contentz%AIAgent._preprocess_anthropic_contentvsy,,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  MZZr\c|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. rNr) get_transport)r}rorragent.transportsr)rXr}modecacherDrs rZrzAIAgent._get_transportsw (4=0$77 =E$)D ! IIdOO 9 6 6 6 6 6 6 d##AE$Kr\ api_messagesc >tfd|Ds|Stj|}|D]g}t|ts|dt|ddpd|d<h|S)Nc3K|]A}t|to'|dVBdS)r N)rbrrr)rrrXs rZrz>AIAgent._prepare_anthropic_messages_for_api..s`   sD ! ! Wd&C&CCGGIDVDV&W&W      r\r rr_)rrrrbrrrrc)rXr transformedrs` rZ#_prepare_anthropic_messages_for_apiz+AIAgent._prepare_anthropic_messages_for_apis    #       mL11   Cc4(( !?? ""CGGFF++5v66C NNr\ct|ddpddvrdSt|ddpd}d|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). 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.r|r>rrrminimax minimax-cnr}r|Tr dashscopealiyuncsrzopencode.ai/zen/z bigmodel.cnr)rorj)rXbases rZ_anthropic_preserve_dotsz AIAgent._anthropic_preserve_dotss D*b ) ) /R 6 6 8 8=   4j"--3::<< 4  *T! *D  *"T) *$  *"T) r\c,t|jdS)z2Return True when the base URL targets Qwen Portal.rrris rZ_is_qwen_portalzAIAgent._is_qwen_portals$T%9;KLLLr\ctj|}|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) Nr rr*rrir4r ephemeral cache_control)rrrbrrrcrr)rXrpreparedrr normalized_partsrs rZ_qwen_prepare_chat_messagesz#AIAgent._qwen_prepare_chat_messagess=.. 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:K3HGBK0r\c|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.Nr rr*rrir4rrr)rbrrrcrr)rXr rr rrs rZ#_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   r\c |jdkr|}||}t|dd}|r|jnd}t|dd}|d|_||j||j||n|j |j |j | |t|dd|j piddk S|jd krd|}t|d dpd }t|d d}||j||j|j pd ||S|jdkr|} t|jdpt|jd} |jdkp|jdkod|jv} |jdkp |jdk} | |j||j|j t|dd|j |j | | | | r|nd S|} |} |}t|jdpt|jd}d|jv}d|jv}t|jdp)t|jdpt|jd} ddlm}m}||j|j}||u}|s|nd}n#t4$rd }d}YnwxYwi}|jr |j|d!<|jr |j|d"<|jr |j|d#<|jr |j|d$<|jrd%|d&<|j r |j |d'<d}|s|rEd(|jpd)!vr( dd*l"m#}||j}n#t4$rYnwxYwd}| r*|j$pd+tKtMj'd,}t|dd}|d|_| |j||j|(|j ||j)|j |j t|dd|jpd)!||| ||||jd-k|j*|pd| r|j+nd| r|j,nd||||-|r|nd|.S)/z9Build the keyword arguments dict for the active API mode.rrkN_ephemeral_max_output_tokensrspeedfast) rr rRrris_oauth preserve_dotsrTr fast_moderrrr)rr rRrrguardrail_configrmodels.github.airrrrrrr) rr rRrrrris_github_responsesis_codex_backendis_xai_responsesgithub_reasoning_extra nousresearchzintegrate.api.nvidia.comr moonshot.ai moonshot.cnr_fixed_temperature_for_modelOMIT_TEMPERATUREFonlyrJordersortTrequire_parametersdata_collectionr r)_get_anthropic_max_outputr@) sessionIdpromptIdr )rr rRrrephemeral_max_output_tokensmax_tokens_param_fnrrrrris_nousis_qwen_portalis_github_models is_nvidia_nimis_kimiis_custom_providerrpprovider_preferencesqwen_prepare_fnqwen_prepare_inplace_fnqwen_session_metadatafixed_temperatureomit_temperaturesupports_reasoningranthropic_max_output).r}rrrorTr build_kwargsrrRrrrrrrrNrr|rvru#_github_models_reasoning_extra_bodyrrrr r rrrrrrrrjrrrrcrrrrrrr_supports_reasoning_extra_body)rXrrrctx_len ephemeral_out_btrr_ctrrr_is_qwen_is_or_is_gh_is_nous _is_nvidia_is_kimir r _ft _omit_temp _fixed_temp_prefs_ant_maxr _qwen_meta_ephemeral_outs rZ_build_api_kwargszAIAgent._build_api_kwargs%s =0 0 0,,..J!%!I!I,!W!W d$8$??G07Ag,,TG#D*H$OOM(481**j+j,9,E==4?!%!61";;==& '.s1SS5##F++SSSSSSr\) rNrurr=rrrrjr)rXr=reasoning_model_prefixesrs @rZr(z&AIAgent._supports_reasoning_extra_bodys( !!57I J J 4 !57M N N 4 !$"68J K K $T%9;RSS  LLLLLL::4:FFGGG   uu  t3 3 35 t3 3 35!r((**$  SSSS:RSSSSSSs"A>> B  B c 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.rr<Nr*Feffortmediumxhighhighminimallow) rr=rrrrbrrrcrrj)rXr=supported_effortsrequested_efforts rZr'z+AIAgent._github_models_reasoning_extra_bodysZ  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 ||}t|}|sO|jpd}tjd|tj}|r#dd|D}|pd}|r.|jr'tj dt|d||r<|j r5|j s.|j s' | |n#t$rYnwxYw|jpd}t|} |rt|}t!| t"r)| r'|| } d | ||d } t)|d rTt+|d d} | t| | d <n.| d r|rd| d <t)|d r|jr|j} g} | D]}t!|t2r| |-t)|dr| |jXt)|dr'| || r| | d <t+|dd}|r|| d<t+|dd}|r|| d<|jrHg}|jD]8}t+|dd}t+|dd}t!|t"r|s||\}}|}t!|t"r|st!|t"r)|r|}n_t+|dd}|rt+|ddnd}|rt+|ddnd}|||t|}|}t+|dd}t!|t"r|s||\}}|}| |t!|t"r|nd}||||j!|j"j#|j"j$dd}t+|dd}|)t)|dr|}||d<||:|| d <| S)zBuild a normalized assistant message dict from an API response message. Handles reasoning extraction, reasoning_details, and optional tool_calls so both the tool-call path and the final-response path share one builder. rrJrrKc3fK|],}||V-dSrgr)rbs rZrz3AIAgent._build_assistant_message..s7&T&TQ!''))&Tqwwyy&T&T&T&T&T&Tr\NzCaptured reasoning ( chars): r)rr rErrFrrG__dict__rrrr rrrprr(rr)r rrrrr)%rQrr r;rLrrrrrrdrrrrrrbrcrrrror_needs_deepseek_tool_reasoningrGrrrMrrrCrBrArrrpr)rXrrrb_from_structuredr  think_blockscombined _raw_content _san_contentrraw_reasoning_content raw_details preservedd codex_itemsrrrrrembedded_call_idrE_fn_fn_name_fn_argsrembedded_response_item_idtc_dictrs rZ_build_assistant_messagez AIAgent._build_assistant_messages 001BCC//  2'/52G:&=wbiXXXL 2!;;&T&T,&T&T&TTT!)!1T  ad2 a M_^1D1D__~__ ` ` `  d5 - d6K ++N;;;; D )06B +L99  B1.AAN lC ( ( J\ J33LAAGGIIL #'*    $&9 : : .$+,=?RTX$Y$Y !$0+?@U+V+V'((&& .4+N+N+P+P . ,.'( $&9 : : 5?P?b 5 ,=KI  5 5a&&5$$Q''''Q ++5$$QZ0000Q --5$$Q\\^^444 5+4'(/1H$OO  7+6C' ( &&79NPTUU  =)>c"(,,..%iTBB?B#J73#;#;#;FI#S73 T#B#B#Bt"&"="=hRUV`RaRa"b"b!--//#*96H$#O#O !"2C88A@P@V@V@X@XA373P3PQW3X3X0A0'@$#'#J#J(23CS(I(IS$$t$$ "&(8%N ) 2 7%.%7%A!!   ?DAA$ul333 % 0 0 2 2/4GO,!!'**** *C  s>C C! C!c|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. > kimi-codingkimi-coding-cnrr r )r|rNrris rZ_needs_kimi_tool_reasoningz"AIAgent._needs_kimi_tool_reasoningsU M> > C$T]NCC C$T]MBB C%T]MBB  r\c|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.com)r|rjrrNr)rXr|rs rZrNz&AIAgent._needs_deepseek_tool_reasoningseM'R..00!r((**  " HU" H$T]4FGG r\ source_msgapi_msgc|ddkrdS|d}t|tr||d<dS|d}t|tr |r||d<dS|do'|p|}|rd|d<dS|s|rd|d<dS|dddS)zACopy provider-facing reasoning fields onto an API replay message.rrNrFrErr)rrbrcrcrNr)rXrfrgrnormalized_reasoningneeds_empty_reasonings rZ_copy_reasoning_content_for_apiz'AIAgent._copy_reasoning_content_for_apisD >>& ! ![ 0 0 F >>"566 h $ $ +3G' ( F *~~k:: *C 0 0 5I +?G' ( F NN< ( ( //1196688  ! +-G' ( F  + + - - 2244 ,.G' ( F  '.....r\c|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 rrrc~g|]9}t|tr fd|Dn|:S)c$i|] \}}|v || Srwrw)rrr _STRIP_KEYSs rZrzJAIAgent._sanitize_tool_calls_for_strict_api...s) A A AdaA[,@,@Q,@,@,@r\)rbrr)rrros rZrz?AIAgent._sanitize_tool_calls_for_strict_api..s_! ! ! "d## , A A A Abhhjj A A A A)+! ! ! r\)rrbr)rgrros @rZ#_sanitize_tool_calls_for_strict_apiz+AIAgent._sanitize_tool_calls_for_strict_apisn"[[.. *d++ N "45 ! ! ! ! !! ! !   r\r6rc |ptjt}t|tsdSd}t jdtddffd }d}|t|krv||}t|tr| ddkr|dz }P| d }t|tr|s|dz }|dz} |D]} t| ts| d } t| tsD| d } | | d krd | d <gt| tr| sd | d <t| ts tj | #tj$r| d} | dd}| dd}|d|pd|| pd||d | d <d}|dz}|t|krk||}t|tr| ddkrn4| d| kr|}n|dz }|t|kk| || d| d| dz } n |||dz }YwxYw|dz }|t|kv|S)z|d}t|tr)|s|d<n|s d||d<dS||d<dS t j|}n#t $rt|}YnwxYwd||d<dS)Nr r)rrbrcrrr8r:)rr existing_textr7s rZ_prepend_markerz>AIAgent._sanitize_tool_call_arguments.._prepend_marker(s||I..H(C(( B*0HY''!,,V44B-3*A*Ax*A*AHY'&,# . $ 8 4 4  . . . #H  .%+">">}">">HY   sA44BBrrrrrrrr(r rpr%r5z~Corrupted tool_call arguments repaired before request (session=%s, message_index=%s, tool_call_id=%s, function=%s, preview=%r)rrrYrrYr )rrrrrbrrp&_TOOL_CALL_ARGUMENTS_CORRUPTION_MARKERrrdrrcrrrr9r7insert)r r6rlogr7ru message_indexrr insert_atrrrrY function_namepreviewexisting_tool_msg scan_index candidater7s @rZ_sanitize_tool_call_argumentsz%AIAgent._sanitize_tool_call_argumentss3)(33(D)) 1? ?d ?t ? ? ? ? ? ?" c(mm++=)Cc4(( CGGFOO{,J,J" ..Jj$// z " %)I': ": " !)T22$==44!(D11$LL55 $ R,0H[)i--ioo6G6G,0H[)!)S11)"Jy))))+'"'"'"#,==#6#6L$,LL$=$=M'nGKKc")c%$+%-1H[)(,%!.!2J$s8}}44$,Z$8 ))T::"immF>S>SW]>]>]!$==88LHH09-!"a %s8}}44)0 %(.0<+1"Q '(9:::MHHHO'"R Q MQc(mm++Ts FDKKc|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)r}ris rZ_should_sanitize_tool_callsz#AIAgent._should_sanitize_tool_callss} 111r\r) approx_tokensrR focus_topicrrc:t|}td|jpd||r|dnd|j||jr, |j|n#t$rYnwxYw |j |||}n,#t$r|j ||}YnwxYwt|jdd}|r5t|d d|kr ||_ | d |d |j} | r|d | d |||} | |_|jr |j|j} |||j|jd|j} t1jddt7jjdd|_|jd|jdz |_|j |j|j!ptDj#$dd|j| | ru |j%| } |j&|j| n9#tNtf$r%}t(d|Yd}~nd}~wwxYw|j)|j| d|_*n2#t$r%}t+d|Yd}~nd}~wwxYw|jj,}|dkr"|-|j.d|ddt_| ta|z}||j_1d|j_2 ddl3m4}||n#t$rYnwxYwtd |jpd|t||d|| fS)!uCompress conversation context and split the session in SQLite. Args: focus_topic: Optional focus string for guided compression — the summariser will prioritise preserving information related to this topic. Inspired by Claude Code's ``/compact ``. Returns: (compressed_messages, new_system_prompt) tuple zPcontext compression started: session=%s messages=%d tokens=~%s model=%s focus=%rrr,ro)current_tokensr)r_last_summary_errorN!_last_compression_summary_warningu ⚠ Compression summary failed: z%. Inserted a fallback context marker.r_rr rKr rEr!r%r&r,r-)rr.rrz,Could not propagate title on compression: %sruKSession DB compression split failed — new session will NOT be indexed: %sru⚠️ Session compressed u> times — accuracy may degrade. Consider /new to start fresh.Tr)reset_file_dedupz?context compression done: session=%s messages=%d->%d tokens=~%s)5rdr6rrrron_pre_compressrrkcompressr:rorrrformat_for_injectionrrrrrrrM end_sessionr rrrrrrrrrgrrrget_next_title_in_lineageset_session_titlerarupdate_system_promptrr7compression_countrrr+r,last_prompt_tokenslast_completion_tokenstools.file_toolsr)rXr rjrrRr_pre_msg_count compressed summary_error todo_snapshotnew_system_prompt old_titleold_session_id new_titlerArv_compressed_estrs rZ_compress_contextzAIAgent._compress_contextsX ^ O %v~$1 @} y$*         $44X>>>>     b099(S`ny9zzJJ b b b099(S`9aaJJJ b   79NPTUU  t@$GG=XX9F6"":}::: (==??  J   v-HH I I I &&((( 55nEE%6"   q q ,>>tOO **8444 ,,T_mLLL!%%-\^^%<%<_%M%M"f"fPTPZP\P\P`acbcacPd"f"f(, 8Y4?8Y8Y8Y(Y% //#=ZBJNN;RTY,Z,Z*&4 0XX$($4$N$Ny$Y$Y (::4?IVVVV& 2XXX %SUVWWWWWWWWX 55doGXYYY,-)) q q qlnopppppppp q%7 !88 LL?GGsGGG     ""3 4 4,Z88 9 6E29:6   9 9 9 9 9 9  W % % % %    D   M O %v~s: " "   ,,,sy A$$ A10A15B&B<;B<8DL% :KL%K:K50L%5K::*L%% M/MMO O"!O"effective_task_idrBc|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)rrr_execute_tool_calls_sequential_execute_tool_calls_concurrent)rXrr rrBrs rZ_execute_tool_callszAIAgent._execute_tool_calls s'1 !% *1*== ::%x1BN%*D ! ! 66!8->%*D ! !ED ! ) ) ) )s&AA A&rc 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)rgoalr[toolsetstasksrr~rr) rr[rrrr~rr parent_agent)rrr)rXr_delegate_tasks rZ_dispatch_delegate_taskzAIAgent._dispatch_delegate_task s HGGGGG~""6**!%%i00"&&z22##G,,(,,-=>>%))-88"&&z22""6**    r\r|c d} ddlm}||||pd}n#t$rYnwxYw|tjd|idS|d kr@dd lm}||d |d d|j S|dkry|j stjdddSddl m } | |dd|d|dd|j |j S|dkr|dd} ddl m} | |d| |d|d|j} |jr|ddvrm |j|dd| |dd||| n#t$rYnwxYw| S|jr5|j|r|j||S|d!kr@dd"lm} | |d#d|d$|j%S|d&kr||St3|||||j pd|jrt7|jndd'(S))a@Invoke a single tool and return the result string. No display logic. Handles both agent-level tools (todo, memory, etc.) and registry-dispatched tools. Used by the concurrent execution path; the sequential path retains its own inline invocation for backward-compatible display handling. Nrget_pre_tool_call_block_messagerr\rFrtodo todo_toolrbrcrbrcstorerSession database not available.rZrrr role_filterlimitrJrrrdbcurrent_session_idr2r memory_toolactionr old_textrrr rrrrrRrYrr clarify_toolquestionr"rr"callbackrTrYr enabled_toolsskip_pre_tool_call_hook)rrrrr8rrrrrtools.session_search_toolrrrrrron_memory_writerhas_toolhandle_tool_calltools.clarify_toolrrrrrr)rXr|rrrYr  block_messager _todo_tool_session_searchr _memory_toolr _clarify_tools rZ _invoke_toolzAIAgent._invoke_tool/ s(,   J J J J J J;;}6G6M2MM    D   $:w 6UKKK K F " " ? ? ? ? ? ?:#''00#''77&  . . .# bze>_"`"`aaa S S S S S S"?#''44)--m<<#''33##'?  h & &"&&x::F E E E E E E!\$((22%)))44&**:66( F#  (9(9((C(CGY(Y(Y (88%))(B77%)))R88!%!B!B$5)5"C"" 9!DM  ! d&:&C&CM&R&R '88 VV V i ' ' H H H H H H =&**:r::%)))44.  o - -// >> >'}.?)?0b=A=R\d4#8999X\(,  s ((AG55 HH rhrcddl}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)r+rrTF)widthbreak_long_wordsbreak_on_hyphens) shutiltextwrapget_terminal_sizecolumnsrrdrrwrapextendr) rhrr_shutil_twcols wrap_width out_linesraw_linewrappedrs rZ _wrap_verbosezAIAgent._wrap_verbose s !   ((33;TCKK/00 !  4(( 8 8H8}} **  ****((8:4849#;;  !6XJ7777v ##I..'%''''r\c P/01|j}t|}jrMtjd|d|D].}dd|jjd|jd/dSg0|D]}|jj} | dkrd _ n | d krd _ tj |jj } n#tj$ri} YnwxYwt| t si} | d vrnjjrb | d d } | r8j| } j| d| n#t,$rYnwxYw| dkrjjr | dd } t/| ra| dp%t1jdt1j}j|d| ddn#t,$rYnwxYw0|| | fdd0D}js#td|d|t;0dD]\}\}}}tj|d}jrqtd|d|dtA|!dt"d tj|d!d"t|j#kr|dj#d#zn|}td|d|dtA|!d$|0D]e\}}}j$rX tK||}$d%|||7#t,$r!}tMj'd&|Yd}~]d}~wwxYwf0D]Y\}}}j(rL (|j||+#t,$r!}tMj'd'|Yd}~Qd}~wwxYwZdg|z1|_)*d(|d)|1fd*}d}+rj,rVt[j.t_j0}t_|d+|d,d-j1.}|2 tg|th}tjj67|/5}g/t;0D]7\}\}}}|8|||||}/|8tsj9}d} tjj6:/d12\}} | snjrn|s1d0};jd3t| d4d05| D]}|<tjj6:| d62nt{tsj9|z }!|!d kr_|!d7zd8krV/0fd9| D}"*d:|!d;t| d1D}#t}d?1D}$|?d@|#dA|dB|$dCdDnZ#|rSt}d>1D}#t}d?1D}$|?d@|#dA|dB|$dCdDwwxYwt;0D]\}\}}}1|}%|%jrd|d}&ndE|dF}&dG}'n|%\} } }&}'}(|(rtdT|dzdM|'dNdOt"dU|&nHt|&j#kr|&dj#d#zn|&}+tdT|dzdM|'dNdV|+d_)*dW|dX|'dCdYjDrM D|j|||&n.#t,$r!}tMj'dZ|Yd}~nd}~wwxYwt|&||jt[}&jGH||},|,r|&|,z }&d|&|jd}-|-Idt0}|d kr)| d}.t|.t\|d krI|dSdS)]zExecute multiple tool calls concurrently using a thread pool. Results are collected in the original tool-call order and appended to messages so the API sees them in the expected sequence. ⚡ Interrupt: skipping tool call(s)r[Tool execution cancelled — # was skipped due to user interrupt]rNr2rrlrrrrbefore terminalrworkdirrlbefore terminal: rrc3"K|] \}}}|V dSrgrw)rrErps rZrz9AIAgent._execute_tool_calls_concurrent.. s("G"GJAtQ4"G"G"G"G"G"Gr\u ⚡ Concurrent: u tool calls — rFr 📞 Tool rT(reArgs: rrrr) - tool.startedTool progress callback error: Tool start callback error: z executing z tools concurrently: ctjj}j5j|dddn #1swxYwYjr" td|n#t$rYnwxYw ddl m }|j n#t$rYnwxYwtj }  || |j }n=#t$r0}d|d|}td||d Yd}~nd}~wwxYwtj |z } t#||\} } | r&td || |dd n*td || t'||||| | f|<j5j|dddn #1swxYwY td |dS#t$rYdSwxYw)z%Worker function executed in a thread.NTrset_activity_callbackr Error executing tool '': z_invoke_tool raised for %s: %srztool %s failed (%.2fs): %sr#tool %s completed (%.2fs, %d chars)F)rrrrrrrrrtools.environments.baser r4rrr r6rrHrrddiscard)rrr|r _worker_tidr rr tool_errordurationis_errorrErr resultsrXs rZ _run_toolz9AIAgent._execute_tool_calls_concurrent.._run_tool s $244:K/ ; ;)--k::: ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ( "45555 D  IIIIII%%d&:;;;;    IKKE i**=-IZ\e\hs{*|| i i iP-PPJPP =}jcg hhhhhhhh iy{{U*H.}fEEKHa i 8-SYZ^[^Z^S_```` A=RZ\_`f\g\ghhh+]FHhWGEN/ ? ?)11+>>> ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? uk22222    sqAA A A,, A98A9=B B! B!8C D"&D  D!GG G G&& G43G4u ⚡ running z tools concurrentlydots spinner_typeprint_fn) max_workersT@ru⚡ Interrupt: cancelling z pending concurrent tool(s)rg@rr!cZg|]'}|v|d(S)r)r)rrfutures parsed_callss rZrz:AIAgent._execute_tool_calls_concurrent..c!s@*** ! G||)q)9)9:1=+||r\zconcurrent tools running (zs, z remaining: rJc3K|]}|dV dS)Nrrwrrs rZrz9AIAgent._execute_tool_calls_concurrent..o!s"DDaammmmmDDr\c3*K|]}||dVdS)NrJrwr s rZrz9AIAgent._execute_tool_calls_concurrent..p!s&GG!GGr\u⚡ rz tools completed in .1fzs totalr z!': thread did not return a resultrnr"Tool %s returned error (%.2fs): %stool.completedr r Tool  completed in .2fr Tool result (rLr ✅ Tool Result: s - tool completed: rdrTool complete callback error: r r tool_use_idenvr, )Krrdrrrrrrpr rrrrrr9rbrrr*rget_working_dir_for_pathensure_checkpointrrrrgetcwdrrrr8rrkeysrrr_build_tool_previewrrrrr4rrrandomchoicerEget_waiting_facesrrr_MAX_TOOL_WORKERS concurrentr ThreadPoolExecutorsubmitrwaitrcancelrrrr6r7_get_cute_tool_message_implrrrrrcheck_tool_callr1r)2rXrr rrBr num_toolsrrr|r file_pathwork_dirrrtool_names_strr!rprargs_str args_previewr}cb_errr spinnerfacer executorr _conc_start_interrupt_loggedrnot_done _conc_elapsed_still_runningr total_durr function_result tool_durationr result_previewcute_msgresponse_preview subdir_hintsrturn_tool_msgsr r r s2` `` @@@rZrz&AIAgent._execute_tool_calls_concurrent s '1  OO   $  T_VViVVV W W W   "u @Puuu$&E!! F #& K& KI%.3M((+,((.00*+' # $ 9+=+G H H ' # # # "  #mT22 # "  777D>xIbS`IbIbccc D **t/C/K*'++Ir::C.s33+// ::dbiXZXaXcXc>d>d,>>!?S"X!?!?!D   M= I J J J J"G"G,"G"G"GGG \ RyRR.RR S S S'0q'A'A \ \##Bd:d???'\IIIdIIT$))++5F5FIIIJJJ$,,Xtz$q_d7e7e7effggggORS[}}_c_tOtOt8,BT-B,B#Ce#K#K{CLZZZdZZT$))++5F5FZZLZZ[[[[* M MNBd* MM1$==G//gtTTTT MMMM"K6"K"KLLLLLLLLM  M+ J JNBd' JJ,,RUD$???? JJJM"H"H"HIIIIIIIIJ J&9$, Z)ZZ.ZZ[[[/ / / / / / / / d  0 0 2 2 t7W7W7Y7Y =!@!B!BCCD#t$X$X)$X$X$Xgmx|yGHHHG MMOOO; gi):;;K#66;6OO3 S[+4\+B+B&&'A'D$  1b$EEANN1%%%%#ikk $)!&%/%7%<%<&=&&ND($0 004- LL#'?!N!N#&x==!N!N!N&*) "*''AHHJJJJ#*//#/FFF$' k(A$B$BM$q((]R-?!-C-C*****%-*** ,,[[["8}}[[:>))NSUTUSUDV:W:W[[[G&3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 j gDD7DDDDD GGgGGGGG  eIee eeyeeeefff  gDD7DDDDD GGgGGGGG  eIee eeyeeeeffff  g$-\#:#:G CG C AD$ Ay,g&pt&p&p&pOO&ft&f&f&fO # YZV }o}hw>A/>R>RUX>X>X_TcT%:%:^mNNN#GXeguvvv.QQ33,mT4%2X4%QQQ &Ov&O&OPPPPPPPPQ'dM"[-"["[}"["["["[\\\M"b#o2F2F"b"bQ`"b"bccc4466 f6tT=Yhiii  h1111_ f'fO!OO=OOOOPPP$,,ZIIJJJJZ]^mZnZnqurG[G[G7M8M7M'NQV'V'VM\$d!dd=dddRbddeee!%D   !QD!Q!QM!Q!Q!Q!Q R R R* MM//tT?SSSS MMMM"K6"K"KLLLLLLLLM8'E"#455 O 3CCD$OOL 0</* "H OOH % % %  5 5h B B B B %% q==%yjkk2N NCT4U4U V V V V q==  5 5h J J J J J =s B??CC>AE EE2BG99 HH=(N&& O0O  O%P P- P((P-"5\ FZ) \ )Z--\ 0Z-1\ A] +` `2`--`2?f g'ggcP)t|jdD]/\}}|jr{|j|dz d}|r/||jdt |dd|D]2}|jj} dd| d |jd } | | 3n|jj} tj |jj } n5#tj $r#} tjd | i} Yd} ~ nd} ~ wwxYwt!| t"si} d} d d lm}|| | |pd}n#t($rYnwxYw|n| dkrd |_n | dkrd |_|jstj| d}|jrqt5d|d| dt7| dt5|dtj| ddnft ||jkr|d|jdzn|}t5d|d| dt7| d||| |_| d| |( d dl!m"}||j n#t($rYnwxYw|_|j#rX tI| | }|#d| || n.#t($r!}tj%d |Yd}~nd}~wwxYw|S|j&rL |&|j| | n.#t($r!}tj%d!|Yd}~nd}~wwxYw|r| d"vrn|j'j(rb | )d#d}|r8|j'*|}|j'+|d$| n#t($rYnwxYw|| d%kr|j'j(r | )d&d}tY|ra| )d'p%t[j.d(t[j/}|j'+|d)|dd*n#t($rYnwxYwtaj0}|tjd+|id}d,} n| d-krd d.l1m2}|| )d/| )d0d|j31}taj0|z }|4r)|d2tkd-| ||3 n| d4kr|j6stjdd5d6}n[d d7l7m8}|| )d8d| )d9| )d:d;|j6|j9<}taj0|z }|4r)|d2tkd4| ||3 n| dkrY| )d=d}d d>l:m;}|| )d?|| )d@| )dA|j<B}|j=r| )d?dCvr| |j=>| )d?d|| )d@d|?|t|dDdEFn#t($rYnwxYwtaj0|z }|4r)|d2tkd| ||3 nN| dGkrd dHlAmB} | | )dId| )dJ|jCK}taj0|z }|4r)|d2tkdG| ||3n| dLkr| )dM}!|!r)t!|!t6rdNt |!dO}"n(| )dPpdddQ}#|#rdR|#ndS}"d}$|4ri|DrUtjFtjH}%t|%dT|"dU|jIV}$|$J|$|_Kd}& |L| }|}&d|_Ktaj0|z }tkdL| ||&3}'|$r|$M|'n[|4r|d2|'n-#d|_Ktaj0|z }tkdL| ||&3}'|$r|$M|'w|4r|d2|'wwxYw|jNr| |jNvrd}$|4rytjFtjH}%t| }(tI| | p| }t|%dT|(dT|dU|jIV}$|$Jd}) |jPQ| | |W}|})nQ#t($rD}*tjd+dX| dY|*i}tSdZ| |*d[Yd}*~*nd}*~*wwxYwtaj0|z }tk| | ||)3}'|$r|$M|'n\|4r|d2|'n.#taj0|z }tk| | ||)3}'|$r|$M|'w|4r|d2|'wwxYw|j=r|j=T| rd}$|4r|DrytjFtjH}%t| }(tI| | p| }t|%dT|(dT|dU|jIV}$|$Jd}+ |j=Q| | }|}+nQ#t($rD}*tjd+d\| dY|*i}tSd]| |*d[Yd}*~*nd}*~*wwxYwtaj0|z }tk| | ||+3}'|$r|$M|'nA|4r|d2|'n#taj0|z }tk| | ||+3}'|$r|$M|'w|4r|d2|'wwxYw|jrd}$|4r|DrytjFtjH}%t| }(tI| | p| }t|%dT|(dT|dU|jIV}$|$Jd}, t| | ||j|j9pd|jVrt7|jVndd^}|},n=#t($r0}*d_| d`|*}tSda| |*d[Yd}*~*nd}*~*wwxYwtaj0|z }tk| | ||,3}'|$r|$M|'n3|4r|d2|'n#taj0|z }tk| | ||,3}'|$r|$M|'w|4r|d2|'wwxYw t| | ||j|j9pd|jVrt7|jVndd^}n=#t($r0}*d_| d`|*}tSda| |*d[Yd}*~*nd}*~*wwxYwtaj0|z }|jr|nt |dbkr |ddbn|}-t| |\}.}/|.rtdc| ||-n*tXdd| |t ||j#rK |#de| dd||.fn.#t($r!}tj%d |Yd}~nd}~wwxYwd|_| dg| dh|didj|jrCtj%dk| dl|dmdntj%dot |dp||jYrM |Y|j| | |n.#t($r!}tj%dq|Yd}~nd}~wwxYwt|| |jt|r}|j\]| | }0|0r||0z }d||jd }1| |1|^|d|js|jr;t5ds|dl|dmdnt5|dt|nEt ||jkr|d|jdzn|}2t5ds|dl|dmdu|2|jr|t |jkr}t |j|z }3||jd|3dvd|j|dD]2}|jj} ddw| dx|jd } | | 3n>|j_d kr1|t |jkrtaj`|j_1t |j}4|4d kr't||4 dt|y|4d kr|^||4dSdS)zz`Execute tool calls sequentially (original behavior). Used for single calls or interactive tools.rNrrTrrrrrz(Unexpected JSON error after validation: rrrr\r2rlFrrrTrrerrrrrzexecuting tool: r rrrrrrrrrrlrrrrnrrrbrcrr$ r# rrrrrrrrJrrrrr rrrr rrrrrr"rrru🔀 delegating z tasksrru🔀 u🔀 delegatingrr r r zContext engine tool 'z ' failed: z1context_engine.handle_tool_call raised for %s: %srz Memory tool 'z1memory_manager.handle_tool_call raised for %s: %srr r z&handle_function_call raised for %s: %srr r r r r( rdr rr r r! rr" rLr) r* r% r& r' z remaining tool call(s)u[Tool execution skipped — z* was not started. User sent a new message]r- )brrrrrrdrrpr rrrrr9rr7rbrrrrrrrr8rrrr1 rrrr4r r rr2 rrrr*rr. r/ rrrr0 rrrrrr< rrrrrrrrrrrorrrrr3 r4 rEr5 rr_delegate_spinnerrrr _get_tool_emojirkrr6rrrrrHrrrrrr= r1rrr)5rXrr rrBr!rremaining_calls skipped_tc skipped_nameskip_msgr|rrA _block_msgrrB rC r r}rD r? r@ rrtool_start_timerN rO rrrrr tasks_arg spinner_label goal_previewrE rF _delegate_resultrQ emoji _ce_resultr _mem_result_spinner_resultrP _is_error_resultrErS rrR r num_tools_seqs5 rZrz&AIAgent._execute_tool_calls_sequential!s%&7&BAFFt ,t ,LAy( "3">qstt"D"~LLDO!p!pSQ`MaMa!p!p!px|L}}}"1..J#-#6#;L &#uL#u#u#u(2   H OOH----%.3M # $ 9+=+G H H ' # # # N1 N NOOO "  #mT22 # " )-J NNNNNN<<!=:K:Qr     %!H,,/0D,,"n44./D+? n:m%HHH'n[[[m[[d=CUCUCWCW>X>X[[[\\\$,,Xtz-XYhm7n7n7nooppppORS[}}_c_tOtOt8,BT-B,B#Ce#K#K{CLlllmlld=CUCUCWCW>X>Xll^jllmmm!%2"$$%G %G%GHHH !MMMMMM))$*>???? D!d&A!M1-OOG// wXeffff MMMM"K6"K"KLLLLLLLLM!d&>!J,,Y\=-XXXX JJJM"H"H"HIIIIIIIIJ!m7N&N&NSWSgSo&N - 1 1&" = =I #'#7#P#PQZ#[#[,>>$&? &?&?!D!mz&A&AdFZFb&A'++Ir::C.s33+// ::dbiXZXaXcXc>d>d,>>!?S"X!?!?!D#ikkO%"&*gz-BQV"W"W"W # &((CCCCCC",*'++G44'++GU;;*### !% o = 88::CLL"B&A&-Yfo~&&&"B"BCCC"222' &*jUMn1o1o&p&pOO[[[[[[&5o+//<<$1$5$5m$D$D+//;;++/? '''O!% o = 88::MLL"L&ABRTacpzI'J'J'J"L"LMMM(**&**8X>>IIIIII".,(,,X66!)--i88*..z::, ###' M,=,=h,G,GK],],] ,<<)--h;;")--i<<%)%F%F(9-4Yd-K-K&G&& =% $ o = 88::ELL"D&A(M[hrA'B'B'B"D"DEEE)++LLLLLL"/-*..z2>>)--i88!2### !% o = 88::FLL"E&A)]\isB'C'C'C"E"EFFF/11)--g66 bIt!J$a$:L$:$:$:PaM88::$t?_?_?a?a$!=)H)J)JKKD+t,E,Em,E,ETZeiestttGMMOOO)0&#'  6&*&B&B=&Q&QO'6$-1D*$(IKK/$AM:?M[hrB C C CH6 X....>>@@6 _(__555 .2D*$(IKK/$AM:?M[hrB C C CH6 X....>>@@6 _(__555560W >]dFe5e5e88::$!=)H)J)JKKD+M::E1-OO`S`G+t,G,Ge,G,Gg,G,GV\gkguvvvGMMOOO!  6&*&=&N&N}^kv~&N&&O!0JJ @@@&*j';xS`;x;xlv;x;x1y&z&zOLL!TVceoz~L@%)IKK/$AM:=-YfoyzzzH6 X....>>@@6 _(__555 %)IKK/$AM:=-YfoyzzzH6 X....>>@@6 _(__55556%@ >$*>*G*G *V*V@ >88::$t?_?_?a?a$!=)H)J)JKKD+M::E1-OO`S`G+t,G,Ge,G,Gg,G,GV\gkguvvvGMMOOO"  6&*&:&K&KM[h&i&iO"1KK @@@&*j';p=;p;pdn;p;p1q&r&rOLL!TVceoz~L@%)IKK/$AM:=-Yfoz{{{H6 X....>>@@6 _(__555 %)IKK/$AM:=-Yfoz{{{H6 X....>>@@6 _(__55556( >88::$t?_?_?a?a$!=)H)J)JKKD+M::E1-OO`S`G+t,G,Ge,G,Gg,G,GV\gkguvvvGMMOOO"&6&:%}6G%.\#'?#8bEIEZ&dd4+@&A&A&A`d04 '''O'6OO uuu&]}&]&]Q[&]&]OLL!I=ZdosLttttttttu%)IKK/$AM:=-Yfo~H6 X....>>@@6 _(__555 %)IKK/$AM:=-Yfo~H6 X....>>@@6 _(__55556 u&:%}6G%.\#'?#8bEIEZ&dd4+@&A&A&A`d04 '''OO!uuu&]}&]&]Q[&]&]OLL!I=ZdosLttttttttu!% o = 040D__),_)=)=)C)C%%  #7}o"V"V  a wC]Tacqrrrr A=R_adetauauvvv* MM//(-t!.9I0!MMMM"K6"K"KLLLLLLLLM"&D   !ZM!Z!Z]!Z!Z!Z!Z [ [ [# ` WmWW=WWWWXXX ^c/.B.B^^_^^___* MM// m]\kllll MMMM"K6"K"KLLLLLLLLM8''%L"#455 O 3CCMS`aaL 0</* ) H OOH % % %  5 5h B B B? d'dMMMMMMMNNN$,,ZIIJJJJZ]^mZnZnqurG[G[G7M8M7M'NQV'V'VM\$bbbbbbP`bbccc( Q5F5Q1R1R-R-R 1 <==A  kkkkksw xxx"3">qrr"B..J#-#6#;L &#z,#z#z#z(2   H OOH----""q3/@/K+L+L'L'L 4?+++-899 1   - 9~N_?`?` a a a a 1    5 5h N N N N N  s+C  C<C77C<D00 D=<D==J J! J!.(K L!K==LL,, M6MM-AN>> O  O #BQ** Q76Q7+A*\ \#"\#fA7h:kn l($:l#n#l((nA0p s54v65 u?:t>9v6>uv66A0x&?| }!&}  }A0A@4@8=AA6A6 AB0B&AB+B+AB0EAE2E2 AFE<AFFAFHAH4H4 AIH>AIIAIc td|jdd}|d|d |}g}|D]s}|}|||dD]}||d|r||||t|jpd} |j r| d z|j z } | r d | dg|z}|j rK| rd nd } t|j D]0\} } | | | z| 1i} d d lm}m}n#t"$rd}d}YnwxYw|||j|jnd}||u}|rdn|}d|jv}|r|j |j| d<nddd| d<|rdg| d<|jdkr||}|dd||}|}||}|jpd }n|j|d}|||d<|j-|||ji}|j r |j |d<|j!r |j!|d<|j"r |j"|d<|j#r |j#|d<|r|| d<| r| |d<|jdkr|}|$|j|d|j|j|j%|& }|'|}|||j%!}|jpd }nm|(d"#j)j*j+d.i|}||}|jpd }|rXd$|vr4tYj-d%d|tXj.& }|r|d'|dnVd(}nR|jdkr||}|dd||}|}||} | jpd }ng|jdkr|}!|!$|j|d|j%|j|j|&)}"|'|"}|!||j%!}#|#jpd }n|j|d}|||d<|j-|||j| r| |d<|(d*#j)j*j+d.i|}||}#|#jpd }|rVd$|vr4tYj-d%d|tXj.& }|r|d'|dnd(}nd(}nH#t"$r;}$t_j0d+|$d,|jd-tc|$}Yd}$~$nd}$~$wwxYw|S)/zSRequest a summary when max iterations are reached. Returns the final response text.u$⚠️ Reached maximum iterations (z). Requesting summary...zYou've reached the maximum number of tool-calling iterations allowed. Please provide a final response summarizing what you've found and accomplished so far, without calling any more tools.r_r)rEr_thinking_prefillNrrKrirrr rrETrB)r*rAzproduct=hermes-agenttagsrrR)rr  temperaturerrJrrr| extra_bodyr)rr rRrrrrstrip_tool_prefixiteration_limit_summaryr,rz.*?\s*rrz>I reached the iteration limit and couldn't generate a summary.)rr rRrrrriteration_limit_summary_retryz Failed to get summary response: z"I reached the maximum iterations (z!) but couldn't summarize. Error: rw)2rrrrrrkrrprrrrrrxrr r rrrrur(rr}r:rirnormalize_responser rr"rrrrrr&rrrr-rrrpr;rrrr7rc)%rXr rBsummary_request_needs_sanitizerrrginternal_fieldeffective_system sys_offsetrpfmsummary_extra_bodyr  _OMIT_TEMP_raw_summary_temp_omit_summary_temperature_summary_temperaturer0 codex_kwargssummary_response_ct_sum_cnr_sumrOsummary_kwargsr_tsum_ant_kw_summary_resultretry_response _ct_retry _cnr_retry_tretry_ant_kw2 _retry_resultrAs% rZ_handle_max_iterationszAIAgent._handle_max_iterationsO#s bT5Hbbbccc .  ODDEEEU A#>>@@OL - -((**44S'BBB&Y66NKK5555"F<N O OPS__ $ F"29QQ )$*? @ @FFHC '' S(8#((**EEEE!#  "ooooooooo " " "/3,!  " 0;-,TZGGG  ):Z(G %+D#[44J[ %)==H2244 (46:6K&{33$("*77&{3 F.D-E"6*} 111#55lCC   $///#'#9#9,#G#G --//"556FGG"*"2"8b!?!?!A!A"Z ,""(34HN=1?."))$*@*@*Q*QRRR(*$)J373I(0)L595K(2'I484H(1%F373E(0'J5I&z2%F3EN<0=$888 //11E#00tzL`d.2oPTPe,0,D151N1N1P1P1RRG(,'F'Fw'O'O$&+&>&>?Ocgc{&>&|&|O&5&=&C%J%J%L%LNN(Dt'I'IQj'I'k'k'p'|(D(V(VGU(V(V$&*&9&9&;&;&N&NO_&`&`O&5&=&C%J%J%L%LN1 f..%'V,Db.`b`i%j%j%j%p%p%r%rN!fOO[^$T$TUUUU%eNN=$555#'#9#9,#G#GL $$Wd333%)%;%;L%I%IN $ 3 3 5 5I!*!=!=n!M!MJ&0&8&>B%E%E%G%GNN]&:::"1133G&33$*|cg-1-E/3QUQf262O2O2Q2Q 4 S SH&*%D%DX%N%NN$+$>$>~aeay$>$z$zM&3&;&Ar%H%H%J%JNN"&$0&&N,78L}52&--d.D.DT_.U.UVVV)J7I|4(Jt'I'IQp'I'q'q'v(C(J(\(\M[(\(\$$($7$7$9$9$L$LM]$^$^M&3&;&Ar%H%H%J%JN!f N22)+0H"ndfdm)n)n)n)t)t)v)v%j (X(XYYYY)i%eN A A A OBqBB C C CA$BUAAx{|}x~x~AANNNNNN As=D[E[E)&[(E))U[ \ 1\\stream_callbackpersist_user_messagec)*+,-.tddlm}|jt |t rt|}t |t rt|}t |t rt|}t |t rt|}|_ d_ |_ |pt tj }|_d_d_d_d_d_d_d_d_d_d_d_jdkr; rdn#t:$rYnwxYwjrd_tAj!_"tG|} tI| dkr | dddzn| } | %d d } tL'd jpd j(j)pd j*pd tI|pg| |rtW|ng} |r.j,-s.|xj/dz c_/||n|} d} j0dkr9dj1vr0j2r)xj3dz c_3j3j0kr d} d_3d|d}| 4|tI| dz }|_ j5sGtG|}6d|ddtI|dkrdnddj7=d}|rQj8rJ j89j}|r|:dpd}n#t:$rYnwxYw|r|_7nމ;|_7 ddl|:d)r)|4t |d)Ut |t r)|Nr|4||rd*O|}n2#t:$r%}tL?d+|Yd}~nd}~wwxYwd}d}d} d}!d}"d}#d}$d}%d }&tjQjR_StdjSjUrtdjSd_Vnd_Wd_VjXrK t | t r| nd}'jXYj/|'n#t:$rYnwxYwd}(jXrG t | t r| nd})jXZ|)pd}(n#t:$rYnwxYw|j!krj"j[dksj\Yr߉j]^jUr"d} d,}&j5s6d-Yn|dz }|__`d.|j\rd_\nTj"as;d/}&j5s06d0j"jbd1j"jcd2Ynjd" g}*tt| D]\}+},|,:d3d4kr|,:d5rtI| |+z }-i*| |-dD]N}.|.:d3d6krn2|.:d7}/|/r|.:d8d*|/<O*fd9|,d5D}*nd||*n3#t:$r&}0tLAd:||0Yd}0~0nd}0~0wwxYwjgdkrd;j1vrxjhdz c_hi}1|1rid}2ttI| dz d|5d?|7|4d8<n#t:$rYnwxYwd}2tLAd@|3n|2sqt}dAd}8|8<|85jjrjjd z|1z_jn|1_jdddn #1swxYwYn"t}dBd}6|6r|6d z|1zn|1_jt}dCdptjlt}9n| |9jD}:|:dkr|9'dE|:jpdFg};t| D]a\}<}=|=o}>|<|kr|=:d3dkrg}?|(r&t|(}@|@r|?4|@|r|?4||?rI|>:d8d}At |At r|Ad*zd*O|?z|>d8<q|=|>dG|>vr|>rdGdH|>vr|>rdH|>rdIdsrt|>|;4|>c|pd}Bjur|Bd*zjuzN}B|Br dJ|Bdg|;z};jvrK|Brdnd}CtjvD]0\}<}D|;w|C||Ss|t|r+tI|d?krjd@|dd?dn jdAtjd0dd)lm}|}tjdB|dCtjdD|dEtjdFtjdGtjdHtjdI|jtj kr|Wsd}W| D].},t |,tr|,rdJd/jdKdhtj?dLjtI| Yd}~ |Odz }Ot#j|Nz }`dM|Od1|Pdt|jm}t |+ |}tL?dN|O|P||t}d d }t}dOd }At}dzd }|rdP|dQnd}ĉjdR|Od1|Pd||ědhjdS|›dT|ÛdhjdU|AdhjdV|dh|rY|dWkrRt}|d*d}|rt |ŦddXnd}|r"jdY|ƛdhjdZ|dxd[tI|;d\|Jd d` rd]+vrjd^|Ûd_dhjr@jd`dhjdadhjdb|ÛdhjUrjdcdh| |dd|dt |d͝| |dddΜcYd}~St}|dd}|jtjkr)d}ljjC}|jI}||kr|Ȑj(|ljjt}ddj)etQ|drd|_d|_jdf|d dg|d d`dh|%dz }%|%|RkrtI| }ʉK| ||J|%\} }d}tI| |ks||kr?dh|d di|d djt#jd d}YYd}~n |jtjtjfv}|rrjtIjkrUt'j}|s=dk|jqr d}Od}%d}QYd}~%P|rj)dbkr|jtjkr|sd} ddllm}ΐm}t}|d+d}|rt}|Аdmdnd}||щjn}|r|||ontj'dpn#t:$rYnwxYw|r|P}OYd}~&|jtjk}|Ґr|%dz }%|%|Rkrjdq|Rdrdhjdsdhtjjdt|Rdu| || d|dv|RdwddddxcYd}~Sdy|%d1|RdtI| }ʉK| ||J|%\} }d}tI| |krJdz|ʛdgtI| d{t#jd d}YYd}~ ngjd|dhjdsdhtjjd}| || d|d~ddddxcYd}~S|jtjk}|ӐrljjC}|jI}ɐt5+}|ԁt7d|Ԑdz }|Չ_jd|d d|d d|d ddh|%dz }%|%|Rkrjdq|Rdwdhjdsdhtjjd|Rdu| || d|d|RdwddddxcYd}~Sd}YYd}~ nt;+}t}d dpd}t}dOdpdd1}|אdvp|ؐd}|o |duod+v}|r2||kr,|}ۉjd|d di|d ddhn:|r(|}ۉjd|d ddhntA|ɦ}|r||kr|Ȑj(|ۉjt}ddj)etQ|dr!d|_t|o||k|_jd|d dg|d d`dhn jddh|%dz }%|%|Rkrjdq|Rdwdhjdsdhtjjd|Rdu| || d|d|RdwddddxcYd}~Sd|Jd d|%d1|RdǝtI| }ʉK| ||J|%\} }d}tI| |ks|rc||kr]tI| |kr,dz|ʛdgtI| d{t#jd d}YYd}~njddhjddhtjjd|Jd d| || d|d|Jd dddddxcYd}~St |tntlfo@t |ttj!f ot |tDj# }|ps|j ok|j oc|jtjtjtj$tjtjtjtj fvo| }|ݐrd|dr d}Od}%d}QYd}~-|]|]d|d|d |jd|ddhjdS|›dT|ÛdhjdU|Adh|j%s|jtjkr2|d$kr|d%krjddhjddhjddhjddhnÉjddhjddhjd|ÛdQdhtMt |Adr jddhn jddhtjjd||dkr;|JdkstI|;dkr!jddhn| |d| |ddt |djcYd}~S|O|Pkr|Qs$'||O|Pr d}Qd}OYd}~0‰d|Pdr d}Od}%d}QYd}~0 |}|rd|Pd|ޛnd|Pd|ޛjd|ޛdht}|dd otQ+fddD}|r@jddhjddhtjdj|P|||tI|;|Jd |]|]d|| |d|Pd|ޛ}|r|dz }|| |dd|djcYd}~Sd}|rt}t}|d+ddmd}|r{tQ|dri|:dp|:d}|r; tStk|d}n#tltnf$rYnwxYw|r|nts|OddĦ}z|r&d|zdd|Odzd1|Pdǝn!d|zdd|Od1|PdǝtL?d|z|O|P|t#j|zz}{d}|t#j|{krjUr^jdʝdh| |d|Od1|Pd͝| |dddΜcYd}~St#jdϦ||dz }|||dzdkrC`d|Od1|PdҐtk|{t#jz dӝt#j|{kYd}~nd}~wwxYw|O|Pk4| rd}&n|Yr(|dz}j"*|Odz }Od}Y?|Zr3jrjnd}||"dzz}tS|dŦ_?S|\4d}&tjdǝ| |ny }i}jdkr j|d<|j|\fi|}|}|j}[|jt |jt ss|j}t |trG|:d>dp)|:d8dptj||_nt |tVrg}|D]}t |t r|4|-t |trD|:dɦd>kr*|4|:d>dt |tr,d>|vr(|4t |d>d O||_nt ||_ ddlr( >dn#t:$rYnwxYw?|| ||d}#d_@d|j1D} | dhkrj"*jC}|jAdkr |jA} nt| } jBrU|| r?6dK| |jCjA|%\} }d}| _| P|jpd}d_|set}ddpd}|ryd}&|N}tL'dtI|d|}d_Bnt}dd}|rt}ddr{d}&tL'ddd_d_d_|N}d_BntQd| ddD}|rt}ddsd_d_d_tL'd d ||[}d |d8<| 4|| 4dd dRtt}|dGdp#t}|d dpt}|dJd}|rjd krxjdz c_tL'djdjd|dզ}d|dI<| 4|| _| SӉ|N }|o jd k}|rj|r|rdjd$krYxjdz c_tL?djj(djdٝTy|rjrtL?djj(j)drWd_dj(dj)dtL'dj(j)U1d}&C|}||[}d |d8<| 4||r\tI|dWkr|ddWdzn|}tL?d|dnQtL?djj(j)djrdndzd }nd_d_jdkkrj1r|!d krD||| r|!dz }!|dզ}| 4|0|ddd}| 4|| _| Vd}!|$r |$|z}d}$d}"|N}||[}| rt | d<trg| d<:dIrL| r| r6t | d<tr| d<:dIL| 4|d |[d}&j5s6d!|d"n#t:$r}d#|dt |+ td$+n4#ttnf$rtL+YnwxYwtLAd%|d&ttI| dz dt}d?ddzj(d j)dOjd@jdAjdBjdCjdDjdjjjt}jCdEdpdjjjdF}&i}'|'r|'|&dG<d_B| rjWr jW|&dH<d_ d}(jgdkr#jhjgkrd;j1vr d}(d_hH| || I|rA| s?| s|(r: ItW| | |(Jn#t:$rYnwxYw ddl= %s threshold (model %s, ctx %s)r,u📦 Preflight compression: ~z tokens >= z thresholdrJ)rrR pre_llm_callr)rrrq is_first_turnrrg sender_idr[rKzpre_llm_call hook failed: %sinterrupted_by_useru2 ⚡ Breaking out of tool loop due to interrupt...zstarting API call #budget_exhaustedu% ⚠️ Iteration budget exhausted (rz iterations used)rrrrrYr cg|]h}t|t|dd|d|dddiS)rrpr r)rprrr)rr_results_by_ids rZrz,AIAgent.run_conversation..%s~*** %'#-b$#7#7*,.zN6,B.<.@.@.N.N13J1C1CK1P1P!"!"***r\z&step_callback error (iteration %s): %srlr4r)rr*z.c&s.DDc#c((mmDDDDDDr\u🔄 Making API call #u 📊 Request size: z messages, ~z tokens (~z chars)u 🔧 Available tools: )brainsparklepulsemoonstarr zAPI Request - Model: z , Messages: z , Tools: zLast message role: zTotal message size: ~z tokensrr})nous_rate_limit_remainingformat_remainingu,Nous Portal rate limit active — resets in .u⏳ z Trying fallback...rzg No fallback provider available. Try again after the reset, or add a fallback provider in config.yaml.)rOr  api_callsrfailedrrrlpre_api_request) rRrrgrr|rr}rBr tool_countapprox_input_tokensrequest_char_countrHERMES_DUMP_REQUESTS preflightr,cvrddjrddSdSrt)rr)rXthinking_spinnersrZ _stop_spinnerz/AIAgent.run_conversation.._stop_spinner&sT+4,11"555/3,17 2226666677r\r`rrru⏱️ API call completed in r! rrzN/AzAPI Response received - Model: z , Usage: rzresponse is NonerG>r cancelledrrzResponses API returned status 'z>Codex response status='%s' (error=%s). Routing to fallback. %szresponse.status=rTrKzaCodex response.output is empty but output_text is present (%d chars); deferring to normalization.rHzeCodex response.output is empty after stream backfill (status=%s, incomplete_details=%s, model=%s). %sz api_mode=rzresponse.output is emptyz/response.content invalid (not a non-empty list)rz/Bedrock response invalid (no output or choices)r"z#response has no 'choices' attributezresponse.choices is Nonezresponse.choices is emptyu(´;ω;`) oops, retrying...u<⚠️ Empty/malformed response — switching to fallback...Unknownrr%zmodel=cni|]2\}}|d|t|dd3S)rENrz)rrcrs rZrz,AIAgent.run_conversation..'sA)v)v)vdadedpdpqtdudu)v!SVVDSD\)v)v)vr\z*Response attributes for invalid response: ri z-upstream provider timed out (Cloudflare 524, z.0frizupstream gateway timeout (504, rz'rate limited by upstream provider (429))rizupstream server error (r)iizupstream provider overloaded (rezupstream error (code r1zfast response (r us) — likely rate limitedzslow response (us) — likely upstream timeoutzresponse time u&⚠️ Invalid API response (attempt z): u 🏢 Provider: u 📝 Provider message: u ⏱️ u⚠️ Max retries (u.) for invalid responses — trying fallback...u❌ Max retries (z,) exceeded for invalid responses. Giving up.zInvalid API response after z retries.z retries: )r rr rr r r) base_delay max_delayu⏳ Retrying in zs (z)...zInvalid API response (retry z | Provider: u3⚡ Interrupt detected during retry wait, aborting.z$Operation interrupted during retry (z , attempt z).)rOr r rrPrQrzretry backoff (z), z s remainingr incomplete>rmax_output_tokensruA⚠️ Treating suspicious Ollama/GLM stop response as truncateduQ⚠️ Response truncated (finish_reason='length') - model hit max output tokensrm z8<(?:think|thinking|reasoning|REASONING_SCRATCHPAD)[^>]*>zModel used all output tokens on reasoning with none left for the response. Try lowering reasoning effort or increasing max_tokens.uV💭 Reasoning exhausted the output token budget — no visible response was produced.u ⚠️ **Thinking Budget Exhausted** The model used all its output tokens on reasoning and had none left for the actual response. To fix this: → Lower reasoning effort: `/thinkon low` or `/thinkon minimal` → Or switch to a larger/non-reasoning model with `/model`)rOr r rpartialr)rrru↻ Requesting continuation (z/3)...z[System: Your previous response was truncated by the output length limit. Continue exactly where you left off. Do not restart or repeat prior text. Finish the answer directly.]z9Response remained truncated after 3 continuation attemptsu=⚠️ Truncated tool call detected — retrying API call...uf⚠️ Truncated tool call response detected again — refusing to execute incomplete tool arguments.z-Response truncated due to output length limitu3 ⏪ Rolling back to last complete assistant turnu-❌ First response truncated - cannot recoverz3First response truncated due to output length limitr)rcompletion_tokensr_context_probed_context_probe_persistableu💾 Cached context length: z tokens for z cache=rdrzz%)zHAPI call #%d: model=%s provider=%s in=%d out=%d total=%d latency=%.1fs%sr{)r|rr{includedsubscription_included) input_tokens output_tokenscache_read_tokenscache_write_tokensreasoning_tokensestimated_cost_usd cost_status cost_sourcebilling_providerbilling_base_url billing_moderrBzToken usage: prompt=rz , completion=r z, total=ru 💾 Cache: z tokens (z% hit, z written))clear_nous_rate_limitz API call #z completedu ⚡ Interrupted during API call.z3Operation interrupted: waiting for model response (z s elapsed).u(╥_╥) error, retrying..._unicode_sanitization_passesrz'ascii'rI surrogatez'utf-8'ruH⚠️ Stripped invalid surrogate characters from messages. Retrying...uP⚠️ Surrogate encoding error — retrying after full-payload sanitization...rRrrru⚠️ API key contained non-ASCII characters (bad copy-paste?) — stripped them. If auth fails, re-copy the key from your provider's dashboard.ud⚠️ System encoding is ASCII — stripped non-ASCII characters from request payload. Retrying...uT⚠️ System encoding is ASCII — enabling full-payload sanitization for retry...rrkrTi@ r|)r|rrrT num_messageszTError classified: reason=%s status=%s retryable=%s compress=%s rotate=%s fallback=%s)rrrrrru8🔐 Codex auth refreshed after 401. Retrying request...ru<🔐 Nous agent key refreshed after 401. Retrying request...)display_hermes_homerrru/🔐 Nous 401 — Portal authentication failed.z Response: zS Most likely: Portal OAuth expired, account out of credits, or agent key revoked.z Troubleshooting:u6 • Re-authenticate: hermes login --provider nousuA • Check credits / billing: https://portal.nousresearch.comu$ • Verify stored credentials: z /auth.jsonuK • Switch providers temporarily: /model --provider openrouterruA🔐 Copilot credentials refreshed after 401. Retrying request...rruC🔐 Anthropic credentials refreshed after 401. Retrying request...zBearer (OAuth/setup-token)zx-api-key (API key)u-🔐 Anthropic 401 — authentication failed.z Auth method: rz Token prefix: z Token: (empty or short)u" • Check ANTHROPIC_TOKEN in z+/.env for Hermes-managed OAuth/setup tokensu$ • Check ANTHROPIC_API_KEY in z)/.env for API keys or legacy token valuesuJ • For API keys: verify at https://platform.claude.com/settings/keysuD • For Claude Code: run 'claude /login' to refresh, then retryu= • Legacy cleanup: hermes config set ANTHROPIC_TOKEN ""uA • Clear stale keys: hermes config set ANTHROPIC_API_KEY ""rGuV⚠️ Thinking block signature invalid — stripped all thinking blocks, retrying...zP%sThinking block signature recovery: stripped reasoning_details from %d messageszAPI error recovery (attempt z;API call failed (attempt %s/%s) error_type=%s %s summary=%srz [HTTP r2u!⚠️ API call failed (attempt u 🔌 Provider: z Model: u 🌐 Endpoint: u 📝 Error: rru 📋 Details: u ⏱️ Elapsed: z s Context: z msgs, ~zsupport tool useu$ 💡 No OpenRouter providers for z1 support tool calling with your current settings.zU Your provider_routing.only restriction is filtering out tool-capable providers.zY Try removing the restriction or adding providers that support tools for this model.zH Check which providers support tools: https://openrouter.ai/models/u?⚡ Interrupt detected during error handling, aborting retries.z+Operation interrupted: handling API error (rbuO⚠️ Anthropic long-context tier requires extra usage — reducing context: ru🗜️ Context reduced to z tokens (was z), retrying...u9⚠️ Rate limited — switching to fallback provider...)is_genuine_nous_rate_limitrecord_nous_rate_limitr=)r=last_known_state)r=rzNous 429 looks like upstream capacity (no exhausted bucket in headers or last-known state) -- not tripping cross-session breaker.u❌ Max compression attempts (z&) reached for payload-too-large error.uR 💡 Try /new to start a fresh conversation, or /compress to retry compression.z413 compression failed after z attempts.z5Request payload too large: max compression attempts (z ) reached.)r rr rr r compression_exhaustedu@⚠️ Request payload too large (413) — compression attempt u🗜️ Compressed z messages, retrying...u2❌ Payload too large and cannot compress further.z/413 payload too large. Cannot compress further.z9Request payload too large (413). Cannot compress further.@uM⚠️ Output cap too large for current prompt — retrying with max_tokens=z (available_tokens=z; context_length unchanged at z!Context compression failed after z3Context length exceeded: max compression attempts (>rr)z https://api.minimax.io/anthropicz"https://api.minimaxi.com/anthropiczcontext window exceeds limit (z!Context limit detected from API: zBProvider reported overflow amount only; keeping context_length at z tokens and compressing.u3⚠️ Context length exceeded — stepping down: uM⚠️ Context length exceeded at minimum tier — attempting compression...u🗜️ Context too large (~u tokens) — compressing (u8❌ Context length exceeded and cannot compress further.u 💡 The conversation has accumulated too much content. Try /new to start fresh, or /compress to manually trigger compression.zContext length exceeded: z! tokens. Cannot compress further.zContext length exceeded (z" tokens). Cannot compress further.u!⚠️ Non-retryable error (HTTP u) — trying fallback...non_retryable_client_error)rru❌ Non-retryable error (HTTP u%❌ Non-retryable client error (HTTP z ). Aborting.uK 💡 Codex OAuth token was rejected (HTTP 401). Your token may have beenz? refreshed by another client (Codex CLI, VS Code). To fix:z? 1. Run `codex` in your terminal to generate fresh tokens.z3 2. Then run `hermes auth` to re-authenticate.u9 💡 Your API key was rejected by the provider. Check:u- • Is the key valid? Run: hermes setupu+ • Does your account have access to ru? • Check credits: https://openrouter.ai/settings/creditsu6 💡 This type of error won't be fixed by retrying.zNon-retryable client error: iruU⚠️ Skipping session persistence for large failed session to prevent growth loop.)rru") exhausted — trying fallback...u❌ Rate limited after u retries — u❌ API failed after u 💀 Final error: c3 K|]}|vV dSrgrw)rrurs rZrz+AIAgent.run_conversation..,s7$$qAN$$$$$$r\)rNrOrPrRrQrSu 💡 The provider's stream connection keeps dropping. This often happens when the model tries to write a very large file in a single tool call.z~ Try asking the model to use execute_code with Python's open() for large files, or to write the file in smaller sections.zP%sAPI call failed after %s retries. %s | provider=%s model=%s msgs=%s tokens=~%smax_retries_exhaustedzAPI call failed after u The provider's stream connection keeps dropping — this often happens when generating very large tool call responses (e.g. write_file with long content). Try asking me to use execute_code with Python's open() for large files, or to write in smaller sections.rrrr+rgN@u⏱️ Rate limited. Waiting z s (attempt z4Retrying API call in %ss (attempt %s/%s) %s error=%szr _thinkingzreasoning.availableuL⚠️ Incomplete detected (opened but never closed)u🔄 Retrying API call (z/2)...uA❌ Max retries (2) for incomplete scratchpad. Saving as partial.z/Incomplete REASONING_SCRATCHPAD after 2 retriesrru0↻ Codex response incomplete; continuing turn (z/3)z@Codex response remained incomplete after 3 continuation attempts_codex_incomplete_retriesu🔧 Processing z tool call(s)...z Tool call: z with args: u🔧 Auto-repaired tool name: 'z' -> 'cNg|]!}|jjjv|jj"Srw)rrpr)rrrXs rZrz,AIAgent.run_conversation.. .s;***-/;+43HHH (HHHr\u⚠️ Unknown tool 'u2' — sending error to model for self-correction (uI❌ Max retries (3) for invalid tool calls exceeded. Stopping as partial.z#Model generated invalid tool call: zTool 'z#' does not exist. Available tools: zZSkipped: another tool call in this turn used an invalid name. Please retry this tool call.rvr(c3K|]P}|jjdDv|jjpdd VQdS)ch|]\}}|Srwrw)rr"rEs rZrz5AIAgent.run_conversation...S.s3T3T3T$!QA3T3T3Tr\r)r0r2N)rrprrr>)rrinvalid_json_argss rZrz+AIAgent.run_conversation..P.sw)) "!{/3T3TBS3T3T3TTT"$!6!<" D D F F O OPZ [ [[TTTT))r\u>⚠️ Truncated tool call arguments detected (finish_reason=u) — refusing to execute.u1⚠️ Invalid JSON in tool call arguments for 'r u;⚠️ Injecting recovery tool results for invalid JSON...ch|]\}}|Srwrw)rrprEs rZrz+AIAgent.run_conversation..|.s,S,S,SgdAT,S,S,Sr\c3BK|]\}}|jjk|VdSrgr)rr"rArs rZrz+AIAgent.run_conversation...s9.h.hTQRSWYWbWgRgRgqRgRgRgRg.h.hr\zError: Invalid JSON arguments. z_. For tools with no required parameters, use an empty object: {}. Please retry with valid JSON.z;Skipped: other tool call in this response had invalid JSON.>rr2rlrc34K|]}|jjvVdSrgr)rr_HOUSEKEEPING_TOOLSs rZrz+AIAgent.run_conversation...sB00 "K,0CC000000r\u ┊ 💬 c&h|]}|jjSrwrrs rZrz+AIAgent.run_conversation...s Y Y Yb!1 Y Y Yr\ execute_codeu ⟳ compacting context…rpartial_stream_recoveryuGPartial stream content delivered (%d chars) — using as final responseuD↻ Stream interrupted — using delivered content as final response_last_content_with_tools$_last_content_tools_all_housekeepingfallback_prior_turn_contentuOEmpty follow-up after tool calls — using prior turn content as final responseuM↻ Empty response after tool calls — using earlier content as final answerc3HK|]}|ddkVdSrrrrs rZrz+AIAgent.run_conversation..m/sE.. !EE&MMV3......r\_post_tool_empty_retrieduHEmpty response after tool calls — nudging model to continue processinguD⚠️ Model returned empty after tool calls — nudging to continuerz~You just executed tool calls but returned an empty response. Please process the tool results above and continue with the task.rFuMThinking-only response (no visible content) — prefilling to continue (%d/2)u7↻ Thinking-only response — prefilling to continue (z/2)uBEmpty response (no content or reasoning) — retry %d/3 (model=%s)u/⚠️ Empty response from model — retrying (uOEmpty response after %d retries — attempting fallback (model=%s, provider=%s)uL⚠️ Model returning empty responses — switching to fallback provider...u↻ Switched to fallback: z.d0sP((( !)!T22(89uuV}}7N7Nn-7N7N7Nr\r zError executing tool: zerror_near_max_iterations(z0I apologize, but I encountered repeated errors: zmax_iterations_reached(u#⚠️ Iteration budget exhausted (u) — asking model to summariseu) — requesting summary...c3K|]I}t|tr2|ddk0|dEdVJdS)rrrrNrr s rZrz+AIAgent.run_conversation..0sf  !T"" '(uuV}} 'C'ClH[H['C 'C'C'C'C  r\zuTurn ended: reason=%s model=%s api_calls=%d/%d budget=%d/%d tool_turns=%d last_msg_role=%s response_len=%d session=%sz>Turn ended with pending tool result (agent may appear stuck). z last_tool=%s post_llm_call)rrassistant_responserqrrgzpost_llm_call hook failed: %srOlast_reasoningr r rr rPresponse_previewed_response_was_previewedr r r r r r)r rrr r r pending_steerinterrupt_message)rNrOrP)rjrkrlrI)rrrPrrgzon_session_end hook failed: %s)r (Jrrr rrrbrcrr rrrrr_current_task_id_invalid_tool_retries_invalid_json_retries_empty_content_retries_incomplete_scratchpad_retriesr _thinking_prefill_retriesr r r rr r}r6rrrrrrrrDrdrr6rrr|rgrr has_itemsrfrrrrrrrrrr get_sessionrrrr ror7rrr rkrdrRr-rRrrTr=rrrrrrrrrrrrrr on_turn_start prefetch_allrrrnew_turnrr4rrrrrrdrrr&rrrrrrrrrkrrrprrrxrr6rrrrrr8rGrrr,rrr3 r4 rEget_thinking_facesget_thinking_verbsrrrrrrrragent.nous_rate_guardr r rr ImportErrorrr:rrTrrorrrPr rrrrrrrvalidate_responserjrr"rrrrrvarsrrr:rarr!r"rmap_finish_reason stop_reasonrq rrrr;rr rrUr_r rrrrr@rr rupdate_from_responser1r r rrrrrr rrr rr rr r? amount_usdrrrGrr.rupdate_token_countsr rOUnicodeEncodeErrorr rQrUrNrr{rrr"rrr retryableshould_compressshould_rotate_credentialshould_fallbackrr{rrhermes_constantsr rrrrrr#thinking_signaturerrrrlong_context_tierr rrrbrr r rpayload_too_largecontext_overflowr0rrr/rrr.r9sslSSLError overloadedis_authrNrrrrrrrrrKrrrrprrrr nextrr frozensetallrrrrrr rQrCr`r rrTr(/rXrrjrqrRr r r r _preview_text _msg_previewr rN_should_review_memoryuser_msgcurrent_turn_user_idx_print_preview stored_prompt session_row _invoke_hookrurAactive_system_prompt_preflight_tokens_pass _orig_len_plugin_user_context _pre_results _ctx_partsr rBrOrPcodex_ack_continuationslength_continue_retriestruncated_tool_call_retriestruncated_response_prefixcompression_attempts_turn_exit_reason _turn_msg_ext_prefetch_cache_query prev_tools_idx_m _fwd_start_tm_tcid _step_err_pre_api_steer _injected_si_smr7rr0rrequest_loggerrepaired_tool_callsrrrrg _injections_fencedrru rv rw amtcsnew_tcsargs_obj total_charsrrF verbr api_start_timerrprimary_recovery_attemptedmax_compression_attemptscodex_auth_retry_attemptedanthropic_auth_retry_attemptednous_auth_retry_attemptedcopilot_auth_retry_attemptedthinking_sig_retry_attemptedr restart_with_compressed_messages restart_with_length_continuationrrrr _fmt_nous_remaining_nous_remaining _nous_msgr _use_streamingrr resp_modelresponse_invalid error_details_ct_v_codex_resp_status_codex_error_obj_codex_error_msg _out_text_out_text_stripped _resp_status_resp_incomplete_tv_btv_ctvr% resp_attrs_resp_error_code _code_raw _failure_hintcleaned_provider_errorr sleep_end_backoff_touch_counterrGrHincomplete_reason_tfr_bt_fr_bedrock_result_cc_fr_finish_resultr _trunc_msg_trunc_transport _trunc_result_trunc_content_trunc_has_tool_calls_has_think_tags_thinking_exhausted_exhaust_error_exhaust_response interim_msg continue_msgpartial_responserolled_back_messagescanonical_usagerr r usage_dictctx _cache_pct cost_resultrwrittenr~hit_pctr api_elapsedr_err_str_is_ascii_codec_is_surrogate_error_surrogates_found_messages_sanitized_prefill_sanitized_tools_sanitized_system_sanitized_sanitized_system_sanitized_ephemeral_headers_sanitizedr_credential_sanitized_raw_key _clean_key_any_sanitizedrr _compressor_ctx_len classifiedrecovered_with_pool_dhh_fn_dhh _body_text_bodyrr auth_method elapsed_timer_error_summary _provider_model_status_code_str _err_body _err_body_str _reduced_ctxrZold_ctx original_lenis_rate_limitedpool_may_recover_genuine_nous_rate_limitr r _err_resp _err_hdrsis_payload_too_largeis_context_length_error available_outsafe_out parsed_limit_provider_lower _base_loweris_minimax_providerminimax_delta_only_overflownew_ctxis_local_validation_erroris_client_error_final_summary_is_stream_drop_final_response _retry_after _resp_headers_ra_raw _boost_base_boostr_normalize_kwargsrrrr_assistant_tool_calls_assistant_text _think_text first_lineinterim_has_contentinterim_has_reasoninginterim_has_codex_reasoninginterim_has_codex_message_itemslast_msglast_codex_itemsinterim_codex_itemslast_codex_message_itemsinterim_codex_message_itemsduplicate_interimr7invalid_tool_callsr invalid_nameinvalid_previewrr r _truncatedrrecovery_assistant invalid_nameserrr turn_content_all_housekeepingclean _had_prefill _tc_names _real_tokens_partial_streamed _recoveredfallback_prior_was_tool _nudge_msg_has_structured _truly_empty_prefill_exhaustedrbreasoning_preview final_msg answered_idserr_msgr_last_msg_role_last_tool_name_tcs_turn_tool_count _resp_len _budget_used _budget_max _diag_msg _diag_argsr r_leftover_steer_should_review_skillsr r rr rr s/` @@@@@@rZrvzAIAgent.run_conversation#s<  766666DO,,, %%''' lC ( ( >/ ==L *C 0 0 N#78L#M#M  lC ( ( :+L99L *C 0 0 J#34H#I#I !0)-&.B+#8s4:<<'8'8 !2&'"%&"&'#./+)*&)*&(-%(,%491#( ,-) =0 0 0 1133%%&       $ -  , , . . .(,D % !00C D D8 EE 7:=7I7IB7N7N crc*U22Ta #++D#66  ^ O %vtz4=3MI M &Y,@,FB(G(G     2FM4,---2  ;(8(B(B(D(D ;  $ $%9 : : : "9M8X 4 4^j !&  '! + + 555&6  $ $ ) $ $'4+FFF(,%+,(#|<<!!! #H  1)>& @<\JJN   ~^CRC=P~[^_m[n[nqs[s[sRWRWy{~~~     % - M# (8 "&"2">">t"O"OK"Q(3(H(H(PD  D V.;**.2-F-F~-V-V* LNNNNNN L*#'?"j!(z4!@!@!FB  !LLLNN#EsKKKKKKKKL#VV(==dotOijjjj$VVV %QSTUUUUUUUUV $9  $; H  7 G"&"9"H!IKL!MMM !>28bj(D!!!  !D$;$LLL Z(,,.?CCJ.=AA $$U8IUUU"5FTUUU #1XXE #H I595K5K .@Q 16L662H28}} 11 ,0( 34D/56D248D1@ED=/4D,(E &:&@b"j0D)))% )4+B+SSST " @ F F F F F F'<?2%)(^^#'(<#=#==j z488>B!$ D99?R   L%'J! ) )a&&)155+;+;)%%c!I,&7&788883'')AGGII)%%a((( ?'-{{:'>'>$ @ @ @ NN93 ? ? ? ? ? ? ? ? @ "#"#&'#$&! % %.$<$>$>$D! ud7888  $ : 4!: ; ; ;49D 1 1&*D #49D 1    5?@UWZ5[5[c11ac $2243H)TTTT    !    2<=RTW2X2X`..^`&*&:&G&G&O&O&USU##     3338M8WZ[8[8[`d`w8[  ) ) + + +( " $9!\$$%Z[[[ a N#1D  !G~!G!G H H H & */''*2244 $6!_$$&^dNcNh&^&^kolAlK&^&^&^___!-f!#J$-hx.@.@$A$A""b66&>>[88RVVL=Q=Q8),X)=J-/N'/ '<SS#&776??f#<#<$)E(+(?(?#(!S[deeeeeeeef *Q..&$*???''1,''"6688N# q!  X!2B;;C"3-C!#t,,F1J1J!G~!G!G#&779b#9#9%h44 %-5->C NN%;C)Kh & vv.N.N O O O17I#,%%% $%$(  Z q$D*?FFE("EE#2E6:6ID6PSa6a 3 36D 3 EEEEEEEEEEEEEEE $+41A4#H#HT\.px$/O/Obp+%T8T::Yg>OPX>Y>YN"&"D"D%?#E##  #Q&&##\'O*s L%h//* -* -S((**///CGGFOOv4M4M"$K*8"<=P"Q"Q"8'..w777+A#**+?@@@"[ ' Ir : :%eS11[16&++kBZBZ1ZGI.44S'BBB'))KK ,,,"g--KK000 /666 3355F<N O OPS__ $ F"29QQ )$*? @ @FFHC '' S(8#((**EEEE' < "o%)%B     66|DDL# : :bffY//55:$&yM$7$7$9$9ByM" + +ff\**''B!"d++ b0@0@ '+z"Z.2M'N'NH"B" 5"$Z.5 +TZ$,.2."."."55""BB ):U ":{ ; ": 2 263 ? ?;;BzN;777 NN2&&&&#*<  *, 7 7 7DD|DDDDDK:<HHM $ ? - r$/rrrrZ^Zmrrrsss XXs+>T+>+>+>????3355-$:Z:Z:\:\-$*=1^1^1^#_#_L'45H5Ht5H5H5HWcnrn|'}'}'}$$**,,,# P MdjMMcRZmmMMy}zDgKfijnjtfufufuJKMMNNN bH4`HRL4H4HZ`bbccc NmNNNNOOO!Y[[NK/K). &'( $', &+0 *&+ %). (+0 (#O/4 ,/4 ,"MHJ ++ =F**'+D*C*E*E*6?Q;N;N!U-@-@-Q-Q!U!U!U&!LL#'? V V V V V&*)!--.@Y.@.@AAA#::<<)./ 78 4=B : ( 11(>U44Z 4TTT777777&*Nt%95AA3).!77993766666%gdHd&C&CTJJ3-2N%L#'#I#I&}$J$$$(#?#? #K#K#'9;;#?L(0(--b111+/(-3..r222?l %j%jWc%j%j%j%jkkk+XJR%]WXw%F%F%FX]  'W 'W'WovwBIpJpJ^U]e]k]kPU'W'WXXX(-$$&M}(999 $ 3 3 5 5$66x@@-Y'/37 0 - 4 45G H H H H 698UW9X9X9^\^5_5_5e5e5g5g5m5m5o5o 2#59P#P#P7>xRV7W7W$4KUVfhlKmKm)e(8(<(>>"1133"44X>>h/3,'/ - 4 45G H H H H - 4 45f g g g*<<<#2244#55h??h/3,'/ - 4 45G H H H H - 4 45f g g g#2244#55h?? R/3,'/ - 4 45G H H H H%,Xy%A%AR - 4 45Z [ [ [ [!)!1!9 - 4 45O P P P P - 4 45P Q Q Q'D!+4,112OPPP/3,17 222666$q(  /#d6J2K2KKK --.lmmm6688%*+K3409>6$%. (1 #>'(B(B>x~>(+HN(;(;I&x~zBBhx~G^h080G0K0KO]f0g0g %>'(I*F*F>8K[>(+H,<(=(=I)I55(5wxY`GaGa5fnft5,EX^,E,EM)I55(5)v)vd8nnFZFZF\F\)v)v)vJ#3i ' .g[e.g.g h h h,0(#)'(B(B)x~)(/(M(MI(0ZPT5U5U0,4N,>,>v,F,F (4!)7:9~~$4$4(1:'>!)!)!)$(D!) ,s22,p\h,p,p,p,pMM-44,bl,b,b,b,bMM-44,VMM-;;,nFV,n,nZf,n,n,n,nMM-;;,`M],`,`,`MM-9,lDT,l,lXd,l,l,l,lMM)B..,jl,j,j,j,jMM)B..,nl,n,n,n,nMM,P\,P,P,P,PM &X&X_j&X&Xmx&X&X~B~G~GHU~V~V&X&X`d eee %Z%Z=%Z%Zbf ggg151J1J91U1U. %k%kSi%k%ksw xxx %S%SM%S%S[_ ```&+55 --/A[/A/A/ABBB#::<<)./ 78 4=B : ( --.{+.{.{.{|||#MT_*o*oYd*o*o*oppp 11(>>#2244(,(>(>x?S(T(T *<<+>+@+@(=,@@@,<,O,O (D#>$(LL+/?)L)L,C)L)L)L%&%&%& 17-i4&4&L%-OOL$A$A$A=ED$:$($:$:8$D$D$DGK$D$)373K3KLe3f3f3l3l3n3n 0 $ < <=N O O O $ 5 5h@T U U U6F6N$081?16/3-h ("("!" =,jjj0:-0#B#B$?1$D$?$(LL+/?(y(y(y.2%1%&%&%&%- $ '+%_%_%_*.!-!"!"!"!% < <=N O O O $ 5 5h@T U U U6:081?16/3-\ ("("!"x==1,, LLDO)p)p)pqqq373Z3Z[c3d3d0 889JKKK 11(@\^cddB 3DJ s S S S $ 0 0DO2A2Aad2A2A2Atxt~2A2A!B!B!BFKD3CQVD3N22mC2266:KK6611\A11..!3..11_5QQ1122o6SS2266/:[[6677?;]]77559YY55&( *<dd*d?3T*d*dWd*d*dhkl{mNiNO\i\*d*d*d*dJ f 2DJ @ZQZ)+3E03>3E0 +%%% $ 0 D D$(O1@1M2A2O6E6W7F7Y5D5U'2'='I8=[=S7T7T7TOS0;0B0;0B59]59]'2'9Z'G'G2I1HMQ*.*34!!E!"!"!"!"$$-%%% $% /x#M+wOA\+w+w+wmwyLnM+w+w+wYcdrYs+w+w+wxxx"1!B"1"D!+O!<"gtAG!v'<'KLLDO!U!U!U]aLbbb))(4HIII"&K%w[f%w%w%w%wNE JJJ'0(--.LMMM+/(-3..r222")-?@@W%WTSqstEuEuxyEyEy#&y>>#7#7#9#9*3x*?*V7hCV (83O )X 5 Mo:M,-J(,S,S)%lD999<\JJ948 1%j$779=jII948 1%gd4F&M&MtTT9DD=4DEY4Z4Z 1#48L#L#L;L$8ARD$>8<$5)'$8QSW*X*XZ]^^=7GHd7e7e 4#74;W#W#WCWD$@8<$516.$.gdH (;<@$9$(LL+/?)[)[)[/3 %1%&%&%&!==B== 3!9#5!9#3!9$5!9$6 !9 $9 + . " $ '+%]%]%]*.!-!"!"!"!" !% '+%M%M%M*.!-!"!"!"%HHHH"))]D"I"IK$($C$CI$N$NM#*$0Dd"K"KKQ\hw{4DfMMMbhH!3!!(z2!>!>!D"%dGR88>B&3'/:F%MS%6%6%6A """JLLn")/1G",j.H";Z=W <@;];]$/(7*4*;&3 <^<<8' +!  )::: M^;;'3.. :/6:2EEDEQQ% LLDO)u)u)uvvv$HHHH );;; MV33'3.. 9/591DD4DPP%!T_"r"r"rsss$HHHHTSSSSS&wyy%' !$+Ivt$D$D$lPY[egkHlHlE$0-0ZZ-= (!!! D!aaabbb%Q!T_"O"O:"O"OPPPFFFGGGEEEFFFhhhiiissstttffVZfffggg}}}~~~ 22'3.. </8<4GGII% LLDO)~)~)~$HHHH )==='3..#D*>??/ >/:>6KKKKKKIIKK%!T_"y"y"yzzz$HHHH"5FUoVYFZFZ&u&B&B`u ___```OO+OOPPPTW^\_`c\d\dgi\i\iPP3ss8PPPPrvsBp^p^p^___EEEFFFSSSSSS&wyyFFTXFFFGGGFFVZFFFGGG|||}}}vvvwwwqqqrrruuuvvv#)^-NNN <O8<4"*BBB)"d33B "':D A A A #III"&%  A OS]] !1$K#'9;;#?L((S{SS[SSS"&i!9J #I 4 4 6 6I%)%>%>y%I%INNNU##"0022& !(j) D DI#D*i@@E$T7I>>FCN'V'?'?'?'?'?TV$LLDO"S"SVa"S"Sdo"S"St~"SAQ"S"S[_L```LLDO!c!cy!c!c[a!c!ckoLpppLLDO!N!Nu!N!NVZL[[[LLDO!T!TN!T!T\`Laaa"k{S'8'8$+Ivt$D$D @I(SItt(<(T>>:H&:480"8}}|;;w?U?U $ 1 1%F,$Z%F%F,3$E%F%F%F!"!"!"!% 1 CG @ %'1&7&1&.<'O' )4+?#dFZB[B[+[+[,M 1,,( 0) --.ijjj#::*BS:TT)./ 78 4=B : (.((% MV33&-1JJJ 3K490!)0 :t(L(LI$-!7 9d C C C26&8R7Q(1151G8884 8 " 6 6,52?!"!"!"!"!" !( %=!"!"!" )!!! D!3%+6K$HHHH #)^-MM),.,1,/2JJJ LLDO*\*\[s*\*\*\dhLiii LLDO*P*P*PX\L]]]#MT_**[s***AAA 11( >  * 1 . 9 . 6 . 9 . ? . @ . @ . A:! '665$"'8))*sk*s*s*sttt6688%*+K3409>6$HHHH%1 88 *3OW`9))F[FF#88CCFF %w%w^i%w%w%w@D EEE %g%g9%g%g_e%g%gos ttt %R%R5%R%RZ^ ___%- A1BnF\1\1\(N::{c?Q?Q $ .M.M.MUY !Z!Z!Z $ .A.A.AIM !N!N!N $ .A.A.AIM !N!N!N $ -t-t-t}A !B!B!B!B $ -z-z-zCG !H!H!H $ -n-n-nvz { { { $ -u-ulr-u-u-u~B !C!C!C#8U_#U#U!R$(LLDO2E2E2EMQL%R%R%R LLDO)s)s)s{LAAA &a&aV_&a&abbb '#--=53H3HCP\L]L]`bLbLb LL#'?!T!T!T&*) !11(a>a%;K?b??%:>6*+K$HHHH))*p*p*p*pqqq6688%*+K3409>6$HHHH)-)B)B9)M)M*r --.r .r.rbp.r.rssss --.pk.p.p`n.p.pqqq %^%^n%^%^fj kkk!( =$ G GG #$$$$=$$$!!(+ LL#'?!?!?!?'+ )!LL#'?!-!-!-'+ ) n O[.%vs(0)7).&*%3   $(L&)(/ :t0T0TV_ae(f(f ()W]E-J-J)&3&7&7 &F&F&j-J[J[\iJjJjG&)!)36s7||S3I3ILL(1:'>!)!)!)$(D!)0<  BRS^knz~BBBI&x))+H)+H+H+Hdorsds+H+HwB+H+H+HIIII))*vY*v*v*vWb*v*vep*v*v*vwwwNNN!##0022! !% i 7I-.*)++ 114  LLDO)p)p)px|L}}} 11(#?#?!M!M!M#)++ 11mJQ ++j4 $A!/ !#%,,...q 380/ 26Jdood $(?!(CD474F4F1 $G!dddeee%%h0DEEEx !0022 $&!=$888=A=U%&9::Z:8YYGXYY $.! * 8 %,8L]LegjAkAk8+3C!#t,,=47GGFB4G4G4t377S\^`KaKa4teieopsetet)11#C.. = "$'@@D)$44@ % T 2 2 2 2!+D$!7!7@DHHV-> ? ? ?48IIe4D4D)1147HH)1NNNNNN,34E|UY,Z,Z,`^`)&7&?&E2O L* 1#'?#8b!%!4""j!%!%!%'5%1&3&),&7&7'.x$'G'G"FFxPP03O0D0D256K2L2L!$!D%,cT_c+c %d%dIZIb%d%deeee &b&bIZIbcgdgcgIh&bsvxIxQtRtRUXtXtXjojo^`&b&bccc&-!$2M!"3";"A"A"C"CK"$&G[##egg EP!W!2!24!8!8!;CRC!@!@UWJ! !gd4Eq&I&IA&M&M! 77 ZPPPP(!!! D!$!! 778M{\ghlilhl\mostttt(!!! D! -->-F-L"MM771<77LLDO"B"B"BCCC:a?? %|%|QUQt%|%|%|}}}  %z%z%zCG HHH>?;/3/V/VW_/`/`,445FGGG--h8LMMM/3(<)7).'+%V   783=$555-<:W:W22a722"&"?"?@QS`"a"aK*.  0J0J0Pb/W/W/Y/Y*Z*Z'^hitixixzEjFjFHK_L_L-WDb1Q1Q1W1W1Y1Y,Z,Z,ZRW)26{G^7_7_2`2`/6:;??K`;a;a6b6b3,N0N7N; N 4<#E8B<<U__gimTnTn+x8<<8O+P+P+Ptx(.9oo>U.V.V+ZdemosZtZt3~8<<@U3V3V3Vz~06AooF[6\6\3&x66X ( V 4 4 CX ( _ = = MX"*i!8!8!>BKOOT]D^D^Ddbd eX"*k!:!:!@bkooVaFbFbFhfh i X !14G G X !9??756D2%/U ?~ %|%|M^MiIjIj%|%|%|}}}+x"3">xxB#M*v 8H*v*vVXVaVklpmplpVq*v*v*vwwww0:<<;+43HHH'+'='=bk>N'O'OH'< %&|&|Y[YdYi&|&|qy&|&|&| } } }3; 0****3D3O***&*#!22a722%)IIfT5J.K.K$L$L '9!'< GJ  B!{/t7LLL*s2;3C*s*shq*s*s+G$OO(.02+2-- !12D.)+%/:QQ!{4%dT4L99%48Jt4D4DBK1$+JtS4I4I+47IIBK1#%;#8D#%4::<<%48BK1$Q Jt,,,,#3QQQ-44bk6FA5OPPPPPPPPQ)C%&)))))&7&B)))&& & LL#'?!^!^2?!^!^!^&*) :;D6 889JKKK 11(???-T,SAR,S,S,SM&7&B###%;#3}#D#D*..h.h.h.h=N.h.h.h*h*hC)I#)I)I)I%0K 3pK (,246E/:1"1"!#!#!#!# %23D.483P3P)444%0483O3O)444%0%)$A$ABSUb$c$cM $5#<#BL#D(K(KL(Y(YD8D5 /8999//+-00000&7&B000--)EVA,D1K1K1M1MD7;D44!BBDDD$($<$<\$J$J$P$P$R$RE$D $ -B5-B-B C C C$)L ,&x|T::,%RL,,-@AA, ! '+ !,&x|T::,%RL,,-@AA,$89:66735:D1OOM22288GGG1!! 66t<<<<(!!! D!,,->J[]klll 34/04D, !Z Y%D"N05D, >>~NNe$D*LbQQWUW* >>?PQQ"0I-)-)A)ABS)T)T)Z)Z)\)\J"KK!> #J !--!4.8N;?D8!$+41KT#R#R# "6\^c(d(d "0M-"KK(yzzz --.}~~~<@D9HMDE:;D7 .2-E-Eh-O-O-U-U-W-WN;?D8!+...%-bcc]...++ ,!%$+D2Le$T$T!%=AD9=AD9HMDE"KK!9!--!6*.)F)FGXZg)h)hJ4=Jy1$OOJ777$OO(.%P--%+/#$5{DIIU&'8:MtTTU&'8:MtTT++ +%t/MPQ/Q/Q ::a?::"KK!@ $ > !--!H$($B!H!H!H+/*G*G 1<++K@DK(;<$OOK8885=D2 228<<<$,0+C+C*,,%''(" ,D $ >! C+( % %DV %\`\wz{\{\{ 771<77"NN!8 $ ;TZ !--!E$($?!E!E!E%()D,@)"NN!N $ ;TZ $  !--!D $::<< )>? ; $ 1 1%9%9%9(, %9%9%9!"!"!"!' %9$(J !"!"!" !) -G))-)@)@AR)S)S(,(E(EFWYf(g(g 3< i0  666)PSTbPcPcfiPiPitt0Du0L0Lo}-"NN!01B !--!O #NN!7!% ;TZ $ !-- Q@D@T$I#<#<#H!J *334D/56D2 )::: 1;3a77 CC)5.<%-D8014/&*&C&CDUWc&d&d   444<<[III%+!U(( ! 55519...x888 ./+04)B^)S46123/&*%=%=n%M%M%S%S%U%UN $ = =>OQ^ _ _I!'&x|T::'%RL,,-@AA' !  !'&x|T::'%RL,,-@AA'OOI...(W}(W(W(W%?~(()|n)|)|)|}}}0 0 0 bbbZ]^_Z`Z`bb ,,,,----,,,,LL+++++, ?Z^ ___ !X!2B;;C"3-C%c400wwv&00 wwv+55#'',:O:O5((%-cAghh%7((( #&l"399B#%KZD-A-AK8!$x|;;,246tH/S /S/S+"+" !) 8 8 8"T%81%<<<(VYsPRs^(V(V(V%%cXa%c%cNOO[^$T$TUUUEEEE =<<<RRN#$.W>DDW3W  h(G (U(UW`aaa $$%6777 h(<=== 6>G"))&1114 V # #x((  66&>>[00RVVL5I5I0l+DS 47D 9 9S*.r(,,z2*F*F*J*J6*R*RE       ,:@C'''q 595JQt,11PQ 9=9NUd+55TU  H  tz>4;N + ni O %v   V # #K # NP-.  -      K /J / / / /  E+ E EJJJJJJ ##!6'5)-h*$T:t<<B E E E>DDDDDDDD EH%%  Cwwv+--#''+2F2F-!$[!1 n n        u   ;  !'$0I5"Q"Q  TZ        D5  T7  !?  !$"A  =! " T7# $"&!? 5")$*ACWYZ"["["`_`"&"A33/   83355  6&5F? #',$  B42 B*.*AF& ' !%!&  & * *+t/III"d&;;;$( !&'D # ++"7)# ,     + 3H La  --&*8nn"7"7.      B F F F F F F L ?#'j z488>B       B B B NN;S A A A A A A A A B sq-)F F$#F$&8O O,+O,0Q Q4Q//Q4?%R%% S/SSD]## ^-^  ^9a aa'5b b*)b*"C-j kj;;k0o oo "p99p=p=A A A@,@+A@,K(A=AN M&"AN N AN#N AN#N"AN#N'A4B`PA'ARRB`R ARRB`RARRU?B`hF B`nAn0n/B`n0AooB`oAooEB`t&AB`vC>B`zA=B`|J9B`F:B0B`I,AB`K 9B`LAB`MA8B`O=B`PJ B`ZBB\$\#B`\$ B\1\.B`\0B\1\1B,B`_B_0_/B`_0 B_=_:B`_<B_=_=B``BD^b; D^cFD^ iK"D^ uDD^ yAD^ z*AD^ |D^ |>B}}D^ } B}(}%D^ }'B}(}(DD^ B A#D^ C4G2D^ K,M D^ X5D^X;E D^ ^BD^ `%(D^ aA-Cb<b;D^ b< Cc cD^ cCc c D^ cB0D^ fD^f B!D^ h3A>D^ j1D^j7DD^ oD^oD^ o!ID^ x<D^yCD^ | B D^ ~D^~DD^ B.J6D^ M$D^M*'D^ N4D^ OE$D^ T5D^T;A(D^ V$ DWWD^ WDWWD^ WDWWD'D^ \D^\A>D^ ^ D^`7GFB.hB'Dj9j8FB.j9 DkkFB.kDkkDFB.o!Do:o9FB.o: DppFB.pDppFB.p $Dp2p1FB.p2 Dp?p<FB.p>Dp?p?A;FB.rFB.{B>FB.~DFB.B. FJB9FJCFC'C&FJC'.FDDFJDFDDE!FJJFJT)AFU,U, FVU6FVVFV](F^^ F^^ F^^5F__ F_8_F_3_3F_8c@|||}|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 )r rO)rv)rXrr rs rZrz AIAgent.chatI1s(&&w&PP&''r\)$?|@%A|B#C|D E|F (G|H%-I|J$K|L"M|NO|PsCx.Q|RS|T S>U|VtCH~.W|XY|Z[|\]|^_|`a|bc|de|f!g|h!i|jk|no|p,q|rS#Xs|v"w|x#&y|z{|||||%%7%7%7Nr r r r h$,1***D****6T&  $     UCUDUUUU(VSVTVVVV" EC Em E E E E E tCH~    B",,c,T,,,,))S)D)))) >E>>>>(uUD[7I0 $tCH~:N SX    LDLLLL#'"&"&# HHH3-H3- H 3- H } H tTz HHHHT %S %T % % %\ %#'<<<<3-<  <<<\<" %s %t % % % %%c%d%%%%.\3\3\\\\| Gc Gd G G G\ GHHHHH$( CCC4. C  CCCC>EeEeEetCH~& Ee  EeEeEeEePAx}AAAAFVsVtVVVVD L G4 G*<d<T < c<<<\<B$# ll:ll l  llllb'++/!%&* JJJsmJ$C= J # J sm J c3hJJJJ4*T$Z*D****$KKdK4PT:KKKK0F0Fd4j0FX\]aXb0F0F0F0Fd-4:-$t*---->?#????0cd4S>6JcX[chlcquvz{~AD|DwErFccccJ Dd38n)= D3 D[_ D D D D%&I%&#%&%&%&\%&N)(3-)HSM))))cc4>)>S#X>>>\>@CHTRUWZRZ^D\*&* PPPcNP P  " P $ PPPPd\@D@D$tCH~*>@D@D@D@DDBVBVBVBVBVBVBVH++++B"#"$""""Hhsm = T= RU= Z^= = = = ~(C(D(((( #$&&&& d    $6  d d    ) #) )  )  ))))V----^6666p4S#X+?D@))))X)eIeI3eI#eIeIeIeIV++++\+ !y!a!a!abbCd38n)=C$tCQTH~BVCCC\CJTd\<GDGTGGG\G"F3F3:FFFFP 0 0 0GGGGCGPSGGG\G66x}hsm7S1T666\6+/SSS#3-S SSSS/#//// S    Y_\:sC\0Y4YCYQUYZ]YYYYv88888\8t33QU0"ss D4DDDDLWsWsWWWWG3G3G4GGGG{{D{#{V^{{{{zLgLgDLg#LgLgLgLg\FJdd:EI!!!T!T!!!!F!!!!!F141111f=3=4====2JJJJF7;26 R&R&R&c]R& R& $N3 R&  S#X/ R& tTz R&R&R&R&hDTDDDD (P"$P"P"P"P"h3333CD1c1c111\1 >S >T > > > > LT#s(^ LPT L L L L7s7t7777(#$       t    ?CF "F "F "F "3;F "F "F "F "T11-D1PT1111FK$KKKK^#,)---## N"N47NFIN NNNNd#$\CE#xPT~BUMMMMMBDT8b db tb b b b H#T#T#T#T#TJ,TD[,,,,@[[QU[[[[z  D            3/$3/3/RV3/3/3/3/jTd\6 jjjj j jjj\jX 2T 2 2 2 2^br{QUp-p-p-$p-p-WZp-lop-KNp-Z_p-p-p-p-d**t*X[*mp*y}****. T c    (KOQQ#QdQWZQ#+C=QCGQSVQQQQf((S((S(s(((\(0mKmK$mKcfmKx{mKEImKmKmKmK^ AOAO$AOcfAOx{AOEIAOAOAOAOJ btbSbSbbbbN#59.2.2T5T5T5T5#4S>2 T5  T5 "(+ T5'smT5 c3hT5T5T5T5lj ( (C ((82D (PS ( ( ( ( ( (r\rprr1Frrrr{ 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(----------------------------------------)webrvisioncreativerE)research developmentrcontent_creation full_stacku 📌 Basic Toolsets:resolved_toolsrru • rz - rz Tools: u5 📂 Composite Toolsets (built from other toolsets):includesz Includes: z Total tools: r u! 🎭 Scenario-Specific Toolsets:20u3 📦 Legacy Toolsets (for backward compatibility):ru✅u❌r$ rrTz Requirements: rCu 🔧 Individual Tools (z available):u 📌 z (from reu 💡 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|]}|SrwrrCs rZrzmain..1s P P Pq P P Pr\r,u🎯 Enabled toolsets: c6g|]}|SrwrrCs rZrzmain..1s !R!R!R!''))!R!R!Rr\u🚫 Disabled toolsets: u💾 Trajectory saving: ENABLEDu: - Successful conversations → trajectory_samples.jsonlu7 - Failed conversations → failed_trajectories.jsonl) rrr{rrrrrru ❌ 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: ru📞 API Calls: r u💬 Messages: r rOu 🎯 FINAL RESPONSE:z------------------------------rsample_r&) conversationsrrrrrorrFr)rru" 💾 Sample trajectory saved to: u ⚠️ Failed to save sample: u 👋 Agent execution completed!)r model_toolsr r rr r rrrrdrrrrprrvrcrrrr rrr'r_rr8r)(rrr{rr rrr rr r rr r r r all_toolsetsbasic_toolsetscomposite_toolsetsscenario_toolsetsrpr|rr tools_str includes_strlegacy_toolsetsrG all_toolsrenabled_toolsets_listdisabled_toolsets_listrGrArr sample_idsample_filenamerrs( rZmainr" X1sH +,,, (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__r)r%) NrNrr1NNFFFFr)rurrconcurrent.futuresr7 rrrrrrrr6rr3 r;r rrrrtypesrurllib.requestrrtypingrrrr urllib.parserr r r_r firer pathlibr r rhermes_cli.env_loaderrhermes_cli.timeoutsrrr__file__parent _project_env_loaded_env_paths _env_pathrr rrrrtools.terminal_toolrrrtools.tool_result_storagerrtools.interruptrrtools.browser_toolrrrr agent.retry_utilsr!agent.error_classifierr"r#agent.prompt_builderr$r%r&r'r(r)rr*r+r,r-r.r/r0r1r2r3agent.context_compressorr4agent.subdirectory_hintsr5agent.prompt_cachingr6r7r8r9r:r;r<r=r>agent.usage_pricingr?r@agent.codex_responses_adapterrArrBrrCrrD agent.displayrErFr2 rGr< rHrIrW agent.trajectoryrJrKrLrutilsrMrNrOrPrQrSrcrrrrr rrrr6 compileVERBOSErrrrrrrrrrr rrr$rGrNrQrUrTrhr]rbrnrprr" Firerwr\rZrD s; *     8 $ $  !!!!!! ,,,,,,,,,,,,7777777777 ,,,,,,544444   tH~~$v- &&<\ZZZK&GG  :IFFFFG KKIJJJ NMMMMMMMMMTTTTTTTT;;;;;;......NMMMMMMM......EEEEEEEE 766666<<<<<<>>>>>>DDDDDDDD  tsssssssssssss.*.*.*.*.*.*.*.*b Xc]    hsm &;;;;)7)7)7)7)7)7)7)7\" 9+..!y " " "  YCCCDD#   J  !bj!455)$))))X=C==PT===="??d?t???? -.. ssCDBADATAAAAH's's''''T^^#^#^^^^^BA3A3AAAA848D8888v0T0d0000 34TT#t####2 d    kx(kx(kx(kx(kx(kx(kx(kx(^q !#S/S/ S/ S/S/ S/  S/  S/S/S/S/S/S/S/S/S/S/l z DIdOOOOOr\