[ǻi dZddlZddlmZddlmZddlmZmZm Z de dedefd Z d ed e de efd Z dd d ede e e zdzde efdZy)aResources adapter for converting MCP resources to LangChain [Blob objects][langchain_core.documents.base.Blob]. This module provides functionality to convert MCP resources into LangChain Blob objects, handling both text and binary resource content types. N)Blob) ClientSession)BlobResourceContentsResourceContentsTextResourceContents resource_uricontentsreturnct|tr |j}n@t|tr t j |j }nd|}t|tj||jd|iS)zConvert an MCP resource content to a LangChain Blob. Args: resource_uri: URI of the resource contents: The resource contents Returns: A LangChain Blob z!Unsupported content type for URI uri)data mime_typemetadata) isinstancertextrbase64 b64decodeblob TypeErrorr from_datamimeType)rr r msgs ^/opt/lhia/marcimex/agent/venv/lib/python3.12/site-packages/langchain_mcp_adapters/resources.py&convert_mcp_resource_to_langchain_blobrsp(01}} H2 3 .1,@n >> X..%9N sessionr cK|j|d{}|jrt|jdk(rgS|jDcgc]}t||c}S7Ncc}ww)a)Fetch a single MCP resource and convert it to LangChain [Blob objects][langchain_core.documents.base.Blob]. Args: session: MCP client session. uri: URI of the resource to fetch. Returns: A list of LangChain [Blob][langchain_core.documents.base.Blob] objects. Nr) read_resourcer lenr)rr contents_resultcontents rget_mcp_resourcer"(so$11#66O  # #s?+C+C'D'I '//   /sG<  7 s!A-A&8A-A(#A-(A-)urisr#ctKg}|<|jd{}|jDcgc]}|j}}nt|tr|g}n|}d} |D])}|}t ||d{}|j |+ |S7rcc}w7!#t$r} d|} t| | d} ~ wwxYww)azLoad MCP resources and convert them to LangChain [Blob objects][langchain_core.documents.base.Blob]. Args: session: MCP client session. uris: List of URIs to load. If `None`, all resources will be loaded. !!! note Dynamic resources will NOT be loaded when `None` is specified, as they require parameters and are ignored by the MCP SDK's `session.list_resources()` method. Returns: A list of LangChain [Blob][langchain_core.documents.base.Blob] objects. Raises: RuntimeError: If an error occurs while fetching a resource. NzError fetching resource ) list_resources resourcesr rstrr"extend Exception RuntimeError) rr#blobsresources_listruri_list current_urir resource_blobsers rload_mcp_resourcesr2<s. E |&5577#1#;#;r9s .RR!1 4MT .$(+ + S /D + $Z +r