*"hj`/ UdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlmZddlmZmZddlmZmZddlZddlmZmZmZmZddlmZmZd d lmZd d l m!Z!d d l"m#Z$d d l"m%Z&d dl'm(Z(d dl)m*Z*ejVe,Z-dZ.dZ/dZ0dZ1dZ2hdZ3dZ4dZ5dxdZ6dydZ7e jpde jrZ:e jpdZ;e jpde jrZ<e jpde jrZ=dZ>dZ?dZ@d ZAd ZBd!d"hZChd#ZDhd$ZEd%hZFd&hZGhd'ZHd(hZIhd)ZJe jpd*e jZLe jpd+ZMdzd,ZNd{d-ZOd|d.ZPd!d/ d}d0ZQ d~d1ZRdd2ZSdd3ZTdd4ZUdd5ZVdd6ZWdd7ZXdd8ZYdd9ZZdd:Z[dd;Z\dd<Z]dd=Z^ dd>Z_ d dd?Z`dd@ZaddAZb ddBZcddCZdddDZeddEZfe jpdFe jdGfe jpdHe jdIfe jpdJe jdKfe jpdLe jdMfe jpdNe jdOfe jpdPe jdQfe jpdRe jdSfgZhdTeidU<ddVZjddWZkddXZl ddYZmddZZndd[Zo dd\Zp dd]Zq d dd^Zrdd_Zsdd`ZtddaZudbZvddcZwdddZxddeZyddfZzddgZ{ddhZ|ddiZ}ddjZ~ddkZddlZddmZddnZ ddoZddpZddqZddrZddsZddtZ d dduZGdvdwZy)z FastAPI proxy server for SkillClaw. Intercepts LLM requests from Claw agents, injects skills into system prompts, forwards to a real LLM API, and optionally collects PRM scores. ) annotationsN)asynccontextmanager)datetimetimezone)AnyOptional)FastAPIHeader HTTPExceptionRequest) JSONResponseStreamingResponse)SkillClawConfig) PRMScorer)anthropic_messages)openai_responses) SkillManager)run_llmzzzzz> turn_type session_id session_done_skillclaw_protocolrresponses_compatc"t|tr|St|trZ|Dcgc]:}t|ts|j ddk(s)|j dd<}}|rdj |SdS| t|SdScc}w)Ntypetext ) isinstancestrlistdictgetjoin)contentitempartss //root/.hermes/SkillClaw/skillclaw/api_server.py_flatten_message_contentr*<s'3'4 29s$Zd=SX\X`X`agXhlrXr&"%ss"'sxx/R/".3w<6B6tsB B B cZg}g}t|D]\}}t|ts|jd}|dk(r7|jd}t|tsO|sR|j |d|dk(sj|jd}|jdi}t|ts t j|d}|jd xsd |} |j | d |xsd |d ddj|j|fS#t$rd}YdwxYw)zLExtract plain text and OpenAI-style tool_calls from assistant content parts.rrtoolCallname argumentsF ensure_ascii{}idcall_function unknown_toolr-r.r2rr4r) enumerater r#r$r!appendjsondumps Exceptionr%strip) r& text_parts tool_callsir' item_typerr-argstc_ids r)"_normalize_assistant_content_partsrDEs,JJW%4$% HHV$  88F#D$$!!$' * $88F#D88K,DdC( ::d?DHHTN1aSkE   & $ 6%)! #6 HHZ & & (* 55! D s.D D*)D*z.*?z^call_(?:kimi|xml)_\d+$zu<\|tool_call_begin\|>\s*([a-zA-Z0-9_.-]+)(?::\d+)?\s*<\|tool_call_argument_begin\|>\s*(\{.*?\})\s*<\|tool_call_end\|>z"\s*(.*?)\s*imainside>1onyestrue>readreadfile file_read read_file skill_viewskill>mveditmovepatchwriter9renamereplace edit_file writefile file_write write_file append_file apply_patch create_filereplace_in_file skill_manage>bashexecshellterminalz)^\*\*\* (?:Add|Update|Delete) File: (.+)$zy([~./A-Za-z0-9_\-][^\n\"'`]*?(?:SKILL\.md|references/[^\s\"'`]+|scripts/[^\s\"'`]+|assets/[^\s\"'`]+|history/[^\s\"'`]+))c&t}|xsgD]}}t|tr8|jdxs$|jdxs|jd}n|}t |xsdj }|sm|j ||S)N skill_namer-rRr)setr r#r$r!r=add)itemsnamesr'rawr-s r)_extract_skill_namesrnseE  dD !((<(QDHHV,<Q@QCC39"~##%  IIdO Lct}|xsgD]<}t|ts|jt |j d>|S)Nmodified_skills)rir r#updaternr$)turnsrlturns r)_extract_modified_skill_namesrusKeE L dD ! LL-dhh7H.IJ KL Lrocttjjddj } t |}|dkDr|SdS#t $rYywxYw)NSKILLCLAW_LLM_REQUEST_TIMEOUT_S120g^@r)r!osenvironr$r=float ValueError)rmtimeouts r)_llm_request_timeout_secondsr~sZ bjjnn>F G M M OC*k7,u, s A AAdefaultc|tvrd}||n|}t|xsdjj}|s|S|tvr|Stj d|||S)zResolve request turn_type safely. Defaults to ``main`` to avoid silently dropping record/PRM paths when clients include a session id but forget to provide turn_type. rGrz1[SessionDetect] invalid turn_type=%r; fallback=%s)_VALID_TURN_TYPESr!r=lowerloggerwarning)header_turn_typebody_turn_typer candidaterms r)_resolve_turn_typersk''$4$@ nI io2  $ $ & , , .C    NNFWU Nroc||n|}t|tr|S|yt|jj t vS)z)Resolve session_done from header or body.F)r boolr!r=r _TRUE_STRINGS)header_session_donebody_session_doners r)_resolve_session_donersL (;'F#L]I)T" y>   ! ' ' )] ::roc|t|xsdj}|rt|dkDry tj|}t |trt|jdhz ry|jd}t |txrt|jS#t $rYywxYw)zGReturn True for Claude Code's internal generate_session_title response.rFtitle) r!r=lenr:loadsr<r r#rikeysr$r)r&rparsedrs r)"_looks_like_session_title_responsers w}"  # # %D 3t9s?D! fd #s6;;='9WI'E JJw E eS ! 9d5;;=&99 sB// B;:B;c4|ry|tk(r t|ryy)zAClassify recorded raw/main turns for user-turn cadence decisions.tool_use session_titlefinal)_PROTOCOL_ANTHROPIC_MESSAGESr)protocolr&r?s r)_classify_raw_turn_kindrs //4VW^4_ roc |dk(S)zEOnly final assistant responses advance the user-visible turn counter.r) raw_turn_kinds r)_is_user_turn_boundaryrs G ##roc|xsdj}|jdr|jddd}tj |s|xsdS t j |xsd}t|trbt|jdtr|jdryt|jd tr|jd ry y#t$ri}YwxYw) z Normalize tool names from model output. Fixes common drift where a call handle (e.g. call_kimi_0) is emitted as function name instead of the actual tool name. r functions..rr5r1commandrd sessionIdprocess) r= startswithsplit_TOOL_HANDLE_RE fullmatchr:rr<r r#r$r!)raw_nameargs_rawr-args_objs r)_normalize_tool_namers N ! ! #D |$zz#q!!$  $ $T *%~%::h.$/(D! hll9-s 3 Y8O hll;/ 5(,,{:S  sC## C10C1ct|xsdj}|jdr|jdddS|S)z3Strip transport-specific prefixes from a tool name.rrrr)r!r=rr)rr-s r)_normalize_tool_call_namer s@ x~2  $ $ &D |$zz#q!!$$ Kroct}g}|D]H}t|xsdj}|r||vr'|j||j |J|S)Nr)rir!r=rjr9)pathsseenoutpathcleans r)_deduplicate_pathsrs]UDCDJB%%'   5  Jroct|xsdj}|r|dvryd|vxs*d|vxs$|jdxs|jdS)Nr>..rF/\~zSKILL.md)r!r=rendswith)valuers r)_looks_like_pathr sV u{  ! ! #D 4;& $; [$$, [$//#*> [$--PZB[[rocttjt|xsdDcgc]A}|j dj s#|j dj Cc}Scc}wNrr)r_PATCH_PATH_REfinditerr!groupr=)raw_textmatchs r)_extract_skill_paths_from_patchr's^ -;-D-DSUWEX-YtE]b]h]hij]k]q]q]sQ   t ts $A7!A7cttjt|xsdDcgc]@}|j dj r|j dj Bc}Scc}wr)r_SHELL_SKILL_PATH_RErr!rr=)rrs r)_extract_skill_paths_from_shellr-se .66s7=b7IJ {{1~##% KKN "   sAA6cg}dD]O}|j|}t|ts%t|s1|j |j Q|jd}t|t rC|D]>}t|tst|s |j |j @t|S)N) rfile file_pathtarget destinationdesttosourcesrcold_pathnew_pathr)r$r r!rr9r=r"r)rBrkeyr raw_pathsr's r)#_extract_skill_paths_from_args_dictr7sE (  eS !&6u&= LL '("!I)T" +D$$)9$)? TZZ\* + e $$roc`t|tr|jdini}t|jdxsd}|jdd}t|ts t j |d}g}d} t j|}t|tr{|jt||jtvrKt |jdxs|jd xsd}|jt||jd vr|jt|n0|jtvr|jt||t|fS#t$rd}YwxYw#t$rd}YwxYw) Nr4r-rr.r1Fr/rcmd>rVr_)r r#r$rr!r:r;r<rextendrr_SHELL_TOOL_NAMESrrr) tool_callfunc tool_namerrrrs r)#_extract_skill_paths_from_tool_callrRsi,6y$,G9==R (RD)$((6*:*@bAIxx T*H h $ zz(?HEH::h'(D! 8BC ??  1 1(,,y1NX\\%5HNBOG LL8A B44 4X>?  / / 4X>? (/ //+ H  s$&F F FF F-,F-ct|tr|jdini}t|jdxsd}|jdd}t|ts t j |d} t j|}t|ts|ddfSd}dD]F}|j|}t|ts%|js6|j}nd D]I}|j|}t|ts%|js6||j|fcS|d|fS#t$rd}YwxYw#t$ri}YwxYw) zGExtract Hermes-native skill name + relative file path from skill calls.r4r-rr.r1Fr/)rr)rhr-rR) r r#r$rr!r:r;r<rr=)rrrrrrel_pathrrs r))_extract_hermes_skill_name_from_tool_callrqsP,6y$,G9==R (RD)$((6*:*@bAIxx T*H h $ zz(?H::h' h %"b  H$ S! eS !ekkm{{}H   /6 S! eS !ekkmekkmX5 56 b( ""+ H  s$&E>E EE E'&E'c\tjjt|xsdj }|rtjj |nd}|j |xs?|j |xs,|j t|xsdj }|r[t|j ddxsdt|j ddxsdt|xsdj dSddt|xsdj dS)Nrskill_idrhrrhr)ryr expanduserr!r=realpathr$)rskill_path_mapexpanded real_path skill_infos r)_resolve_skill_referencersww!!#djb/"7"7"9:H.6  *BI9%t););H)EtI[I[\_`d`jhj\k\q\q\sItJNN:r:@bAjnn\2>D"E O))+  DJB%%' roc2t|xsdj}|sddddSt|xsdjjddjd}|rd|}|j D]\}}t|j ddxsdj|k7r7t|xsdjdd}|j |s||k(smt|j ddxsd|t|xsddcS|j D]g\}}t|j ddxsdj|k(s7t|j ddxsd|t|xsddcSd|ddS)Nrrrrz./rhr)r!r=rYlstriprkr$r) rhrr clean_namenormalized_relsuffixrrrs r) _resolve_skill_reference_by_namers Z%2&,,.J b"==R(..088sCJJ4PN^$% . 4 4 6  D*:>>,39r:@@BjPDJB//c:I!!&)Y.-H #JNN:r$B$Hb I", O +002j z~~lB/52 6 < < >* L z2 > D"E(DJB *b AAroc|sdgfSg}ttj|D]\}}|jdxsdj }|jdxsdj }t ||} t j|}t j|d}|jd|d|xsd |d d ttj|t| D]\}}|jdxsdj } t j| } | jd xs8| jdxs%| jdijd xsd } | jdxs%| jdijdxsi} t| ts t j| d} t t| | } |jd|d| | d d |} t j#d| } | j%dd} t'j"dd| t&j(} t'j"dd| t&j(} tj#d| } | j } | |fS#t$r |r|nd}YwxYw#t$rYwxYw#t$rd} Y wxYw)z Parse tool-call tags embedded in assistant text into OpenAI-style tool_calls. Supports Kimi markers and Qwen wrappers. rrr1Fr/ call_kimi_r4r5r6r7)startr-rr. call_xml_zz+<\|tool_call_begin\|>.*?<\|tool_call_end\|>)flagsz=<\|tool_calls_section_begin\|>.*?<\|tool_calls_section_end\|>)r8_KIMI_TOOL_CALL_RErrr=rr:rr;r<r9_QWEN_TOOL_CALL_RErr$r r! _THINK_REsubrYreDOTALL)rr?r@mrrrrargs_str payload_rawpayloadr-rBrs r)_extract_tool_calls_from_textrs 2v J,55d;< 1GGAJ$"++-GGAJ&$--/(8<  6zz(+Hzz(?H "1#&"%.%@.xX   ",55d;3z?S 1wwqz'R..0  jj-G KK  x7;;{#; xw{{:WY?Z?^?^_e?f xjx {{;']7;;z2+F+J+J;+W][]$$ zz$U;$CIt4!!o"%)=  ! 0 E MM"e $E MM*b )E FFA2uTVT]T] ^E FFSUWY^fhfofo pE  " "2u -E KKME * U 6#+xH 6     s6,J6!K  K6K K  KK K+*K+c|jd}t|tr|ry|jd}t|trt|\}}t |St|t r|rt |\}}t |Sy)Nr?Tr&F)r$r r"rDrr!r)messageraw_tool_calls raw_content_part_tool_callstext_tool_callss r)!_assistant_message_has_tool_callsrsz[[.N.$'N++i(K+t$? L?O$$+s# :;G?O$$ roct|Dcgc]6\}}t|tr!|jddk(r t |r|8}}}|Dcgc]'}t|ts|jds&|)}}|r|syd}t t |t |D][\}}||}|jdrt|jdxsdj} | sLi|d| i||<|dz }]|Scc}}wcc}w)zBBackfill reasoning_content for prior assistant tool-call messages.role assistantr?rreasoning_contentrr) r8r r#r$rzipreversedr!r=) messages prior_turnsidxmsgassistant_tool_indicesrtprior_tool_turnsrestoredmsg_idx reasonings r)"_restore_missing_reasoning_contentrs#"(+ C c4 SWWV_ %CHijmHn  *5j 48NSWS[S[\hSijj !)9HX&<=xHX?YZ w 77& ' !45;<BBD  CsC$7CA  O' ks;DD 'D 9D cg}t}|D]}t|tst|j dxsdj }|j dxsi}t|j dxsd}t|j dxsd}|rd|nd|d|}||vr|j ||j||S) zDeduplicate tool calls while preserving order. Priority key is tool-call id. When id is missing, fallback to (function.name, function.arguments). r2rr4r-r.zid:zfn:z|args:)rir r#r!r$r=rjr9) r?dedupedrtcrCrfn_namefn_argsrs r)_deduplicate_tool_callsr$.s GUD "d# BFF4L&B'--/vvj!'Rdhhv&,"-dhh{+1r2$E7mCywi*H $;   r  Nrocdg}|D]'}t|}|jd}|dk(rd|d<d}|dk(rdt|jdd}|jdxs|jd }|r||d <|jd xs|jd }|r||d <|j||jd}|d k(r+t |t rt |\} } | |d<| r&| |d <n t |ts|t||d<|j|*|S)zGNormalize OpenClaw-style messages into chat-template-compatible format.r developersystem toolResulttoolr&rr& toolCallId tool_call_idtoolNamer-rr?)r#r$r*r9r r"rDr!) rrrrrtool_msgrCrrmrr?s r) _normalize_messages_for_templater/Es> C! IuuV} ;  AfID < 3AEE)4DE(HEE,'@155+@E+0(j):QUU6]I#, JJx eeI ; :c4#8A#F D*AiL",,C%#/3C8AiL 1 C!D Jroct|D]H}t|ts|jddk(s)t |jd}|sF|cSy)zGReturn the most recent user message text from the current turn context.ruserr&r)rr r#r$r*)rrrs r)_extract_last_user_instructionr2msO! c4 SWWV_%>+CGGI,>?D  rozGexited with code (?!0\b)\d+|exit code (?!0\b)\d+|exit status (?!0\b)\d+ exit_codez4Traceback \(most recent call last\)|\.py\", line \d+ tracebackz(Permission denied|EACCES|PermissionError permissionz/No such file|FileNotFoundError|ENOENT|not found not_foundz5command not found|not recognized as|is not recognizedcommand_not_foundz#timed?\s*out|TimeoutError|ETIMEDOUTr}z(?:^|\W)(?:Error|Exception):\s generic_errorzlist[tuple[re.Pattern, str]]_ERROR_PATTERNScNtD]\}}|j|sd|fcSy)zJReturn (has_error, error_type) by matching content against known patterns.T)FN)r9search)r&pattern error_types r)_classify_tool_errorr>s2.$ >>' "# #$ roc g}t|D]}t|ts|jdd}|dvrt |jd}|jdxs(|jdxs|jdxsd}t |\}}|j ||jd xs|jd xsd|d t||d |d k(rn|j|S)a.Extract tool results from the most recent tool-call round in messages. Scans backwards from the end of *messages*, collecting all consecutive tool / toolResult messages that appear after the last assistant message. Returns a list of summary dicts suitable for skill feedback tracking. rrr(r)r&r-r-runknownr+r,N)rr,r& has_errorr=r1) rr r#r$r*r>r9_TOOL_RESULT_CONTENT_MAX_CHARSreverse)rresultsrrr&rrBr=s r)_extract_recent_tool_resultsrFsG!#t$ wwvr" ) ).swwy/ABG +cswwvc#''+BVcZcI$8$A !Iz NN!*%(WW\%:%[cggn>U%[Y[&'F(FG!*",  V^  )* OO Nroc ng}t|D]k}t|ts|jdd}|dvr; |j t j t j|de|dk(rkn|j|S#t$r|j t|YwxYw)a Extract raw tool result messages from the most recent tool round. This preserves the original payload shape so cloud sessions can retain a complete tool-execution snapshot for future analysis. No truncation or error classification is applied here. rrr@Fr/r1) rr r#r$r9r:rr;r<rD)rrErrs r)$_extract_recent_tool_result_messagesrHsG! #t$ wwvr" ) ) *tzz$**Su*MNOV^    OO N *tCy) *s9B#B43B4c ddl}i}d}|}t|j}i}|D]#}t|tst |j dxs|}t |j dxs|}|j d} t| tr| }t|j dtrt|d}|j dgxsgD]i} t| tst| j d d} |j | d gidd } | j d xsi} t| j d tr| d | d <| j d}t|tr| dj|n_t|trO|D]J}t|tst|j dts4| dj|dL| j dgxsgD]}t|tst|j d d}| dj ||j dxsd||j dddddd}|j dr|d|d<|j dr|d|d<|j dxsi}t|j dtr|ddxx|dz cc<t|j dts |ddxx|dz cc<!| j d}|e|| d<l&g}t|D]g} || } | d dj| dd}| dr%t| dDcgc] }| d| c}|d<|j| || dxsddi|xsd|d|||xs dd ddddg|dScc}w) zBCollapse OpenAI-style SSE chat chunks into a single response dict.rNrr2modelcreatedusagechoicesindexr)r content_partsr? finish_reasondeltarr&rOrr?r3rr4r6r7r-r.rPr*stoprNrrPzchatcmpl-stream-chat.completion)r2objectrKrJrMrL) timeintr r#r!r$ setdefaultr9r"sortedr%)eventsfallback_modelrVbuilders response_idresponse_modelresponse_createdrLeventrKchoicerNentryrQr&r'r!tc_index tool_entryfnrPrMrr@s r)#_assemble_streaming_chat_completionrfs  *,HK#N9499;'E<7%& %))D/8[9 UYYw/A>B))I& gs #&  eii($ /w(Eii 2.4"1 7Ffd+ 7A./E'''%'"$%) EJJw'-2E%))F+S1 %f f ii *G'3'o&--g6GT*#DD!$-*TXXf=Ms2So.55d6lCDii b17R K!"d+rvvgq12"<0;; ffTl@hZ.@ "vz :-/b$A 66$<')$xJt$66&>)+FJv&VVJ'-2bffVnc2z*62bj@2bff[137z*;72k?J7) K,#JJ7M()6o&c1 7<7|%'G! &Mwwu_56#   EKER^L_E`$aU<%8%;$aGL !"!&!7!A6   "B/0@/AB## $/B?!'   %bsO#cNKg}|j23d{}|s |jds|ddj}|r|dk(r9 tj|}t |ts`|j|r7m#tj $rYwxYw6|Sw)zARead SSE `data:` lines from a streaming chat completion response.Ndata:[DONE]) aiter_linesrr=r:rJSONDecodeErrorr r#r9)responserZlinerr`s r)_collect_sse_chat_eventsro8s#%F**, ! !d w' qr(.."'X-  JJw'E eT " MM%  !##   - MsIB%B"BB"1B%B $B%5B%B" BB%BB%cFg}|D]t}|jdi}t|jdd}|jdd}t|ts t j |d} t j|}t|\}}|t|jdxsd |d tdd } |jtvr?t|jd xs|jd xsd } | r | d t| d <t|jdxs(|jdxs|jdxsd } | r| | d<n |r|d| d<|j| w|S#t $rd}YwxYw#t $ri}YwxYw)a;Build tool summary dicts from the model's tool_calls. Extracts the tool name and key arguments (``command`` for shell-like tools, ``path`` for file-based tools) into a compact format for the turn record. ``has_error`` defaults to ``False`` and is merged later when actual tool results arrive. r4r-rAr.r1Fr/r2rN)rr,r.rBrrrrrr) r$rr r!r:r;r<rr_TOOL_ARGS_MAX_CHARSrrr9) r? summariesr!rr-rrBr  skill_pathssummaryrrs r)_build_tool_summariesruLsI!"vvj"%(&))DE88K.(C( ::hUC ::h'D=R@;t 23!"7#78 #  ::<, ,dhhy)BTXXe_BCC%()>*>%? "488F#Vtxx'7V488K;PVTVW "GFO )!nGFO!C!"D 7   D s$E?1F? F F F F crg}t}|D]}t|\}}|j}|tvrit |\}} } t | || } | j dxs| j d} | r&| |vr"|j| |j| |tvrjt |\}} } t | || } | j dxs| j d} | r&| |vr"|j| |j| |tvr|D]} t| |} | j ds| j ds2| j dxs$| j dxs| j d} | r| |vrp|j| |j| |S)zIdentify which skill bundle files were read from the model's tool_calls. Returns a list of ``{"skill_id": ..., "skill_name": ...}`` dicts for each ``read`` tool call whose ``path`` argument points inside a skill. rrhr) rirr_HERMES_SKILL_READ_TOOL_NAMESrrr$r9rj_CLAUDE_CODE_SKILL_TOOL_NAMES_READ_TOOL_NAMESr)r?r read_skillsseen_idsr!rrs normalizedr rhr skill_ref dedupe_keyrs r)$_extract_read_skills_from_tool_callsrzs!KH%!DR!H ;__& 6 6&OPR&S #Az88^U]^I"z2QimmL6QJj8""9- Z(  6 6&OPR&S #Az88^U]^I"z2QimmL6QJj8""9- Z(  - -  %D0~FI==,Y]]<5P"z2jimmF6Kjy}}]iOjJx!7   y ) LL $ %+%> rocg}t}|D]X}t|\}}|j}|tvr+|tvrot |\}} } t | || } | jdxs| jd} | r,| |vr(|ji| d|i|j| |tvr |tvr|D]} t| |} | jds| jds2| jdxs$| jdxs| jd} | r| |vrp|ji| d|tvrdn|i|j| [|S)zCIdentify skill bundle files the model attempted to write or update.rrhactionrre) rirrry_HERMES_SKILL_WRITE_TOOL_NAMESrrr$r9rj_SKILL_WRITE_TOOL_NAMESrr)r?rrqr{r!rrsr|r rhrr}r~rs r)(_extract_modified_skills_from_tool_callsrs #%OH%!DR!H ;__& ) )  7 7&OPR&S #Az88^U]^I"z2QimmL6QJj8&&'J)'JXz'JK Z(  4 4K\9\  %D0~FI==,Y]]<5P"z2jimmF6Kjy}}]iOjJx!7  " "7H)Hgj  LL $ %%: roc |jdg}g}|Zg}|D]M}t|ts |jt j t j |dO||d<n|jdgt|D]\}}|jdd|jdd t|jd dd } |jd r|d | d <|jd d } | rt| dt| d <|j| |t|krt|jd d||d <|jd||jdd||d<|jdr |d||d<|jd r |d ||d <n||jd d|jd d } | rt| dt||d <o||jd d|jdd|jdd t|jd dd } |jd r|d | d <|jd d } | rt| dt| d <|j| ||d<|D cgc]u} | jd rbd| jddi| jdrd| dini| jd rd | d ini| jd rd | d iniwc} |d<y#t$r|jt|Y>wxYwcc} w)aiMerge error information from tool results into the turn record. Matches tool results to the ``tool_results`` summaries built from tool calls (by position). Updates ``has_error``, ``error_type``, and ``content`` on matching entries, then rebuilds ``tool_errors``. ``raw_tool_results`` preserves the original tool payloads for cloud upload. tool_resultsNFr/tool_results_rawrrAr,rrB)rr,rBr=r&tool_observations tool_errors)r$r r#r9r:rr;r<rXr8rr!rCrpop) turn_recordrraw_tool_resultsrr observations raw_snapshotr'r@resultobsr&rbss r)_merge_tool_error_inforsu3I!L##% $ 0DdD) 0##DJJtzz$U/S$TU  0+7 &'126|,&$ 6K;"JJ~r:fjje<=  ::l # &| 4C **Y+  \*I+IJC NC s9~ (,VZZ U-K(LIaL %(. ; ! @P@PQ\^g@h(iIaL %zz.)/5n/E ! ^,zz,'-3L-A ! \*!   t4jjB/G*-g,7V8V*W ! Y'!   D1$ZZ Y? & >2 >!&**[%"@A%E zz,'&,\&:l#jjB/G#&w<0O1O#Pi   U #M&$P(4K#$ "  55  {I6 67eeN6K. 12QS 34%% 2E a o.2 -.EE),< 1Y<("   "K _ 0##DJ/ 0^ "s9L32A:M3#MMchd}g}|D]}t|ts|j|%|jddk7r|j|Kt |jd}|j }d|vr|ji|ddi|dz }|j|||fS)a Rewrite OpenClaw /new bootstrap user prompt to a safer variant. Some upstream providers over-trigger policy filters on the stock bootstrap text ("A new session was started via /new or /reset ..."). This keeps behavior while avoiding brittle phrasing. rrr1r&z,a new session was started via /new or /resetzfA new chat session just started. Greet the user briefly in 1-3 sentences and ask what they want to do.r)r r#r9r$r*r)r rewrittenrrrlowereds r)%_rewrite_new_session_bootstrap_promptrsIC#t$ JJsO  776?f $ JJsO ' (:;**, 9W D JJ`  NI  3+,  >roc,tj|SN)anthropic_protocolto_openai_body)bodys r)_anthropic_to_openai_bodyrFs  , ,T 22roct}|jd}t|ts|S|D]S}t|tst |jdxsdj }|sC|j|U|S)Ntoolsr-r)rir$r r"r#r!r=rj)r tool_namesrr'r-s r)_anthropic_request_tool_namesrJs{5J HHW E eT "!$% 488F#)r*002  NN4 ! roi@c|jdrd|vry|jdd\}}d|vry tj|dS#t$rYywxYw)Nrh,rz;base64F)validate)rrbase64 b64decoder<)urlheaderdatas r)_data_url_bytesr[s` >>' "cn99S!$LFDu55 sA AAc|jdr:t|dk\r,tjd|dd\}}|dkDr |dkDr||fSdS|jds|jdr;t|dk\r,tjd |d d\}}|dkDr |dkDr||fSdSy|jd rt|d k\r|d ddk(r|dddk(rHtj |ddddz}tj |dd ddz}|dkDr |dkDr||fSdS|dddk(r\t|d k\rNtjd|ddddz}tjd|dd ddz}|dkDr |dkDr||fSdS|jdrd}|dzt|kr||dk7r|dz }||dz}|dz }|dvr1|dzt|kDrytjd|||dzd}|dks||zt|kDry|dvr8|d k\r2tjd!||d"z|d z\}}|dkDr |dkDr||fSdSy||z }|dzt|kry)#NsPNG  z>IIrsGIF87asGIF89a zz>H> z>HH)rrstructunpackrW from_bytes)rwidthheightrNmarkersegment_lengths r)_image_dimensions_from_bytesrgs +,Tb eT"R[9 v"'!) vDD y!T__Y%? t9?"MM%aF&+aiFQJE6? HD H 2;' !c$i2oMM$R 4Q7&@E]]4b5a86AF&+aiFQJE6? HD H {#ai#d)#E{d" %!)_F QJE%qy3t9$#]]4eeai1HI!LN!U^%;c$i%G"Q&$*MM%eai%RS)9T$UMFE.3aiFQJE6?PDP ^ #EAai#d)#B roct|}|tSt|}|tS|\}}tt||zdzdzS)Nii)r_IMAGE_TOKEN_ESTIMATErmax)rr dimensionsrrs r)_image_token_estimate_from_urlrsR 3 D |$$-d3J$$ME6 $uv~';&C DDroc|jd}t|tr|jdn|}t|tr|st|jdtr|jdni}|jddk(rIt|jdxsd}t|jdxsd }|rd |d |nd }nt|jdxsd }|stSt |S) N image_urlrrrr media_typez image/pngrrrhz;base64,)r$r r#r!rr)r&rrrrrs r)_image_token_estimate_from_partrs K(I",Y"=)-- 9C c3 s*4W[[5JD*QX&WY ::f  )VZZ 5DEJvzz&)/R0D8z1_estimate_image_content_tokens..sLD1$7Lsr>imager input_imagerr&)r r"sumr#r$rr)r&rAcounts r)rrst'4 LGLLL'4 KK' r input_text output_textr>rrz[image]r&rc3&K|] }|s| ywrrrparts r)rz'_token_estimate_text..s7$7FTr0 sort_keysr) r r!r"r#r9r$_token_estimate_textr%r:r;)r&r(r'rAs r)rrs'3'4  HDdD)#LLT+(IAAjQUQYQYZ`QacfFg T&\*44 Y'd" 1$((92EFG Hxx7777'4 zz'FF".3w<6B6roc t|jdxsg}|jd}td|D}g}|D]}t|ts|j |jdddt |jd|jdsd|j tj|jdd d |r'|j tj|d d d jd |D}tdt|dzdz|zS)aReturn a provider-agnostic rough input token estimate. SkillClaw proxies external agents and does not own the upstream model's exact tokenization. Keep this estimate local and dependency-free so daemon readiness never depends on model-specific tokenization. rrc3rK|]/}t|tst|jd1yw)r&N)r r#rr$)rrs r)rz5_estimate_openai_body_input_tokens..s+wcakloquav5cggi6HIws77rr: r&r?FTr c3&K|] }|s| ywrrrs r)rz5_estimate_openai_body_input_tokens..s9dDT9rrr) r"r$rr r#r9rr:r;r%rr) openai_bodyrr image_tokensr>rrs r)"_estimate_openai_body_input_tokensrsKOOJ/526H OOG $EwU]wwLJe#t$ SWWVR014HQZI[4\3]^_ 77<   djj)>U^bc d e  $**U$OP 999j9 9D q3t9q=Q&5 66rocj tj|dddS#t$rt|cYSwxYw)NFT)r:)r0r separators)r:r;r<r!)rs r)_message_identityrs6zz'R\]] 7|s 22cd}|t|kr>||}t|tr|jddk7rn|dz }|t|kr>|d|||dfS)Nrrr'r)rr r#r$)rrNrs r)_split_leading_system_messagesrsj E #h- uo#t$8(C    #h-  FU Xef- --roc^t|}d|vrt|jd|d<|S)Nr&)r#r*r$)rr|s r)_canonical_overlap_messagers1gJJ 8 9R S 9 rocg}g}|D]b}t|jd}|r|j||jd}t|tsR|j |dddj |d}|r||d<|S)Nr&r?rrr*)r*r$r9r r"rr%)rrOr?rr&msg_tool_callsmergeds r)_merge_assistant_overlap_runr s!MJ.*3779+=>    ). nd +   n - .'2chh}>UVF)| Mroc\g}d}|t|kr||}t|ts'|jt d|i|dzf|dz }K|j ddk(r |g}|dz}t|j dt xrt|j d}|t|kr||}t|tr|j ddk7rnd|j||xs;t|j dt xrt|j d}|dz }|t|kr|r)|jt t||f|}j|jt t||dzf|dz }|t|kr|S)Nrrrrrr?) rr r#r9rr$r"rrr)rentriesrNrrun next_indexhas_tool_callsnext_msgs r)_messages_for_overlaprs%'G E #h- uo#t$ NN-wn=uqyI J QJE  776?k )%CJ' (=tDdcggVbNcIdNs8},#J/!(D1X\\&5I[5X 8$!/"x||L94@eT(,,WcJdEea s8}, 12Ns2S TV`ab")*DS*IJETUIVW  5 #h- 6 Nroc|s|S|s|St|\}}|rt|\}}n|}t|}t|}|Dcgc]\}}| } }}|Dcgc]\}}| } }}| dt| | k(r||zStt| t| } d} t | ddD]} | | d| d| k(s| } n| r || dz dnd}||z||dzScc}}wcc}}w)Nrr)rrrminrange)previous_messagescurrent_messagescurrent_system_messagescurrent_body_messagesr previous_body_messagesprevious_entriescurrent_entriesr previous_keys current_keys max_overlapoverlapsizecurrent_drop_indexs r)!_merge_previous_response_messagesr>s9    5STd5e22$BCT$U! !!2,-CD+,ABO'78VS!S8M8&56FCC6L6(c-()]:&)>>>c-(#l*;STfTg>h hh96s  C C c,tj|Sr)responses_protocolnormalize_content_to_textr&s r)_normalize_responses_contentr^s  7 7 @@roc,tj|Sr)rtools_to_openai_tools)rs r) _responses_tools_to_openai_toolsr"bs  3 3E ::roc tj||S#t$r}tdt ||d}~wwxYw)N status_codedetail)rrr|r r!)r default_modelexcs r)_responses_to_openai_bodyr*fs@G!00}EE GCH=3FGs =8=c.tj||Sr)rfunction_item_id)call_idrNs r)_responses_function_item_idr.ms  . .w >>roc.tj||Sr)rfrom_openai_chat_payload)rrJs r)!_openai_chat_to_responses_payloadr1qs  6 6w FFroc0tj|||Sr)rfrom_openai_response) openai_resprJrs r)_openai_to_anthropic_responser5us  2 2;z RRroceZdZdZ dB dCdZdDdZdEdZdFdZdGdZdHdZ dId Z dJd Z dKd Z dLd Z dMdNd ZdFdZdFdZdOdZdFdZdFdZdPdZdFdZdQdRdZdSdZ dTdZdUdZdZ dV dWdZ dXdZdYdZdYdZdZdZd[dZ d\d Z!d]d!Z"d^d"Z# d_d#Z$d`d$Z%dad%Z& dbd&Z'd]d'Z(dd( dcd)Z)ddd*Z*d]d+Z+d]d,Z, ded-Z-dfd.Z.dfd/Z/dgd0Z0dhd1Z1dFd2Z2dMdid3Z3 djd4Z4dkd5Z5dSd6Z6 dld7Z7dmd8Z8dnd9Z9 dM dod:Z:d;Z;d<ZZ>dpdqd?Z?d@Z@eAdrdAZBy)sSkillClawAPIServerawProxy between client agents and the upstream model with SkillClaw hooks. OpenClaw sends ``X-Session-Id`` and ``X-Turn-Type`` headers with every request. The proxy injects skills, records conversation artifacts when enabled, and can attach PRM scoring when configured. Side tasks (``turn_type != "main"``) are forwarded but do not generate the main conversation artifact path. Parameters ---------- config: SkillClawConfig instance. skill_manager: Optional SkillManager for injecting skills into system prompts. prm_scorer: Optional PRMScorer for turn feedback. Nc ||_||_||_||_||_t j |_|j|_|j|_ tj|jd|jdk(|_|jd|j }tj"j%|jd|d|_i|_i|_i|_i|_i|_i|_i|_i|_t9|_t9|_i|_d|_ d|_!tEdtGtI|dtJ|_&tEd tGtI|d tN|_(tEd tGtI|d tR|_*tEd tGtI|d dxsd|_+i|_,d}||_-d|_.d|_/|j`rtj|jdtj"j%|jd|_.tj"j%|jd|_/tc|j\d5 dddtc|j^d5 ddd|je|_3d|_4d|_5tmjn|_8tmjn|_9y#1swYxYw#1swYkxYw)NT)exist_okopenclawr system_prompt_cache_.jsonrsession_idle_close_secondsrsession_sweep_interval_secondsshutdown_drain_timeout_secondsri%sharing_skill_reload_interval_secondsri,rzconversations.jsonlzprm_scores.jsonlw):config_sampling_client skill_manager prm_scorer_last_request_trackerrV_last_request_atserved_model_name _served_model proxy_api_key_expected_api_keyrymakedirs record_dir claw_type_compress_system_prompt llm_providerrr%_system_prompt_cache_file _turn_counts_user_turn_counts_pending_turn_data _prm_tasks_pending_records_session_scored_turns_session_turns_session_last_activeri_closing_sessions_background_tasks_responses_store_session_sweeper_task_skill_reload_taskrrWgetattr_SESSION_IDLE_CLOSE_SECONDS_session_idle_close_seconds_SESSION_SWEEP_INTERVAL_SECONDS_session_sweep_interval_seconds_SHUTDOWN_DRAIN_TIMEOUT_SECONDS_shutdown_drain_timeout_seconds_skill_reload_interval_seconds_tui_session_meta_tui_inactivity_timeout _record_file_prm_record_filerecord_enabledopen _build_appapp_server_thread threadingEvent _ready_event_server_stopped_event)selfrBsampling_clientrDrElast_request_tracker cache_suffix_INACTIVITY_TIMEOUTs r)__init__zSkillClawAPIServer.__init__s /*$%9" $ #55!'!5!5 F%%5 (.'7'7:'E$ **+1V-@-@,AB )+f6G6GK_`l_mmrIs)t&-/13>@>@1357"/168!+.547E;==A":>+.  <>YZ [, (03  @Bab c0 ,03  @Bab c0 ,/2  GLRPR S/ +35!':$ "  KK))D 9 " V->->@U VD $&GGLL1B1BDV$WD !d''-  d++S1  ??$26 37 %OO-%.__%6"    s0L0L<0L9<Mc f | td fd }td|}||j_|j dd}|j dt df dd}|j d t df dd }|j d t dt dt dt df dd }|j d t dt dt ddt dt df dd}|j dt df dd}|jdt df dd} |j dt dt ddf dd} |j dt dt ddt dt ddt dt df d d} |S)!NcfKjjjj djj j d{y7#jj j d{7wxYwwr)rsri_start_session_idle_sweeper_start_skill_reload_pollingclear_shutdown_cleanup)_appowners r)lifespanz/SkillClawAPIServer._build_app..lifespans    " " $  - - /  - - / 0""((*--///""((*--///s4;B1A9-B11A72B19.B.'B*(B..B1zSkillClaw Proxy)rrz/healthzcKddiSw)NokTrrror)healthzz.SkillClawAPIServer._build_app..healthzs$< sz/internal/reload-skillsrc K|jjj}|j|d{|j d{|j r#t |j jnd}d|dS7R7<w)NrT)rskills)rnstater _check_auth_pull_skills_from_cloudrDrget_all_skills)request authorizationr skill_counts r) reload_skillsz4SkillClawAPIServer._build_app..reload_skillss{ )0 (9(9(?(?E##M2 2 2//1 1 1GLGZGZ#e11@@BC`aK+6 6 3 1s!5BB BB ;B Bz /v1/modelscK|jjj}|j|d{|j}t d|ddddgdS7%w)Nr"rJr skillclaw)r2rUrKowned_by)rUrr)rnrrrrIr )rrrmodel_ids r) list_modelsz2SkillClawAPIServer._build_app..list_models sn )0 (9(9(?(?E##M2 2 2**H$#+&-'((3     3s5AA&Az/v1/chat/completionscK|jjj}|j|j |d{|j d{}|j dg}t|trt|\}} ||d<|xs|j dxsd} | r | } t||j dd} net|j dxsg} |j|j dd| d{} t||j dd} t||j d }t|j d d }|j|| | | d{}|rt!|j#|d St%|dS7r7]779w)NrrrrrGrrJrrstreamFrrrtext/event-streamrrmr)rnrr_mark_request_activityrr:r$r r"rrr_resolve_tui_sessionrr_handle_requestr_stream_responser )rr x_session_id x_turn_typex_session_donerrincoming_messagesrewritten_messagesr _raw_sidrr msg_countrrrs r)chat_completionsz7SkillClawAPIServer._build_app..chat_completions"s)0 (9(9(?(?E  ( ( *##M2 2 2 'D $R 8 +T2(MN_(`%"A#5Z #Ctxx '=CH % .{DHH[.responsesRs)0 (9(9(?(?E  ( ( *##M2 2 2 'D..0"mmD1 .{DHH['$'!ABVAWX+LJ/5264:;+ J'$W'7W488L;QWUWH% .{DHH[DHHXu-.(445EF2 (89 9y 3' *"$O@sqAR>R,R>R/ C$R>R2A0R>5R56FR>R8AR>R;DR>/R>2R>5R>8R>;R>z/v1/responses/{response_id}cK|jjj}|j|d{|jj |}| t ddt|dS7=w)Nrresponse not foundr%rmr)rnrrrr\r$r r r]rrrrs r) get_responsez3SkillClawAPIServer._build_app..get_responseso )0 (9(9(?(?E##M2 2 2++// A7cK|jjj}|j|d{|jj |d}| t ddt|dddS7?w)Nrrr%rmT)r2rUdeletedr)rnrrrr\rr r rs r)delete_responsez6SkillClawAPIServer._build_app..delete_responsest )0 (9(9(?(?E##M2 2 2++// TBF~#.anthropic_count_tokenss )0 (9(9(?(?E  ( ( *'YYgi[,ATXK##K0 0 0$\\^+H3H=K=kJL(FG G 1+s$ABBB,B-)BBz /v1/messageszx-claude-code-session-idc"K|jjj}|j|xs |rd|nd}|j |d{|j d{} t | jdd} t| } t| } t| d<| jdxs |j} | jdg}t|trt|\}}|| d<|xs|xs| jdxsd}|r |}t|| jd d }nUt!| jdxsg}|j#| |d{}t|| jd d }t%|| jd }|j'| ||| d{}| rt)|j+|| | dSt-t/|d| | S7777Fw)NrrFrrJrrrrrGrrrrrrmr)rnrrrrr:rr$rrrrIr r"rrrrrrr_stream_anthropic_responser r5)rrrrx_claude_code_session_idrrrrrrrrrJrrr rrrrrrs r)rz9SkillClawAPIServer._build_app..anthropic_messagess)0 (9(9(?(?E  ( ( *'YYgi[,ATXK##K0 0 0$\\^+H(,,x78F6x@J3H=K1MK- .LL)@U-@-@E + B ? +T2(MN_(`%"A*< J'#c'?c8<)/)=,24,@ - <- <(- <(- <' - < * - < *- <^ / ",2$+?*0*>.4T.V)/)=,24,@ f :f :(f :(f :, f : ' f : * f : #f :P . /,2$+? < < <) < 0 < 1 2,2$+? d d d) d 3 d" - .,2$+?'-d+'N H H( H% H / H . !,2$+?'-d+'N*0*>6N seconds. When a boundary is detected the old session is flushed (session data uploaded, state dicts cleaned up) and a new unique id is assigned. rNztui--r)rlast_msg_countlast_request_timez2[SessionDetect] new TUI session %s (first request)FrTu;[SessionDetect] msg count dropped %d → %d — new sessionru4[SessionDetect] inactivity %ds > %ds — new sessionr tui_boundaryreasonz1[SessionDetect] new TUI session %s (replacing %s)) uuidrVrgr$uuid4hexrinforhrW_close_session) rurJrrtui_keynowmetasid new_sessionidle_secold_sids r)rz'SkillClawAPIServer._resolve_tui_sessionEs .iik%%))'2 <q!1!1"1!5 67C!"+%(/D " "7 + KKLc RJ t,- -K KKM%&  D,--1M1M MK3&9!::;H KKF,,  <(G%%gn%E E Eq!1!1"1!5 67C!"+%(/D " "7 + KKKSRY ZJ"+ $' !L!! FsDE=E;A#E=cL|r"tj|j|<yyr)rVrYrurs r)_touch_sessionz!SkillClawAPIServer._touch_sessions 48IIKD % %j 1 roc^tjj}|jjj|jj j|jj j|jjj|jjj|jjjtfd|DS)Nc3FK|]}|s|jvs|ywr)rZ)rrrus r)rzASkillClawAPIServer._collect_active_session_ids..s VAat?U?U6UaVs !!!) rirYrrrrVrXrTrRrWrUrY)ru session_idss` r)rz.SkillClawAPIServer._collect_active_session_idss$3388:; 40055784..3356422779:4,,1134455::<=4??//12VVVVrocjdkrgStjtjtfdjj DS)Nrc3jK|]*\}}|r#|jvrt|z k\r|,ywr)rZr{)rrtsrru thresholds r)rz?SkillClawAPIServer._collect_idle_session_ids..s= Rs$"8"88cE"IoR[=[  s03)rarVr{rYrYrk)rurrs``@r)_collect_idle_session_idsz,SkillClawAPIServer._collect_idle_session_idss_  + +q 0I ;))+C$::;  44::<   roc|jdkrtjdy|j|jj syt j |j|_|jj|jtjd|j|jy)Nrz4[SessionDetect] idle sweeper disabled (timeout <= 0)z?[SessionDetect] idle sweeper started (timeout=%ss interval=%ss)) rarrr]doneasyncio create_task_session_idle_sweeper_loopadd_done_callback _task_done_cbrcrs r)r}z.SkillClawAPIServer._start_session_idle_sweepers  + +q 0 KKN O   % % 1$:T:T:Y:Y:[ %,%8%89X9X9Z%[" ""44T5G5GH M  , ,  0 0 roc$K tj|jd{|j}|D]}|j |dd{Z777 #tj $rt jdwxYww)N idle_timeoutrz$[SessionDetect] idle sweeper stopped)rsleeprcrrCancelledErrorrr)ru stale_idsrs r)rz-SkillClawAPIServer._session_idle_sweeper_loops mmD$H$HIII ::< $JC--c.-IIIJIJ%%  KK> ?  s2B#A#A/A#A!A#!A##*B  BcKt|jDcgc]}|jr|}}|sytj||d{\}}|rTt j dt||D]}|jtj|ddid{yt jdt|ycc}w77,w)Nr}z=[OpenClaw] background drain timeout: %d task(s) still runningreturn_exceptionsTz1[OpenClaw] background drain complete (%d task(s))) r"r[rrwaitrrrcancelgatherr)rutimeout_secondstpendingr still_pendingtasks r)_await_background_tasksz*SkillClawAPIServer._await_background_taskss"4#9#9:K!&&(1KK $+LL/$RRm  NNOM" &   ..-H4H H H KKKSQUY WLS Is3CCCCCAC+C,+CCc|jjsytt|jddxsdj j }|dk7ry|j |j jsytj|j|_|j j|jtjd|jy)Nsharing_skill_reload_moderpollz4[SkillHub] skill reload polling enabled interval=%ds)rBsharing_enabledr!r_r=rr^rrr_skill_reload_poll_looprrrrrf)rumodes r)r~z.SkillClawAPIServer._start_skill_reload_pollings{{** 74;;(CRHRFSYY[aac 6>   " " .t7N7N7S7S7U ")"5"5d6R6R6T"U 11$2D2DE B  / / rocKd}d} |rd}n_tjd|jdz}t|dzd}t j |j|z|zd{ |j d{d}7 7 #t$r&}|dz }tjd||Yd}~/d}~wwxYw#tj$rtjd wxYww) NrTFg?g@gN@rz3[SkillHub] skill reload poll failed (streak=%d): %sz'[SkillHub] skill reload polling stopped) randomuniformrfr rr rr<rrr r)ruconsecutive_failures first_pulljitterbackoffr)s r)rz*SkillClawAPIServer._skill_reload_poll_loops   !&J#^^At/R/RUX/XYF!"6" K|sy|jvryjj| j|djj |i}j j |i}jjrjrt|jD]\}}||vr tjjj|j dd|j dd||}|jj |j||ffd |||<t|j#}|r7 tj$tj&|ddit( d{t1t|j3D]}|j5|}|j5d d} |j |}| #|!|j7r |j9} |j5|dj?|||| d{j@j5|d } jBj5|djDj5|djj5|dj j5|i}|j#D]>} tG| tjHs| j7r/| jK@t,jMd ||| jNrjNjQjRj5|g} tU| } | r7jjVr!jYj[|| jjVr!jYj]| j^j5|dtj`jD]G\}}tG|tbs|j d|k(s,j`j5|dI jje|y7 #tj*$rt,j/d |Y5wxYw#tj:t<f$rd} YwxYw7#jje|wxYww)zUFlush a session: finalize pending turn feedback, upload session data, clean up state.N response_textr prompt_textrturn_numc*j|||Sr_on_prm_done_record_only)_trtnumrus r)z3SkillClawAPIServer._close_session..s$B_B_`ceikmBnrorTrz2[SessionDetect] PRM drain timed out for session=%s prm_resultrz=[SessionDetect] closed session=%s reason=%s (scored_turns=%d) skip_namesr)3rZrj_flush_pending_recordrTr$rUrXrBuse_prmrEr"rkrrevaluaterrvalueswait_forrrd TimeoutErrorrrrYrrrrr r<_finalize_turn_feedbackrWrRrSr TaskrrrD _save_statsrXrur_safe_create_task_upload_session_datarrYrgr#discard)rurrr prm_tasksr0 turn_dataprm_taskactive_prm_tasksr7effrrsmodified_skill_namesrrs` r)rz!SkillClawAPIServer._close_sessionsk  // /  "":.I 7  & &z4 8--11*bAG22:rBI{{""t+/ +@3'Hi9, &2200%MM/2>%MM-<'1%- 1 H..t/A/AB..'1n+3Ih'3 $I$4$4$67 e!**(8QDQ ? #4 #78 #KK1 &]]<> $==2%(*>8==?*%-__%6  h-22   ,,00Q?C    ! !*d 3  " " & &z4 8  # # ' ' D 9++J;I!((* "dGLL1$))+KKM " KKO   !!""..0''++J;E#@#G 44&&t'@'@U'ST{{**&&t'C'COc'C'de  % % ) )*d ;!$"8"8">">"@A : TdD)dhh|.D .R**..sD9 :  " " * *: 6c++eNN#WYcde$22I>*%) *B  " " * *: 6s.TD6S=)1R(R%R(A-S= S)S=S:B?S=S=D.sd.?.? HVX.Yroc*j|Srr2rns r)r6z6SkillClawAPIServer._fire_prm_scoring..sd.K.KJX`bd.eroThas_next_state) rErrr<rrrUrXrTr$) rurr0r-rPrMfinalize_ready_turns inst_textrtds ``` r)rWz$SkillClawAPIServer._fire_prm_scoringsj $* "" OO $ $]I*_g $ h  t112   " "#Y Z  " "#e f?C"":r28<  $ $ ( (R 8 < #'B  roc|r|jddnd}|jj|g}|dz }d|cxkrt|krnn|||d<||jdg}|r(|jr|jj ||||jdg}|r_|jrS|D cgc]*} t | t s| jds&| d,} } | r|jj | ||jj|ij|} t | t r|| d <yycc} w) Nrcrrr prm_scorerrzrhr7)r$rXrrDrecord_feedbackr r#rT) rurr0r7rcrsrinjectedrMr read_names pending_turns r)_apply_prm_resultz$SkillClawAPIServer._apply_prm_results7 1; w,##'' B7l  c%j &+E#J{ #Sz~~&7>-4D**7;k!z!T?RWXW\W\]iWja ok k&&66z5I..22:rBFFxP lD ))3L & * ls=EE%Ec|jry |j}|j|||||jvry|j |y#t$rYywxYw)uQCallback after PRM scoring completes — write score back and update skill stats.N) cancelledrr<r{rZ_maybe_finalize_ready_turnsrurr0rr7s r)rmzSkillClawAPIServer._on_prm_donesf >>   J z8Z@ // /  ((4    sA A#"A#c|jry |j}|j|||y#t$rYywxYw)z>Callback used for close-session PRM tasks; records score only.N)r}rr<r{rs r)r3z+SkillClawAPIServer._on_prm_done_record_onlysG >>   J z8Z@   s7 AAc t|jdd5}tj|}dddj dd}t |t r|SdS#1swY/xYw#t$rYywxYw)NrxrRrScompressed_system_promptr)rlrQr:loadr$r r!r<)rur\rcacheds r)_read_cached_system_promptz-SkillClawAPIServer._read_cached_system_promptsv d44cGL $PQyy| $XX8"=F'46 <" < $ $  s-A*A+A*A*A'#A** A65A6c t|jdd5}tjd|i|ddddy#1swYyxYw#t$r }t j d|Yd}~yd}~wwxYw)NrArRrSrFr/z2[OpenClaw] failed to write system prompt cache: %s)rlrQr:dumpr<rr)rupromptr\r]s r)_write_cached_system_promptz.SkillClawAPIServer._write_cached_system_prompt sq Td44cGL WPQ 5v>PUV W W W T NNOQR S S Ts1A >A AA A A3A..A3cKtjdxsdj}jd}t|tr|s t dd|j |d}|D]o}t|ts|jdd k(s)t|jd tsI|jd djd sk|d z }q|rtjd |fd} d} |jr|j} | sd} |D]C} t| ts| jddk(s)t| jd } n| rW tjt d | dg|j"d{} | xs| j} |j)| | r2|D]-} t| ts| jddk(s)| | d </t+||j,j|g}|rtjd|jd}g}|j.r|dk(r|j1|\}}|jr"| r tjd| d| dg|j"j2t5jdxsdz }|dkDr|j7|||}j9Dcic]\}}|t:vs||}}}d|d<|j=ddd|vr|j>|d<||d<|jA|d{}|jdxs |j>|d<|jdigd}|jdi}t|tsdt|d}|jdxsg}t|tr t |ng}|jd }t|tr"tC|\}}|}|jE|n t|}tG|\}}|r|}|jE|tI|}||d <|r||d<n|j=dd||d<t|jdtr|dr ||dd<n|g|d<|jd xsd} tjtJd!|d"|d#tM|tNtjtPd!|d"|d$tM| d%|tN |r.tjd&tSjT|d'dd(|dk(rtW|}!|j,j|g}"|!r|"rtY|}#t[|"d)|!|#||j\vr|r|j_||d)t|}$|$jd d|$d <|j.r|j.jani}%tc||%}&te||%}'tg|}(|&r6tjd*tM|&d+jid,|&D|'r6tjd-tM|'d+jid.|'Dtk|})|jlj|dd z|jl|<|jl|}*d/jid0|D}+|xs|rtSjT|d'nd},|jo||*||+|,|tq|||}-|*|-|)|,| xsd||&|'|(ggg|dd1}.|j,js|gju|.tw|-r(|jy|}/|/|.d2<|j{||/|+|,d3|j|js|i|*<tjd4||*|.jd2d5|-t||d6tM|,|j|ntjd7||r|j|d{||d8<d9|iS7#t$$r1} tj'd| | j} Yd} ~  d} ~ wwxYwcc}}w7t7Vw):Nrrrr$z!messages must be a non-empty listr%rrr1r&z A new chat session just started.rzG[OpenClaw] rewrote %d /new bootstrap user prompt(s) for provider safetyc>t|jddS)Nrrr)rr$)msgsrs r) _prompt_lenz7SkillClawAPIServer._handle_request.._prompt_len s 54RVRZRZ[bRc6de eror'r*uK[OpenClaw] system prompt compression failed: %s — using raw system promptzP[OpenClaw] restored reasoning_content on %d prior assistant tool-call message(s)rrGz&[OpenClaw] system prompt cached len=%d max_tokensiFrstream_optionsrJrMrrr?rz [OpenClaw] [z ] session=z prompt_msgs=z thinking=z chars, response: z[OpenClaw] tool_calls: %sr/rr z)[SkillManager] model read %d skill(s): %s, c3@K|]}|jddywrhrNNr$rrxs r)rz5SkillClawAPIServer._handle_request.. sL1aeeL#6Lz-[SkillManager] model modified %d skill(s): %sc3@K|]}|jddywrrrs r)rz5SkillClawAPIServer._handle_request.. sP1aeeL#6Prrc 3|K|]4}|jdddt|jdd6yw)rrNrr&rN)r$r*)rrs r)rz5SkillClawAPIServer._handle_request.. s?$^_155%&b)A!%% SUBV)W(XY$s:<)r0rr.r-rr?rzrqrrrrrru user_turn_num)r.r-z^[OpenClaw] MAIN session=%s turn=%d user_turn=%s kind=%s prompt_est_tokens=%d response_chars=%drrz9[OpenClaw] SIDE session=%s -> skipped (side-channel turn)rrm)Br!r$r=r r"r rr#rrrrOrr*r to_threadrrBr<rrrrXrD_inject_skillsmax_context_tokensrW_truncate_messagesrk_NON_STANDARD_BODY_KEYSrrI_forward_to_llmrDrrr$_YELLOWrrV_REDr:r;rFrHrrVr:get_skill_path_maprrrur%r2rRrarrXr9r_next_user_turn_num_maybe_upload_session_snapshotrTrr~r)0rurrrrrrrrr cached_system raw_systemrr]restored_reasoningrr max_promptkv forward_bodyoutputra assistant_msgr r?r  part_textr r& clean_contentr rr prev_turnsr response_msgrrzrqtool_summariesuser_instructionr0r.r-rrrs0 ` r)rz"SkillClawAPIServer._handle_request stxx 56<"=CCE88J'(D)C8[\ \ J'  C3%GGFOv-swwy137GGIr*556XYQ    KKacl m f   ' ' ;;=M  !A!!T*quuV}/H%=aeeI>N%O  ;.5.?.?#&,DE KK/) *7)D*(K(K(M 44]C!5A!!T*quuV}/H'4) 5@     # #J 3   KKb"  !&(   )v"5(,(;(;H(E %Ho  ' 'M KK8h=IJK  [[33c$((<:P:XTX6YY >..x KH)-ZABY9Y1Z Z!& X)40 , &$($6$6L !#+ Z ++L99&**73It7I7IwIt,Q/ 9b1 -.%0=UVc=deM&**<8>B-7-MT.)SU #'' 2 k4 ()KK)X &IG   o ..{;G*Gw)O&  #G   o .,Z8 #* i *4M, '   lD 1)y fjj+T 2vi7H#)F9 a !'F9 !%%&9:@b  wi|I;j MZ]^fZgYhiohpqr fL :j\BI'':7)F8 M   KK3TZZ Y^5_`dad5e f  7AL,,00R@J #G#Q &z"~|EUVT222x**:x|D .L *2*, Y'HLHZHZT//BBD`bN>KGO3:>N ? $IIL LL  C(IIPPP >hG ,0,=,=,A,A*a,PST,TD  j )((4H))$ck$K$iV` :E(RfhM    Hh ]\f g3HgzRM$!./!.%.%6$(*#2 .$&%'!#2!K    * *:r : A A+ N%m4 $ 8 8 D /< O,33J N*!.LD # # . .z2 >x H KKp52SX3YZM"   , ,Z 8 KKSU_ ` %%j1 1 1)|F##{) %;i)3(8(8(: ;P[:J 2sBc cc>!c Ac<cc1,b b b 6(cc4D c?c c AccTc;c< c b c&c;cc cccK|jjdk(r|j|d{S|j|d{S77w)uUForward to a real LLM API. Supports providers: - ``"openai"`` (default) — any OpenAI-compatible ``/v1/chat/completions`` endpoint. - ``"openrouter"`` — OpenRouter gateway (OpenAI-compatible + routing extensions). - ``"bedrock"`` — AWS Bedrock Converse API via :class:`BedrockChatClient`. bedrockN)rBrP_forward_to_llm_bedrock_forward_to_llm_openai)rurs r)rz"SkillClawAPIServer._forward_to_llm sK ;; # #y 055d;; ;00666<6s!.AAA A AAcltt|jddxsdjdk(S)zBReturn whether /v1/responses should be forwarded as Responses API. llm_api_modechatr)r!r_rBrrs r)rz,SkillClawAPIServer._responses_native_enabled s.74;;?I6JPPRVaaaroc|jjjd}|s tdd|j Dcic]\}}|t vs||}}}|jj xs|jdd|d<||d<i}|jjrd|jj|d <|d ||fScc}}w) zBuild URL, body, and headers for native Responses forwarding. Native mode intentionally keeps Responses-only tools (custom, web_search, namespace, etc.) untouched instead of converting the request to chat. r>dkk+DfM? I''668 ?Ia!ZXY[_M`quuV_5a a R   IIk "4C ( ++K8/0LMKS6 1J >EEGYc^) S NNNPQ R R Sbs#D5E"E"5 E>EEc |sy|j|t|jdd}|jd}t|tr|r|dz|zj n|}nt|t rg} |D]R} t| ts| jddk(s)| jt| jddT| r+d j| } |r|dz| zj n| }g} |jd gD]} t| ts| jd d k(r_| jdgD]I} t| ts| jd d k(s)| j| jddK| jd dk(s| jdd}t | jdddd}| jd|d|dj| }|jj|g}t|dz}||dk(rdnd|dd|dd|dd}|j||dk(r(|j|}||d<|j||tj!d||||jddt|t||rdj|nd|r#|j#|j%|d !yy)"z=Record a Responses API turn into the session tracking system.Nrrrrrr1r&rrrrrr function_callr-r.rz[tool:z] rrGrrHi)r0rr.r-rrurzV[Codex] %s session=%s turn=%d user_turn=%s prompt=%d chars response=%d chars skills=%srrz(none)codex_session_doner)rrr$r r!r=r"r#r9r%rXrXrrrrrrCr)rur request_bodyrrrrr.inp user_partsr'joinedresponse_partsrr-rBr-rsr0rrs r)rz)SkillClawAPIServer._record_responses_turnA s  J'2<3C3CNTV3WX w' c3 @K;-3::&.H%%&B488IWYCZ&[\ ]*-GR{T1F:AACX^ $((26 ?DdD)xx9, HHY3DD!$-$((62Bm2S&--dhhvr.BCD&!_4xx+488K45ds;%%tfBtf&=> ? .1 ##..z2>u:> (1V(;W&u-*5D1.    [!   44Z@M+8K (  / / M J d    OOOS 1    )8CHH_ %h    " "4#6#6zJ^#6#_ ` roc Kddl}|j|d\}}}d}t|D]t} |jt 4d{}|j |||d{} | j | jcdddd{cSy7U7;7 #1d{7swYnxYw#|j$r} | jjdd} ||d z kr{td |ztjdd zd } tjd |d z|| | jj | t#j$| d{7Yd} ~ ?tj'd | jj | t)dd| | d} ~ wt*$r} ||d z krftd |ztjdd zd } tjd|d z|| | t#j$| d{7Yd} ~ tj'd| dt)dd| | d} ~ wwxYww)z?Forward a Codex Responses payload to an upstream Responses API.rNFrrrr:rrOrrrzM[OpenClaw] upstream Responses error (attempt %d/%d), retrying in %.1fs: %s %sz*[OpenClaw] upstream Responses error: %s %szUpstream Responses error: r%zJ[OpenClaw] Responses forward failed (attempt %d/%d), retrying in %.1fs: %sz'[OpenClaw] Responses forward failed: %sTexc_infozResponses forward error: )httpxrr  AsyncClientr~rraise_for_statusr:HTTPStatusErrorrmrr r!r"rrr&rr errorr r<) rurrrrr max_retriesattemptclientrespr]r-rs r)rz,SkillClawAPIServer._forward_to_llm_responses sB"&"A"A$u"A"UY [)' dG& d ,,5Q5S,T''X^!'& '"-"D ))+99;'''' d''''''(( e !  5 [1_,q'zFNN1a,@@"EDNNg! # ..% "----- I1::KaKacpq#>XYZX[<\]cdd d[1_,q'zFNN1a,@@"EDNNd! # "----- FTX Y#>WXYWZ<[\bcc ds,IB? B#B?B))B%*#B) B?B'B?I#B?%B)'B?)B; /B20B; 7B?>I?IBF&E!F&$I*.ensure_message_item sQ**%')! Dooi4Ggt,"$YKroc(|}|jdg}t||kr$|jddgdt||kr$||}t|tr0|j dxsd|d<||d<|jdgyy)Nr&rr)rrrrrr)rXrr9r r#r$)r content_indexrr'r&rrs r)apply_output_textzISkillClawAPIServer._stream_and_track_responses..apply_output_text s&|4Dooi4Gg,-/ rRTUVg,-/=)D$%#xx/@=V #V  r2&roc|jd}t|jddxsd}t|jddxsd}|dk(r'|jd}t|tr| |<y|dk(r'|jd}t|tr| |<y|dk(rF||f} j|d t |jd xsd z |< || |y|d k(rBt |jd xs j||fd }| ||f< |||y|d k(rw|jd}t|trU|jddk(rAt |jd xs j||fd }| ||f< |||y|dk(rt|jdtr|jdn t|} rC|jds2i|dt j D cgc]\} }| c}} i}|Sycc}} w)Nrrrrzresponse.output_item.addedr'zresponse.output_item.donezresponse.output_text.deltarrQzresponse.output_text.donerzresponse.content_part.donerrzresponse.completedrmr)r$rWr r#r!rYrk) r event_typerrr'rrrrr rroutput_text_partss r)parse_responses_stream_eventzTSkillClawAPIServer._stream_and_track_responses..parse_responses_stream_event so&)Jtxx:?a@L! < ABM99xx'dD)15L.65::xx'dD)15L..-;;#]3):)>)>sB)G#dhhW^N_NeceJf)f!#&!, ?PQT?UV&%::488F+g/@/D/DlTaEbdf/ghCG!<"?@!, tD;;xx'dD)dhhv.>-.Otxx/k3D3H3H,XeIfhj3klDGK%|]&CD%lM4H33;EdhhzFZ\`;a488J#7gklpgq (8(<(P>P>R7S"TGAt4"T($('#Us* H? NrRignore)errorsrrdata: rrjrT)rrWreturndict[str, Any])rrWrrWrr!rNone)rrrdict[str, Any] | None) _stream_llm_responsesr bytesdecoderr=rr:rr<r#r)rurrrrrrtrackedbufrchunkrrnstrippedrmrrrrrrs @@@@r)rz.SkillClawAPIServer._stream_and_track_responses sr24 8:  3# J 55d;  %EOPUW\E]5<<<AchD4KC#+$'IIdA$6 c#'::<'228<$&qrl(?$%#'::c?DR\\`bfQg+G+Mmq(+7 77 * + 3t 0*30?-9 8'+G!/#+4K?  )%$%!;DD- D+ DDDD D(%D-'D((D-cKddl}|j|d\}}} |jt4d{}|j d|||4d{}|j |j 23d{}|s |7T7876dddd{7n#1d{7swYnxYwdddd{7y#1d{7swYyxYw#|j$rZ} | jjdd} tjd | jj| td d |  | d} ~ wt$r.} tjd | dtd d|  | d} ~ wwxYww)zKPassthrough upstream Responses SSE without aggregating or rewriting events.rNTrrPOSTrrOz1[OpenClaw] upstream Responses stream error: %s %srz!Upstream Responses stream error: r%z&[OpenClaw] Responses stream failed: %srzResponses stream error: )rrrr~rr aiter_bytesrrmrrrr&r r<) rurrrrrrrr r]r-s r)rz(SkillClawAPIServer._stream_llm_responses$ s|"&"A"A$t"A"TY _((1M1O(P ( (TZ!==9g=V((Z^))+'+'7'7'9((e "'K  ((('9((((( ( ( ( ( ( $$ hJJOODS1M LLLajjNdNdfs tC:[\][^8_`fg g _ LLA1tL TC:RSTRU8VW]^ ^ _sFC'BC'CBC!B+BB BB+ B+C'CBB+ C$B'%C+B= 1B42B= 9C C' C C'FC$C C$ C'#F$C''F6AE  F)FFFc  Kddl}|jjjd}|s t dd|j Dcic] \}}|dvs ||}}}|jj xs|jdd |d<d |d <i}|jjrd |jj|d <|jjdk(r%|jjr|jj|d<|jjr|jj|d<|jj}|r |dk7rd|i|d<|jj} | rX| jdD cgc]#} | js| j%} } | r|jdd g| z|d<|jj dk(r|j#did|dd<d} t%| D]w} |j't)4d{}|j+|d||d{}|j-|j/cdddd{cSycc}}wcc} w7c7F7#1d{7swYnxYw#|j0$r}|j2j4dd}|j2j6dk(rEd|j2j4vr-t8j;d|j=d dYd}~)|j2j6dk(rd!|j2j4vrt8j;d"t?|}d#|d < |j't)4d{7}|jAd$|d||4d{7}|j-tC|d{7}dddd{7n#1d{7swYnxYwdddd{7n#1d{7swYnxYwtE|jdd %cYd}~cS#|j0$rX}t8jGd&|j2j6|j2j4ddt d'd(||d}~wtH$r.}t8jGd)|d#*t d'd+||d}~wwxYw| | d,z kr{tKd-| ztMjNdd,zd.}t8jQd/| d,z| ||j2j6|tSjT|d{7Yd}~t8jGd0|j2j6|t d'd1||d}~wtH$r}| | d,z krftKd-| ztMjNdd,zd.}t8jQd2| d,z| ||tSjT|d{7Yd}~6t8jGd3|d#*t d'd4||d}~wwxYww)5z$Forward to an OpenAI-compatible API.rNrrrr%>logprobs top_logprobsrrJrFrrr openrouterzX-Titlez HTTP-Refererfallbacksortproviderrmodelsdenydata_collectionrrz/chat/completionsrrOr$z'temperature' is not supportedzB[OpenClaw] upstream rejects temperature param, retrying without it temperaturezStream must be set to truezF[OpenClaw] upstream requires stream=true, retrying with SSE collectionTr)r[z*[OpenClaw] upstream SSE retry error: %s %srzUpstream LLM SSE retry error: z([OpenClaw] upstream SSE retry failed: %srzUpstream LLM SSE retry failed: rrrzG[OpenClaw] upstream LLM error (attempt %d/%d), retrying in %.1fs: %s %sz$[OpenClaw] upstream LLM error: %s %szUpstream LLM error: zD[OpenClaw] LLM forward failed (attempt %d/%d), retrying in %.1fs: %sz![OpenClaw] LLM forward failed: %szLLM forward error: )+rrBrrr rkrr$rrPopenrouter_app_nameopenrouter_app_urlopenrouter_routeopenrouter_fallback_modelsrr=openrouter_data_policyrXr rr~rrr:rrmrr&rrrr#rrorfrr<r r!r"rrr )rurrrrrrrrouterrrrrrrr]r- stream_body stream_resprZ stream_errorrs r)rz)SkillClawAPIServer._forward_to_llm_openai8 s;;++2237U  '+jjlndaa?m6mQTn n![[55N'29N '# ("$ ;; " ")01H1H0I'JGO $ ;; # #| 3{{..%)[[%D%D "{{--*.++*H*H'KK00E*,)/ *%{{==H-5^^C-@NAGGI!'')NN+4=="+E*F*OIh'{{11V;$$Z4;A *%&78 [)N ^GM ^ ,,5Q5S,T''X^!'#*$56& '"-"D ))+99;'''N ^=o*O''''''((6 _ !  5 ::))S05UYZYcYcYhYh5hKK deMM-6::))S05QUVU_U_UdUd5dKK hi"&y/K,0K),#(#4#4=Y=[#4#\UU`f'-}} &#+*,= >%0(/ (5(UU "- + < < >/G /T)T)TUUUUUUUUUU C"+4=="+E !00 , H(11==(1166t< ,(+%CL>#R ,,%, %OQ]hl m+(+%D\N#S ,,,[1_,q'zFNN1a,@@"EDNNa! # ..% "----- CQZZE[E[]jk#>RSTRUQRSQTAWQ35N8 6Q3:P:O P:P ;O> <P  P: P P:P% PP% !P:( Q33P64Q3:Q QQ #Q3+Y9,Y<3TAS T!)T  TA:W V  WY<  d1155j"EF  tHHUZ[\roc~K|j||d{}|r|jd{yy7 7wr)rD_trigger_evolve)rurrsuploadeds r)rJz7SkillClawAPIServer._upload_session_snapshot_and_trigger, s?22:uEE &&( ( ( F (s=9=;==c4Ktt|jddxsdjj d}|syddl}t dD]} |jd4d{}|j|dd{}|j|j}dddd{tjd |ttr9t|j!d xsddkDr|j#d{yy777k#1d{7swY{xYw7##t$$rK}|d kr%t'j(d |d zzd{7ntj+d|Yd}~:d}~wwxYww)Nevolve_server_urlrrrrgr@rz/triggerz&[SkillHub] triggered evolve server: %suploaded_skillsrg?rz5[SkillHub] evolve trigger failed after 3 attempts: %s)r!r_rBr=rrr rrrr:rrr r#rWr$rr<rr r)rurrrrrrr]s r)rMz"SkillClawAPIServer._trigger_evolve1 sh'$++':B?E2FLLNUUVYZ Qx _G _ ,,U,;))v!'uH-=!>>D))+!YY[F)) DcJfd+FJJ?P4Q4VUV0WZ[0[66888 _)>)))) 9 _Q;!--w{(;<<<NN#Z\]^  _sAFE0D$1E4D* D& $D*1 E<D(=AED?E F$E&D*(E*D< 0D31D< 8E F #F-E0.F FFFc K ddlm}|j|j}|j |jj |}t jd|d|d|jdd|jd d|jd d|jd r(t jd d j|d |jrX|jdddkDs'|jd ddkDs|jddr|jjyyy#t$r }t jd|Yd}~yd}~wwxYww)uPull latest skills from cloud storage and reload the skill manager. This is a *read-only* operation — local skills are never pushed automatically. Use ``skillclaw skills push`` for explicit uploads. rr0r8zZ[SkillHub] skill pull: %d downloaded, %d unchanged, %d failed, %d deleted, %d total remote downloadedskippedfailedrr total_remote failed_namesz&[SkillHub] skill pull failed names: %srrestored_from_backupFz [SkillHub] skill pull failed: %sN)r9r1 from_configrB pull_skills skills_dirrrr$rr%rDreloadr<)rur9r1rB pull_resultr]s r)rz*SkillClawAPIServer._pull_skills_from_cloudK s5  B +&&t{{3C//$++*@*@Z/XK KKlL)I&!, 1-2  ~.GS^_mSnIop!! a014??9a014??#95A""))+B"  B NN=q A A Bs/E&D3D:7E&: E#EE&E##E&cfd}|||kr|S|Dcgc]}|jddk(s|}}|Dcgc]}|jddk7s|}}d}t|dkDr0|||dzdz} || |kr|dz }n|dz }t|dkDr0|||dz} |r%tjd||||| || Scc}wcc}w)zGDrop oldest non-system messages using a dependency-free token estimate.c t|dS)Nr)r)rrs r)rz:SkillClawAPIServer._truncate_messages.._prompt_lenu s54RW6XY Yrorr'rrNzX[OpenClaw] context truncated: dropped %d oldest messages (%d -> %d est tokens, limit=%d))r$rrr) rurrmax_prompt_tokensrrsys_msgsnon_sysdroppedrrs ` r)rz%SkillClawAPIServer._truncate_messagesm s Z x $5 5O (E!155=H+DAEE&D!%%-8*C1DD'lQ 77Q;=#99I9%)::1  qLG 'lQGGH--  KKjH%F#!   )FDsC C CCc|js|gfS |jj|jj t |jdd}|s|gfS|jj}|Dcgc]%}t|ts|jdd'}}tjdt|d j|dd |jj|t!|}t#|Dcgc]\}}|jd d k(s|} }}| r;| d } t%|| jdd} i|| d| dz|zi|| <||fS|j'd d |d||fS#t$r!}tj d|Yd}~d}~wwxYwcc}wcc}}w)aInject an OpenClaw-compatible skill catalog into the system message. Lists ALL eligible skills as an XML ```` catalog with ````, ````, and ```` per entry. The model is instructed to ``read`` at most one SKILL.md when relevant (lazy loading), matching OpenClaw's injection behaviour. Returns (modified_messages, listed_skill_names). rNrrrr-rz/[SkillManager] listing %d skills in catalog: %srr$rr'rr&rrr*)rDrr<rrrr_rBrr r#r$rrr%rr"r8r*insert) rurr]rrrrr@r sys_indicesrrs r)rz!SkillClawAPIServer._inject_skills s!!R<  S    1 1 3''>>dkk+DfM? R< ''668 ?Ia!ZXY[_M`quuV_5a a =   IIk "4C ( ++K8>%.x%8VTQAEE&MX ))--j"=tGLLN34 H }}X.H{{""t#}} H-I"|T:J!h&:x}}!)!2J h-  " ",,  #  .. :sD%%EEc @K|r|jddnd}|rP|j||||jdg|jj|ddz|j|<tj d|||t |jddy w) zFinalize a turn after optional PRM scoring. SkillClaw acts as an external-agent proxy, so finalization keeps only feedback/record side effects that are consumed by the framework. rcrrdrrzI[OpenClaw] finalized turn session=%s turn=%d score=%.1f response_chars=%dr-rN)r$rerWrrr)rur0rGrr7rcs r)r@z*SkillClawAPIServer._finalize_turn_feedback s1; w,   # #J%PWY[A\ ]595O5O5S5ST^`a5bef5fD & &z 2 W     or2 3  sBBc fK|d}|jdigd}|jdi}d|jddxsdd}|jd r|d |d <|jd dd |jd ttj|jd d|jddd}i|dd|ddgi}i|ddi|jdddgi}dtj|dddtj|dddyw)NrmrMrrrr&rr*r?r2zchat.completion.chunkrKrJr)r2rUrKrJr)rNrQrPrPrRrFr/rzdata: [DONE] )r$rWrVr:r;) rurrrarrQ chunk_basefirstrs r)rz#SkillClawAPIServer._stream_response sE$Y-a0**Y+$Y1K1QrR ;;| $"),"7E, ++dB'-{{9c$))+.>?[["-!++lB7  a:`yQY]+^*_`  !b6::o_eCfgh tzz%e<=TBBtzz%e<=TBB  sD/D1cZKtj|23d{}|7 6yw)z1Yield OpenAI Responses API-compatible SSE events.N)rstream_response)rurr s r)rz-SkillClawAPIServer._stream_responses_response s/-==>NO  %K Os+)')+)+c^Ktj|||23d{}|7 6yw)z?Yield Anthropic-format SSE events from an internal result dict.N)rstream_from_openai_result)rurrJrr s r)rz-SkillClawAPIServer._stream_anthropic_response s6.GGPUWab  %K bs-+)+-+-cb|jr|jjry|jj|jjt j |j|jj|jjd}t j||_ tj|jd|_|jj!tj|j"dj!y)Nr)hostport log_levelT)rdaemon)rpis_aliversrrtuvicornConfigrnrB proxy_host proxy_portServerrorqThread _run_serverr_print_ready_banner)rucfgs r)rzSkillClawAPIServer.start( s <._on_donea s%  " " * *1 -   q !ro)r asyncio.Task)rrr[rjr)rucororrs` r)rCz$SkillClawAPIServer._safe_create_task] sA""4( ""4( " x( roc||jry|j}|tjd||yy)Nz%[OpenClaw] background task failed: %sr)r} exceptionrr)rr)s r)rz SkillClawAPIServer._task_done_cbh s9 >>  nn ? LL@#PSL T ro)NNNN)rBrrDzOptional[SkillManager]rEzOptional[PRMScorer])rr )rr)rr)rOptional[float])rrW)rrWrr)rJr!rrWrr!)rr!rr)r list[str]r)rrrr)rr{rr)rr!rr)explicit)rr!rr!rr)rr!) rr!r0rWrr"r.r!r-r!r?r")rr!r0rWrcr{rdr")T) rr!r0rWr-r!rPr!rqr)rr!r0rWr7Optional[dict]rr)rr!r0rWrrrr!)rr!) rrrr!rr!rrrrrrrr)rr)rrrrrz*tuple[str, dict[str, Any], dict[str, str]])rrrr!rr)rrrr!rr)rr!rrrrrr!rrrrrr) rrrrrr!rr!rrrr)rr)rr!rs list[dict]rr)rr!rrW)rr!rrWrr)rr!rsrrr)r9zOptional[set[str]]rr)rrr`rWrr)rrrztuple[list[dict], list[str]])r0rWrGrrr!r7r)rr)rr)rrrJr!rset[str] | None)g>@)rr{rr)rr)C__name__ __module__ __qualname____doc__rzrmrrrrrrrrrr}rrr~rr)rrr:rarerjrWr{rmr3rrrrrrrrrrrrrrrDrrGrrJrMrrrr~r@rrrrr|r}rRrrC staticmethodrrror)r7r7s*04*.! Q7Q7. Q7 ( Q7nqf K3 76<"|@W     X  2: QP7lK8  ), 8< KN _b pt "K( S2&*((( (  (#(2444# 4  40 5ATf$f$f$ f$  f$  f$X 7b;; ; 4 ;6 :AaAa%Aa) Aa  Aa#AaAa AaF.dh.2 nn+ n  n  n#nn`_(x^t3^r***  *X2 ]) _4BD## #  #J+%b<  "   #  :!.'+ $ O & 1)9 UUror7r)r&rrtuple[str, list[dict]])rkzlist[Any] | Nonerset[str])rslist[dict] | Nonerr)rr{)rrrrrr!rr!)rrrrrr)r&r!rr)rr!r&r!r?rrr!)rr!rr)rr!rr!rr!)rr!rr!)rrrr)rr!rr)rr!rr)rr!rr)rBrrr)rr#rztuple[str, list[str]])rr#rztuple[str, str, str])rr!rdict[str, dict[str, str]]rdict[str, str])r)rhr!rrrr!rr)rr!rr)rrrr)rlist[dict[str, Any]]rrrrW)r?rrr)rrrr)rrrr!)r&r!rztuple[bool, str | None])rZrr[r!rr)rr)r?rrrrrr)rr#rrrrrr)rrrztuple[list[dict], int]r)rrrr)rr!rz bytes | None)rrrztuple[int, int] | None)rr!rrW)r&rrrW)r&rrrW)r&rrr!)rrrrW)rrrr!)rrrz1tuple[list[dict[str, Any]], list[dict[str, Any]]])rrrr)rrrr)rrrzlist[tuple[str, int]])r rrrrr)rrrr)rrr(r!rr)r-r!rNrWrr!)rrrJr!rr)r4rrJr!rrrr)r __future__rrrrr:loggingryr!rrrqrV contextlibrrrtypingrrrvfastapir r r r fastapi.responsesr rrBrrEr protocolsrrrrrDrutilsr getLoggerrrrUrr_CYANrVrrrr*rDcompilerrrrrrqrCr`rbrdrrryrwrxrrr MULTILINErrrnrur~rrrrrrrrrrrrrrrrrrrr$r/r2 IGNORECASEr9__annotations__r>rFrHrfrorurrrrrrrrrrrrrrrrrrrrrr"r*r.r1r5r7rror)rs#   *' ;;=#!?='   8 $    4/76D BJJ,bii 8 "**78RZZII   RZZ EryyQ!&!"$"$V$* A!-!( $#1!19H",,W!rzzd - #   . ;& ; ;  ; :$ 0 \ %60>#@ -2BB-BB B>;| "% 6.%P  V MM   RZZGWYdeRZZ;R]]K\ZRZZBBMMRT_`RZZH"--XZmnRZZ6 F RRZZ12<<@/R1-"B2k kk k\(+\**-**Z$$-$$T+/NNN(N NbN3  5pE /  7.7.."Bi+i*ii@A;G?G#'SS S S SlUlUro