iG@zdZddlmZddlZddlmZddlmZmZm Z m Z m Z ddl Z erddlmZddlmZddlmZddlZddlZdd l mZmZdd l mZdd lmZmZmZmZmZmZdd l m!Z!dd l"m#Z#ddl$m%Z%ddl&m'Z'm(Z(ddl)m*Z*GddejVZ,GddejVZ-Gdde*ZgdZ.ddZ/y)z2Base classes and interfaces for FastMCP resources.) annotationsN)Callable) TYPE_CHECKING AnnotatedAnyClassVaroverload)Docket) ExecutionFunctionResource) AnnotationsIcon)Resource)AnyUrl ConfigDictFieldUrlConstraintsfield_validatormodel_validator)SkipJsonSchema)Self) AuthCheck) TaskConfigTaskMeta)FastMCPComponentcleZdZUdZded<dZded<dZded< d d fd Z d d ZxZ S)ResourceContentafWrapper for resource content with optional MIME type and metadata. Accepts any value for content - strings and bytes pass through directly, other types (dict, list, BaseModel, etc.) are automatically JSON-serialized. Example: ```python from fastmcp.resources import ResourceContent # String content ResourceContent("plain text") # Binary content ResourceContent(b"binary data", mime_type="application/octet-stream") # Auto-serialized to JSON ResourceContent({"key": "value"}) ResourceContent(["a", "b", "c"]) ``` z str | bytescontentN str | None mime_typedict[str, Any] | Nonemetact|tr |}|xsd}nHt|tr |}|xsd}n/tj|tj }|xsd}t ||||y)uCreate ResourceContent with automatic serialization. Args: content: The content value. str and bytes pass through directly. Other types (dict, list, BaseModel) are JSON-serialized. mime_type: Optional MIME type. Defaults based on content type: str → "text/plain", bytes → "application/octet-stream", other → "application/json" meta: Optional metadata dictionary. text/plainapplication/octet-stream)fallbackzapplication/json)rr!r#N) isinstancestrbytes pydantic_coreto_jsondecodesuper__init__)selfrr!r#normalized_content __class__s j/Users/bowang/.openclaw/workspace/ChatDev/.venv/lib/python3.12/site-packages/fastmcp/resources/resource.pyr/zResourceContent.__init__?sx gs #.5 !1\I  '!( !?%?I"/!6!6w!M!T!T!V !7%7I !3ytTct|jtr`tjj t|tr t |n||j|jxsd|jStjjt|tr t |n|tj|jj|jxsd|jS)zConvert to MCP resource contents type. Args: uri: The URI of the resource (required by MCP types) Returns: TextResourceContents for str content, BlobResourceContents for bytes r%)uritextmimeType_metar&)r6blobr8r9) r(rr)mcptypesTextResourceContentsrr!r#BlobResourceContentsbase64 b64encoder-)r0r6s r3to_mcp_resource_contentsz(ResourceContent.to_mcp_resource_contents\s dllC (9911#-c3#7F3KS\\7<ii 2 9911#-c3#7F3KS%%dll3::<E+Eii 2 r4)NN)rrr!r r#r")r6 AnyUrl | strreturnz?mcp.types.TextResourceContents | mcp.types.BlobResourceContents) __name__ __module__ __qualname____doc____annotations__r!r#r/rA __classcell__r2s@r3rr%sg* Iz "&D & !%&* UUU$ U: Hr4rcjeZdZUdZded<dZded< d d fd Ze d dZd d Z xZ S)ResourceResultaCanonical result type for resource reads. Provides explicit control over resource responses: multiple content items, per-item MIME types, and metadata at both the item and result level. Accepts: - str: Wrapped as single ResourceContent (text/plain) - bytes: Wrapped as single ResourceContent (application/octet-stream) - list[ResourceContent]: Used directly for multiple items or custom MIME types Example: ```python from fastmcp import FastMCP from fastmcp.resources import ResourceResult, ResourceContent mcp = FastMCP() # Simple string content @mcp.resource("data://simple") def get_simple() -> ResourceResult: return ResourceResult("hello world") # Multiple items with custom MIME types @mcp.resource("data://items") def get_items() -> ResourceResult: return ResourceResult( contents=[ ResourceContent({"key": "value"}), # auto-serialized to JSON ResourceContent(b"binary data"), ], meta={"count": 2} ) ``` list[ResourceContent]contentsNr"r#cJ|j|}t| ||y)zCreate ResourceResult. Args: contents: String, bytes, or list of ResourceContent objects. meta: Optional metadata about the resource result. )rNr#N)_normalize_contentsr.r/)r0rNr# normalizedr2s r3r/zResourceResult.__init__s'--h7  *48r4c nt|tr t|gSt|tr t|gSt|trMt |D]=\}}t|trt d|dt|jd|d|St dt|j)z)Normalize input to list[ResourceContent].z contents[z] must be ResourceContent, got z. Use ResourceContent(z) to wrap the value.z;contents must be str, bytes, or list[ResourceContent], got ) r(r)rr*list enumerate TypeErrortyperD)rNiitems r3rPz"ResourceResult._normalize_contentss h $#H-. . h &#H-. . h %$X.4!$8##A3&Ed4jFYFYEZ[//3h6JL/ OI$x.JaJaIb c  r4c|jDcgc]}|j|}}tjj ||j Scc}w)zConvert to MCP ReadResourceResult. Args: uri: The URI of the resource (required by MCP types) Returns: MCP ReadResourceResult with converted contents )rNr9)rNrAr;r<ReadResourceResultr#)r0r6rX mcp_contentss r3 to_mcp_resultzResourceResult.to_mcp_resultsUHL}}U}t55c:} Uyy++!)),  VsAN)rN#str | bytes | list[ResourceContent]r#r")rNr^rCrM)r6rBrCzmcp.types.ReadResourceResult) rDrErFrGrHr#r/ staticmethodrPr\rIrJs@r3rLrLwsa!F$#"&D & '+ 95 9$ 9 5   *  r4rLc  eZdZUdZdZded<edZedd Z d ed <ed d Z ded<edd Z ded<dZ ded<dZ ded<edddddddddddd d+dZedded,dZedd-dZ d.dZd/d Zed0d1d!Zed2d"Z d0 d3d#Z d4d$Zd5d%Zed5d&Zd6d'Zddd( d7d)Zd8fd* ZxZS)9rzBase class for all resources.resourcez ClassVar[str] KEY_PREFIXT)validate_default.zURI of the resource)default descriptionz6Annotated[AnyUrl, UrlConstraints(host_required=False)]r6zName of the resourcer)namer%z!MIME type of the resource contentr!NzfAnnotated[Annotations | None, Field(description="Optional annotations about the resource's behavior")]rzAnnotated[SkipJsonSchema[AuthCheck | list[AuthCheck] | None], Field(description='Authorization checks for this resource', exclude=True)]auth) rgversiontitlereiconsr!tagsrr#taskrhc Lddlm}|j||||||||| | | | |  S)Nrr ) fnr6rgrirjrerkr!rlrr#rmrh)#fastmcp.resources.function_resourcer from_function)clsror6rgrirjrerkr!rlrr#rmrhr s r3rqzResource.from_functionsF$ .--##  r4before)modec |r|Sy)z&Set default MIME type if not provided.r%)rrr!s r3set_default_mime_typezResource.set_default_mime_types  r4afterc|jr |S|jrt|j|_|Std)z*Set default name from URI if not provided.z#Either name or uri must be provided)rgr6r) ValueErrorr0s r3set_default_namezResource.set_default_namesB 99   XXDHH DI BC Cr4c Ktdw)a Read the resource content. Subclasses implement this to return resource data. Supported return types: - str: Text content - bytes: Binary content - ResourceResult: Full control over contents and result-level meta z Subclasses must implement read())NotImplementedErrorr{s r3readz Resource.read#s""DEEs ct|tr|St|ttfr,tt ||j |j gSt|S)a$Convert a raw result to ResourceResult. This is used in two contexts: 1. In _read() to convert user function return values to ResourceResult 2. In tasks_result_handler() to convert Docket task results to ResourceResult Handles ResourceResult passthrough and converts raw values using ResourceResult's normalization. When the raw value is a plain string or bytes, the resource's own ``mime_type`` is forwarded so that ``ui://`` resources (and others with non-default MIME types) don't fall back to ``text/plain``. The resource's component-level ``meta`` (e.g. ``ui`` metadata for MCP Apps CSP/permissions) is propagated to each content item so that hosts can read it from the ``resources/read`` response. )r!r#)r(rLr)r*rr!r#)r0 raw_values r3convert_resultzResource.convert_result/sU" i 0  i#u .! dnn499UV  i((r4c Kywr]rvr0 task_metas r3_readzResource._readNs EHc Kywr]rvrs r3rzResource._readQs NQrcKddlm}||dd|d{}|r|S|jd{}|j|S717w)aServer entry point that handles task routing. This allows ANY Resource subclass to support background execution by setting task_config.mode to "supported" or "required". The server calls this method instead of read() directly. Args: task_meta: If provided, execute as a background task and return CreateTaskResult. If None (default), execute synchronously and return ResourceResult. Returns: ResourceResult when task_meta is None. CreateTaskResult when task_meta is provided. Subclasses can override this to customize task routing behavior. For example, FastMCPProviderResource overrides to delegate to child middleware without submitting to Docket. r)check_background_taskraN) component task_type argumentsr)fastmcp.server.tasks.routingrrr)r0rr task_resultresults r3rzResource._readTs[, G1jDI    yy{"""6** #sAA AA A Ac t|jd|j|jd|j|jd|j|jd|j |jd|j |jd|j|jd|j|jd|j S) z'Convert the resource to an SDKResource.rgr6rer8rjrkrr9)rgr6rer8rjrkrr9) SDKResourcegetrgr6rer!rjrkrget_meta)r0 overridess r3to_mcp_resourcezResource.to_mcp_resourcevs vtyy1 eTXX.! mT5E5EF]]:t~~>--4--4! mT5E5EF--  r4c |jjd|jd|jd|jd|j d S)Nz(uri=z, name=z, description=z, tags=))r2rDr6rgrerlr{s r3__repr__zResource.__repr__sb..))*%|7499-~^b^n^n]qqxy}zCzCyDDEF Fr4ct|jt|j}|d|jxsdS)z1The globally unique lookup key for this resource.@rf)make_keyr)r6ri)r0base_keys r3keyz Resource.keys5==TXX/1T\\/R011r4c|jjsy|j|j|jgy)zHH QQ,0 +( + 4 +D    &F22 5"# 88 8  8  8 8*  r4r)rrrLcddd}||vrLddl}ddl}|jjr|j d|dt d dd lm}t||Std td |) z2Deprecated re-exports for backwards compatibility.r ra)r rarNz Importing zh from fastmcp.resources.resource is deprecated. Import from fastmcp.resources.function_resource instead.) stacklevel)function_resourcezmodule z has no attribute ) warningsfastmcpsettingsdeprecation_warningswarnDeprecationWarningfastmcp.resourcesrgetattrAttributeErrorrD)rgdeprecated_exportsrrrs r3 __getattr__rs/  !!    0 0 MMTF#KL"   8($// 78,.@I JJr4)rgr)rCr)0rG __future__rr?collections.abcrtypingrrrrr mcp.typesr;rr docket.executionr rpr pydanticr+rrrrrrrrrrpydantic.json_schemartyping_extensionsr!fastmcp.server.auth.authorizationrfastmcp.server.tasks.configrrfastmcp.utilities.componentsr BaseModelrrL__all__rrvr4r3rs8" $DD*D'-0"7<9Oh((OdX X''X v_ _ D Kr4