*"hjKZdZddlmZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZmZmZdd lmZdd lmZdd lmZdd lmZdd lmZmZmZddlmZm Z m!Z!m"Z"m#Z#m$Z$ddl%m&Z&ddl'm(Z(ddl)m*Z*ddl+m,Z,ejZe.Z/GddZ0Gdde*Z1y)zG Agent-driven evolve server implementation inside the unified package. ) annotationsN)datetimetimezone)Path)Any)bundle_entrypoint_bytesbundle_file_recordsbundle_tree_sha256)EvolveServerConfig)AsyncLLMClient)SkillIDRegistry)build_skill_md)_extract_session_metadatabuild_session_trajectorysummarize_sessions_parallel)delete_session_keysfetch_skill_bundlelist_object_keyslist_session_keys save_manifestsave_version_bundle)AgentWorkspace)load_agents_md)EvolveEngineMixin)OpenClawRunnercJeZdZdZ d ddZddZd dZy) _AnthropicMessagesLLMClientz:Minimal Anthropic Messages client for the summarizer path.cJ||_||_||_||_||_y)Napi_keybase_urlmodel max_tokens temperature)selfr"r#r$r%r&s 6/root/.hermes/SkillClaw/evolve_server/engines/agent.py__init__z$_AnthropicMessagesLLMClient.__init__2s(    $&ct|jxsdjd}|jdr|S|jdr|dS|dS)Nhttps://api.anthropic.com/z /messagesz/v1z /v1/messages)strr#rstripendswith)r'bases r( _messages_urlz)_AnthropicMessagesLLMClient._messages_url@sX4==?$?@GGL == %K == V9% %|$$r*c Kddl}ddl}g}g}|D]p}t|jdxsd}t|jdxsd} |dk(r| r|j | X|dvs]|j || dr|j |xsdddg|j d |j|j d |jd } |rd j|| d<| j|d dd} |jr|j| d<d} |jdd} |j| 4d{}t| D]} |j|j!| | d{}|j#|j%}g}|jdgxsgD]^}t'|t(s|jddk(s)|jd}t'|tsK|sN|j |`dj|ccdddd{Sdddd{y7 77#t*$rM|| dz krCt-d|z|j/ddzd}t1j2|d{7YXwxYw7e#1d{7swYyxYww)Nrrolecontentsystem>user assistant)r4r6r8r%r&)r$messagesr%r&z zapplication/jsonz 2023-06-01)z content-typezanthropic-versionz x-api-keyg@g>@)connect)timeout)jsonheaderstypetextrr )randomhttpxr.getappendr$popr%r&joinupdater"Timeout AsyncClientrangepostr2raise_for_statusr> isinstancedict Exceptionminuniformasynciosleep)r'r:kwargsrCrD system_parts body_messagesmessager4r6 request_bodyr? max_retriesr=clientattemptresppayloadpartsitemrAwaits r(chatz _AnthropicMessagesLLMClient.chatHs"$ .0  IGw{{6*0b1D'++i06B7Gx ''0,,$$dw%GH IZZ%J6b*I)J **\4??C!::mT5E5EF ( %+[[%>L "F#/!-  <<#'<)!        "!q0"1g:q!0D#DbI%mmD111  #    sA+K.CKIKJ2%I<I=AI I"!II#I*J2, K8I9K>J2? K J0 KIKA J-"J% #J-(J2+J--J20K2K8J; 9KKN)r5r,zgpt-5.4ig?) r"r.r#r.r$r.r%intr&floatreturnNonerfr.)r:zlist[dict[str, str]]rVrrfr.)__name__ __module__ __qualname____doc__r)r2rcr*r(rr/s_D3  ' ' ' '  '  '  '%:r*rc~eZdZdZddd ddZddZddZ d ddZdd Zdd Z dd Z dd Z d Z y)AgentEvolveServera?Agent-driven evolution server. Parameters ---------- config: Server configuration (storage, LLM, scheduling, OpenClaw settings). mock: If ``True``, use a local directory instead of remote storage. mock_root: Custom root for mock mode (default: ``evolve_server/mock/``). FNmock mock_rootc ||_||_|r5|3tttj j dz n|}|j||||_|jd|_ t|_ d|_ |jj|j|jt|j |_t%|j&|j(|j*|j,|j.|j0|j2|j4|_d|j|_y)Nrqrpr-F) openclaw_bin openclaw_homefreshr= llm_api_key llm_base_url llm_model llm_api_typezevolve-)config_mockr.r__file__resolveparent _build_bucket_bucketgroup_id_prefixr _id_registry_running load_from_ossrworkspace_root _workspacerrtrurv agent_timeoutrwrxryrz_runner_agent_session_id)r'r{rqrr default_mocks r(r)zAgentEvolveServer.__init__s  HLQZQbs4>113::VCDhq ))&t|)T  //*!, +-  '' dllC()>)>?%,, ..,,((**,,&&,,   $+6??*;!<r*cFKt|jjxsdjj }|dvrt |jj |jj|jj|jj|jj}t||d{y|dk(rt|jj |jj|jj|jj|jj}t||d{ytjd|xsd|D] }t|t!||d<d|d <"y77Gw) z?Attach compact trajectory/summary fields before workspace prep.r5>openai-responsesopenai-completionsr5ollamar!Nzanthropic-messageszk[AgentEvolveServer] summarizer does not support llm_api_type=%s; falling back to metadata + trajectory onlyz(empty) _trajectory_summary)r.r{rzstriplowerr rwrxryllm_max_tokensllm_temperaturerrloggerwarningrr)r'sessionsapi_typellmsessions r(_summarize_sessionsz%AgentEvolveServer._summarize_sessionssYt{{//526<<>DDF O O% //11kk++;;55 KK77 C.c8< < <  + +- //11kk++;;55 KK77 C.c8< < <  9  !    %G %g .%=g%FGM ""$GJ  %' = =s&CF! F B F!FAF!F!ci}|jD]/\}}t|j|j||}|s+|||<1|S)z9Fetch full bundle content for all skills in the manifest.)itemsrrr)r'manifestskillsnamerecordbundles r(_fetch_all_skillsz#AgentEvolveServer._fetch_all_skillssL.0$NN, &LD&' dllD&QF%t  & r*c|jdd}|sy|jj|}d|vr i|dt|j di}t |}|j d|d}|jj||t}t|jD]L\} } | dk(r |j d|d| } |j| |jj| | Nt|j|j d|dD]"} | |vs|jj| $tj |j#} t%|} dd| t'|d }|jj)|| || }t+|j|j ||||j-}i|j|i|||| | dd|d d t/j0t2j4j7|jd d|jddd ||<t9|j|j |t:j=d||||y)Nrr5zSKILL.mdutf-8zskills/z /SKILL.mdz/files/ bundle_v1)format entrypoint tree_sha256files)action bundle_recordr evolve_server descriptioncategorygeneral) rskill_idversionsha256rrrr uploaded_by uploaded_atrrz8[AgentEvolveServer] uploaded skill %s (id=%s, v%d) to %s)rEr get_or_createrencoderrr put_objectsetsortedraddr delete_objecthashlibr hexdigestr r record_updater_load_remote_skillsrnowrutc isoformatrrinfo)r'skill bundle_filesrrrmd_bytes object_keykeep_bundle_keysrel_pathdatakey content_shatree_sharrrs r( _upload_skillzAgentEvolveServer._upload_skills{ yy$ $$2248 \ )^l^Ju8M8T8TU\8]^L*<8 ~WTF)<   H5%(U$\%7%7%9: /NHd:%\\N'$wxjAC   % LL # #C .  /$DLLT\\N'$w2WX 0C** **3/ 0nnX.88: %l3!$#(6  ##11  ' 2  DLL$,,g|T++- ll4$  !#!$"7+*#<< 5??A 99]B7 *i8  dllDLL(; F      r*c Ktjdtj}|j d{\}}|stjdddddS|j |d{tjdt ||jjr|jj|j|jd{}|j|j|d{}|j}|jj!}|jj#||||||jj%}|jjs |j&nd} dt |d t |d } t)j*|j,j.t1|jj2| | d{} |jj5|} d} g}| D]}|d }|d }|j7|j9d|d}||d< |j|j:||j9di|d{| dz } |j=|||jj?||jjA|dd|j|jjF|jH|jJd{|jtL|jH|d{|jjOtj|z }tQjRtTjVjYt[|dt || | j\|d}|j_|tjdt || || j\|S777377 7#tB$r"}tjEd||Yd}~&d}~wwxYw737 w)a^Run one full agent-driven evolution cycle. 1. Drain session files from storage 2. Prepare workspace (sessions + existing skills) 3. Snapshot current skills state 4. Run OpenClaw agent 5. Collect skill changes from workspace 6. Upload changed skills to storage 7. Ack consumed sessions z4[AgentEvolveServer] === starting evolution cycle ===Nu6[AgentEvolveServer] queue empty — nothing to processr)rskills_evolvedagent_returncodez,[AgentEvolveServer] summarized %d session(s))rexisting_skillsr agents_mdskill_registry_infoz Process the z session file(s) in the sessions/ directory. Follow the instructions in AGENTS.md to analyze them and evolve the skill library in skills/. There are currently z existing skill(s).)workspace_pathrY session_idrrrrragent)r skill_namerrsourcez3[AgentEvolveServer] failed to upload skill '%s': %s) timestampelapsed_secondsrrr evolutionsz_[AgentEvolveServer] === cycle done: %d sessions, %d skills evolved in %.1fs (agent exit=%d) ===)0rrtime monotonic_drain_sessionsrlenr{rvrreset _call_storagerr_load_agents_mdr all_entriespreparesnapshot_skillsrrT to_threadrrunrrcollect_changes_sanitise_namerErrFr get_versionrQerror save_to_ossrrrcleanup_sessionsrrrrrround returncode_append_history)r't0r session_keysrragents_md_text registry_infobefore_snapshotrrYresultchangesrevolution_recordschangerrreelapsedsummarys r(run_oncezAgentEvolveServer.run_once2s  JK ^^ (,';';'=!=, KKP Q"#$( &&x000 : M ;;   OO ! ! #++D,D,DEE $ 2 243I3I8 TT--/))557  +$ -  //99;48;;3D3DT++$ 3x=/*#$'#7"88K M (( LL   : :;!   //11/B(* F7OEH%F&&uyy'HID E&M ((&&JJ~r2  !#!(("(&*$($5$5$C$CD$I#'#4#4#@#@#F")  >     ) ) LL LL     !4dllLQQQ ((*.."R'!hll3==?$Wa0H , & 1 1+   W% m M       y"> 1FT4 *   I  Rs=QP8Q8P9A1Q*P+#QP C4QP#AQ 1P)P&AP)$AQ$Q%(Q QC QQQ Q#Q&P)) Q2Q QQQQc|jj}|rFtjj |r't |d5}|j cdddStS#1swYtSxYw)z8Load AGENTS.md from custom path or the built-in default.r)encodingN)r{agents_md_pathospathisfileopenreadr)r' custom_pathfs r(rz!AgentEvolveServer._load_agents_mds_kk00 277>>+6kG4 vvx   s A))A;cKd|_tjd|jj|jrX |j d{tj|jjd{|jrWyy7D#t $r"}tjd|dYd}~hd}~wwxYw7Cw)NTz/[AgentEvolveServer] periodic mode: interval=%dsz#[AgentEvolveServer] cycle error: %s)exc_info) rrrr{interval_secondsrrQrrTrU)r'rs r( run_periodiczAgentEvolveServer.run_periodics  = KK ( ( mm Vmmo%%-- < <= = = mm% V BAPT UU V =sS>C BBB,C C C C B C$C<C CC cd|_y)NF)r)r's r(stopzAgentEvolveServer.stops  r*cddlm}ddlm|d}|j dfd}|j dfd }|j d d }|S) zAReturn a FastAPI app with ``/trigger``, ``/status``, ``/health``.r)FastAPI) JSONResponsezSkillClaw Agent Evolve Server)titlez/triggercRKjd{}|S7 w)Nr6)r)rrr's r(trigger_evolvez9AgentEvolveServer.create_http_app..trigger_evolves% MMO+G0 0,s '%'z/statusc Kjj}|jDcic]\}}||d|jddd }}}j t j jd{}jt|t||jjdScc}}w7Iw)Nrrr)rr)runningpending_sessionsregistered_skillsr fresh_moder) rrrrErrrrrrr{rv)entriesrr skill_summary pending_keysrr's r(statusz1AgentEvolveServer.create_http_app..statuss''335G '}}  D!  !*  uuY2M"&!3!3!  "L  #}}(+L(9),W+"&++"3"3  s.C#C 1CCA Cz/healthcKddiSw)Nr!okrmrmr*r(healthz1AgentEvolveServer.create_http_app..healthsd# #s)fastapirfastapi.responsesrrMrE)r'rapprr!r$rs` @r(create_http_appz!AgentEvolveServer.create_http_appsp#2;< *  1  1     0   $  $ r*)r{r rqboolrrz str | Nonerfrg)rz list[dict]rfrg)rzdict[str, dict]rfzdict[str, dict[str, bytes]])create)rrPrzdict[str, bytes]rr.rfrg)rfrPrh)rfrg) rirjrkrlr)rrrrrrrr(rmr*r(roros   $ =" = =  =  =D!%N" D D 'D  D  D TKb  >)r*ro)2rl __future__rrTrloggingrrrrpathlibrtypingrskillclaw.skill_bundlerr r core.configr core.llm_clientr core.skill_registryr core.utilsrpipeline.summarizerrrrstorage.oss_helpersrrrrrragent_workspacerrrcommonropenclaw_runnerr getLoggerrirrrormr*r(r:s# ' -,1' ,%%+   8 $SSlG)Gr*