AXj=`dZddlmZddlZddlZddlmZmZddlm Z ddl m Z  ddl m Z mZmZmZmZmZmZmZmZmZddlmZd 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/Z0Gdde1Z2d%dZ3d&dZ4Gdde5Z6dd d'dZ7dd d(dZ8dd d)dZ9dd d*dZ: d+d Z;d,d!Zy#e$rZed edZ[wwxYw)/aGHelpers 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/webpceZdZdZy) _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__]/var/www/html/content_generation/venv/lib/python3.12/site-packages/anthropic/lib/tools/mcp.pyr.r.Jsr5r.ceZdZdZy) _TaggedTuplezBA tuple subclass that can carry a ``_stainless_helper`` attribute.Nr/r4r5r6r8r8RsLr5r8c|tvSN)_SUPPORTED_IMAGE_TYPES mime_types r6_is_supported_image_typer>Vs . ..r5cX|duxs%|jdxs|dk(xs t|S)Ntext/application/pdf) startswithr>r<s r6 _is_supported_resource_mime_typerCZs?T /    ( / ) ) / $I . r5ceZdZdZy)r(zURaised when an MCP value cannot be converted to a format supported by the Claude API.Nr/r4r5r6r(r(hs_r5r( cache_controlc&t|tr-td|jd}|||d<t |d|St|t rpt |jstd|jtdtd|j|jd }|||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)typerHrFr$zUnsupported image MIME type: imagebase64rIdata media_typerIsourcerErIzUnsupported MCP content type: ) isinstancer r.rHr r r>mimeTyper(rrMr_resource_contents_to_blockresourcegetattrrIr0)contentrFblock image_block content_types r6r$r$qs ';'VW\\BC  $%2E/ "5-( '<('(8(89*-J7K[K[J\+]^ ^!4! &//     $+8K (; .'+,*7+;+;=YY7FDM,B,BCL "%CL>#R SSr5c|j}|lt|rat|tst d|j t dtd|j|d}|||d<t|d|S|dk(rat|tst d |j t d td|jdd}|||d<t|d|S||jd rzt|tr |j}n.tj|jj!d }t d t#d |dd}|||d<t|d|St d|d|j )zrQrr(urir.rblobr rrBrrHrK b64decodedecoder)rTrFr=rX pdf_blockrM text_blocks r6rSrSs !!I!9)!D($89*-`aiamam`n+op p!4!!(     $+8K (; 9:%%($89*-^_g_k_k^l+mn n"2!!0     $)6Io &978I009 h 4 5==D##HMM299'BD "2+     $*7J ':89 "%z*mcp_resource_to_content.. sTOq'G 'SOs$$Nz>No supported MIME type found in resource contents. Available: z, rE)contentsr(nextrRjoinrS)rfrF supportedrk mime_typess r6r&r&s ??&'_``TFOOT I*0//T/QQZZ=Sajj/ T&LTYYWaMbLc d   'y NN Us BBc|js td|jd}t|j}t |j }|r|j dddnd}t|tr tj|j}n|jjd}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``. rhr/rNr\r')rmr(strr]rpathrsplitrQrrKr_r^rHencoder8rRr )rfrTuri_strrvname content_bytes file_tuples r6r'r's ??&'_``q!H(,,G G  ! !D&*4;;sA r "D(01((7  ,,W5 t]H4E4EFGJz12 r5c:|jr,t|jDcgc] }t|c}|js+|jt j |jS|jDcgc] }t|c}Scc}wcc}w)zQConvert MCP ``CallToolResult`` to a value suitable for returning from ``call()``.)isErrorrrVr$structuredContentjsondumps)rfitems r6_convert_tool_resultr8s~ ~~v~~F~tT*~FGG >>f66Bzz&2233*0.. 9.$K . 99 G :s B>B)rF defer_loadingallowed_callerseager_input_streaminginput_examplesstrictc  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. rNchjjj|}t|Sr:) from_threadrun call_toolr)kwargsrfanyioclient tool_names r6call_mcpzmcp_tool..call_mcpss.""&&v'7'7FK#F++r5 rz description input_schemarFrrrrrr"rrreturnr)anyio.from_threadrzrr inputSchemar ) toolrrFrrrrrrrfrrs ` @@r6r"r"Is^L I, $$%%##'3% Fvz" Mr5c  |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. c\Kj|d{}t|S7w)N)rz arguments)rr)rrfrrs r6rz async_mcp_tool..call_mcps0''Y&'II#F++Js ,*,rr"r)rzrrrr ) rrrFrrrrrrrfrs ` @r6r#r#s[L I, $$%%##'3% Fvz" Mr5)r=rurbool)r=z str | Nonerr)rVr rF%BetaCacheControlEphemeralParam | Noner BetaContent)rTz+TextResourceContents | BlobResourceContentsrFrrr)rer rFrrzdict[str, Any])rfrrFrrr)rfrrz$tuple[str | None, bytes, str | None])rfr rr)rrrrrFrr bool | Nonerolist[Literal['direct', 'code_execution_20250825', 'code_execution_20260120', 'code_execution_20260521']] | Nonerrr"Iterable[dict[str, object]] | NonerrrzBetaFunctionTool[Any])rrrrrFrrrrrrrrrrrrzBetaAsyncFunctionTool[Any])?r3 __future__rrrKtypingrr 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!r__all__ frozensetr;dictr.tupler8r>rC Exceptionr(r$rSr%r&r'rr"r#r4r5r6rsq # !%   1  ,M ##YZ$M5M/`y`<@(T (T9(T (T\<@Ch9Ch9Ch Ch\<@   9  0<@O O9O O4 )D :*<@!%)-9=; ; ;9 ;  ;  ;';7; ;;D<@!%)-9=9 9 99 9  9  9'979 9 9I   I  sDD- D((D-