iU=dZddlmZddlZddlZddlmZmZddlm Z ddl m Z  ddl m Z mZmZmZmZmZmZmZmZmZddlmZn#e$rZed edZ[wwxYwd d lmZmZmZmZd d l m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&ddl'm(Z(d dl)m*Z+gdZ,e-hdZ.Gdde/Z0Gdde1Z2dGdZ3dHdZ4Gdde5Z6dd dId&Z7dd dJd)Z8dd dKd-Z9dd dLd0Z:dMd2Z;dNd5ZdS)QaGHelpers for integrating MCP (Model Context Protocol) SDK types with the Anthropic SDK. These helpers reduce boilerplate when converting between MCP types and Anthropic API types. Usage:: from anthropic.lib.tools.mcp import mcp_tool, async_mcp_tool, mcp_message This module requires the ``mcp`` package to be installed. ) annotationsN)AnyIterable)urlparse)Literal) Tool TextContent ContentBlock ImageContent PromptMessageCallToolResultEmbeddedResourceReadResourceResultBlobResourceContentsTextResourceContents) ClientSessionz~The `mcp` package is required to use MCP helpers. Install it with: pip install anthropic[mcp]. Requires Python 3.10 or higher.)BetaBase64PDFSourceParamBetaPlainTextSourceParamBetaBase64ImageSourceParamBetaCacheControlEphemeralParam) ToolErrorBetaFunctionToolBetaAsyncFunctionToolBetaFunctionToolResultType beta_toolbeta_async_tool) tag_helper)Content)mcp_toolasync_mcp_tool mcp_content mcp_messagemcp_resource_to_contentmcp_resource_to_fileUnsupportedMCPValueError> image/gif image/png image/jpeg image/webpceZdZdZdS) _TaggedDictzA dict subclass that can carry a ``_stainless_helper`` attribute. Behaves identically to a regular dict for serialization and isinstance checks, but allows attaching tracking metadata that won't appear in JSON output. N__name__ __module__ __qualname____doc__T/root/projects/qq-shell/venv/lib/python3.11/site-packages/anthropic/lib/tools/mcp.pyr.r.Jsr5r.ceZdZdZdS) _TaggedTuplezBA tuple subclass that can carry a ``_stainless_helper`` attribute.Nr/r4r5r6r8r8RsLLLLr5r8 mime_typestrreturnboolc|tvSN)_SUPPORTED_IMAGE_TYPESr9s r6_is_supported_image_typerAVs . ..r5 str | Nonec^|dup)|dp|dkpt|S)Ntext/application/pdf) startswithrAr@s r6 _is_supported_resource_mime_typerGZsET /    ( ( / ) ) / $I . . r5ceZdZdZdS)r(zURaised when an MCP value cannot be converted to a format supported by the Claude API.Nr/r4r5r6r(r(hs____r5r( cache_controlcontentr rJ%BetaCacheControlEphemeralParam | None BetaContentcVt|tr0td|jd}|||d<t |d|St|t rpt |jstd|jtdtd|j |j d }|||d<t |d|St|trt|j | St|d t|j}td |)zConvert a single MCP content block to an Anthropic content block. Handles text, image, and embedded resource content types. Raises :class:`UnsupportedMCPValueError` for audio and resource_link types. text)typerONrJr$zUnsupported image MIME type: imagebase64rPdata media_typerPsourcerIrPzUnsupported MCP content type: ) isinstancer r.rOr r rAmimeTyper(rrTr_resource_contents_to_blockresourcegetattrrPr0)rKrJblock image_block content_types r6r$r$qsS';''VW\BBCC  $%2E/ "5-((( '<(('(899 _*+]7K[+]+]^^ ^!4! &/       $+8K (; ...'+,,Z*7+;=YYYY7FDMM,BCCL "#RL#R#R S SSr5r[+TextResourceContents | BlobResourceContentscX|j}|{t|rlt|tst d|jt dtd|j|d}|||d<t|d|S|d krlt|tst d |jt d td|jd d}|||d<t|d|S|| d rt|tr|j }n,tj|jd }t d t#d|dd}|||d<t|d|St d|d|j)z)rGrY.0cs r6 z*mcp_resource_to_content.. s2TTq'G 'S'STTTTTTTr5Nc*g|]}|j |jSr>)rYrrs r6 z+mcp_resource_to_content..s!TTTQQZ=Saj=S=S=Sr5z>No supported MIME type found in resource contents. Available: z, rI)contentsr(nextjoinrZ)rnrJ supported mime_typess r6r&r&s ?a&'_```TTFOTTT ITT&/TTT & dTYYWaMbMb d d    'y N N NNr5$tuple[str | None, bytes, str | None]c|jstd|jd}t|j}t |j}|r|dddnd}t|trtj |j }n|j d}t|||jf}t!|d|S) zConvert MCP resource contents to a file tuple for ``files.upload()``. Returns a ``(filename, content_bytes, mime_type)`` tuple compatible with the SDK's ``FileTypes``. rpr/rNrcr')rxr(r:rdrpathrsplitrXrrRrfrerOencoder8rYr )rnr[uri_strrname content_bytes file_tuples r6r'r's ?a&'_```q!H(,G G   !D&* 44;;sA  r " "D(0116(77  ,,W55 t]H4EFGGJz1222 r5r rc|jrtd|jD|js |jt j|jSd|jDS)zQConvert MCP ``CallToolResult`` to a value suitable for returning from ``call()``.c,g|]}t|Sr4r$rsitems r6rwz(_convert_tool_result..;s FFFtT**FFFr5Nc,g|]}t|Sr4rrs r6rwz(_convert_tool_result..As 9 9 9$K   9 9 9r5)isErrorrrKstructuredContentjsondumps)rns r6_convert_tool_resultr8si ~HFFv~FFFGGG >4f6Bz&2333 9 9&. 9 9 99r5)rJ defer_loadingallowed_callerseager_input_streaminginput_examplesstricttoolrclientrr bool | NonerTlist[Literal['direct', 'code_execution_20250825', 'code_execution_20260120']] | Nonerr"Iterable[dict[str, object]] | NonerBetaFunctionTool[Any]c  ddl |j d  fd }t| |j|j|||||| } t | d | S) aConvert an MCP tool to a sync runnable tool for ``tool_runner()``. Example:: from anthropic.lib.tools.mcp import mcp_tool tools_result = await mcp_client.list_tools() runner = client.beta.messages.tool_runner( model="claude-sonnet-4-20250514", max_tokens=1024, tools=[mcp_tool(t, mcp_client) for t in tools_result.tools], messages=[{"role": "user", "content": "Use the available tools"}], ) Args: tool: An MCP tool definition from ``client.list_tools()``. client: The MCP ``ClientSession`` used to call the tool. cache_control: Cache control configuration. defer_loading: If true, tool will not be included in initial system prompt. allowed_callers: Which callers may use this tool. eager_input_streaming: Enable eager input streaming for this tool. input_examples: Example inputs for the tool. strict: When true, guarantees schema validation on tool names and inputs. rNkwargsrr;rcdjj|}t|Sr>) from_threadrun call_toolr)rrnanyior tool_names r6call_mcpzmcp_tool..call_mcpps."&&v'7FKK#F+++r5 r description input_schemarJrrrrrr"rrr;r)anyio.from_threadrrr inputSchemar ) rrrJrrrrrrrnrrs ` @@r6r"r"IsF I,,,,,,,, $%##'3%   Fvz""" Mr5BetaAsyncFunctionTool[Any]c  |j d fd }t| |j|j|||||| } t | d| S) aConvert an MCP tool to an async runnable tool for ``tool_runner()``. Example:: from anthropic.lib.tools.mcp import async_mcp_tool tools_result = await mcp_client.list_tools() runner = await client.beta.messages.tool_runner( model="claude-sonnet-4-20250514", max_tokens=1024, tools=[async_mcp_tool(t, mcp_client) for t in tools_result.tools], messages=[{"role": "user", "content": "Use the available tools"}], ) Args: tool: An MCP tool definition from ``client.list_tools()``. client: The MCP ``ClientSession`` used to call the tool. cache_control: Cache control configuration. defer_loading: If true, tool will not be included in initial system prompt. allowed_callers: Which callers may use this tool. eager_input_streaming: Enable eager input streaming for this tool. input_examples: Example inputs for the tool. strict: When true, guarantees schema validation on tool names and inputs. rrr;rc`K|d{V}t|S)N)r arguments)rr)rrnrrs r6rz async_mcp_tool..call_mcps?''Y&'IIIIIIII#F+++r5rr"r)rrrrr ) rrrJrrrrrrrnrs ` @r6r#r#sF I,,,,,,, $%##'3%   Fvz""" Mr5)r9r:r;r<)r9rBr;r<)rKr rJrLr;rM)r[r`rJrLr;rM)rjr rJrLr;rk)rnrrJrLr;rM)rnrr;r})rnr r;r)rrrrrJrLrrrrrrrrrrr;r)rrrrrJrLrrrrrrrrrrr;r)?r3 __future__rrrRtypingrr urllib.parsertyping_extensionsr mcp.typesrr r r r r rrrrmcp.client.sessionr ImportError_err types.betarrrr_beta_functionsrrrrrr_stainless_helpersr 'types.beta.beta_tool_result_block_paramr!rM__all__ frozensetr?dictr.tupler8rArG Exceptionr(r$rZr%r&r'rr"r#r4r5r6rs  #""""" !!!!!!%%%%%%                        1000000 + I     ,+++++MMMMMM   ##Y#Y#YZZ$MMMMM5MMM////`````y```<@(T(T(T(T(T(T\<@ChChChChChCh\<@      0<@OOOOOO4D : : : :*<@!%lp)-9=888888~<@!%lp)-9=66666666sAA AA