Ki*dZddlZddlZddlZddlZddlZddlZddlZddl Z e j e Z ddl Z ddlZddlZddlZddlZddlZddlZddlZddlmZddlZddlmZmZmZmZddlmZddlZddl m Z ddl!m"Z"ddl#m$Z$dd l%m&Z&e$Z'e"e(j)d z Z*e&e'e* Z+e+re+D]Z,e -d e,ne -d ddl.m/Z/m0Z0m1Z1m2Z2ddl3m4Z4ddl5m6Z7ddl8m9Z9ddl#m:Z:ddl;mZ>m?Z?m@Z@mAZAddlBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJddlKmLZLddlMmNZNddl;mOZOmPZPmQZQmRZRmSZSmTZTmUZUddlVmWZWmXZXddlYmZZZm[Z\m]Z^m_Z_m`ZaddlbmcZcmdZdmeZfddlgmhZhmiZiGddZjdLdZkGd d!Zlemd"hZnemhd#Zoemhd$Zpd%Zqejrd&ejsZtejrd'Zud(evdewfd)Zxdewfd*Zyd+evd,ezde"dzfd-Z{d.e"d/e"dewfd0Z|ejrd1Z}ejrd2ej~Zd3evdevfd4Zd5edewfd6Zd5eddfd7ZGd8d9Z dMd>evd?evd@evdAevdBedCevdDevdEewdFewdGewdHewdIefdJZe dKkrejedSdS)Nao 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)OpenAI)datetime)Pathget_hermes_home)load_hermes_dotenvz.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_vm) set_interrupt)cleanup_browser)OPENROUTER_BASE_URL)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_errorsave_context_lengthis_local_endpoint)ContextCompressor)apply_anthropic_cache_control)build_skills_system_promptbuild_context_files_prompt load_soul_mdTOOL_USE_ENFORCEMENT_GUIDANCETOOL_USE_ENFORCEMENT_MODELSDEVELOPER_ROLE_MODELS!GOOGLE_MODEL_OPERATIONAL_GUIDANCE)estimate_usage_costnormalize_usage) KawaiiSpinnerbuild_tool_previewget_cute_tool_message_detect_tool_failureget_tool_emoji)convert_scratchpad_to_thinkhas_incomplete_scratchpadsave_trajectory)atomic_json_writeenv_var_enabledc: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)Nr=)object __setattr__)selfinners &/home/ubuntu/hermes-agent/run_agent.py__init__z_SafeWriter.__init__s 4511111c |j|S#ttf$r)t |t rt |ndcYSwxYwNr)r=writeOSError ValueError isinstancestrlen)rAdatas rCrHz_SafeWriter.writesb =;$$T** *$ = = = *4 5 5<3t9991 < < < =s7AAcj |jdS#ttf$rYdSwxYwN)r=flushrIrJrAs rCrQz_SafeWriter.flushsH  K       $    DD s 22c4|jSrP)r=filenorRs rCrTz_SafeWriter.filenos{!!###rEcf |jS#ttf$rYdSwxYw)NF)r=isattyrIrJrRs rCrVz_SafeWriter.isattysB ;%%'' '$   55 s 00c,t|j|SrP)getattrr=)rAnames rC __getattr__z_SafeWriter.__getattr__st{D)))rEN) __name__ __module__ __qualname____doc__ __slots__rDrHrQrTrVrZrErCr<r<ls$I222===  $$$ *****rEr<returncdD]R}tt|d}|8t|ts#t t|t|SdS)zHWrap stdout/stderr so best-effort console output cannot crash the agent.)stdoutstderrN)rXsysrKr<setattr) stream_namestreams rC_install_safe_stdioris\+;; k400  j&E&E  Ck&&9&9 : : :;;rEcjeZdZdZdefdZdefdZd 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|_dSrG)rl_used threadingLock_lock)rArls rCrDzIterationBudget.__init__s#" ^%% rErac|j5|j|jkr ddddS|xjdz c_ ddddS#1swxYwYdS)z7Try to consume one iteration. Returns True if allowed.NFT)rqrnrlrRs rCconsumezIterationBudget.consumes Z  zT^++         JJ!OJJ                   sAAA  A Nc||j5|jdkr|xjdzc_ddddS#1swxYwYdS)z6Give back one iteration (e.g. for execute_code turns).rrsN)rqrnrRs rCrefundzIterationBudget.refunds Z  zA~~ a                   s 155c|jSrP)rnrRs rCusedzIterationBudget.useds zrEc~|j5td|j|jz cdddS#1swxYwYdSrG)rqmaxrlrnrRs rC 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 266raN) r[r\r]r^intrDboolrtrvpropertyrxr{r`rErCrkrks  &#&&&&     cX73777X777rErkclarify> 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| 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 rC_is_destructive_commandrsJ u##C((t!!#&&t 5rEc 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.rsFc&g|]}|jjSr`functionrY.0tcs rC z2_should_parallelize_tool_batch.. s888r"+"888rEc3(K|] }|tvVdSrP)_NEVER_PARALLEL_TOOLS)rrYs rC z1_should_parallelize_tool_batch.. s( @ @T4( ( @ @ @ @ @ @rEu@Could not parse args for %s — defaulting to sequential; raw=%sNu6Non-dict args for %s (%s) — defaulting to sequentialc38K|]}t|VdSrP)_paths_overlap)rexisting scoped_paths rCrz1_should_parallelize_tool_batch..'s-XXX>+x88XXXXXXrET)rManyrrYjsonloads arguments ExceptionloggingdebugrKdicttyper[_PATH_SCOPED_TOOLS_extract_parallel_scope_pathappend_PARALLEL_SAFE_TOOLS) tool_calls tool_namesreserved_paths tool_call tool_name function_argsrs @rC_should_parallelize_tool_batchrs :!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) rgetrKrLstripr expanduser is_absoluteosrabspathcwd)rrraw_pathexpandeds rCrr2s***t  ((H h $ $HNN,<,<tH~~((**H4BGOOCMM22333 DHJJ$9 : :;; < < >>rEz[\ud800-\udfff]z5\[BUDGET(?:\s+WARNING)?:\s+Iteration\s+\d+/\d+\..*?\]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_RErsub)rs rC_sanitize_surrogatesrWs5 D!!1  4000 KrEmessagesc4d}|D]}t|ts|d}t|tr;t|r!td||d<d}~t|tr~|D]{}t|trd|d}t|tr:t|r td||d<d}||S)zSanitize 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. FcontentrTr)rKrrrLrrrlist)rfoundmsgrpartrs rC_sanitize_messages_surrogatesrbs E % %#t$$  '')$$ gs # # % (<(e f`d?Zd@ZdAZd dBdCe fdDZdEeddfdFZddede fdGZde fdHZde fdIZde defdJZdKede fdLZdKedefdMZdNedOedPe eeefde fdQZdeefdRZdSeedTe dUe eeefdVee eeefdeeeff dWZdXeddfdYZ dZZ!d[Z"d\Z# dd]e ed^e d_e ddfd`Z$dPe eddfdaZ%ddPe edVe efdbZ&ddPe edVe efdcZ'dPe ede efddZ(defdeZ)dPe eeefdfedge de eeeffdhZ*dPe eeefdfedge fdiZ+e,dje-defdkZ.dleedeefdmZ/dnedefdoZ0ddpdqeeefdredjee-dee1fdsZ2e,dKedefdtZ3ddPe eeeffduZ4ddEeddfdvZ5ddwZ6ddPeddfdxZ7dye eeefddfdzZ8ede fd{Z9dd|edefd}Z:e,defd~Z;e,dPe eeefde eeeffdZdededzfdZ?dZ@ddee eeefdee eeeffdZAe,ddedede defdZBe,dedeCeeeeffdZD ddedeedefdZEdPe eeefde eeeffdZFdede eeeffdZGd ddqede deeeffdZHdedefdZIdedefdZJdedeCeeffdZKdefdZLdefdZMdeNjOfdZPe,dede fdZQdedrede defdZRe,dede fdZSdedrede ddfdZTdrede fdZUdredefdZVde fdZWdredefdZXdedreddfdZYddqedede fdZZddqedefdZ[d dBdCe de fdZ\d dBdCe de fdZ]de fdZ^deddfdZ_ddZ`dee de deCe e ffdZadqefdZbdqefdZcdeddfdZddeddfdZededdfdZfde fdZgdddqede fdZhde fdZide fdZjekhd£Zlde-de de de fdƄZme,dKede fdDŽZne,dedeCeee1ffdɄZodededefd˄ZpdKededefd̄ZqdUedefd̈́Zrde fd΄ZsdUedefdτZtde fdЄZudedzfdфZvdSedefd҄Zwe,dedefdԄZxddPede fdքZyddd؜dPed|edTe dXedeCf dلZzddPedede ddfd܄Z{dedededefd߄Z|ddPedede ddfdZ}ddPedede ddfdZ~de deefdZde ddfdZdPede defdZ ddNed|edVe eeefdXedee deedeeeffdZddEedee defdZdS)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. rac|jSrP) _base_urlrRs rCbase_urlzAIAgent.base_urls ~rEvalueNcN||_|r|nd|_dSNr)rlower_base_url_lowerrArs rCrzAIAgent.base_urls(05=u{{}}}2rErZ?Fd2Trapi_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_callbacktool_gen_callbackstatus_callback max_tokensreasoning_configprefill_messagesplatformskip_context_files skip_memoryiteration_budgetrkfallback_modelcheckpoints_enabledcheckpoint_max_snapshotspass_session_idpersist_sessionc33t| |_| |_|,pt| |_| |_||_||_||_||_ |(|_ d|_ d|_ |)|_ |1|_|2|_|.|_||_|r|dnd|_|pd|_t)|t*r:|r&|nd}3|3pd|_|p||_t5|p|pg|_|dvr||_n|jdkrd|_n{|3d|jvrd|_d|_na|jdks |3d |jvrd |_d|_n<|jd d rd |_nd |_|jd kr| rd|_|jdks|!r)tEj#dd$||_%||_&||_'||_(||_)d|_*| |_+|!|_,|"|_-|$|_.|#|_/d|_0d|_1d|_2d|_3tEj4|_5d|_6g|_7tEj8|_9||_:||_;||_<||_=||_>||_?| |_@| |_A|%|_B|&|_C|'pg|_D|!}4d|jv}5|jd k}6|4r|5p|6|_Ed|_Fd|_Gd|_Hd|_Id|_JddlKmLtjN}7tdz }8|8dz }9|9Ptfd|7jRD}:ddlSmT};|:sw|8Udd|9dd }<|tjN|>Vtj_4d|_`d|_ad|_bd|_ci|_dd|_ed|_f|jd krdd3lgmh}?mi}@|jdk}A|Ar|p |@pdn|pd}B|B|_j|B|_k||_ldd4lgmm}C|C|B|_f|?|B||_ed|_ni|_o|jsRtd5|jd6|Br8t|Bd7kr%td8|Bdd9d:|Bd;dn/|r|r||d<}D|jd=kr|j|Dd><|j|Dd?<|}Ed|Evr d@dAdBdC|DdD<n6dE|EvrddFlrms}F|F|DdD<n dG|EvrdHdIi|DdD<nddJltmu}G|G|jpdK|jdL\}H}I|HK|Hjjt+|Hjd<}Dt|HdMr|Hjwrt|Hjw|DdD<n}|jpd}J|Jr,|JdNvr(tdO|JdP|JzdQtj|dRdtd@dAdBdCdS}D|D|_ot+|D~dTd}Kd|Kvrgd|jpdvrJ|D~dDpi}L|L~dUd}MdV}N|N|Mvr|Mr |MdW|N|LdU<n|N|LdU<|L|DdD<|D~dXd|_j ||DdYdZ|_n|jstd5|j|rtd[||D~dXd\}O|Or?|Od]kr9t|Od7kr&td^|Odd9d:|Od;dntd_|Or |Odd`nd\dan%#t$r}Ptdb|Pd}P~PwwxYwt)|-t4rdc|-D|_nOt)|-tr3|-~ddr|-~der |-g|_ng|_d|_d|_|jr |jdnd|_|jr|jst|jdfkr0|jd}Qtdg|Qdedh|QdddinJtdjt|jdkdldm|jDzt | | |jn|_t|_|jrdo|jD|_t|j}R|jstdpt|jdqdr|R| r%tdsdr| | r%tdtdr| n|jstdu|jrH|jsAt}Sdv|SD}T|Trtdw|T|jr|jstdx|j rK|jsDt|j dykr|j ddyd:zn|j }Utdz|Ud{|jEr(|js!|6rd|nd}}Vtd~|Vdr|jFdtj|_|r||_nG|jd}Wt%jjdd}X|Wd|X|_t+}Y|Ydz |_|jUdd|jd|jdz |_g|_d|_ddlm}Z|Z|/|0|_|+|_d|_|jr |j|j|j ptj~dd|j|j|&|%ddn3#t$r%}Ptd|PYd}P~Pnd}P~PwwxYwddlm}[|[|_ ddlm}\|\}]n#t$ri}]YnwxYwd|_d|_d|_d|_d|_d|_d|_|*s |]~di}^|^~dd|_|^~dd|_t]|^~dd|_t]|^~dd|_|js|jrYddlm}_|_|^~dd|^~dd|_|jn#t$rYnwxYwd|_|*s |^r|^~dddnd}`|`s ddlm}a|a}b|bjr~|bjjs|bjrpd}` ddlm}cm}d|c}ed|edidd<|d|en#t$rYnwxYw|jstdtdn#t$rYnwxYw|`rddlm}fddlm}g|f|_|g|`}h|hr.|hr|j|h|jjrddlm}i|j|(pdt+|idd}j ddlm}k|k}l|l|jd<d|jd<n#t$rYnwxYw|jjdi|jt^d|`n"td|`d|_n:#t$r,}mtd|md|_Yd}m~mnd}m~mwwxYw|jrt|jm|jD]S}nd|nd}o|j|o|n~dd}p|pr|j|pTd|_ |]~di}qt]|q~dd|_n#t$rYnwxYw|]~di}rt)|rtsi}r|r~ddK|_|]~di}st)|stsi}st|s~dd}tt+|s~dddv}u|s~dpd}vt|s~dd}wt]|s~dd`}x|]~dei}yt)|ytr|y~d}znd}z|z- t]|z}zn#ttf$rd}zYnwxYw|z1|]~d}{t)|{t4r|{D]}|t)||ts||~dTpdd }}|}r|}|jd kr||~di}~t)|~trr|~~|ji}t)|trB|~d}|+ t]|}zn#ttf$rYnwxYwnt|j|td|x|w|v|j|jt|dXd|z|j |_|u|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d\|_|jsa|urAtd|jjdWdĐt]|tdzd|jjdWdintd|jjdWdǝ|j}|j|j|j|jt|dXdt|jo|jE|j|jt|dXd|j|j|jdȜ |_|jd kr/|j|jk|jl|jfdɜdSdS)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!"}] 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_responseschat_completionsanthropic_messages openai-codexr(zchatgpt.com/backend-api/codex anthropicapi.anthropic.comr*/ /anthropicr) openrouterctSrP)rr`rErCz"AIAgent.__init__..As 355rETtargetdaemonFrclaude5mffffff?g?)RotatingFileHandlerlogsz errors.logc3K|]H}t|o3tt|ddkVIdS) baseFilenamerN)rKr rXresolve)rhandlerr9resolved_error_log_paths rCrz#AIAgent.__init__..ss% %  w 3 4 4 `WWnb99::BBDDH__% % % % % % rE)RedactingFormatter)parentsexist_oki )maxBytes backupCountz/%(asctime)s %(levelname)s %(name)s: %(message)sz4%(asctime)s - %(name)s - %(levelname)s - %(message)sz%H:%M:%S)levelformatdatefmt)rHopenaizopenai._base_clienthttpxhttpcoreasynciohpackz hpack.hpackgrpcmodalz rex-deployz=Verbose logging enabled (third-party library logs suppressed)z)%(asctime)s - %(levelname)s - %(message)s)tools run_agenttrajectory_compressorcron hermes_cli)build_anthropic_clientresolve_anthropic_token_is_oauth_tokenu&🤖 AI Agent initialized with model: z (Anthropic native) u🔑 Using token: r...rr copilot-acprrz%https://hermes-agent.nousresearch.comz Hermes Agentzproductivity,cli-agent)z HTTP-RefererzX-OpenRouter-TitlezX-OpenRouter-Categoriesdefault_headersapi.githubcopilot.comcopilot_default_headers api.kimi.com User-Agent KimiCLI/1.3resolve_provider_clientautor raw_codex_default_headers)rgr0customz Provider 'z:' is set in config.yaml but no API key was found. Set the zU_API_KEY environment variable, or switch to a different provider with `hermes model`.OPENROUTER_API_KEY)rrr^rzx-anthropic-betaz&fine-grained-tool-streaming-2025-05-14,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)rrrKrrrfs rCrz$AIAgent.__init__..es^$$$a&&$+,55+<+<$ABw$$$$rErrrsu🔄 Fallback model:  ()u🔄 Fallback chain (z providers):  → c3>K|]}|dd|ddVdS)rrxrryNr`rvs rCrz#AIAgent.__init__..ws;"c"caj#D#DAjM#D#D#D"c"c"c"c"c"crE)rrrc*h|]}|ddSrr`)rrs rC z#AIAgent.__init__..s"$U$U$U$T*%5f%=$U$U$UrEu🛠️ Loaded z tools: , u ✅ Enabled toolsets: u ❌ Disabled toolsets: u@🛠️ No tools loaded (all tools filtered out or unavailable)cg|] \}}|| Sr`r`)rrY availables rCrz$AIAgent.__init__..s"^^^_T9T]^D^^^rEu=⚠️ Some tools may not work due to missing requirements: u📝 Trajectory saving enabled<u🔒 Ephemeral system prompt: 'z' (not saved to trajectories)znative AnthropiczClaude via OpenRouteru💾 Prompt caching: ENABLED (z TTL) %Y%m%d_%H%M%S_sessionssession_.json)CheckpointManager)enabled max_snapshotsHERMES_SESSION_SOURCEcli)rrr)rsourcer model_configuser_idzESession DB create_session failed (session_search still available): %s) TodoStore) load_config memorymemory_enableduser_profile_enablednudge_intervalflush_min_turns) MemoryStorememory_char_limitiuser_char_limiti_)rr)HonchoClientConfighoncho)r save_configu5 ✓ Auto-migrated Honcho to memory provider plugin.z( Your config and data are preserved. ) MemoryManager)load_memory_providerr primary)rrr agent_context)get_active_profile_nameagent_identityhermesagent_workspacezMemory provider '%s' activatedz/Memory provider '%s' not found or not availablez&Memory provider plugin init failed: %sr)rrrYskillscreation_nudge_intervalagenttool_use_enforcement compression threshold?r)true1yes summary_model target_ratio皙?protect_last_ncontext_lengthcustom_providersmodels) rthreshold_percentprotect_first_nrsummary_target_ratiosummary_model_overriderrrconfig_context_lengthrunknownu📊 Context limit: z tokens (compress at rz% = z# tokens (auto-compression disabled)) rrrrr client_kwargsuse_prompt_cachingcompressor_modelcompressor_base_urlcompressor_api_keycompressor_providercompressor_context_lengthcompressor_threshold_tokens)anthropic_api_keyanthropic_base_urlis_anthropic_oauthr`)rirrrkr rrrrrr _print_fnbackground_review_callbackrr$r%_credential_poolrrrrKrLrrrrrrrrrstripendswith_is_direct_openai_url_is_openrouter_urlroThreadstartrrrrr_reasoning_deltas_firedrrrrr_last_reported_tool_executing_tools_interrupt_requested_interrupt_messageRLock _client_lock_delegate_depth_active_childrenrp_active_children_lockr r r r r rrrrrr_use_prompt_caching _cache_ttl_budget_caution_threshold_budget_warning_threshold_budget_pressure_enabled_context_pressure_warnedlogging.handlersr9r getLogger _hermes_homer=rhandlers agent.redactr@mkdirsetLevelWARNING setFormatter addHandler basicConfigDEBUGINFOloggerinfoERROR_stream_callback_stream_needs_break_persist_user_message_idx_persist_user_message_override_anthropic_image_fallback_cache_anthropic_client_is_anthropic_oauthagent.anthropic_adapterrUrVr_anthropic_api_key_anthropic_base_urlrXclient_client_kwargsprintrMhermes_cli.modelsraagent.auxiliary_clientrfhasattrrjr RuntimeErrorupperrgetenvrr_create_openai_clientr_fallback_chain_fallback_index_fallback_activated_fallback_modeljoinrrPsetvalid_tool_namessortedritemsr now session_startrstrftimeuuiduuid4hexr logs_dirsession_log_file_session_messages_cached_system_prompttools.checkpoint_managerr_checkpoint_mgr _session_db_last_flushed_db_idxcreate_sessionenvironwarningtools.todo_toolr _todo_storehermes_cli.configr _memory_store_memory_enabled_user_profile_enabled_memory_nudge_interval_memory_flush_min_turns_turns_since_memory_iters_since_skillr}tools.memory_toolrload_from_disk_memory_managerplugins.memory.honcho.clientrfrom_global_configrr setdefaultagent.memory_managerrplugins.memoryr is_available add_provider providershermes_constantshermes_cli.profilesrinitialize_allrget_all_tool_schemasradd_skill_nudge_interval_tool_use_enforcementfloatrrJr&rXcontext_compressorcompression_enabled_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_sourcerthreshold_tokens_primary_runtimeupdate)rArrrrrrrrrrrrrrrrrrrr r r r r rrrrrrrrrrrrrrrrrr session_dbr r!credential_poolr"r#r$r% provider_name is_openrouter is_claudeis_native_anthropic root_logger error_log_direrror_log_pathhas_errors_log_handlerr@error_file_handlerr> quiet_loggerrUrV_is_native_anthropic effective_key_is_oatreffective_baserarf_routed_clientr _explicit_effective_baseheaders existing_beta _FINE_GRAINEDkey_usedefbr requirements missing_reqsprompt_previewr timestamp_str short_uuidrrr_load_agent_config _agent_cfg mem_configr_mem_provider_name_HCC_hcfg_lc_sc_cfg_MemoryManager _load_mem_mp_ghh _init_kwargsr_profile_mpe_schema_wrapped_tname skills_config_agent_section_compression_cfgcompression_thresholdr?compression_summary_modelcompression_target_ratiocompression_protect_last _model_cfg_config_context_length_custom_providers _cp_entry_cp_url _cp_models _cp_model_cfg_cp_ctx_ccr9r?s @@rCrDzAIAgent.__init__sx  ,!1 SON4S4S$!2.$'>$  *.'"4.. / 0.8@Z****b B 4>x4M4MlRZR`R`RbRbl((..000hl %+ &1'X3344 T T T$DMM ]n , ,-DMM#)HDL`)`)`-DM*DMM ]k ) )m.CH[_c_sHsHs0DM'DMM  ! ( ( - - 6 6| D D /1DMM.DM =. . .43M3M3O3O .-DM =L ( (D,C,C,E,E (  55   eggg&<##6 &<#!2"4',$ 0*%:".!2#' !&%*!"&%O-- ! "%.^%5%5""3!2.*+F((@%!1!2% 0 0 6B //11  0 0 2 22 "m/CC$1$?i#WDW  *-&),&(,% ).% 988888')) $v- &5"0"8"8":":!$% % % % % '/% % % " "  433333% 7   t  < < ,>A--     " "#5 6 6 6  1 L  mM"     #,..7  $$%7%7J&&&&  h ' ' 0 0 A A A  3 4 4 = =go N N N  g & & / / @ @ @  j ) ) 2 27? C C C  i ( ( 1 1'/ B B B  g & & / / @ @ @  m , , 5 5go F F F  f % % . .w ? ? ?  g & & / / @ @ @  l + + 4 4W\ B B B KKW X X X X  lB"      h ' ' 0 0 ? ? ?  3 4 4 = =gm L L L  g & & / / > > >  j ) ) 2 27= A A A L%LLL%l33<>D" ' ,> C C H  55$D9F6X6X6X6X 2336C 237>M"34(,,Y;;DL 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+>[''D[F S6SST_SSS T T T&\^^  >(DOO!.77HHM)"1"-J!.====DO&'' #j0  D4888 $ 0Q4?0Q0Q0Q Q8:59" ?>>>>>00'2    &$%!     //#=ZBJNN;RTY,Z,Z**.*=,<&0"" !0       []^  .-----$9;;  K K K K K K++--JJ   JJJ "$%*"&(#'($#$ "#  '^^Hb99 '1~~6F'N'N$-7^^>BSUV3W3W/X/X,'84+E8======)4*4..9Ld*S*S(27H$(O(O***D&&55777     $; ,: ,GQ%YZ^^J%C%C%CWY"*[[[[[[ $ 7 7 9 9 = Sem Su~ S19.% d d d d d d d d'*suuLT" = =j I #D #,%%% $%#'?S %&] ^ ^ ^ %&Q R R R$&4TTTTTTPPPPPP+9>+;+;D(#)$677C?s//11?,99#>>>+54LLLLLL*./(0(9E+.ttvv;;-6 (( !SSSSSS'>'>'@'@H=EL)9:>FL):;;(!!! D!;,;KKlKKK $DFXYYYY %VXjkkk/3, , , ,GNNN'+$$$$$$ ,   6DJ$:/DDFF 6 6$.GDD !!(+++ VR006)--f555&(" &NN8R88M),]->->?XZ\-]-])^)^D & &    D  $44.$// N%3%7%78NPV%W%W" &>>-<<*D11 "!  %&6&:&:;&M&M N N!"2"6"6y$"G"GHHNNPPThh$4$8$8$I$I$QT!#()9)=)=nd)S)S#T#T #&'7';';BFFsKKG 7dm.B.B3.G.G#G#G%.]]8R%@%@ %j$77-,6NN4:r,J,JM)->>-*7*;*;(>,5z+B%-%-%-(,%-"3*33!9#<]D)R00"8] # # # $7 !&'")*&$%!!"$%!%&")*&*+'()%*-'#, #)  |" |~T-D-S~~~loqFGJqJmKmK~~QUQhQy~~~~zT-D-Szzzz{{{ %Z   tY33!$"566"&": # #&<")#y""="=#&<),);+.+?! !  =0 0 0  ! ( (%)%<&*&>&*&>**      1 0seAK?K?(AL(L'AQL( AL6L3AQL5AL6L6BAQOAO#O"AQO# AO1O.AQO0AO1O1AAQQ AQ<Q"AQ7Q7AQ<T?AUU AUUAU[A[[A[1[0A[1_:A` ` A`!` A`!cd|_d|_d|_d|_d|_d|_d|_d|_d|_d|_ d|_ d|_ d|_ t|dr]|jrXd|j_d|j_d|j_d|j_d|j_d|j_d|j_dSdSdS)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. rrrrrr>FN)rCrErFrArBrGrHrIrDrJrKrLr@rr>last_prompt_tokenslast_completion_tokenslast_total_tokenscompression_count_context_probed_context_probe_persistable_previous_summaryrRs rCreset_session_statezAIAgent.reset_session_states&%&!$%!%&"%&")*&)*&*+'()%!"*-'#, #) !" 4- . . =43J =9:D # 6=>D # :89D # 589D # 56;D # 3AFD # >8S  F$)&)))))rEmessagec ||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_infoN)rrrrrr)rArs rC _emit_statuszAIAgent._emit_statuss  LLDO6W66dL C C C C    D    U U$$['::::: U U U Dt TTTTTT U U Us # 00A&A=<A=cH|p|j}d|vod|vS)z8Return True when a base URL targets OpenAI's native API.zapi.openai.comr0)rr)rArurls rCrzAIAgent._is_direct_openai_url1s0/4/66883&BR>Y>YZ]>^>^>g>ght>u>uurEc:|rd|iSd|iS)zReturn the correct max tokens kwarg for the current provider. OpenAI's newer models (gpt-4o, o-series, gpt-5+) require 'max_completion_tokens'. OpenRouter, local models, and older OpenAI models use 'max_tokens'. max_completion_tokensr)rrs rC_max_tokens_paramzAIAgent._max_tokens_param>s.  % % ' ' 4+U3 3e$$rErcv|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_blocksr~r)rArrs rC_has_content_after_think_blockz&AIAgent._has_content_after_think_blockIs> 5**733GMMOO$$$rEc||sdStjdd|tj}tjdd|tjtjz}tjdd|tj}tjdd|tj}tjdd|tj}|S)zKRemove reasoning/thinking blocks from content, returning only visible text.rz.*?flagsz.*?z.*?z0.*?z8\s*)rerDOTALL IGNORECASE)rArs rCrzAIAgent._strip_think_blocks`s 2&.G29MMM&4b'UWUbIbccc&6G29UUU&LbRYacajkkk&TVXZaikivwwwrE user_messageassistant_contentrcF 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|ddkV3dS)rrNrurrs rCrz=AIAgent._looks_like_codex_intermediate_ack..ts@WWsz#t$$BF)BWWWWWWrEFriu@\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 dSrPr`)rmarker user_texts rCrz=AIAgent._looks_like_codex_intermediate_ack..s(DD)#DDDDDDrEz~/r.c3 K|]}|vV dSrPr`rrassistant_texts rCrz=AIAgent._looks_like_codex_intermediate_ack..s('^'^V.(@'^'^'^'^'^'^rEc3 K|]}|vV dSrPr`rs rCrz=AIAgent._looks_like_codex_intermediate_ack..s9* * )/Fn $* * * * * * rE)rrrrrMr~rr) rArrrhas_future_ackaction_markersworkspace_markersuser_targets_workspaceassistant_mentions_actionassistant_targets_workspacerrs @@rC"_looks_like_codex_intermediate_ackz*AIAgent._looks_like_codex_intermediate_ackms WWhWWW W W 5112C2IrJJPPRRXXZZ 5 ~   % %5 IY[i j j   5 *  "'R..006688 DDDD2CDDD D D y  i  %('^'^'^'^~'^'^'^$^$^!&)* * * * 3D* * * ' ' #'E*EdKddrEc~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_detailssummarythinkingrrN)(.*?)z(.*?)z(.*?)z2(.*?)r )rrrrrrKrrrXrLrrrfindallrr ) rAassistant_messagereasoning_partsdetailrrinline_patternspatternrblockrs rC_extract_reasoningzAIAgent._extract_reasonings" $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;;// /trE finish_reason approx_tokens api_messagesconversation_historyc t||}tt|ddp!t|ddpt|dd}t|ddpd}||} ||pdt||pdf} | t|ddk} t|dd} t| d d pd } t| d d pd }t| r$|t t | d z|kpt|d k}tt|ddpd}t|}t|dkt| dd||g}t|j o|o|o| }| |_ ||| ||||dS)aClassify think-only/empty responses so we can retry, compress, or salvage. We intentionally do NOT short-circuit all structured-reasoning responses. Prior discussion/PR history shows some models recover on retry. Instead we: - compress immediately when the pattern looks like implicit context pressure - salvage reasoning early when the same reasoning-only payload repeats - otherwise preserve the normal retry path rNrrrr_last_empty_content_signaturer>rrrM皙?PrlengthrF)reasoning_texthas_structured_reasoningrepeated_signatureshould_compressis_local_customis_large_session is_resumed) rr~rXrrrzr}rMr%rr?r)rArrrrrrrrstripped_content signaturer compressorctx_lenrMrrrcontext_pressure_signalsrs rC _classify_empty_content_responsez(AIAgent._classify_empty_content_responses-"001BCC#' %{D 9 9 E(*=tDD E(*=tDD$ $  +Y==C33G<<BBDD   b ) * *  R  ''$8WY]*^*^^T#7>> *&6::?a":/A1EEJ  S#c'C-.@.@BR*S*SS &<  2%  ,GD*b,I,I,ORPP.// #&) $5u==   $ $    $ % %( %%$   .7*,(@"4.. 0$   rEtask_idc6 t|n8#t$r+}|jrtjd|d|Yd}~nd}~wwxYw t |dS#t$r2}|jr tjd|d|Yd}~dSYd}~dSd}~wwxYw)z3Clean up VM and browser resources for a given task.zFailed to cleanup VM for task : Nz#Failed to cleanup browser for task )rrrrr r)rAr rgs rC_cleanup_task_resourceszAIAgent._cleanup_task_resources;s Q w     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!AA A B&!BBuReview 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.aReview the conversation above and consider saving or updating a skill if appropriate. Focus on: was a non-trivial approach used to complete a task that required trial and error, or changing course due to experiential findings along the way, or did the user expect or desire a different method or outcome? If a relevant skill already exists, update it with what you learned. Otherwise, create a new skill if the approach is reusable. If nothing is worth saving, 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, or changing course due to experiential findings along the way, or did the user expect or desire a different method or outcome? If a relevant skill already exists, update it. Otherwise, create a new one if the approach is reusable. Only act if there's something genuinely worth saving. If nothing stands out, just say 'Nothing to save.' and stop.messages_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. rNc ddl}ddl}d} t|jd5}||5||5t jddjj }j |_ j |_ j |_ d|_ d|_|dddn #1swxYwYdddn #1swxYwYdddn #1swxYwYg}t!|dgD]}t#|t$r|dd kr2 t)j|d d }n#t(jt.f$rYtwxYw|d s|d d}|dd}d|vr||d|vr||d|vs|rBd|vr,|dkrdn |dkrdn|} || dmd|vr,|dkrdn |dkrdn|} || dd|vsd|vr*|dkrdn |dkrdn|} || d|rndt$|} d| j} | r | d| n#t<$rYnwxYwn2#t<$r%} t> d| Yd} ~ nd} ~ wwxYw|Ft!|d d} | 5 |!| d!d"d|_"dS#t<$rYdSwxYwdSdS#|Dt!|d d} | 2 |!| d!d"d|_"w#t<$rYwwxYwwwxYw)#NrwrT)rrrrr)rrrrrr{}successrrr4createdupdatedaddedr:rMemoryuserz User profilez updatedz Entry addedremovedreplacedu · u 💾 u💾 z)Background memory/skill review failed: %srbg_review_donero)# contextlibrrdevnullredirect_stdoutredirect_stderrrrrrr$r%r&r'r;run_conversationrXrKrrrrrrrrr fromkeysrrrrr_close_openai_clientr)r_os review_agent_devnullactionsrrNrr4labelr_bg_cbrgrrpromptrAs rC _run_reviewz5AIAgent._spawn_background_review.._run_reviews ( ( ( ( ( ( ( (LK !#+s++x//99//99$+"j'(#'!%!% $$$L261CL.373GL09=9SL6:;L79:L6 11%+->2!."<1DbII;;C%c400!CGGFOOv4M4M !#z#'')T*B*BCC 0)<!!! !88I..! "hhy"55G!XXh33F GMMOO33w////"gmmoo55w//// GMMOO3335GMMOOC[C[,2h,>,>V\`fVfVfNNlr%'9'9'9::::&'11,2h,>,>V\`fVfVfNNlr%'9'9'9::::"gmmoo55w}}9V9V,2h,>,>V\`fVfVfNNlr%'9'9'9:::!$kk$--*@*@AAG$$%8w%8%8999!37L///(!!! DD!,+)) +$\8TBBF)!(== &/?>37L//(!!! D!,)sM9C5CA-C; CC CC C C5C" "C5%C" &C5) M95C99M9<C9=AM9(E/.M9/FM9FGM9M('M9( M52M94M55M98O79 N(N#O7#N((O7O"" O0/O07QP.-Q. P;8Q:P;;QTz bg-review)r4r5rY)ro_COMBINED_REVIEW_PROMPT_MEMORY_REVIEW_PROMPT_SKILL_REVIEW_PROMPTrr)rArrrror,tr+s`` @rC_spawn_background_reviewz AIAgent._spawn_background_reviewos   /] /1FF  //FF.FN !N !N !N !N !N !N !` I K; O O O  rEct|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. rNrrrrr)rXrMrKrr)rAridxoverriders rC$_apply_persist_user_message_overridez,AIAgent._apply_persist_user_message_overridesd7>>4!A4HH  s{ F  # # # #c(mm # # # # # #3-C#t$$ *F)B)B!)I $ # * *)B)BrEc|jsdS||||_|||||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. Skipped when ``persist_session=False`` (ephemeral helper flows). N)r%r5r_save_session_log_flush_messages_to_session_db)rArrs rC_persist_sessionzAIAgent._persist_sessionsa #  F 11(;;;!) x((( **85IJJJJJrEc|jsdS|| |j|j|jpd|j|rt |nd}t||j}||dD]<}| dd}| d}d}t|dr|j rd |j D}n0t| dtr|d}|j|j||| d || d | d |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)rrrrrrrc@g|]}|jj|jjdS)rYr)rrYrrs rCrz9AIAgent._flush_messages_to_session_db..s:'''"$!1 @UVV'''rEr tool_call_idr assistantrrcodex_reasoning_items) rrrrrr=rrrr?z$Session DB append_message failed: %s)rr5ensure_sessionrrrrMrzrrrrrKrappend_messagerrr ) rArr start_idx flush_fromrrrtool_calls_datargs rCr8z%AIAgent._flush_messages_to_session_dbsX  F 11(;;;$ F   + +}-j ,    6JP0111qIY(ABBJ ,  wwvy11''),,"&3 --8#.8''"%.'''OO  5 5t<<8&),&7O //##!ggk22.!$!8!8"%''/":":6:k6I6Icggk222tFJkFYFYcgg.A&B&B&B_cNRVaNaNa#''2I*J*J*Jgk0    ),H D % % % F F F NNA1 E E E E E E E E E FsF2G HG??Hc|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) Nrsrr>)rangerMrcopy)rArlast_assistant_idxis rC"_get_messages_up_to_last_assistantz*AIAgent._get_messages_up_to_last_assistant(s I"s8}}q("b11  A{v&&+55%&"6  %==?? "+++,,rEc|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[]rrY descriptionr parametersN)rYrMrNrequiredFr)rPrrrr)rAformatted_toolsrfuncformatted_tools rC _format_tools_for_system_messagez(AIAgent._format_tools_for_system_messageGsz 4J 3 3D #DV #xx r::"hh|R88 N  " "> 2 2 2 2z/>>>>rE 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': } system)fromrhumanrsrr>rrrz z r rrz2Unexpected invalid JSON in trajectory conversion: NrrYr<z Frz z gptrz ){[rr=)r=rYrz r)rSrrMrrr6rKrrLrrrrr rr startswithAttributeErrorr )rArrTrU trajectory system_msgrJrrrrtool_call_jsontool_responsesjtool_msg tool_response tool_content tool_indexr raw_contents rC_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. rNz ]*>([^<]+)rsz!HTML error page (title not found)z2Cloudflare Ray ID:\s*]*>([^<]+) status_codezHTTP zRay u — bodyrorr r,) rrLrrgrouprrXrr rKrr) ro_rerawmtitlerayray_idrrrrsrprefixs rC_summarize_api_errorzAIAgent._summarize_api_errors0 %jj #  C 93OOA*+TAGGAJJ$$&&&1TE**RTWXXC-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)%%%rEkeycb|sdSt|dkrdS|ddd|ddS)NrYz***rrZr[)rM)rArs rC_mask_api_key_for_logszAIAgent._mask_api_key_for_logs<sG 4 s88r>>5bqb'((c"##h(((rE 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 errorzz3AIAgent._dump_api_request_debug..nsCCCTQQ]Aq]]]rErz,Could not extract API key for debug dump: %sPOSTr.r(z /responsesz/chat/completionszBearer zapplication/json) Authorizationz Content-Type)methodrrcrs) timestamprrprequest)rr)rr request_idcodeparamrrsresponserrresponse_status response_textz,Could not extract error response details: %sroz%Y%m%d_%H%M%S_%f request_dump_rrFrC)rindentdefaultutf-8encodingu$🧾 Request debug dump written to: HERMES_DUMP_REQUEST_STDOUTz*Failed to dump API request debug payload: )!rHdeepcopypoprrXrrrrr r isoformatrrrrrrr[rLrrr write_textrrrrr:rrrr )rArrprorsrrg dump_payload error_info attr_name attr_value body_attr response_objr dump_file dump_errors rC_dump_api_request_debugzAIAgent._dump_api_request_debug]sB =,,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)r6rrr)rs rC_clean_session_contentzAIAgent._clean_session_contentsS N-g66&'7;;&)7G<<}}rEc <|p|j}|sdS g}|D]r}|ddkrB|dr-t|}||d|d<||s|jr tj|j d}|dt|dg}|t|kr%tj d |t|dSn#t$rYnwxYw|j|j|j|j|jt)j|jpd |jpgt||d }t1|j|d t2 dS#t$r/}|jrtjd|Yd}~dSYd}~dSd}~wwxYw)a Save the full raw session to a JSON file. Stores every message exactly as the agent sees it: user messages, assistant messages (with reasoning, finish_reason, tool_calls), tool responses (with tool_call_id, tool_name), and injected system messages (compression summaries, todo snapshots, etc.). REASONING_SCRATCHPAD tags are converted to blocks for consistency. Overwritten after each turn so it always reflects the latest state. Nrr>rrr message_countrzHSkipping session log overwrite: existing has %d messages, current has %dr) rrrrr last_updated system_promptrPrrrC)rrzFailed to save session log: )rrrrrrexistsrr read_textrMrrrrrrrrrr rrrPr9rLrr )rArrrrexisting_countentryrgs rCr7zAIAgent._save_session_logs5t5  F0 DG $ $776??k11cggi6H6H1s))C%)%@%@Y%P%PC Ns#### $++--  #z$*?*I*ISZ*I*[*[\\H%-\\/3x||T^`bGcGcCdCd%e%eN%G 44 f*CLL 5 !D#o M M!%!3!=!=!?!? (  8 8 : :!%!;!Ar)r!$W#  E %        D D D# D Bq B BCCCCCCCCC D D D D D D Ds>BG" BD=<G"= E G" E  BG"" H,HHcd|_||_td|j5t |j}dddn #1swxYwY|D]J} ||#t$r%}t d|Yd}~Cd}~wwxYw|j s?td|r!t|dkrd|dddn |rd|dnd 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) TNz0Failed to propagate interrupt to child agent: %su ⚡ Interrupt requested(z: 'z...''r) rr_set_interruptrrr interruptrrrrrrM)rAr children_copychildrgs rCrzAIAgent.interrupts0%)!")t  ' 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 Vs)AA  A A,, B6BBc@d|_d|_tddS)zIClear any pending interrupt request and the global tool interrupt signal.FN)rrrrRs rCclear_interruptzAIAgent.clear_interrupt" s&$)!"&urEc|jr[ |j|pgn#t$rYnwxYw |jdS#t$rYdSwxYwdS)uShut down the memory provider — call at actual session boundaries. This calls on_session_end() then shutdown_all() on the memory manager. NOT called per-turn — only at CLI exit, /reset, gateway session expiry, etc. N)r-on_session_endr shutdown_all)rArs rCshutdown_memory_providerz AIAgent.shutdown_memory_provider( s    $33HNCCCC     $1133333      s& 33A A A historycd}t|D]}|ddkr|dd}d|vr7 tj|}d|vr%t |dt r |d}nv#tjtf$rYwxYw|rP|j |d |j s-| |j d t|d tddS) a Recover todo state from conversation history. The gateway creates a fresh AIAgent per message, so the in-memory TodoStore is empty. We scan the history for the most recent todo tool response and replay it to reconstruct the state. Nrrrrz"todos"todosF)mergeu📋 Restored z todo item(s) from history)reversedrrrrKrrrr"rHrrrrMr)rArlast_todo_responserrrNs rC_hydrate_todo_storezAIAgent._hydrate_todo_store9 s6"G$$  Cwwv&((ggi,,G'' z'**d??z$w-'F'F?)-g&E()4      t   " "#5U " C C C? t rrsCU?V?Vrrrsssus ;BB! B!c|jS)z)Check if an interrupt has been requested.)rrRs rCis_interruptedzAIAgent.is_interruptedY s ((rEsystem_messagecZ d}jst}|r|g}d}|s* d}|rtjdd|d}nt}|g}g}djvr|t djvr|td jvr|t|r(|d |tj}|r||jrMj } d} | dus+t| tr| d vrd} n| dus+t| tr| d vrd} nt| tr7jpd t#fd| D} n;jpd t#fdt$D} | rW|t&jpd } d| vsd| vr|t(|||jrpjr1jd} | r|| jr1jd} | r|| jrB j}|r||n#t6$rYnwxYwt#fddD}|r2ddjDD}t9j|}nd }|r||js>t;jdpd}t?||}|r||ddl m!}|}d|"d}j#rj$r |dj$z }jr |djz }j%r |d j%z }||j%d!krQd"jvr j&d"d#nj}|d$|d%jd&j'pd (}|tRvr |tR|d' |S)(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. FTNzYou are Hermes AgentzYou are rsrr skill_manager')ralwaysron)falsenevernooffrc3nK|]/}t|t|vV0dSrP)rKrLrrp model_lowers rCrz/AIAgent._build_system_prompt.. sA__1JWXZ]L^L^_aggii;6______rEc3 K|]}|vV dSrPr`rs rCrz/AIAgent._build_system_prompt.. s(TT1a;.TTTTTTrEgeminigemmarc3*K|] }|jvVdSrP)r )rrYrAs rCrz/AIAgent._build_system_prompt.. s+wwtt'<<wwwwwwrE)rrrch|]}||Sr`r`)rtoolsets rCr}z/AIAgent._build_system_prompt.. s0 rEc34K|]}t|VdSrP)r)rrs rCrz/AIAgent._build_system_prompt.. s<  8A(33      rE)available_toolsavailable_toolsets TERMINAL_CWD)r skip_soulr)rzConversation started: z%A, %B %d, %Y %I:%M %pz Session ID: z Model: z Provider: alibabar.rFz#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.r)*rr*rreplacer rrrrr rr<rKrLrrrrr,r+r.r$r%format_for_system_promptr&r-build_system_promptrr(rrr) hermes_timerrr$rrrrrr)rAr _soul_loaded _soul_content prompt_parts _ai_peer_name _identity 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 platform_keyrs` @rC_build_system_promptzAIAgent._build_system_promptg sT$ & $(NNM $ - #  '   32:*.}.. 3 %;L 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   K1HG4Jx$=$=(..BRBRVuBuBuU""z(C'@'@"X^^EUEUYxExExHd++ U#z/R6688 _________ $z/R6688 TTTT8STTTTT K##$ABBB!% 0b7799 |++w,/F/F ''(IJJJ  %    / / /   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::<< > ) )   | < = = ={{<(((s80L)) L65L6ct|tr|ddpdSt|ddpdS)z8Extract call ID from a tool_call entry (dict or object).idr)rKrrrX)rs rC_get_tool_call_id_staticz AIAgent._get_tool_call_id_static sF b$   *66$##)r )r4$$**rEct}|D]f}|ddkrK|dpgD]3}t|}|r||4gt}|D]G}|ddkr,|d}|r||H||z r6fd|D}t dt||z }|rg}|D]}|||ddkrQ|dpgD]9}t|}||vr|dd|d :|}t d 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. rr>rrr=ctg|]4}|ddkr|dv2|5Srrr=)r)rryorphaned_resultss rCrz2AIAgent._sanitize_api_messages..6 sOf //AEE.4I4IM]4]4]4]4]4]rEz6Pre-call sanitizer: removed %d orphaned tool result(s)u2[Result unavailable — see context summary above]rrr=z0Pre-call sanitizer: added %d stub tool result(s)) r rrrr:rrrMr) rsurviving_call_idsrrcidresult_call_idsmissing_resultspatchedrs @rC_sanitize_api_messageszAIAgent._sanitize_api_messages s.#&%% 4 4Cwwv+--'',//5244B!::2>>C4*..s333"uu - -Cwwv&((ggn---#'',,,+-??  #H LLH$%%    ->  ,.G  s###776??k11!ggl339r%>>rBB/11#NN(.+_03,, H LLBO$$   rErc0ddlm}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)MAX_CONCURRENT_CHILDRENc3:K|]}|jjdkdVdS) delegate_taskrsNrrs rCrz3AIAgent._cap_delegate_task_calls..` s1[[2r{7G?7Z7ZQ7Z7Z7Z7Z[[rErrszUTruncated %d excess delegate_task call(s) to enforce MAX_CONCURRENT_CHILDREN=%d limit)tools.delegate_toolrsumrrYrrr )rrdelegate_countkept_delegates truncatedrs rC_cap_delegate_task_callsz AIAgent._cap_delegate_task_callsU s @?????[[[[[[[ 4 4 4   % %B{?22!$;;;$$R((("a'N  $$$$ / 4 46M   rEcLt}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) r rrYrr:rrr rM)rseenuniquerrs rC_deduplicate_tool_callszAIAgent._deduplicate_tool_callss sEE T TB;#R[%:;C$  b!!!!@"+BRSSSSVs:66vvJFrErcddlm}|}||jvr|S|dddd}||jvr|S|||jdd}|r|dSd S) aAttempt to repair a mismatched tool name before aborting. 1. Try lowercase 2. Try normalized (lowercase + hyphens/spaces -> underscores) 3. Try fuzzy match (difflib, cutoff=0.7) Returns the repaired name if found in valid_tool_names, else None. r)get_close_matches-rr'rsr8)ncutoffN)difflibrrr r)rArrlowered normalizedmatchess rC_repair_tool_callzAIAgent._repair_tool_call s .-----//## d+ + +N__S#..66sC@@ . . . $#GT-BaPSTTT  1: trEcXd|_|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)rr$r,rRs rC_invalidate_system_promptz!AIAgent._invalidate_system_prompt s<&*"   0   - - / / / / / 0 0rErPc ||n|j}|sdSg}|D]}t|tr|dini}|d}t|tr|sn|d||ddd|ddid d |pdS) zIConvert chat-completions tool schemas to Responses function-tool schemas.NrrYrMrFrNr?)r propertiesrrYrMstrictrN)rPrKrrrLrr)rArP source_tools converteditemrrYs rC_responses_toolszAIAgent._responses_tools s % 1uutz  4*,   D-7d-C-CK*b)))B66&>>DdC((      "!vvmR88 ff\HTV3W3WXX      D rErfn_namerindexcddl}|d|d|}|j|dddd}d|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. rN:rr)errorsrYcall_)hashlibsha256encode hexdigest)r2rr3r8seeddigests rC_deterministic_call_idzAIAgent._deterministic_call_id so //I//// GI F FGGQQSSTWUWTWXvrEraw_idc4t|tsdS|}|sdSd|vrI|dd\}}|pd}|pd}||fS|drd|fS|dfS)z8Split a stored tool id into (call_id, response_item_id).NN|rsNfc_)rKrLrrr_)r?rcall_idresponse_item_ids rC_split_responses_tool_idz AIAgent._split_responses_tool_id s&#&& :  : %<<(- C(;(; %G%mmoo-G/5577?4 ,, ,   E " " ; d{rErDrEcrt|tr+|}|dr|S|pd}|dr|S|dr:t |t dkrd|t ddSt jdd|}|dr|S|dr:t |t dkrd|t ddS|r d|ddS|p(t|pdptjj }tj | d dd}d|S) zCBuild a valid Responses `function_call.id` (must start with `fc_`).rCrr7Nz[^A-Za-z0-9_-]0r)rKrLrr_rMrrrrrr8sha1r:r;)rArDrE candidater sanitizedr<r=s rC"_derive_responses_function_call_idz*AIAgent._derive_responses_function_call_id s & , , !(..00I##E** !  -R&&((   U # # M   W % % 1#f++G *D*D0G .00 0F,b&99    & &      ( ( 4S^^c'll-J-J33w<<==133 3  *)3B3)) )H-344H 8Hdkk'2233==??DV~~rEc  g}|D]}t|ts|d}|dkr5|dvr|dd}|t|nd}|dkrB|d}d }t|trF|D]C} t| tr,| d r|| d }D|r|d|d n|r|ddd |d } t| tr\| D]X} t| ts| di} | d} t| tr| sn|| d\}}| d}t|tr|s|}t|tr|st|trP|dr;t|tdkrd|tdd}nGt| dd}| | |t|}|}| dd}t|trtj |d }n$t|tst|}|pd}|d|| |dZ|||d |dkr|d}||\}}t|tr|s=t|tr(|r|}t|tr|s|d|t|ddpdd|S)z>Convert internal chat-style messages to Responses input items.rrW>rr>rrNr>r?Fencrypted_contentTrrrrrYrrDrCr7rrr function_callrrDrYrrr=function_call_outputrrDoutput) rKrrrLrrrrFr_rMr>rr)rArrrrr content_textcodex_reasoninghas_codex_reasoningrirrrr2embedded_call_idembedded_response_item_idrD _raw_argsrraw_tool_call_idrs rC!_chat_messages_to_responses_inputz)AIAgent._chat_messages_to_responses_input s&(Z Z Cc4(( 776??Dx,,,'')R00/6/Bs7||| ;&&'*gg.E&F&FO*/'!/488;"1;;B)"d33;?R8S8S; % R 0 0 06: 3#))++K kl%S%STTTT,K  kb%I%IJJJ!$!6!6J!*d33'",&&B#-b$#7#7) (!# B!7!7B&(ffVnnG#-gs#;#;)7==??) (JNJgJg "t KKG,.G')ffY&7&7G#-gs#;#;;7==??;*:#-gs#;#; j7==?? j$./H#$N$N!j(A(L(LU(S(S!j),,E(F(FU(S(S.^6OPSTYPZPZP[P[6\.^.^GG03BFF;4M4M0N0NI.2.I.I'S\^abg^h^h.i.iG&-mmooG(*{D(A(AI))T::;,0Jyu,U,U,U %/ 3%?%?;,/ NN (1(9(9(ATI!LL(7+2(/-6 **  d|DDEEEv~~#&77>#:#: !::;KLL !'3//;w}};!"2C88;=M=S=S=U=U;"2"8"8":":!'3//w}} 2&!#'')R"8"8">B??  rE raw_itemsc t|tstdg}t|D]\}}t|tstd|d|d}|dkr^|d}|d}t|t r|std|dt|t r|std|d |d d }t|trtj |d }n$t|t st |}|pd }| d|||d|dkr|d}t|t r|std|d|dd} | d} t| t st | } | d|| dj|dkr|d} t| t r| rd| d} |d} t| t r| r| | d<|d} t| tr| | d<ng| d<| | |d}|dvrX|dd}|d}t|t st |}| ||dtd|d|d|d|S) Nz4Codex Responses input must be a list of input items.zCodex Responses input[] must be an object.rrQrDrYz#] function_call is missing call_id.z ] function_call is missing name.rrFrrRrSz*] function_call_output is missing call_id.rUrrTrrOrrOrrr>rr>rrPz#] has unsupported item shape (type=z, role=).) rKrrJ enumeraterrrLrrrr)rAr_r%r3r0 item_typerDrYrrU encryptedreasoning_itemitem_idrrrs rC_preflight_codex_input_itemsz$AIAgent._preflight_codex_input_items^ s)T** USTT T+- "9--M M ICdD)) U !S#!S!S!STTT((IO++((9--xx''!'3//hw}}h$%fc%f%f%fggg!$,,eDJJLLe$%cc%c%c%cddd HH[$77 i../ $ 95 I I III#Is33/ #II%OO--5 !! /#*==?? $ %. 222((9--!'3//ow}}o$%mc%m%m%mnnn(B//>F!&#..) [[F!! 6#*==??"(K'' HH%899 i-- 6) 6.9PY%Z%ZN"hhtnnG!'3//7G7/6t,"hhy11G!'40074;y1146y1%%n55588F##D,,,((9b11? G!'3//+!'llG!!4G"D"DEEEoooQZooeiooo rE allow_streamrkc | ttstdhd}fd|D}|r3tddt |dd}t|t r|std|}d }|d }t|t st |}|pt}| d }d }d} |t|tstd g} t|D]\} } t| tstd| d| ddkr)td| d| dd| d} | d} t| t r| std| dt| tstd| d| dd }|d }t|t st |}| dd}t|tst|}| d| ||| ddd}|durtdhd|||dd}| | |d <d}t|tr||d<d }t|tr||d <d!}t|ttfr|d"krt||d!<d#}t|ttfrt||d#<d$D]}|}||||<|rId%}||d&urtd'|d&urd&|d%<d%nd%vrtd(t fd)D}|r&td*d|d|S)+Nz'Codex Responses request must be a dict.>inputr instructionscg|]}|v| Sr`r`)rrrs rCrz7AIAgent._preflight_codex_api_kwargs.. s#DDD3c.C.C3.C.C.CrEz3Codex Responses request missing required field(s): r~.rz;Codex Responses request 'model' must be a non-empty string.rnrrmrPz=Codex Responses request 'tools' must be a list when provided.zCodex Responses tools[rarrz] has unsupported type rYrNz] is missing a valid name.z] is missing valid parameters.rMr-Fr,storez6Codex Responses contract requires 'store' to be false.> rmrrqrPincluder temperature tool_choicernprompt_cache_keymax_output_tokensparallel_tool_calls)rrnrmrqrrrrvrrs)rtrwrurhTz/Codex Responses 'stream' must be true when set.zKCodex Responses stream flag is only allowed in fallback streaming requests.c3$K|] }|v|V dSrPr`)rr allowed_keyss rCrz6AIAgent._preflight_codex_api_kwargs..) s-XXC<@W@WC@W@W@W@WXXrEz2Codex Responses request has unsupported field(s): )rKrrJr rrrLrrrirrdr~rr}r=r:keys)rArrkrOmissingrrnnormalized_inputrPnormalized_toolsr3rrYrNrMr-rqr%rrrrvrspassthrough_keyvalrh unexpectedrys ` @rC_preflight_codex_api_kwargsz#AIAgent._preflight_codex_api_kwargs s *d++ HFGG G555DDDD(DDD  rpSWS\S\]cdk]l]lSmSmpppqq qw''%%% \U[[]] \Z[[ [ !~~n55  L,,, -|,,L#))++E/E <?? '#u 6 6 E;Lq;P;P.12C.D.DJ* + nn]33 kC< 0 0 ;(-k(:(:J} % Z 2 2O..11C.1 ?+  l^^H--F!fD&8&8 !RSSS~~'+ 8$   X & & & &  # #jkk kXXXX:??+<+<XXXXX  ]TYYzEZEZ]]] rEr0cTt|dd}t|tsdSg}|D]U}t|dd}|dvrt|dd}t|tr|r||Vd|S)zr output_textrrXrKrrLrr r)rAr0rchunksrptypers rC_extract_responses_message_textz'AIAgent._extract_responses_message_text1 s$ 400'4(( 2 $ $DD&$//E3334..D$$$ $ $ d###wwv$$&&&rEct|dd}t|trmg}|D]?}t|dd}t|tr|r||@|r'd|St|dd}t|tr|r|SdS)zAExtract a compact reasoning text from a Responses reasoning item.rNrrZrr)rAr0rrrrs rC!_extract_responses_reasoning_textz)AIAgent._extract_responses_reasoning_textA s$ 400 gt $ $ 1 "F ( (tVT22dC(((T(MM$''' 1yy((..000tVT** dC  T ::<< rrErc  t|dd}t|tr|stdt|dd}t|tr'|}nd}|dvrqt|dd}t|tr%|dpt |}n|rt |nd|d }t|g}g}g}g} |d v} d } d } |D]} t| d d}t| dd}t|tr'|}nd}|d vrd } |dkrt| dd}t|tr3|}|dvrd } n|dvrd } | | }|r| ||dkr | | }|r| |t| dd}t|tr|rd|d}t| dd}t|tr|r||d<t| dd}t|trJg}|D]@}t|dd}t|tr| d|dA||d<| | |dkr|d vrt| ddpd}t| dd}t|tstj |d }t| dd}t| dd}||\}} t|tr|r|n|}!t|!tr|!s$|||t!| }!|!}!t|tr|nd}"||!|"}"| t%|!|!|"d t%||!"|d#kr|t| ddpd}t| d$d}t|tstj |d }t| dd}t| dd}||\}} t|tr|r|n|}!t|!tr|!s$|||t!| }!|!}!t|tr|nd}"||!|"}"| t%|!|!|"d t%||!"d%d&|D}#|#sJt)|d'r:t|d'd}$t|$tr|$}#t%|#| |r'd(|nddd|pd)}%| rd*}&n| s| r| sd+}&n |r|#sd+}&nd,}&|%|&fS)-zENormalize a Responses API object to an assistant_message-like object.rUNz&Responses API returned no output itemsstatus>failed cancelledrorzResponses API returned status 'r>queued incomplete in_progressFrTphase>analysis commentary>final final_answerrrOrbrrr summary_text)rrrQrYrrrrrDrr<rrDrErrcustom_tool_callrmrZcg|]}||Sr`r`)rrs rCrz5AIAgent._normalize_codex_response.. s>>>aA>>>>rErr)rrrrrr?rrstop)rXrKrrrLrrrrrrrrrrFr>rMrMrr r)'rArrUr error_objr content_partsrreasoning_items_rawrhas_incomplete_itemssaw_commentary_phasesaw_final_answer_phaser0re item_status item_phasenormalized_phase message_textrrfraw_itemrhr raw_summaryrrr2r raw_call_id raw_item_idrZrrDrE final_textout_textrrs' rC_normalize_codex_responsez!AIAgent._normalize_codex_responseQ s8T22&$'' Iv IGHH H!(Hd;; os + + #-3355;;==OO"O 5 5 5'488I)T** r%MM)44FI .7qC NNN=q_n=q=q=q y)) )#% %'46 " .2YY$!&X X Dfd33I!$$77K+s++ #)//117799 " EEE'+$I%%$T7D99 j#..6'1'7'7'9'9'?'?'A'A$'+EEE/3,,)-FFF15.#CCDII 7!((666k))!%!G!G!M!M!;#**>:::$D*=tDD i--9)9(3)TTH%dD$77G!'3//1G1)0%dIt<#>D)$44[ + 2 2NTX3Y3Y Z Z Z.9+'..x888o--"III!$339r#D+t<< !)S11J $ 95 I I II%dIt<< %dD$77 &*&C&CK&P&P# !)3K)E)Es+J[J[J]J]s++cs!'3//_w}}_"99'9cR\oo^^G!--//2<[#2N2N#X;;TX #'#J#J7Td#e#e !!/#%5#,'YOOO ###000!$339r#D'488 !)S11J $ 95 I I II%dIt<< %dD$77 &*&C&CK&P&P# !)3K)E)Es+J[J[J]J]s++cs!'3//_w}}_"99'9cR\oo^^G!--//2<[#2N2N#X;;TX #'#J#J7Td#e#e !!/#%5#,'YOOO ###YY>>=>>>??EEGG  .gh >> .x;;H(C(( .%^^-- +!>MWfkk/2288:::SW"""5"=      #(MM ! #&: #CY #(MM # #)MM"M -//rEcJtj}|jd|jS)Nr5)rocurrent_threadrYident)rAthreads rC_thread_identityzAIAgent._thread_identity s()+++.. ...rEct|dd}t|dd}t|dd}d|d|d|d|S) Nrrrrzthread=z provider=z base_url=z model=)rXr)rArrrs rC_client_log_contextzAIAgent._client_log_context s}4Y774Y77gy11 1d++-- 1 1 1 1  1 1). 1 1 rEc`t|dd}|tj}||_|S)Nr)rXrorr)rAlocks rC_openai_client_lockzAIAgent._openai_client_lock s2t^T22 <?$$D $D  rErcddlm}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.mockrrKrXcallabler~)rris_closed_attr http_clients rC_is_openai_client_closedz AIAgent._is_openai_client_closed s '&&&&& fd # # 5 d;;  %'' !>## 4 n%% tfi66  " [%@@AA AurErrqc||jdks6t|dddr?ddlm}|d i|}t d||||Std i|}t d||||S) Nr]rrz acp://copilotr)CopilotACPClientz-Copilot ACP client created (%s, shared=%s) %sz(OpenAI client created (%s, shared=%s) %sr`) rrLrr_agent.copilot_acp_clientrrrrr)rArrprqrrs rCrzAIAgent._create_openai_client s =M ) )S1B1B:r1R1R-S-S-^-^_n-o-o ) A A A A A A%%66 66F KK?((**     M((-(( 6    $ $ & &     rEcddl}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_sockrhrsz'Force-close TCP sockets sweep error: %s) socketrXrshutdown SHUT_RDWRrIcloserrr) r_socketclosedr transportpool connectionsconnrhsockexcs rC_force_close_tcp_socketsz AIAgent._force_close_tcp_sockets- s !   ) 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)NrTroz7Failed to rebuild shared OpenAI client (%s) %s error=%sFzreplace:) rrXrrrrr rrr$)rArp old_client new_clientrs rC_replace_primary_openai_clientz&AIAgent._replace_primary_openai_client sU  % % ' ' % % x66J !778KTZcg7hh    M,,..  uuu % % % % % % % % %DK % % % % % % % % % % % % % % % !!*5H5H5HQU!VVVts:B+AB+ B/B?B+B B++B/2B/c|5t|dd}|#||s|cdddSdddn #1swxYwYtd|||d|std|5|jcdddS#1swxYwYdS)NrzCDetected closed shared OpenAI client; recreating before use (%s) %szrecreate_closed:rpz'Failed to recreate closed OpenAI client) rrXrrr rrrr)rArprs rC_ensure_primary_openai_clientz%AIAgent._ensure_primary_openai_client s  % % ' '  T8T22F!$*G*G*O*O!                         Q   $ $ & &   22:UV:U:U2VV JHII I  % % ' '  ;                  s#*AAA C!!C%(C%c,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. rNFrrrrrrrrrhrsrETu@Found %d dead connection(s) in client pool — rebuilding clientdead_connection_cleanuprzDead connection check error: %s)rXrr setblockingrecvMSG_PEEK MSG_DONTWAITBlockingIOErrorrIrr rrr) rArrrrr dead_countrrhrrrNrs rC_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)NrrrFro)rrrrKrrrr)rArprprimary_clientrequest_kwargss rC_create_request_openai_clientz%AIAgent._create_request_openai_client s&&&&&&;;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)NFro)r$)rArrps rC_close_request_openai_clientz$AIAgent._close_request_openai_client s# !!&!FFFFFrEon_first_deltac (ddl}|p|d}d}d}d}d|_t|dzD]T} |jjdi|5} | D]} |jrnt| dd} d | vs| d krMt| d d} | r9|s7|s d }|r |n#t$rYnwxYw| | sd | vrd }zd| vr,d | vr(t| d d}|r| || cdddcS#1swxYwY#|j |j |jtf$r}| |kr J J J!4466377777777777777777774.0BFDWYhi ` ` `///LLh! *Q.0022 HHHH o,,.. ==jQ^=__________   s88$8H$D!$3E)E)ELLa! *Q.0022  HHHH$dLLs0022 AA*UbAcccccccccc# Y= = sD.AD" B"!D"" B/ ,D".B/ /A$D" D."D& &D.)D& *D..J response.failedresponse.incompleterrrzHResponses create(stream=True) fallback did not emit a terminal response.r`) rrrrcreaterrXrKrrrr) rArrrfallback_kwargsstream_or_responseterminal_responserrclose_fns rCrz)AIAgent._run_codex_create_stream_fallback<sk$"D"DLj"D"k"k z**$(!::?Y]:^^;]4;NNoNN %x 0 0 &% %):66 &% %  + - -$UFD99 !3j&=&=3!&6!2!2J%eee$+E:t$D$D!$,E41H1H,(- *(=(=%$0,,,17DAAH!! HJJJJ D  1 -17DAAH!! HJJJJ D 17DAAH!! HJJJJ D   ($ $efffs[=BF& D11 D>=D>F% E00 E=<E=!F?# F.-F?. F;8F?:F;;F?c|jdks |jdkrdS ddlm}||}n3#t$r&}t d|Yd}~dSd}~wwxYw|d}|d }t|tr| sdSt|tr| sdS| |_ | d |_ |j |jd<|j |jd <|d sdSd S)Nr(r+Fr)!resolve_codex_runtime_credentials) force_refreshz#Codex credential refresh failed: %srrr.codex_credential_refreshrT)rrhermes_cli.authrrrrrrKrLrrrrrr)rArrcredsrrrs rC%_try_refresh_codex_client_credentialsz-AIAgent._try_refresh_codex_client_credentialsdsp =- - -.1P1P5  I I I I I I55EJJJEE    LL> 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)Nr)nousFr) resolve_nous_runtime_credentialsrHERMES_NOUS_MIN_KEY_TTL_SECONDS1800HERMES_NOUS_TIMEOUT_SECONDS15)min_key_ttl_secondstimeout_seconds force_mintz"Nous credential refresh failed: %srrr.r^nous_credential_refreshrT)rrrrrzr}rrr=rrrrrKrLrrrrrrr)rArrrrrrs rC$_try_refresh_nous_client_credentialsz,AIAgent._try_refresh_nous_client_credentialss =. . .$-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-c|jdkst|dsdS|jdkrdS ddlm}m}|}n3#t $r&}td|Yd}~dSd}~wwxYwt|tr| sdS| }||j krdS |j n#t $rYnwxYw ||t|dd|_ n3#t $r&}td |Yd}~dSd}~wwxYw||_ dd lm}|||_d S) Nr*rFr,r)rVrUz'Anthropic credential refresh failed: %srz?Failed to rebuild Anthropic client after credential refresh: %srWT)rrrrrVrUrrrrKrLrrrrrXr rXr)rArVrU new_tokenrrXs rC)_try_refresh_anthropic_client_credentialsz1AIAgent._try_refresh_anthropic_client_credentialss =0 0 0FZ8[8[ 05 =K ' '5  _ _ _ _ _ _ _ _//11II    LLBC H H H55555 )S)) 1B1B 5OO%% / / /5   " ( ( * * * *    D  %;%;IwtUjlpGqGq%r%rD " "    NN\^a b b b55555 #,;;;;;;#2?9#=#= ts?? A/ A**A/?C C&%C&* D D;D66D;cddlm}|pd}d|vrt||jd<dSd|vrddlm}||jd<dSd|vrd d i|jd<dS|jdddS) Nr) _OR_HEADERSrr0r^r_r`rbrcrd)rr*rrrrrar)rArr*r%ras rC"_apply_client_headers_for_base_urlz*AIAgent._apply_client_headers_for_base_urls666666n"++-- : % %59+5F5FD  1 2 2 2 $ 2 2 A A A A A A5L5L5N5ND  1 2 2 2 z ) )6BM5RD  1 2 2 2   # #$5t < < < < |S4Q4Qc ++C000Wc )-I&*.-J' // >>> ++3H+IIIIIs A:: BBrrhas_retried_429c8|j}||d|fS|dkr_|d}|Ctdt |dd||dSd|fS|d kra|sd S|d }|Ctd t |dd||dSd S|d kr|}|Etd t |dd||d|fS|d }|Ctdt |dd||dSd|fS)aAttempt credential recovery via pool rotation. Returns (recovered, has_retried_429). On 429: first occurrence retries same credential (sets flag True). second consecutive 429 rotates to next credential (resets flag). On 402: immediately rotates (billing exhaustion won't resolve with retry). On 401: attempts token refresh before rotating. NFi)rru3Credential 402 (billing) — rotated to pool entry r?)TF)FTu6Credential 429 (rate limit) — rotated to pool entry u(Credential 401 — refreshed pool entry Tu:Credential 401 (refresh failed) — rotated to pool entry )rmark_exhausted_and_rotaterrrXr3try_refresh_current)rArrr4r next_entry refresheds rC_recover_with_credential_poolz%AIAgent._recover_with_credential_pools$ <;./) ) #  77C7HHJ% rRYZdfjloRpRprrsss%%j111"{/) ) #  " #"{77C7HHJ% uU\]gimorUsUsuuvvv%%j111"{; #  0022I$ fwyZ^`cGdGdffggg%%i000_,,77C7HHJ% yY`akmqsvYwYwyyzzz%%j111"{o%%rEcn|jdkr||jjjdi|S)Nr*r`)rr(rrr)rArs rC_anthropic_messages_createz"AIAgent._anthropic_messages_create)sA =0 0 0  : : < < <5t%.5CC CCCrEcxdddddifd}tj|d}||r|djr jd krEd d lm}j |j td d_ n. d}||d n#t$rYnwxYwt!d|ЉdddS)ad Run the API call in a background thread so the main conversation loop can detect interrupts without waiting for the full HTTP round-trip. Each worker thread gets its own OpenAI client instance. Interrupts only close that worker-local client, so retries and other requests never inherit a closed transport. Nrrorc p jdkrJdd<dtddd<n]jdkrd<n9d d<djjjd id<n#t$r}|d <Yd}~nd}~wwxYw d}| |d dSdS# d}| |d wwxYw) Nr(codex_stream_requestrr_codex_on_first_delta)rrrr*chat_completion_requestrorequest_completer`) rrrrXr?chat completionsrrrr)rgrequest_clientrrequest_client_holderresultrAs rC_callz.AIAgent._interruptible_api_call.._call:s a=$5556:6X6X`v6X6w6w)(3)-)?)?"4X>'.t5Ld'S'S*@**F:&& ]&:::)-)H)H)T)TF:&&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````.s0B2B65D6 CC D CD1D5Tr3333333?rr*rrUrinterrupt_abortrz!Agent interrupted during API callror)rorris_aliver rrrrUrrrrXrrrInterruptedError)rArrLr0rUrIrJrKs`` @@rC_interruptible_api_callzAIAgent._interruptible_api_call.s#T22!)4 0 a a a a a a a a*  E$ 7 7 7  jjll L FF3F   ( L}(<<<RRRRRR.446661G1G 3#D*?FF22.. *?)B)B8)L)L)5 ==nUf=ggg D&'JKKK+jjll L, '? &/ !j!!s2A>C11 C>=C>rct|ddr"|r |r d|_d|z}|j|jfD]!}| ||#t $rYwxYw"dS)z;Fire all registered stream delta callbacks (display + TTS).rFrN)rXrrrrrrArcbs rCrzAIAgent._fire_stream_deltams 4. 6 6 !4 !DJJLL !',D $D=D-t/DE  B~BtHHHH D  s A A A cdd|_|j}| ||dS#t$rYdSwxYwdS)z&Fire reasoning callback if registered.TN)rrrrUs rCrzAIAgent._fire_reasoning_delta}sV'+$  $ > 4     >s  --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)rArrVs rC_fire_tool_gen_startedzAIAgent._fire_tool_gen_startedsP # > 9      >s  &&c:|jdupt|ddduS)z4Return True if any streaming consumer is registered.Nr)rrXrRs rCrzAIAgent._has_stream_consumerss/  &d 2 Ct/66dB rErc jdkr0_ d_S#d_wxYwdddddiddiddidtjifd  fd  fd  fd }t t jd d}tddgDdz}|dkrt|d}n|dkrt|d}n|}tj |d}| | r|dtjdz |krtd| d}||dn#t$$rYnwxYw dn#t$$rYnwxYwtjd<jr jdkrEdd lm} j| jt5d!d_n.d} | | d"n#t$$rYnwxYwt7d#| d$d$d%S)&uStreaming 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. r(NrArdoneFrr0cfds%r%dd< dS#t$rYdSwxYwdSdS)Nr]T)r)rrsrC_fire_first_deltazDAIAgent._interruptible_streaming_api_call.._fire_first_deltasq$V,  ,0!&)"N$$$$$ DD     s  ,,c  ddl}ttjdd}ttjdd}i!dddi|d ||d d }%d $d<t j#d<$djjj d+i|}g}i}t}i}i} d} d} d} g} d}d%_ |D]h}t j#d<%j rnG|j s=t|dr|jr|j} t|dr|jr|j}g|j dj}t|dr|jr|j} t%|ddpt%|dd}|r4| | %||r|jry||j|s* %|jd"d<n3%jr, %|jn#t0$rYnwxYw|r|jr|jD]}|j|jnd}|jpd}|| vr|| |<|r)||vr%|||krt9|ddz}|| |<|r|||<| |}||vr|jpddddddd||<||}|jr |j|d<|jrX|jjr |ddxx|jjz cc<|jjr |dd xx|jjz cc<t%|d!d}|,t|d"r|j pi!d!}|)t|d#r|"}||d!<|dd}|r8||vr4|#| %$||j dj%r|j dj%} t|dr|jr|j}jd&|pd}d}|rg}tO|D]v}||}|tQ|d|d$|!d!tQ|dd|dd %wd&| pd}tQ| |||&}tQd|| pd'(}tQd)tStUj+z| |g|*S),z#Stream a chat completions response.rNHERMES_API_TIMEOUT @HERMES_STREAM_READ_TIMEOUTgN@T include_usage>@)connectrrHr)rhstream_optionsrchat_completion_stream_requestrrr0r>FrusagerrrrrF)rrsrr<)rrr extra_contentrrYrrj model_extra model_dumpr)rrrjr)rrrrr)r3rrzstream-)rrchoicesrir`),rJr=rrTimeoutrtimerGrHrr rrrmrrrirrXrrrrrrrr3rrzrrYrrkrrlr:rYrr rrrLrr)&r _base_timeout_stream_read_timeout stream_kwargsrhrtool_calls_acctool_gen_notified_last_id_at_idx_active_slot_by_idxr model_namerr usage_objchunkrrtc_deltaraw_idxdelta_idnew_slotr3rextrarY full_contentmock_tool_callsrfull_reasoning mock_message mock_choicer_rdeltas_were_sentlast_chunk_timerJrAs& rC_call_chat_completionszIAIAgent._interruptible_streaming_api_call.._call_chat_completionss " " " "!"),@&"I"IJJM#(3OQU)V)V#W#W   #2D"9!>> -' *   M/3.P.P7/Q// !( + $(9;;OC L*849EL]]}]]F"$M#%N%(UU  %'O(*  MJD$&OI,1D (i ,i ,'+y{{$,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 I#,%%% $%/>U-/>$)$4.>.>42'F'F'F'JH;C/8#@7?OG41':n44&.k&7R(257b,I,I15 33N3/ !/s 3#;6*2+E$K#,^'05T %j 1& 9 9 9X=N=S S 9 9 9'0:^ %j 1+ > > >(BSB] ] > > > '/4 H H =WX}-M-M=%-%9%?R$D$D_$U$UE ,&ul;;;(-(8(8(:(:5:E/2$Z08>C/@$@$@-11#666--/// 77====#1C$)M!$4$BM5'**,u{, % I77=119TL"O "$!.11  C',B#**?d8Z&(ff_&=&=!0!#J!7&(n[&A""" ,,, WW_55=N*$*"0 L *$+5vK #s4:<<000 $   s(I IIcd}d _tj d< jjjdi 5}|D]} jrnt |dd}|dkr]t |dd}|rIt |dddkr4d}t |d d}|r  ||d krt |d d}|rt |dd}|d kr5t |d d}|r!|s  ||dkr2t |dd} | r  |  | 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. Fr0rNcontent_block_start content_blocktool_useTrYcontent_block_deltar text_deltarrthinking_deltarr`) rrorrrhrrXrYrrget_final_message) has_tool_userhrrrrr delta_typer thinking_textr_rrrAs rC_call_anthropiczBAIAgent._interruptible_streaming_api_call.._call_anthropics9!L+0D ($(9;;OC 7'07EE*EE 2#NNE0!(!=!=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#'!B !B$5$5$7$7$7$($;$;D$A$A$A!+/?!?!?07z20N0N #0!N$5$5$7$7$7$($>$>}$M$M$M//11A 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2sD6E;;E?E?c Tddl}ttjdd} t |dzD]} jdkr"d<n d<d}||d dSdS#t$r}d rWt d ||d <Yd}~d}||d dSdSt||j |j|jf}t||j|jt$f}d }|sg|seddlm}t||rOt+|dds>t-|d} t1fd| D}|s|s|r||krtd|dz|dzt5|j|dt5|jd|dzd|dzdd} | | d dd< d n#t$rYnwxYwYd}~ed|dzdt d|dz|n[t-|} d| vod| v} | rdtd| t?jd < d<n#t$r} | d <Yd} ~ nd} ~ wwxYwYd}~d}||d dSdSd}~wwxYw d}||d dSdS#d}||d wwxYw)!NrHERMES_STREAM_RETRIESrCrsr*rrstream_request_completerrz9Streaming failed after partial delivery, not retrying: %sroF)APIErrorrr) connection lostconnection resetconnection closedzconnection terminated network errornetwork connection terminatedz peer closedz broken pipezupstream connect errorc3 K|]}|vV dSrPr`)rphrase_err_lower_sses rCrzKAIAgent._interruptible_streaming_api_call.._call..s<7"7"(.%+n$<7"7"7"7"7"7"rEzJStreaming attempt %s/%s failed (%s: %s), retrying with fresh connection...u'⚠️ Connection to provider dropped (u). Reconnecting… (attempt r.rystream_retry_cleanupstream_retry_pool_cleanupu(❌ Connection to provider failed after uM attempts. The provider may be experiencing issues — try again in a moment.zTStreaming exhausted %s retries on transient error, falling back to non-streaming: %srhz not supportedu ⚠ Streaming is not supported for this model/provider. Falling back to non-streaming. To avoid this delay, set display.streaming: false in config.yaml zCStreaming failed before delivery, falling back to non-streaming: %sr0)!rJr}rrrGrr(rrrrr rKrConnectTimeout PoolTimeoutrrrrIrrXrLrrrrr[rrrrorS)r_max_stream_retries_stream_attemptrIrg _is_timeout _is_conn_err_is_sse_conn_err _APIError_SSE_CONN_PHRASESstale _err_lower_is_stream_unsupported fallback_errrrrrrrrJrKrAs @rCrLz8AIAgent._interruptible_streaming_api_call.._calls " " " ""%bi0G&K&K"L"L D h',-@1-D'E'EO~=,@@@ JJLLL1@1B1BF:..1G1G1I1IF:.t"7!:!:8!D!D!-55nMf5ggggg.-u%www+E2##NN []^/0F7O"FFFF`"7!:!:8!D!D!-55nMf5ggggg.-_'1 2F4I6K]^'' (2 3V5OQ`a(( ,1(*"<"DDDDDD)!Y77"=Z^@_@_"14Q 5" 1477"7"7"7"2C7"7"7"4"4" 0 '=,=:J= /1DDD & %H$3a$7$7!$;$(GG$4$% !"!"!"!% 1 1%a(,Q(8%a%a0?!0C%a%aFY\]F]%a%a%a!"!"!" )>(A(A((K(K#(#4$($E$E(-6L%F%&%&%&GK$9($C!)$($G$G/J%H%&%&%&%&(1!)!)!)$(D!) ( --!9#6#:!9!9!9 #NN!D 3a 7 ! *-QJ (J 6!B$3z$A3 6" $ 0 0%7!"!"!" #KK e ! ;489;;OC0151M1Mj1Y1YF:..(;;;.:F7OOOOOO;!6!:!:8!D!D!-55nMf5ggggg.-uwB"7!:!:8!D!D!-55nMf5ggggg.-"7!:!:8!D!D!-55nMf5gggg.sO6:B-:O6- O8(N; O6EN;4J  N; JN;JN;O6!BN;9.M('N;( N2M<7N;<NN;O6;OO661P'HERMES_STREAM_STALE_TIMEOUTgf@c3NK|] }tt|V!dSrPrMrL)rrs rCrz.Es.NN!#c!ff++NNNNNNrEr順gr@Pgn@Tr3rMrNuBStream stale for %.0fs — no chunks received. Killing connection.stale_stream_killrstale_stream_pool_cleanupr*rrOrstream_interrupt_abortz+Agent interrupted during streaming API callror)rrDrSror=rrrrrzrorrrQr rr rrrrrrUrrrrXrR)rArrrL_stream_stale_timeout_base _est_tokens_stream_stale_timeoutr0rcrUrIrrr_rrrrJrKs``` @@@@@@@@rC!_interruptible_streaming_api_callz)AIAgent._interruptible_streaming_api_callsA$ =- - - *8D & 233J??-1**T*1111"T22!)4 0#UO!5> ,      w w w w w w w w w w r. 2. 2. 2. 2. 2. 2. 2. 2`I hI hI hI hI hI hI hI hI hI hI hI hV&+295RTY+Z+Z%[%[" NNz~~j"/M/MNNNNNRSS  $'(BE$J$J ! ! 6 ! !$'(BE$J$J ! !$> !  E$ 7 7 7  jjll+ V FF3F    y{{_S114IIIX).228<J(( J54J5cj|jt|jkrdS|j|j}|xjdz c_|dpd}|dpd}|r|s|S ddlm}|||d \}}|)tj d ||Sd }t|j }|d krd}nZ|dks:| ddrd}n||rd}|j} ||_||_||_ ||_d|_|dkrddlm} m} m} |dkr|jp | pdn|jpd} | |_| |_t5|dd |_| | |j|_| | |_d |_i|_n"|j|_||_|j|d|_|dk}d|vrd|vp||_ tC|dr|j"rddl#m$}||j|j |j|j}|j|j"_|j |j"_ |j|j"_|j|j"_||j"_%tM||j"j'z|j"_(|)d|d|tj*d| ||dS#tV$r4}tj,d|||cYd }~Sd }~wwxYw)uSwitch 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. FrsrrrrreTrhNz.Fallback to %s failed: provider not configuredr)r+r(r,r.r/r*)rUrVrXrr\r0r6r>)get_model_context_length)rrru5🔄 Primary model failed — switching to fallback: z via u"Fallback activated: %s → %s (%s)z"Failed to activate fallback %s: %s)-rrMrrrr_try_activate_fallbackrrfrr rLrrrrrrrr rrUrVrXrrrXrrrrrrrr>agent.model_metadatarrr}rrMrrrro)rArh fb_providerfb_modelrf fb_clientr fb_api_mode fb_base_url old_modelrUrVrXr]rUrfb_context_lengthrgs rCrzAIAgent._try_activate_fallbacks  3t';#<#< < <5  !$"6 7 !vvj))/R6688>>@@ FF7OO)r0022 1( 1..00 0 T 1 F F F F F F228t===LIq D!!!22444-Ki011Kn,,/  ++{/A/A#/F/F/L/L/N/N/W/WXd/e/e+2 ++K88 0/  I!DJ'DM'DM'DM'+D $222ttttttttttZeitZtZt!2!U6M6M6O6O!USU|E|M|SQS , *7'+29j$+O+O()?)? tOg)h)h&+:?=+I+I(" &(## )0 ' (0 +''# #.1E"E !2!2!4!44UX^^EUEU9U'&  $t122 t7N IIIIII$<$<J L4=%%%!15 '-37='026,'/37='09J'6;>%(?(QQ<<'8   000"-00    L48[   4 1 1 1 M>! L L L..00 0 0 0 0 0 0 1s&?AM4I1M44 N2>)N-'N2-N2cr|jsdS|j} |d|_|d|_|d|_|d|_|d|_t|d|_|d|_ |jd krRd d l m }|d |_ |d |_ ||d |d |_|d|_d|_n0|t|ddd|_|j}|d|_|d|_|d|_|d|_|d|_|d|_d|_d |_t-jd|j|jdS#t0$r }t-jd|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 creates a fresh agent per message so this is a no-op there (``_fallback_activated`` is always False at turn start). Frrrrrrrr*rrOrrrNrestore_primaryTrorrrrrrz.Primary runtime restored for new turn: %s (%s)z%Failed to restore primary runtime: %s)r rNrrrrrrrrrrUrrrrrrr>rrMrrrrr )rArtrUccrgs rC_restore_primary_runtimez AIAgent._restore_primary_runtimes' 5  "/ GDJzNDMzNDMzNDMi=DL"&r/':";";D ')*>'?D $} 444JJJJJJ*,-@*A'+-.B+C()?)?*+R0D-E**&,..B+C(" "88O,--,9 (B,-BH23BK01BJ23BK "#> ?B "$%B"CB (-D $#$D L@ DM   4    OCQ G G G55555 sE8F F6F11F6>rrrrr api_error retry_count max_retriesc J|jrdSt|j}||jvrdS|rdS|jpd}|dvrdS t|dd/ | |j ddn#t$rYnwxYw|j }t|d |_|d |_|d |_|d |_|d |_|d|_|jdkrRddlm}|d|_|d|_||d|d|_|d|_d|_ n0|t|d dd|_ t5d|zd}||jd|d|jd|ddt;j|dS#t$r } t?j 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)rz nous-researchrNprimary_recoveryTrorrrrrrr*rrOrrrrru🔁 Transient z on u — rebuilt client, waiting z"s before one last primary attempt.rz%Primary transport recovery failed: %s)!r rr[_TRANSIENT_TRANSPORT_ERRORSrrrrrXr$rrrNrrrrrrrrUrrrrrrrrrosleeprr ) rArrr error_typeprovider_lowerrrU wait_timergs rC_try_recover_primary_transportz&AIAgent._try_recover_primary_transport9s  # 5)__- T= = =5  " " $ $ 5--24466<<>> 6 6 65- tXt,,8-- ,>t.!D&B"&r/':";";D GDJzNDMzNDMzNDMi=DL} 444JJJJJJ*,-@*A'+-.B+C()?)?*+R0D-E**&,..B+C(" "88O,---9 A OQ//I LL?YY:YY4=YY+4YYY     Jy ! ! !4    OCQ G G G55555 s=3G8B#"G8# B0-G8/B00EG88 H"HH"ct|tsdS|D]1}t|tr|ddvrdS2dS)NFr> image_url input_imageT)rKrrr)rrs rC_content_has_image_partsz AIAgent._content_has_image_partss^'4(( 5  D$%% $((6*:*:>Z*Z*ZtturErcft|pdd\}}}d}|drZ|tddddd}|dr|}d d d d d d |d }tjd|d}|5| tj |dddn #1swxYwYt|j }t||fS)Nrrm image/jpegdata:;rsrzimage/z.pngz.gifz.webpz.jpg)z image/pngz image/gifz image/webprz image/jpganthropic_image_F)r}suffixdelete)rL partitionr_rMrrrtempfileNamedTemporaryFilerHbase64 b64decoder rY) rheaderrrNmime mime_partrtmprs rC _materialize_data_url_for_visionz(AIAgent._materialize_data_url_for_visionsqio2..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)Nrrr>z tool result)r>rrzDescribe 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_promptrzImage analysis failed: zImage analysis failed.z[The z- attached an image. Here's what it contains: ]z@ [If you need a closer look, use vision_analyze with image_url: )r8r9rLr:r;rrr_rtools.vision_toolsrrLrrKrrrrrunlinkrI)rArr cache_keycached role_labelanalysis_prompt vision_source cleanup_pathrMr result_jsonrKrgnotes rC&_describe_image_for_anthropic_fallbackz.AIAgent._describe_image_for_anthropic_fallbacksN3yB#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.]rc3K|]}||V dSrPr`)rrs rCrz8AIAgent._preprocess_anthropic_content..s'BBdTBTBBBBBBrErZc3K|]}||V dSrPr`)rrs rCrz8AIAgent._preprocess_anthropic_content..s'??D$?4??????rEzI[A multimodal message was converted to text for Anthropic compatibility.]) rrKrLrrrrrr ) rArr text_parts image_notesrrr image_datarr}rs rC_preprocess_anthropic_contentz%AIAgent._preprocess_anthropic_contentsy,,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  MZZrEc >tfd|Ds|Stj|}|D]g}t|ts|dt|ddpd|d<h|S)Nc3K|]A}t|to'|dVBdS)rN)rKrrr)rrrAs rCrz>AIAgent._prepare_anthropic_messages_for_api..s`   sD ! ! Wd&C&CCGGIDVDV&W&W      rErrr)rrHrrKrrrrL)rAr transformedrs` rC#_prepare_anthropic_messages_for_apiz+AIAgent._prepare_anthropic_messages_for_apis    #       mL11   Cc4(( !?? ""CGGFF++5v66C NNrEct|ddpddkrdSt|ddpd}d|vpd|vS)zkTrue when using Alibaba/DashScope anthropic-compatible endpoint (model names keep dots, e.g. qwen3.5-plus).rrrTr dashscopealiyuncs)rXr)rAbases rC_anthropic_preserve_dotsz AIAgent._anthropic_preserve_dotssf D*b ) ) /R 6 6 8 8I E E4j"--3::<<d"8jD&88rEc  |jdkruddlm}||}t |dd}|r|jnd}||j||j|j|j |j | |S|jdkrd}|}|re|d d d krFt|d d pd}|d d}|st}d |jvpd|jv}d}d} |j r`t%|j t&rF|j ddurd} n'|j dr |j d}|j||||dddd} |s |j| d<| r-|r|} | | | d<n|dd| d<dg| d<n|sg| d<|j |j| d<| S|} d} |D]u}t%|t&sd|vrd} nV| d}t%|t0r+|D]$}t%|t&sd|vsd|vrd} n%| rnv| rt3j|} | D]}t%|t&s|dd| d}t%|t0rF|D]C}t%|t&r,|dd|ddD|jpd| r_| d d d kr@t9fd t:Dr t1| } i| dd d!i| d<i}|jr |j|d"<|jr |j|d#<|j r |j |d$<|j!r |j!|d%<|j"rd|d&<|j#r |j#|d'<|j| tItKj&d(d)d*}|jr |j|d+<|j.|'|(|jn^|)rJd,|jpdvr- dd-lm*}||j}||d.<n#tV$rYnwxYwi}|)}d |j,vpd|j,v}|r|r||d/<d0|j,v}|-ra|r|} | | |d<nC|j 4t'|j }|r| ddurn||d<nddd1|d<|rd2g|d3<|r||d4<|S)5z9Build the keyword arguments dict for the active API mode.r*rbuild_anthropic_kwargsr>N)rrrPrris_oauth preserve_dotsrr(rrrWrrsmodels.github.air_mediumTrFeffortrg)rrnrmrPrtrwrqrur)rrzreasoning.encrypted_contentrrrvr?rrDrEc3 K|]}|vV dSrPr`)rrrs rCrz,AIAgent._build_api_kwargs..s(EE!A%EEEEEErE developeronlyignoreordersortrequire_parametersdata_collectionrarb)rrrrPr6)_get_anthropic_max_outputrr nousresearchrrproduct=hermes-agenttags extra_body).rrrrrXrrrPrrrr rrLrrrrrKrr^r1r#_github_models_reasoning_extra_bodyrrHrrrr-r r r r r rr=rrrOrrrrr_supports_reasoning_extra_body)rArrr*rrnpayload_messagesis_github_responsesreasoning_effortreasoning_enabledrgithub_reasoningsanitized_messagesneeds_sanitizationrrrprovider_preferencesrr_model_output_limitr"_is_openrouter_is_github_models_is_nousrrs @rC_build_api_kwargszAIAgent._build_api_kwargss =0 0 0 F F F F F F!%!I!I,!W!W d$8$??G07Ag,,TG))j+j?!%!61";;==&     =- - -L+  4 Q 3 3F ; ;x G G"<?#6#6y#A#A#GRHHNNPP #/#3  65 #dm&9&9&;&;;D*dm.A.A.C.CC (  $ $ GD4I4)P)P G(,,Y775@@(-%%*..x88G'+'{+5ERX*Y*YF;')F(GF9%%( '$&y!*.2o*+M)"  Cc4(( &#--%)"..J*d++ !+I%i66!  I--1Cy1P1P-1*2Q&E  D!%|!"&&8!9!9 $R'9!'<$Rfk$R$R q !!  ! B+/+A  (  ! D-1-C  *   A,0,@  )   >+/+=  (  + >9= !5 6  ( T6:6S !2 3Z*RY';VDDEE  : -"&*Jw  ? &   d44T_EE F F F F  $ $ & & 8 8Hb7O7O7Q7Q+Q+Q MMMMMM&?&? &K&K#+> <((     0022 $"6 6 ?&$*>>   :N :%9Jz "!T%99  . . 0 0   #'#K#K#M#M #/.>J{+(4d344B 5BFF9$5$5$>$>24 ;//$("*//J{+  :"8!9Jv   2'1J| $s!S== T  T cZd|jvrdSd|jvrdSd|jvs d|jvr5 ddlm}t||jS#t $rYdSwxYwd |jvrdSd |jvrdS|jpd d }tfd |DS)a3Return True when reasoning extra_body is safe to send for this route/model. OpenRouter forwards unknown extra_body fields to upstream providers. Some providers/routes reject `reasoning` with 400s, so gate it to known reasoning-capable model families and direct Nous Portal. rTzai-gateway.vercel.shrr_rgithub_model_reasoning_effortsFr0api.mistral.air)z deepseek/z anthropic/zopenai/zx-ai/zgoogle/gemini-2z qwen/qwen3c3BK|]}|VdSrP)r_)rr}rs rCrz9AIAgent._supports_reasoning_extra_body.. s1SS5##F++SSSSSSrE)rrr4r~rrrr)rAr4reasoning_model_prefixesrs @rCr$z&AIAgent._supports_reasoning_extra_bodys  T1 1 14 !T%9 9 94 !5 5 59PTXTh9h9h LLLLLL::4:FFGGG   uu  t3 3 35 t3 3 35!r((**$  SSSS:RSSSSSSs"A AAc 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.rr3NrFrrxhighhighminimallow) rr4rrrrKrrrLrr)rAr4supported_effortsrequested_efforts rCr#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||r5|j r.|j s' | |n#t$rYnwxYwd |jpd||d }t|d r|jr|j} g} | D]} t!| t"r| | -t| d r| | jXt| d r'| | | 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|jj|jjdd}t+|dd}|)t|d r|}||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. rrrrc3fK|],}||V-dSrPr)rbs rCrz3AIAgent._build_assistant_message..?s7&T&TQ!''))&Tqwwyy&T&T&T&T&T&TrENzCaptured reasoning ( chars): r>rrrrr__dict__rlr?rrDrrYrrrEr<rrjr) rr~rrrrr rrrrMrrrrrrKrrrErlrXrrLrrFr>rMrrrYr)rArrr_from_structuredr think_blockscombinedr raw_details preservedd codex_itemsrrr?rDrZr_fn_fn_name_fn_argsrEr[tc_dictr~s rC_build_assistant_messagez AIAgent._build_assistant_message/s 001BCC//  2'/52G:&=wbiXXXL 2!;;&T&T,&T&T&TTT!)!1T  ad2 a M_^1D1D__~__ ` ` `  d5 - ++N;;;; D (06B'*    $&9 : : 5?P?b 5 ,=KI  5 5a&&5$$Q''''Q ++5$$QZ0000Q --5$$Q\\^^444 5+4'(/1H$OO  7+6C' (  '/ +J.9, +, +  D$77!)Y==!'3///w}}/*.*G*G*O*O'$a.G!'3//cw}}c!&#..c6<<>>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  s7C CCapi_msgc|d}t|ts|Sddhfd|D|d<|S)ubStrip Codex Responses API fields from tool_calls for strict providers. Providers like Mistral strictly validate the Chat Completions schema and reject unknown fields (call_id, response_item_id) with 422. 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). rrDrEc~g|]9}t|tr fd|Dn|:S)c$i|] \}}|v || Sr`r`)rrr _STRIP_KEYSs rCrzJAIAgent._sanitize_tool_calls_for_strict_api...s) A A AdaA[,@,@Q,@,@,@rE)rKrr)rrrVs rCrz?AIAgent._sanitize_tool_calls_for_strict_api..s_! ! ! "d## , A A A Abhhjj A A A A)+! ! ! rE)rrKr)rRrrVs @rC#_sanitize_tool_calls_for_strict_apiz+AIAgent._sanitize_tool_calls_for_strict_apisn[[.. *d++ N "45 ! ! ! ! !! ! !   rE min_turnsc H |jdkr|dSd|jvs|jsdS||n|j}|j|krdS|t |dd}|rt |dkrdSd}dt |dtj}d ||d }| | d |j v}g}|D]} | } | d d kr| d} | r| | d<| dd| dd| dd|r|| | | |jrd|jdg|z}d} |jpgD]3} | di ddkr| } n4| s|  |rW|d d|kr8| |sn!|r|d d|k8|r5|d d|kr| dSdSdSddlm}d} |d|| gddd}n#t&$rd}d}YnwxYw|s]|jdkrR||}|| g|d <d|d!<d"|vrd|d"<||}n|sP|jd#krEdd$lm}||j|| gdd|%}||}nS|sQ|j|| gdd&|d}|d'jj j!d5i|d(di}g}|jdkr+|s)|"|\}}|r|j#r|j#}np|jd#kr.|s,dd)lm$}|||j%*\}}|r|j#r|j#}n7tM|d+r'|j'r |j'dj(}|j#r|j#}|D]}|j)j*dkr tWj,|j)j-}| d,d}dd-l.m/}|| d.|| d/| d0|j1}|j0s&tcd2| d,d#td$r%} tf4d3| Yd} ~ d} ~ wwxYwn2#td$r%} tf4d4| Yd} ~ nd} ~ wwxYw|rW|d d|kr8| |sn!|r|d d|k8|r5|d d|kr| dSdSdS#|rW|d d|kr8| |sn!|r|d d|k8|r4|d d|kr| wwwxYw)6aGive the model one turn to persist memories before context is lost. Called before compression, session reset, or CLI exit. Injects a flush message, makes one API call, executes any memory tool calls, then strips all flush artifacts from the message list. Args: messages: The current conversation messages. If None, uses self._session_messages (last run_conversation state). min_turns: Minimum user turns required to trigger the flush. None = use config value (flush_min_turns). 0 = always flush (used for compression). rNrrru[System: The session is being compressed. Save anything worth remembering — prioritize user preferences, corrections, and recurring patterns over task-specific details.]__flush_rr)rr_flush_sentinelr5rr>rrrr[rWrPrrYrF)call_llmTflush_memoriesrMire)taskrrPrsrrFr(rPrsrvr*r)rrrPrrr)rrrPrsrrnormalize_anthropic_responsestrip_tool_prefixrmr4 memory_toolactionrold_textrer4rrfrqu 🧠 Memory flush: saved to z!Memory flush tool call failed: %sz Memory flush API call failed: %sr`)5r(r r$r@rXrMrro monotonicrrrHrrrWrrPrr\rrr1r1rrrrr r?rrrGrHrrrr`rrrmrrrYrrrr+rdrrrrr)!rArrX effective_min flush_content _sentinel flush_msg_is_strict_apirrrRrmemory_tool_defr0 _call_llm_aux_availabler codex_kwargs_build_ant_kwargs ant_kwargsrr assistant_msgr _nar_flush _flush_msgrrr flush_target _memory_toolrKrgs! rCr]zAIAgent.flush_memoriess  '1 , ,1B F 40 0 08J 0 F%.%: @\  = 0 0 F  t%8$??H 3x==1,, F O  =r$xx<<$.*:*:<< # R[\\  """w -1EENL - -((**776??k11 # 4 4I A7@ 34 K... OT222 -t444!F<X Y YZ]ii #Oj&B  55R((,,V44@@&'OEA#  j x|//0ABBiOO  x|//0ABBiOO HRL,,->??9LL   LLk E D D D D D!N $9))*+ ##     !& " Kdm7H&H&H#55lCC (,(=(=>O(P(P W%.1 ]+&,668(2B >$,$4Q$7$?!$/>!2!=J  M M;#x//M#z"+*?@@'+xx('C'C QQQQQQ!-#'88H#5#5#/$(HHY$7$7%)XXj%9%9"&"4 """ $c!"a488HV^C_C_"a"abbb$MMM %H!LLLLLLLLM0 M" @ @ @ LL;Q ? ? ? ? ? ? ? ? @  x|//0ABBiOO  x|//0ABBiOO HRL,,->??9LL   LL  x|//0ABBiOO  x|//0ABBiOO HRL,,->??9LL  Ls(D1U .U 7J U JU JGU B5TU  UT?:U ?UU X U8U3.X3U88XBZ!rrr cN||d|jr, |j|n#t$rYnwxYw|j||}|j}|r|d|d| | |}||_ |j r |j |j}|j |jd|j} t!jddt'jjd d |_|jd |jd z |_|j |j|jpt4jd d|j| |ru |j |} |j |j| n9#t@tf$r%} tB"d| Yd } ~ nd } ~ wwxYw|j #|j|d|_$n2#t$r%} tB%d| Yd } ~ nd } ~ wwxYwtM|tO|z} | |j_(d|j_)|jj*dkr| |jj*z } | dkrd|_+ ddl,m-}||n#t$rYnwxYw||fS)zCompress conversation context and split the session in SQLite. Returns: (compressed_messages, new_system_prompt) tuple r)rX)current_tokensrrPrrrNrrrrr)rrrparent_session_idz,Could not propagate title on compression: %suKSession DB compression split failed — new session will NOT be indexed: %s333333?F)reset_file_dedup).r]r-on_pre_compressrr>compressr"format_for_injectionrr)rrrget_session_titler end_sessionr rrrrrrrrrrrrrget_next_title_in_lineageset_session_titlerJrrupdate_system_promptrr rr rrrMrtools.file_toolsr~)rArrrr  compressed todo_snapshotnew_system_prompt old_titleold_session_id new_titlerg_compressed_est_post_progressr~s rC_compress_contextzAIAgent._compress_context[s H222    $44X>>>>    ,55h}5]] (==??  J   v-HH I I I &&((( 55nEE%6"   q q ,>>tOO  ,,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 ""3 4 4,Z88 9 6E29:6  " 3a 7 7,t/F/WWN$$05-   9 9 9 9 9 9  W % % % %    D ,,,sd; AAC;I+:H I+ IH;6I+;I*I++ J5JJL L L effective_task_idapi_call_countc|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)rArrrrrs rC_execute_tool_callszAIAgent._execute_tool_callss'1 !% *1*== ::%x1BN%*D ! ! 66!8->%*D ! !ED ! ) ) ) )s&AA A& function_namerc |dkr@ddlm}||d|dd|jS|dkry|jst jdd d Sdd lm}||d d |d|dd|j|j S|dkr|dd}ddl m }||d||d|d|j }|j rm|ddvrV |j |dd ||dd n#t$rYnwxYw|S|j r5|j |r|j ||S|dkr@ddlm} | |dd |d|jS|dkrvdd lm} | |d!|d"|d#|d$|d%|&St/||||jrt3|jnd'(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. todor todo_toolrrFrrrqrSession database not available.rrorqueryr role_filterlimitrrrrdbcurrent_session_idrr4rcrerrfrg)r:rr clarify_toolquestionrmrrmcallbackrrgoalcontexttoolsetstasksrrrrrr parent_agentN enabled_tools)r!rrr"rrrtools.session_search_toolrrr+rdr$r-on_memory_writerhas_toolhandle_tool_calltools.clarify_toolrrrrrr r) rArrr _todo_tool_session_searchr4rxrK _clarify_tool_delegate_tasks rC _invoke_toolzAIAgent._invoke_tools 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 !DM  ! d&:&C&CM&R&R '88 VV V i ' ' H H H H H H =&**:r::%)))44.  o - - K K K K K K!>"&&v..%)))44&**:66#''00,001ABB!  (}.?=A=R\d4#8999X\ sAF F'&F'c ,0|j}t|}jrMtjd|d|D].}|dd|jjd|jd/dSg}|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,$rYnwxYw|| | | fdd|D}jstd|d|t;|dD]\}\}}}tj|d}jrKtd|d|dtA|!dtd |qt|j"kr|dj"d!zn|}td|d|dtA|!d"||D]d\}}}j#rW tI||}#|||6#t,$r!}tKj&d#|Yd}~\d}~wwxYwe|D]Y\}}}j'rL '|j||+#t,$r!}tKj&d$|Yd}~Qd}~wwxYwZdg|z00fd%}d}jrVj#sOtQj)tTj+}tU|d&|d'd(j,)}|- t]|t^}t`j12|*5}g}t;|D]7\}\}}}|3|||||}||8t`j14|dddn #1swxYwY|rRtkd+0D}tkd,0D} |6d-|d.|d/| d0d1nZ#|rStkd+0D}tkd,0D} |6d-|d.|d/| d0d1wwxYwt;|D]\}\}}}0|}!|! d2|d3}"d4}#n|!\} } }"}#}$|$r|&njs|jr-td?|dzd8|#d9d:td@|"nHt|"j"kr|"dj"d!zn|"}'td?|dzd8|#d9dA|'j;rM ;|j|||"n.#t,$r!}tKj&dB|Yd}~nd}~wwxYwdC}(t|"|(kr%t|"})|"d|(dD|)dEdF|(dEdGz}"d|"|jd}*||*<|}+|+r|r|dHdIdkr|dHdJ}, tj |,}-t|-t r%|+|-dK<tj|-d|dHdJ<n|,dL|+z|dHdJ<n-#tjtzf$r|,dL|+z|dHdJ<YnwxYwjs@j>|z }.|.j>dMzkrdNndO}/tj|/d|.dPdSdSdSdSdS)QzExecute 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]r Nrrrrrrrbefore terminalrworkdirrbefore terminal: rr~c3"K|] \}}}|V dSrPr`)rrrYs rCrz9AIAgent._execute_tool_calls_concurrent..Ls("G"GJAtQ4"G"G"G"G"G"GrEu ⚡ Concurrent: u tool calls — rsFr 📞 Tool r (ry Args: rZ) - Tool progress callback error: Tool start callback error: c@tj} || }n=#t$r0}d|d|}td||dYd}~nd}~wwxYwtj|z }t ||\}} |||||f |<dS)z%Worker function executed in a thread.Error executing tool '': z_invoke_tool raised for %s: %sTrN)rorrrror4) r3rrrrrK tool_errordurationis_errorrrresultsrAs rC _run_toolz9AIAgent._execute_tool_calls_concurrent.._run_toolksIKKE i**=-IZ[[ i i iP-PPJPP =}jcg hhhhhhhh iy{{U*H.}fEEKHa+]FHhWGENNNs. A(&A##A(u ⚡ running z tools concurrentlydots spinner_typeprint_fn) max_workersc3K|]}|dV dS)Nrsr`rrs rCrz9AIAgent._execute_tool_calls_concurrent..s"DDaammmmmDDrEc3*K|]}||dVdS)Nrr`rs rCrz9AIAgent._execute_tool_calls_concurrent..s&GG!GGrEu⚡ r.z tools completed in .1fzs totalrz!': thread did not return a resultrr"Tool %s returned error (%.2fs): %sTool  completed in .2fs Tool result (rCrK ✅ Tool Result: s - Tool complete callback error: r [Truncated: tool response was rm chars, exceeding the char limit]rFrrrr皙?⚠️ WARNING 💡 CAUTION iterations remaining)?rrMrrrrrrYrr)r*rrrrrKrrrrget_working_dir_for_pathensure_checkpointrrrrgetcwdr rrdrrrrzrr_build_tool_previewrrrrandomchoicer1KAWAII_WAITINGrrr_MAX_TOOL_WORKERS concurrentfuturesThreadPoolExecutorsubmitwaitrrrr _get_cute_tool_message_implrr_get_budget_warningrr)1rArrrrr num_toolsr parsed_callsrrr file_pathwork_dirrrtool_names_strrJrYrargs_str args_previewpreviewcb_errrspinnerfacerexecutorrrwrU total_durrfunction_result tool_durationrresult_previewcute_msgresponse_previewMAX_TOOL_RESULT_CHARS original_lenrfbudget_warning last_contentrr{tierrs1` ` @rCrz&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$))++5F5FIIIJJJ2223333ORS[}}_c_tOtOt8,BT-B,B#Ce#K#K{CLZZZdZZT$))++5F5FZZLZZ[[[[* M MNBd* MM1$==G//gtDDDD MMMM"K6"K"KLLLLLLLLM  M+ J JNBd' JJ,,RUD$???? JJJM"H"H"HIIIIIIIIJ J&9$ X X X X X X X ? 4#> =!=>>D#t$X$X)$X$X$Xgmx|yGHHHG MMOOO gi):;;K#66;6OO 1S[+4\+B+B&&'A'D$  1b$EEANN1%%%%"''000 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 gDD7DDDDD GGgGGGGG  eIee eeyeeeefff  gDD7DDDDD GGgGGGGG  eIee eeyeeeeffff  g$-\#:#:3 &3 & AD$ Ay"b4"b"b"b # YZV }o}hw>A/>R>RUX>X>X_TcT%:%:^mNNN#GXeguvvv'dM"[-"["[}"["["["[\\\M"b#o2F2F"b"bQ`"b"bccc f6tT=Yhiii  h1111_ f'fO!OO=OOOOPPP;/;;<<<F,-.2je.T.T.THRL++.:=TN=T=T.THRL+()4 Q Q Q*69P9P9P*P Y''' Q? T /.@ ,59Ls9R,R,R((XfR$RR)RRRSSSSS T T T T+M+M T TsB<<CC;AE  EE/BG66 HH'M;; N&N!!N&:O P!O==P35U=(A)T U=T!!U=$T!%U==AW]// ^9^^Ab 'c  c c t|jdD ]U\}}|jr{|j|dz d}|r/||jdt |dd|D]2}|jj} dd| d |jd } | | 3 n|jj} | d krd |_ n | d krd |_ tj |jj} n5#tj$r#} t!jd| i} Yd} ~ nd} ~ wwxYwt%| t&si} |jstj| d}|jrKt/d|d| dt1| dt/d|nft ||jkr|d|jdzn|}t/d|d| dt1| d||jrW t9| | }|| || n.#t:$r!}t!jd|Yd}~nd}~wwxYw|jrL ||j| | n.#t:$r!}t!jd|Yd}~nd}~wwxYw| dvrn|j j!rb | "dd}|r8|j #|}|j $|d| n#t:$rYnwxYw| dkr|j j!r | "dd}tK|ra| "d p%tMj'd!tMj(}|j $|d"|dd#n#t:$rYnwxYwtSj)}| d$krd d%l*m+}|| "d&| "d'd|j,(}tSj)|z }|jr)|d)t[d$| ||*nP| d+kr|j.stjdd,d-}n[d d.l/m0}|| "d/d| "d0| "d1d2|j.|j13}tSj)|z }|jr)|d)t[d+| ||*n| d kr| "d4d }d d5l2m3}|| "d6|| "d7| "d8|j49}tSj)|z }|jr)|d)t[d | ||*n| d:krd d;l5m6}|| "d}tSj)|z }|jr)|d)t[d:| ||*nB| d?kr d d@l8m9}| "dA}|r)t%|t0rdBt |dC} n(| "dDpdddE}!|!rdF|!ndG} d}"|jrU|jsNtuj;txj=}#ty|#dH| dI|j>J}"|"?|"|_@d}$ || "dD| "dK| "dL|| "dM|N}|}$d|_@tSj)|z }t[d?| ||$*}%|"r|"A|%n|jr|d)|%n#d|_@tSj)|z }t[d?| ||$*}%|"r|"A|%w|jr|d)|%wwxYw|jrd}"|jsrtuj;txj=}#t| }&t9| | p| }ty|#dH|&dH|dI|j>J}"|"?d}' t| | ||jDrt1|jDndO}|}'n=#t:$r0}(dP| dQ|(}tFdR| |(dSYd}(~(nd}(~(wwxYwtSj)|z }t[| | ||'*}%|"r|"A|%n|d)|%n#tSj)|z }t[| | ||'*}%|"r|"A|%w|d)|%wxYw t| | ||jDrt1|jDndO}n=#t:$r0}(dP| dQ|(}tFdR| |(dSYd}(~(nd}(~(wwxYwtSj)|z }|jr|nt |dTkr |ddTn|})t| |\}*}+|*rtdU| ||)|jrCt!jdV| dW|dXdYt!jdZt |d[||jHrM |H|j| | |n.#t:$r!}t!jd\|Yd}~nd}~wwxYwd]},t ||,kr%t |}-|d|,d^|-d_d`|,d_daz}d||jd }.| |.|jsv|jr*t/db|dW|dXdYt/dc|nEt ||jkr|d|jdzn|}/t/db|dW|dXdd|/|jr|t |jkr}t |j|z }0||jd|0ded|j|dD]2}|jj} ddf| dg|jd } | | 3n>|jId kr1|t |jkrtSjJ|jI W|K|}1|1r|r|dh"didkr|dhd7}2 tj |2}3t%|3t&r%|1|3dj<tj|3d|dhd7<n|2dk|1z|dhd7<n-#tjtf$r|2dk|1z|dhd7<YnwxYw|js@|jM|z }0|0|jMdlzkrdmndn}4t/|j|4d|0dodSdSdSdSdS)pz`Execute tool calls sequentially (original behavior). Used for single calls or interactive tools.rsNrrTrrrrr rrrz(Unexpected JSON error after validation: Frrr rryrrZrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr4rcrerrfrgrrrrmrrrru🔀 delegating z tasksru🔀 u🔀 delegatingr'rrrrrrrrrz&handle_function_call raised for %s: %srrrrrrrrrCrrrrmrrrrrz remaining tool call(s)u[Tool execution skipped — z* was not started. User sent a new message]rFrrrrrrr)NrdrrrrrMrrYrrr)r*rrrrrr rKrrrrrrrzrrrrrrrrrrrrrrrror!rr"rrrrrr+rdr$rrrrrrrr1rrr_delegate_spinnerr_get_tool_emojirr rror4rrrrrr)5rArrrrrJrremaining_calls skipped_tc skipped_nameskip_msgrrrgrr r r rrrrtool_start_timerrrrr4rxrr tasks_arg spinner_label goal_previewr r _delegate_resultremoji_spinner_resultrr_is_error_resultrrrrfrr{rrrrs5 rCrz&AIAgent._execute_tool_calls_sequentials%&7&BAFFE ,E ,LAy( "3">qstt"D"~LLDO!p!pSQ`MaMa!p!p!px|L}}}"1..J#-#6#;L &#uL#u#u#u(2   H OOH----%.3M((+,((.00*+' # $ 9+=+G H H ' # # # N1 N NOOO "  #mT22 # " ? n:m%HHH'n[[[m[[d=CUCUCWCW>X>X[[[\\\2223333ORS[}}_c_tOtOt8,BT-B,B#Ce#K#K{CLlllmlld=CUCUCWCW>X>Xll^jllmmm* MM1-OOG// w VVVV MMMM"K6"K"KLLLLLLLLM' JJ,,Y\=-XXXX JJJM"H"H"HIIIIIIIIJ 777D>$&? &?&?!D **t/C/K*'++Ir::C.s33+// ::dbiXZXaXcXc>d>d,>>!?S"X!?!?!D#ikkO&&CCCCCC",*'++G44'++GU;;*### !% o = ?CLL"B&A&-Yfo~&&&"B"BCCC"222' &*jUMn1o1o&p&pOO[[[[[[&5o+//<<$1$5$5m$D$D+//;;++/? '''O!% o = ?MLL"L&ABRTacpzI'J'J'J"L"LMMM(**&**8X>>IIIIII".,(,,X66!)--i88*..z::, ###!% o = ?ELL"D&A(M[hrA'B'B'B"D"DEEE)++LLLLLL"/-*..z2>>)--i88!2### !% o = ?FLL"E&A)]\isB'C'C'C"E"EFFF/11OOOOOO)--g66 bIt!J$a$:L$:$:$:PaM?$4+F$!=)EFFD+t,E,Em,E,ETZeiestttGMMOOO)0&#' 6&4n*..v66 - 1 1) < !>''4'8'89I'J'J%) '''O(7$-1D*$(IKK/$AM:?M[hrB C C CH6 X....6 _(__555 .2D*$(IKK/$AM:?M[hrB C C CH6 X....6 _(__55556" >2$!=)EFFD+M::E1-OO`S`G+t,G,Ge,G,Gg,G,GV\gkguvvvGMMOOO"&6&:%}6GEIEZ&dd4+@&A&A&A`d'''O'6OO uuu&]}&]&]Q[&]&]OLL!I=ZdosLttttttttu%)IKK/$AM:=-Yfo~H6 X.... _(__5555 %)IKK/$AM:=-Yfo~H6 X.... _(__5555u&:%}6GEIEZ&dd4+@&A&A&A`d'''OO!uuu&]}&]&]Q[&]&]OLL!I=ZdosLttttttttu!% o = 040D__),_)=)=)C)C%%  #7}o"V"V  a sC]Tacqrrr# ` WmWW=WWWWXXX ^c/.B.B^^_^^___* MM// m]\kllll MMMM"K6"K"KLLLLLLLLM%, !?##&;;;"?33 #$:%:$:;K<SKK%:JKKKK * ) H OOH % % %? d'dMMMMMMMNNN;/;;<<<qrr"B..J#-#6#;L &#z,#z#z#z(2   H OOH----""q3/@/K+L+L'L'L 4?+++ 11.AA  Th T8B<+;+;F+C+Cv+M+M#B< 2L QL11fd++U0>F,-.2je.T.T.THRL++.:=TN=T=T.THRL+()4 Q Q Q*69P9P9P*P Y''' Q? T /.@ ,59Ls9R,R,R((XfR$RR)RRRSSSSS T T T T+M+M T TsC%%D4DD'H66 I!II!,J  J4J//J4AL L&%L&.i11 j+;&j&&j+0n n9n44n94Ax'x>=x>c|jr |jdkrdS||jz }|j|z }||jkrd|d|jd|dS||jkrd|d|jd|d SdS) zReturn a budget pressure string, or None if not yet needed. Two-tier system: - Caution (70%): nudge to consolidate work - Warning (90%): urgent, must respond now rNzUDGET WARNING: Iteration r.z. Only zd iteration(s) left. Provide your final response NOW. No more tool calls unless absolutely critical.]z[BUDGET: Iteration z. z1 iterations left. Start consolidating your work.])rrrr)rArprogressr{s rCrzAIAgent._get_budget_warnings, 0Cq0H0H4!D$77'.8 t5 5 5cncct?Rcc!ccc  t5 5 5PnPPt7JPPPPP trEcompaction_progressctddlm}m}|jr|j|jz nd}|jdvr.|||j||j}|||jrY ||||j}|d|d S#t$r t dd Yd SwxYwd S) uNotify the user that context is approaching the compaction threshold. Args: compaction_progress: How close to compaction (0.0–1.0, where 1.0 = fires). compressor: The ContextCompressor instance (for threshold/context info). Purely user-facing — does NOT modify the message stream. For CLI: prints a formatted line with a progress bar. For gateway: fires status_callback so the platform can send a chat message. r)format_context_pressureformat_context_pressure_gatewayr)Nr)r,rMrr?)r,rr?context_pressurez)status_callback error in context pressureTrN) agent.displayr.r/rrMrr?rrrrr)rAr,rr.r/ threshold_pctliners rC_emit_context_pressurezAIAgent._emit_context_pressure s+ [ZZZZZZZS]Slu 3j6OOOru =M ) )**$7!+!<"/$($< D   T " " "   Y Y55(;&3(,(@ $$%7===== Y Y Y HSW XXXXXX Y Y Ys )B &B54B5c d td|jdd}|d|d d|jv}g}|D]]}|}dD]}||d|r||||^|jpd } |jr| d z|jz } | r d | dg|z}|j rK| rd nd } t|j D]0\} } | | | z| 1i} d|jv}| r|j |j| d<nddd| d<|rdg| d<|jdkry||}|dd||}||\}}|r|jpd nd }n|j|d}|j-|||ji}|jr |j|d<|jr |j|d<|jr |j|d<|jr |j|d<|r|| d<| r| |d<|jdkrd dlm}m}||j|d|j|j|j| }|!|}|||j!\}}|jpd }nc|"d"#j#j$j%d.i|}|j&r/|j&d j'jr|j&d j'j}nd }|rXd$|vr4tQj)d%d |tPj*& }|r|d'|dnd(}n|jdkry||}|dd||}||\}}|r|jpd nd }n9|jdkrd dlm}m}||j|d|j|j|j| )}|!|}|||j!\}}|jpd }n|j|d}|j-|||j| r| |d<|"d*#j#j$j%d.i|}|j&r/|j&d j'jr|j&d j'j}nd }|rVd$|vr4tQj)d%d |tPj*& }|r|d'|dnd(}nd(}nH#tV$r;} tYj-d+| d,|jd-t]| }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.rrPr5)rrNrrrWrsrrrTrrr r!r(rP)rrrrrrrr"r*)rr`)rrrPrrrrraiteration_limit_summaryrr[z.*?\s*rr>z>I reached the iteration limit and couldn't generate a summary.)rrrPrrrriteration_limit_summary_retryz Failed to get summary response: z"I reached the maximum iterations (z!) but couldn't summarize. Error: r`)/rrrrrHrrWrrrrrdinsertr$rrr1rrrrrrOrr r r r rrr`rr r?rrGrHrrmrrrrrrr rL)!rArrsummary_requestrmrrrRinternal_fieldeffective_system sys_offsetr3pfmsummary_extra_bodyr0rqsummary_responserrfinal_responsesummary_kwargsr,_bak_nar_ant_kw_msgretry_response retry_msg_bak2_nar2_ant_kw2 _retry_msgrgs! rC_handle_max_iterationszAIAgent._handle_max_iterations4s bT5Hbbbccc .  ODDEEEH A.1EENL - -((**&D66NKK5555!F<N O OPS__ $ F"29QQ )$*? @ @FFHC '' S(8#((**EEEE!# %)==H2244 (46:6K&{33$("*77&{3 F.D-E"6*} 111#55lCC   $///#'#9#9,#G#G '+'E'EFV'W'W$!1N_!g"3";"Ar!H!H!J!J!Jeg"Z ,""?."))$*@*@*Q*QRRR(*$)J373I(0)L595K(2'I484H(1%F373E(0'J5I&z2%F3EN<0=$888||||||||"dlRV.2oPTPe,0,D151N1N1P1PRRRG(,'F'Fw'O'O$"d#3tG_```GD!&*l&8b%?%?%A%ANN(Dt'I'IQj'I'k'k'p'|(D(V(VGU(V(V$'/,4D4LQ4O4W4_,)9)A!)D)L)T)+1 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#'#A#A.#Q#QLIqJS%[i&7&=2%D%D%F%F%FY[NN]&:::~~~~~~~~$u4: TX-1-E/3QUQf262O2O2Q2Q S S SH&*%D%DX%N%NN$)E.DLd$e$e$eMJ&0&8&>B%E%E%G%GNN"&$0&&N2&--d.D.DT_.U.UVVV)J7I|4(Jt'I'IQp'I'q'q'v(C(J(\(\M[(\(\$'/,4D4LQ4O4W4_,)9)A!)D)L)T)+!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 AsV3W(( X-21X((X-stream_callbackpersist_user_messagec•ɇʇˇ̗tt|trt |}t|trt |}|_d_|_|pttj }d_ d_ d_ d_ d_d_d_d_jdkr; rdn#t*$rYnwxYwt-j_|rt3|ng}|rt5||r.js|xjdz c_||n|} d} jdkr9dj vr0j!r)xj"dz c_"j"jkr d} d_"d |d } |#| tI|dz } | _j%s8&d |dd tI|d krd nddj'=d} |rQj(rJ j()j*}|r|+dpd} n#t*$rYnwxYw| r| _'nމ,|_' ddl-m.}|dj*j/taddpdn2#t*$r%}tb2d|Yd}~nd}~wwxYwj(rY j(3j*j'n2#t*$r%}tb4d|Yd}~nd}~wwxYwj'}j5rFtI|j6j7j6j8zdzkrts||pdj:pd}|j6j;krtb<d|dj6j;dj/j6j=dj%s(&d|ddj6j;ddt}dD]q}tI|}?||||\}}tI||krn0d}ts||pdj:pd}|j6j;krnrd} ddl-m.}|dj*| t3|t| j/taddpd }g}|D]}t|tr>|+d!r)|#t|d!Ut|tr)|Br|#||rd"C|}n2#t*$r%}tb2d#|Yd}~nd}~wwxYwd}d}d}d}d}d}d} Dd}!jErG t|tr|nd}"jEF|"pd}!n#t*$rYnwxYw|jk@rjjGdk@r~jHIjJr d}j%s&d$@n>|dz }jKs9j%s0&d%jjLd&jjMd'?njN g}#t|D]D}$|$+d(d)kr)|$+d*rd+|$d*D}#nEN||#n3#t*$r&}%tb4d,||%Yd}%~%nd}%~%wwxYwjPdkrd-j vrxjQdz c_Qg}&t|D] \}'}(|(S})|'| krQ|(+d(d kr8|!r6|)+d.d}*t|*tr |*d"z|!z|)d.<|(+d(d)kr|(+d/}+|+r|+|)d0<d/|)vr|)Td/d1|)vr|)Td1d2jUvrV|)|&#|) |pd},jWr|,d"zjWzB},|r|,d"z|zB},|,r d3|,d g|&z}&jXrK|,rdnd}-tjXD]0\}'}.|&Y|-|'z|.S1jZr t|&j\jdk4}&]|&}&td5|&D}/|/d6z}0d̉j%s_d7j`d8|d&jd _j`d9tI|&d:|0dd;|/dd<_j`d=j:rtIj:ndntjbtjd}1tjbtje}2jfrf|1d>|2d n[gsGtjbgd?}3t|1d>|2d |3jh@̠̉ijjrtj4dAj/dBtI|dCj:rtIj:ndtj4dD|r|dEd(ndFtj4dG|0ddHtjl}4d}5d}6d}7d}8d}9d}:d};d}dI}?d}@|5|6k"r m|&}AjdJkrn|AdK}AtdLrp|AdMNfdO}Bd}Cgs'ddPlqmr}DttadQd|Drd}C|Crs|A|BR}@nt|A}@tjl|4z }Er̠udd̉jfrfdj%s!_j`dS|EdTdUjjrF|@rta|@dVdWndW}Ftj4dX|FdYt|@dZr|@jwndWd}Gg}HjdJkr|@ta|@d[dnd}I|@d}G|H#d\nt|It2sd}G|H#d]natI|Idkrd}G|H#d^n5jdkr|@ta|@d.dnd}J|@d}G|H#d\nt|Jt2sd}G|H#d_ntI|Jdkrd}G|H#d`n|@/t|@dar|@jxtI|@jxdkrrd}G|@|H#d\nXt|@das|H#dbn2|@jx|H#dcn|H#dd|Grr̠uded̉jfrfd|5dz }5jytIjzkrdf{rd}5dgdg}K|@rmt|@dhr]|@j|rVt|@j|t|@j|dir,|@j|j}r |@j|j}+djdg}Kn-|@r+t|@dkr|@j~rt|@j~|Kdgkr#|@r!t|@dVr|@j/r dl|@j/}K|KdgkrK|@rIdmt|@D}Ljjrtj4dn|L_j`do|5d&|6dpdqC|Hdr_j`ds|Kdrʦ}M_j`dt|Mdr_j`du|EdTdvdr|5|6krdw|6dx{rd}5dy|6dztj|j`d{|6d||||d|d}dd~Stdd|5dz zzd}N_j`d|Nddrtj2d|5d&|6dpdqC|Hd|Ktjl|Nz}Otjl|OkrjJrX_j`ddr||Dd|5d&|6d||dddStjdtjl|OkojdJkrpta|@dd}Pta|@dd}Qd}Rt|Qtr|Q+d}Rnta|Qdd}R|Pdkr|Rdvrd}?nCdI}?n@jdkr#dId*ddId}S|S+|@jdI}?n|@jxdj}?|?dkr1_j`ddrd}TjdkrAt|@dar|@jxr|@jxdj~nd}U|Urta|Ud.dnd}Tnsjdkrhg}Vta|@d.gD];}Wta|Wdddkr$|V#ta|Wdd<|Vrd7C|Vnd}T|Tduo|T p|Tdu}X|XrWd}Y_j`ddrd}Z||||Z||dd|YdSjdkr|@jxdj~}[|[js|dz }|[|?}\|#|\|[jr ||[jz }|dkrZ_j`d|dd dd }]|#|]|_|d}>nS|B}^||||^pd||ddddStI|dkrf_j`d|}_|||d|_|ddddS_j`ddr||d||ddddSt|@dZr|@jwrt!|@jwjj}`|`j}a|`j}b|`j}c|a|b|cd}dj6|dj6jr~j6j=}etaj6ddrDt/j/j|e&j`d|eddj/dj6_dj6_xj|az c_xj|bz c_xj|cz c_xjdz c_xj|`jz c_xj|`jz c_xj|`jz c_xj|`jz c_xj|`jz c_tOj/|`jjtadd}f|fj#xjtU|fjz c_|fj_|fj_j(rj*r j(j*|`j|`j|`j|`j|`j|fjtU|fjnd|fj|fjjj|fjdkrdndj/ n#t*$rYnwxYwjjr2tj4d|dddd|dddd|dddjZr̉jdkr1ta|@jwddpd}gta|@jwddpd}hnDta|@jwdd}i|irta|iddpdnd}g|irta|iddpdnd}h|dd}j|jdkr|g|jz dznd}kj%s-_j`d|gdd&|jdd|kdd|hdd d}<np#t`$rr̠udd̉jfrfdtjl|4z }l_j`ddr||d}d|ldd}Ynt*$r}mr̠ud¦d̉jfrfdt|mtbrMtadds|ndkr8|;s6d};drrtmj`d˝Yd}m~mJjdkr|ndkrtd̦r|:sd}:ddlm}prtmj`dΝYd}m~mj}q|p|qrdnd}rtmj`dѝtmj`d|rtm|qr(tI|qdkrj`d|qddӅd n j`d՝tmj`d֝ddlm}s|s}ttmj`d|tdٝtmj`d|td۝tmj`dܝtmj`dݝtmj`dޝtmj`dߝ|5dz }5tjl|4z }ut{|mj}vt|mʉ|m}wtb2d|5|6|v|wtadd}xtadd}*tadVd}y|nrd|ndnd}z_j`d|5d&|6dp|v|zdr_j`d|xd|ydr_j`d|*dr_j`d|wdr|nrU|ndkrOta|mdd}{|{rt|{ddnd}|||r!_j`d||dr_j`d|udTdtI|&d|0ddHjJr}_j`ddr||Dd|vdt|md||dddcYd}m~mSta|mdd}n|ndkpdvpdvp dvpdvpdv}}|}rojytIjzkrRj}~|~duo|~}|s1d{rd}5Yd}m~m|ndkp dvpdvpdv}|r| dz } | |8kr_j`d|8ddr_j`ddrtj|j`d|8d|||d|d|8dddcYd}m~mSd| d&|8d tI|}?|||0|\}}tI||krHd |d tI|d tjdd}=Yd}m~m nM_j`d dr_j`ddrtj|j`d |||d|dddcYd}m~mStfddD}|s|ndkrtatadddd}|0|dzkptI|&dk}tIʠBdk}|r:|r8d}_j`d|0ddtI|&ddr|rj6}|j=}tʦ}|r3||kr-|}_j`d|dd|dddrnt|}|ru||kro||_=t||jz|_;d|_t|o||k|__j`d|dd |ddHdrn _j`ddr| dz } | |8kr_j`d|8ddr_j`ddrtj|j`d |8d|||d|d!|8dddcYd}m~mS_j`d"| d&|8d tI|}?|||0|\}}tI||ks|ra||kr[tI||kr,d |d tI|d tjdd}=Yd}m~mn_j`d#dr_j`d$drtj|j`d%|0dd&|||d|d'|0dd(ddcYd}m~mShd)}t|mttfot|mtb }ta|mddpi}{t|{tr*|{+dhi+dkdnd}|ndko(|Bd*v}t|ntod|ncxkodknco|n|vo| }|s |stfd+d,Do| }|r*d-|nd.{rd}5Yd}m~mԉp|Ad/|m0_j`d1|nd2dr_j`d|xd|ydr_j`d|*dr|nd3vsd4vs d5vsd6vr_j`d7dr_j`d8dr_j`d9|yd:drd;t|*vr _j`d<drn _j`d=drtj|j`d>|m|ndkr<|0d?kstI|&dkr!_j`d@drn||d||ddt|mdcYd}m~mS|5|6kr|7s#|m|5|6Ar d}7d}5Yd}m~mdw|6dB{rd}5Yd}m~m)|m}|}r%_j`dC|6dDdrn#_j`dy|6dEdr_j`dF|drta|mdd otfdGdHD}|r@_j`dIdr_j`dJdrtj|dKj`|6||x|ytI|&|0dp|AdL|m0||dM|6dN|}|r|dOz }|||dd|dcYd}m~mSd}|}rtata|mdPddQd}|ryt|dRrh|+dSp|+dT}|r: tt|d}n#ttf$rYnwxYw|r|ntd|5zd }N|}r&dU|NdV|5dzd&|6dWn!d|NdX|5d&|6dWtb2dY|N|5|6|mtjl|Nz}Otjl|OkrjJr^_j`ddr||DdZ|5d&|6d||dddcYd}m~mStjdtjl|OkYd}m~mnd}m~mwwxYw|5|6k"|rnC|=r'|dz}j|5dz }5d}=(|>r(|@1tmj`d[||n jdJkr|@\}[}?n;jdkrdd\lm}||@j]\}[}?n|@jxdj~}[|[jt|[jtss|[j}t|trH|+ddp*|+d.dptj||[_nt|t2rg}|D]}t|tr|#|-t|trC|+ddkr*|#|+ddt|tr,d|vr(|#t|dd7C||[_nt||[_|[jr}j%svjjr&_j`d^|[jnI_j`d^|[jddtI|[jdkrd nd|[jrjrtad_ddkr|[jB}tjd`d|B}|r$|d7dddnd}|r) da|n#t*$rYnwxYwt|[jpdrtdbsd_ xj dz c_ _j`dcj dkr)_j`ddj de,}_j`dfdrd_ |}_|||d|_|dddgdStdbrd_ jdJkr|?dkrtdhsd_xjdz c_|[|?}\t|\+d.pdB}t|\+d/tr5t|\+d/dBnd}t|\+di}|s|s|r|r|dEnd}t|tr|+dind}|\+di}t|to|+d(d)ko~|+d1dkoe|+d.pd|\+d.pdko5|+d/pd|\+d/pdko||k}|s|#|\jdkrLj%s'_j`djjdk|_|/d_||d||dddldStdhrd_|[jr^j%s4_j`dmtI|[jdnjjrD|[jD]:d}|r ||z}d}d}|B}|[|?}|#|j%s&d|dn#t*$r}d|dt| tmdʛn3#ttf$rtb|ʦYnwxYwjjrtjdd}t}tI|dz dEdED]}'||'}(t|(tsn|(+d(d}kr<|(+d(d)kr|(+d*rpd||'dzdD}|(d*D]Mˉrttsːd|vr(d}ːddʛd~}|#|ĦNd}|jdz kr#dʛ}|#d)|d Yd}~n)Yd}~nd}~wwxYw|jkrjjGdk@~|s|jksjjGdkrXjjGdkr2j%s+tmd%jjLd&jjMd'||}|duo |jk}ʼn|||Ŧ||||ry|sw ddl-m.}|dj*| |t3|j/taddpdn3#t*$r&}tb2d|Yd}~nd}~wwxYwd}t|D]:}(|(+d(d)kr|(+d/r |(d/}n;id|d|Ɠd|d|d|œddd|dtadddVj/djdjdjdjdjdjd‰jdjjjtaj6ddpdjjjdĜ}d_|rjr j|ǐd<Dd_d}ȉjPdkr"jQjPkrd-j vr d}d_QjErK|rI|rG jE||jE|n#t*$rYnwxYw|r>|s<| s|r8 t3|| |ȐƦn#t*$rYnwxYw ddl-m.}|dljj*||j/taddpdȦn3#t*$r&}tb2d|Yd}~nd}~wwxYw|S(a[ Run a complete conversation with tool calling until completion. Args: user_message (str): The user's message/question system_message (str): Custom system message (optional, overrides ephemeral_system_prompt if provided) conversation_history (List[Dict]): Previous conversation messages (optional) task_id (str): Unique identifier for this task to isolate VMs between concurrent tasks (optional, auto-generated if not provided) stream_callback: Optional callback invoked with each text delta during streaming. Used by the TTS pipeline to start audio generation before the full response. When None (default), API calls use the standard non-streaming path. persist_user_message: Optional clean user message to store in transcripts/history when user_message contains API-only synthetic prefixes. or queuing follow-up prefetch work. Returns: Dict: Complete conversation result with final response and message history NrFr*u~🔌 Detected stale connections from a previous provider issue — cleaned up automatically. Proceeding with fresh connection.rsrTrrPu💬 Starting conversation: 'rrZrrr) invoke_hookon_session_startr)rrrz on_session_start hook failed: %sz*Session DB update_system_prompt failed: %s)rrPzDPreflight compression: ~%s tokens >= %s threshold (model %s, ctx %s)rmu📦 Preflight compression: ~z tokens >= z thresholdrry pre_llm_call)rrr is_first_turnrrrrzpre_llm_call hook failed: %su2 ⚡ Breaking out of tool loop due to interrupt...u% ⚠️ Iteration budget exhausted (r.z iterations used)rr>rcTg|]%}t|t|dd&Sr)rKrrs rCrz,AIAgent.run_conversation..sA***$&#-b$#7#7* ":v 6***rEz&step_callback error (iteration %s): %srrrrrr5rW) cache_ttlnative_anthropicc3NK|] }tt|V!dSrPrrs rCrz+AIAgent.run_conversation.._s.DDc#c((mmDDDDDDrErrZu🔄 Making API call #u 📊 Request size: z messages, ~z tokens (~z chars)u 🔧 Available tools: r')brainsparklepulsemoonstarrzAPI Request - Model: z , Messages: z , Tools: zLast message role: rFrrzTotal message size: ~z tokensrr(rjHERMES_DUMP_REQUESTS preflightrcvrddjrddSdSr)rr)rAthinking_spinnersrC _stop_spinnerz/AIAgent.run_conversation.._stop_spinnersT+4,11"555/3,17 2226666677rErrr[u⏱️ API call completed in rrrzN/AzAPI Response received - Model: z , Usage: rirUzresponse is Nonezresponse.output is not a listzresponse.output is emptyzresponse.content is not a listzresponse.content is emptyrmz#response has no 'choices' attributezresponse.choices is Nonezresponse.choices is emptyu(´;ω;`) oops, retrying...u<⚠️ Empty/malformed response — switching to fallback...UnknownrometadatarRrzmodel=cni|]2\}}|d|t|dd3S)rNr)r_rLrs rCrz,AIAgent.run_conversation..sA)v)v)vdadedpdpqtdudu)v!SVVDSD\)v)v)vrEz*Response attributes for invalid response: u&⚠️ Invalid API response (attempt z): r~ru 🏢 Provider: u 📝 Provider message: u ⏱️ Response time: z/s (fast response often indicates rate limiting)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.zOInvalid API response shape. Likely rate limited or malformed provider response.)rrU api_callsrorrCxu⏳ Retrying in z/s (extended backoff for possible rate limit)...zInvalid API response (retry z | Provider: u3⚡ Interrupt detected during retry wait, aborting.zAOperation interrupted: retrying API call after rate limit (retry rc)r@rrerU interruptedrrincomplete_detailsrpr>rrvr)end_turnrr stop_sequenceuQ⚠️ Response truncated (finish_reason='length') - model hit max output tokensr)rrzModel 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` → Increase the output token limit: set `model.max_tokens` in config.yaml)r@rrerUpartialrou↻ 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 attemptsu3 ⏪ Rolling back to last complete assistant turnz-Response truncated due to output length limitu-❌ First response truncated - cannot recoverz3First response truncated due to output length limit)r@rrerUrro)rr) prompt_tokenscompletion_tokens total_tokensru💾 Cached context length: z tokens for r)rrrincludedsubscription_included) input_tokens output_tokenscache_read_tokenscache_write_tokensreasoning_tokensestimated_cost_usd cost_status cost_sourcebilling_providerbilling_base_url billing_moderzToken usage: prompt=rmz , completion=rnz, total=rocache_read_input_tokenscache_creation_input_tokensprompt_tokens_details cached_tokensruru 💾 Cache: z tokens (z.0fz% hit, z written)u ⚡ Interrupted during API call.z3Operation interrupted: waiting for model response (rz s elapsed).u(╥_╥) error, retrying..._surrogate_sanitizeduH⚠️ Stripped invalid surrogate characters from messages. Retrying...rr)rrr4r+r8u8🔐 Codex auth refreshed after 401. Retrying request...ru<🔐 Nous agent key refreshed after 401. Retrying request...rrWuC🔐 Anthropic credentials refreshed after 401. Retrying request...zBearer (OAuth/setup-token)zx-api-key (API key)u-🔐 Anthropic 401 — authentication failed.z Auth method: rYz Token prefix: z Token: (empty or short)z Troubleshooting:)display_hermes_homeu" • 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 valuesuL • For API keys: verify at https://console.anthropic.com/settings/keysuD • For Claude Code: run 'claude /login' to refresh, then retryu? • Clear stale keys: hermes config set ANTHROPIC_TOKEN ""u? • Legacy cleanup: hermes config set ANTHROPIC_API_KEY ""z;API call failed (attempt %s/%s) error_type=%s %s summary=%srrrz [HTTP ru!⚠️ API call failed (attempt u 🔌 Provider: z Model: u 🌐 Endpoint: u 📝 Error: rursrtu 📋 Details: u ⏱️ Elapsed: z s Context: z msgs, ~u?⚡ Interrupt detected during error handling, aborting retries.z+Operation interrupted: handling API error (r r7z rate limitztoo many requests rate_limitz usage limitquotau9⚠️ Rate limited — switching to fallback provider...request entity too largezpayload too largezerror code: 413u❌ 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.)rrUrerorlu@⚠️ Request payload too large (413) — compression attempt u🗜️ Compressed rzz 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.c3 K|]}|vV dSrPr`rrrs rCrz+AIAgent.run_conversation..s822&&I2E222222rE) zcontext lengthz context sizezmaximum contextz token limitztoo many tokenszreduce the lengthzexceeds the limitzcontext windowrzprompt is too longzprompt exceeds max lengthir>ri@ rrru)⚠️ Generic 400 with large session (~z tokens, u1 msgs) — treating as probable context overflow.u)⚠️ Context limit detected from API: z tokens (was ryu3⚠️ Context length exceeded — stepping down: uM⚠️ Context length exceeded at minimum tier — attempting compression...z!Context compression failed after z3Context length exceeded: max compression attempts (u( 🗜️ Context compression attempt 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.>rr7)rorc3 K|]}|vV dSrPr`rs rCrz+AIAgent.run_conversation..sGbb{AbhlububbbbbbrE) zerror code: 401zerror code: 403zerror code: 404zerror code: 422zis not a valid modelz invalid modelzmodel not foundzinvalid api keyinvalid_api_keyauthentication unauthorized forbiddenz not foundu!⚠️ Non-retryable error (HTTP u) — trying fallback...non_retryable_client_error)rprou%❌ Non-retryable client error (HTTP z ). Aborting.)r8irr permissionu9 💡 Your API key was rejected by the provider. Check:u- • Is the key valid? Run: hermes setupu+ • Does your account have access to r6r0u? • Check credits: https://openrouter.ai/settings/creditsu6 💡 This type of error won't be fixed by retrying.zNon-retryable client error: ruU⚠️ Skipping session persistence for large failed session to prevent growth loop.)rru") exhausted — trying fallback...u❌ Rate limit persisted after z! retries. Please try again later.z) exceeded. Giving up.u 💀 Final error: c3 K|]}|vV dSrPr`)rrrs rCrz+AIAgent.run_conversation..s7$$qAN$$$$$$rE)rrrrrru 💡 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 z retries: 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.rrcrz retry-afterz Retry-Afteru#⏱️ Rate limit reached. Waiting zs before retry (attempt z)...z s (attempt z4Retrying API call in %ss (attempt %s/%s) %s error=%sz _thinking_incomplete_scratchpad_retriesuL⚠️ 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 retries_codex_incomplete_retriesr?u0↻ Codex response incomplete; continuing turn (z/3)z@Codex response remained incomplete after 3 continuation attemptsu🔧 Processing z tool call(s)...z Tool call: z with args: ru🔧 Auto-repaired tool name: 'z' -> 'cNg|]!}|jjjv|jj"Sr`)rrYr )rrrAs rCrz,AIAgent.run_conversation..s;***-/;+43HHH (HHHrE_invalid_tool_retriesu⚠️ 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.r)rr=rru1⚠️ Invalid JSON in tool call arguments for 'ru;⚠️ Injecting recovery tool results for invalid JSON...ch|]\}}|Sr`r`)rrYrs rCr}z+AIAgent.run_conversation..Ps,S,S,SgdAT,S,S,SrEc3BK|]\}}|jjk|VdSrPr)rr!rgrs rCrz+AIAgent.run_conversation..Ss9.h.hTQRSWYWbWgRgRgqRgRgRgRg.h.hrEzError: 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.>rrrrc34K|]}|jjvVdSrPr)rr_HOUSEKEEPING_TOOLSs rCrz+AIAgent.run_conversation..~sB00 "K,0CC000000rEu ┊ 💬 c&h|]}|jjSr`rrs rCr}z+AIAgent.run_conversation..s Y Y Yb!1 Y Y YrE execute_coder}_last_content_with_toolsuOEmpty follow-up after tool calls — using prior turn content as final responserrYz Calling the z tool_empty_content_retries)rrrrruC⚠️ Response only contains think block with no content after itz Reasoning: z Content: 'ru 💡 Local/custom backend returned reasoning-only output with no visible content. This often means the resumed/large session exceeds the runtime context window. Try /new or lower model.context_length to the actual runtime limit.ub🗜️ Reasoning-only response looks like implicit context pressure — attempting compression (z4 messages after reasoning-only response, retrying...zQ Compression could not shrink the session; falling back to retry/salvage logic.rru`ℹ️ Structured reasoning-only response repeated unchanged — using reasoning text directly.rDu/❌ Max retries (3) for empty content exceeded.zRUsing reasoning as response content (model wrapped entire response in think tags).zIModel generated only think blocks with no actual response after 3 retriesrzLocal/custom backend returned reasoning-only output with no visible response after 3 retries. Likely causes: wrong /v1 endpoint, runtime context window smaller than Hermes expects, or a resumed/large session exceeding the backend's actual context limit.)rrrzr[System: Continue now. Execute the required tool calls and only send your final answer after completing the task.]u"🎉 Conversation completed after z OpenAI-compatible API call(s)z)Error during OpenAI-compatible API call #u❌ zDetailed error information:czh|]8}t|tr!|ddk0|d9Srru)rrys rCr}z+AIAgent.run_conversation.. sP((( !)!T22(89uuV}}7N7Nn-7N7N7NrErzError executing tool: z0I apologize, but I encountered repeated errors: post_llm_call)rrassistant_responserrrzpost_llm_call hook failed: %sr@last_reasoningrrerUrlrhresponse_previewed_response_was_previewedrrrsrtrvr)rnrorrwrxryinterrupt_message)rrrr)rrUrhrrzon_session_end hook failed: %s)rirrKrLrrrrrrr_invalid_json_retriesrrrrrrrrrrrkrr rrr" has_itemsrr@r'r r$r)rrMrrrr get_sessionrrrhermes_cli.pluginsrPrrXrr rrr?r>rrr!rPrMrrrGrr~rrr rr- prefetch_allr{rnew_turnrrtrxrlrrr;r*rdrHrrrWrrr8rr'rrrrrrrr1KAWAII_THINKINGTHINKING_VERBSrrrrrrror1rr:rrrrrSrrrirmrrrrorcrvarsrrr9rr stop_reasonrrr rrQrrr7rrKr0rrmrsroupdate_from_responserr$rrrArBrCrDrErrrFrGrtrHrurIrvr/ amount_usdrJr=rrKrrLupdate_token_countsrRUnicodeEncodeErrorrr=rr%rrrXr(rr6rrr[rr~rr has_availablerr#r"r}rrJrrrvrr`rrrrrrrr7rrYrr'rrrrnextrr frozensetallrrrrrrr4rrr rrrI exceptionrLrnrsync_allqueue_prefetch_allr1)rArrrr rMrNrroriginal_user_message_should_review_memoryuser_msgcurrent_turn_user_idx stored_prompt session_row _invoke_hookrrgactive_system_prompt_preflight_tokens_pass _orig_len_plugin_turn_context _pre_results _ctx_partsrrr@rhcodex_ack_continuationslength_continue_retriestruncated_response_prefixcompression_attempts_ext_prefetch_cache_query prev_tools_m _step_errrr3rrR_baserr;r<r= total_charsrr verbrapi_start_timerrprimary_recovery_attemptedmax_compression_attemptscodex_auth_retry_attemptedanthropic_auth_retry_attemptednous_auth_retry_attemptedr4 restart_with_compressed_messages restart_with_length_continuationrrrra_use_streamingr api_duration resp_modelresponse_invalid error_details output_itemscontent_blocksrR resp_attrscleaned_provider_errorr sleep_endrriincomplete_reasonstop_reason_map_trunc_content _trunc_msg _text_parts_blk_thinking_exhausted_exhaust_error_exhaust_responser interim_msg continue_msgpartial_responserolled_back_messagescanonical_usagermrnro usage_dictctx cost_resultrwrittendetailsr+hit_pct api_elapsedrrrrecovered_with_poolrXr auth_method_dhh_fn_dhh elapsed_timer_error_summary _provider_model_status_code_str _err_body _err_body_stris_rate_limitedrpool_may_recoveris_payload_too_largeris_context_length_errorrris_generic_errorrold_ctx parsed_limitnew_ctx_RETRYABLE_STATUS_CODESis_local_validation_error _err_message_is_generic_400is_client_status_erroris_client_error_final_summary_is_stream_drop_final_response _retry_after _resp_headers_ra_rawr`rxrr _think_text first_lineinterim_has_contentinterim_has_reasoninginterim_has_codex_reasoninglast_msglast_codex_itemsinterim_codex_itemsduplicate_interimrepairedinvalid_tool_callsr invalid_nameinvalid_previewrtrinvalid_json_argsrrrecovery_assistant invalid_nameserr tool_result turn_content_all_housekeepingclean _tc_names _compressor _real_tokens_compaction_progressfallbackrJrrempty_response_inforeasoning_previewcontent_preview empty_msg error_message final_msgpending_handled answered_idserr_msgrUrrK_should_review_skillsrrrr`s` @@@@rCr"zAIAgent.run_conversationsf<  %%''' lC ( ( >/ ==L *C 0 0 N#78L#M#M !0)-&.B+#8s4:<<'8'8&'"%&"&'#./+)*&(,%#( $)! =0 0 0 1133%%&      !00C D D2FM4,---2  : / 9 9 9  ;(8(B(B(D(D ;  $ $%9 : : : "9M8X 4 4^j !&  '! + + 555&6  $ $ ) $ $'4+FFF(,%+,(#|<<!!! #H  1)>& |   z\#2#=NzY\]iYjYjmoYoYoPUPUuwzzz { { {  % - 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  $1 H  7 G"&"9"H!IKL!MMM !>28bj(D!!!  !D$;$LLL Z(,,.?CCJ.=AA $$U8IUUU"5FTUUU #1XXE #H I595K5K .@Q 16L662H28}} 11 ,0((E &:&@b"j0D)))% )4+B+SSST " @ F F F F F F'<?2%)(^^#'(<#=#==j z488>BLJ! ) )a&&)155+;+;)%%c!I,&7&788883'')AGGII)%%a((( ?'-{{:'>'>$ @ @ @ NN93 ? ? ? ? ? ? ? ? @ "#"#$&!   !    )3L#)F)FNB&*&:&G&G&O&O&USU##    t222t7L7VYZ7Z7Z  ) ) + + +( " \$$%Z[[[ a N(0022 _$$&^dNcNh&^&^kolAlK&^&^&^___!- f!#J&x00""66&>>[88RVVL=Q=Q8***,\*:***J "E&&~zBBBB fffLL!I>[deeeeeeeef *Q..&$*???''1,''L%h// - -S((**///CGGFOOv4M4MRe4M#KK 266E!%--R-2V^>Q-Q *776??k11%(WW[%9%9N%F7E 34'))KK ,,,"g--KK000 $t';;;<N O OPS__ $ F"29QQ )$*? @ @FFHC '' S(8#((**EEEE ' `<\UYUdx|yFJ^y^ ` ` `  66|DDLDD|DDDDDK'1,M $ ? - r$/rrrrZ^Zmrrrsss XXs+>T+>+>+>????3355-$*=1^1^1^#_#_L'45H5Ht5H5H5HWcnrn|'}'}'}$$**,,,# P MdjMMcRZmmMMy}zDgKfijnjtfufufuJKMMNNN bH4`HRL4H4HZ`bbccc NmNNNNOOO!Y[[NKK). &'( $', &+0 *&+ %#O/4 ,/4 ,"MH ++p(!%!7!7 !E!EJ}(999%)%E%Ej_d%E%e%e &'=>>U44Z 4TTT777777&*N55773766666%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}(999LTL`wx4'H'H'Hfj #+/3,)001CDDDD!+L$!?!?M/3,)001PQQQQ ..!33/3,)001KLLL*>>>OWOc9d)K)K)Kim#+/3,)001CDDDD!+ND!A!AN/3,)001QRRRR 00A55/3,)001LMMM#+78Y3O3O+S[ScSkors{tDpEpEIJpJpJ/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'U!+4,112OPPP/3,17 222666$q(  /#d6J2K2KKK --.lmmm6688%*+K$%. (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 &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 &U&US_&U&U&U&U]a bbb&+55 --/A[/A/A/ABBB#::<<)./ ( --.{+.{.{.{|||#MT_*o*oYd*o*o*oppp 11(>>7=>>IPQY[dIeIe*Fjrjz*F)9!)<)D)DBFJU_-iWZD-Q-Q-QeiNN!].BBB*,K(/)R(H(HRR#*4#>#>&#H#H$/$6$6wtVR7P7P$Q$Q$QGR-\TYY{-C-C-CX\N+$6X$($G$G$W$W W/4,t3, / !9+ !LL#'?!E!E!E&*)!H.!889JKKK 11(>>080@0C0K-#4#?$" 71 < 7.2.K.KL]_l.m.m ( < < <#4#<![$=ARAZ$Z$=#:Q#>#>$(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 ("("!"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&9 J+%)]%)]$+D)R$@$@ ''' '1= ;;u[E[?\?\\;;3>3E03>3E0 +%%% $ 0 D D$(O1@1M2A2O6E6W7F7Y5D5U'2'='I8=[=S7T7T7TOS0;0B0;0B59]59]'2'9Z'G'G2I1HMQ*.*!E!"!"!"!""$-%%% $% /x#M+wOA\+w+w+wmwyLnM+w+w+wYcdrYs+w+w+wxxx 3 X#}0DDD)0AZ\])^)^)cbc*1(.B_ab*c*c*hgh+2(.BY[_*`*`V])d/1)M)M)RQRcd\c*j'';OQR*S*S*XWXij%/%@FAG!v'<'KLLDO!U!U!U]aLbbb))(4HIII"&K%w[f%w%w%w%wNE r(r(r('0(--.LMMM+/(-3..r222")-?@@%QUWmotIuIu%4818BB% LL#'? | | |&*)%HHHH#*)]D"I"IK;?;];]$/(7<^<<8'+!  )::: M^;;'3.. :/6:2EEDEQQ% LLDO)u)u)uvvv$HHHH );;; MV33'3.. 9/591DD4DPP%!T_"r"r"rsss$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~~~vvvwwwssstttsssttt1$K#'9;;#?L!%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(<(d:e:eJ79=J6 EI , H1HEEJA!LLDO*S*Spw*S*S*SAH*S*S*S*S[_L```` LLDO*K*K*KSWLXXX,1,/2JJJ LLDO))[s)))HLLMMM LLDO*P*P*PX\L]]]#MT_+D+D_w+D+D+DEEE 11(oo+"9z9.EFFJ *96H I II.!( 64 @ @ FBIU_`ikoUpUp$xIMM'2$>$>$B$B9b$Q$Q$QvxL'2c'9'kl>P>P>R>R>X>X>Z>Z^k>kO-7 S-I-I.ncU`NfNfNfNfcfNfNfNfNf.nkvVlV.n_n[n*'@(DZ(^abbbbEbbb__'8 !87 $'+))*sk*s*s*sttt6688%*+K$HHHH44&/KS\5 %w%w^i%w%w%w@D EEE %g%g9%g%g_e%g%gos ttt %R%R5%R%RZ^ ___&*44)8S8SWbfoWoWosDMtMtM LLDO)v)v)vCLDDD LLDO)j)j)jrvLwww LLDO)q)qhn)q)q)qy}L~~~+s5zz/?/?/A/AAA $ .A.A.AIM !N!N!N 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%*+K$HHHH)-)B)B9)M)M* LLDO*K*K\g*K*K*KSWLXXXX LLDO)q)qk)q)q)qy}L~~~ %^%^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< [ #a;FVXZB[B[I&t))+WPY+W+Ws~BCtC+W+WFQ+W+W+WXXXX))*rY*r*rS^*r*ral*r*r*rsssNNN!##0022! !% i 7I)++ 114  LLDO)p)p)px|L}}} 11(-F-L"MM"4)IJJ@>?;771<77LLDO"B"B"BCCC:a?? %|%|QUQt%|%|%|}}}  %z%z%zCG HHH>?;/3/V/VW_/`/`,445FGGG--h8LMMM/3(<)7).'+%V   4!ABB<:;D7=$555-<:W:W"4)DEE;9:622a722"&"?"?@QS`"a"aK*.  0J0J0Pb/W/W/Y/Y*Z*Z'^hitixixzEjFjFHK_L_L-WDb1Q1Q1W1W1Y1Y,Z,Z,ZRW)26{G^7_7_2`2`/*9.C9Gb93;#E8B<< U__gimTnTn+x8<<8O+P+P+Ptx(.9oo>U.V.V+&x66H ( V 4 4 CH ( _ = = MH"*i!8!8!>BKOOT]D^D^Ddbd eH"*k!:!:!@bkooVaFbFbFhfh i H !14G G * 19$OOK888599#R LLDO*Q*QmqnL*Q*Q*QRRR19...x888 56D2))(4HIII*.$,%3%*#'!c T#>??756D2%/?~ %|%|M^MiIjIj%|%|%|}}}+x"3">xxB#M*v 8H*v*vVXVaVklpmplpVq*v*v*vwwww0:<<;+43HHH'+'='=bk>N'O'OH'< %&|&|Y[YdYi&|&|qy&|&|&| } } }3; 0****3D3O***&*%!&t-DEE;9:D622a722%)IIfT5J.K.K$L$L '9!'< GJ  B!{/t7LLL*s2;3C*s*shq*s*s+G$OO(.02+2-- !t%<==7562)+%/:QQ!{4%dT4L99%48Jt4D4DBK1$+JtS4I4I+47IIBK1#%;#8D#%4::<<%48BK1$Q Jt,,,,#3QQQ-44bk6FA5OPPPPPPPPQ)&%22a722/@/C, 9 &D&Djs&D&DyB&D&DEEE599 LLDO)w)wUYUo)w)w)wxxx$!LLDO)x)x)xyyy9:D6261N1NO`bo1p1p.$OO,>???-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--)-D1K1K1M1MD7;D44!_D$($<$<\$J$J$P$P$R$RE$D $ -B5-B-B C C COOM2221!! 66t<<<<(!!! D!,,->J[]klll04D, !Z YZ/Z,/477@]7<@D9 778LkZZZ/ 4K4O4OP\4]4] 49=9O9O$n*.*A*T$5:P::6"604,.6D***8444&7%>%D"N >>~NN] $+41KT#R#R#""LL)z{{{<@D9:;D7%*3x==1+*>$'x==<#?#?;?$8$($5$57cL7c7c_bck_l_l7c7c7c%d%d%d$(JqMMM$2a$7N$($9$@$@$B$B$B$/1$4K$, $ .S.S.S!T!T!T+" 34H I"!44N O" !LLDO*^*^*^fjLkkk:;D7-;N(3+9-;1> ))I %OOI666!6:: LLDO)x)xUYUp)x)x)xyyy$ LLDO)l)l)ltxLyyy:;D7 (/t5OQU'V'VH'&@D =).s8}}q/@"b)I)I !. !.A*21+C'*wwv+'E'E#''R^J_J_'E57 25l2C)Y)YB35,[ZD=Q=Q,[S[13 B1G1GB,6,=,=bffVY>W>W,X,X,X,X:L R\H]H]:L:Lknoykzkz}~k~k~dgdgEG:L:L:LI(-151I1I(1S1S1Y1Y1[1[?C < % . & $ .T.T.T\` !a!a!a1?,7/=1?5B -"-" !) : : : %)4+9-;1> ))I %OOI666 889JKKK 11(>86739=D6 )::: 1;3a77 CC)5.<%-D8014/&*&C&CDUWc&d&d   444%+!U(( ! 55519...x888 ./+04)B^)S46123/&*%=%=n%M%M%S%S%U%UN $ = =>OQ^ _ _IOOI...?~(()|n)|)|)|}}}2 2 2 bbbZ]^_Z`Z`bb ,,,,----,,,,LL+++++,'E%&CDDD #( 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%<<<%cXa%c%cNOO[^$T$TUUUEEEE =<<<<[2 w5t222t7L7VYZ7Z7Z^7  ! d1 1 1$.!33$.!33DO3Ot?T?YOO\`\q\{OOOPPP!88>RRN#$.W>DDW3W  h i@@@ $$%6777 h(<===  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/   2(-$  B42 B*.*AF& ' !%!&  & * *+t/III"d&;;;$( !&'D #   N |  $--lNKKK$77 EEEE      + 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 sY+)D D"!D"48J-- J:9J:"0L ML==M %M33 N"=NN"=C=W;; X*X%%X*5Z ZZA,_ _8_33_8O"An@>HAnIAAnJC:AnN+AnOHAnWCAnZ AAn[=A8An]6=An^4H&AngBAi#i"Ani# Ai0i-Ani/Ai0i0DAnnBB{)p B{)p$BB{$r<-B{$s/AB{$uAB{$vAB{$w=N5B{$F2B{)F8BB{$IB)B{$K=B{)LBB{$N&ADUmD:DUrCr*r)DUr* Cr7r4DUr6Cr7r7D DUwFDU} HDUE#A8DUG1DUHE)DUM;ADUN>A!DUP B7DUSBDUU D\U'D\U>DVVD\V-DWWD\WDWWE D\\D\`ADaa Da8aDa3a3Da8g05Dh&h& Dh3h2Dh3h?&Di&i& Di3i2Di3i74Dj,j, Dkj6DkkDkc@|||}|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 )rMr@)r")rArrMrKs rCrGz AIAgent.chatg!s(&&w&PP&''rE)2NNNNNNNNrrrNNFFFNrrNNNNFNNNNNNNNNNNNNNNNFFNNNNFrFTrP)FFr|)rrA)NNNNN)r[r\r]r^rrLrsetterrr}r=rr~rrrrDrrrrrrrrrrrrrrr r r.r/r-r1r5r9r8rKrSrkrn staticmethodrr~rrr rrr7rrrrrrrrrrr'r)r1r>tuplerFrMr^rirrrrrrrorrrrrr$rrrrrrrrr%r(r+r3r=r?rSrrrYrrrrrrrrrrrrr r1r$r#rQrWr]rrrrrrr4rLr"rGr`rErCrrs#X_>c>d>>>_> %)!% &*'+"' % '+ #'+'+%)!,1(,+/(,+/&*'+%)"&*.&*$(+/15#(!.2)-$)(* % $g^ ^ ^ ^  ^   ^   ^ s)d"^ ^ 3i$^ ^ ^ ^ s)^  9^  ^  !^ "#^ $"%%^ &'^ ()^ * 9+^ , 9-^ .c/^ 01^ 2&*3^ 4#&5^ 67^ 8!)9^ :&;^ <!)=^ >$?^ @%A^ B#C^ D E^ F (G^ H$I^ J"K^ LM^ NsCx.O^ PtCH~.Q^ RS^ T!U^ VW^ Z,[^ \S#X]^ `"a^ b#&c^ de^ fg^ ^ ^ ^ @,=,=,=\$,1***D****(UCUDUUUU(CCcCTCCCC 4D4444v4vvvv %s %t % % % %%c%d%%%%. 3 3    EeEeEetCH~& Ee  EeEeEeEeP@x}@@@@DB  } B  B 4S>* B 'tDcN';<B  c3hB B B B H Vs Vt V V V V$ L L G"$# hh:hh h  hhhhT*T$Z*D****$ K Kd K4PT: K K K K.F.Fd4j.FX\]aXb.F.F.F.F`-4:-$t*---->?#????0cd4S>6JcX[chlcquvz{~AD|DwErFccccJ Dd38n)= D3 D[_ D D D D&&I&&#&&&&&&\&&P)(3-)HSM))))cc>&* PPPcNP P  " P $ PPPPd\@D@D$tCH~*>@D@D@D@DD%V%V%V%V%V%V%VN "4S#X+?D@))))X)h)h)3h)#h)h)h)h)\++++\+ 6d38n)=6$tCQTH~BV666\6pTd\:GDGTGGG\G"33:8 0 0 0!!htDcN/C&D!PXY]^bcfhkck^lYmPn!!!!*       C  PS    \  x}hsm7S1T\&+/#3- :`$tCH~:N`SWX\]`be]eXfSg````DTcTd4S>>RTTTTt# {{{{ { c3h {{{{z'C'C'''' cc S0#S0%S/S0S0S0S0j/#//// S    Y_\:4CQUZ]*88888\8t33QU0"ss D4DDDDLWsWsWWWWG3G3G4GGGGFFDF#FV^FFFFP&g&gD&g#&g&g&g&gPFJdd:EI!!!T!T!!!!F%4%%%%N =3 =4 = = = =JJJJ62&c]2& 2& tTz  2&2&2&2&hDTDDDD ;"$;";";";"~st #$       t    ?C`"`"`"`"3;`"`"`"`"Hm1m1m1m1m1b>$>>>>D#,)---## K"K47KFIK KKKK^#$\CE#xPT~BU2 Z"  Z" "(+ Z"'smZ" c3hZ"Z"Z"Z"xD ( (C ((82D (PS ( ( ( ( ( (rErrrFrsrrrr max_turnsrr list_toolsr save_sampleverboserc  tdtd|rddlm} m} 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]#}| |}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_namesrget_available_toolsets)get_all_toolsetsget_toolset_infou 📋 Available Tools & Toolsets:z2--------------------------------------------------u' 🎯 Predefined Toolsets (New System):z(----------------------------------------)webrvisioncreativer)research developmentrcontent_creation full_stacku 📌 Basic Toolsets:resolved_toolsr~rru • r z - rMz Tools: u5 📂 Composite Toolsets (built from other toolsets):includesz Includes: z Total tools: tool_countu! 🎭 Scenario-Specific Toolsets:20u3 📦 Legacy Toolsets (for backward compatibility):ru✅u❌rr'r z Requirements: riu 🔧 Individual Tools (z available):u 📌 z (from ryu 💡 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|]}|Sr`rArr0s rCrzmain..!s P P Pq P P PrErmu🎯 Enabled toolsets: c6g|]}|Sr`rArYs rCrzmain..!s !R!R!R!''))!R!R!RrEu🚫 Disabled toolsets: u💾 Trajectory saving: ENABLEDu: - Successful conversations → trajectory_samples.jsonlu7 - Failed conversations → failed_trajectories.jsonl) rrrrrrrrru ❌ Failed to initialize agent: zTell me about the latest developments in Python 3.13 and what new features developers should know about. Please search for current information and try it out.u 📝 User Query: z3 ==================================================u📋 CONVERSATION SUMMARYu✅ Completed: rUu📞 API Calls: reu💬 Messages: rr@u 🎯 FINAL RESPONSE:z------------------------------rsample_r) conversationsrrrUrrrrFrC)rru" 💾 Sample trajectory saved to: u ⚠️ Failed to save sample: u 👋 Agent execution completed!)r model_toolsrIrrJrrKrLrrr rMrrrrr"rLrrrkr rrrrHrrr))rrrrrDrrrErrFrGrrIrrJrKrL all_toolsetsbasic_toolsetscomposite_toolsetsscenario_toolsetsrYrrr tools_str includes_strlegacy_toolsetsr all_toolsrenabled_toolsets_listdisabled_toolsets_listrrgrTrK sample_idsample_filenamerarws) rCmainrjv!sH +,,, (OOOP``````````???????? 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 Z0+Z Z0ZZ0ZZ00 [:[[__main__r|) NrNrrNNFFFFrs)r^atexitrLrconcurrent.futuresrrHr8rrrr[rrrrrerroroweakreftypesrrtypingrrrrrIrfirer pathlibr r6r hermes_cli.env_loaderr r__file__parent _project_env_loaded_env_paths _env_pathrr]rrrrtools.terminal_toolrtools.interruptrrtools.browser_toolrragent.prompt_builderrrrrrrrrrr r!r"r#r$r%agent.context_compressorr&agent.prompt_cachingr'r(r)r*r+r,r-r.agent.usage_pricingr/r0r1r1r2rr3rr4r5ragent.trajectoryr6r7r8rmutilsr9r:r<rirkrrrrrcompileVERBOSErrrLr~rrrrrrrrrrrrrr}rjFirer`rErCrs*      8 $ $  !!!!!! ,,,,,,,,,,,, ,,,,,,544444  tH~~$v- &&<\ZZZK&GG  :IFFFFG KKIJJJ +*****;;;;;;......100000  766666>>>>>>\\\\\\\\\\\\\\\\\\DDDDDDDD 54444444.*.*.*.*.*.*.*.*b;;;;)7)7)7)7)7)7)7)7\" 9+..!y " " "  YCCCDD#  J  !bj!455)$))))X=C==PT===="??d?t???? -.. RZ<I ssDT0%$%4%%%%<[([([([([([([([(~~ !#S/S/ S/ S/S/ S/  S/  S/S/S/S/S/S/S/S/S/S/l z DIdOOOOOrE