iD[,dZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z m Z mZmZmZmZmZmZmZmZmZmZejZ ddlmZn #e$rdZYnwxYwddlmZmZm Z ddl!m"Z"hd Z#d Z$dd Z%d Z&d Z'ddZ(de)de*fdZ+dS)zt Hermes Web UI -- SSE streaming engine and agent thread runner. Includes Sprint 10 cancel support via CANCEL_FLAGS. N)Path)parse_reasoning_effort) STREAMS STREAMS_LOCK CANCEL_FLAGS CLI_TOOLSETSLOCKSESSIONS SESSION_DIR_get_session_agent_lock_set_thread_env_clear_thread_envclamp_reasoning_effortresolve_model_provider)AIAgent)Session get_session title_from)set_last_workspace>namerolecontentrefusal tool_calls tool_call_idcg}|D]`}t|tsd|D}|dr||a|S)a*Return a deep copy of messages with only API-safe fields. The webui stores extra metadata on messages (attachments, timestamp, _ts) for display purposes. Some providers (e.g. Z.AI/GLM) reject unknown fields instead of ignoring them, causing HTTP 400 errors on subsequent messages. c,i|]\}}|tv||S)_API_SAFE_MSG_KEYS).0kvs */home/ubuntu/hermes-webui/api/streaming.py z._sanitize_messages_for_api..5s)MMMdaQ:L5L5LQ5L5L5Lr) isinstancedictitemsgetappend)messagescleanmsg sanitizeds r#_sanitize_messages_for_apir/*st E$$#t$$  MMciikkMMM ==  $ LL # # # Lr%cd} t|}n#t$rd}YnwxYw tj|}n#t$rd}YnwxYw|rJ|rHt t |dgpgt t |dgpgkr|}n|}n|p|}|dS|dk}|rdnd}|rdnd} d|d | d |} |r | d |d z } |jr |jd nd} t| trT| ddkr;t| dd | krdS|j d| ttjdt|j|j|_|t$5|t&|<t)t&drt'j|ddddS#1swxYwYdS)zIAppend a visible assistant error to the session so reloads don't lose it.Nr+ rate_limitu⏱️u⚠️zRate limit reachedErrorz** z:** z **r assistantrrr timestamp move_to_end)r Exceptionrloadlengetattrr+r&r'r)strstripr*inttimertitlesaver r hasattrr:) session_id error_typemessagehintcached persisteds is_rate_limiticonlabelrlasts r#_persist_stream_errorrQ;s FZ(( L,,   V wy*b117R 8 8CPZ\^@_@_@ece wE.4..%..W..G #?4???"Z 11:b>>TD$$((6"2"2k"A"Ac$((S\^`JaJaFbFbFhFhFjFjnuFuFuJ%% QW--AGFFHHH --  8] + + -   , , ,------------------s- ##< A  A ?4HHHct|pd}|st|pgSt|pg}tdt |Dd}|r=t|ddpd|kr|S|d|ttjd|S)zEEnsure a returned final_response exists in persisted message history.r7c3vK|]4}t|tr|ddk0|V5dS)rr6N)r&r'r))r r-s r# z1_ensure_final_response_message..ssU  #t$$ ),K)G)G )G)G)G)G  r%Nrr6r8) r?r@listnextreversedr)r*rArB)r+final_response normalizedresultlast_assistants r#_ensure_final_response_messager\ks^)r**0022J $HN### (.b ! !F  #F++    N#n00B??E2FFLLNNR\\\  MM%% Mr%cd|dtj|dd}|j|d|jdS)z+Write one SSE event to the response stream.zevent: z data: F) ensure_asciiz zutf-8N)jsondumpswfilewriteencodeflush)handlereventdatapayloads r#_sseriseQQQtz$U'K'K'KQQQG Mw//000 Mr%r7c RSTtj|TTdStjRt5Rt |<dddn #1swxYwYRTfdS t }tt| |_ ||_ t||pt|dd|_t!}RriSdddi t%t5tj|dt j|dddddS#1swxYwYdS dd lm} t| } n0#t,$r#t.jd d} YnwxYwt3t|j d | t45t.jd } t.jd} t.jd} t.jd }t|j t.jd <d t.jd<t.jd<| r| t.jd < Sfd}Sfd}t6t-dt9|\}}}d} ddlm}||}|d}|s|d}|s|d}n+#t>$r}tAd|dYd}~nd}~wwxYwddl!m"}|}|di}tG|tHr|dtJntJ}t7||||dd|dtMt|ddpd|| }d|j d }d!|j d"}d}t|d#d} | r$|d$i}!|!d%i}"tG|"tHr| |"vr|"| }#tG|#tHr|#d&dp|#d'dg}$|#d(r|$'d)|#d(|#d*r|$'d+|#d*d,(d-|$D}nt|#}|r||_)|*||z|tW|j,|.}%t[|%d/p|j,|%d0|_,t|d1d}&d2}'|&r|&kr}(|&})t\|(d3z }*t\|)d3z }+|)|_/t`5|(tbvrtcj|(tb|)<dddn #1swxYwY|*2r;|+2s' |*3|+n#th$rYnwxYwd}'|'s*t|d4d},|,rt|,d5ddkrd}'|'rSd6dd7itkj5}-|j,D]S}.tG|.tHr<|.d8s'|.d9stm|-|.d8<Tto|j,|j8|_8t|d:dpd}/t|d;dpd}0t|dkr|7d?d}8tG|8tzr|8D]}}9tG|9tHrf|9d@dAkrM|9dBd}:|9dCd|3|:<|9dDi|4|:<|6|5|:<~|7dEgD]};tG|;tHs|;dBdp|;dFd}:|;dGi}<|<dCd}= ddl>}>|>?|<dHdIpdI}?n#t>$ri}?YnwxYw|:r|=r|=|3|:<|?|4|:<|6|5|:<ǐ|7d=dJkr|7dKp|7dLd}:|3|:d}=|=r|=dJkr|5|:dM}@|4|:i}?t|7d?d}A t}j?|A}Bt|BdNp+|BdOp|BdPp|AddQ}Cn#t>$r |AddQ}CYnwxYwi}DtG|?tHrct{|?@ddRD]9\}E}Ft|F}G|GddSt|GdSkrdTndz|D|E<:|2'|=|C|:|@|DdU{|2|_B|rt|j,D]}7|7d=dVkrot|7d?d}H|DdWdE}I|IddX|Hvs |HddX|vr||7dY<n|F ddZl!mG}J|Jd[rGdd\lHmI}K|K|j/|j9pd|j:pd|j;||j8t|j,]n#t>$rYnwxYw|/|0|1d^}Lt|d4d}M|MrBt|Md_dpd|Ld_<t|Md`dpd|Ld`<t|Mdadpd|Lda<Sdb|J|j,|2dcz|Ldd| !t.jd dn| t.jd <| !t.jddn| t.jd<| !t.jddn| t.jd<|!t.jd dn|t.jd <n#| !t.jd dn| t.jd <| !t.jddn| t.jd<| !t.jddn| t.jd<|!t.jd dn|t.jd <wxYwdddn #1swxYwYn#t>$r}NtAdetjLzdt|N}Odf|OMvpdg|Ovpdht|NjOv}P|Pr%di}Qtdj|O|QSdk|Odj|Qdln tdP|OSdk|OdPdmYd}N~Nnd}N~NwwxYwt%t5tj|dt j|dddddS#1swxYwYdS#t%t5tj|dt j|ddddw#1swxYwYwxYw)nzIRun agent in background thread, writing SSE events to STREAMS[stream_id].Ncr|dvrdS ||fdS#t$rYdSwxYw)N)cancelerror)is_set put_nowaitr;)rfrg cancel_eventqs r#putz!_run_agent_streaming..putsj     U2E%E%E F  LL% ' ' ' ' '    DD s6 AAreasoning_effortr7rlrHzCancelled before startr)get_active_hermes_home HERMES_HOME1) TERMINAL_CWDHERMES_EXEC_ASKHERMES_SESSION_KEYrurwrxryc,|dSdd|idS)Ntokentextr)r|rrs r#on_tokenz&_run_agent_streaming..on_tokens)<FGfd^,,,,,r%ci}t|trct|ddD]9\}}t |}|ddt |dkrdndz||<: d|||dddlm}m}m } | rM| 5t| i} dddn #1swxYwY| r d | dSdSdS) Nx...r7tool)rpreviewargsr) has_pending_pending_lockapproval) r&r'rUr(r?r=tools.approvalrrrr)) rrr args_snapr!r"s2 _has_pendingrrprrrFs r#on_toolz%_run_agent_streaming..on_toolst dD))\ $TZZ\\ 2 22A2 6\\1 VVBttHs2wws{{eeXZ4[Yq\\FTgyQQRRRWWWWWWWWWW< +++?? j"!=!=>>???????????????+J***** ++++s#$CCCz?AIAgent not available -- check that hermes-agent is on sys.path)resolve_runtime_provider) requestedapi_keyproviderbase_urlz2[webui] WARNING: resolve_runtime_provider failed: T)rd) get_configplatform_toolsetscli) modelrrrplatform quiet_modeenabled_toolsetsfallback_modelrFreasoning_configstream_delta_callbacktool_progress_callbackz [Workspace: z] z#Active workspace at session start: ab Every user message is prefixed with [Workspace: /absolute/path] indicating the workspace the user has selected in the web UI at the time they sent that message. This tag is the single authoritative source of the active workspace and updates with every message. It overrides any prior workspace mentioned in this system prompt, memory, or conversation history. Always use the value from the most recent [Workspace: ...] tag as your default working directory for ALL file operations: write_file, read_file, search_files, terminal workdir, and patch. Never fall back to a hardcoded path when this tag is present. personalityagent personalities system_promptprompttonezTone: stylezStyle:  c3K|]}||V dSNr)r rs r#rTz'_run_agent_streaming..$s'7O7OaQ7O7O7O7O7O7O7Or%) user_messagesystem_messageconversation_historytask_idpersist_user_messager+rXrFFz.jsoncontext_compressorcompression_count compressedz4Context auto-compressed to continue the conversationr9_tssession_prompt_tokenssession_completion_tokenssession_estimated_cost_usdrr6rtypetool_useidrinputrcall_idfunction argumentsz{}rr tool_use_idr5outputrZrmrr)rsnippettidassistant_msg_idxruserz [Attached files:< attachments) load_settingssync_to_insights)sync_session_usage)rF input_tokens output_tokensestimated_costrrC message_count)rrrcontext_lengththreshold_tokenslast_prompt_tokensdone)r+r)sessionusagez[webui] stream error: z rate limit429RateLimitErrorz*Rate limit reached. Try again in a moment.r1apperror)rHrrI)rHr)Qrr) threadingEventrrrr?r expanduserresolve workspacerrr>rsr rnrpop api.profilesrt ImportErrorosenvironr _ENV_LOCKrrhermes_cli.runtime_providerrr;print api.configrr&r'rrr*joinephemeral_system_promptrun_conversationr/r+r\r rFr r existsrenameOSErrorrBrArrCrrr enumeraterUr_loadsr(r=rrWsplitr@rDrapi.state_syncrcompact traceback format_exclowerr__name__rQ)UrFmsg_textrr stream_idrrsrL _agent_lockrt _profile_homeold_cwd old_exec_askold_session_keyold_hermes_homer}rresolved_modelresolved_providerresolved_base_urlresolved_api_keyr_rt_e _get_config_cfg_pt _toolsetsr workspace_ctxworkspace_system_msg_personality_prompt_pname _agent_cfg_personalities_pval_partsrZ _agent_sid _compressedold_sidnew_sidold_pathnew_path _compressor_now_mrrrr pending_names pending_argspending_asst_idxmsg_idxmcrrtcfnr_jrasst_idxrawrdrrr!r"rr base_text_load_settingsrr_cceerr_strrMrIrprrrqsU` @@@r#_run_agent_streamingr's IAy?$$L //". Y///////////////D.  # #$y//4466>>@@AA 3   B+=r B B   .j99       C9&>? @ @ @ f   . . K 4 ( ( (  Y - - - . . . . . . . . . . . . . . . . . .c  > ; ; ; ; ; ; 6 6 8 899MM > > >JNN="==MMM > Q[)))%     O >O >JNN>22'(9::,JNN+?@@/JNN=99/'*1;'7'7"*^ $*-"*& '-7"*) *  8*7bj'D > - - - - - + + + + + +!"cdddCYZ_C`C` @N-/@ $  ]PPPPPP..9JKKK#&779#5#5 (<(+ (;(;%(<(+ (;(;% ] ] ]O2OOW[\\\\\\\\\ ] = < < < < <;==D((.33C8B38M8M_|444S_I$**(!* $%!7CUWY8Z8Z8`^`!a!a&.'.E&<1;;;;MPakPPP !#' Q t44F 9!XXgr22 !+!D!Dnd33 9.8P8P*62E!%..9"'))OR"@"@"[EIIhXZD[D[!\ 99V,,D"MM*B5=*B*BCCC 99W--F"MM*DE'N*D*DEEE.2ii7O7O67O7O7O.O.O++.1%jj+" D0C-++*X53%? %K%K"%- ,F8 :&&4!* +,,AJ! d;;JK #jJ66$$&G):):)::&G):):)::& BB(**,4L,A,A)BBBBBBBBBBBBBBB??$$X__->-> 1111""  '%e-A4HH '7;8KQ#O#ORS#S#S"&K LU# 9;;Dj 0 0b$''0{0C0C0BFFSXMM0&)$iiB{O QW55AG"5*A1EEJL#E+FJJOaM$U,H$OONn1\AAN 3!}DAO L$%$4$9^#K JML! ' 331 1  55==K//i,,A!!T**@!"@@A)!T22@quuV}} 7R7R&'eeD"oo56UU625F5F c 245EE'24F4F S 18? 0 5eeL"55<<)"d33%$ ffT2..G"&&B2G2GVVJ33!vvfb11&----#%88BFF;,E,E,M#N#NDD(&&&#%DDD&<4<15M#.04L-4;,S1<UU6]]f,,%%//K1553K3KC(,,S"55D!46>> /33C<W44 8P8P/:Am,!E FFHHH FFFFFF!>##''(:;; AAAAAA&&#$<%&^%8q&'o&:'('7#g&)!*oo    %1MesttE%!5t<"*./& 7KT(R(R(R(R5D"*12& }d(K(K(K(K.="*]++ ~t D D D D/6"*^,#RZ^^4Et%L%L%L%L2>"*./& 7KT(R(R(R(R5D"*12& }d(K(K(K(K.="*]+====_O >O >O >O >O >O >O >O >O >O >O >O >O >O >O >b CCC ')*>*@*@@MMMMa&&% 7s5G;KsO_cghicjcjcsOs  C?D !*lGT J J J C "$     "*gw ? ? ? C AA B B B!C$   . . K 4 ( ( (  Y - - - . . . . . . . . . . . . . . . . . .   . . K 4 ( ( (  Y - - - . . . . . . . . . . . . . . . .s AAA B2{(+E  E$'E$.F { *F96{8F99/{(C {66w7-AMw7 M+ M&!w7&M++J*w7&Y; w7Y w7Y +w7;Zw7 Zw7ZJ'w7/e65w76 f w7f C w7A*j>=w7>kw7kEw7,A*rw7 r$!w7#r$$B w7.C {7C {{ {{{{{8 ~&B+~8~83+++/2/8AA@+AA@9 AAAAA A AAA AA A AArreturncHt5|tvr ddddStj|}|r|tj|}|r+ |dddifn#t $rYnwxYwdddn #1swxYwYdS)zISignal an in-flight stream to cancel. Returns True if the stream existed.NFrlrHzCancelled by userT)rrrr)setror;)rflagrqs r# cancel_streamr,s    G # #         **   HHJJJ K " "    h4G(HIJJJJ                    4s; BAB!A;:B; BBBBBBr)Nr7),__doc__r_rqueuerrBrpathlibrhermes_constantsrrrrrrr r r r r rrrLockr run_agentrr api.modelsrrr api.workspacerrr/rQr\rir'r?boolr,rr%r#r6s  333333 IN   !!!!!!!GGG7777777777,,,,,, ZYY"--------`2X.X.X.X.D STsAA$#A$