6i{@ ~dZddlmZddlmZddlmZmZmZddl m Z ddl m Z Gdd ed Z dd Zdd Z ddZ ddZddZ ddZ ddZ ddZ ddZe j.eede j0eede j2eede j4eediZy)zAnthropic-specific utilities. This module contains utilities specific to the Anthropic provider, including reask functions, response handlers, and message formatting. ) annotations)dedent)Any TypedDictUnion)Mode)generate_anthropic_schemac,eZdZUded<ded<ded<y) SystemMessagestrtypetextzdict[str, str] cache_controlN)__name__ __module__ __qualname____annotations__o/root/.openclaw/workspace/visionaryfx/venv/lib/python3.12/site-packages/instructor/providers/anthropic/utils.pyr r s I I!!rr F)totalc||St|ttfrt|ttfs#tdt |dt |t|trt|tr|d|St|tr.t|trt|}|j ||St|tr1t|tr!t d|g}|j ||St|tr;t|tr+t d|}t|}|j||S|S)a) Combine existing and new system messages. This optimized version uses a more direct approach with fewer branches. Args: existing_system: Existing system message(s) or None new_system: New system message(s) to add Returns: Combined system message(s) z.System messages must be strings or lists, got z and z rrr) isinstancer list ValueErrorrextendr append)existing_system new_systemresult new_messages rcombine_system_messagesr$s0" oT{ 3:S$K<|sgStd|D}|dk(rgSdd}g}|D]t}|jddk(s|jd}|s,t|tr"|D]}|s|j ||^|j ||v|S)a Extract system messages from a list of messages. This optimized version pre-allocates the result list and reduces function call overhead. Args: messages: List of messages to extract system messages from Returns: List of system messages c3JK|]}|jddk(sdyw)rolesystemN)get).0ms r z*extract_system_messages..bsHQaeeFmx.GqHs##rcontentct|tr td|St|tr tdi|St dt |)NrrzUnsupported content type: r)rr r dictrr)r.s rconvert_messagez0extract_system_messages..convert_messageisH gs # f7; ;  & +7+ +9$w-IJ Jrr'r()r.rreturnr )sumr*rrr)messages system_countr1r"messager.items rextract_system_messagesr8Ps  H(HHLq K#%F8 ;;v ( *kk),G'4(#=D od&;<=  og67!8$ Mrc|j}ddlm}t||s|dj dd|dd|Sg}d}|j D]=}|j |j |jd k(s2|j}?d |dg}||j dd |d|dd d gdn|j dd|dd|dj||S)z Handle reask for Anthropic tools mode when validation fails. Kwargs modifications: - Adds: "messages" (tool result messages indicating validation errors) rMessager4userzValidation Error found: . Recall the function correctly, fix the errorsr'r.Ntool_use assistant tool_resultT)r tool_use_idr.is_errorz,Validation Error due to no tool invocation: ) copyanthropic.typesr;rrr. model_dumpridr)kwargsresponse exceptionr;assistant_contentrBr. reask_msgss rreask_anthropic_toolsrMs3[[]F' h (z!!/ {;DD   K##%  !3!3!56 <<: %!**K% '3DEFJ!.'2%>ykIx#y$(    J9+VEF   :j) MrcF|j}ddlm}t||s|dj dd|dd|S|j Dcgc]}|j dk(s|}}|sd }n|d j}dd|d |d}|dj ||Scc}w) z Handle reask for Anthropic JSON mode when validation fails. Kwargs modifications: - Adds: "messages" (user message requesting JSON correction) rr:r4r<zValidation Errors found: r=r>rz!No text content found in responsezO Recall the function correctly, fix the errors found in the following attempt: )rDrEr;rrr.rr)rHrIrJr;c text_blocks text_content reask_msgs rreask_anthropic_jsonrTs[[]F' h (z!!0 >*b1QvY(5JJz : %% s  B B ct||\}}|d|fSddi|d<td}t|jdd|dg|d<||fS) av Handle Anthropic reasoning tools mode. This mode is similar to regular tools mode but with reasoning enabled: - Uses "auto" tool choice instead of forced tool use - Adds a system message encouraging tool use only when relevant - Allows Claude to reason about whether to use tools When response_model is None: - Performs the same message conversion as handle_anthropic_tools - No tools are configured When response_model is provided: - Sets up tools as in regular tools mode - Changes tool_choice to "auto" to allow reasoning - Adds system message to guide tool usage Kwargs modifications: - All modifications from handle_anthropic_tools, plus: - Modifies: "tool_choice" (changes to {"type": "auto"}) - only when response_model provided - Modifies: "system" (adds implicit forced tool message) Nrautor]zC Return only the tool call and no additional text. r(rr)r`rr$r*)r^rVimplict_forced_tool_messages r handle_anthropic_reasoning_toolsrd:s6"8 !SNJZ"( 0J}#) # 3x "= >?Jx : %%rcddl}t|jdg}|rt|jd||d<|jdgDcgc] }|ddk7s |c}|d<|d|fSt d|j |j dd d }t|jdd |d g|d<||fScc}w) ac Handle Anthropic JSON mode. This mode instructs Claude to return JSON responses: - System messages are extracted and combined - A JSON schema message is added to guide the response format When response_model is None: - Extracts and moves system messages to the 'system' parameter - Filters system messages from the messages list - No JSON schema is added When response_model is provided: - Performs system message handling as above - Adds a system message with the JSON schema - Instructs Claude to return an instance matching the schema Kwargs modifications: - Modifies: "messages" (removes system messages) - Adds/Modifies: "system" (combines existing with extracted system messages) - Modifies: "system" (adds JSON schema message) - only when response_model provided rNr4r(r'z As a genius expert, your task is to understand the content and provide the parsed objects in json that match the following json_schema: F)indent ensure_asciizU Make sure to return an instance of the JSON, not the schema itself rr)jsonr8r*r$rdumpsmodel_json_schema)r^rVrirWr,json_schema_messages rhandle_anthropic_jsonrmls2-jnnZ.LMO6 NN8 $o 8 >>*b1QvY(5JJzZ   N446qu UVW   3x "5 67Jx : %%1s  C"Ccdddlm}m}ddlm}|j ddr|d|||d<dd i|d <t |j d g}|rt|j d ||d <|j d gDcgc] }|d d k7s |c}|d <|||fScc}w)ay Handle Anthropic parallel tools mode. Kwargs modifications: - Adds: "tools" (multiple function schemas from parallel model) - Adds: "tool_choice" ("auto" to allow model to choose which tools to call) - Modifies: "system" (moves system messages into system parameter) - Removes: "system" messages from "messages" list - Validates: stream=False r)AnthropicParallelModelhandle_anthropic_parallel_model)ConfigurationErrorstreamFzEstream=True is not supported when using ANTHROPIC_PARALLEL_TOOLS moderZrrbr]r4r(r')typehint) dsl.parallelrorpcore.exceptionsrqr*r8r$)r^rVrorprqrWr,s rhandle_anthropic_parallel_toolsrvs6~~h& S  :.IJw!' 0J}-jnnZ.LMO6 NN8 $o 8 >>*b1QvY(5JJz "> :J FF s B-B-)reaskrIN)r z%Union[str, list[SystemMessage], None]r!Union[str, list[SystemMessage]]r2rx)r4zlist[dict[str, Any]]r2zlist[SystemMessage])rHdict[str, Any]rIrrJ Exception)rVryr2ry)r^ztype[Any] | NonerVryr2z'tuple[type[Any] | None, dict[str, Any]])r^z type[Any]rVryr2ztuple[Any, dict[str, Any]])__doc__ __future__rtextwraprtypingrrrmoder processing.schemar r r$r8rMrTrXr`rdrmrvANTHROPIC_TOOLSANTHROPIC_JSONANTHROPIC_REASONING_TOOLSANTHROPIC_PARALLEL_TOOLSANTHROPIC_HANDLERSrrrrsu #((:"IU" 6:6/6%6r6r: :::z* ***Z*/&$/&2@/&,/&d/&$/&2@/&,/&d:&$:&2@:&,:&z&G&G+9&G&GV &* %) ""&4% !!&3$r