k7id6SSKJr SSKrSSKrSSKJrJr SSKJr SSK J r J r J r SSK Jr SSKrSSKJr SSKJr SS KJrJr SS KJr SS KJrJrJrJr SS KJr SSKrSS K J!r!J"r" SSK#J$r$ SSK%J&r& SSK'J(r( SSK)J*r* SSK+J,r,J-r-J.r. SSK/J0r0 SSK1J2r2J3r3 SSK4J5r5 SSK6J7r7 SSK8J9r9J:r: SSK;Jr> SSK?J@r@ SSKAJBrB SSKCJDrDJErE SSKFJGrG SSKHJIrI SSKJJKrK SS KLJMrM \ (aSSKNJ>r> \M"\O5rP\/\!4\/\\!4-rQ"S!S"5rR"S#S$\G\R5rS"S%S&\<\R5rT"S'S(\7\R5rU"S)S*\D\K5rV"S+S,\9\K5rW"S-S.\:\K5rX"S/S0\2\K5rY"S1S2\B5rZS8S3jr["S4S5\!\*5r\"S6S7\\\*5r]g)9) annotationsN) AwaitableCallable)Path) TYPE_CHECKINGAnycast)quote) ServerSession) ClientSession)LifespanContextTRequestContext)McpError)METHOD_NOT_FOUNDBlobResourceContentsGetPromptResultTextResourceContents)AnyUrl)ClientFastMCP1Server) ElicitResult) LogMessage) RootsList)ClientTransportT) NotFoundError ResourceError ToolError) MCPConfig)Prompt PromptMessage)PromptArgument) PromptManager)ResourceResourceTemplate)ResourceManager)Context) get_context)FastMCP)Tool ToolResult) ToolManager)apply_transformations_to_tools)MirroredComponent) get_loggerc.\rSrSr%SrS\S'SSjrSrg) ProxyManagerMixin8zHA mixin for proxy managers to provide a unified client retrieval method.ClientFactoryTclient_factoryc|# UR5n[R"U5(a UIShvN nU$N7f)z[TU]"S0UD6 XlgNr<super__init__r3r7r3kwargs __class__s r9rMProxyToolManager.__init__H "6",rEc*># [TU]5IShvN nUR5IShvN nUIShvN UR5IShvN nUH6nURU;dM[ R X$5XR'M8 SSS5IShvN [UURS9nU$NNNNlN"!,IShvN (df  N7=f![a*nURR[:XaSnANgUeSnAff=f7f)zMGets the unfiltered tool inventory including local, mounted, and proxy tools.N)toolstransformations) rL get_toolsr: list_toolsname ProxyTool from_mcp_toolrerrorcoderr,rU)r7 all_toolsr8 client_toolstooletransformed_toolsrPs r9rVProxyToolManager.get_toolsLs '+--  ++--Fv%+%6%6%88 (Dyy 1/8/F/Fv/T )),)v; 00  ! +..8vvv  ww||//  sDB8DCB: CB<CCB>C-%C CCC"D:C<C>CCCC CCDC D&D D D  DDcp# UR5IShvN n[UR55$N7f)zJGets the filtered list of tools including local, mounted, and proxy tools.N)rVlistvalues)r7 tools_dicts r9rWProxyToolManager.list_toolsfs->>++ J%%'((, 646ct># [TU]X5IShvN $N![a UR5IShvN nUIShvN URX5IShvN n[ UR UR S9sSSS5IShvN s$!,IShvN (df  g=ff=f7f)zBCalls a tool, trying local/mounted first, then proxy if not found.Ncontentstructured_content)rL call_toolrr:r*rkrl)r7key argumentsr8resultrPs r9rmProxyToolManager.call_toolks *3:: :: ++---Fv%//???!"NN'-'@'@vvvvv sB8B8B5> B5A B5 B!A$""B B5BB5B8B1 B" B1 ,B5/B81B55B8r3r3r2rOr)r=zdict[str, Tool])r=z list[Tool])rnstrrodict[str, Any]r=r*) r>r?r@rArBrMrVrWrmrD __classcell__rPs@r9rGrGEsk-!4)  rErGct^\rSrSrSrS U4SjjrS U4SjjrS U4SjjrS SjrSSjr SU4Sjjr S r U=r $)ProxyResourceManager{zmA ResourceManager that sources its resources from a remote client in addition to local and mounted resources.c 2>[TU]"S0UD6 XlgrJrKrNs r9rMProxyResourceManager.__init__~rRrEc,># [TU]5IShvN nUR5IShvN nUIShvN UR5IShvN nUHIn[ UR 5U;dM[ RX$5U[ UR 5'MK SSS5IShvN U$NNNNkN!,IShvN (df  U$=f![a+nURR[:XaSnAU$UeSnAff=f7f)zUGets the unfiltered resource inventory including local, mounted, and proxy resources.N) rL get_resourcesr:list_resourcesrturi ProxyResourcefrom_mcp_resourcerr[r\r)r7 all_resourcesr8client_resourcesresourcer`rPs r9r~"ProxyResourceManager.get_resourcess$g355  ++--Fv)/)>)>)@#@ 0H8<<( =);;FM&c(,,&78!1v%6.#@vv  ww||//  sDB7DCB9 CB;CCB= C6/C% C0B?1C5D9C;C=C?CCC  CCDC D&D D D  DDc># [TU]5IShvN nUR5IShvN nUIShvN UR5IShvN nUH6nURU;dM[ R X$5XR'M8 SSS5IShvN U$NNwNnNXN!,IShvN (df  U$=f![a+nURR[:XaSnAU$UeSnAff=f7f)zUGets the unfiltered template inventory including local, mounted, and proxy templates.N) rLget_resource_templatesr:list_resource_templates uriTemplate ProxyTemplatefrom_mcp_templaterr[r\r)r7 all_templatesr8client_templatestemplater`rPs r9r+ProxyResourceManager.get_resource_templatess$g<>>  ++--Fv)/)G)G)I#I 0H++=@);;FM&&:&:;!1v%?.#Ivv  ww||//  DB$DC B& C B(C B.B*B.-%B. C B,C "D&C (C *B.,C .C4B7 5 CC DC C>C91D7C99C>>Dcp# UR5IShvN n[UR55$N7f)zRGets the filtered list of resources including local, mounted, and proxy resources.N)r~rdre)r7resources_dicts r9r#ProxyResourceManager.list_resourcess/#1133N))+,,4rhcp# UR5IShvN n[UR55$N7f)zRGets the filtered list of templates including local, mounted, and proxy templates.N)rrdre)r7templates_dicts r9r,ProxyResourceManager.list_resource_templatess/#::<<N))+,,=rhc 2># [TU]U5IShvN $N![a UR5IShvN nUIShvN URU5IShvN n[ US[ 5(a#USR sSSS5IShvN s$[ US[5(a#USRsSSS5IShvN s$[S[US535Se!,IShvN (df  g=ff=f7f)zFReads a resource, trying local/mounted first, then proxy if not found.NrUnsupported content type: ) rL read_resourcerr: isinstancertextrblobrtype)r7rr8rprPs r9r"ProxyResourceManager.read_resources .s33 33 ++---Fv%33C888fQi)=>>!!9>>vv q +?@@!!9>> vv(4T&)_4EF vv sDDD> DA D C8!A$"+C8 DBD D"&C8 DCDDC88D >D? D DDDDrrrs)r=zdict[str, Resource])r=zdict[str, ResourceTemplate])r=zlist[Resource])r=zlist[ResourceTemplate])rz AnyUrl | strr= str | bytes) r>r?r@rArBrMr~rrrrrDrvrws@r9ryry{s)w-..- -   rErycj^\rSrSrSrSU4SjjrS U4SjjrS SjrS S U4SjjjrSr U=r $) ProxyPromptManagerzgA PromptManager that sources its prompts from a remote client in addition to local and mounted prompts.c 2>[TU]"S0UD6 XlgrJrKrNs r9rMProxyPromptManager.__init__rRrEc># [TU]5IShvN nUR5IShvN nUIShvN UR5IShvN nUH6nURU;dM[ R X$5XR'M8 SSS5IShvN U$NNwNnNXN!,IShvN (df  U$=f![a+nURR[:XaSnAU$UeSnAff=f7f)zQGets the unfiltered prompt inventory including local, mounted, and proxy prompts.N) rL get_promptsr: list_promptsrX ProxyPromptfrom_mcp_promptrr[r\r)r7 all_promptsr8client_promptspromptr`rPs r9rProxyPromptManager.get_promptss"G/11  ++--Fv'-':':'3N3N"4 KK0-v%2.!<vv  ww||//  rcp# UR5IShvN n[UR55$N7f)zNGets the filtered list of prompts including local, mounted, and proxy prompts.N)rrdre)r7 prompts_dicts r9rProxyPromptManager.list_promptss/!--// L'')**0rhc<># [TU]X5IShvN $N![aq UR5IShvN nUIShvN UR X5IShvN nUsSSS5IShvN s$!,IShvN (df  g=ff=f7f)zFRenders a prompt, trying local/mounted first, then proxy if not found.N)rL render_promptrr: get_prompt)r7rXror8rprPs r9r ProxyPromptManager.render_promptsq  .t?? ?? ++---Fv%00AAAvvvvv sBBB> BA B A=!A$"A=( B4A75B;B=B B B BBBBrrrs)r=zdict[str, Prompt])r=z list[Prompt]N)rXrtrozdict[str, Any] | Noner=r) r>r?r@rArBrMrrrrDrvrws@r9rrs@q-.+,0)  rErc^^\rSrSrSrSU4Sjjr\SSj5rS S SjjrSr U=r $) rYiz@ A Tool that represents and executes a tool on a remote server. c 2>[TU]"S0UD6 XlgrJrLrM_clientr7r8rOrPs r9rMProxyTool.__init__ "6" rEc U"UURURURURURUR UR =(d 0R S05R S/5SS9 $)z@Factory method to create a ProxyTool from a raw MCP tool schema._fastmcptagsT) r8rX description parametersr output_schemametar _mirrored)rXr inputSchemar outputSchemarget)clsr8mcp_tools r9rZProxyTool.from_mcp_tool so ,,++ ,,"//--%2**:r:>>vrJ  rEc# URIShvN URRURUS9IShvN nSSS5IShvN WR(aD[ [ [ RRURS5R5e[URURS9$NNN{!,IShvN (df  N=f7f)z6Executes the tool by making a call through the client.N)rXrorrj) r call_tool_mcprXisErrorrr mcptypes TextContentrkrr*structuredContent)r7rocontextrps r9run ProxyTool.runs <<<<<55YY#6F < >>D!6!6q8IJOOP PNN%77    <<r?r@rArBrM classmethodrZrrDrvrws@r9rYrYsL    "#' !       rErYc^\rSrSr%SrS\S'SrS\S'SS.S U4S jjjr\SS j5r SS jr S r U=r $)ri-zG A Resource that represents and reads a resource from a remote server. rrNstr | bytes | None_value)rc >>[TU]"S0UD6 XlX lgrJ)rLrMrr)r7r8rrOrPs r9rMProxyResource.__init__5s "6"  rEc U"UURURURUR=(d SURUR=(d 0R S05R S/5SS9$)zHFactory method to create a ProxyResource from a raw MCP resource schema. text/plainrrT)r8rrXr mime_typerrr)rrXrmimeTyperr)rr8 mcp_resources r9rProxyResource.from_mcp_resource@sq  ""$00"++;|""##)r..z2>BB62N  rEc# URb UR$URIShvN URRUR5IShvN nSSS5IShvN [ WS[ 5(aUSR $[ US[5(aUSR$[S[US535eNN~Np!,IShvN (df  N=f7f)z1Read the resource content from the remote server.Nrr) rrrrrrrrrrr)r7rps r9readProxyResource.readSs ;; ";; <<<<<55dhh??F < fQi!5 6 6!9>> ! q #7 8 8!9>> !"r?r@rArBrCrrMrrrrDrvrws@r9rr-swO!%F % &*  #    )     $ P PrErcn^\rSrSrSrSU4Sjjr\SSj5rS S SjjrSr U=r $) ribzY A ResourceTemplate that represents and creates resources from a remote server template. c 2>[TU]"S0UD6 XlgrJrrs r9rMProxyTemplate.__init__grrEc U"UURURURUR=(d S0URUR=(d 0R S05R S/5SS9 $)zHFactory method to create a ProxyTemplate from a raw MCP template schema.rrrT) r8 uri_templaterXrrrrrr)rrXrrrr)rr8 mcp_templates r9rProxyTemplate.from_mcp_templatekst %11""$00"++;|""##)r..z2>BB62N  rEc># URR"S 0UR5VVs0sHupEU[USS9_M snnD6nURIShvN URR U5IShvN nSSS5IShvN [ WS[5(aUSRnOB[ US[5(aUSRnO[S[US535e[URUURURUSR UR"UR"=(d 0R%S05R%S/5US9$s snnfGN NN!,IShvN (df  GN=f7f) zACreate a resource from the template by calling the remote server.)safeNrrrr)r8rrXrrrrrr<)rformatitemsr rrrrrrrrrrrXrrrr) r7rparamsrkvparameterized_urirpvalues r9create_resourceProxyTemplate.create_resource|sI!--44 06 ?q%##? <<<<<556GHHF < fQi!5 6 61INNE q #7 8 81INNE"E>?F FFC-F>FFFF FFrr)r8rrzmcp.types.ResourceTemplater=rr)rrtrrurrr=r) r>r?r@rArBrMrrrrDrvrws@r9rrbsn  +E   (#'           rErcf^\rSrSr%SrS\S'S U4Sjjr\S Sj5rS Sjr Sr U=r $) rizE A Prompt that represents and renders a prompt from a remote server. rrc 2>[TU]"S0UD6 XlgrJrrs r9rMProxyPrompt.__init__rrEc pUR=(d /Vs/sH5n[URURUR=(d SS9PM7 nnU"UURURUUR UR =(d 0R S05R S/5SS9$s snf)zDFactory method to create a ProxyPrompt from a raw MCP prompt schema.F)rXrrequiredrrT)r8rXrrorrr)ror!rXrrrr)rr8 mcp_promptargros r9rProxyPrompt.from_mcp_prompts"++1r1  2 XXOO.  2  "..//'R,,Z<@@L   sr?r@rArBrCrMrrrrDrvrws@r9rrsJO  )9   ,rErcD^\rSrSrSrSSS.SU4SjjjjrSrU=r$) FastMCPProxyiz A FastMCP server that acts as a proxy to a remote MCP-compliant server. It uses specialized managers that fulfill requests via a client factory. Nrrc >^[TU]"S 0UD6 TbUb [S5eTbF[RR (a[ R"S[SS9 U4SjnX@l OUbX l O [S5e[URURRS9Ul [URS 9Ul[URS 9Ulg) a Initializes the proxy server. FastMCPProxy requires explicit session management via client_factory. Use FastMCP.as_proxy() for convenience with automatic session strategy. Args: client: [DEPRECATED] A Client instance. Use client_factory instead for explicit session management. When provided, a client_factory will be automatically created that provides session isolation for backwards compatibility. client_factory: A callable that returns a Client instance when called. This gives you full control over session creation and reuse. Can be either a synchronous or asynchronous function. **kwargs: Additional settings for the FastMCP server. Nz1Cannot specify both 'client' and 'client_factory'zPassing 'client' to FastMCPProxy is deprecated. Use 'client_factory' instead for explicit session management. For automatic session strategy, use FastMCP.as_proxy().) stacklevelc$>TR5$r)new)r8sr9deprecated_client_factory8FastMCPProxy.__init__..deprecated_client_factoryszz|#rEzMust specify 'client_factory')r3rUrrr<)rLrM ValueErrorfastmcpsettingsdeprecation_warningswarningswarnDeprecationWarningr3rG _tool_managerrUry_resource_managerr_prompt_manager)r7r8r3rOrrPs ` r9rMFastMCPProxy.__init__s. "6"  ."<PQ Q  44 N&  $#<   '"0 <= =... ..>>  "6.."  2ATATUrE)rrrr3r)r8z Client | Noner3zClientFactoryT | None)r>r?r@rArBrMrDrvrws@r9rrs8!%:V15 :V:V. :V:VrErcR# [5nUR5IShvN $N7f)z A handler that forwards the list roots request from the remote server to the proxy's connected clients and relays the response back to the remote server. N)r' list_roots)rctxs r9default_proxy_roots_handlerr s! -C! !! !s '%'c^\rSrSrSrS U4Sjjr\S Sj5r\S Sj5r\S Sj5r \S Sj5r Sr U=r $) ProxyClientiz A proxy client that forwards advanced interactions between a remote MCP server and the proxy's connected clients. Supports forwarding roots, sampling, elicitation, logging, and progress. c H>SU;aUR5US'SU;a [US'SU;a[RUS'SU;a[RUS'SU;a[R US'SU;a[R US'[TU] "S0USU0-D6 g) NrXrootssampling_handlerelicitation_handler log_handlerprogress_handler transportr<) generate_namerr default_sampling_handlerdefault_elicitation_handlerdefault_log_handlerdefault_progress_handlerrLrM)r7r'rOrPs r9rMProxyClient.__init__s  !//1F6N & 9F7O V +)4)M)MF% &  .,7,S,SF( )  &$/$C$CF= ! V +)4)M)MF% & =6[)$<<=rEc# [5nUR[U5URURUR UR S9IShvN n[U[RR[RR-5(a [S5e[RRSSUS9$Nr7f)z A handler that forwards the sampling request from the remote server to the proxy's connected clients and relays the response back to the remote server. ) system_prompt temperature max_tokensmodel_preferencesNzContent is not supported assistantzfastmcp-client)rolemodelrk)r'samplerd systemPromptr0 maxTokensmodelPreferencesrrr ResourceLinkEmbeddedResource RuntimeErrorCreateMessageResult)rrrrrrks r9r)$ProxyClient.default_sampling_handler5sm N --**''$55 #   gsyy55 8R8RR S S9: :yy,,"-   sAC CA3C c# [5nURRUURURS9IShvN n[ UR URS9$N"7f)z A handler that forwards the elicitation request from the remote server to the proxy's connected clients and relays the response back to the remote server. )messagerequestedSchemarelated_request_idN)actionrk)r'sessionelicitrA request_idrrCrk)rr@ response_typerrrrps r9r*'ProxyClient.default_elicitation_handlerOs[m{{))"22"~~*   6==&..II  s=A$A"#A$c# [5nURRS5nURRS5nURX1RUR US9IShvN gN7f)zg A handler that forwards the log notification from the remote server to the proxy's connected clients. msgextra)level logger_namerKN)r'datarlogrLlogger)rr@rrJrKs r9r+ProxyClient.default_log_handlerbsW mllu%   )ggcGNNRWgXXXsA)A3+A1,A3cX# [5nURXU5IShvN gN7f)zl A handler that forwards the progress notification from the remote server to the proxy's connected clients. N)r'report_progress)rprogresstotalr@rs r9r,$ProxyClient.default_progress_handlerls$m!!(7;;;s *(*r<)r'z^ClientTransportT | FastMCP | FastMCP1Server | AnyUrl | Path | MCPConfig | dict[str, Any] | str)rzlist[mcp.types.SamplingMessage]rz$mcp.types.CreateMessageRequestParamsr/RequestContext[ClientSession, LifespanContextT]r=zmcp.types.CreateMessageResult) r@rtrGrrzmcp.types.ElicitRequestParamsrrWr=r)r@rr=None)rTfloatrUz float | Noner@z str | Noner=rX) r>r?r@rArBrMrr)r*r+r,rDrvrws@r9r r s >>4 1 5 A  '   2JJJ. J A J  JJ$YY < < < <  < [TU]"U0UD6 0Ulgr)rLrM_caches)r7argsrOrPs r9rMStatefulProxyClient.__init__s $)&)FH rEc # g7f)zj The stateful proxy client will be forced disconnected when the session is exited. So we do nothing here. Nr<)r7exc_type exc_value tracebacks r9 __aexit__StatefulProxyClient.__aexit__ssc# UR(aGURR5upURSS9IShvN UR(aMFggN7f)z5 Clear all cached clients and force disconnect them. TforceN)r]popitem _disconnect)r7_caches r9clearStatefulProxyClient.clearsGll||++-HA##$#/ / /lll /sAAAAAc*^^^[5RmTRRTS5mTc\TR 5m[ R TST35 TTRT'UUU4SjnTRRU5 T$)z Create a new stateful proxy client instance with the same configuration. Use this method as the client factory for stateful proxy server. Nz created for c># TRRT5 [RTS35 TR SS9IShvN gN7f)Nz will be disconnectTrg)r]poprPdebugrj) proxy_clientr7rDsr9_on_session_exit:StatefulProxyClient.new_stateful.._on_session_exitsC   ) ~-@AB"..T.:::sAA A A) r'rDr]rr rPrr _exit_stackpush_async_callback)r7rtrsrDs` @@r9 new_stateful StatefulProxyClient.new_statefuls -''||''6  88:L LLL>wi@ A$0DLL ! ;    3 34D ErE)r])r^rrOr)r=rX)r=zClient[ClientTransportT]) r>r?r@rArBrMrdrmrxrDrvrws@r9r[r[zs"I 0rEr[)rrWr=r)^ __future__rr5rcollections.abcrrpathlibrtypingrrr urllib.parser mcp.typesrr mcp.client.sessionr mcp.shared.contextr rmcp.shared.exceptionsrrrrrpydantic.networksrrfastmcp.client.clientrrfastmcp.client.elicitationrfastmcp.client.loggingrfastmcp.client.rootsrfastmcp.client.transportsrfastmcp.exceptionsrrrfastmcp.mcp_configrfastmcp.promptsrr fastmcp.prompts.promptr!fastmcp.prompts.prompt_managerr"fastmcp.resourcesr#r$"fastmcp.resources.resource_managerr%fastmcp.server.contextr&fastmcp.server.dependenciesr'fastmcp.server.serverr(fastmcp.tools.toolr)r*fastmcp.tools.tool_managerr+fastmcp.tools.tool_transformr,fastmcp.utilities.componentsr-fastmcp.utilities.loggingr.fastmcp.serverr>rPr2r0rGryrrYrrrrrr r[r<rEr9rs"/++,?* %83-*6FF(1188>*3)/2;0& H "f*%Yv5F1F(GG  3{$53lP ?,=P f1(91h( '( V2PH/2Pj: $&7: z&&+&R@V7@VF" <""b<&)*b