kKj@EdZddlmZddlZddlZddlmZddlmZm Z m Z m Z m Z ddl ZerddlmZddlmZddlmZddlZddlZdd l mZmZdd l mZdd lmZmZmZmZmZm Z dd l!m"Z"dd l#m$Z$ddl%m&Z&ddl'm(Z(ddl)m*Z*ddl+m,Z,m-Z-Gddej\Z/Gddej\Z0Gdde*ZgdZ1ddZ2y)z2Base classes and interfaces for FastMCP resources.) annotationsN)Callable) TYPE_CHECKING AnnotatedAnyClassVaroverload)Docket) ExecutionFunctionResource) AnnotationsIcon)Resource)AnyUrl ConfigDictFieldUrlConstraintsfield_validatormodel_validator)SkipJsonSchema)Self)FastMCPDeprecationWarning) AuthCheck)FastMCPComponent) TaskConfigTaskMetacleZdZUdZded<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)fallbackapplication/json)r r"r$N) isinstancestrbytes pydantic_coreto_jsondecodesuper__init__)selfr r"r$normalized_content __class__s g/Users/ahmed/devFolder/Ultron/claude-voice/.venv/lib/python3.12/site-packages/fastmcp/resources/base.pyr1zResourceContent.__init__Asx 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')r8blobr:r;) r*r r+mcptypesTextResourceContentsrr"r$BlobResourceContentsbase64 b64encoder/)r2r8s r5to_mcp_resource_contentsz(ResourceContent.to_mcp_resource_contents^s dllC (9911#-c3#7F3KS\\7<ii 2 9911#-c3#7F3KS%%dll3::<E+Eii 2 r6)NN)r rr"r!r$r#)r8 AnyUrl | strreturnz?mcp.types.TextResourceContents | mcp.types.BlobResourceContents) __name__ __module__ __qualname____doc____annotations__r"r$r1rC __classcell__r4s@r5rr'sg* Iz "&D & !%&* UUU$ U: Hr6rcjeZdZUdZded<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. )rPr$N)_normalize_contentsr0r1)r2rPr$ normalizedr4s r5r1zResourceResult.__init__s'--h7  *48r6c t|tr t|gSt|tr t|gSt|trMt |D]=\}}t|trt d|dt|jd|d|St|ttztztztztzs|!ttj|dgSt dt|j)z)Normalize input to list[ResourceContent].z contents[z] must be ResourceContent, got z. Use ResourceContent(z) to wrap the value.r))r"z;contents must be str, bytes, or list[ResourceContent], got )r*r+rr,list enumerate TypeErrortyperFdicttupleintfloatbooljsondumps)rPiitems r5rRz"ResourceResult._normalize_contentss h $#H-. . h &#H-. . h %$X.4!$8##A3&Ed4jFYFYEZ[//3h6JL/ O xu!4s!:U!BT!I J#DJJx$8DVWX XI$x.JaJaIb c  r6c|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 )rPr;)rPrCr=r>ReadResourceResultr$)r2r8ra mcp_contentss r5 to_mcp_resultzResourceResult.to_mcp_resultsUHL}}U}t55c:} Uyy++!)),  VsAN)rP#str | bytes | list[ResourceContent]r$r#)rPrgrErO)r8rDrEzmcp.types.ReadResourceResult) rFrGrHrIrJr$r1 staticmethodrRrerKrLs@r5rNrNysa!F$#"&D & '+ 95 9$ 9 5   6  r6rNc  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)]r8zName 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) rpversiontitlerniconsr"tagsrr$taskrqc Lddlm}|j||||||||| | | | |  S)Nrr ) fnr8rprrrsrnrtr"rurr$rvrq)#fastmcp.resources.function_resourcer from_function)clsrxr8rprrrsrnrtr"rurr$rvrqr s r5rzzResource.from_functionsF$ .--##  r6before)modec |r|Sy)z&Set default MIME type if not provided.r&)r{r"s r5set_default_mime_typezResource.set_default_mime_types  r6afterc|jr |S|jrt|j|_|Std)z*Set default name from URI if not provided.z#Either name or uri must be provided)rpr8r+ ValueErrorr2s r5set_default_namezResource.set_default_name sB 99   XXDHH DI BC Cr6c 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())NotImplementedErrorrs r5readz Resource.read+s""DEEs ct|tr|St|ttfr,tt ||j |j gSt|ttztztztztzs|ht|tr|rt|dtsCtt tj||j xsd|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$rr))r*rNr+r,rr"r$rYrUrZr[r\r]r^r_)r2 raw_values r5convert_resultzResource.convert_result7s" i 0  i#u .! dnn499UV  y$+"5";e"Cd"J K y$ '9Q<9!# 9-"&.."F4F!YY i((r6c Kywrfrr2 task_metas r5_readzResource._readms EHc Kywrfrrs r5rzResource._readps 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_taskrjN) component task_type argumentsr)fastmcp.server.tasks.routingrrr)r2rr task_resultresults r5rzResource._readss[, 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.rpr8rnr:rsrtrr;)rpr8rnr:rsrtrr;) SDKResourcegetrpr8rnr"rsrtrget_meta)r2 overridess r5to_mcp_resourcezResource.to_mcp_resources vtyy1 eTXX.! mT5E5EF]]:t~~>--4--4! mT5E5EF--  r6c |jjd|jd|jd|jd|j d S)Nz(uri=z, name=z, description=z, tags=))r4rFr8rprnrurs r5__repr__zResource.__repr__sb..))*%|7499-~^b^n^n]qqxy}zCzCyDDEF Fr6ct|jt|j}|d|jxsdS)z1The globally unique lookup key for this resource.@ro)make_keyr+r8rr)r2base_keys r5keyz Resource.keys5==TXX/1T\\/R011r6c|jjsy|j|j|jgy)zrs8" $DD*D'-0"8598Oh((Od^ X''^ Bv v r Kr6