Ki(dZddlmZddlZddlmZddlmZmZddl m Z m Z m Z m Z mZmZmZmZmZmZmZmZddl mZddl mZdd lmZdd lmZdd lmZdd l m!Z!e!e"Z#erdd l$m%Z%ede&Z'eGddee'Z(eGddZ) ddZ*ddZ+ ddZ, d ddZ-y)z8Sampling types and helper functions for FastMCP servers.) annotationsN) dataclass) TYPE_CHECKINGGeneric) ClientCapabilitiesCreateMessageResultCreateMessageResultWithTools ModelHintModelPreferencesSamplingCapabilitySamplingMessageSamplingToolsCapability TextContent ToolChoiceToolResultContentToolUseContent)CreateMessageRequestParams)Tool)TypeVar) ToolError) SamplingTool) get_logger)ContextResultT)defaultc0eZdZUdZded<ded<ded<y) SamplingResultaResult of a sampling operation. Attributes: text: The text representation of the result (raw text or JSON for structured). result: The typed result (str for text, parsed object for structured output). history: All messages exchanged during sampling. str | Nonetextrresultlist[SamplingMessage]historyN)__name__ __module__ __qualname____doc____annotations__g/home/jay/workspace/scripts/.codegraph-venv/lib/python3.12/site-packages/fastmcp/server/sampling/run.pyrr's  O ""r)rc\eZdZUdZded<ded<ed dZed dZed dZy ) SampleStepzsResult of a single sampling call. Represents what the LLM returned in this step plus the message history. 2CreateMessageResult | CreateMessageResultWithToolsresponser!r"cjt|jtr|jjdk(Sy)z-True if the LLM is requesting tool execution.toolUseF) isinstancer.r stopReason)selfs r* is_tool_usezSampleStep.is_tool_use@s+ dmm%A B==++y8 8r)c|jj}t|tr&|D] }t|ts|j cSyt|tr |j Sy)z-Extract text from the response, if available.N)r.contentr1listrr)r3r6blocks r*rzSampleStep.textGs\--'' gt $  &e[1 ::% &  -<< r)c|jj}t|tr!|Dcgc]}t|ts|c}St|tr|gSgScc}w)z-Get the list of tool calls from the response.)r.r6r1r7r)r3r6cs r* tool_callszSampleStep.tool_callsTsT--'' gt $&H!*Q*GAH H  09  Is AAN)returnbool)r<r)r<list[ToolUseContent]) r#r$r%r&r'propertyr4rr;r(r)r*r,r,6sP A@ ""    r)r,c<|yt|tr|St|trtt|gSt|trAt d|Ds t dt|Dcgc]}t|c}St dcc}w)z5Convert model preferences to ModelPreferences object.N)name)hintsc3<K|]}t|tyw)N)r1str).0hs r* z+_parse_model_preferences..jsA!:a%Asz7All elements of model_preferences list must be strings.zLmodel_preferences must be one of: ModelPreferences, str, list[str], or None.)r1r rDr r7all ValueError)model_preferencesrFs r*_parse_model_preferencesrK_s  %'7 8  %s +y6G'H&IJJ %t ,A/@AAVW WBS&TQya'8&TUU Z  'Us3Bc4|j}|j}|jtt }|jtt t }|j dk(r|j tdy|j dk(r7|xr| xs|}|s)|j|r|r |s tdtd yy |j td |j d |s td |r |s tdy ) aqDetermine whether to use fallback handler or client for sampling. Args: context: The MCP context. needs_tools: Whether the sampling request requires tool support. Returns: True if fallback handler should be used, False to use client. Raises: ValueError: If client lacks required capability and no fallback configured. )sampling) capability)toolsalwaysz?sampling_handler_behavior is 'always' but no handler configuredTfallbackzeClient does not support sampling with tools. The client must advertise the sampling.tools capability.z Client does not support samplingz#Invalid sampling_handler_behavior: z(. Must be 'always', 'fallback', or None.F) fastmcpsessioncheck_client_capabilityrr rsampling_handler_behaviorsampling_handlerrI)context needs_toolsrRrS has_samplinghas_tools_capabilityclient_sufficients r*determine_handler_moder\vsZooGooG22%/A/CD3L#::%'.E.GH ; ((H4  # # +Q   * *j 8(V+o.UAU ''/<8L$S!!CDD   * * 61'2S2S1VW5 5  ;<< 1 G  r)c K|jj td|j td|jj|t ||||t ||||j}t j|r |d{}t|trtdtd|dd S|S70w) zMake LLM call using the fallback handler. Note: This function expects the caller (sample_step) to have validated that sampling_handler is set via determine_handler_mode(). The checks below are safeguards against internal misuse. Nzsampling_handler is Nonezrequest_context is None) systemPromptmessages temperature maxTokensmodelPreferencesrO toolChoice assistantrtyperunknownendTurn)roler6modelr2) rRrV RuntimeErrorrequest_contextSamplingParamsrKinspect isawaitabler1rDrr) rWr_ system_promptr` max_tokensrJ sdk_tools tool_choicer s r*call_sampling_handlerrts"''/566&455 __ - -&# 56GH"   F6"&#"V&9    MsBCC1CcKg}|D]}|j|j}|C|jtd|jt dd|jdgdc |j |jd{}|jtd|jt dt|g |S7D#t$rk}tjd |jd|jtd|jt dt|gdYd}~8d}~wt$r}tjd |jd|rd |jd}nd |jd |}|jtd|jt d|gdYd}~d}~wwxYww) aExecute tool calls and return results. Args: tool_calls: List of tool use requests from the LLM. tool_map: Mapping from tool name to SamplingTool. mask_error_details: If True, mask detailed error messages from tool execution. When masked, only generic error messages are returned to the LLM. Tools can explicitly raise ToolError to bypass masking when they want to provide specific error messages to the LLM. Returns: List of tool result content blocks. N tool_resultrzError: Unknown tool ''reT)rf toolUseIdr6isError)rfrxr6zError calling sampling tool 'zError executing tool 'z': ) getrAappendridrruninputrDrlogger exception Exception) r;tool_mapmask_error_details tool_resultstool_usetool result_valuee error_texts r* execute_toolsrs$-/L3||HMM* <   !&&kk#!'#8q!I !  " %)XXhnn%== ##%*"*++!,&s   #@q!QR##%*"*++!,&s1v!F G $    #@q!QR%#9(--!JJ#9(--A3!OJ##%*"*++!,&z!J K $  sWA(G+C C AC GC GA D?9G? G Arzdict[str, SamplingTool]rr=r<zlist[ToolResultContent]).r& __future__rrn dataclassesrtypingrr mcp.typesrrr r r r r rrrrrrrmrSDKTooltyping_extensionsrfastmcp.exceptionsr%fastmcp.server.sampling.sampling_toolrfastmcp.utilities.loggingrr#rfastmcp.server.contextrrDrrr,rKr\rtrr(r)r*rs>>"!)    C%%(>0 H . )S )  #WW% #  # %% %P @  .8v0 0#0 0  0  0A0$0#080l %I$I%II Ir)