i dZddlZddlZddlZddlZddlZddlZddlZej e Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlmZddlZddlmZmZmZmZddlmZddlZddlmZddlm 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-m.Z.m/Z/m0Z0ddl1m2Z2m3Z3m4Z4ddl5m6Z6m7Z7ddl8m9Z:ddl;mm?Z?m@Z@ddlAmBZBddlCmDZDmEZEddlFmGZGmHZHmIZImJZJmKZKmLZLddlMmNZNmOZOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZWddlXmYZYddlZm[Z[ddl\m]Z]ddlFm^Z^m_Z_m`Z`maZambZbmcZcmdZdmeZemfZfddlgmhZhmiZiddljmkZkmlZmmnZompZpmqZrddlsmtZtmuZumvZwdd lxmyZymzZzGd!d"Z{dWd$Z|Gd%d&Z}e~d'hZe~hd(Ze~hd)Zd*Zejd+ejZejd,Zd-ed#efd.Zd#efd/Zd0ed1ed#e dzfd2Zd3e d4e d#efd5Zejd6Zd7ed#efd8Zd9ed#efd:Zd7ed#efd;Zd9ed#efd<Zd=ed#efd>Zd?ed#efd@ZdAZd#efdBZGdCdDZ dXdIedJedKedLedMedNedOedPedQedRedSedTefdUZe dVkrejedSdS)Yao 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_vmget_active_envis_persistent_env)maybe_persist_tool_resultenforce_turn_budget) set_interruptcleanup_browser)OPENROUTER_BASE_URL)build_memory_context_blocksanitize_context)jittered_backoff)classify_api_errorFailoverReason)DEFAULT_AGENT_IDENTITYPLATFORM_HINTSMEMORY_GUIDANCESESSION_SEARCH_GUIDANCESKILLS_GUIDANCEbuild_nous_subscription_prompt) fetch_model_metadataestimate_tokens_roughestimate_messages_tokens_roughestimate_request_tokens_roughget_next_probe_tierparse_context_limit_from_error(parse_available_output_tokens_from_errorsave_context_lengthis_local_endpointquery_ollama_num_ctx)ContextCompressor)SubdirectoryHintTracker)apply_anthropic_cache_control) build_skills_system_promptbuild_context_files_promptbuild_environment_hints load_soul_mdTOOL_USE_ENFORCEMENT_GUIDANCETOOL_USE_ENFORCEMENT_MODELSDEVELOPER_ROLE_MODELS!GOOGLE_MODEL_OPERATIONAL_GUIDANCEOPENAI_MODEL_EXECUTION_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)NrL)object __setattr__)selfinners 1/home/agentuser/.hermes/hermes-agent/run_agent.py__init__z_SafeWriter.__init__s 4511111c |j|S#ttf$r)t |t rt |ndcYSwxYwNr)rLwriteOSError ValueError isinstancestrlen)rPdatas rRrWz_SafeWriter.writesb =;$$T** *$ = = = *4 5 5<3t9991 < < < =s7AAcj |jdS#ttf$rYdSwxYwN)rLflushrXrYrPs rRr`z_SafeWriter.flushsH  K       $    DD s 22c4|jSr_)rLfilenoras rRrcz_SafeWriter.filenos{!!###rTcf |jS#ttf$rYdSwxYw)NF)rLisattyrXrYras rRrez_SafeWriter.isattysB ;%%'' '$   55 s 00c,t|j|Sr_)getattrrL)rPnames rR __getattr__z_SafeWriter.__getattr__st{D)))rTN) __name__ __module__ __qualname____doc__ __slots__rSrWr`rcrerirTrRrKrKqs$I222===  $$$ *****rTrKreturncdD]R}tt|d}|8t|ts#t t|t|SdS)zHWrap stdout/stderr so best-effort console output cannot crash the agent.)stdoutstderrN)rgsysrZrKsetattr) stream_namestreams rR_install_safe_stdiorxs\+;; k400  j&E&E  Ck&&9&9 : : :;;rTcjeZdZdZdefdZdefdZd 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|_dSrV)r{_used threadingLock_lock)rPr{s rRrSzIterationBudget.__init__s#" ^%% rTrpc|j5|j|jkr ddddS|xjdz c_ ddddS#1swxYwYdS)z7Try to consume one iteration. Returns True if allowed.NFT)rr}r{ras rRconsumezIterationBudget.consumes Z  zT^++         JJ!OJJ                   sAAA  A Nc||j5|jdkr|xjdzc_ddddS#1swxYwYdS)z6Give back one iteration (e.g. for execute_code turns).rrN)rr}ras rRrefundzIterationBudget.refunds Z  zA~~ a                   s 155c|jSr_)r}ras rRusedzIterationBudget.useds zrTc~|j5td|j|jz cdddS#1swxYwYdSrV)rmaxr{r}ras rR 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 266rpN) rjrkrlrmintrSboolrrpropertyrrrorTrRrzrzs  &#&&&&     cX73777X777rTrzclarify> 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 rR_is_destructive_commandrsJ u##C((t!!#&&t 5rTc t|dkrdSd|D}td|DrdSg}|D]}|jj} t j|jj}n:#t$r-tj d||jjddYdSwxYwt|ts+tj d|t|j dS|tvrIt||dStfd |DrdS||t"vrdS d S) z?Return True when a tool-call batch is safe to run concurrently.rFc&g|]}|jjSrofunctionrh.0tcs rR z2_should_parallelize_tool_batch..s888r"+"888rTc3(K|] }|tvVdSr_)_NEVER_PARALLEL_TOOLS)rrhs rR z1_should_parallelize_tool_batch..s( @ @T4( ( @ @ @ @ @ @rTu@Could not parse args for %s — defaulting to sequential; raw=%sNu6Non-dict args for %s (%s) — defaulting to sequentialc38K|]}t|VdSr_)_paths_overlap)rexisting scoped_paths rRrz1_should_parallelize_tool_batch..,s-XXX>+x88XXXXXXrTT)r\anyrrhjsonloads arguments ExceptionloggingdebugrZdicttyperj_PATH_SCOPED_TOOLS_extract_parallel_scope_pathappend_PARALLEL_SAFE_TOOLS) tool_calls tool_namesreserved_paths tool_call tool_name function_argsrs @rR_should_parallelize_tool_batchr s :!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) rgetrZr[stripr expanduser is_absoluteosrabspathcwd)rrraw_pathexpandeds rRrr7s***t  ((H h $ $HNN,<,<tH~~((**H4BGOOCMM22333 DHJJ$9 : :;; < < >>rTz[\ud800-\udfff]textcpt|rtd|S|S)zReplace lone surrogate code points with U+FFFD (replacement character). Surrogates are invalid in UTF-8 and will crash ``json.dumps()`` inside the OpenAI SDK. This is a fast no-op when the text contains no surrogates. �) _SURROGATE_RErsubrs rR_sanitize_surrogatesrYs5 D!!1  4000 KrTmessagesc8d}|D]}t|ts|d}t|tr;t|r!td||d<d}nt|tr~|D]{}t|trd|d}t|tr:t|r td||d<d}||d}t|tr:t|r td||d<d}|d}t|trs|D]o}t|ts|d} t| tr:t| r td| |d<d}|d } t| tr| d} t| tr:t| r td| | d<d}| d } t| tr:t| r td| | d <d}q|S) a,Sanitize surrogate characters from all string content in a messages list. Walks message dicts in-place. Returns True if any surrogates were found and replaced, False otherwise. Covers content/text, name, and tool call metadata/arguments so retries don't fail on a non-content field. FcontentrTrrhridrr)rZrrr[rrrlist) rfoundmsgrpartrrhrrtc_idfnfn_namefn_argss rR_sanitize_messages_surrogatesrds E$%$%#t$$  '')$$ gs # # % (<(rhrolerr)rZrrr[rritems)rrrr sanitizedrrrhrrrrkeyvalues rR_sanitize_messages_non_asciirs] E/!/!#t$$  '')$$ gs # # )(11IG##!*I  & & ) ) )dD)))88F++D!$,,)$4T$:$: $,,+4DL$(Ewwv dC  (..ID  'F WW\** j$ ' ' - - -b$''- B//B!"d++-"$&&"5"5%gs33-(8(A(AI(G332;;(,))++ ! !JC???%%% !,U33 %%(CH E ! LrTtoolsc t|S)z7Strip non-ASCII characters from tool payloads in-place.)_sanitize_structure_non_ascii)rs rR_sanitize_tools_non_asciirs ( / //rTpayloadc0dfd|S)zCStrip non-ASCII characters from nested dict/list payloads in-place.Fc&t|tru|D]^\}}t|trt |}||kr|||<d7t|tt fr |_dSt|t rnt |D]`\}}t|trt |}||kr|||<d7t|tt fr |_dSdS)NT)rZrrr[rr enumerate)noderrridx_walkrs rRrz,_sanitize_structure_non_ascii.._walks5 dD ! ! !"jjll ! ! UeS))! 0 7 7I E))$-S $d|44!E%LLL ! !d # # !'oo ! ! UeS))! 0 7 7I E))$-S $d|44!E%LLL ! ! ! !rTro)rrrs @@rRrrs; E!!!!!!* E'NNN LrTz0.14.1cddl}dtd|d|d}|d|dd S) z8Return default HTTP headers required by Qwen Portal API.rNz QwenCode/ (z; )enablez qwen-oauth) User-AgentzX-DashScope-CacheControlzX-DashScope-UserAgentzX-DashScope-AuthType)platform_QWEN_CODE_VERSIONsystemlowermachine)_plat_uas rR_qwen_portal_headersr sf X( X XELLNN,@,@,B,B X Xemmoo X X XC$,!$ ,   rTcmneZdZdZedefdZejdeddfdZ ddedededededeedzdedeedzdede de de ede ede de de dede d ed!e ed"e ed#e ed$ed%e d&ed'ed(e d)e d*e d+e d,e d-e d.e d/e d0e d1e d2e d3e d4eeefd5ed6eeefd7e eeefd8ed9ed:ed;e dd?d@eeefdAe dBe dCe dDe fldEZdFZddGZdHZd dIdJe fdKZde fdLZde fdMZdNeddfdOZdeeeffdPZddQZddRZddede fdSZde fdTZedede fdUZeddVdedeede fdWZ de de!fdXZ"dYede fdZZ#dYedefd[Z$edYede fd\Z%de fd]Z& dd^ed_eede fd`Z'daedbed_e eeefde fdcZ(deefddZ)deeddfdfZ*dgZ+dhZ,diZ- ddje edke dle ddfdmZ.d_e eddfdnZ/dd_e edoe efdpZ0dd_e edoe efdqZ1d_e ede efdrZ2defdsZ3d_e eeefdtedue de eeeffdvZ4d_e eeefdtedue fdwZ5edxe6defdyZ7dzeedeefd{Z8d|edefd}Z9edxe6deeeffd~Z:dedeeeeffdZ;dddeeefdedxee6dee<fdZ=edYedefdZ>dd_e eeeffdZ?ddNeddfdZ@ddZAdeddfdZBdeddfdZCdZDde!fdZEdd_eddfdZFdd_eddfdZGddZHde eeefddfdZIede fdZJddedefdZKedefdZLeMhdZNed_e eeefde eeeffdZOededefdZPededefdZQdededzfdZRdZSddee eeefdee eeeffdZTeddedede defdZUededeVeeeeffdZW ddedeedefdZXd_e eeefde eeeffdZYdede eeeffdZZd ddede deeeffdZ[dedefdZ\dedefdZ]dedeVeeffdZ^defdZ_defdZ`deajbfdZcedede fdZdde!dede defdZeedede fdZfdedede ddfdZgdede fdZhdedefdZide fd„ZjdedefdÄZkdededdfdĄZldde!dede fdƄZmdde!defdDŽZnd dIdJe de fdȄZod dIdJe de fdɄZpde fdʄZqdeddfd˄Zrdd̄Zsddd͜dee de deetdeeeefdeVe e ff d҄Zude!fdӄZvde!fdԄZwddՄZxdeddfdׄZyededefd؄ZzdYede fdلZ{deeefddfdۄZ|deddfd܄Z}deddfd݄Z~deddfdބZde fd߄Zddde!de fdZde fdZde fdZeMhdZde6de de de fdZedYede fdZededeVeee<ffdZdededefdZdYededefdZdedefdZde fdZde fdZdedefdZd_eddfdZdede!fdZde fdZde!dzfdZd^ede!fdZede!de!fdZde fdZdd_ede fdZddddd_edede deededeVf dZdd_edede ddfdZ ddede!dedeedef d Zedd eded edefd Zdd_edede ddfdZdd_edede ddfdZd_ede defdZ ddaededoe eeefdeedee deedeeeffdZddNedee 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. rpc|jSr_) _base_urlras rRbase_urlzAIAgent.base_urls ~rTrNcN||_|r|nd|_dSN)rr_base_url_lowerrPrs rRrzAIAgent.base_url#s(05=u{{}}}2rTrZ?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_callbackinterim_assistant_callbacktool_gen_callbackstatus_callback max_tokensreasoning_config service_tierrequest_overridesprefill_messagesruser_idgateway_session_keyskip_context_files skip_memoryparent_session_iditeration_budgetrzfallback_modelcheckpoints_enabledcheckpoint_max_snapshotspass_session_idpersist_sessionc9@t| |_| |_|2pt| |_| |_||_||_||_||_ |+|_ |,|_ |-|_ d|_ d|_|.|_|7|_|8|_|4|_||_|r|dnd|_|pd|_t-|t.r:|r&|nd}9|9pd|_|p||_t9|p|pg|_|dvr||_n|jdkrd|_n|jdkrd|_n|9d|jvrd|_d|_n|9d |jvrd|_d|_n}|jd ks |9d |jvrd |_d |_nX|j d !drd |_n#|jdks d|jvrd|_nd|_ ddl"m#}:m$};|j|:vr|;|j|j|_n#tJ$rYnwxYw||jdkr|jdkrt/|jpd&dswt/|jpd&ds<|'s!|(|j|jrd|_|jdks|)r)tUj+dd,||_-||_.||_/d|_0||_1||_2| |_3|!|_4|"|_5|#|_6|%|_7|$|_8d|_9d|_:d|_;d|_<d|_=tUj>|_?d|_@g|_AtUjB|_C||_D||_E||_F||_G||_H||_I| |_J| |_K|&|_L|'|_M|(|_Nt|)pi|_P|*pg|_Qd|_R|)}||_Sd|_Td|_Ud|_VtjW|_Xd |_Yd|_Zd|_[d|_\dd!l]m^}?m_}@|?t"|jr%|@tbd#n=|jr6d$D]3}Atjd|Aetjf4d|_gd|_hd|_id|_jd|_ki|_ld|_md|_n|jd krydd%lomp}Bmq}C|jdk}D|Drdd&lomr}Eddls}F|Ftd'|pd}G|Gr|Gud(nd)}H|H|_v|E|H|_md*|_w||_xd|_nd*|_yd|_zi|_{|jstd+|jd,|Hd-n|jd k}I|Ir|p |Cpdn|pd}J|J|_y|J|_w||_xdd.lom}}K|K|J|_n|B|J||_md|_zi|_{|jsRtd+|jd/|Jr8t|Jd0kr%td1|Jdd2d3|Jd4dn|jdkrYddls}F|Ftd'|pd}G|Gr|Gud(nd)|_vd|_ dd5lm}L|Ldid6i}M|Md7ru|Md8r`|Md7|Md8d9|_|Md:r|Md:|jd;<|Md<r|Md<|jd<<n#tJ$rYnwxYwd|_zi|_{|js-|jrd=nd}Ntd+|jd>|jv|Nd-n|r|r||d?}O|jdkr|j|Od@<|j|OdA<|}Pd|Pvr dBdCdDdE|OdF<ndG|PvrddHlm}Q|Q|OdF<nndI|Pvr dJdKi|OdF<nOdL|Pvrt |OdF<n%ddMlm}R|R|jpdN|jdO\}S}T|SL|Sjyt/|Sjd?}Ot|SdPr|Sjrt|Sj|OdF<n|jpd}U|Uru|UdQvrq|UdR}V ddSlm}W|W|U}X|Xr|Xjr |Xjd}Vn#tJ$rYnwxYwtdT|UdU|VdVtdW|O|_{t/|OdXd}Yd|Yvrgd|jpdvrJ|OdFpi}Z|ZdYd}[dZ}\|\|[vr|[r |[d[|\|ZdY<n|\|ZdY<|Z|OdF<|Od\d|_y|OdX|j|_ ||Od]d^|_z|jstd+|j|rtd_||Od\d`}]|]r?|]dakr9t|]d0kr&tdb|]dd2d3|]d4dntdc|]r |]dddnd`den%#tJ$r}^tdf|^d}^~^wwxYwt-|3t8rdg|3D|_nOt-|3tr3|3dhr|3dir |3g|_ng|_d|_d|_|jr |jdnd|_|jr|jst|jd(kr0|jd}_tdj|_didk|_dhd-nJtdlt|jdmdndo|jDzt+| | |jp|_t/|_|jrdq|jD|_t3|j}`|jstdrt|jdsdt|`| r%tdudt| | r%tdvdt| n|jstdw|jrH|jsAt5}adx|aD}b|brtdy|b|jr|jstdz|j rK|jsDt|j d{kr|j dd{d3zn|j }ctd||cd}|jSr(|js!|>rd~nd}dtd|ddt|jTdt9j|_|r||_nG|jd}etCjjdd}f|ed|f|_tI}g|gdz |_|jdd|jd|jdz |_g|_d|_ddlm}h|h|5|6|_|0|_|1|_d|_|jr |j|j|j p tbjdd|j|j|'|&dd|jn2#tJ$r%}^td|^Yd}^~^nd}^~^wwxYwddlm}i|i|_ dd5lm}j|j}kn#tJ$ri}kYnwxYwd|_d|_d|_d|_d|_d|_d|_|/s |kdi}l|ldd|_|ldd|_t}|ldd|_t}|ldd|_|js|jrYddlm}m|m|ldd|ldd|_|jn#tJ$rYnwxYwd|_|/sr |lr|ldhdnd}n|ns ddlm}o|o}p|pjr}|pjys|pjrod}n ddlm}qm}r|q}sd|sdidh<|r|sn#tJ$rYnwxYw|jstdtdn#tJ$rYnwxYw|nrhddlm}tddlm}u|t|_|u|n}v|vr.|vr|j|v|jjrddlm}w|j|+pdt/|wdd}x|jr8 |j|j}y|yr|y|xd<n#tJ$rYnwxYw|j r |j |xd<|j r |j |xd< ddlm}z|z}{|{|xd<d|xd<n#tJ$rYnwxYw|jjdi|xtbd|nn"td|nd|_n9#tJ$r,}|td||d|_Yd}|~|nd}|~|wwxYw|jr|jd|jD}}|jD]o}~|~dd}|r||}vrd|~d}|j||r/|j||}|pd|_ |kdi}t}|dd|_n#tJ$rYnwxYw|kdi}t-|tsi}|ddN|_|kdi}t-|tsi}t|dd}t/|dddv}t|dd}t}|ddd}|kdii}t-|tr|d}nd}|f t}|}nT#ttf$r>td|ddl}td|dĝ|jŦd}YnwxYw||_| ddlm}||k}n<#tJ$r/|kdǦ}t-|t8sg}YnwxYw|D]J}t-|ts|dXpd d }|r||j d kr|di}t-|tr||ji}t-|tr|d}|r t}|}n`#ttf$rJtd|j|ddl}td|jd|dĝ|jŦYnwxYwnLd}d} t-|ktr|kdini}|dd̦pd}n#tJ$rYnwxYw|dkr ddlm}||}n2#tJ$r%}td|Yd}~nd}~wwxYw|1 ddlm}|}|r |j|kr|}n#tJ$rYnwxYw|td||||_ddlm}||j|jt|d\d||jԦ}|j|j||jt|d\d|jզ|js tbd|jnJt|j|d||d|j|jt|d\d||j|jئ |_||_ddlm}t|jdd}|r-||kr'td|jd|d[d|d[d|dzdߝ t/|_t|dr|jr|j|jD]m}~d|~d}|j||~dd}|r4|j||j|nt|dr|jr |j|jt/tI|j pd|jt|jddn2#tJ$r%}td|Yd}~nd}~wwxYwttcjdpd|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d`|_d|_d}t-|tr|d}|L t}||_n4#ttf$rtd|YnwxYw|j{|jrtt|jr_ t |j|j}|r|dkr||_n2#tJ$r%}td|Yd}~nd}~wwxYw|jr(|js!tbd|j|jsd|rCtd|jjd[dt}|dzd|jjd[d-ntd|jjd[dd|_||j}|j|j|j|jt|d\dt|j{|jSt|di|jt|dX|jt|d\dt|dh|j|j|jd |_ |jd kr1|j  |jw|jx|jnddSdS)a Initialize the AI Agent. Args: base_url (str): Base URL for the model API (optional) api_key (str): API key for authentication (optional, uses env var if not provided) provider (str): Provider identifier (optional; used for telemetry/routing hints) api_mode (str): API mode override: "chat_completions" or "codex_responses" model (str): Model name to use (default: "anthropic/claude-opus-4.6") max_iterations (int): Maximum number of tool calling iterations (default: 90) tool_delay (float): Delay between tool calls in seconds (default: 1.0) enabled_toolsets (List[str]): Only enable tools from these toolsets (optional) disabled_toolsets (List[str]): Disable tools from these toolsets (optional) save_trajectories (bool): Whether to save conversation trajectories to JSONL files (default: False) verbose_logging (bool): Enable verbose logging for debugging (default: False) quiet_mode (bool): Suppress progress output for clean CLI experience (default: False) ephemeral_system_prompt (str): System prompt used during agent execution but NOT saved to trajectories (optional) log_prefix_chars (int): Number of characters to show in log previews for tool calls/responses (default: 100) log_prefix (str): Prefix to add to all log messages for identification in parallel processing (default: "") providers_allowed (List[str]): OpenRouter providers to allow (optional) providers_ignored (List[str]): OpenRouter providers to ignore (optional) providers_order (List[str]): OpenRouter providers to try in order (optional) provider_sort (str): Sort providers by price/throughput/latency (optional) session_id (str): Pre-generated session ID for logging (optional, auto-generated if not provided) tool_progress_callback (callable): Callback function(tool_name, args_preview) for progress notifications clarify_callback (callable): Callback function(question, choices) -> str for interactive user questions. Provided by the platform layer (CLI or gateway). If None, the clarify tool returns an error. max_tokens (int): Maximum tokens for model responses (optional, uses model default if not set) reasoning_config (Dict): OpenRouter reasoning configuration override (e.g. {"effort": "none"} to disable thinking). If None, defaults to {"enabled": True, "effort": "medium"} for OpenRouter. Set to disable/customize reasoning. prefill_messages (List[Dict]): Messages to prepend to conversation history as prefilled context. Useful for injecting a few-shot example or priming the model's response style. Example: [{"role": "user", "content": "Hi!"}, {"role": "assistant", "content": "Hello!"}] NOTE: Anthropic Sonnet 4.6+ and Opus 4.6+ reject a conversation that ends on an assistant-role message (400 error). For those models use structured outputs or output_config.format instead of a trailing-assistant prefill. platform (str): The interface platform the user is on (e.g. "cli", "telegram", "discord", "whatsapp"). Used to inject platform-specific formatting hints into the system prompt. skip_context_files (bool): If True, skip auto-injection of SOUL.md, AGENTS.md, and .cursorrules into the system prompt. Use this for batch processing and data generation to avoid polluting trajectories with user-specific persona or project instructions. N r>codex_responsesbedrock_conversechat_completionsanthropic_messages openai-codexrZxaichatgpt.com/backend-api/codexapi.x.ai anthropiczapi.anthropic.comr]/ /anthropicbedrockbedrock-runtimer[r\r)_AGGREGATOR_PROVIDERSnormalize_model_for_provider copilot-acp acp://copilotz acp+tcp://r% openrouterctSr_)r(rorTrRz"AIAgent.__init__..s 355rTTtargetdaemonFclaude5m initializing) setup_loggingsetup_verbose_logging)rz=Verbose logging enabled (third-party library logs suppressed))r run_agenttrajectory_compressorcron hermes_cli)build_anthropic_clientresolve_anthropic_token)build_anthropic_bedrock_clientzbedrock-runtime\.([a-z0-9-]+)\.r us-east-1zaws-sdku&🤖 AI Agent initialized with model: z& (AWS Bedrock + AnthropicBedrock SDK, r _is_oauth_tokenz (Anthropic native) u🔑 Using token: r...) load_config guardrailguardrail_identifierguardrail_version)guardrailIdentifierguardrailVersionstream_processing_modestreamProcessingModetracez + Guardrailsz (AWS Bedrock, r$rr)r*z%https://hermes-agent.nousresearch.comz Hermes Agentzproductivity,cli-agent)z HTTP-RefererzX-OpenRouter-TitlezX-OpenRouter-Categoriesdefault_headersapi.githubcopilot.comcopilot_default_headers api.kimi.comr KimiCLI/1.30.0portal.qwen.airesolve_provider_clientauto)r+ raw_codex_default_headers)rrlcustom_API_KEY)PROVIDER_REGISTRYz Provider 'z:' is set in config.yaml but no API key was found. Set the zM environment variable, or switch to a different provider with `hermes model`.zxNo LLM provider configured. Run `hermes model` to select a provider, or run `hermes setup` for first-time configuration.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)r%r+rZrrrfs rRrz$AIAgent.__init__..,s^$$$a&&$+,55+<+<$ABw$$$$rTr%r+u🔄 Fallback model: r u🔄 Fallback chain (z providers):  → c3>K|]}|dd|ddVdS)r+r r%r Nrors rRrz#AIAgent.__init__..>s;"c"caj#D#DAjM#D#D#D"c"c"c"c"c"crT)r.r/r2c*h|]}|ddSrro)rtools rR z#AIAgent.__init__..Js"$U$U$U$T*%5f%=$U$U$UrTu🛠️ Loaded z tools: , u ✅ Enabled toolsets: u ❌ Disabled toolsets: u@🛠️ No tools loaded (all tools filtered out or unavailable)cg|] \}}|| Sroro)rrh availables rRrz$AIAgent.__init__..Zs"^^^_T9T]^D^^^rTu=⚠️ 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_sessions)parentsexist_oksession_.json)CheckpointManager)enabled max_snapshotsHERMES_SESSION_SOURCEcli)r,rIrH)r<sourcer+ model_configrMrQzESession DB create_session failed (session_search still available): %s) TodoStore 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)r<rr agent_context session_titlerMrN)get_active_profile_nameagent_identityhermesagent_workspacezMemory provider '%s' activatedz/Memory provider '%s' not found or not availablez&Memory provider plugin init failed: %sch|]@}t|t|didASrrrts rRrz#AIAgent.__init__..#sT$$$a&&$j"%%))&11$$$rTrhr)rrskillscreation_nudge_intervalagenttool_use_enforcement compression thresholdg?r)true1yes target_ratio皙?protect_last_ncontext_lengthuInvalid model.context_length in config.yaml: %r — must be a plain integer (e.g. 256000, not '256K'). Falling back to auto-detection.u2 ⚠ Invalid model.context_length in config.yaml: zf Must be a plain integer (e.g. 256000, not '256K'). Falling back to auto-detected context window. )file)get_compatible_custom_providerscustom_providersmodelsuInvalid context_length for model %r in custom_providers: %r — must be a plain integer (e.g. 256000, not '256K'). Falling back to auto-detection.u& ⚠ Invalid context_length for model z in custom_providers: compressorcontextengine)load_context_enginez4Context engine load from plugins/context_engine/: %s)get_plugin_context_engineuEContext engine '%s' not found — falling back to built-in compressorget_model_context_length)rr$config_context_lengthr%r+rrr$r%zUsing context engine: %s) r+threshold_percentprotect_first_nrsummary_target_ratiosummary_model_overrider2rr$rr%r&)MINIMUM_CONTEXT_LENGTHzModel z has a context window of z$ tokens, which is below the minimum z9 required by Hermes Agent. Choose a model with at least izBK context, or set model.context_length in config.yaml to override.context_compressor)rrr+rz#Context engine on_session_start: %s TERMINAL_CWD) working_dirunknownollama_num_ctxz'Invalid ollama_num_ctx config value: %rz#Ollama num_ctx detection failed: %szAOllama num_ctx: will request %d tokens (model max from /api/show)u📊 Context limit: z tokens (compress at r"z% = z# tokens (auto-compression disabled) r+r%rr&r$ client_kwargsuse_prompt_cachingcompressor_modelcompressor_base_urlcompressor_api_keycompressor_providercompressor_context_lengthcompressor_threshold_tokensanthropic_api_keyanthropic_base_urlis_anthropic_oauthro( rxr+r,rzrRr-r0r1r2r3r_user_id_gateway_session_key _print_fnbackground_review_callbackrOrVrW_credential_poolr4r5rrZr[rrr%r'rr(r&rrstripendswithhermes_cli.model_normalizergrhr startswith_is_direct_openai_url&_provider_model_requires_responses_api_is_openrouter_urlr~Threadstartr=r>r?suppress_status_outputr@rArBrCrDrErGrF_executing_tools_interrupt_requested_interrupt_message_execution_thread_id _interrupt_thread_signal_pendingRLock _client_lock_delegate_depth_active_childrenr_active_children_lockr6r7r8r9r:r;r.r/rHrIrJrrKrL_force_ascii_payload_use_prompt_caching _cache_ttl_budget_exhausted_injected_budget_grace_calltime_last_activity_ts_last_activity_desc _current_tool_api_call_count_rate_limit_statehermes_loggingrurv _hermes_homeloggerinfor getLoggersetLevelERROR_stream_callback_stream_needs_break _current_streamed_assistant_text_persist_user_message_idx_persist_user_message_override_anthropic_image_fallback_cache_anthropic_client_is_anthropic_oauthagent.anthropic_adapterr{r|r}rergroup_bedrock_region_anthropic_api_key_anthropic_base_urlr$client_client_kwargsprintrr\_bedrock_guardrail_confighermes_cli.configrrhermes_cli.modelsrragent.auxiliary_clientrhasattrrupperhermes_cli.authrapi_key_env_vars RuntimeError_create_openai_client_fallback_chain_fallback_index_fallback_activated_fallback_modeljoinrrsetvalid_tool_namessortedrrr now session_startr<strftimeuuiduuid4hexr logs_dirmkdirsession_log_file_session_messages_cached_system_prompttools.checkpoint_managerr_checkpoint_mgr _session_db_parent_session_id_last_flushed_db_idxcreate_sessionrenvironwarningtools.todo_toolr _todo_store _memory_store_memory_enabled_user_profile_enabled_memory_nudge_interval_memory_flush_min_turns_turns_since_memory_iters_since_skillrtools.memory_toolrload_from_disk_memory_managerplugins.memory.honcho.clientrfrom_global_configrr setdefaultagent.memory_managerrplugins.memoryr is_available add_provider providershermes_constantsget_session_titlehermes_cli.profilesrinitialize_allrget_all_tool_schemasradd_skill_nudge_interval_tool_use_enforcementfloat TypeErrorrYrtrs_config_context_lengthrplugins.context_enginerhermes_cli.pluginsrrhragent.model_metadatarrg update_modelr2compression_enabledr_context_engine_tool_namesget_tool_schemason_session_startr3getenv_subdirectory_hints_user_turn_countsession_prompt_tokenssession_completion_tokenssession_total_tokenssession_api_callssession_input_tokenssession_output_tokenssession_cache_read_tokenssession_cache_write_tokenssession_reasoning_tokenssession_estimated_cost_usdsession_cost_statussession_cost_source_ollama_num_ctxr0r1rthreshold_tokens_compression_warning$_check_compression_model_feasibility_primary_runtimeupdate)rPrr$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrrMrNrOrP session_dbrQrRrScredential_poolrTrUrVrW provider_namergrh is_openrouter is_claudeis_native_anthropicrurv quiet_loggerr{r|_is_bedrock_anthropicr}_re _region_match _br_region_is_native_anthropic effective_key_is_oat _load_br_cfg_gr _gr_labelreffective_baserr_routed_clientr _explicit _env_hintr_pcfg_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_kwargs_str_profile_mpe_existing_tool_names_schema_tname_wrapped skills_config_agent_section_compression_cfgcompression_thresholdrcompression_target_ratiocompression_protect_last _model_cfgrrtr_custom_providers _cp_entry_cp_url _cp_models _cp_model_cfg_cp_ctx_selected_engine _engine_name_ctx_cfgr _ce_load_errr _candidater_plugin_ctx_lenr_ctx_ce_err_ollama_num_ctx_override _detectedexc_ccs rRrSzAIAgent.__init__(s)J  ,!1 SON4S4S$!2.$'>$   $7! *.'"4.. / 0.8@Z****b B 4>x4M4MlRZR`R`RbRbl((..000hl %+ &1'X3344 h h h$DMM ]n , ,-DMM ]e # #-DMM#)HDL`)`)`-DM*DMM#t7K)K)K-DM!DMM ]k ) )m.CH[_c_sHsHs0DM'DMM  ! ( ( - - 6 6| D D /1DMM ]i ' '+<@T+T+T.DMM.DM          }$99999$*dmTT     D    !333 .. +,,2244??PP/ +,,2244?? MM/**,, / >>J!]? /.DM =L ( (D,C,C,E,E (  55   eggg&<##6 &<#&+#!2"4 0*%:"*D'.!2 !&%*!"&04!05-%O-- ! "%.^%5%5""3!2.*+F((@%!1!2% 0(!%&7&=2!>!> 0 6B$)! //11  0 0 2 22 "m/CCd YdHd$1$?i#WDW +0'"' )- (6 )-$%>B HGGGGGGG ,////   L ! ! # # # KKW X X X X L %LLL%l33< !$! _RRRRRR    # +Mx~[] ^ ^ 7DU]00333+ '1$)G)G )S)S&*3'+3(+0(( " &(#DC4:CCuCCCDDD (,} 'C$Pd y!K,C,C,E,E!Kkrkxvx , *7'+3(NNNNNN+27=+A+A()?)? x)X)X&" &(#_b4:bbbccc$_]););b)@)@]=!3D]]WYWZWZI[]]^^^ ]0 0 0    JJ'I8>WYZZM=J#[=#6#6q#9#9#9P[D -1D * IIIIII"lnn((B77;;KLL77122Osww?R7S7SO/23I/J,/0C,D66D2ww788oQTUmQn67MNwww''OBEg,6w?    DK"$D ? ~/3/MUOOSU |tz||Z^Zn|py|||}}}@ 8@ -4 J J =M11/3/?M),,0MM&)!)>#7#7#9#999(O.<3K88M"344 -0D0D0F0FFFIIIIII7N7N7P7PM"344#~';';'='===$&68M"344&)=)=)?)???7K7M7MM"34KJJJJJ$;$;M+V4:%O%O%O!!-#1#9$'(?$@$@%%M ~/ABBa~Gfa;?@_;`;` &78 "&!4" ; ; = = C C E EI Y6V%V%V(1'8'8$B$B$B !IIIIII$5$9$9)$D$DE$F)?F,1,B1,E (!!! D!*```2;``` ') #0D "-"3"3J"C"CDDJJLLO..8 @Pb?W?W?Y?Y3Y3Y'++,=>>D" ' ,> C C H  55$D9F6X6X6X6X 2336C 237>M"34(,,Y;;DL)--j$-HHDM O"88|dh8ii  JO4:OOPPPIGXGGHHH,00FCCHJH $;$;H PR@R@RUXbqb\UUhrssmUUVVVVImu]B\dehfheh\i\i|BIIIJJJ O O O"#M!#M#MNNN O nd + + &$$)$$$D  - - &.2D2DZ2P2P &UcUgUghoUpUp &$2#3D #%D  #( :>:NXt3A66TX   e e4'((A--)!,NbkNNR ^NNNOOOOVc$2F.G.GVVVll"c"cdNb"c"c"cccdeee*-/    !$ : V$U$U$*$U$U$UD ! 566J? WYTZYY$))JBWBWYYZZZ$USdii@P6Q6QSSTTT$WUtyyAR7S7SUUVVV V T U U U : fdo f577L^^ 8J8J8L8L^^^L fdVbddeee  ! 4$/ 4 2 3 3 3  ' c cJMdNjJkJknpJpJpT9#2#>FFvzwSN aNaaa b b b  # UDO U+>[''D[F S6SST_SSS T T T&\^^  >(DOO!.77HHM)"1"-J!.====DO&'' #j0  D4888 $ 0Q4?0Q0Q0Q Q8:59" ?>>>>>00'2    &"3$%!     //#=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     $J ,I ,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#>>>+5#4LLLLLL*./(0(9E+.ttvv;;-6 ((  +%%&*&6&H&H&Y&Y#&!HDGL$A#,%%% $% =D6:mL34\BFB[L)>?!SSSSSS'>'>'@'@H=EL)9:>FL):;;(!!! D!;,;KKlKKK $DFXYYYY %VXjkkk/3, , , ,GNNN'+$$$$$$ ,   5DJ$:$$$$$  /DDFF 5 5 VR00f(<<<$.GDD !!(+++5)--f555(,,V444&(" &NN8R88M),]->->?XZ\-]-])^)^D & &    D  $44.$// N%3%7%78NPV%W%W" &>>-<<*D11 "!  %&6&:&:;&M&M N N!"2"6"6y$"G"GHHNNPPThh#()9)=)=nd)S)S#T#T #&'7';';*>s*C*CCC!*x!!&!&!&$*NN)J)- G %&%&%&%/JJJ$))]RVR\)])]v})])])].1Z %&%&%&%&%&%&!&E #  8B:t8T8T\z~~i444Z\H#<<,??OOPTP]>^>^ ' I0T]KK 5Q+4D( I I I BCHHHHHHHH I     KKS$     |" |~T-D-S~~~loqFGJqJmKmK~~QUQhQy~~~~zT-D-Szzzz{{{ %)! 11333 %Z   tY33!$"566"&":!(Wdj A A#*3 DM#J#J")#y""="=#*3 DM#J#J),);+.+?!! ! $ =0 0 0  ! ( (%)%<&*&>&*&>**      1 0s,H?? I  I /Ca22 a?>a?1i33 j?j Cq q5q00q5B'AADD AD5DAD0D0AD5EAEE AE.E-AE.F&DAJ,J, AJ9J8AJ9KAS?K$1ANL6AM M ANM AMMANMAMM(ANNAS?N ANN AS?NANNBAS?P)&AQQAS?Q AQQAS?QAQQ%AS?RARRAS?R AR+R(AS?R*AR+R+AAS?S? AT5T "AT0T0AT5W(?AX(X( AX5X4AX5^A^'^'AA_8_7A_8`A``6AaaAad-Ad>d>AAffAff'AAg-g- Ag:g9Ag:hAhh Aih AiiAii Ai+i+ Ai8i7Ai8r,AAt t At;tAt6t6At;w=Axx.AyyAyy-+Azz A{z#A{{A{c$d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_ d|_ d|_ d|_ t|dr"|jr|jdSdSdS)aReset all session-scoped token counters to 0 for a fresh session. This method encapsulates the reset logic for all session-level metrics including: - Token usage counters (input, output, total, prompt, completion) - Cache read/write tokens - API call count - Reasoning tokens - Estimated cost tracking - Context compressor internal counters The method safely handles optional attributes (e.g., context compressor) using ``hasattr`` checks. This keeps the counter reset logic DRY and maintainable in one place rather than scattering it across multiple methods. rrrrrN)rrrrrrrrrrrrrrLron_session_resetras rRreset_session_statezAIAgent.reset_session_stateWs&%&!$%!%&"%&")*&)*&*+'()%!"*-'#, #) !" 4- . . 743J 7  # 4 4 6 6 6 6 6 7 7 7 7rTcddl}ddl}ddlm}|s |||}|dkr2|dvr.t |t r|r|dd|}|j} |j} ||_||_|p|j |_ ||_ |r||_ |dkrddl m } m} m} |d k}|r|p|j p | pdn |p|j pd}||_ ||_|pt#|d d|_| ||j|_| ||_d|_i|_nK|p|j }|p|j }||d |_|t1|jd d |_|dko|d k}d|j pdvrd|vp||_t7|dr|jr|ddlm}||j|j |j |jt#|dd}|j|j||j t#|dd|j|j d|_ t7|dr|jr|jnd}|j|j|j |j t#|ddt1|j|j|rt#|d|jn|j|rt#|d|j n|j |rt#|ddnd|rt#|d|jn|j|r|j!nd|r|j"ndd |_#|dkr-|j#$|j|j|jdd|_%d|_&|j'd| | ||dS)a]Switch the model/provider in-place for a live agent. Called by the /model command handlers (CLI and gateway) after ``model_switch.switch_model()`` has resolved credentials and validated the model. This method performs the actual runtime swap: rebuilding clients, updating caching flags, and refreshing the context compressor. The implementation mirrors ``_try_activate_fallback()`` for the client-swap logic but also updates ``_primary_runtime`` so the change persists across turns (unlike fallback which is turn-scoped). rN)determine_api_moder]) opencode-zen opencode-goz/v1/?$rr{r|rrbrDr switch_modelTrrlrrrrr)rr$r%rr$)r+rrr$r%r&r+rr%rrFz+Model switched in-place: %s (%s) -> %s (%s))(rr@hermes_cli.providersrrZr[rr+r%rr&r$r?r{r|rrCrgrDr=r>rErFrQrrr&rLrrrrrdrrrrrTrSr3)rP new_model new_providerr$rr&rrr old_model old_providerr{r|rrrrrrnew_context_lengthrs rRrzAIAgent.switch_model~s ;;;;;; B)),AAH , , , ???8S))@@wwy"h77HJ }  $  1DM    #"DL + + +          $0;#> \pVWW W8O8O8Q8QWUWw~xUCGCOxUSUM(DL&3D #'/']74AVX\3]3]D $%;%;t7&&D "(7}'E'ED $DK"$D  #3t|M%6N(*##D 44T())%5DK'*>>^&*&>**   $)   9 |Y      rTcd |jpt}||i|dS#ttf$rYdSwxYw)a3Print that silently handles broken pipes / closed stdout. In headless environments (systemd, Docker, nohup) stdout may become unavailable mid-session. A raw ``print()`` raises ``OSError`` which can crash cron jobs and lose completed work. Internally routes through ``self._print_fn`` (default: builtin ``print``) so callers such as the CLI can inject a renderer that handles ANSI escape sequences properly (e.g. prompt_toolkit's ``print_formatted_text(ANSI(...))``) without touching this method. N)rrGrXrY)rPr*kwargsrs rR _safe_printzAIAgent._safe_print sU (5B B      $    DD s //forcer ct|ddrdS|st|ddrdS|s|r |jsdS|j|i|dS)ueVerbose print — suppressed when actively streaming tokens. Pass ``force=True`` for error/warning messages that should always be shown even during streaming playback (TTS or display). During tool execution (``_executing_tools`` is True), printing is allowed even with stream consumers registered because no tokens are being streamed at that point. After the main response has been delivered and the remaining tool calls are post-response housekeeping (``_mute_post_response``), all non-forced output is suppressed. ``suppress_status_output`` is a stricter CLI automation mode used by parseable single-query flows such as ``hermes chat -q``. In that mode, all status/diagnostic prints routed through ``_vprint`` are suppressed so stdout stays machine-readable. rFN_mute_post_response)rg_has_stream_consumersrr )rPr r*r s rR_vprintzAIAgent._vprints& 415 9 9  F 'S  F$)&)))))rTc|jdSttdd}|dS t|S#t t tf$rYdSwxYw)aReturn True when quiet-mode spinner output has a safe sink. In headless/stdio-protocol environments, a raw spinner with no custom ``_print_fn`` falls back to ``sys.stdout`` and can corrupt protocol streams such as ACP JSON-RPC. Allow quiet spinners only when either: - output is explicitly rerouted via ``_print_fn``; or - stdout is a real TTY. NTrrF)rrgrtrreAttributeErrorrYrX)rPrws rR_should_start_quiet_spinnerz#AIAgent._should_start_quiet_spinner9sp > %4h-- >5  (( ( G4   55 s AA! A!c |jo|j S)aReturn True when quiet-mode tool summaries should print directly. When the caller provides ``tool_progress_callback`` (for example the CLI TUI or a gateway progress renderer), that callback owns progress display. Emitting quiet-mode summary lines here duplicates progress and leaks tool previews into flows that are expected to stay silent, such as ``hermes chat -q``. )r2r=ras rR _should_emit_quiet_tool_messagesz(AIAgent._should_emit_quiet_tool_messagesLsBt'B#BBrTmessagec ||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)rr5rrGr2r)rPrs rR _emit_statuszAIAgent._emit_statusWs  LLDO6W66dL C C C C    D    U U$$['::::: U U U Dt TTTTTT U U Us # 00A&A=<A=c t|ddpdt|ddpdt|ddpdt|ddpdt|ddpddS)zBReturn the live main runtime for session-scoped auxiliary routing.r+rr%rr$r&)r+r%rr$r&)rgras rR_current_main_runtimezAIAgent._current_main_runtimekswT7B//52j"55;j"55;tY339rj"55;    rTc |jsdS ddlm}ddlm}|d|\}}||s:d}||_||t ddStt|d d }tt|d d }|j pi d i di}t|tr| d nd} | * t!| } n#t"t$f$rd} YnwxYw||||| } |jj} | | krot!| |jjz dz} d|d| dd| dd| dd| d }||_||t d|| | dSdS#t,$r&} td| Yd} ~ dSd} ~ wwxYw)aWarn at session start if the auxiliary compression model's context window is smaller than the main model's compression threshold. When the auxiliary model cannot fit the content that needs summarising, compression will either fail outright (the LLM call errors) or produce a severely truncated summary. Called during ``__init__`` so CLI users see the warning immediately (via ``_vprint``). The gateway sets ``status_callback`` *after* construction, so ``_replay_compression_warning()`` re-sends the stored warning through the callback on the first ``run_conversation()`` call. Nr)get_text_auxiliary_clientrr) main_runtimeu⚠ No auxiliary LLM provider configured — context compression will drop middle turns without a summary. Run `hermes setup` or set OPENROUTER_API_KEY.uLNo auxiliary LLM provider for compression — summaries will be unavailable.rrr$ auxiliaryr)rr$rr"u⚠ Compression model (z ) context is rz7 tokens, but the main model's compression threshold is u  tokens. Context compression will not be possible — the content to summarise will exceed the auxiliary model's context window. Fix options (config.yaml): 1. Use a larger compression model: auxiliary: compression: model: 2. Lower the compression threshold to fit the current model: compression: threshold: 0.02duAuxiliary compression model %s has %d token context, below the main model's compression threshold of %d tokens — compression summaries will fail or be severely truncated.z4Compression feasibility check failed (non-fatal): %s)rrKrrrrrrr2rlr[rgconfigrrZrrrrYrrrrr)rPrrrE aux_modelr aux_base_url aux_api_key_aux_cfg_aux_context_config aux_contextrsafe_pctrs rRrz,AIAgent._check_compression_model_feasibilityus'  FQ  H H H H H H E E E E E E 9 9!7799!!! FI~Y~D -0)!!#&&&5wvz2>>??Lgfi<<==K )r..{B??CCMSUVVHDNxY]D^D^"h(,,/?"@"@"@dh "./*-.A*B*B''!:.///*.'''/32%#&9 K/@IY&& d.E.T TX[[\\G99G>ct|dd}|r1|jr, |d|dS#t$rYdSwxYwdSdS)uRe-send the compression warning through ``status_callback``. During ``__init__`` the gateway's ``status_callback`` is not yet wired, so ``_emit_status`` only reaches ``_vprint`` (CLI). This method is called once at the start of the first ``run_conversation()`` — by then the gateway has set the callback, so every platform (Telegram, Discord, Slack, etc.) receives the warning. rNr)rgrGr)rPrs rR_replay_compression_warningz#AIAgent._replay_compression_warningsd2D99  4'  $$[#66666        s4 AAcH|p|j}d|vod|vS)z8Return True when a base URL targets OpenAI's native API.zapi.openai.comrl)rr)rPrurls rRrzAIAgent._is_direct_openai_urls0/4/66883&BReturn True for models that require the Responses API path. GPT-5.x models are rejected on /v1/chat/completions by both OpenAI and OpenRouter (error: ``unsupported_api_for_model``). Detect these so the correct api_mode is set regardless of which provider is serving the model. rcrzgpt-5)rrsplitr)r+ms rR_model_requires_responses_apiz%AIAgent._model_requires_responses_apisD KKMM !88a  $A||G$$$rTrkc|pd}|dkr" ddlm}||S#t$rYnwxYwt |S)zCReturn True when this provider/model pair should use Responses API.rcopilotr)!_should_use_copilot_responses_api)rrrJr8rrr5)r+r%normalized_providerr8s rRrz.AIAgent._provider_model_requires_responses_apis (~24466<<>> ) + + OOOOOO88???    44U;;;sA A Ac:|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_tokensrH)rrs rR_max_tokens_paramzAIAgent._max_tokens_params.  % % ' ' 4+U3 3e$$rTrcv|sdS||}t|S)a Check if content has actual text after any reasoning/thinking blocks. This detects cases where the model only outputs reasoning but no actual response, which indicates an incomplete generation that should be retried. Must stay in sync with _strip_think_blocks() tag variants. Args: content: The assistant message content to check Returns: True if there's meaningful content after think blocks, False otherwise F)_strip_think_blocksrr)rPrcleaneds rR_has_content_after_think_blockz&AIAgent._has_content_after_think_blocks> 5**733GMMOO$$$rTc|sdStjdd|tj}tjdd|tjtjz}tjdd|tj}tjdd|tj}tjdd|tjtjz}tjdd|tj}|S) zKRemove reasoning/thinking blocks from content, returning only visible text.rz.*?flagsz.*?z.*?z0.*?z.*?z@\s*)r@rDOTALL IGNORECASE)rPrs rRr>zAIAgent._strip_think_blocks5s 2&.G29MMM&4b'UWUbIbccc&6G29UUU&LbRYacajkkk&2BrySUS`G`aaa&\^`biqsq~rTc||sdS|}|sdS|drdS|ddvS)zCHeuristic: does visible assistant text look intentionally finished?Fz```Tr2u$.!?:)"']}。！？：）】」』》)rr)rstrippeds rR_has_natural_response_endingz$AIAgent._has_natural_response_endingCsX 5>>## 5   U # # 4|FFFrTc|jpd}|jpd}d|vr|dkrdSd|jvs d|jvrdSt |jot |jS)zHDetect the narrow backend family affected by Ollama/GLM stop misreports.rglmzaiFollamaz:11434T)r+rr%rrrr0)rP model_lowerprovider_lowers rR_is_ollama_glm_backendzAIAgent._is_ollama_glm_backendOsz'R..00 --24466  # #%(?(?5 t+ + +x4;O/O/O4DMF&7 &F&FGGGrT finish_reasonrc|dks |jdkrdS|sdStd|pgDsdS|t|ddrdSt|dd}t |t sdS||}|sdSt|dkstj d |sdS| | S) zIDetect conservative stop->length misreports for Ollama-hosted GLM models.stopr\Fc3rK|]2}t|to|ddkV3dSrrNrrrs rRrz:AIAgent._should_treat_stop_as_truncated..dsT   sD ! ! ?cggfoo&?      rTNrrrz\s) r&rOrrgrZr[r>rr\r@rrH)rPrPassistant_messagerr visible_texts rR_should_treat_stop_as_truncatedz'AIAgent._should_treat_stop_as_truncatedYs& F " "dm7I&I&I5**,, 5   B      5  $0A>@@  5 |  r ! !5,)G)G !544\BBBBrT user_messageassistant_contentcF td|DrdS||pd sdSt dkrdSt t jd }|sdSd}d}|pd t fd|Dpd vpd v}t fd |D}t fd |D} |s| o|S) zNDetect a planning/ack message that should continue instead of ending the turn.c3rK|]2}t|to|ddkV3dSrTrrUs rRrz=AIAgent._looks_like_codex_intermediate_ack..s@WWsz#t$$BF)BWWWWWWrTFriu@\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 dSr_ro)rmarker user_texts rRrz=AIAgent._looks_like_codex_intermediate_ack..s(DD)#DDDDDDrTz~/rcc3 K|]}|vV dSr_rorrtassistant_texts rRrz=AIAgent._looks_like_codex_intermediate_ack..s('^'^V.(@'^'^'^'^'^'^rTc3 K|]}|vV dSr_rorws rRrz=AIAgent._looks_like_codex_intermediate_ack..s9* * )/Fn $* * * * * * rT)rr>rrr\rr@r) rPrYrZrhas_future_ackaction_markersworkspace_markersuser_targets_workspaceassistant_mentions_actionassistant_targets_workspacerxrus @@rR"_looks_like_codex_intermediate_ackz*AIAgent._looks_like_codex_intermediate_ackxs WWhWWW W W 5112C2IrJJPPRRXXZZ 5 ~   % %5 IY[i j j   5 *  "'R..006688 DDDD2CDDD D D y  i  %('^'^'^'^~'^'^'^$^$^!&)* * * * 3D* * * ' ' #'E*EdKddrTc~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(.*?)z(.*?)z2(.*?)rB )rLrrrrrZrrrgr[r@rDrEfindallrrV) rPrVreasoning_partsdetailrrinline_patternspatternrCblockr?s rR_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;;// /trTtask_idc t|r |jrtjd|dnt |n8#t $r+}|jrtjd|d|Yd}~nd}~wwxYw t|dS#t $r2}|jr tjd|d|Yd}~dSYd}~dSd}~wwxYw)aHClean up VM and browser resources for a given task. Skips ``cleanup_vm`` when the active terminal environment is marked persistent (``persistent_filesystem=True``) so that long-lived sandbox containers survive between turns. The idle reaper in ``terminal_tool._cleanup_inactive_envs`` still tears them down once ``terminal.lifetime_seconds`` is exceeded. Non-persistent backends are torn down per-turn as before to prevent resource leakage (the original intent of this hook for the Morph backend, see commit fbd3a2fd). z0Skipping per-turn cleanup_vm for persistent env z; idle reaper will handle it.zFailed to cleanup VM for task : Nz#Failed to cleanup browser for task )rr1rrrrrlr)rPrrs rR_cleanup_task_resourceszAIAgent._cleanup_task_resources sU Q )) $'M77777 7### Q Q Q# Q O O OA O OPPP Q V G $ $ $ $ $ V V V# V Tg T TQR T TUUUUUUUUU V V V V V V Vs/>A A6 !A11A6:B C!CCuReview the conversation above and consider saving to memory if appropriate. Focus on: 1. Has the user revealed things about themselves — their persona, desires, preferences, or personal details worth remembering? 2. Has the user expressed expectations about how you should behave, their work style, or ways they want you to operate? If something stands out, save it using the memory tool. If nothing is worth saving, just say 'Nothing to save.' and stop.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|( |!dS#t<$rYdSwxYwdS#|& |!w#t<$rYwwxYwwxYw) NrwrT)r+r,r2rr%)rYconversation_historyrcrrr{}successrrrpcreatedupdatedaddedrrMemoryuserz User profilez updatedz Entry addedremovedreplacedu · u 💾 u💾 z)Background memory/skill review failed: %s)" contextlibrrddevnullredirect_stdoutredirect_stderrrr+rr%rorprqrrrrun_conversationrgrZrrrrJSONDecodeErrorrrrrVfromkeysr rrr2rclose)r_os review_agent_devnullactionsrr]rrplabelr_bg_cbrrpromptrPs rR _run_reviewz5AIAgent._spawn_background_review.._run_review^ s ( ( ( ( ( ( ( (LF #+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!>4!A4HH  s{ F  # # # #c(mm # # # # # #3-C#t$$ *F)B)B!)I $ # * *)B)BrTrc|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)rWrrc_save_session_log_flush_messages_to_session_db)rPrrs rR_persist_sessionzAIAgent._persist_session sa #  F 11(;;;!) x((( **85IJJJJJrTc|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)rr+rrrrrc@g|]}|jj|jjdS)rhr)rrhrrs rRrz9AIAgent._flush_messages_to_session_db.. s:'''"$!1 @UVV'''rTr tool_call_idrP assistantrrcodex_reasoning_items) r<rrrrrrPrrrz$Session DB append_message failed: %s)rgrensure_sessionr<rr+r\rrirrLrrZrappend_messagerr2rl) rPrr start_idx flush_fromrrrtool_calls_datars rRrz%AIAgent._flush_messages_to_session_db sX  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) Nrr2rr)ranger\rcopy)rPrlast_assistant_idxis rR"_get_messages_up_to_last_assistantz*AIAgent._get_messages_up_to_last_assistant s I"s8}}q("b11  A{v&&+55%&"6  %==?? "+++,,rTc|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[]rrh descriptionr parametersN)rhrrrequiredF ensure_ascii)rrrrdumps)rPformatted_toolsrfuncformatted_tools rR _format_tools_for_system_messagez(AIAgent._format_tools_for_system_message sz 4J 3 3D #DV #xx r::"hh|R88 N  " "> 2 2 2 2z/>>>>rT 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': } r)fromrhumanrrrrrrz z r rrz2Unexpected invalid JSON in trajectory conversion: Nr"rhrz Frz z gptrz ){[rr)rrhrz r)rrr\rrrErZrr[rrrrrlrrrrrV)rPrrr trajectory system_msgrrrrrtool_call_jsontool_responsesjtool_msg tool_response tool_content tool_indexr raw_contents rR_convert_to_trajectory_formatz%AIAgent._convert_to_trajectory_format2 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 ]*>([^<]+)rz!HTML error page (title not found)z2Cloudflare Ray ID:\s*]*>([^<]+) status_codezHTTP zRay u — bodyrrrr,) r@r[rrErArrgrrVrZrr) rrrawr4titlerayray_idrrrrprefixs rR_summarize_api_errorzAIAgent._summarize_api_error s0 %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)%%%rTrcb|sdSt|dkrdS|ddd|ddS)Nrz***rrrr\)rPrs rR_mask_api_key_for_logszAIAgent._mask_api_key_for_logs sG 4 s88r>>5bqb'((c"##h(((rT error_msgc|sdS|dsd|vrdSd|}t |dkr |dddz}|S) a Clean up error messages for user display, removing HTML content and truncating. Args: error_msg: Raw error message from API or exception Returns: Clean, user-friendly error message z Unknown errorz> 3$*LLNN!kk),,P >O 6:W#<#<&5 # G # #e****,,K 7%0#%6 " W $ $kk),,2G'3'' V i(Z\cegerss  V!+"3"3A"6"677E0;0A0A!0D0D0J0J0L0LPT0T0TefnnZ_G*.)++*?GJ'' " Z !!I !V.2ikkE)//RSBTBT>GG*&II%$I%rc|dSt|dd}|sdSddlm}t||j|j}||}|dd|j|d<|j|d<|S) zLToken buckets for ``post_api_request`` plugins (no raw ``response`` object).Nusager)asdictr%r& raw_usage prompt_tokens total_tokens) rg dataclassesrr?r%r&poprr)rPrrrcurs rR#_usage_summary_for_api_request_hookz+AIAgent._usage_summary_for_api_request_hookq s  4Hgt44  4&&&&&& Y W W W&** K&&&#%#3 "$/rT)r api_kwargsrc  tj|}|ddd|D}d} t |jdd}n2#t $r%}td|Yd}~nd}~wwxYwtj |j |d|j d|jdkrd nd d ||d d |dd}|t#|jt'|d}dD]} t || d} | | || <t |dd} | | |d<t |dd} | R t | dd|d<| j|d<n2#t $r%}td|Yd}~nd}~wwxYw||d<tj d} |jd|j d| dz }|t1j|ddt&d !||jd"|t9d#r*t;t1j|ddt&|S#t $r)}|jrt?j d$|Yd}~dSd}~wwxYw)%a Dump a debug-friendly HTTP request record for the active inference API. Captures the request body from api_kwargs (excluding transport-only keys like timeout). Intended for debugging provider-side 4xx failures where retries are not useful. timeoutNci|] \}}||| Sr_rorkvs rR z3AIAgent._dump_api_request_debug.. sCCCTQQ]Aq]]]rTr$z,Could not extract API key for debug dump: %sPOSTrcrZz /responsesz/chat/completionszBearer zapplication/json) Authorizationz Content-Type)methodr.rr) timestampr<rrequest)rr)r request_idr paramrrrrresponse_status response_textz,Could not extract error response details: %srz%Y%m%d_%H%M%S_%f request_dump_rrFr)rindentdefaultutf-8encodingu$🧾 Request debug dump written to: HERMES_DUMP_REQUEST_STDOUTz*Failed to dump API request debug payload: )!rdeepcopyr!rrgrErr2rr rZ isoformatr<rrr&rrrjr[rr\r` write_textrrrr5rIrGr1rrl)rPr$rrrr$r dump_payload error_info attr_name attr_value body_attr response_objr/ dump_file dump_errors rR_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)rEr@rr)rs rR_clean_session_contentzAIAgent._clean_session_content sS N-g66&'7;;&)7G<<}}rTc <|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. Nrrrr8r9 message_countrzHSkipping session log overwrite: existing has %d messages, current has %dr) r<r+rrr[ last_updated system_promptrrKrr)r6r7zFailed to save session log: )rcrrrIrrbexistsrr read_textr\rrrr<r+rrr[r=r rZrdrrHr[r1rl)rPrr?rrexisting_countentryrs rRrzAIAgent._save_session_log s5t5  F0 DG $ $776??k11cggi6H6H1s))C%)%@%@Y%P%PC Ns#### $++--  #z$*?*I*ISZ*I*[*[\\H%-\\/3x||T^`bGcGcCdCd%e%eN%G 44 f*CLL 5 !D#o M M!%!3!=!=!?!? (  8 8 : :!%!;!Ar)r!$W#  E %        D D D# D Bq B BCCCCCCCCC D D D D D D Ds>BG" BD=<G"= E G" E  BG"" H,HHcd|_||_|jtd|jd|_nd|_|j5t |j}dddn #1swxYwY|D]J} ||#t$r%}t d|Yd}~Cd}~wwxYw|j s?td|r!t|dkrd|dddn |rd|d nd zdSdS) a Request the agent to interrupt its current tool-calling loop. Call this from another thread (e.g., input handler, message receiver) to gracefully stop the agent and process a new message. Also signals long-running tool executions (e.g. terminal commands) to terminate early, so the agent can respond immediately. Args: message: Optional new message that triggered the interrupt. If provided, the agent will include this in its response context. Example (CLI): # In a separate input thread: if user_typed_something: agent.interrupt(user_input) Example (Messaging): # When new message arrives for active session: if session_has_running_agent: running_agent.interrupt(new_message.text) TNFz0Failed to propagate interrupt to child agent: %su ⚡ Interrupt requested(z: 'z...''r)rrr_set_interruptrr$rr# interruptrr2rr2rGr\)rPr children_copychildrs rRrVzAIAgent.interrupt s0%)!")  $ 0 4!: ; ; ;49D 1 1 59D 1  ' 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*A""A&)A&2B B7B22B7cld|_d|_d|_|jt d|jdSdS)zMClear any pending interrupt request and the per-thread tool interrupt signal.FN)rrrrrUras rRclear_interruptzAIAgent.clear_interruptP sD$)!"&05-  $ 0 5$"; < < < < < 1 0rTdesccDtj|_||_dS)zAUpdate the last-activity timestamp and description (thread-safe).N)r*r+r,)rPr[s rR_touch_activityzAIAgent._touch_activityX s!%#'   rT http_responsec|dSt|dd}|sdS ddlm}|||j}| ||_dSdS#t $rYdSwxYw)zParse x-ratelimit-* headers from an HTTP response and cache the state. Called after each streaming API call. The httpx Response object is available on the OpenAI SDK Stream via ``stream.response``. Nrr)parse_rate_limit_headersrk)rgagent.rate_limit_trackerr`r%r/r)rPr^rr`states rR_capture_rate_limitszAIAgent._capture_rate_limits] s  F-D99  F  I I I I I I,,Wt}MMME ).&&&!     DD s!A A Ac|jS)z1Return the last captured RateLimitState, or None.)r/ras rRget_rate_limit_statezAIAgent.get_rate_limit_statep s %%rTc tj|jz }|j|jt|d|j|j|j|jj|jj dS)zReturn a snapshot of the agent's current activity for diagnostics. Called by the gateway timeout handler to report what the agent was doing when it was killed, and by the periodic "still working" notifications. r)last_activity_tslast_activity_descseconds_since_activity current_toolapi_call_countr, budget_used budget_max) r*r+r,roundr-r.r,rRrr{)rPelapseds rRget_activity_summaryzAIAgent.get_activity_summaryt sc )++ 66 $ 6"&":&+GQ&7&7 ."2"105/9   rTch|jrY |j|pgn#t$rYnwxYw |jn#t$rYnwxYwt |dr?|jr: |j|jpd|pgdS#t$rYdSwxYwdSdS)uCShut down the memory provider and context engine — call at actual session boundaries. This calls on_session_end() then shutdown_all() on the memory manager, and on_session_end() on the context engine. NOT called per-turn — only at CLI exit, /reset, gateway session expiry, etc. rrN)rxon_session_endr shutdown_allrLrr<rPrs rRshutdown_memory_providerz AIAgent.shutdown_memory_provider s!    $33HNCCCC     $113333     4- . . 43J  '66O)rN         s/& 33A AA9$B B-,B-ct|jsdS |j|pgdS#t$rYdSwxYw)uTrigger end-of-session extraction without tearing providers down. Called when session_id rotates (e.g. /new, context compression); providers keep their state and continue running under the old session_id — they just flush pending extraction now.N)rxrrrrts rRcommit_memory_sessionzAIAgent.commit_memory_session s\ #  F   / /B ? ? ? ? ?    DD s ) 77ct|ddpd} ddlm}||n#t$rYnwxYw ddlm}||n#t$rYnwxYw ddlm}||n#t$rYnwxYw |j 5t|j }|j dddn #1swxYwY|D]'} | #t$rY$wxYwn#t$rYnwxYw t|d d}|!||d d d|_dSdS#t$rYdSwxYw) aRelease all resources held by this agent instance. Cleans up subprocess resources that would otherwise become orphans: - Background processes tracked in ProcessRegistry - Terminal sandbox environments - Browser daemon sessions - Active child agents (subagent delegation) - OpenAI/httpx client connections Safe to call multiple times (idempotent). Each cleanup step is independently guarded so a failure in one does not prevent the rest. r<Nrr)process_registryr)rrrE agent_closeTr)rgtools.process_registryrykill_allrtools.terminal_toolrtools.browser_toolrr$rr#clearr_close_openai_clientrE)rPrryrrchildrenrXrEs rRrz AIAgent.close sa$ d339r  ? ? ? ? ? ?  % %g % 6 6 6 6    D   6 6 6 6 6 6 Jw        D   : : : : : : OG $ $ $ $    D  + . . 566%++--- . . . . . . . . . . . . . . ."  KKMMMM D      D  T8T22F!))&t)TTT" "!    DD s2 ??A A"!A"&A88 BB D.C > D CDCDC/.D/ C<9D;C<<D D  D 2E EEhistorycd}t|D]}|ddkr|dd}d|vr7 tj|}d|vr%t |dt r |d}nv#tjtf$rYwxYw|rP|j |d |j s-| |j d t|d tddS) a Recover todo state from conversation history. The gateway creates a fresh AIAgent per message, so the in-memory TodoStore is empty. We scan the history for the most recent todo tool response and replay it to reconstruct the state. Nrrrrz"todos"todosF)mergeu📋 Restored z todo item(s) from history)reversedrrrrZrrrrnrWr2rr5r\rU)rPrlast_todo_responserrr]s rR_hydrate_todo_storezAIAgent._hydrate_todo_store 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.rras rRis_interruptedzAIAgent.is_interrupted s ((rTsystem_messagec d}jst}|r|g}d}|stg}g}djvr|t djvr|t djvr|t|r(|d|tj}|r||jroj }d}|dus+t|tr| dvrd}n|dus+t|tr| dvrd}nt|tr7jpd t!fd |D}n;jpd t!fd t"D}|ry|t$jpd } d | vsd | vr|t&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 |dj%z }||j%d krQd!jvr j&d!d"nj}|d#|d$jd%tO}|r||j(pd )}|tTvr |tT|d&d'|DS)(a; Assemble the full system prompt from all layers. Called once per session (cached on self._cached_system_prompt) and only rebuilt after context compression events. This ensures the system prompt is stable across all turns in a session, maximizing prefix cache hits. FTrr skill_managerY)ralwaysron)falsenevernooffrc3nK|]/}t|t|vV0dSr_)rZr[rrprMs rRrz/AIAgent._build_system_prompt..P sA__1JWXZ]L^L^_aggii;6______rTc3 K|]}|vV dSr_rors rRrz/AIAgent._build_system_prompt..T s(TT1a;.TTTTTTrTgeminigemmarcodexNrc3*K|] }|jvVdSr_)rX)rrhrPs rRrz/AIAgent._build_system_prompt..| s+wwtt'<<wwwwwwrT)rrrch|]}||Sroro)rtoolsets rRrz/AIAgent._build_system_prompt..~ s0 rTc34K|]}t|VdSr_)r)rrs rRrz/AIAgent._build_system_prompt.. s<  8A(33      rT)available_toolsavailable_toolsetsr)r skip_soulr)rZzConversation started: z%A, %B %d, %Y %I:%M %pz Session ID: z Model: z Provider: alibabarcr2z#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.rc3fK|],}||V-dSr_rrrs rRrz/AIAgent._build_system_prompt.. s7HHaggiiH17799HHHHHHrT)+rOr8r"rXrr$r%r&rVr'rrZr[rrr+rr:r9r<r=rorpformat_for_system_promptrqrxbuild_system_promptrr5rrr6 hermes_timerZr\rVr<r%rr7rrr#)rPr _soul_loaded _soul_content prompt_parts tool_guidancenous_subscription_prompt_enforce_inject _model_lower mem_block user_block_ext_mem_blockhas_skills_toolsavail_toolsets skills_prompt _context_cwdcontext_files_prompt _hermes_nowrZtimestamp_line _model_short _env_hints platform_keyrMs` @rR_build_system_promptzAIAgent._build_system_prompt so$ & $(NNM $ - #  423L t, , ,   1 1 1 t4 4 4  !8 9 9 9 T2 2 2   1 1 1  9    7 7 8 8 8#A$BW#X#X # :    8 9 9 9   I1HG4Jx$=$=(..BRBRVuBuBuU""z(C'@'@"X^^EUEUYxExExHd++ U#z/R6688 _________ $z/R6688 TTTT8STTTTT I##$ABBB $ 0b7799 |++w,/F/F ''(IJJJL((G|,C,C ''(GHHH  %    / / /   4# 3 .GGQQ 3 '' 222) 4!/HHPP 4 '' 333    !%!5!I!I!K!K!8 ''777    wwwwIvwwwww    EIEZ   N7 $ 5#1MM M  /    . . .& : 9^44<L#= L$:$:$: # :##$8999222222kmmZ#,,?W2X2XZZ   ADO A @t@@ @N : 7 6$*66 6N = = l>>)->>>   -..  ,    + + + +2244::<< > ) )   | < = = ={{HHlHHHHHHs80L)) L65L6ct|tr|ddpdSt|ddpdS)z8Extract call ID from a tool_call entry (dict or object).rr)rZrrrg)rs rR_get_tool_call_id_staticz AIAgent._get_tool_call_id_static sF b$   *66$##)r )r4$$**rT>rrrrr developercH g}|D]V}|d}|tjvrtd|A||W|}t }|D]f}|ddkrK|dpgD]3}t|}|r||4gt }|D]G}|ddkr,|d}|r||H||z r6 fd|D}tdt ||z }|rg} |D]}| ||ddkrQ|dpgD]9}t|}||vr| dd |d :| }td t||S) u Fix orphaned tool_call / tool_result pairs before every LLM call. Runs unconditionally — not gated on whether the context compressor is present — so orphans from session loading or manual message manipulation are always caught. rz9Pre-call sanitizer: dropping message with invalid role %rrrrrctg|]4}|ddkr|dv2|5Srrrr)rr4orphaned_resultss rRrz2AIAgent._sanitize_api_messages.. sOf //AEE.4I4IM]4]4]4]4]4]rTz6Pre-call sanitizer: removed %d orphaned tool result(s)u2[Result unavailable — see context summary above]rrrz0Pre-call sanitizer: added %d stub tool result(s)) rr_VALID_API_ROLESr2rrrWrrr\) rfilteredrrsurviving_call_idsrcidresult_call_idsmissing_resultspatchedrs @rR_sanitize_api_messageszAIAgent._sanitize_api_messages s ! !C776??D7333 O OOC "%%% 4 4Cwwv+--'',//5244B!::2>>C4*..s333"uu - -Cwwv&((ggn---#'',,,+-??  #H LLH$%%    ->  ,.G  s###776??k11!ggl339r%>>rBB/11#NN(.+_03,, H LLBO$$   rTrcDddlm}|}td|D}||kr|Sd}g}|D]H}|jjdkr!||kr|||dz }3||It d||z ||S)ajTruncate excess delegate_task calls to max_concurrent_children. The delegate_tool caps the task list inside a single call, but the model can emit multiple separate delegate_task tool_calls in one turn. This truncates the excess, preserving all non-delegate calls. Returns the original list if no truncation was needed. r)_get_max_concurrent_childrenc3:K|]}|jjdkdVdS) delegate_taskrNrrs rRrz3AIAgent._cap_delegate_task_calls..s1[[2r{7G?7Z7ZQ7Z7Z7Z7Z[[rTrrzUTruncated %d excess delegate_task call(s) to enforce max_concurrent_children=%d limit)tools.delegate_toolrsumrrhrr2rl)rr max_childrendelegate_countkept_delegates truncatedrs rR_cap_delegate_task_callsz AIAgent._cap_delegate_task_callss EDDDDD3355 [[[[[[[ \ ) )   % %B{?22!L00$$R((("a'N  $$$$ / \ )<   rTcLt}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) rWrrhrrrr2rlr\)rseenuniquerrs rR_deduplicate_tool_callszAIAgent._deduplicate_tool_calls.sEE T TB;#R[%:;C$  b!!!!@"+BRSSSSVs:66vvJFrTrcddlm}|}||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-rrYrgffffff?)ncutoffN)difflibrrrXreplace)rPrrlowered normalizedmatchess rR_repair_tool_callzAIAgent._repair_tool_call@s .-----//## d+ + +N__S#..66sC@@ . . . $#GT-BaPSTTT  1: trTcXd|_|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)rdrorwras rR_invalidate_system_promptz!AIAgent._invalidate_system_prompt\s<&*"   0   - - / / / / / 0 0rTrc ||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.NrrhrrFrrN)r propertiesrrhrstrictr)rrZrrr[rr)rPr source_tools converteditemrrhs rR_responses_toolszAIAgent._responses_toolsgs % 1uutz  4*,   D-7d-C-CK*b)))B66&>>DdC((      "!vvmR88 ff\HTV3W3WXX      D rTrrrindexcddl}|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:r8rrrcall_)hashlibsha256r hexdigest)rrrrseeddigests rR_deterministic_call_idzAIAgent._deterministic_call_id|so //I//// GI F FGGQQSSTWUWTWXvrTraw_idc4t|tsdS|}|sdSd|vrI|dd\}}|pd}|pd}||fS|drd|fS|dfS)z8Split a stored tool id into (call_id, response_item_id).NN|rNfc_)rZr[rrr)rrcall_idresponse_item_ids rR_split_responses_tool_idz AIAgent._split_responses_tool_ids&#&& :  : %<<(- C(;(; %G%mmoo-G/5577?4 ,, ,   E " " ; d{rTrrcrt|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_`).rrrNz[^A-Za-z0-9_-]0r8)rZr[rrr\r@rr]r^r_rsha1rr)rPrr candidaterrrrs rR"_derive_responses_function_call_idz*AIAgent._derive_responses_function_call_ids & , , !(..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~~rTc \ g}t}|D]}t|ts|d}|dkr5|dvr|dd}|t |nd}|dkr|d}d } t|t r|D]} t| tr}| d rh| d } | r| |vrHd | D} || | r|| d } | r|d|dn| r|ddd|d} t| t r\| 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.rr>rrrrNrrFencrypted_contentrc&i|]\}}|dk ||S)rror(s rRr+z=AIAgent._chat_messages_to_responses_input..s$.X.X.X1aSWiiq!iiirTTrrrrrhrrrrrr function_callrrrhrrrfunction_call_outputrroutput)rWrZrrr[rrrrrrrr\rrr)rPrr seen_item_idsrrr content_textcodex_reasoninghas_codex_reasoningriitem_id replay_itemrrrrembedded_call_idembedded_response_item_idr _raw_argsrraw_tool_call_idrs rR!_chat_messages_to_responses_inputz)AIAgent._chat_messages_to_responses_inputsE&( UU d d Cc4(( 776??Dx,,,'')R00/6/Bs7||| ;&&'*gg.E&F&FO*/'!/488;"1 ; ;B)"d33 ;?R8S8S ;*,&&,,#*!-w-/G/G$, /Y.X .X.X.X % [ 9 9 9#*!?$1$5$5g$>$>$>6: 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??  rT raw_itemsc t|tstdg}t}t |D]\}}t|t std|d|d}|dkr^|d}|d}t|tr|std|dt|tr|std|d |d d } t| t rtj | d } n$t| tst| } | pd } | d||| d|dkr|d}t|tr|std|d|dd} | d} t| tst| } | d|| dj|dkr|d} t| tr| r|d} t| tr| r| |vr| | d| d} |d}t|tr|| d<ng| d<| | 4|d}|dvrX|dd}|d}t|tst|}| ||dtd|d|d|d|S) Nz4Codex Responses input must be a list of input items.zCodex Responses input[] must be an object.rrrrhz#] function_call is missing call_id.z ] function_call is missing name.rrFrrrz*] function_call_output is missing call_id.rrrrrrrrrr>rrrrz#] has unsupported item shape (type=z, role=).) rZrrYrWrrrr[rrrrr)rPr#rseen_idsrr item_typerrhrr encryptedrreasoning_itemrrrs rR_preflight_codex_input_itemsz$AIAgent._preflight_codex_input_items$s>)T** USTT T+- "9--S S 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"hhtnnG!'3//.G."h..$ W---.9PY%Z%ZN #hhy11G!'40074;y1146y1%%n55588F##D,,,((9b11? G!'3//+!'llG!!4G"D"DEEEoooQZooeiooo rT allow_streamr.c | 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|t r+|r||d!<d"}t|ttfr|d#krt||d"<d$}t|ttfrt||d$<d%D]}|}||||<d&}|t|tstd'i}|D]d\}}t|t r|std(|@t |||<e|r||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| Sroro)rrr$s rRrz7AIAgent._preflight_codex_api_kwargs..s#DDD3c.C.C3.C.C.CrTz3Codex Responses request missing required field(s): r.r+z;Codex Responses request 'model' must be a non-empty string.r1rr0rz=Codex Responses request 'tools' must be a list when provided.zCodex Responses tools[r%rrz] has unsupported type rhrz] is missing a valid name.z] is missing valid parameters.rrFrstorez6Codex Responses contract requires 'store' to be false.>r0r+r4rincluder temperature tool_choicer1rJ extra_headersprompt_cache_keymax_output_tokensparallel_tool_calls)r+r1r0r4rr5rJr:rr6)r7r;r9r8z:Codex Responses request 'extra_headers' must be an object.zGCodex Responses request 'extra_headers' keys must be non-empty strings.rwTz/Codex Responses 'stream' must be true when set.zKCodex Responses stream flag is only allowed in fallback streaming requests.c3$K|] }|v|V dSr_ro)rr allowed_keyss rRrz6AIAgent._preflight_codex_api_kwargs..s-QQCL9P9PC9P9P9P9PQQrTz2Codex Responses request has unsupported field(s): )rZrrYrVrYrr[rr"r,rrrrrrrr) rPr$r.rmissingr+r1normalized_inputrnormalized_toolsrrrhrrrr4rrr5rJr:r6passthrough_keyvalr8normalized_headersrrrw unexpectedr=s ` @rR_preflight_codex_api_kwargsz#AIAgent._preflight_codex_api_kwargss *d++ HFGG G555DDDD(DDD  rpSWS\S\]cdk]l]lSmSmpppqq qw''%%% \U[[]] \Z[[ [ !~~n55  L,,, -|,,L#))++E/E <\-?-?-A-A >)5););)=)=J~ &'NN+>?? '#u 6 6 E;Lq;P;P.12C.D.DJ* + nn]33 kC< 0 0 ;(-k(:(:J} % Z 2 2O..11C.1 ?+"77  $mT22 _ !]^^^13 +1133 = = U!#s++p399;;p$%nooo=25e**"399;;//! A.@ ?+  l^^H--F!fD&8&8 !RSSS~~'+ 8$   X & & & &  # #jkk kQQQQ:QQQQQ  ]TYYzEZEZ]]] rTrcTt|dd}t|tsdSg}|D]U}t|dd}|dvrt|dd}t|tr|r||Vd|S)zr output_textrrgrZrr[rrVr)rPrrchunksrptypers rR_extract_responses_message_textz'AIAgent._extract_responses_message_texts$ 400'4(( 2 $ $DD&$//E3334..D$$$ $ $ d###wwv$$&&&rTct|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.rNrrrrH)rPrrrIrrs rR!_extract_responses_reasoning_textz)AIAgent._extract_responses_reasoning_text s$ 400 gt $ $ 1 "F ( (tVT22dC(((T(MM$''' 1yy((..000tVT** dC  T ::<< rrTc bt|dd}t|tr|st|dd}t|tr|rxt dt|tdddtd|g g}||_ ntd t|d d}t|tr'| }nd}|d vrqt|d d}t|tr%| dpt|}n|rt|nd|d}t|g}g}g} g} |dv} d} d} |D]}t|dd}t|d d}t|tr'| }nd}|dvrd} |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|dvrt|dd pd }t|d!d"}t|tst#j|d#}t|d$d}t|dd}||\} }!t|tr|r|n| }"t|"tr|"s$|||t| }"|"}"t|tr|nd}#||"|#}#| t|"|"|#d%t||&'|d(kr|t|dd pd }t|d)d"}t|tst#j|d#}t|d$d}t|dd}||\} }!t|tr|r|n| }"t|"tr|"s$|||t| }"|"}"t|tr|nd}#||"|#}#| t|"|"|#d%t||&'d*d+|D}$|$sJt/|dr:t|dd }t|tr|}$t|$| |r'd,|nddd| pd-}%| rd.}&n| s| r| sd/}&n | r|$sd/}&nd0}&|%|&fS)1zENormalize a Responses API object to an assistant_message-like object.rNrGz`Codex response has empty output but output_text is present (%d chars); synthesizing output item.rrrrrrrstatusrz&Responses API returned no output itemsrQ>failed cancelledrzResponses API returned status 'rT>queued incomplete in_progressFrTphase>analysis commentary>final final_answerrrr&rrr summary_textrrhrrrrrrrrrrrrcustom_tool_callr0rcg|]}||Srorors rRrz5AIAgent._normalize_codex_response..s>>>aA>>>>rTr)rrrrrrrrUrR)rgrZrr[rr2rr\rrrPrrrrKrrMrrrrr rVrL)'rPrrout_textr3 error_objr content_partsrreasoning_items_rawrhas_incomplete_itemssaw_commentary_phasesaw_final_answer_phaserr) item_status item_phasenormalized_phase message_textreasoning_textr*raw_itemrr raw_summaryrrrr raw_call_id raw_item_idrrrr final_textrVrPs' rR_normalize_codex_responsez!AIAgent._normalize_codex_response0s{8T22&$'' Mv Mx==H(C(( MX^^-=-= M 014X^^5E5E1F1F*"[,-hnnFVFVWWWX#)"#KLLL!(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 -//rTcJtj}|jd|jS)Nr)r~current_threadrhident)rPthreads rR_thread_identityzAIAgent._thread_identitys()+++.. ...rTct|dd}t|dd}t|dd}d|d|d|d|S) Nr%rrr+zthread= provider=z base_url=z model=)rgrv)rPr%rr+s rR_client_log_contextzAIAgent._client_log_contexts}4Y774Y77gy11 1d++-- 1 1 1 1  1 1). 1 1 rTc`t|dd}|tj}||_|S)Nr!)rgr~r r!)rPlocks rR_openai_client_lockzAIAgent._openai_client_locks2t^T22 <?$$D $D  rTrEcddlm}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.mockrrZrgcallabler)rEris_closed_attr http_clients rR_is_openai_client_closedz AIAgent._is_openai_client_closeds '&&&&& fd # # 5 d;;  %'' !>## 4 n%% tfi66  " [%@@AA AurTrrc@ddlm}m}t|}|||d|jdks6t |dddr?ddlm }|di|}t d||| |S|jd ks6t |ddd r]dd l m}d |D} |di| }t d ||| |Sd|vr ddl} ddl} | j| jdfg} t)| drg| | j| jdf| | j| jdf| | j| jdfn2t)| dr"| | j| jdf| | | |d<n#t:$rYnwxYwt=di|}t d||| |S)Nr)_validate_base_url_validate_proxy_env_urlsrrirrj)CopilotACPClientz-Copilot ACP client created (%s, shared=%s) %szgoogle-gemini-clizcloudcode-pa://)GeminiCloudCodeClientc"i|] \}}|dv || S)>r$r&r project_idrror(s rRr+z1AIAgent._create_openai_client.."s4A[[[1[[[rTz:Gemini Cloud Code Assist client created (%s, shared=%s) %srr TCP_KEEPIDLErr TCP_KEEPALIVE)socket_options) transportz(OpenAI client created (%s, shared=%s) %sro)rKrrrrr%r[ragent.copilot_acp_clientrr2r3ryagent.gemini_cloudcode_adapterrrhttpxsocket SOL_SOCKET SO_KEEPALIVErLr IPPROTO_TCPr TCP_KEEPINTVL TCP_KEEPCNTrClient HTTPTransportrr) rPrrrrrrrEr safe_kwargs_httpx_socket _sock_optss rRrQzAIAgent._create_openai_clients?WWWWWWWW]++   """=,,Z88999 =M ) )S1B1B:r1R1R-S-S-^-^_n-o-o ) A A A A A A%%66 66F KK?((**     M =/ / /3}7H7HUW7X7X3Y3Y3d3dev3w3w / L L L L L L!.!4!4!6!6K+*99[99F KKL((**     M$  - - &&&&((((&173GKL 7N33X%%w':Gvw55<"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)NrETrz7Failed to rebuild shared OpenAI client (%s) %s error=%sFzreplace:) r|rgrQrFrr2rlryrEr)rPr old_client new_clientrs rR_replace_primary_openai_clientz&AIAgent._replace_primary_openai_clientsU  % % ' ' % % x66J !778KTZcg7hh    M,,..  uuu % % % % % % % % %DK % % % % % % % % % % % % % % % !!*5H5H5HQU!VVVts:B+AB+ B/B?B+B B++B/2B/c|5t|dd}|#||s|cdddSdddn #1swxYwYtd|||d|std|5|jcdddS#1swxYwYdS)NrEzCDetected closed shared OpenAI client; recreating before use (%s) %szrecreate_closed:rz'Failed to recreate closed OpenAI client) r|rgrr2rlryrrPrE)rPrrEs rR_ensure_primary_openai_clientz%AIAgent._ensure_primary_openai_clients  % % ' '  T8T22F!$*G*G*O*O!                         Q   $ $ & &   22:UV:U:U2VV JHII I  % % ' '  ;                  s#*AAA C!!C%(C%c,t|dd}|dS t|dd}|dSt|dd}|dSt|dd}|dSt|ddpt|ddpg}d}t|D]}t|d dpt|d d}|(t|d d} | $t|d d} | t| d d} | bddl} | d| d | j| jz} | dkr|d z }n #t$rYnt$r|d z }YnwxYw | d#t$rYwxYw# | dw#t$rYwwxYwxYw|dkr3t d|| ddSn2#t$r%} t d| Yd} ~ nd} ~ wwxYwdS)aYDetect and clean up dead TCP connections on the primary client. Inspects the httpx connection pool for sockets in unhealthy states (CLOSE-WAIT, errors). If any are found, force-closes all sockets and rebuilds the primary client from scratch. Returns True if dead connections were found and cleaned up. rENFrrrrrrrrrwrrTTu@Found %d dead connection(s) in client pool — rebuilding clientdead_connection_cleanuprzDead connection check error: %s)rgrr setblockingrecvMSG_PEEK MSG_DONTWAITBlockingIOErrorrXr2rlrrr) rPrErrrr dead_countrrwrrr]rs rR_cleanup_dead_connectionsz!AIAgent._cleanup_dead_connectionssx.. >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)Nrr~rFr)rrrrZr|rrFrQ)rPrrprimary_clientrequest_kwargss rR_create_request_openai_clientz%AIAgent._create_request_openai_clients&&&&&&;;6;JJ nd + + "! !  % % ' ' 7 7!$"566N 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7)).PU)VVVsA$$A(+A(c6|||ddS)NFr)r)rPrErs rR_close_request_openai_clientz$AIAgent._close_request_openai_clients# !!&!FFFFFrTon_first_deltac ddl}|p|d}d}d}d}g|_t|dzD]8} g} |jjd'i|5} | D]} |d|jrnzt| dd } d | vs| d krit| d d }|r|j ||r9|s7|s d }|r |n#t$rYnwxYw| |d| vrd }d| vr-d | vr)t| d d }|r| || dkr*t| dd}|| || dvrt| dd}|rt|ddnd}|rt|ddnd}td| ||td|jD|| }t|dd}t%|t&r|s| r=t'| |_tdt-| n|jr|s~d |j}t1dddt1d|gg|_td t-|jt-||cdddcS#1swxYwY#|j|j|jt8f$r}| |kr.]s(#T#TqCFF#T#T#T#T#T#TrTrz;Codex stream: backfilled %d output items from stream eventsrrrrGrOrPz?Codex stream: synthesized output from %d text deltas (%d chars)zNCodex Responses stream transport failed (attempt %s/%s); retrying. %s error=%szYCodex Responses stream transport failed; falling back to create(stream=True). %s error=%s)rEresponse.completedzGResponses stream closed before completion (attempt %s/%s); retrying. %szYResponses stream did not emit response.completed; falling back to create(stream=True). %sro) rr_codex_streamed_text_partsr responsesrwr]rrgrr_fire_stream_delta_fire_reasoning_deltar2rlrryget_final_responserZrrrr\rVrRemoteProtocolError ReadTimeout ConnectErrorConnectionError!_run_codex_create_stream_fallbackrPr[)rPr$rErr active_clientmax_stream_retrieshas_tool_callsfirst_delta_firedattemptcollected_output_itemsrwevent event_type delta_textrk done_itemresp_objrQrfinal_response_out assembledrerr_textmissing_completeds rR_run_codex_streamzAIAgent._run_codex_stream!s3b$"D"DLa"D"b"b !13'/!344m m G+- "k 3],3AAjAAH*V!'..,,-HIII4"!E%,UFB%?%? .*<< Nj@j@j)0)D)DJ)S $ ? F Fz R R R)D.D'8!18<$5'5%1)1,:N,<,<,<, J J J (+FFF(/vt(D(DI(4 6 = =i H H H'+UUU'.uj$'G'GHJR%\WXx%F%F%FX\Fbj1tCWY]1^1^1^pt."NN!\ *F4F ##T#TD4S#T#T#T T T $ 8 8 : : &,%>%>%@%@N#>8TBBD!$--d1489O4P4PN1"LL ] #$: ; ;"< ^ (*0O(P(PI5D%.%0'2)8mR[)\)\)\(] 6665N1 #LL a #D$C D Dc)nn*QH*H*H*H*H*H*H*H*H*H*H*H*H*H*H*H*H*H*H*R.0BFDWYhi ` ` `///LLh! *Q.0022 HHHH o,,.. ==jQ^=__________   s88$8H$D!$3E)E)ELLa! *Q.0022  HHHH$dLLs0022 AA*UbAcccccccccc# ym m sLA7L CL C$ !L#C$ $HL6 LL L L LQ3/rrrrz1Codex fallback stream: backfilled %d output itemsrrrrGrOrPz 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: %sr$rrcrnous_credential_refreshrT)r&r%rNrrrrrrrr2rrrZr[rr$rrrFr!r)rPr rrrr$rs rR$_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]rCFrbr)r|r{z'Anthropic credential refresh failed: %srDz?Failed to rebuild Anthropic client after credential refresh: %srT)r&rLr%r?r|r{rr2rrZr[rrCr=rrgrlrr>)rPr|r{ new_tokenrrs rR)_try_refresh_anthropic_client_credentialsz1AIAgent._try_refresh_anthropic_client_credentials*s =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;cFddlm}|pd}d|vrt||jd<dSd|vrddlm}||jd<dSd|vrd d i|jd<dSd |vrt|jd<dS|jdddS) Nr) _OR_HEADERSrrlrrrrr rr) rKrrrrFrJrrr!)rPrrrrs rR"_apply_client_headers_for_base_urlz*AIAgent._apply_client_headers_for_base_urlQs666666n"++-- : % %59+5F5FD  1 2 2 2 $ 2 2 A A A A A A5L5L5N5ND  1 2 2 2 z ) )6BDT5UD  1 2 2 2  + +5I5K5KD  1 2 2 2   # #$5t < < < < r$rZr[rrFrr)rPrQ runtime_key runtime_baser{rs rR_swap_credentialzAIAgent._swap_credentialbse%6==cP^`bAcAc u&8$??t75R\^bCcCctgkgt =0 0 0 W W W W W W W W &,,....    '2D #'3D $%;%;K%V%VD "'6{'C'CD $&DL(DM F" 4>|S4Q4Qc ++C000Wc )-I&*.-J' // >>> ++3H+IIIIIs A:: BB)classified_reason error_contextrhas_retried_429rrc  |j}|d|fS|}|8|dkr tj}n%|dkr tj}n|dkr tj}|tjkre||nd}|||}|Bt d|t|dd | |d Sd|fS|tjkrg|sd S||nd}|||}|Bt d |t|dd | |d Sd S|tjkr| } | Et d t| dd | | d|fS||nd}|||}|Bt d|t|dd | |d Sd|fS)aAttempt credential recovery via pool rotation. Returns (recovered, has_retried_429). On rate limits: first occurrence retries same credential (sets flag True). second consecutive failure rotates to next credential. On billing exhaustion: immediately rotates. On auth failures: attempts token refresh before rotating. `classified_reason` lets the recovery path honor the structured error classifier instead of relying only on raw HTTP codes. This matters for providers that surface billing/rate-limit/auth conditions under a different status code, such as Anthropic returning HTTP 400 for "out of extra usage". NFi)rru4Credential %s (billing) — rotated to pool entry %sr?)TF)FTu7Credential %s (rate limit) — rotated to pool entry %su1Credential auth failure — refreshed pool entry Tu@Credential %s (auth refresh failed) — rotated to pool entry %s) rr!billing rate_limitauthmark_exhausted_and_rotater2r3rgrtry_refresh_current) rPrrrrreffective_reason rotate_status next_entry refresheds rR_recover_with_credential_poolz%AIAgent._recover_with_credential_pool}sx,$ </) ),  #c!!#1#9  ###1#<  ###1#6 ~5 5 5+6+BKKM77Man7ooJ% J!Jc22 %%j111"{/) ) ~8 8 8" #"{+6+BKKM77Man7ooJ% M!Jc22 %%j111"{; ~2 2 20022I$ oPWXacgilPmPmooppp%%i000_,,,7+BKKM77Man7ooJ% V!Jc22 %%j111"{o%%rTcn|jdkr||jjjdi|S)Nr]ro)r&r r=rr)rPr$s rR_anthropic_messages_createz"AIAgent._anthropic_messages_createsA =0 0 0  : : < < <5t%.5CC CCCrTc xdddddifd}ttjdd}tddpd}|dkr!|rt |rtd }n`t d d gDd z}|d krt|d}n|dkrt|d}n|}tj} dtj |d}| d} | r|d| dz } | dzdkr._calls; a=$5556:6X6X`v6X6w6w)(3)-)?)?"4X>'.t5Ld'S'S*@**F:&& ]&:::)-)H)H)T)TF:&&]&888(^^,@+NNFNN#94@@@88@@F#26?#@#@Z#@#@L)D)D\)R)RF:&&6:6X6X`y6X6z6z)(3)`)>x)H)M)Y)`)n)ncm)n)nF:& $ $ $"#w $"7!:!:8!D!D!-55nM_5`````.-"7!:!:8!D!D!-55nM_5````.s0DDE* D5&D0+E*0D55E**1FHERMES_API_CALL_STALE_TIMEOUTr@rrinfc3NK|] }tt|V!dSr_r\r[rr*s rRrz2AIAgent._interruptible_api_call...RRac#a&&kkRRRRRRrTr順g@Pg |@z&waiting for non-streaming API responseTror333333?r&rr"z$waiting for non-streaming response (z s elapsed)c3NK|] }tt|V!dSr_rErFs rRrz2AIAgent._interruptible_api_call..0.SSqs3q66{{SSSSSSrTzjNon-streaming API call stale for %.0fs (threshold %.0fs). model=%s context=~%s tokens. Killing connection.r+rr%⚠️ No response from provider for zs (non-streaming, model: z). Aborting call.r]r{rDstale_call_killrz&stale non-streaming call killed after s@rrz'Non-streaming API call timed out after zs with no response (threshold: s)interrupt_abortz!Agent interrupted during API call)rrrrgr0rrrr*r]r~rris_aliverVrr2rlrr&r?r{r=rrCrr TimeoutErrorrInterruptedError)rPr$r@ _stale_baser_stale_timeout _est_tokens _call_startr _poll_count_elapsed_est_ctxr{rcr=r>r?s`` @@rR_interruptible_api_callzAIAgent._interruptible_api_calls(#T22!)4 0 a a a a a a a aLBI&EuMMNN D+t44: %  I 2CI2N2N "5\\NNRR:>>*b3Q3QRRRRRVWWKW$$!$[%!8!8v%%!$[%!8!8!,ikk  EFFF  E$ 7 7 7   jjllJ L FF3F    1 KS A%%9;;4$$T3x==TTT y{{[0H.((SSJNN:r4R4RSSSSSWXXGnNN7I668  !!&CMM&&.8nnWi.P.P&&& }(<<<RRRRRR.446661G1G 3#D*?FF22.. 366x@@> ==bIZ=[[[ D$$MS]]MMMs###'?*vj/A/I&2P#h--PP8;N8K8KPPP''F7O( L}(<<<RRRRRR.446661G1G 3#D*?FF22.. *?)B)B8)L)L)5 ==nUf=ggg D&'JKKKUjjllJ LV '? &/ !j!!s&A>K K&%K&1A>O00 O=<O=cd|_dS)zDReset tracking for text delivered during the current model response.rN)r9ras rR_reset_stream_delivery_trackingz'AIAgent._reset_stream_delivery_trackingqs02---rTrcnt|tr|rt|dd|z|_dSdSdS)zCAccumulate visible assistant text emitted through stream callbacks.r9rN)rZr[rgr9)rPrs rR_record_streamed_assistant_textz'AIAgent._record_streamed_assistant_textusR dC  T @"EEL  1 1 1    rTct|tsdStjdd|S)Nrz\s+rY)rZr[r@rrrs rR_normalize_interim_visible_textz'AIAgent._normalize_interim_visible_text|s9$$$ 2vfc4((..000rTc |||pd}|sdS||t|ddpd}t|o||kS)NrFr9)rgr>rgr)rPrvisible_contentstreameds rR_interim_content_was_streamedz%AIAgent._interim_content_was_streameds>>  $ $W] 3 3   577  $ $WT3UWY%Z%Z%`^` a a  H~~=(o"==rT assistant_msgct|dd}|t|tsdS|d}||pd}|r|dkrdS||} |||dS#t$r t dd YdSwxYw) zESurface a real mid-turn assistant commentary message to the UI layer.rENrr(empty))already_streamedz interim_assistant_callback errorTr) rgrZrrr>rrkrr2r)rPrlcbrvisibleros rR_emit_interim_assistant_messagez'AIAgent._emit_interim_assistant_messages T7 > > :Z t<<: F##I..**7=b99??AA 'Y.. F==gFF L Bw)9 : : : : : : L L L LL;dL K K K K K K Ls B&CCct|ddr"|r |r d|_d|z}d|j|jfD}d}|D] } ||d}#t $rYwxYw|r||dSdS)z;Fire all registered stream delta callbacks (display + TTS).r8Frcg|]}||Sr_ro)rrps rRrz.AIAgent._fire_stream_delta..shhhBY[YgRYgYgYgrTTN)rgrr8rDr7rre)rPr callbacks deliveredrps rRrzAIAgent._fire_stream_deltas 4. 6 6 !4 !DJJLL !',D $D=Dhh4#=t?T"Uhhh    B 4       7  0 0 6 6 6 6 6 7 7s A!! A.-A.cV|j}| ||dS#t$rYdSwxYwdS)z&Fire reasoning callback if registered.N)rAr)rPrrps rRrzAIAgent._fire_reasoning_deltasN  $ > 4     >  &&cV|j}| ||dS#t$rYdSwxYwdS)aNotify display layer that the model is generating tool call arguments. Fires once per tool name when the streaming response begins producing tool_call / tool_use tokens. Gives the TUI a chance to show a spinner or status line so the user isn't staring at a frozen screen while a large tool payload (e.g. a 45 KB write_file) is being generated. N)rFr)rPrrps rR_fire_tool_gen_startedzAIAgent._fire_tool_gen_startedsP # > 9      >rxc:|jdupt|ddduS)z4Return True if any streaming consumer is registered.Nr7)rDrgras rRrzAIAgent._has_stream_consumerss/  &d 2 Ct/66dB rTrc ~ jdkr0_ d_S#d_wxYwjdkrdddddiddifdfd }tj|d }||r@|d jrtd|@dddSdddddiddiddidtj ifdfdfdfd}ttj dd}|dkrKjrDtjr0td}t djn`t%ddgDdz}|dkrt)|d}n|d krt)|d!}n|}tj|d }|tj } d"} |r|d tj } | | z | kr3| } t+| dz } d#| d$tj dz } | |krIt%d%dgDdz}t d&| |d'd(|d)d*t+| d+d'd(d,|d)d- d}||d./n#t4$rYnwxYw d0/n#t4$rYnwxYwtj d<d1t+| d2jr jd3krEd4d5lm}j|j tCd6d_n.d}||d7/n#t4$rYnwxYwtd8|ddrtCd9d:pd:"pd}t d;tG|pd:dtId<|dd=}tId>tCd'd(tId4|d?@gdASddS)BuStreaming 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. rZNr[r-doneFrcfds%r%dd< dS#t$rYdSwxYwdSdSNr~TrrrsrR _fire_firstz>AIAgent._interruptible_streaming_api_call.._fire_firstsq(0^04%f-&((((($   ,,cz ddlm}m} dd} dd||}|jd i } fd} fd} fd}|| r|nd| js jr|nd fd   d <dS#t$r}| d <Yd}~dSd}~wwxYw)Nr)r1stream_converse_with_callbacksr3r~r4cP|dd<dS)NTr)r)rrdeltas_were_sentrPs rR_on_textzRAIAgent._interruptible_streaming_api_call.._bedrock_call.._on_texts3# //55526(///rTcF|dSr_)rz)rhrrPs rR_on_toolzRAIAgent._interruptible_streaming_api_call.._bedrock_call.._on_tool s(# 33D99999rTcF|dSr_)r)rrrPs rR _on_reasoningzWAIAgent._interruptible_streaming_api_call.._bedrock_call.._on_reasonings(# 22488888rTcjSr_rrasrRrnzRAIAgent._interruptible_streaming_api_call.._bedrock_call..s 43LrT) on_text_delta on_tool_starton_reasoning_deltaon_interrupt_checkrrro) r7r1rr!converse_streamrrArDr)r1rr;rEr<rrrrrr$rr?rPs rR _bedrock_callz@AIAgent._interruptible_streaming_api_call.._bedrock_calls((^^,@+NNFNN#94@@@88@@F#96#9#G#GJ#G#GL7777777 ::::::999999*H)G$262L2L2N2N&XhhTX&.<@._fire_first_delta0sq$V,  ,0!&)"N$$$$$ DD     rc  ddl}ttjdd}ttjdd}|dkr>(jr7t (jr#|}t d(j|i$dd di|d ||d d }( d 'd<tj &d<( d'dj j jd0i|}(t!|ddg}i}t#}i}i} d} d} d} g} d}|D]}tj &d<( d(jrna|js=t)|dr|jr|j} t)|dr|jr|j}||jdj}t)|dr|jr|j} t!|ddpt!|dd}|r4| |#(||r|jr||j|s*#(|jd%d<nM(jrF (|j(|jn#t<$rYnwxYw|r|jr|jD]}|j |j nd}|j!pd}|| vr|| |<|r)||vr%|||krtE|ddz}|| |<|r|||<| |}||vr|j!pddddddd ||<||}|j!r |j!|d!<|j#rX|j#j$r |dd"xx|j#j$z cc<|j#j%r |dd#xx|j#j%z cc<t!|d$d}|,t)|d%r|j&pi'd$}|)t)|d&r|(}||d$<|dd"}|r8||vr4|)|#(*||jdj+r|jdj+} t)|dr|jr|j}d,|pd}d}d'}|rg}t[|D]}||}|dd#}|rA|.r- t_j0|n#t^j1$rd}YnwxYw|te|d!|d(|'d$te|dd"|)| pd*}|rd+}d,| pd} te| ||| ,}!ted|!|-}"ted.tgtij5z| |"g|/S)1z#Stream a chat completions response.rNHERMES_API_TIMEOUT @HERMES_STREAM_READ_TIMEOUT^@uDLocal provider detected (%s) — stream read timeout raised to %.0fsT include_usage>@)connectrcrWr)rwstream_optionsr&chat_completion_stream_requestrrErz)waiting for provider response (streaming)rrrr+rrrrrr2)r7rrr)rrr extra_contentrrhrr model_extra model_dumpFr)rrrrrRlengthrrrrrrrPzstream-rr+choicesrro)6rrrrrr0r2rTimeoutrr*r]r9r:rrcrgrWrrrLr+rrrrrrrDrerrrrrrrhrrrrrrzrPrVrYrrrrrr[r]r^))r _base_timeout_stream_read_timeout stream_kwargsrwrbtool_calls_acctool_gen_notified_last_id_at_idx_active_slot_by_idxrP model_namerr usage_objchunkrrktc_deltaraw_idxdelta_idnew_slotrrQextrarh full_contentmock_tool_callshas_truncated_tool_argsrreffective_finish_reasonfull_reasoning mock_message mock_choicerr$rlast_chunk_timer>rPs) rR_call_chat_completionszIAIAgent._interruptible_streaming_api_call.._call_chat_completions8s " " " "!"),@&"I"IJJM#(3OQV)W)W#X#X $u,,,CTUYUbCcCc,'4$ ZM#7  #2D"9!>> -' *   M/3.P.P7/Q// !( + $(9;;OC  !L M M ML*849EL]]}]]F  % %gfj$&G&G H H H"$M#%N%(UU  %'O(*  MJD$&OIk ,k ,'+y{{$$$%@AAA,E}ug..15;1%*[ ug..05;0$)K  a(.5'**-u{-!&J")0CT!J!J!ogV[]hjnNoNo!?#**>:::%%'''..~>>>%U]%!((777)%))+++// >>>26(// 5%% $ : :5= I I I $ D DU] S S S S#,%%% $%/>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&+ # "$!.11C',B ":{ ;I ;Y__%6%6;; Jy1111#3;;;6:333;#**?d8Z&(ff_&=&=!0!#J!7&/""" ,,,'4&=v #& 3*2'WW_55=N*$*"0 L *$5K #s4:<<000 $   s$34K(( K54K5U##U76U7cdd}tj d<jjjdi 5}|D]O}tj d<djrnt |dd}|dkr]t |dd}|rIt |dddkr4d }t |d d}|r ||d krt |d d}|rt |dd}|d kr;t |dd}|r&|s$ |d d<|dkr2t |dd} | r  | Q| cdddS#1swxYwYdS)a8Stream an Anthropic Messages API response. Fires delta callbacks for real-time token delivery, but returns the native Anthropic Message object from get_final_message() so the rest of the agent loop (validation, tool extraction, etc.) works unchanged. FrrrNcontent_block_start content_blocktool_useTrhcontent_block_deltar text_deltarrrthinking_deltarro) r*r=rrwr]rrgrzrrget_final_message) has_tool_userwrrrrr delta_typer thinking_textrr$rrrPs rR_call_anthropiczBAIAgent._interruptible_streaming_api_call.._call_anthropic sc!L$(9;;OC 7'07EE*EE* 2#&N&NE,09;;OC((()DEEE0!(!=!=J!%::: ' E E GWUFD%A%AZ%O%O+/L(/vt(D(DI(G 1 1 3 3 3 $ ; ;I F F F#'<<< 'w = = N)0)E)EJ)\99'.ufb'A'A#'!C !C$5$5$7$7$7$($;$;D$A$A$A>B$4U$;!+/?!?!?07z20N0N #0!N$5$5$7$7$7$($>$>}$M$M$M//11U* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2* 2sE'F%%F),F)c B ddl}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} t1 fd| D}|s|s|rG||krtd|dz|dzt5|j|dt5|jd|dzd|dzdd|dzd|dzdt5|jd} | | d dd< d n#t$rYnwxYwYd}~d|dzdt d|dz|nbt-|} d| vod| v} | rd _ d!td"||d <Yd}~d}||d dSdSd}~wwxYw d}||d dSdS#d}||d wwxYw)#NrHERMES_STREAM_RETRIESrrr]rrEstream_request_completerrz9Streaming failed after partial delivery, not retrying: %srF)APIErrorr) connection lostconnection resetconnection closedzconnection terminated network errornetwork connection terminatedz peer closedz broken pipezupstream connect errorc3 K|]}|vV dSr_ro)rphrase_err_lower_sses rRrzKAIAgent._interruptible_streaming_api_call.._call..|s<7"7"(.%+n$<7"7"7"7"7"7"rTzJStreaming attempt %s/%s failed (%s: %s), retrying with fresh connection...u'⚠️ Connection to provider dropped (u). Reconnecting… (attempt rcr z stream retry z after stream_retry_cleanupstream_retry_pool_cleanupu(❌ Connection to provider failed after uM attempts. The provider may be experiencing issues — try again in a moment.z5Streaming exhausted %s retries on transient error: %srwz not supportedTu ⚠ Streaming is not supported for this model/provider. Switching to non-streaming. To avoid this delay, set display.streaming: false in config.yaml z$Streaming failed before delivery: %s)!rrrrrr&r rrrr2rlrZrConnectTimeout PoolTimeoutrrropenairrgr[rrr3rrjrr]r_disable_streamingr )r_max_stream_retries_stream_attemptr=r _is_timeout _is_conn_err_is_sse_conn_err _APIError_SSE_CONN_PHRASESstale _err_lower_is_stream_unsupportedrrrrr>r?rPs @rRr@z8AIAgent._interruptible_streaming_api_call.._callCs " " " ""%bi0G&K&K"L"L F h',-@1-D'E'EAAO@=,@@@ JJLLL1@1B1BF:..1G1G1I1IF:.x"7!:!:8!D!D!-55nMf5ggggg.-y%yyy+E2##NN []^/0F7O"FFFFd"7!:!:8!D!D!-55nMf5ggggg.-c'1 2F4I6K]^'' (2 3V5OQ`a(( ,1(*"<"DDDDDD)!Y77"=Z^@_@_"14Q 5" 1477"7"7"7"2C7"7"7"4"4" 0 'A,A:JA /1DDD & %H$3a$7$7!$;$(GG$4$% !"!"!"!% 1 1%a(,Q(8%a%a0?!0C%a%aFY\]F]%a%a%a!"!"!" !% 4 4%@Oa4G%@%@J]`aJa%@%@-1!WW-=%@%@!"!"!" )>(A(A((K(K#(#4$($E$E(-6L%F%&%&%&GK$9($C!)$($G$G/J%H%&%&%&%&(1!)!)!)$(D!) ( --!9#6#:!9!9!9 #NN W 3a 7 ! *-QJ (J 6!B$3z$A3 6":> 7 $ 0 0%7!"!"!" #KK F !+,w!6!:!:8!D!D!-55nMf5ggggg.-yyAF"7!:!:8!D!D!-55nMf5ggggg.-"7!:!:8!D!D!-55nMf5gggg.ssO-:B-:O-- N78(N2 O-FN2+KN2 K N2KN2O-B#N2;O-2N77O--1PHERMES_STREAM_STALE_TIMEOUTgf@rCu>Local provider detected (%s) — stale stream timeout disabledc3NK|] }tt|V!dSr_rErFs rRrz.rGrTrrHrIrBrJgn@rzwaiting for stream response (zs, no chunks yet)c3NK|] }tt|V!dSr_rErFs rRrz.rNrTuqStream stale for %.0fs (threshold %.0fs) — no chunks received. model=%s context=~%s tokens. Killing connection.r+rrrOz s (model: z , context: ~z tokens). Reconnecting...stale_stream_killrstale_stream_pool_cleanupzstale stream detected after zs, reconnectingr]rrPrDstream_interrupt_abortz+Agent interrupted during streaming API callr9rzPartial stream delivered before error; returning stub response with %s chars of recovered content to prevent duplicate messages: %srrzpartial-stream-stubrRrr)%r&r0rar~rrrVrVrrXr*rrrrr0r2rrrrrr]rlrrrrr?r{r=rrCrgrr\r)rPr$rrrr@_stream_stale_timeout_base_stream_stale_timeoutr[_last_heartbeat_HEARTBEAT_INTERVAL_hb_now _waiting_secs_stale_elapsedr_r`r{r= _partial_text _stub_msgrrrrrrrr>r?s``` @@@@@@@@@rR!_interruptible_streaming_api_callz)AIAgent._interruptible_streaming_api_calls$ =- - - *8D & 233J??-1**T*1111 =. . ."&66F!'  %u~        ( ( ( ( ( ( ( ( (D dCCCA GGIII**,, Xs###,X*+VWWW**,, Xg*Wo%*% %"T22!)4 0#UO!5> ,      P P P P P P P P P P d7 27 27 27 27 27 27 27 27 2rK hK hK hK hK hK hK hK hK hK hZ&+295RTY+Z+Z%[%[" & . .4= .EVW[WdEeEe .$)%LL ! LLY[_[h i i i iRR:>>*b3Q3QRRRRRVWWKW$$(+,F(N(N%%v%%(+,F(N(N%%(B%  E$ 7 7 7  )++"jjllH V FF3F   ikkG(,???") #Goc.B$B C C $$TMTTT"Y[[?3+??N 555SSJNN:r4R4RSSSSSWXXG"$9NN7I668  !!'CS SSc " |jt|jkrdS|j|j}|xjdz c_|dpd}|dpd}|r|s|S ddlm}|dpdpd }|d pdpd }|r.d |vr|stj d pd }|||d ||\}}|)tj d||S ddl m} | ||}n#t$rYnwxYwd} t!|j} |dkrd} n|dks:| ddrd} nP|| rd} n8|||rd} n|dksd| vrd} |j} ||_||_| |_| |_d |_| dkrvddlm} m}m}|dkr|jp |pdn|jpd}||_||_| |_ | ||j |_!|||_"d |_#i|_$n[|j|_||_#tK|dd }|stK|dd }|j| d|rdtM|ini|_$| dko|dk}d | vrd!|vp||_'tQ|d"rm|j)rfdd#l*m+}||j|j|j|j$}|j),|j||jtK|d d|j%|-d&|d'|tj.d(| ||d S#t$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. Frr%rr+rrrNr$z ollama.comOLLAMA_API_KEYT)r+rexplicit_base_urlexplicit_api_keyz.Fallback to %s failed: provider not configured)rhr\r^rZrbrcrdr]rkrerfr[r_custom_headersrrrlrrrr)rr$r%ru5🔄 Primary model failed — switching to fallback: z via u"Fallback activated: %s → %s (%s)z"Failed to activate fallback %s: %s)0rSr\rRrrr_try_activate_fallbackrKrrrrrlrrhrr[rrrrrr+r%r&rTr?r{r|rr$rCrDr=r>rErFrgrr&rLrrrrrr3r)rPr fb_providerfb_modelrfb_base_url_hintfb_api_key_hint fb_client_resolved_fb_modelrh fb_api_mode fb_base_urlrr{r|rr fb_headersrrfb_context_lengthrs rRrzAIAgent._try_activate_fallbackXs  3t';#<#< < <5  !$"6 7 !vvj))/R6688>>@@ FF7OO)r0022 1( 1..00 0 z 1 F F F F F F!#z 2 2 8b??AAIT !vvi006B==??G4O  FL4D4J4J4L4L$L$LUd$L"$),<"="="E,C,C8t"2!0-2-2-2 )I) D!!!22444 SSSSSS77+NN    -Ki011Kn,,/  ++{/A/A#/F/F/L/L/N/N/W/WXd/e/e+2 ++K88 1/ <<$= 10  ))->+BSBSBUBU-U-U0  I!DJ'DM'DM'DM'+D $222ttttttttttZeitZtZt!2!U6M6M6O6O!USU|E|M|SQS , *7'+6()?)? tOg)h)h&+:?=+I+I(" &(## )0 ' %Y0A4HH !M!(4Et!L!LJ(0 +''AKR)4 +;+;<! L L L..00 0 0 0 0 0 0 1sD?C Q FQ F*'Q)F**J$Q R)R R RcF|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|dd|_d |_t+jd|j|jdS#t.$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 caches agents across messages (``_agent_cache`` in ``gateway/run.py``), so this restoration IS needed there too. Fr+r%rr&r$rrr]rrPr r r Nrestore_primaryTrrrrrrrz.Primary runtime restored for new turn: %s (%s)z%Failed to restore primary runtime: %s)rTrr+r%rr&r$rrFr&r?r{rCrDr=r>rErQrrrSrr3rrl)rPrtr{ccrs rR_restore_primary_runtimez AIAgent._restore_primary_runtimes' 5  "0 GDJzNDMzNDMzNDMi=DL"&r/':";";D ')*>'?D $} 444JJJJJJ*,-@*A'+-.B+C()?)?*+R0D-E**&,..B+C(" "88O,--,9 (B OO+,!"=>12/012    (-D $#$D L@ DM   4    OCQ G G G55555 sE"E66 F FF >rrrrAPITimeoutErrorAPIConnectionErrorr 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-researchrENprimary_recoveryTrrr+r%rr&r$r]rrPr r r rru🔁 Transient z on u — rebuilt client, waiting z"s before one last primary attempt.r z%Primary transport recovery failed: %s)!rTrrj_TRANSIENT_TRANSPORT_ERRORSrr%rrrgrrErrrrFr+rr&r$r?r{rCrDr=r>rQrrr5r*sleeprrl) rPrrr error_typerNr r{ wait_timers rR_try_recover_primary_transportz&AIAgent._try_recover_primary_transport8s  # 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)rZrrr)rrs rR_content_has_image_partsz AIAgent._content_has_image_partss^'4(( 5  D$%% $((6*:*:>Z*Z*ZtturTrcft|pdd\}}}d}|drZ|tddddd}|dr|}d d d d d d |d }tjd|d}|5| tj |dddn #1swxYwYt|j }t||fS)Nrr image/jpegdata:;rrzimage/z.pngz.gifz.webpz.jpg)z image/pngz image/gifz image/webpr!z image/jpganthropic_image_F)rsuffixdelete)r[ partitionrr\rrrtempfileNamedTemporaryFilerWbase64 b64decoder rh) rheaderrr]mime mime_partr%tmprs rR _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)Nrr8rz tool result)rrrzDescribe everything visible in this image in thorough detail. Include any text, code, UI, data, objects, people, layout, colors, and any other notable visual information.r"r)vision_analyze_tool)r user_promptrXzImage 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: )rrr[rrr<rrr0tools.vision_toolsr2asynciorerZrrrrrNunlinkrX)rPrr cache_keycached role_labelanalysis_prompt vision_source cleanup_pathrr2 result_jsonr?rnotes rR&_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>rrrr.z:[An image was attached but no image source was available.]rc3K|]}||V dSr_ro)rr?s rRrz8AIAgent._preprocess_anthropic_content..s'BBdTBTBBBBBBrTrc3K|]}||V dSr_ro)rrs rRrz8AIAgent._preprocess_anthropic_content..s'??D$?4??????rTzI[A multimodal message was converted to text for Anthropic compatibility.]) rrZr[rrrrr@rV) rPrr text_parts image_notesrrJr image_datarrr%s rR_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  MZZrT api_messagesc >tfd|Ds|Stj|}|D]g}t|ts|dt|ddpd|d<h|S)Nc3K|]A}t|to'|dVBdS)rN)rZrrr)rrrPs rRrz>AIAgent._prepare_anthropic_messages_for_api..s`   sD ! ! Wd&C&CCGGIDVDV&W&W      rTrrr)rrr<rZrrHrr[)rPrI transformedrs` rR#_prepare_anthropic_messages_for_apiz+AIAgent._prepare_anthropic_messages_for_apis    #       mL11   Cc4(( !?? ""CGGFF++5v66C NNrTct|ddpddvrdSt|ddpd}d|vpd|vp d|vpd |vpd |vS) aGTrue when using an anthropic-compatible endpoint that preserves dots in model names. Alibaba/DashScope keeps dots (e.g. qwen3.5-plus). MiniMax keeps dots (e.g. MiniMax-M2.7). OpenCode Go/Zen keeps dots for non-Claude models (e.g. minimax-m2.5-free). ZAI/Zhipu keeps dots (e.g. glm-4.7, glm-5.1).r%r> minimax-cnrKrminimaxrrTr dashscopealiyuncsrPzopencode.ai/zen/z bigmodel.cn)rgr)rPbases rR_anthropic_preserve_dotsz AIAgent._anthropic_preserve_dotss D*b ) ) /R 6 6 8 8=G G G4j"--3::<<d"EjD&8EId?}|"r-|jpd@t#taj1dA|dB<|jr |j|dC<|j .||2|j n|"r)||2dDng|3s dE|j4vrJdF|jpdvr- ddGlm5}||j}||dH<n#tl$rYnwxYwi}|3}d|j4vpd|j4v}|r|r||dI<dE|j4v}|7ra|r|}|||d+<nC|j 4t1|j } |r| dd urn| |d+<ndddJ|d+<|rdKg|dL<|j8r%|dMi}!|j8|!dN<|!|dM<|jdOkr|j rt/|j t0rj|j d!pd}"|j dd}#|"dPks|#d urd |dQ<|"rd|dR<|r||dS<|j r||j |S)Tz9Build the keyword arguments dict for the active API mode.r]rbuild_anthropic_kwargsrN_ephemeral_max_output_tokensrDspeedfast) r+rrrHrIis_oauth preserve_dotsrr fast_moder[)build_converse_kwargsrBr~rHT)r4r3i)r+rrrHr6guardrail_configrZrrrrrmodels.github.airr^r`mediumrFeffortminimallowr)r+r1r0rr7r;r4r9r_razreasoning.encrypted_contentr5r)rlrr:r<zx-grok-conv-idr8rrrrc3 K|]}|vV dSr_ro)rrrs rRrz,AIAgent._build_api_kwargs..s(EE!A%EEEEEErTronlyrordersortrequire_parametersdata_collectionrr)r+rr&r) sessionIdpromptIdmetadatari nousresearchrr)_get_anthropic_max_outputrHr%rrlproduct=hermes-agenttagsoptionsnum_ctxrrthinkvl_high_resolution_images extra_body)9r&r?rarMrgrrbr+rrHrIr>rTrKrr7rhr[rr"rrr%rZrr"rr<#_github_models_reasoning_extra_bodyrrrr<r!rVr\r^rr;r6r7r8r9r:r;rrrr]r^r<rrryr_supports_reasoning_extra_bodyr)%rPrIrar]ctx_len ephemeral_outrhr;rr1payload_messagesis_github_responsesis_codex_backendreasoning_effortreasoning_enabled _effort_clampr is_xai_responsesgithub_reasoningsanitized_messagesneeds_sanitizationrrrprovider_preferencesr$ry_model_output_limitr_is_openrouter_is_github_models_is_nousr`r}_effort_enabledrs% @rR_build_api_kwargszAIAgent._build_api_kwargsas =0 0 0 F F F F F F!%!I!I,!W!W d$8$??G07Ag,,TG$D*H$OOM(481))j+j,9,E==4?!%!61";;==& '{+5ERX*Y*YF;')F(GF9%%( '1A '$&y!% 6 d4555*3C*.2o*+ NGD,$E$E N+;T_*M'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     ! ! !_8 --&&Jz " : -"&*Jw  ? &   d44T_EE F F F F  ! ! # #    d44U;; < < < <%%'' >T=Q+Q+QW_dhdndtrtc{c{c}c}W}W} 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    , nnY33G!%!5GI $+Jy ! =H $ $)> $:dNceiCjCj $,00::@bGGIIOOQQG,00DAAH&  H$5$5&+ 7#    ! ! ;6:J2 3  2'1J| $  ! 6   d4 5 5 5s \'' \43\4cZd|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. rxTzai-gateway.vercel.shrjrrgithub_model_reasoning_effortsFrlzapi.mistral.air)z deepseek/z anthropic/zopenai/zx-ai/zgoogle/gemini-2z qwen/qwen3c3BK|]}|VdSr_)r)rrr+s rRrz9AIAgent._supports_reasoning_extra_body..s1SS5##F++SSSSSSrT)rrJrrr+rrr)rPrreasoning_model_prefixesr+s @rRrz&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.rrNrFrlrkxhighhighrmrn) rJrrr+rIrZrrr[rr)rPrsupported_effortsrequested_efforts rRrz+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$rYnwxYw|jpd}t|} |rt|}d | ||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#|t0r|s||\}}|}t#|t0r|st#|t0r)|r|}n_t-|dd}|rt-|ddnd}|rt-|ddnd}|||t|}|}t-|dd}t#|t0r|s||\}}|}||t#|t0r|nd}||||j|jj|jj dd}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. rrrBrc3fK|],}||V-dSr_r)rbs rRrz3AIAgent._build_assistant_message..s7&T&TQ!''))&Tqwwyy&T&T&T&T&T&TrTNzCaptured reasoning ( chars): r)rrrrPr__dict__rrrrrrhrrrrr]rr)!rrrr@rrDrVr1rrr\rArDrrrLrrZrrrrrgrr[rrrr rrrhr)rPrVrPrk_from_structuredr think_blockscombined _raw_content _san_contentr raw_details preservedd codex_itemsrrrrrr_fn_fn_name_fn_argsrrtc_dictrs rR_build_assistant_messagez AIAgent._build_assistant_messages 001BCC//  2'/52G:&=wbiXXXL 2!;;&T&T,&T&T&TTT!)!1T  ad2 a M_^1D1D__~__ ` ` `  d5 - ++N;;;; D )06B +L99  B1.AAN #'*    $&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)uStrip Codex Responses API fields from tool_calls for strict providers. Providers like Mistral, Fireworks, and other strict OpenAI-compatible APIs validate the Chat Completions schema and reject unknown fields (call_id, response_item_id) with 400 or 422 errors. These fields are preserved in the internal message history — this method only modifies the outgoing API copy. Creates new tool_call dicts rather than mutating in-place, so the original messages list retains call_id/response_item_id for Codex Responses API compatibility (e.g. if the session falls back to a Codex provider later). Fields stripped: call_id, response_item_id rrrc~g|]9}t|tr fd|Dn|:S)c$i|] \}}|v || Sroro)rr)r* _STRIP_KEYSs rRr+zJAIAgent._sanitize_tool_calls_for_strict_api...ms) A A AdaA[,@,@Q,@,@,@rT)rZrr)rrrs rRrz?AIAgent._sanitize_tool_calls_for_strict_api..ls_! ! ! "d## , A A A Abhhjj A A A A)+! ! ! rT)rrZr)rrrs @rR#_sanitize_tool_calls_for_strict_apiz+AIAgent._sanitize_tool_calls_for_strict_apiWsn"[[.. *d++ N "45 ! ! ! ! !! ! !   rTc|jdkS)aDetermine if tool_calls need sanitization for strict APIs. Codex Responses API uses fields like call_id and response_item_id that are not part of the standard Chat Completions schema. These fields must be stripped when calling any other API to avoid validation errors (400 Bad Request). Returns: bool: True if sanitization is needed (non-Codex API), False otherwise. rZ)r&ras rR_should_sanitize_tool_callsz#AIAgent._should_sanitize_tool_callsss} 111rT min_turnsc  |jdkr|dSd|jvs|jsdS||n|j}|j|krdS|t |dd}|rt |dkrdSd}dt |dtj}d ||d }| | | }g}|D]} | } | d d kr| d } | r| | d<| d 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|| gdd}n#t&$rd}d}YnwxYw|s]|jdkrR||}|| g|d<d|d <d!|vrd|d!<||}n|sP|jd"krEdd#lm}||j|| gdd|$}||}nb|s`|j|| gdd%|d}dd&lm}|d'j j!j"d5i|d(|di}g}|jdkr+|s)|#|\}}|r|j$r|j$}np|jd"kr.|s,dd)lm%}|||j&*\}}|r|j$r|j$}n7tO|d+r'|j(r |j(dj)}|j$r|j$}|D]}|j*j+dkr tYj-|j*j.}| d,d}dd-l/m0}|| d.|| d/| d0|j1|j1s&ted2| d,d#tf$r%} th5d3| Yd} ~ d} ~ wwxYwn2#tf$r%} th5d4| 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). rNrrcru[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_sentinelrrrrrPr_thinking_prefillrrrrhr2)call_llmTflush_memoriesrKi)taskrrr6rHFrZrr6r:r]r`)r+rrrHrIrf)r+rrr6)_get_task_timeoutrr&normalize_anthropic_responsestrip_tool_prefixrrp memory_toolactionrold_textrrprrr4u 🧠 Memory flush: saved to z!Memory flush tool call failed: %sz Memory flush API call failed: %sro)6rsrXrorrgr\rr* monotonicrrrrr!rrdrrKrrPr&rrrr?rar+rTr+r<rrr9r:rrqrrr>rLrrrrhrrrrvrr2rGrr2r)!rPrr effective_min flush_content _sentinel flush_msg_needs_sanitizerIrrrmemory_tool_defr _call_llm_aux_availabler codex_kwargs_build_ant_kwargs ant_kwargsr$rrrlr _nar_flush _flush_msgrVrr* flush_target _memory_toolrs! rRrzAIAgent.flush_memoriess  '1 , ,1B F 40 0 08J 0 F%.%: @\  = 0 0 F  t%8$??H 3x==1,, F O  =r$xx<<$.*:*:<< # R[\\  """{ ">>@@OL - -((**776??k11 # 4 4I A7@ 34 K... OT222 -t444 /666"F<X Y YZ]ii #Oj&B  55R((,,V44@@&'OEA#  p x|//0ABBiOO  x|//0ABBiOO HRL,,->??9LL   LLq E D D D D D!N $9))*+ ##     !& " dm7H&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(EU8U8J*)U8*J;8U8:J;;GU8B5UU8 U3U.)U8.U33U87X>8 V'V"X>"V''X>>B[r7) approx_tokensr focus_topicrrcrt|}td|jpd||r|dnd|j|||d|jr, |j|n#t$rYnwxYw|j |||}|j }|r| d|d |||} | |_|jr |j|j} |||j|jd |j} t+jd d t1jjd d|_|jd|jdz |_|j|j|jpt>j !dd|j| | ru |j"| } |j#|j| n9#tHtf$r%} t%d| Yd } ~ nd } ~ wwxYw|j&|j| d|_'n2#t$r%} t(d| Yd } ~ nd } ~ wwxYw|j j)}|dkr"|*|j+d|ddtY| t[|z}||j _.d|j _/ ddl0m1}||n#t$rYnwxYwtd|jpd|t||d|| fS)uCompress conversation context and split the session in SQLite. Args: focus_topic: Optional focus string for guided compression — the summariser will prioritise preserving information related to this topic. Inspired by Claude Code's ``/compact ``. Returns: (compressed_messages, new_system_prompt) tuple zPcontext compression started: session=%s messages=%d tokens=~%s model=%s focus=%rrrrr)r)current_tokensrrrrrrNrrrrr)r<rr+rQz,Could not propagate title on compression: %suKSession DB compression split failed — new session will NOT be indexed: %sru⚠️ Session compressed u> times — accuracy may degrade. Consider /new to start fresh.Tr )reset_file_dedupz?context compression done: session=%s messages=%d->%d tokens=~%s)2r\r2r3r<r+rrxon_pre_compressrrcompressrnformat_for_injectionrrrrdrgrrw end_sessionr rZr\r]r^r_r`rbrjrrrkrget_next_title_in_lineageset_session_titlerYrupdate_system_promptrirlcompression_countrr5r)r*last_prompt_tokenslast_completion_tokenstools.file_toolsr)rPrrrrr_pre_msg_count compressed todo_snapshotnew_system_prompt old_titleold_session_id new_titlerr_compressed_estrs rR_compress_contextzAIAgent._compress_context!skX ^ O %v~$1 @} y$*      H222    $44X>>>>    ,55h}ju5vv (==??  J   v-HH I I I &&((( 55nEE%6"   q q ,>>tOO **8444 ,,T_mLLL!%%-\^^%<%<_%M%M"f"fPTPZP\P\P`acbcacPd"f"f(, 8Y4?8Y8Y8Y(Y% //#=ZBJNN;RTY,Z,Z*&4 0XX$($4$N$Ny$Y$Y (::4?IVVVV& 2XXX %SUVWWWWWWWWX 55doGXYYY,-)) q q qlnopppppppp q%7 !88 LL?GGsGGG     ""3 4 4,Z88 9 6E29:6   9 9 9 9 9 9  W % % % %    D   M O %v~s: " "   ,,,sg A;; BBDK%:I K J1J KJ*K K0 K++K0M11 M>=M>effective_task_idrkc|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)rPrVrrrkrs rR_execute_tool_callszAIAgent._execute_tool_callss'1 !% *1*== ::%x1BN%*D ! ! 66!8->%*D ! !ED ! ) ) ) )s&AA A& function_namerrc Ld} ddlm}||||pd}n#t$rYnwxYw|tjd|idS|d kr@dd lm}||d |d d|j S|dkry|j stjdddSddl m }||dd|d|dd|j |j S|dkr|dd} ddl m} | |d| |d|d|j} |jrm|ddvrV |j|dd| |ddn#t$rYnwxYw| S|jr5|j|r|j||S|dkr@dd lm} | |d!d|d"|j#S|d$krvdd%lm} | |d&|d'|d(|d)|d*|+St3|||||j pd|jrt7|jndd,-S).a@Invoke a single tool and return the result string. No display logic. Handles both agent-level tools (todo, memory, etc.) and registry-dispatched tools. Used by the concurrent execution path; the sequential path retains its own inline invocation for backward-compatible display handling. Nrget_pre_tool_call_block_messagerrzrFrtodo todo_toolrrrrr4rSession database not available.rrrquery role_filterlimitrrr r dbcurrent_session_idrrprrrrrrrr clarify_toolquestionrrrcallbackrrgoalrtoolsetstasksr,rrrrr, parent_agentTrr< enabled_toolsskip_pre_tool_call_hook)rrrrrrmrrrnrgtools.session_search_toolrr<rvrrorxon_memory_writehas_toolhandle_tool_calltools.clarify_toolrrBrrrrXr)rPrrrr block_messager _todo_tool_session_searchrprr? _clarify_tool_delegate_tasks rR _invoke_toolzAIAgent._invoke_tools#(,   J J J J J J;;}6G6M2MM    D   $:w 6UKKK K F " " ? ? ? ? ? ?:#''00#''77&  . . .# bze>_"`"`aaa S S S S S S"?#''44)--m<<#''33##'?  h & &"&&x::F E E E E E E!\$((22%)))44&**:66( F#  (9(9((C(CGY(Y(Y(88%))(B77%)))R88 !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!  (}.?)?0b=A=R\d4#8999X\(,  s ((AG G+*G+ rr6cddl}ddl}|dj}t d|t |z }g}|dD]\}t ||kr||+|||dd} | | p|g]d|z |} ||| S) aFWord-wrap verbose tool output to fit the terminal width. Splits *text* on existing newlines and wraps each line individually, preserving intentional line breaks (e.g. pretty-printed JSON). Returns a ready-to-print string with *label* on the first line and continuation lines indented. rN)xr rSrTF)widthbreak_long_wordsbreak_on_hyphens) shutiltextwrapget_terminal_sizecolumnsrr\rrwrapextendrV) rrr6_shutil_twcols wrap_width out_linesraw_linewrappedrs rR _wrap_verbosezAIAgent._wrap_verboses !   ((33;TCKK/00 !  4(( 8 8H8}} **  ****((8:4849#;;  !6XJ7777v ##I..'%''''rTc /01|j}t|}jrMtjd|d|D].}|dd|jjd|jd/dSg0|D]}|jj} | dkrd _ n | d krd _ tj |jj } n#tj$ri} YnwxYwt| t si} | d vrnjjrb | d d } | r8j| } j| d| n#t,$rYnwxYw| dkrjjr | dd } t/| ra| dp%t1jdt1j}j|d| ddn#t,$rYnwxYw0|| | fdd0D}js#td|d|t;0dD]\}\}}}tj|d}jrqtd|d|dtA|!dt"d tj|d!d"t|j#kr|dj#d#zn|}td|d|dtA|!d$|0D]e\}}}j$rX tK||}$d%|||7#t,$r!}tMj'd&|Yd}~]d}~wwxYwf0D]Y\}}}j(rL (|j||+#t,$r!}tMj'd'|Yd}~Qd}~wwxYwZdg|z1|_)*d(|d)|1fd*}d}+rj,rVt[j.t_j0}t_|d+|d,d-j1.}|2 tg|th}tjj67|/5}g/t;0D]7\}\}}}|8|||||}/|8tsj9}d} tjj6:/d12\}} | snjrn|s1d0};jd3t| d4d05| D]}|<tjj6:| d62nt{tsj9|z }!|!d kr_|!d7zd8krV/0fd9| D}"*d:|!d;t| d1D}#t}d?1D}$|?d@|#dA|dB|$dCdDnZ#|rSt}d>1D}#t}d?1D}$|?d@|#dA|dB|$dCdDwwxYwt;0D]\}\}}}1|}%|%jrd|d}&ndE|dF}&dG}'n|%\} } }&}'}(|(rtdT|dzdM|'dNdOt"dU|&nHt|&j#kr|&dj#d#zn|&}+tdT|dzdM|'dNdV|+d_)*dW|dX|'dCdYjDrM D|j|||&n.#t,$r!}tMj'dZ|Yd}~nd}~wwxYwt|&||jt[}&jGH||},|,r|&|,z }&d|&|jd}-||-t0}|d kr+|| d}.t|.t\dSdS)]zExecute multiple tool calls concurrently using a thread pool. Results are collected in the original tool-call order and appended to messages so the API sees them in the expected sequence. ⚡ Interrupt: skipping tool call(s)r[Tool execution cancelled — # was skipped due to user interrupt]rNrrrrrrrbefore terminalr)workdirrbefore terminal: rrc3"K|] \}}}|V dSr_ro)rrrhs rRrz9AIAgent._execute_tool_calls_concurrent..Ms("G"GJAtQ4"G"G"G"G"G"GrTu ⚡ Concurrent: u tool calls — rFr 📞 Tool r(r Args: rr6rr) - tool.startedTool progress callback error: Tool start callback error: z executing z tools concurrently: c@ ddlm}| jn#t$rYnwxYwt j} || |j}n=#t$r0}d|d|}td||dYd}~nd}~wwxYwt j|z }t||\} } | r&t d |||dd n*t d ||t|||||| f |<dS) z%Worker function executed in a thread.rset_activity_callbackError executing tool '': z_invoke_tool raised for %s: %sTrNztool %s failed (%.2fs): %sr#tool %s completed (%.2fs, %d chars)) tools.environments.baserQr]rr*r'rr2rrCr3r\)rrrrrQrr? tool_errordurationis_errorrrresultsrPs rR _run_toolz9AIAgent._execute_tool_calls_concurrent.._run_toolqsx  IIIIII%%d&:;;;;    IKKE i**=-IZ\e\hii i i iP-PPJPP =}jcg hhhhhhhh iy{{U*H.}fEEKHa i 8-SYZ^[^Z^S_```` A=RZ\_`f\g\ghhh+]FHhWGENNNs# ''A B&&BBu ⚡ running z tools concurrentlydots spinner_typeprint_fn) max_workersT@rLu⚡ Interrupt: cancelling z pending concurrent tool(s)r g@rrcZg|]'}|v|d(S)r)r)rrfutures parsed_callss rRrz:AIAgent._execute_tool_calls_concurrent..s@*** ! G||)q)9)9:1=+||rTzconcurrent tools running (zs, z remaining: rc3K|]}|dV dS)Nrrorrs rRrz9AIAgent._execute_tool_calls_concurrent..s"DDaammmmmDDrTc3*K|]}||dVdS)Nrrores rRrz9AIAgent._execute_tool_calls_concurrent..s&GG!GGrTu⚡ rcz tools completed in .1fzs totalrRz!': thread did not return a resultrr"Tool %s returned error (%.2fs): %stool.completedrWrXTool  completed in .2frR Tool result (rr? ✅ Tool Result: s - tool completed: r rTTool complete callback error: rr tool_use_idenvry)Jrr\rrGr5rrrhrrtrurrrrrZrrfrrget_working_dir_for_pathensure_checkpointrrrrgetcwdrVr2rrr1rkeysr;r4r=_build_tool_previewrrr>r-r]rrrandomchoicer@get_waiting_facesrrr_MAX_TOOL_WORKERS concurrentrbThreadPoolExecutorsubmitr*waitrcancelrrrRr2rl_get_cute_tool_message_implr r?rrrcheck_tool_callr)2rPrVrrrkr num_toolsrrrr file_pathwork_dirrrtool_names_strrrhr*args_str args_previewpreviewcb_errrZspinnerfacer_executorr _conc_start_interrupt_loggedr~not_done _conc_elapsed_still_runningr total_durrffunction_result tool_durationrXresult_previewcute_msgresponse_preview subdir_hintsrturn_tool_msgsrbrcrYs2` ` @@@rRrz&AIAgent._execute_tool_calls_concurrents` '1  OO   $  T_VViVVV W W W   "u @Puuu$&E!! F #& K& KI%.3M((+,((.00*+' # $ 9+=+G H H ' # # # "  #mT22 # "  777D>xIbS`IbIbccc D **t/C/K*'++Ir::C.s33+// ::dbiXZXaXcXc>d>d,>>!?S"X!?!?!D   M= I J J J J"G"G,"G"G"GGG \ RyRR.RR S S S'0q'A'A \ \##Bd:d???'\IIIdIIT$))++5F5FIIIJJJ$,,Xtz$q_d7e7e7effggggORS[}}_c_tOtOt8,BT-B,B#Ce#K#K{CLZZZdZZT$))++5F5FZZLZZ[[[[* M MNBd* MM1$==G//gtTTTT MMMM"K6"K"KLLLLLLLLM  M+ J JNBd' JJ,,RUD$???? JJJM"H"H"HIIIIIIIIJ J&9$, Z)ZZ.ZZ[[[ X X X X X X X4  0 0 2 2 t7W7W7Y7Y =!@!B!BCCD#t$X$X)$X$X$Xgmx|yGHHHG MMOOO; gi):;;K#66;6OO3 S[+4\+B+B&&'A'D$  1b$EEANN1%%%%#ikk $)!&%/%7%<%<&=&&ND($0 004- LL#'?!N!N#&x==!N!N!N&*) "*''AHHJJJJ#*//#/FFF$' k(A$B$BM$q((]R-?!-C-C*****%-*** ,,[[["8}}[[:>))NSUTUSUDV:W:W[[[G&3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 j gDD7DDDDD GGgGGGGG  eIee eeyeeeefff  gDD7DDDDD GGgGGGGG  eIee eeyeeeeffff  g$-\#:#:B &B & AD$ Ay,g&pt&p&p&pOO&ft&f&f&fO # YZV }o}hw>A/>R>RUX>X>X_TcT%:%:^mNNN#GXeguvvv.QQ33,mT4%2X4%QQQ &Ov&O&OPPPPPPPPQ'dM"[-"["[}"["["["[\\\M"b#o2F2F"b"bQ`"b"bccc4466 f6tT=Yhiii  h1111_ f'fO!OO=OOOOPPP$,,ZIIJJJJZ]^mZnZnqurG[G[G7M8M7M'NQV'V'VM\$d!dd=dddRbddeee!%D   !QD!Q!QM!Q!Q!Q!Q R R R* MM//tT?SSSS MMMM"K6"K"KLLLLLLLLM8'E"#455 O 3CCD$OOL 0</* "H OOH % % % % %% q==%yjkk2N NCT4U4U V V V V V V =sB>>CC=AE EE1BG88 HH<(N%% O/O  O$P P, P''P, 5\FZ' \'Z++\.Z+/\A])` `0`++`0=f g%ggc (t|jdD]!\}}|jr{|j|dz d}|r/||jdt |dd|D]2}|jj} dd| d |jd } | | 3n|jj} tj |jj } n5#tj $r#} tjd | i} Yd} ~ nd} ~ wwxYwt!| t"si} d} d d lm}|| | |pd}n#t($rYnwxYw|n| dkrd |_n | dkrd |_|jstj| d}|jrqt5d|d| dt7| dt5|dtj| ddnft ||jkr|d|jdzn|}t5d|d| dt7| d||| |_| d| |( d dl!m"}||j n#t($rYnwxYw|_|j#rX tI| | }|#d| || n.#t($r!}tj%d |Yd}~nd}~wwxYw|S|j&rL |&|j| | n.#t($r!}tj%d!|Yd}~nd}~wwxYw|r| d"vrn|j'j(rb | )d#d}|r8|j'*|}|j'+|d$| n#t($rYnwxYw|| d%kr|j'j(r | )d&d}tY|ra| )d'p%t[j.d(t[j/}|j'+|d)|dd*n#t($rYnwxYwtaj0}|tjd+|id}d,} n&| d-krd d.l1m2}|| )d/| )d0d|j31}taj0|z }|4r)|d2tkd-| ||3 n| d4kr|j6stjdd5d6}n[d d7l7m8}|| )d8d| )d9| )d:d;|j6|j9<}taj0|z }|4r)|d2tkd4| ||3 n| dkr3| )d=d}d d>l:m;}|| )d?|| )d@| )dA|j<B}|j=rm| )d?dCvrV |j=>| )d?d|| )d@dn#t($rYnwxYwtaj0|z }|4r)|d2tkd| ||3 n|| dDkrd dEl?m@} | | )dFd| )dG|jAH}taj0|z }|4r)|d2tkdD| ||3n| dIkrGd dJlBmC}!| )dK}"|"r)t!|"t6rdLt |"dM}#n(| )dNpdddO}$|$rdP|$ndQ}#d}%|4ri|DrUtjFtjH}&t|&dR|#dS|jIT}%|%J|%|_Kd}' |!| )dN| )dU| )dV|"| )dW|X}|}'d|_Ktaj0|z }tkdI| ||'3}(|%r|%L|(n;|4r|d2|(n #d|_Ktaj0|z }tkdI| ||'3}(|%r|%L|(w|4r|d2|(wwxYw|jMr| |jMvrd}%|jr|j#sytjFtjH}&t| })tI| | p| }t|&dR|)dR|dS|jIT}%|%Jd}* |jOP| | |Y}|}*nQ#t($rD}+tjd+dZ| d[|+i}tRd\| |+d]Yd}+~+nd}+~+wwxYwtaj0|z }tk| | ||*3}(|%r|%L|(nB|jr|d2|(n!#taj0|z }tk| | ||*3}(|%r|%L|(w|jr|d2|(wwxYw|j=r|j=S| rd}%|4r|DrytjFtjH}&t| })tI| | p| }t|&dR|)dR|dS|jIT}%|%Jd}, |j=P| | }|},nQ#t($rD}+tjd+d^| d[|+i}tRd_| |+d]Yd}+~+nd}+~+wwxYwtaj0|z }tk| | ||,3}(|%r|%L|(nA|4r|d2|(n#taj0|z }tk| | ||,3}(|%r|%L|(w|4r|d2|(wwxYw|jrd}%|4r|DrytjFtjH}&t| })tI| | p| }t|&dR|)dR|dS|jIT}%|%Jd}- t| | ||j|j9pd|jUrt7|jUndd`}|}-n=#t($r0}+da| db|+}tRdc| |+d]Yd}+~+nd}+~+wwxYwtaj0|z }tk| | ||-3}(|%r|%L|(n3|4r|d2|(n#taj0|z }tk| | ||-3}(|%r|%L|(w|4r|d2|(wwxYw t| | ||j|j9pd|jUrt7|jUndd`}n=#t($r0}+da| db|+}tRdc| |+d]Yd}+~+nd}+~+wwxYwtaj0|z }|jr|nt |ddkr |dddn|}.t| |\}/}0|/rtde| ||.n*tWdf| |t ||j#rK |#dg| dd||/hn.#t($r!}tj%d |Yd}~nd}~wwxYwd|_| di| dj|dkdl|jrCtj%dm| dn|dodptj%dqt |dr||jXrM |X|j| | |n.#t($r!}tj%ds|Yd}~nd}~wwxYwt|| |jt|t}|j[\| | }1|1r||1z }d||jd }2| |2|js|jr;t5du|dn|dodpt5|dv|nEt ||jkr|d|jdzn|}3t5du|dn|dodw|3|jr|t |jkr}t |j|z }4||jd|4dxd|j|dD]2}|jj} ddy| dz|jd } | | 3n>|j]d kr1|t |jkrtaj^|j]#t |j}5|5d kr)t||5 dt|{dSdS)|z`Execute tool calls sequentially (original behavior). Used for single calls or interactive tools.rNr=r>Tr rr?r@rz(Unexpected JSON error after validation: rrrrzrrFrrGrrHr rIrrJrrKzexecuting tool: rPrLrMrNrArrBrCr)rDrrErrrrrrrrrqrprrrrrr r rr rprrrrrrrrrrrrrru🔀 delegating z tasksrru🔀 u🔀 delegatingrYr[r\rrr,r)rzContext engine tool 'z ' failed: z1context_engine.handle_tool_call raised for %s: %srz Memory tool 'z1memory_manager.handle_tool_call raised for %s: %srrRrSz&handle_function_call raised for %s: %srrirTrjrkrur rhrTrlrmrnrRrorrvrwrrrsrtz remaining tool call(s)u[Tool execution skipped — z* was not started. User sent a new message]rz)`rrrrr5r\rrhrrrrrrrrlrZrrrrrtrur2rr1rGrr~r;r4r-r]rUrQr=rrr>rfrrr{r|rrrr}r*rmrrnrrrgrrr<rvrrorxrr!rrBrrrrrr@rrr_delegate_spinnerrRr_get_tool_emojirr r2rrrrXrCr3r?rrrrr-rr)6rPrVrrrkrrremaining_calls skipped_tc skipped_nameskip_msgrrr _block_msgrrrrQrrrrrrtool_start_timerrr#r$rprr%r& tasks_arg spinner_label goal_previewrr_delegate_resultremoji _ce_resultrV _mem_result_spinner_resultr_is_error_resultrrrrr num_tools_seqs6 rRrz&AIAgent._execute_tool_calls_sequentials%&7&BAFFr ,r ,LAy( "3">qstt"D"~LLDO!p!pSQ`MaMa!p!p!px|L}}}"1..J#-#6#;L &#uL#u#u#u(2   H OOH----%.3M # $ 9+=+G H H ' # # # N1 N NOOO "  #mT22 # " )-J NNNNNN<<!=:K:Qr     %!H,,/0D,,"n44./D+? n:m%HHH'n[[[m[[d=CUCUCWCW>X>X[[[\\\$,,Xtz-XYhm7n7n7nooppppORS[}}_c_tOtOt8,BT-B,B#Ce#K#K{CLlllmlld=CUCUCWCW>X>Xll^jllmmm!%2"$$%G %G%GHHH !MMMMMM))$*>???? D!d&A!M1-OOG// wXeffff MMMM"K6"K"KLLLLLLLLM!d&>!J,,Y\=-XXXX JJJM"H"H"HIIIIIIIIJ!m7N&N&NSWSgSo&N - 1 1&" = =I #'#7#P#PQZ#[#[,>>$&? &?&?!D!mz&A&AdFZFb&A'++Ir::C.s33+// ::dbiXZXaXcXc>d>d,>>!?S"X!?!?!D#ikkO%"&*gz-BQV"W"W"W # &((CCCCCC",*'++G44'++GU;;*### !% o = 88::CLL"B&A&-Yfo~&&&"B"BCCC"222' &*jUMn1o1o&p&pOO[[[[[[&5o+//<<$1$5$5m$D$D+//;;++/? '''O!% o = 88::MLL"L&ABRTacpzI'J'J'J"L"LMMM(**&**8X>>IIIIII".,(,,X66!)--i88*..z::, ###'M,=,=h,G,GK],],],<<)--h;;")--i<< % $ o = 88::ELL"D&A(M[hrA'B'B'B"D"DEEE)++LLLLLL"/-*..z2>>)--i88!2### !% o = 88::FLL"E&A)]\isB'C'C'C"E"EFFF/11OOOOOO)--g66 bIt!J$a$:L$:$:$:PaM88::$t?_?_?a?a$!=)H)J)JKKD+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 _(__555560W >]dFe5e5e?$4+F$!=)H)J)JKKD+M::E1-OO`S`G+t,G,Ge,G,Gg,G,GV\gkguvvvGMMOOO!  6&*&=&N&N}^kv~&N&&O!0JJ @@@&*j';xS`;x;xlv;x;x1y&z&zOLL!TVceoz~L@%)IKK/$AM:=-YfoyzzzH6 X....6 _(__555 %)IKK/$AM:=-YfoyzzzH6 X....6 _(__55556%@ >$*>*G*G *V*V@ >88::$t?_?_?a?a$!=)H)J)JKKD+M::E1-OO`S`G+t,G,Ge,G,Gg,G,GV\gkguvvvGMMOOO"  6&*&:&K&KM[h&i&iO"1KK @@@&*j';p=;p;pdn;p;p1q&r&rOLL!TVceoz~L@%)IKK/$AM:=-Yfoz{{{H6 X....>>@@6 _(__555 %)IKK/$AM:=-Yfoz{{{H6 X....>>@@6 _(__55556( >88::$t?_?_?a?a$!=)H)J)JKKD+M::E1-OO`S`G+t,G,Ge,G,Gg,G,GV\gkguvvvGMMOOO"&6&:%}6G%.\#'?#8bEIEZ&dd4+@&A&A&A`d04 '''O'6OO uuu&]}&]&]Q[&]&]OLL!I=ZdosLttttttttu%)IKK/$AM:=-Yfo~H6 X....>>@@6 _(__555 %)IKK/$AM:=-Yfo~H6 X....>>@@6 _(__55556 u&:%}6G%.\#'?#8bEIEZ&dd4+@&A&A&A`d04 '''OO!uuu&]}&]&]Q[&]&]OLL!I=ZdosLttttttttu!% o = 040D__),_)=)=)C)C%%  #7}o"V"V  a wC]Tacqrrrr A=R_adetauauvvv* MM//(-t!.9I0!MMMM"K6"K"KLLLLLLLLM"&D   !ZM!Z!Z]!Z!Z!Z!Z [ [ [# ` WmWW=WWWWXXX ^c/.B.B^^_^^___* MM// m]\kllll MMMM"K6"K"KLLLLLLLLM8''%L"#455 O 3CCMS`aaL 0</* ) H OOH % % %? d'dMMMMMMMNNN$,,ZIIJJJJZ]^mZnZnqurG[G[G7M8M7M'NQV'V'VM\$bbbbbbP`bbccc( Q5F5Q1R1R-R-R 1 <==A  kkkkksw xxx"3">qrr"B..J#-#6#;L &#z,#z#z#z(2   H OOH----""q3/@/K+L+L'L'L 4?+++-899 1   - 9~N_?`?` a a a a a a  s+C  C<C77C<D00 D=<D==J J! J!.(K L!K==LL,, M6MM-AN>> O  O #BQ** Q76Q7+A[00 [=<[=.AgA7h;k<;n0< m :mn0m  n00A#ps=<v>= u :uv>u  v>>A0x.?|  })&} }  A0A@<A=AA>A> AB8B&AB3B3AB8EAE:E: AF%FAF F AF%HAH<H< AI'IAI"I"AI'c z td|jdd}|d|d |}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 |j v}|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#|vr4tSj*d$d|tRj+% }|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#|vr4tSj*d$d|tRj+% }|r|d&|dnd'}nd'}nH#tX$r;} t[j.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.rr)rrPrNrrrrrrxrTrkrzr{r|rZr)r+rrprrqrrr%rr])rar)r+rrrHrIrerfriteration_limit_summaryrrz.*?\s*rBrz>I reached the iteration limit and couldn't generate a summary.)r+rrrerHrIrfiteration_limit_summary_retryz Failed to get summary response: z"I reached the maximum iterations (z!) but couldn't summarize. Error: ro)0rGr,rrrr!rrdr3rrLrinsertrrrIr&rrrqrr+rHrr<r6r7r8r9r?rarr>rTr+rr9r:rrrr@rrDrrrlr[)!rPrrksummary_requestrrIrrinternal_fieldeffective_system sys_offsetrpfmsummary_extra_bodyrrsummary_responserVrrsummary_kwargsr_bak_nar_ant_kw_msgretry_response retry_msg_bak2_nar2_ant_kw2 _retry_msgrs! rR_handle_max_iterationszAIAgent._handle_max_iterationss bT5Hbbbccc .  ODDEEEH A#>>@@OL - -((**&Y66NKK5555"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 AsV>W33 X8=1X33X8stream_callbackpersist_user_messagec tddlm}|jt |t rt|}t |t rt|}t |t rt|}t |t rt|}|_ d_ |_ |pt tj }d_d_d_d_d_d_d_d_d_d_d_jdkr; rdn#t8$rYnwxYwjrd_t?j _!tE|dkr |dddzn|} | #d d } tH%d jpd j&j'pd j(pd tE|pg| |rtS|ng} |r.j*+s,|xj-dz c_-||n|} d} j.dkr9dj/vr0j0r)xj1dz c_1j1j.kr d} d_1d|d} | 2| tE| dz }|_ j3s84d|ddtE|dkrdnddj5=d}|rQj6rJ j67j}|r|8dpd}n#t8$rYnwxYw|r|_5nމ9|_5 ddl:m;}|djj&tyddpdn2#t8$r%}tH=d|Yd}~nd}~wwxYwj6rY j6>jj5n2#t8$r%}tH?d|Yd}~nd}~wwxYwj5}j@rjtE| jAjBjAjCzdzkr|8d)r)|2t |d)Ut |t r)|Lr|2||rd*M|}n2#t8$r%}tH=d+|Yd}~nd}~wwxYwd}d}d}d}d} d}!d}"d}#d }$tjOjP_QtdjQjSrtdjQd_Tnd_Ud_TjVrK t | t r| nd}%jVWj-|%n#t8$rYnwxYwd}&jVrG t | t r| nd}'jVX|'pd}&n#t8$rYnwxYw|j krj!jYdksjZRrj[\jSr"d}d,}$j3s4d-Rn|dz }|_]^d.|jZrd_ZnTj!_s;d/}$j3s04d0j!j`d1j!jad2Rn2jb" g}(tt| D]\})}*|*8d3d4kr|*8d5rtE| |)z }+i| |+dD]N},|,8d3d6krn2|,8d7}-|-r|,8d8d|-<Ofd9|*d5D}(nb||(n3#t8$r&}.tH?d:||.Yd}.~.nd}.~.wwxYwjedkrd;j/vrxjfdz c_fg}/t| D]\}0}1|1g}2|0|kr|18d3dkrg}3|&r&t|&}4|4r|32|4|r|32||3rI|28d8d}5t |5t r|5d*zd*M|3z|2d8<|18d3d4kr|18d<}6|6r|6|2d=<d<|2vr|2id<d>|2vr|2id>|2id?djrk|2|/2|2|pd}7jlr|7d*zjlzL}7|7r d@|7dg|/z}/jmrK|7rdnd}8tjmD]0\}0}9|/n|8|0z|9g1jor t|/jqjdkA}/r|/}/|/D]G}:t |:8d8t r|:d8L|:d8<H|/D]}:|:8d5};|;sg}<|;D]t trddBvr_ tjtdBdC}=idBidBdCtju|=dDdEiin#t8$rYnwxYw|<2|<|:d5<t|/tdF|/D}>t|/}?d j3syd jzdG|d1j dyjzdHtE|/dI|?d dJ|>d dKyjzdLjErtEjEndntj|tj~}@tj|tj}Ajr|@d |Adnqs]rItj|gdM}Bt|@d |Ad|BjN  jrt j?dOj&dPtE| dQjErtEjEndt j?dR| r| dSd3nd t j?dT|?d dUtj}Cd}Dd$}Ed}Fd$}Gd}Hd}Id}Jd}Kd}Ld}Md}NdV}Od}Pd}Q|D|Ek0r؉j'dWkr ddXlm}Rm}S|R}T|T|TdkrdY|S|TdZ}Uyjzd[|Ud\d]d[|Urd}Dd}#d}F| |d[|Ud^| |dd|Ud_Sn#t$rYnt8$rYnwxYw |/}Qjrt#|Qjd`kr|Qda}Q ddl:m;}|db|jpdj(pdj&j'jj|tE|/tEjEpg|?|>jcn#t8$rYnwxYwt+ddr|Qdef fdg}Vd}Wtydhdrd}Wn;s'ddilm}Xt tydjd|Xrd}W|Wr|Q|Vk}Pn|Q}Ptj|Cz }Y r dd jrdj3s!yjzdl|YdmdnjrH|Prty|Pdodpndp}Zt j?dq|Zdrt9|Pdsr|Pjndpd}[g}\jd`kr@|Pty|Pdtdnd}]|Pd}[|\2dun%t |]tRsd}[|\2dvn|]sty|Pdwd}^t |^t r|^Lnd}_|_r*tH?dxtE|_nty|Pdyd}`ty|Pdzd}atH=d{|`|aty|Pdodd|jd}j'd}[|\2d~njdkrv|Pty|Pd8dnd}b|Pd}[|\2dunt |btRsd}[|\2dn|bsd}[|\2dn|Pt9|Pdr|Pj|Pjssd}[|P|\2dunYt9|Pds|\2dn2|Pj|\2dn|\2d|[r| r dd jrd|Ddz }DjtEjkrdrd}Dd}#d}Fdd}c|Prpt9|Pdr_|PjrXt |Pjt9|Pjdr,|Pjjr |Pjj8dd}cn/|Pr-t9|Pdr|Pjrt |Pj|cdkr$|Pr"t9|Pdor|Pj&r d|Pj&}c|cdkrM|PrKdtI|PD}djrt j?d|dd}e|Prt9|Pdr|Pjryty|Pjdd}f|f4t |Pjtr|Pj8d}f|f+ tM|f}en#tNtPf$rYnwxYw|edkrd|Ydd}gna|edkrd|Ydd}gnS|edkrd}gnJ|edvr d|ed|Ydd}gn;|edvrd|ed}gn0|e d|ed|Ydd}gn#|Ydkrd|Ydd}gn|Ydkrd|Ydd}gnd|Yddn}gyjzd|Dd1|EddM|\d]yjzd|cd]}hyjzd|hd]yjzd|gd]|D|Ekrd|Edrd}Dd}#d}F )d|Edt jjzd|Ed| || d|d|Ed|gddStU|Ddd}iyjzd|idd|gdd]t j=d|Dd1|EddM|\d|ctj|iz}jd}ktj|jkr߉jSr[yjzdd]| |d|gd|Dd1|Ed| |dddStjd|kdz }k|kdzdkrB^d|Dd1|EdÐtM|jtjz dĝtj|jkߐ jd`krpty|Pdyd}lty|Pdzd}md}nt |mtr|m8dŦ}nnty|mdd}n|ldkr|ndvrd}OndV}Onjdkr#dVd5ddVdɜ}o|o8|PjdV}On\|Pjdj}O|Pjdj}p|O|p| r!yjzdʝd]d}O|Odkr)yjzd˝d]d}qd}rjdvrdt9|Pdr|Pjr|Pjdjnd}s|srty|sd8dnd}q|srtty|sd5dnd}rnsjdkrhg}tty|Pd8gD];}uty|udddkr$|t2ty|udd<|trd M|tnd}qt|qo!tajd|qt`j}v|r o|vo|qdur|q p|qdu}w|wrWd}xyjzdѝd]d}y|| ||y| |dd|xdӜSjdvr|Pjdj}p|pjs| dz } |p|O}z| 2|z|pjr |"|pjz }"| d$krZyjzd| d՝ddd}{| 2|{| _| d}N"nZ|"L}||| |||pd| |ddddӜSjdvr|Pjdj}p|pjr|!dkr&|!dz }!yjzd؝d]0yjzdٝd]|| |d| |ddddӜStE| dkrfyjzd۝| }}|| |d|}|ddddӜSyjzdܝd]| |d| |dddd_St9|Pdsr |Pjrty|Pjj'jަ}~|~j}|~j}|~j}|||dߜ}jA|tyjAddr~jAjG}tyjAddrDtj&j|4jzd|d dj&djA_djA_xj|z c_xj|z c_xj|z c_xjdz c_xj|~jz c_xj|~jz c_xj|~jz c_xj|~jz c_xj|~jz c_d}|~jr|rd|~jd1|dd|~jz|z dd}tH%djj&j'pd ||||Y| tj&|~j'jtydd}|j#xjt|jz c_|j_|j_j6rjr j6j|~j|~j|~j|~j|~j|jt|jnd|j|jj'j|jdkrdndj& n#t8$rYnwxYwjr3t j?d|dd d|dd d|dd jor̉jdkr1ty|Pjddpd}ty|Pjddpd}nDty|Pjdd}|rty|ddpdnd}|rty|ddpdnd}|d}|dkr||z dznd}j3s-yjzd|d d1|d d|dd|d d d}Lj'dWkr" ddlm}|n#t8$rYnwxYw^d|dn)#t$r r dd jrdtj|Cz }yjzdd]| |d}d|dd}Ynt8$rw} r dd jrdt |trrtydddkrZt |}d|vpd|v}t| }|r6xjdz c_yjzdd]Yd}~8|rd_t| }t |/tRrt|/t |Qtrt#|Qd}t tyd dtRrtjm}d}t tyd dtRrtjE}d}t |t r!t|}||kr |}|_5d}t tyd dt r)tjl}|jlkr |_ld}d}t tyd dtrj8d nd}t |trt#|}d}tyddpd}|rt|}||kr|_t tyd dtr |jd<tydjd"t9jdr |j_d}yjzdd]xjdz c_|p |p|p|p|p|}|r!yjzdd]n yjzdd]Yd}~ ty|dd}|}tydd}|rty|ddnd}t|tyddpdtydodpd|?||/rtE|/nd}tH?d|jj|j|j|j|j|j||L|j|\}}L|rYd}~*jd`krQj'dkrE|dkr>|Hs|d]|rY|d?krRty|d@d}|rt |ddAnd}|r"yjzdB|d]yjzdC|dmdDtE|/dE|?d dUrdFvryjzdG|dHd]jr@yjzdId]yjzdJd]yjzdK|d]jSryjzdLd]| |dM|dNt |d| |dddcYd}~Sty|dd}|jtjkr)d}jA}|jG}||kr|j&|jtyddj'Ot9|drd|_d|_yjzdP|d dQ|d dUd]|#dz }#|#|GkrtE| }I| ||?|%\} }d}tE| |ks||kr?dR|d dS|d dTtjdd}MYd}~n|jtjtjfv}|rvjtEjkrYj}|duo|}|s6dUr d}Dd}#d}FYd}~"r|r|j'dWkrq|jtjkrZ|sX ddVlm}ty|dWd}|rty|dXdnd}|||Yn#t8$rYnwxYw|E}DYd}~"|jtjk}|r|#dz }#|#|GkryjzdZ|Gd[d]yjzd\d]t jjzd]|Gd^| || d|d_|Gd`ddddacYd}~Sdb|#d1|GdtE| }I| ||?|%\} }d}tE| |krJdc|dQtE| ddtjdd}MYd}~ nyjzded]yjzd\d]t jjzdf| || d|dgddddacYd}~S|jtjk}|rjA}|jG}t}|td|dhz }|_ yjzdi|d dj|d dk|d dd]|#dz }#|#|GkryjzdZ|Gd`d]yjzd\d]t jjzdl|Gd^| || d|dm|Gd`ddddacYd}~Sd}MYd}~ nt}|r2||kr,|}yjzdn|d dS|d dd]nt|}|r||kr|j&|jtyddj'Ot9|dr!d|_t|o||k|_yjzdo|d dQ|d dUd]n yjzdpd]|#dz }#|#|GkryjzdZ|Gd`d]yjzd\d]t jjzdl|Gd^| || d|dm|Gd`ddddacYd}~Sdq|?d dr|#d1|GdtE| }I| ||?|%\} }d}tE| |ks|rc||kr]tE| |kr,dc|dQtE| ddtjdd}MYd}~njyjzdsd]yjzdtd]t jjzdu|?d dv| || d|dw|?d dxddddacYd}~St |tPtNfot |t }|pq|j oi|j oa|jtjtjtj tjtjtjtjfvo| }|rdy|dzr d}Dd}#d}FYd}~)|Q|Qd{||d}|d|yjzd~|dd]yjzd;|d<|d]yjzd=|5d]|js|jtjkr8|dkr|dkryjzdd]yjzdd]yjzdd]yjzdd]nɉyjzdd]yjzdd]yjzd|dd]dt |5vr yjzdd]n yjzdd]t jjzd||dkr;|?dkstE|/dkr!yjzdd]n| |d| |ddt |d_cYd}~S|D|Ekr|Fs$||D|Er d}Fd}DYd}~,މd|Edr d}Dd}#d}FYd}~-|}|rd|Ed|›nd|Ed|›yjzd|›d]ty|dd ot!fddD}|r@yjzdd]yjzdd]t jdjz|E|||tE|/|?d |Q|Qd||| |d|Ed|›}|r|Đdz }|| |dd|d_cYd}~Sd}|rtyty|dWddXd}|r{t9|Ɛdri|Ơ8dp|Ơ8d}|r; t#tM|Ǧd}n#tNtPf$rYnwxYw|r|ntU|Ddd}i|r%d|id|Ddzd1|Edn d|id|Dd1|EdtH=d|i|D|E|tj|iz}jd}ktj|jkrjSr^yjzdd]| |d|Dd1|Ed| |dddcYd}~Stjd|kdz }k|kdzdkrC^d|Dd1|EdÐtM|jtjz dĝtj|jkYd}~nd}~wwxYw|D|Ek0|rd}$n(|Mr(|dz}j!|Ddz }Dd}M9 |Nr9$|P4d}$tjzd| |n jd`kr|P\}p}On=jdkr ddlm}||Pj\}p}On|Pjdj}p|pjt |pjt sr|pj}t |trG|ɠ8ddp)|ɠ8d8dptju|ɦ|p_nt |tRrg}|D]}t |t r|ʠ2|˦-t |trC|ˠ8dͦdkr*|ʠ2|ˠ8ddt |tr,d|vr(|ʠ2t |dd M|ʦ|p_nt |ɦ|p_ ddl:m;}ty|pd5dpg}|pjpd}| d/|jpdj(pdj&j'jj||Y|OtE|/ty|Pdod|PtE|ͦtE|̦dn#t8$rYnwxYw|pjr}j3svjr&yjzd|pjnIyjzd|pjddtE|pjdkrdnd|pjrjr|pjL}ΐtajdd|ΦL}|r$|ΐd dddnd}|r@tydddkr* d|ϦnH#t8$rYndkoe|Ӡ8d8pd|z8d8pdko5|Ӡ8d<pd|z8d<pdko||k}|s+| 2|z|zjd$krLj3s'yjzdjd| _| @d_| |d| |ddddӜSt9drd_|pjrj3s4yjzdtE|pjdjrL|pjD]Dt j?djjdjjddÅdE|pjD]zjjj/vrajj}|r<tjzdĐjjd|כd|אj_{fdƄ|pjD}|ؐrlxjdz c_dMtAj/}|d}tE|ڦdkr |dddzn|}ۉyjzd|ۛdȉjdjd$krJyjzdɝd]d_| |d| |ddd|ۛdӜS|p|O}| 2|ܦ|pjD]Ujjj/vrdːjjd|ٛ}nd}| 2d6j!|ݐdΜVCd_g|pjD]jj}t |ttRfr"tju|ަj_Q|ށ@t |t s+t |ަj_jj}|r|ޠLsdϐj_ tjt|ަ#tj"$r=}2jjt |fYd}~d}~wwxYwrt!fdЄ|pjD}|r_yjzd|Odҝd]d_|| |d| |ddddӜSxjdz c_d\}yjzd|dԐjd$kr(yjzdjd՝Eyjzd՝d_|p|O}| 2|dքD}|pjD]`jj|vr(tGfdׄD}d|dٝ}nd}| 2d6j!|dΜaFd_$|pj|p_%|pj|p_|p|O}|pjpd}|r|r|_tMhdۣtOfd܄|pjD}|_|rrd_nIj3rB|L}|ryd|d}| rt | dStri| dS8d?rN| id}| r6t | dStr| dS8d?N|rd_d_d_| 2|ܦ|ܦj(r( (dn#t8$rYnwxYw)|p| ||d}!d_*dބ|pjD}|dhkrj!jA}|j+dkr|j+|j,z}nt| }j@rT||r?4dI| |jAj+|%\} }d}| _| I|pjpd}d_|sFtyddpd}|rud}$|L}tH%dtE|d|}d_-nttydd}|rtyddrzd}$tH%ddd_d_d_|L}d_-nԐt!d| ddD}|rtyddsd_d_d_tH%dd|p|O}d|d8<| 2|| 2dddLtty|pd= %s threshold (model %s, ctx %s)ru📦 Preflight compression: ~z tokens >= z thresholdr)rr pre_llm_callr )r<rYr is_first_turnr+r sender_idrrzpre_llm_call hook failed: %sinterrupted_by_useru2 ⚡ Breaking out of tool loop due to interrupt...zstarting API call #budget_exhaustedu% ⚠️ Iteration budget exhausted (rcz iterations used)rrrrrrcg|]N}t|t|dd|ddOS)rrhr)rhr?r)rr_results_by_ids rRrz,AIAgent.run_conversation..!si*** %'#-b$#7#7 *,.zN6,B.<.@.@.N.N!"!"***rTz&step_callback error (iteration %s): %srrrrPrr) cache_ttlnative_anthropicrr)rr) separators sort_keysc3NK|] }tt|V!dSr_rErUs rRrz+AIAgent.run_conversation..P"s.DDc#c((mmDDDDDDrTu🔄 Making API call #u 📊 Request size: z messages, ~z tokens (~z chars)u 🔧 Available tools: )brainsparklepulsemoonstarr\zAPI Request - Model: z , Messages: z , Tools: zLast message role: r2zTotal message size: ~z tokensrRr)nous_rate_limit_remainingformat_remainingu,Nous Portal rate limit active — resets in r3u⏳ z Trying fallback...r zg No fallback provider available. Try again after the reset, or add a fallback provider in config.yaml.)rr api_callsrrRrrZr-pre_api_request) rr<rr+r%rr&rkrK tool_countapprox_input_tokensrequest_char_countrHHERMES_DUMP_REQUESTS preflightrcvrddjrddSdSr)rRr@)rPthinking_spinnersrR _stop_spinnerz/AIAgent.run_conversation.._stop_spinner"sT+4,11"555/3,17 2226666677rTrr~rEr|u⏱️ API call completed in rnrRr+zN/AzAPI Response received - Model: z , Usage: rrzresponse is Nonezresponse.output is not a listrGzaCodex response.output is empty but output_text is present (%d chars); deferring to normalization.rQrzeCodex response.output is empty after stream backfill (status=%s, incomplete_details=%s, model=%s). %sz api_mode=rxzresponse.output is emptyzresponse.content is not a listzresponse.content is emptyrz#response has no 'choices' attributezresponse.choices is Nonezresponse.choices is emptyu(´;ω;`) oops, retrying...u<⚠️ Empty/malformed response — switching to fallback...Unknownrrwrrzmodel=cni|]2\}}|d|t|dd3S)rNr")rr[r(s rRr+z,AIAgent.run_conversation..n#sA)v)v)vdadedpdpqtdudu)v!SVVDSD\)v)v)vrTz*Response attributes for invalid response: r i z-upstream provider timed out (Cloudflare 524, z.0frTizupstream gateway timeout (504, rz'rate limited by upstream provider (429))rizupstream server error (r)iizupstream provider overloaded (r zupstream error (code rzfast response (rhus) — likely rate limitedzslow response (us) — likely upstream timeoutzresponse time u&⚠️ Invalid API response (attempt z): u 🏢 Provider: u 📝 Provider message: u ⏱️ u⚠️ Max retries (u.) for invalid responses — trying fallback...u❌ Max retries (z,) exceeded for invalid responses. Giving up.zInvalid API response after z retries.z retries: )rrrrrRr`r) base_delay max_delayu⏳ Retrying in zs (z)...zInvalid API response (retry z | Provider: u3⚡ Interrupt detected during retry wait, aborting.z$Operation interrupted during retry (z , attempt r')rrrr interruptedrrzretry backoff (z), z s remainingrrU>rr:r)end_turnrrH stop_sequenceuA⚠️ Treating suspicious Ollama/GLM stop response as truncateduQ⚠️ Response truncated (finish_reason='length') - model hit max output tokens)r\r[rrz8<(?:think|thinking|reasoning|REASONING_SCRATCHPAD)[^>]*>zModel used all output tokens on reasoning with none left for the response. Try lowering reasoning effort or increasing max_tokens.uV💭 Reasoning exhausted the output token budget — no visible response was produced.u⚠️ **Thinking Budget Exhausted** The model used all its output tokens on reasoning and had none left for the actual response. To fix this: → Lower reasoning effort: `/thinkon low` or `/thinkon minimal` → Increase the output token limit: set `model.max_tokens` in config.yaml)rrrrpartialru↻ Requesting continuation (z/3)...z[System: Your previous response was truncated by the output length limit. Continue exactly where you left off. Do not restart or repeat prior text. Finish the answer directly.]z9Response remained truncated after 3 continuation attemptsu=⚠️ Truncated tool call detected — retrying API call...uf⚠️ Truncated tool call response detected again — refusing to execute incomplete tool arguments.z-Response truncated due to output length limitu3 ⏪ Rolling back to last complete assistant turnu-❌ First response truncated - cannot recoverz3First response truncated due to output length limitr)rcompletion_tokensr_context_probed_context_probe_persistableu💾 Cached context length: z tokens for z cache=r r"z%)zHAPI call #%d: model=%s provider=%s in=%d out=%d total=%d latency=%.1fs%sr$)r%rr$includedsubscription_included) input_tokens output_tokenscache_read_tokenscache_write_tokensreasoning_tokensestimated_cost_usd cost_status cost_sourcebilling_providerbilling_base_url billing_moder+zToken usage: prompt=rz , completion=rz, total=rcache_read_input_tokenscache_creation_input_tokensprompt_tokens_details cached_tokensr u 💾 Cache: z tokens (z% hit, z written))clear_nous_rate_limitz API call #z completedu ⚡ Interrupted during API call.z3Operation interrupted: waiting for model response (z s elapsed).u(╥_╥) error, retrying..._unicode_sanitization_passesrz'ascii'ruH⚠️ Stripped invalid surrogate characters from messages. Retrying...rLrr3rFru⚠️ API key contained non-ASCII characters (bad copy-paste?) — stripped them. If auth fails, re-copy the key from your provider's dashboard.ud⚠️ System encoding is ASCII — stripped non-ASCII characters from request payload. Retrying...uT⚠️ System encoding is ASCII — enabling full-payload sanitization for retry...rrri@ r%)r%r+rr num_messageszTError classified: reason=%s status=%s retryable=%s compress=%s rotate=%s fallback=%s)rrrrr^ru8🔐 Codex auth refreshed after 401. Retrying request...r\u<🔐 Nous agent key refreshed after 401. Retrying request...rCruC🔐 Anthropic credentials refreshed after 401. Retrying request...zBearer (OAuth/setup-token)zx-api-key (API key)u-🔐 Anthropic 401 — authentication failed.z Auth method: rz Token prefix: z Token: (empty or short)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= • Legacy cleanup: hermes config set ANTHROPIC_TOKEN ""uA • Clear stale keys: hermes config set ANTHROPIC_API_KEY ""ruV⚠️ Thinking block signature invalid — stripped all thinking blocks, retrying...zP%sThinking block signature recovery: stripped reasoning_details from %d messageszAPI error recovery (attempt z;API call failed (attempt %s/%s) error_type=%s %s summary=%srz [HTTP r4u!⚠️ API call failed (attempt u 🔌 Provider: z Model: u 🌐 Endpoint: u 📝 Error: rrru 📋 Details: u ⏱️ Elapsed: z s Context: z msgs, ~zsupport tool useu$ 💡 No OpenRouter providers for z1 support tool calling with your current settings.zU Your provider_routing.only restriction is filtering out tool-capable providers.zY Try removing the restriction or adding providers that support tools for this model.zH Check which providers support tools: https://openrouter.ai/models/u?⚡ Interrupt detected during error handling, aborting retries.z+Operation interrupted: handling API error (rruO⚠️ Anthropic long-context tier requires extra usage — reducing context: ru🗜️ Context reduced to z tokens (was z), retrying...u9⚠️ Rate limited — switching to fallback provider...)record_nous_rate_limitrr)rru❌ 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.)rrrrrrRcompression_exhaustedu@⚠️ Request payload too large (413) — compression attempt u🗜️ Compressed z messages, retrying...u2❌ Payload too large and cannot compress further.z/413 payload too large. Cannot compress further.z9Request payload too large (413). Cannot compress further.@uM⚠️ Output cap too large for current prompt — retrying with max_tokens=z (available_tokens=z; context_length unchanged at z!Context compression failed after z3Context length exceeded: max compression attempts (u)⚠️ Context limit detected from API: u3⚠️ Context length exceeded — stepping down: uM⚠️ Context length exceeded at minimum tier — attempting compression...u🗜️ Context too large (~u tokens) — compressing (u8❌ Context length exceeded and cannot compress further.u 💡 The conversation has accumulated too much content. Try /new to start fresh, or /compress to manually trigger compression.zContext length exceeded: z! tokens. Cannot compress further.zContext length exceeded (z" tokens). Cannot compress further.u!⚠️ Non-retryable error (HTTP u) — trying fallback...non_retryable_client_error)rru❌ Non-retryable error (HTTP u%❌ Non-retryable client error (HTTP z ). Aborting.uK 💡 Codex OAuth token was rejected (HTTP 401). Your token may have beenz? refreshed by another client (Codex CLI, VS Code). To fix:z? 1. Run `codex` in your terminal to generate fresh tokens.z3 2. Then run `hermes auth` to re-authenticate.u9 💡 Your API key was rejected by the provider. Check:u- • Is the key valid? Run: hermes setupu+ • Does your account have access to rrlu? • Check credits: https://openrouter.ai/settings/creditsu6 💡 This type of error won't be fixed by retrying.zNon-retryable client error: irJuU⚠️ Skipping session persistence for large failed session to prevent growth loop.)rru") exhausted — trying fallback...u❌ Rate limited after u retries — u❌ API failed after u 💀 Final error: c3 K|]}|vV dSr_ro)rrrs rRrz+AIAgent.run_conversation..'s7$$qAN$$$$$$rT)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 u The provider's stream connection keeps dropping — this often happens when generating very large tool call responses (e.g. write_file with long content). Try asking me to use execute_code with Python's open() for large files, or to write in smaller sections.rrrr*rSgN@u#⏱️ Rate limit reached. Waiting zs before retry (attempt z s (attempt z4Retrying API call in %ss (attempt %s/%s) %s error=%szr" _thinkingzreasoning.availableuL⚠️ Incomplete detected (opened but never closed)u🔄 Retrying API call (z/2)...uA❌ Max retries (2) for incomplete scratchpad. Saving as partial.z/Incomplete REASONING_SCRATCHPAD after 2 retriesru0↻ Codex response incomplete; continuing turn (z/3)z@Codex response remained incomplete after 3 continuation attempts_codex_incomplete_retriesu🔧 Processing z tool call(s)...z Tool call: z with args: ru🔧 Auto-repaired tool name: 'z' -> 'cNg|]!}|jjjv|jj"Sro)rrhrX)rrrPs rRrz,AIAgent.run_conversation..4)s;***-/;+43HHH (HHHrTu⚠️ 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.)rrrrc3K|]P}|jjdDv|jjpdd VQdS)ch|]\}}|Sroro)rrrs rRrz5AIAgent.run_conversation...})s3T3T3T$!QA3T3T3TrTr)}r4N)rrhrrr)rrinvalid_json_argss rRrz+AIAgent.run_conversation..z)sw)) "!{/3T3TBS3T3T3TTT"$!6!<" D D F F O OPZ [ [[TTTT))rTu>⚠️ Truncated tool call arguments detected (finish_reason=u) — refusing to execute.u1⚠️ Invalid JSON in tool call arguments for 'rSu;⚠️ Injecting recovery tool results for invalid JSON...ch|]\}}|Sroro)rrhrs rRrz+AIAgent.run_conversation..)s,S,S,SgdAT,S,S,SrTc3BK|]\}}|jjk|VdSr_r)rrrrs rRrz+AIAgent.run_conversation..)s9.h.hTQRSWYWbWgRgRgqRgRgRgRg.h.hrTzError: 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|]}|jjvVdSr_r)rr_HOUSEKEEPING_TOOLSs rRrz+AIAgent.run_conversation..)sB00 "K,0CC000000rTu ┊ 💬 c&h|]}|jjSrorrs rRrz+AIAgent.run_conversation..*s Y Y Yb!1 Y Y YrT execute_codeu ⟳ compacting context…r9partial_stream_recoveryuGPartial stream content delivered (%d chars) — using as final responseuD↻ Stream interrupted — using delivered content as final response_last_content_with_tools$_last_content_tools_all_housekeepingfallback_prior_turn_contentuOEmpty follow-up after tool calls — using prior turn content as final responseuM↻ Empty response after tool calls — using earlier content as final answerc3HK|]}|ddkVdSrTrrr4s rRrz+AIAgent.run_conversation..*sE.. !EE&MMV3......rT_post_tool_empty_retrieduHEmpty response after tool calls — nudging model to continue processinguD⚠️ Model returned empty after tool calls — nudging to continuernz~You just executed tool calls but returned an empty response. Please process the tool results above and continue with the task.uMThinking-only response (no visible content) — prefilling to continue (%d/2)u7↻ Thinking-only response — prefilling to continue (z/2)uBEmpty response (no content or reasoning) — retry %d/3 (model=%s)u/⚠️ Empty response from model — retrying (uOEmpty response after %d retries — attempting fallback (model=%s, provider=%s)uL⚠️ Model returning empty responses — switching to fallback provider...u↻ Switched to fallback: z.+sP((( !)!T22(89uuV}}7N7Nn-7N7N7NrTrzError executing tool: zerror_near_max_iterations(z0I apologize, but I encountered repeated errors: zmax_iterations_reached(u#⚠️ Iteration budget exhausted (u) — asking model to summariseu) — requesting summary...rhc3K|]I}t|tr2|ddk0|dEdVJdS)rrrrNrr/ s rRrz+AIAgent.run_conversation..+sf  !T"" '(uuV}} 'C'ClH[H['C 'C'C'C'C  rTzuTurn ended: reason=%s model=%s api_calls=%d/%d budget=%d/%d tool_turns=%d last_msg_role=%s response_len=%d session=%sz>Turn ended with pending tool result (agent may appear stuck). z last_tool=%s post_llm_call)r<rYassistant_responserr+rzpost_llm_call hook failed: %srlast_reasoningrrrrrresponse_previewed_response_was_previewedrrrr r)rrrr r r interrupt_message)rrrrr)r<rrr+rzon_session_end hook failed: %s)r (6rxr0rr<rrZr[rrr7r:r;r]r^_invalid_tool_retries_invalid_json_retries_empty_content_retries_incomplete_scratchpad_retriesr _thinking_prefill_retriesr1 r+ r, rr r&rrrrr,rzr,rRr\rr2r3r+r%rrrn has_itemsrrrrrXrortrr2r rdrg get_sessionrrrrrgrlrrrrrrr+rrrrrrrrrVr~rsrtrrUrrrrx on_turn_start prefetch_allrr)rfnew_turnr.r]rrr{rCrrrrurrr!rrr3rLrr&r4r'rrrrrrr*rr5rrr@get_thinking_facesget_thinking_verbsr@rrrrr1rr*agent.nous_rate_guardrrrr ImportErrorrcrr%rrErrHrIrGrrrrarRrLrrrSrRrrwrvarsrrrrYrrrZr stop_reasonrPrXr@rrEr@rrrrrcrr>rr?rrrupdate_from_responser/rrrrrrrrrrrrr rr r> amount_usdrrrQrrrupdate_token_countsr rXUnicodeEncodeErrorrrrrrFr$rErr rrr retryableshould_compressshould_rotate_credentialshould_fallbackr)rr rGr?rr rCrr r!thinking_signaturerrjrryrr6long_context_tierrr!r r has_availabler payload_too_largecontext_overflowr.rrbr-r, overloadedis_authrrrrrqrr>r#r=rrrFrrrrhrrrYrrnextrr frozensetallrDrr8rrr9 rrrXrrsync_allqueue_prefetch_allr( rPrYrrrrrrr _msg_previewroriginal_user_message_should_review_memoryuser_msgcurrent_turn_user_idx stored_prompt session_row _invoke_hookrractive_system_prompt_preflight_tokens_pass _orig_len_plugin_user_context _pre_results _ctx_partsrfrkrrcodex_ack_continuationslength_continue_retriestruncated_tool_call_retriestruncated_response_prefixcompression_attempts_turn_exit_reason _turn_msg_ext_prefetch_cache_query prev_tools_idx_m _fwd_start_tm_tcid _step_errrIrrr _injections_fenced_baserkrrramtcsnew_tcsargs_obj total_charsrrverbr]api_start_timerrprimary_recovery_attemptedmax_compression_attemptscodex_auth_retry_attemptedanthropic_auth_retry_attemptednous_auth_retry_attemptedthinking_sig_retry_attemptedr restart_with_compressed_messages restart_with_length_continuationrPrr$r_fmt_nous_remaining_nous_remaining _nous_msgr_use_streamingrr resp_modelresponse_invalid error_details output_items _out_text_out_text_stripped _resp_status_resp_incompletecontent_blocksr resp_attrs_resp_error_code _code_raw _failure_hintcleaned_provider_errorr sleep_end_backoff_touch_counterrQrincomplete_reasonstop_reason_maprV_trunc_content_trunc_has_tool_calls _trunc_msg _text_parts_blk_has_think_tags_thinking_exhausted_exhaust_error_exhaust_response interim_msg continue_msgpartial_responserolled_back_messagescanonical_usagerrr usage_dictctx _cache_pct cost_resultr9writtendetailsrhit_pctr api_elapsedr_err_str_is_ascii_codec_surrogates_found_messages_sanitized_prefill_sanitized_tools_sanitized_system_sanitized_sanitized_system_sanitized_ephemeral_headers_sanitizedr_credential_sanitized_raw_key _clean_key_any_sanitizedrr _compressor_ctx_len classifiedrecovered_with_poolrr auth_method_dhh_fn_dhh elapsed_timer_error_summary _provider_model_status_code_str _err_body _err_body_str _reduced_ctxrold_ctx original_lenis_rate_limitedrpool_may_recoverr _err_resp _err_hdrsis_payload_too_largeis_context_length_error available_outsafe_out parsed_limitnew_ctxis_local_validation_erroris_client_error_final_summary_is_stream_drop_final_response _retry_after _resp_headers_ra_rawrrrr_assistant_tool_calls_assistant_text _think_text first_lineinterim_has_contentinterim_has_reasoninginterim_has_codex_reasoninglast_msglast_codex_itemsinterim_codex_itemsduplicate_interimrepairedinvalid_tool_callsr invalid_nameinvalid_previewrlrr* _truncatedrrecovery_assistant invalid_nameserr tool_result turn_content_all_housekeepingclean _had_prefill _tc_names _real_tokens_partial_streamed _recoveredfallback_prior_was_tool _nudge_msg_has_structured _truly_empty_prefill_exhaustedreasoning_preview final_msg answered_idserr_msgr_last_msg_role_last_tool_name_tcs_turn_tool_count _resp_len _budget_used _budget_max _diag_msg _diag_argsr7 r?_should_review_skillsr' rrr# rrs ` @@@@@@rRrzAIAgent.run_conversation- s<  766666DO,,, %%''' lC ( ( >/ ==L *C 0 0 N#78L#M#M  lC ( ( :+L99L *C 0 0 J#34H#I#I !0)-&.B+#8s4:<<'8'8&'"%&"&'#./+)*&)*&(-%(,%491#( ,-) =0 0 0 1133%%&       $ -  , , . . .(,D % !00C D D7:,6G6G"6L6L SbS)E11R^ #++D#66  ^ O %vtz4=3MI M &Y,@,FB(G(G     2FM4,---2  ;(8(B(B(D(D ;  $ $%9 : : : "9M8X 4 4^j !&  '! + + 555&6  $ $ ) $ $'4+FFF(,%+,(#|<<!!! #H  1)>& |   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  $; H  7 G"&"9"H!IKL!MMM !>28bj(D!!!  !D$;$LLL Z(,,.?CCJ.=AA $$U8IUUU"5FTUUU #1XXE #H I595K5K .@Q 16L662H28}} 11 ,0( 34D/56D248D1@ED=/4D,(E &:&@b"j0D)))% )4+B+SSST " @ F F F F F F'<?2%)(^^#'(<#=#==j z488>B!$ D99?R   L%'J! ) )a&&)155+;+;)%%c!I,&7&788883'')AGGII)%%a((( ?'-{{:'>'>$ @ @ @ NN93 ? ? ? ? ? ? ? ? @ "#"#&'#$&! % %.$<$>$>$D! ud7888  $ : 4!: ; ; ;49D 1 1&*D #49D 1    5?@UWZ5[5[c11ac $2243H)TTTT    !    2<=RTW2X2X`..^`&*&:&G&G&O&O&USU##     3338M8WZ[8[8[`d`w8[  ) ) + + +( " $9!\$$%Z[[[ a N#1D  !G~!G!G H H H & */''*2244 $6!_$$&^dNcNh&^&^kolAlK&^&^&^___!-f!#J$-hx.@.@$A$A""b66&>>[88RVVL=Q=Q8),X)=J-/N'/ '<SS#&776??f#<#<$)E(+(?(?#(!S[deeeeeeeef *Q..&$*???''1,''L%h//. -. -S((**///CGGFOOv4M4M"$K*8"<=P"Q"Q"8'..w777+A#**+?@@@"[ ' Ir : :%eS11[16&++kBZBZ1ZGI.776??k11%(WW[%9%9N%F7E 34'))KK ,,,"g--KK000 /666 3355F<N O OPS__ $ F"29QQ )$*? @ @FFHC '' S(8#((**EEEE ' `<\UYUdx|yFJ^y^ ` ` `  66|DDL# : :bffY//55:$&yM$7$7$9$9ByM" + +ff\** ' 'B!"d++ ! b0@0@ !'+z"Z.2M'N'NH"B" 5"$Z.5 +TZ$,.2."."."55""BB )!!! D!NN2&&&&#*<  *, 7 7 7DD|DDDDDK:<HHM $ ? - r$/rrrrZ^Zmrrrsss XXs+>T+>+>+>????3355-$:Z:Z:\:\-$*=1^1^1^#_#_L'45H5Ht5H5H5HWcnrn|'}'}'}$$**,,,# P MdjMMcRZmmMMy}zDgKfijnjtfufufuJKMMNNN bH4`HRL4H4HZ`bbccc NmNNNNOOO!Y[[NKK). &'( $', &+0 *&+ %+0 (#O/4 ,/4 ,"MHJ ++ =F**'+D*C*E*E*6?Q;N;N!U-@-@-Q-Q!U!U!U&!LL#'? V V V V V&*)!--.@Y.@.@AAA#::<<)./ 78 4=B : ( 11(>U44Z 4TTT777777&*Nt%95AA3).!77993766666%gdHd&C&CTJJ3-2N%L#'#I#I&}$J$$$(#?#? #K#K#'9;;#?L(0(--b111+/(-3..r222?l %j%jWc%j%j%j%jkkk+XJR%]WXw%F%F%FX]  'W 'W'WovwBIpJpJ^U]e]k]kPU'W'WXXX(-$$&M}(999LTL`wx4'H'H'Hfj #+/3,)001CDDDD!+L$!?!?Q/3,)001PQQQQ!-Q )0-(N(NIFPQZ\_F`F`1h1B1B1Bfh.1Q & %N$'(:$;$;!"!"!"!" 07x4/P/P 3:8EY[_3`3` 0 &%W$02B$+Hgt$D$D$X $X$X$X$X !"!"!"48 0 - 4 45O P P P*>>>OWOc9d)K)K)Kim#+/3,)001CDDDD!+ND!A!AN/3,)001QRRRR!/N/3,)001LMMM#+78Y3O3O+S[ScSks{tDSk/3,'/ - 4 45G H H H H%,Xy%A%AR - 4 45Z [ [ [ [!)!1!9 - 4 45O P P P P - 4 45P Q Q Q'D!+4,112OPPP/3,17 222666$q(  /#d6J2K2KKK --.lmmm6688%*+K3409>6$%. (1 #>'(B(B>x~>(+HN(;(;I&x~zBBhx~G^h080G0K0KO]f0g0g %>'(I*F*F>8K[>(+H,<(=(=I)I55(5wxY`GaGa5fnft5,EX^,E,EM)I55(5)v)vd8nnFZFZF\F\)v)v)vJ#3i ' .g[e.g.g h h h,0(#)'(B(B)x~)(/(M(MI(0ZPT5U5U0,4N,>,>v,F,F (4!)7:9~~$4$4(1:'>!)!)!)$(D!) ,s22,p\h,p,p,p,pMM-44,bl,b,b,b,bMM-44,VMM-;;,nFV,n,nZf,n,n,n,nMM-;;,`M],`,`,`MM-9,lDT,l,lXd,l,l,l,lMM)B..,jl,j,j,j,jMM)B..,nl,n,n,n,nMM,P\,P,P,P,PM &X&X_j&X&Xmx&X&X~B~G~GHU~V~V&X&X`d eee %Z%Z=%Z%Zbf ggg151J1J91U1U. %k%kSi%k%ksw xxx %S%SM%S%S[_ ```&+55 --/A[/A/A/ABBB#::<<)./ 78 4=B : ( --.{+.{.{.{|||#MT_*o*oYd*o*o*oppp 11(>>7=#>&#H#H$/$6$6wtVR7P7P$Q$Q$QGR-\TYY{-C-C-CX\N+/*ry [ . " 00++!65 /"0t!;!wDDgDghvDwDw@w!:#1T#9 ,/ !9+ !LL#'?!E!E!E&*)!H.!889JKKK 11(#>$(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 ("("!" =,TTT080@0C0K-0;"#>#B#B$?1$D$?$(LL+/?(y(y(y.2%1%&%&%&%- $ '+%_%_%_*.!-!"!"!"!% < <=N O O O $ 5 5h@T U U U6:081?16/3-\ ("("!"x==1,, LLDO)p)p)pqqq373Z3Z[c3d3d0 889JKKK 11(@\^cddB 3DJ s S S S $ 0 0DO2A2Aad2A2A2Atxt~2A2A!B!B!BFKD3CQVD3N22mC2266:KK6611\A11..!3..11_5QQ1122o6SS2266/:[[6677?;]]77559YY55&( *<dd*d?3T*d*dWd*d*dhkl{mNiNO\i\*d*d*d*dJ f 2DJ @ZQZ)+3E03>3E0 +%%% $ 0 D D$(O1@1M2A2O6E6W7F7Y5D5U'2'='I8=[=S7T7T7TOS0;0B0;0B59]59]'2'9Z'G'G2I1HMQ*.*!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    '0(--.LMMM+/(-3..r222")-?@@q%WTSqstEuEuxyEyEy#&y>>#7#7#9#9*3x*?*V7hCV,I(,S,S),% ==B== LL#'? | | |&*)%HHHH*f%8DD=4DEY4Z4Z 1#48L#L#L;L$8ARD$>8<$5)'$8QSW*X*XZ]^^=7GHd7e7e 4#74;W#W#WCWD$@8<$516.$.gdH (;<@$9$(LL+/?)[)[)[/3 %1%&%&%&!==B== 3!9#5!9#3!9$5!9$6 !9 $9 + . " $ '+%]%]%]*.!-!"!"!"!" !% '+%M%M%M*.!-!"!"!"%HHHH"))]D"I"IK$($C$CI$N$NM#*$0Dd"K"KKQ\hw{4DfMMMbhH!3!!(z2!>!>!D"%dGR88>B&3'/:F%MS%6%6%6A """JLLn")/1G",j.H";Z=W <@;];]$/(7*4*;&3 <^<<8' +!  )::: M^;;'3.. :/6:2EEDEQQ% LLDO)u)u)uvvv$HHHH );;; MV33'3.. 9/591DD4DPP%!T_"r"r"rsss$HHHH )==='3..#D*>??/ >/:>6KKKKKKIIKK%!T_"y"y"yzzz$HHHH"5FUoVYFZFZ&u&B&B`u ___```OO+OOPPPTW^\_`c\d\dgi\i\iPP3ss8PPPPrvsBp^p^p^___EEEFFFSSSSSS&wyyFFTXFFFGGGFFVZFFFGGG~~~vvvwwwqqqrrruuuvvv#)^-NNN <O8<4"*BBB)"d33B "':D A A A #III"&%  A OS]] !1$K#'9;;#?L((S{SS[SSS"&i!9J #I 4 4 6 6I%)%>%>y%I%INNNU##"0022& !(j) D DI#D*i@@E$T7I>>FCN'V'?'?'?'?'?TV$LLDO"S"SVa"S"Sdo"S"St~"SAQ"S"S[_L```LLDO!c!cy!c!c[a!c!ckoLpppLLDO!N!Nu!N!NVZL[[[LLDO!T!TN!T!T\`Laaa"k{S'8'8$+Ivt$D$D @I(SItt(<(T>>:H&:480"8}}|;;w?U?U $ 1 1%F,$Z%F%F,3$E%F%F%F!"!"!"!% 1 CG @ %'1&7&1&.<'O' )4+?#dFZB[B[+[+[ $4+/t+;+T@R@R@T@T(/) --.ijjj#::<<)./ 78 4=B : ((! MV33&-1JJJ 3K !TTTTTT(/ :t(L(LI$-!7 9d C C C26&32(1.; )!!! D!'2  #)^-MM),.,1,/2JJJ LLDO*\*\[s*\*\*\dhLiii LLDO*P*P*PX\L]]]#MT_**[s***AAA 11( >  * 1 . 9 . 6 . 9 . ? . @ . @ . A:! '665$"'8))*sk*s*s*sttt6688%*+K3409>6$HHHH%1 88 *3OW`9))F[FF#88CCFF %w%w^i%w%w%w@D EEE %g%g9%g%g_e%g%gos ttt %R%R5%R%RZ^ ___%- A1BnF\1\1\(N::{c?Q?Q $ .M.M.MUY !Z!Z!Z $ .A.A.AIM !N!N!N $ .A.A.AIM !N!N!N $ -t-t-t}A !B!B!B!B $ -z-z-zCG !H!H!H $ -n-n-nvz { { { $ -u-ulr-u-u-u~B !C!C!C#/3u::3C3C3E3E#E#E$(LLDO2E2E2EMQL%R%R%R LLDO)s)s)s{LAAA &a&aV_&a&abbb '#--=53H3HCP\L]L]`bLbLb LL#'?!T!T!T&*) !11(a>a%;K?b??%:>6*+K$HHHH))*p*p*p*pqqq6688%*+K3409>6$HHHH)-)B)B9)M)M*r --.r .r.rbp.r.rssss --.pk.p.p`n.p.pqqq %^%^n%^%^fj kkk!( =$ G GG #$$$$=$$$!!(+ LL#'?!?!?!?'+ )!LL#'?!-!-!-'+ ) n O[.%vs(0)7).&*%3   $(L&)(/ :t0T0TV_ae(f(f ()W]E-J-J)&3&7&7 &F&F&j-J[J[\iJjJjG&)!)36s7||S3I3ILL(1:'>!)!)!)$(D!)0<  BRS^knz~BBBI&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(#?#?!M!M!M#)++ 11W A ++D/ $A!/ !#%,,...q 380/  $G!dddeee%%h0DEEEm =$5557;7U7UV^7_7_4%}}]&:::TTTTTT7S7S D4L8884%}})1(8(;(C% %,8L]LegjAkAk8+3C!#t,,=47GGFB4G4G4t377S\^`KaKa4teieopsetet)11#C.. = "$'@@D)$44@ % T 2 2 2 2!+D$!7!7@DHHV-> ? ? ?48IIe4D4D)1147HH)1NNNNNN,34E|UY,Z,Z,`^`)&7&?&E2O L* 1#'?#8b!%!4""j!%!%!%'5%1&3&),&7&7'.x$'G'G"FFxPP03O0D0D256K2L2L!$!D%,cT_c+c %d%dIZIb%d%deeee &b&bIZIbcgdgcgIh&bsvxIxQtRtRUXtXtXjojo^`&b&bccc&-!$2M!"3";"A"A"C"CK"$&G[##egg EP!W!2!24!8!8!;CRC!@!@UWJ! !gd4Eq&I&IA&M&M! 77 ZPPPP(!!! D!$!! 778M{\ghlilhl\mostttt(!!! D! -->-F-L"MM771<77LLDO"B"B"BCCC:a?? %|%|QUQt%|%|%|}}}  %z%z%zCG HHH>?;/3/V/VW_/`/`,445FGGG--h8LMMM/3(<)7).'+%V   783=$555-<:W:W22a722"&"?"?@QS`"a"aK*.  0J0J0Pb/W/W/Y/Y*Z*Z'^hitixixzEjFjFHK_L_L-WDb1Q1Q1W1W1Y1Y,Z,Z,ZRW)26{G^7_7_2`2`/*N.CNGbN3;#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 * 1N$OOK888 @@MMM599#R LLDO*Q*QmqnL*Q*Q*QRRR19...x888 56D2))(4HIII*.$,%3%*#'!c T#>??756D2%/S ?~ %|%|M^MiIjIj%|%|%|}}}+x"3">xxB#M*v 8H*v*vVXVaVklpmplpVq*v*v*vwwww0:<<;+43HHH'+'='=bk>N'O'OH'< %&|&|Y[YdYi&|&|qy&|&|&| } } }3; 0****3D3O***&*#!22a722%)IIfT5J.K.K$L$L '9!'< GJ  B!{/t7LLL*s2;3C*s*shq*s*s+G$OO(.02+2-- !12D.)+%/:QQ!{4%dT4L99%48Jt4D4DBK1$+JtS4I4I+47IIBK1#%;#8D#%4::<<%48BK1$Q Jt,,,,#3QQQ-44bk6FA5OPPPPPPPPQ)C%&)))))&7&B)))&& & LL#'?!^!^2?!^!^!^&*) :;D6 889JKKK 11(???-T,SAR,S,S,SM&7&B###%;#3}#D#D*..h.h.h.h=N.h.h.h*h*hC)I#)I)I)I%0K 3pK (,246E/:1"1"!#!#!#!# %23D.483P3P)444%0483O3O)444%0%)$A$ABSUb$c$cM $5#<#BL#D(K(KL(Y(YD8D5 /8999//+-00000&7&B000--)EVA,D1K1K1M1MD7;D44!_D$($<$<\$J$J$P$P$R$RE$D $ -B5-B-B C C C$)L ,&x|T::,%RL,,-@AA, ! '+ !,&x|T::,%RL,,-@AA,$89:66735:D1OOM22288GGG1!! 66t<<<<(!!! D!,,->J[]klll 34/04D, !Z Y%D"N05D, >>~NNe$D*LbQQWUW* >>?PQQ"0I-)-)A)ABS)T)T)Z)Z)\)\J"KK!> #J !--!4.8N;?D8!$+41KT#R#R# "6\^c(d(d "0M-"KK(yzzz --.}~~~<@D9HMDE:;D7 .2-E-Eh-O-O-U-U-W-WN;?D8!+...%-bcc]...++ ,!%$+D2Le$T$T!%=AD9=AD9HMDE"KK!9!--!6*.)F)FGXZg)h)hJ4=Jy1$OOJ777$OO(.%P--%+/#$5{DIIU&'8:MtTTU&'8:MtTT++ +%t/MPQ/Q/Q ::a?::"KK!@ $ > !--!H$($B!H!H!H+/*G*G 1<++K@DK(;<$OOK8885=D2 228<<<$,0+C+C*,,%''(" ,D $ >! C+( % %DV %\`\wz{\{\{ 771<77"NN!8 $ ;TZ !--!E$($?!E!E!E%()D,@)"NN!N $ ;TZ $  !--!D $::<< )>? ; $ 1 1%9%9%9(, %9%9%9!"!"!"!' %9$(J !"!"!" !) -G))-)@)@AR)S)S(,(E(EFWYf(g(g 3< i0  666)PSTbPcPcfiPiPitt0Du0L0Lo}-"NN!01B !--!O #NN!7!% ;TZ $ !-- Q@D@T$I#<#<#H!J *334D/56D2 )::: 1;3a77 CC)5.<%-D8014/&*&C&CDUWc&d&d   444<<[III%+!U(( ! 55519...x888 ./+04)B^)S46123/&*%=%=n%M%M%S%S%U%UN $ = =>OQ^ _ _I!'&x|T::'%RL,,-@AA' !  !'&x|T::'%RL,,-@AA'OOI...(W}(W(W(W%?~(()|n)|)|)|}}}0 0 0 bbbZ]^_Z`Z`bb ,,,,----,,,,LL+++++, ?Z^ ___ !X!2B;;C"3-C%c400wwv&00 wwv+55#'',:O:O5((%-cAghh%7((( #&l"399B#%KZD-A-AK8!$x|;;,246tH/S /S/S+"+" !) 8 8 8"T%81%<<<(VYsPRs^(V(V(V%%cXa%c%cNOO[^$T$TUUUEEEE =<<<RRN#$.W>DDW3W  h i@@@ $$%6777 h(<=== 6>G"))&1114 V # #x((  66&>>[00RVVL5I5I0l+DS 47D 9 9S*.r(,,z2*F*F*J*J6*R*RE       ,:@C'''q 595JQt,11PQ 9=9NUd+55TU  H  tz>4;N + ni O %v   V # #K # NP-.  -      K /J / / / /  E+ E EJJJJJJ ##!6'5)-h*$T:t<<B E E E>DDDDDDDD EH%%  Cwwv+--#''+2F2F-!$[!1 n n        u   ;  !'$0I5"Q"Q  TZ        D5  T7  !?  !$"A  =! " T7# $"&!? 5")$*ACWYZ"["["`_`"&"A33/   2(-$  B42 B*.*AF& ' !%!&  & * *+t/III"d&;;;$( !&'D #   N 7L  $--.C^TTT$778MNNNN      + 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 s(&)F FF8N:: OO/0P Q*Q  Q%R R/ R**R/.D\>> ]-]((]-.9`(( `54`55a88 bb=C-i++ j5jj!A w// w<;w<B+A=AE D)"AE E AE&E AE&E%AE&E*A"BUG A'AH5H4BUH5 AIH?BUIAIIQ(BUZ,F BU`:Aa a BUa Aa!aBUa Aa!a!EBUgABUhC?BUlA=BUnJ;BUyCBU|ABU}:A BUABU@A8BUB=BUCJ BUMBBO'O&BUO' BO4O1BUO3BO4O4DBUTBT#T"BUT# BT0T-BUT/BT0T0BUUBDE-W, DE-W6CDE([K"DE(f8DDE(kADE(lADE(m5A DE(oG/DE(wMDE(DDE-DE DE(I/BDE(L &DE(L1>CM0M/DE(M0 CM=M:DE(M<CM=M=DE(NB1DE(P9DE-P?B!DE(S&A?DE(U%DE-U+DDE(ZDE-ZDE(ZF*DE(aDE-aCDE(d B DE(fDE-fC$DE(jJDE(E(DE-G#G7Ef(OB'DRREf(R DRR Ef(RDRRDEf(V+DWWEf(W DWWEf(WDWWEf(W$DW<W;Ef(W< DX XEf(XDX X A;Ef(ZA0Ef([7I=Ef(e6&Ef(fH)Ef(oBEf(qC Ef(tDt2t1Ef(t2Du?u2Du:u4Ef(u:Du?u?B Ef(x A3Ef(y?CEf(}G;Ef(EEEEEf(E EE'E$Ef(E&EE'E'DEf(I.CEf(L2BEf(OCEf(RC,Ef(V BEf(X*B5Ef([!C7Ef(_B>Ef(bD Ef(f( Em?f3Em:g Eg"g!Em:g".EhhEm:hEhhEEm:m:Em?w;AEx>x> Ey.yEy)y)Ey.07F@(@( F@5@4F@5A(FA+A+ FA8A7FA8A<4FB1B1 FC!B;FCCFC!c@|||}|dS)a Simple chat interface that returns just the final response. Args: message (str): User message stream_callback: Optional callback invoked with each text delta during streaming. Returns: str: Final assistant response )rr)r)rPrrr?s rRr9z AIAgent.chatm,s(&&w&PP&''rT)8NNNNNNNNrr r!NNFFFNr"rNNNNFNNNNNNNNNNNNNNNNNNNNNFFNNNNNFr#FT)rrrrr_)FF)rr)r()NNNNN)rjrkrlrmrr[rsetterrrrrrrrrrSrrr rrrrrrr,rr staticmethodr5rrrr<r@r>rHrOrXrrrrrrrrrrrrrrrrrrrr#r rGrIrrVrZr]rcrerprurwrrrrrr[ rrrrrrrrtuplerr r"r,rErKrMrqrvryr~r r|rrQrrrrrrrrrrr r rrr!r)r+rarcrergrkrrrrrzrrrrrrrr0r@rHrMrTrVr\r^rrrrrrrrrr'r;rrrrr9rorTrRrrs#X_>c>d>>>_> %)!% &*'+"' % '+ #'+'+%)!,1(,+/(,+/&*'+%)"&*./3&*$(+/ ,015#'#(!!%.2)-$)(* % $smmmm m  m  ms)d"mm3i$mmmms)m 9m m !m"#m$"%%m&'m()m* 9+m, 9-m.c/m01m2&*3m4#&5m67m8!)9m:&;m<!)=m>$?m@%AmB#CmD EmF (GmH%-ImJ$KmL"MmNOmPsCx.QmRSmT S>UmVtCH~.WmXYmZ[m\!]m^!_m`amdemf,gmhS#Ximl"mmn#&ompqmrsmmmm^!%7%7%7NL L L L \$,1***D****6T& C$ C C C CUCUDUUUU( tCH~    aaaaF"CCcCTCCCC 4D4444 %S %T % % %\ %#'<<<<3-<  <<<\<" %s %t % % % %%c%d%%%%. 3 3     Gc Gd G G G\ GHHHHH$( CCC4. C  CCCC>EeEeEetCH~& Ee  EeEeEeEePAx}AAAAFVsVtVVVVD L L G"$# cc:cc c  ccccJ*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))))cc4>)>S#X>>>\>@CHTRUWZRZ^D\*&* PPPcNP P  " P $ PPPPd\@D@D$tCH~*>@D@D@D@DD/V/V/V/V/V/V/Vb====(C(D(((( #$&&&& d    $6  d d    8888t4S#X+?D@))))X)eIeI3eI#eIeIeIeIV++++\+ !y!a!a!abbCd38n)=C$tCQTH~BVCCC\CJTd\<GDGTGGG\G"33:8 0 0 0!!htDcN/C&D!PXY]^bcfhkck^lYmPn!!!!*       C  PS    \  x}hsm7S1T\&+/#3- :k$tCH~:NkSWX\]`be]eXfSgkkkkZ[c[d4S>>R[[[[B# MMMM M c3h MMMM^'C'C'''' cc b0#b0%S/b0b0b0b0H/#//// S    Y_\:R4RCRQURZ]RRRRh88888\8t33QU0"ss D4DDDDLWsWsWWWWG3G3G4GGGGyyDy#yV^yyyyvLgLgDLg#LgLgLgLg\FJdd:EI!!!T!T!!!!F%4%%%%N=3=4===="JJJJ@7;26 R&R&R&c]R& R& $N3 R&  S#X/ R& tTz R&R&R&R&hDTDDDD W"$W"W"W"W"v3333CD1c1c111\1 >S >T > > > > LT#s(^ LPT L L L L7s7t7777(#$       t    ?CE "E "E "E "3;E "E "E "E "RS1S1S1S1S1n?$????F#,)---## K"K47KFIK KKKK^#$\CE#xPT~BU2 ~0  ~0 "(+ ~0'sm~0 c3h~0~0~0~0@b ( (C ((82D (PS ( ( ( ( ( (rTrrrFrrr+r$r max_turnsr.r/ list_toolsr0 save_sampleverboser4c  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(----------------------------------------)webrCvisioncreativer)research developmentrXcontent_creation full_stacku 📌 Basic Toolsets:resolved_toolsrru • rz - rz Tools: u5 📂 Composite Toolsets (built from other toolsets):includesz Includes: z Total tools: ru! 🎭 Scenario-Specific Toolsets:20u3 📦 Legacy Toolsets (for backward compatibility):ru✅u❌rqrYrz Requirements: ru 🔧 Individual Tools (z available):u 📌 z (from r u 💡 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|]}|Srorrs rRrzmain..,s P P Pq P P PrTru🎯 Enabled toolsets: c6g|]}|Srorrs rRrzmain..,s !R!R!R!''))!R!R!RrTu🚫 Disabled toolsets: u💾 Trajectory saving: ENABLEDu: - Successful conversations → trajectory_samples.jsonlu7 - Failed conversations → failed_trajectories.jsonl) rr+r$r,r.r/r0r1r4u ❌ Failed to initialize agent: zTell me about the latest developments in Python 3.13 and what new features developers should know about. Please search for current information and try it out.u 📝 User Query: z3 ==================================================u📋 CONVERSATION SUMMARYu✅ Completed: ru📞 API Calls: ru💬 Messages: rru 🎯 FINAL RESPONSE:z------------------------------rsample_r) conversationsr/r+rrrr8r9Fr)rr6u" 💾 Sample trajectory saved to: u ⚠️ Failed to save sample: u 👋 Agent execution completed!)rG model_toolsr& rr' rr( r) rrrVr\rYrrrPrr[r]r^rr rZr=rdrWrrr))rr+r$rr! r.r/r" r0r# r$ r4r& rr' r( r) all_toolsetsbasic_toolsetscomposite_toolsetsscenario_toolsetsrhrr3rQ tools_str includes_strlegacy_toolsetsrQ all_toolsrenabled_toolsets_listdisabled_toolsets_listrrrr? sample_idsample_filenamerrs) rRmainrE |,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) NrNrrNNFFFFr)rmr6r*concurrent.futuresrrrrrr4rjr2rrr@rtr(r*r~typesrr]typingrrrrrrfirer pathlibr rr hermes_cli.env_loaderr r1__file__parent _project_env_loaded_env_paths _env_pathr3r8 rrrrr~rrrtools.tool_result_storagerrtools.interruptrrUrrrr|rragent.retry_utilsragent.error_classifierr r!agent.prompt_builderr"r#r$r%r&r'rr(r)r*r+r,r-r.r/r0r1agent.context_compressorr2agent.subdirectory_hintsr3agent.prompt_cachingr4r5r6r7r8r9r:r;r<r=agent.usage_pricingr>r? agent.displayr@rArrBrrCrDragent.trajectoryrErFrGrutilsrHrIrKrxrzr[ rrrrcompileVERBOSErrr[rrrrrrrrrrrrrrrrrrrE FirerorTrRra s*     8 $ $  !!!!!! ,,,,,,,,,,,, ,,,,,,544444  tH~~$v- &&<\ZZZK&GG  :IFFFFG KKIJJJ NMMMMMMMMMTTTTTTTT;;;;;;......100000NMMMMMMM......EEEEEEEE 766666<<<<<<>>>>>>VVVVVVVVVVVVVVVVVVVVVVDDDDDDDD 54444444.*.*.*.*.*.*.*.*b;;;;)7)7)7)7)7)7)7)7\" 9+..!y " " "  YCCCDD#  J  !bj!455)$))))X=C==PT===="??d?t???? -.. ss-D-T----`A3A3AAAA848D8888v0T0d0000 34T d    bi(bi(bi(bi(bi(bi(bi(bi(LS !#S/S/ S/ S/S/ S/  S/  S/S/S/S/S/S/S/S/S/S/l z DIdOOOOOrT