i4dZddlmZddlZddlZddlmZmZmZm Z ddl Z ddl m Z mZerddlmZddlmZddlmZdd lmZdd lmZeeZee j6j8e j6j:zZGd d Zy) z,Resource-related methods for FastMCP Client.) annotationsN) TYPE_CHECKINGAnyLiteraloverload)AnyUrl RootModel)Client) ResourceTask) client_span)inject_trace_context) get_loggerc2eZdZdZdd ddZddZdd ddZddZ d ddZe ddd d  dd Z e dddd d  ddZ ddd dd d ddZ d ddZ y)ClientResourcesMixinz4Mixin providing resource-related methods for Client.NcursorcKtjd|jd|j|jj |d{}|S7w)aSend a resources/list request and return the complete MCP protocol result. Args: cursor: Optional pagination cursor from a previous request's nextCursor. Returns: mcp.types.ListResourcesResult: The complete response object from the protocol, containing the list of resources and any additional metadata. Raises: RuntimeError: If called while the client is not connected. McpError: If the request results in a TimeoutError | JSONRPCError [z] called list_resourcesrN)loggerdebugname_await_with_session_monitoringsessionlist_resourcesselfrresults o/Users/bowang/.openclaw/workspace/ChatDev/.venv/lib/python3.12/site-packages/fastmcp/client/mixins/resources.pylist_resources_mcpz'ClientResourcesMixin.list_resources_mcp!sX  q #:;<:: LL ' 'v ' 6    AAAAcKg}d}t} |j|d{}|j|j|js |S|j|vr3t j d|jd|jd |S|j|j|j}7w)a>Retrieve all resources available on the server. This method automatically fetches all pages if the server paginates results, returning the complete list. For manual pagination control (e.g., to handle large result sets incrementally), use list_resources_mcp() with the cursor parameter. Returns: list[mcp.types.Resource]: A list of all Resource objects. Raises: RuntimeError: If called while the client is not connected. McpError: If the request results in a TimeoutError | JSONRPCError Nrr.] Server returned duplicate pagination cursor z( for list_resources; stopping pagination) setrextend resources nextCursorrwarningradd)r all_resourcesr seen_cursorsrs rrz#ClientResourcesMixin.list_resources8s35 !!$ 22&2AAF  !1!1 2$$  L0 {#)),,TV   V.. /&&FA%CB?BCcKtjd|jd|j|jj |d{}|S7w)a:Send a resources/listResourceTemplates request and return the complete MCP protocol result. Args: cursor: Optional pagination cursor from a previous request's nextCursor. Returns: mcp.types.ListResourceTemplatesResult: The complete response object from the protocol, containing the list of resource templates and any additional metadata. Raises: RuntimeError: If called while the client is not connected. McpError: If the request results in a TimeoutError | JSONRPCError rz ] called list_resource_templatesrN)rrrrrlist_resource_templatesrs rlist_resource_templates_mcpz0ClientResourcesMixin.list_resource_templates_mcpZsX  q #CDE:: LL 0 0 0 ?    r cKg}d}t} |j|d{}|j|j|js |S|j|vr3t j d|jd|jd |S|j|j|j}7w)ahRetrieve all resource templates available on the server. This method automatically fetches all pages if the server paginates results, returning the complete list. For manual pagination control (e.g., to handle large result sets incrementally), use list_resource_templates_mcp() with the cursor parameter. Returns: list[mcp.types.ResourceTemplate]: A list of all ResourceTemplate objects. Raises: RuntimeError: If called while the client is not connected. McpError: If the request results in a TimeoutError | JSONRPCError Nrrr"z1 for list_resource_templates; stopping pagination) r#r.r$resourceTemplatesr&rr'rr()r all_templatesrr*rs rr-z,ClientResourcesMixin.list_resource_templatesqs;= !!$ ;;6;JJF  !9!9 :$$  L0 {#)),-++    V.. /&&FJr+c *Kt|}td|d||jj|5tj d|j d|t|tr t|}t|}|r|jd}tjjtjj||rtjjd i|nd| }|j!|j"j%|tjj& d{}n2|j!|j"j)|d{}|cdddS7B7#1swYyxYww) aSend a resources/read request and return the complete MCP protocol result. Args: uri (AnyUrl | str): The URI of the resource to read. Can be a string or an AnyUrl object. meta (dict[str, Any] | None, optional): Request metadata (e.g., for SEP-1686 tasks). Defaults to None. Returns: mcp.types.ReadResourceResult: The complete response object from the protocol, containing the resource contents and any additional metadata. Raises: RuntimeError: If called while the client is not connected. McpError: If the request results in a TimeoutError | JSONRPCError zresources/read zresources/read) session_id resource_urirz] called read_resource: zmodelcontextprotocol.io/taskNuritask_metaparamsrequest result_type)strr transportget_session_idrrr isinstancerr getmcptypesReadResourceRequestReadResourceRequestParams TaskMetadatarr send_requestReadResourceResult read_resource)rr6metauri_strpropagated_meta task_dictr<rs rread_resource_mcpz&ClientResourcesMixin.read_resource_mcpso"c( gY '  ~~446   LL1TYYK'?uE F#s#Sk348O+//0NO ))7799>>DMSYY33@i@SW-?8 $BBLL-- '$'II$@$@.  $BBLL..s3 G  2A  sA7FDFF2F3F4F9 FFFF FF)versionrLr7c KywNr>)rr6rQrLr7s rrKz"ClientResourcesMixin.read_resources QT`)rQrLtask_idttlc KywrSr>)rr6rQrLr7rVrWs rrKz"ClientResourcesMixin.read_resources rT)rQrLr7rVrWcK|r t|ni}|i|jdid|i|d<|r!|j||||xsdd{St|tr t |}|j||xsdd{} | jS7K#t $r}tdt ||d}~wwxYw7;w)aRead the contents of a resource or resolved template. Args: uri (AnyUrl | str): The URI of the resource to read. Can be a string or an AnyUrl object. version (str | None): Specific version to read. If None, reads highest version. meta (dict[str, Any] | None): Optional request-level metadata. task (bool): If True, execute as background task (SEP-1686). Defaults to False. task_id (str | None): Optional client-provided task ID (auto-generated if not provided). ttl (int): Time to keep results available in milliseconds (default 60s). Returns: list[mcp.types.TextResourceContents | mcp.types.BlobResourceContents] | ResourceTask: A list of content objects if task=False, or a ResourceTask object if task=True. Raises: RuntimeError: If called while the client is not connected. McpError: If the request results in a TimeoutError | JSONRPCError NfastmcprQ)rLz"Provided resource URI is invalid: ) dictrC_read_resource_as_taskrBr?r Exception ValueErrorrPcontents) rr6rQrLr7rVrW request_metaers rrKz"ClientResourcesMixin.read_resources@&*tDzr  '""9b1'7'L # 44Wc (<5  c3  Sk --c 8L-MM  8S E NsBA C BC# B.CC C C$B<<CCcFKt|}t|tr t|}tj j tj j|tj j||}|j|jj|td{}|j}t|tj jrm|jj } |j"j%| t'|| t|d} t)j*| |j,| <| S|xstt/j0} t'|| t||j2S7w)a0Read a resource for background execution (SEP-1686). Returns a ResourceTask object that handles both background and immediate execution. Args: uri: Resource URI to read task_id: Optional client-provided task ID (ignored, for backward compatibility) ttl: Time to keep results available in milliseconds (default 60s) meta: Optional metadata to pass with the request (e.g., version info) Returns: ResourceTask: Future-like object for accessing task status and results )rWr5r9r;N)r6immediate_result)r rBr?rrDrErFrGrHrrrIResourceTaskResponseUnionrootCreateTaskResultr7taskId_submitted_task_idsr(r weakrefref_task_registryuuiduuid4r_) rr6rVrWrLrNr<wrapped_result raw_resultserver_task_idtask_objsynthetic_task_ids rr\z+ClientResourcesMixin._read_resource_as_tasks_,/t4 c3 +C))//9966YY+++4%70  $BB LL % %5 &    $(( j#))"<"< ='__33N  $ $ ( ( 8#n#c(TH3:++h2GD   /O!( <3tzz|+< !H!+!4!4  + sB8F!:F;C%F!)rr r str | Nonereturnzmcp.types.ListResourcesResult)rr rtzlist[mcp.types.Resource])rr rrsrtz%mcp.types.ListResourceTemplatesResult)rr rtz list[mcp.types.ResourceTemplate]rS)rr r6 AnyUrl | strrLdict[str, Any] | Nonertzmcp.types.ReadResourceResult) rr r6rurQrsrLrvr7zLiteral[False]rtzElist[mcp.types.TextResourceContents | mcp.types.BlobResourceContents])rr r6rurQrsrLrvr7z Literal[True]rVrsrWintrtr )rr r6rurQrsrLrvr7boolrVrsrWrwrtzTlist[mcp.types.TextResourceContents | mcp.types.BlobResourceContents] | ResourceTask)NrUN) rr r6rurVrsrWrwrLrvrtr ) __name__ __module__ __qualname____doc__rrr.r-rPrrKr\r>rrrs> /3!+ &. F/3!+ .."JHL55'5/D5 %5n #&*$ TT T T $ T  T OTT #&*"      $        #&*"44 4 4 $ 4  444 4r#&* >> >> > $ >  >r}r) r| __future__rrlritypingrrrr mcp.typesrDpydanticrr fastmcp.client.clientr fastmcp.client.tasksr fastmcp.client.telemetryr fastmcp.telemetryr fastmcp.utilities.loggingrryrrErfrJrdrr>r}rrsn2" 88&,-020 H &II!=!== zzr}