+ Q(i/~Rt^RIHt^RIt^RIt^RIHtHtHt^RI H t H t H t ^RI Ht^RIt^RIHt^RIHt^RIHt^R IHtHt^R IHt^R IHtHtHtHt^R IH t ^R I!H"t"H#t#^RI$H%t%^RI&H't'^RI(H)t)^RI*H+t+^RI,H-t-^RI.H/t/H0t0^RI1H2t2^RI3H4t4H5t5H6t6^RI7H8t8^RI9H:t:H;t;^RIt>^RI?H@t@^RIAHBtB^RICHDtD^RIEHFtF^RIGHHtH^RIIHJtJHKtK^RILHMtMHNtN^R IOHPtP] 'd ^R!IQHRtR^R"I,HStS]P!]T4tU].]"3,].]]",3,,tV!R#R$]J4tW!R%R&]:4tX!R'R(];4tY!R)R*]54tZ!R+R,]D4t[R-R.lt\!R/R0]F4t]R1R2lt^R3R4lt_R5R6lt`R7R8ltaR9R:ltbR;R<ltcR=R>ltd!R?R@]"]-,4te!RARB]e]-,4tfR#)CzProxyProvider for proxying to remote MCP servers. This module provides the `ProxyProvider` class that proxies components from a remote MCP server via a client factory. It also provides proxy component classes that forward execution to remote servers. ) annotationsN) AwaitableCallableSequence) TYPE_CHECKINGAnycast)quote) ServerSession) ClientSession) request_ctx)LifespanContextTRequestContext)McpError)METHOD_NOT_FOUNDBlobResourceContentsElicitRequestFormParamsTextResourceContents)AnyUrl)ClientFastMCP1Server) ElicitResult) LogMessage) RootsList) client_span)ClientTransportT) ResourceError ToolError) MCPConfig)MessagePrompt PromptResult)PromptArgument)ResourceResourceTemplate)ResourceContentResourceResult)Context) get_context)Provider)FastMCP) TaskConfig)Tool ToolResult)FastMCPComponentget_fastmcp_metadata) get_logger)Path)ClientTransportca]tRt^Ct$Rt]!RR7tR]R&RtR]R&R V3R llt R R lt R V3Rllt ] RRl4t RRRlltRV3RlltRtV;t#) ProxyToolz>A Tool that represents and executes a tool on a remote server. forbiddenmoder+ task_configN str | None _backend_namec V^8dQhRRRR/#client_factoryClientFactoryTkwargsr)formats"d/Users/agent/.openclaw/workspace/venv/lib/python3.14/site-packages/fastmcp/server/providers/proxy.py __annotate__ProxyTool.__annotate__I..~..c 4<\SV`!R/VBWnR#NrAsuper__init___client_factoryselfr>r@ __class__s&&,rCrLProxyTool.__init__I "6"-rGcV^8dQhRR/#r=returnrrA)rBs"rCrDrEM6rGc "VP4p\P!V4'd\\VGRjxL 4pV#L 5izr?mcp_toolzmcp.types.ToolrUr4rA)rBs"rCrDrE^s$  + 7E  rGc V!VVPVPVPVPVPVP VP VP\VP4PR.4R7 #)z@Factory method to create a ProxyTool from a raw MCP tool schema.tags) r>rftitle description parametersr output_schemaiconsmetarp) rfrqrr inputSchemar outputSchemarurvr/rh)clsr>rns&&&rC from_mcp_toolProxyTool.from_mcp_tool]sm ).. ,,++ ,,"//..%hmm488D  rGc$V^8dQhRRRRRR/#)r= argumentsdict[str, Any]contextContext | NonerUr-rA)rBs"rCrDrEos(55!5 5  5rGc t"VP;'g VPp\RV 2RV4;_uu_4pVPRR4VP 4GRjxL pT;_uu_4GRjxL T;'g \ 4p\ V\4'd?VPVP3\\\,VP4^&Rp\VR4'dVPp\VR4'd(VP'd\!VP4p\VR4'dx\VP"R 4'd\VP"P$'d@VP"P&p V 'd"T;'g/pV P)R R 7VR &VP+W1VR 7GRjxL p RRR4GRjxL X P,'dI\/\\0P2P4V P6^,4P84h\;V P6V P<V PR7uuRRR4#ELEL LL +GRjxL 'giL;i +'giR#;i5i)z6Executes the tool by making a call through the client.z tools/call z tools/callfastmcp.provider.type ProxyProviderNrequest_contextrv experimentalis_taskT) exclude_nonezmodelcontextprotocol.io/task)rfr}rv)contentstructured_contentrv)r:rfr set_attributer^r( isinstanceStatefulProxyClientr_fastmcprlistr _proxy_rc_refhasattrrvdictrr task_metadata model_dump call_tool_mcpisErrorrmcptypes TextContentrtextr-structuredContent) rOr}r backend_namespanr]ctxrvreq_ctxrresults &&& rCrun ProxyTool.runos ))66TYY , (,      6 H++--Fvv.. f&9::++ @DcF$8$89!< /33 122!11Gw//GLLL#GLL1 88#G$8$8)DD#00888(/(<(<(J(J (#'::2D - 8 8d 8 K!!?@ &33% 4 ?vD~~~SYY%:%:FNN1?vvv    s9J8&J$!I>"J$4J 5J$8B,J %AJ J "J +.J J J  J$)J*J$A3J$3 J8>J$J$J J$J! J J! J! J$$ J5 / J8cV^8dQhRR/#r=rUr~rA)rBs"rCrDrE  ^ rGc J<\SV`4RRRVP/,#rrzfastmcp.proxy.backend_namerKget_span_attributesr:rOrPs&rCrProxyTool.get_span_attributes-w*, #_ ($*<*<0   rGrMN)__name__ __module__ __qualname____firstlineno____doc__r+r8__annotations__r:rLr^ri classmethodrzrr__static_attributes__ __classcell__rPs@rCr4r4Cs\H(k:K: $M:$..,,  "5n  rGr4ca]tRt^t$Rt]!RR7tR]R&RtR]R&Rt R ]R &RR/R V3R lllt R Rlt RV3Rllt ] RRl4tRRltRV3RlltRtV;t#) ProxyResourcezEA Resource that represents and reads a resource from a remote server.r5r6r+r8NResourceResult | None_cached_contentr9 _backend_uric V^8dQhRRRR/#)r=r>r?rrrA)rBs"rCrDProxyResource.__annotate__s / /& // /rGc @<\SV`!R/VBWnW nR#rI)rKrLrMr)rOr>rr@rPs&&$,rCrLProxyResource.__init__s! "6"-.rGcV^8dQhRR/#rTrA)rBs"rCrDrrVrGc "VP4p\P!V4'd\\VGRjxL 4pV#L 5irXrYr\s& rCr^ProxyResource._get_clientr`rac V^8dQhRRRR/#)r=r@rrUrrA)rBs"rCrDr,,3,=,rGc <VPR/4pRV9d.VPf /VCR\VP4/CpW!R&\SV`!R/VB#)z3Override to preserve _backend_uri when uri changes.reurirrA)rhrstrrrKrirjs&, rCriProxyResource.model_copysYHb) F?t008>>DHH >F%8 w!+F++rGc$V^8dQhRRRRRR/#)r=r>r? mcp_resourcezmcp.types.ResourcerUrrA)rBs"rCrDrs(  & )    rGc T!TVPVPVPVPVP;'gRVP VP \VP 4PR.4\RR7R7 #)zHFactory method to create a ProxyResource from a raw MCP resource schema. text/plainrpr5r6) r>rrfrqrr mime_typerurvrpr8) rrfrqrrmimeTyperurvr/rhr+)ryr>rs&&&rCfrom_mcp_resourceProxyResource.from_mcp_resources~)  ""$$$00"++;;|$$""%l&7&78<VP\VPVPVPR74KV\V\ 4'dRVP\\"P$!VP&4VPVPR74K\R \)V4 24h \+VR 7uuRRR4#ELGEL7EL!EL +GRjxL 'giEL,;i +'giR#;i5i) z1Read the resource content from the remote server.Nzresources/read zresources/read) resource_urirr)Remote server returned empty content for rrrvUnsupported content type: contents)rrrrrrr^ read_resourcerrrappendr%rrrvrbase64 b64decodeblobtyper&)rO backend_urirr]rritems& rCreadProxyResource.reads    +'' '''883txx= k] +  $      6 H++--Fvv%33K@@v#? }M /1Hd$899OO'$(II&*mm!% &:;;OO'$*$4$4TYY$?&*mm!%(*DT$ZL(QRR%("84K  .@vvv   s-H 0H  &G6G G6G G6G 2G 3G 7 G6G G6C3G6 H  G6G6G G6G3 G" G3 +G3 - G66 H  H cV^8dQhRR/#rrA)rBs"rCrDrrrGc J<\SV`4RRRVP/,#)rrzfastmcp.proxy.backend_uri)rKrrrs&rCr!ProxyResource.get_span_attributess-w*, #_ '):):0   rG)rrM)rrrrrr+r8rrrrLr^rirrrrrrrs@rCrrsqO(k:K:-1O*1#L*# /26 / /,,  (+5Z  rGrca]tRtRt$Rt]!RR7tR]R&RtR]R &R V3R llt R R lt RV3Rllt ] RRl4t RRRlltRV3RlltRtV;t#) ProxyTemplateizWA ResourceTemplate that represents and creates resources from a remote server template.r5r6r+r8Nr9_backend_uri_templatec V^8dQhRRRR/#r<rA)rBs"rCrDProxyTemplate.__annotate__rFrGc 4<\SV`!R/VBWnR#rIrJrNs&&,rCrLProxyTemplate.__init__rRrGcV^8dQhRR/#rTrA)rBs"rCrDr"rVrGc "VP4p\P!V4'd\\VGRjxL 4pV#L 5irXrYr\s& rCr^ProxyTemplate._get_client"r`rac V^8dQhRRRR/#)r=r@rrUrrA)rBs"rCrDr)rrGc <VPR/4pRV9d%VPf/VCRVP/CpW!R&\SV`!R/VB#)zEOverride to preserve _backend_uri_template when uri_template changes.re uri_templaterrA)rhrrrKrirjs&, rCriProxyTemplate.model_copy)sYHb) V #(B(B(JKK 79J9JKF%8 w!+F++rGc$V^8dQhRRRRRR/#)r=r>r? mcp_templatezmcp.types.ResourceTemplaterUrrA)rBs"rCrDr3s$  + ;U  rGc "T!TVPVPVPVPVP;'gRVP /VP \VP 4PR.4\RR7R7 #)zHFactory method to create a ProxyTemplate from a raw MCP template schema.rrpr5r6) r>rrfrqrrrrursrvrpr8) uriTemplaterfrqrrrrurvr/rhr+)ryr>rs&&&rCfrom_mcp_templateProxyTemplate.from_mcp_template2s )%11""$$$00"++;;|$$""%l&7&78<V P\V PV PV PR74KV\V \4'dRV P\\ P"!V P$4V PV PR74K\R\'V 4 24h \)V R7p \+VP,VVP.VP0VP2V ^,PVP4VP\7VP4P9R.4V R 7 #uuppiELELELEL +GRjxL 'giEL;i5i) zACreate a resource from the template by calling the remote server.)safeNrrrrrp) r>rrfrqrrrrurvrprrA)rrrBitemsr r^rrrrrr%rrrvrrrrrr&rrMrfrqrrrur/rh) rOrrrbackend_templatekvparameterized_urir]rrrcached_contents &&&& rCcreate_resourceProxyTemplate.create_resourceFs 55JJ9J9J,33 06 ?q%##? ''))66!//0ABBF6;7I' I I' I "I#I ' I'2I3 I'?FI'I'I I' I$ I I$ I$  I'cV^8dQhRR/#rrA)rBs"rCrDrrrGc J<\SV`4RRRVP/,#)rrz"fastmcp.proxy.backend_uri_template)rKrrrs&rCr!ProxyTemplate.get_span_attributess-w*, #_ 0$2L2L0   rGrr)rrrrrr+r8rrrLr^rirrrrrrrs@rCrrs]a(k:K:(,:,..,,  &< |  rGrca]tRtRt$Rt]!RR7tR]R&RtR]R &R V3R llt R R lt RV3Rllt ] RRl4t RRltRV3RlltRtV;t#) ProxyPromptizCA Prompt that represents and renders a prompt from a remote server.r5r6r+r8Nr9r:cV^8dQhRR/#r=r>r?rA)rBs"rCrDProxyPrompt.__annotate__s..~.rGc 4<\SV`!R/VBWnR#rIrJrNs&&,rCrLProxyPrompt.__init__rRrGcV^8dQhRR/#rTrA)rBs"rCrDrrVrGc "VP4p\P!V4'd\\VGRjxL 4pV#L 5irXrYr\s& rCr^ProxyPrompt._get_clientr`rac V^8dQhRRRR/#)r=r@rrUr rA)rBs"rCrDrs,,3,;,rGc <VPR/4pRV9d%VPf/VCRVP/CpW!R&\SV`!R/VB#rdrgrjs&, rCriProxyPrompt.model_copyrlrGc$V^8dQhRRRRRR/#)r=r>r? mcp_promptzmcp.types.PromptrUr rA)rBs"rCrDrs$  + 9I  rGc VP;'g.Uu.uF9p\VPVPVP;'gRR7NK; ppV!VVPVP VPVVP VP\VP4PR.4\RR7R7 #uupi)zDFactory method to create a ProxyPrompt from a raw MCP prompt schema.F)rfrrrequiredrpr5r6) r>rfrqrrr}rurvrpr8) r}r"rfrrrrqrurvr/rhr+)ryr>rargr}s&&& rCfrom_mcp_promptProxyPrompt.from_mcp_prompts"++11r1  2 XXOO..  2  )"""..""%joo6::62F" 4   s 2C  C c V^8dQhRRRR/#)r=r}r~rUr!rA)rBs"rCrDrsnrGc "VP;'g VPp\RV 2RV4;_uu_4pVPRR4VP 4GRjxL pT;_uu_4GRjxL VP W!4GRjxL pRRR4GRjxL XP Uu.uF$p\VPVPR7NK& pp\VVPVPR7uuRRR4#LLL~Lp +GRjxL 'giL;iuupi +'giR#;i5i)z6Render the prompt by making a call through the client.z prompts/get z prompts/getrrN)rrole)messagesrrrv) r:rfrrr^ get_promptr"rrr!r!rrrv)rOr}rrr]rmr"s&& rCrenderProxyPrompt.renders))66TYY <. )=,     6 H++--Fvv%00IIv BHAPA 7  !"..[[  .Ivvv    s9E&D1!D"D14D 5D18D D D  D1DD10*D,#D1= ED1 D1 D D1D) D D) "D) $ D11 E < EcV^8dQhRR/#rrA)rBs"rCrDrrrGc J<\SV`4RRRVP/,#rrrs&rCrProxyPrompt.get_span_attributesrrGr)rrrrrr+r8rr:rLr^rirrr%rrrrs@rCr r s[M(k:K: $M:$..,,  0,  rGr cza]tRtRtRtRV3RlltRRltRRltR R ltR R lt R Rlt RRlt Rt V;t #)riaProvider that proxies to a remote MCP server via a client factory. This provider fetches components from a remote server and returns Proxy* component instances that forward execution to the remote server. All components returned by this provider have task_config.mode="forbidden" because tasks cannot be executed through a proxy. Example: ```python from fastmcp import FastMCP from fastmcp.server.providers.proxy import ProxyProvider, ProxyClient # Create a proxy provider for a remote server proxy = ProxyProvider(lambda: ProxyClient("http://localhost:8000/mcp")) mcp = FastMCP("Proxy Server") mcp.add_provider(proxy) # Can also add with namespace mcp.add_provider(proxy.with_namespace("remote")) ``` cV^8dQhRR/#rrA)rBs"rCrDProxyProvider.__annotate__s - -& -rGc 0<\SV`4WnR#)aInitialize a ProxyProvider. Args: 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. N)rKrLr>)rOr>rPs&&rCrLProxyProvider.__init__s ,rGcV^8dQhRR/#rTrA)rBs"rCrDr,rVrGc "VP4p\P!V4'd\\VGRjxL 4pV#L 5irX)r>rZr[rrr\s& rCr^ProxyProvider._get_clients<$$&   v & &&,/F #/racV^8dQhRR/#)r=rUzSequence[Tool]rA)rBs"rCrDr,s  > rGc "VP4GRjxL pT;_uu_4GRjxL VP4GRjxL pVUu.uF#p\PVPV4NK% upuuRRR4GRjxL #LqL`LJuupiL +GRjxL 'giR#;i \ d-pTP P\8Xd.uRp?#hRp?ii;i5i)z&List all tools from the remote server.N) r^ list_toolsr4rzr>rerrorcoder)rOr] mcp_toolstes& rC _list_toolsProxyProvider._list_toolss ++--Fvv"("3"3"55 MVMVI++D,?,?CYvv.5vvv  ww||//  C-B3B B3B B3BB B )B4B6 B3BB3C- B3 B3 BBB3B0 B B0 (B0 *B3.C-0B33 C*> C%C*C-$C%%C**C-cV^8dQhRR/#)r=rUzSequence[Resource]rA)rBs"rCrDr,$s  '9 rGc "VP4GRjxL pT;_uu_4GRjxL VP4GRjxL pVUu.uF#p\PVPV4NK% upuuRRR4GRjxL #LqL`LJuupiL +GRjxL 'giR#;i \ d-pTP P\8Xd.uRp?#hRp?ii;i5i)z*List all resources from the remote server.N) r^list_resourcesrrr>rr5r6r)rOr] mcp_resourcesrr9s& rC_list_resourcesProxyProvider._list_resources$s ++--Fvv&,&;&;&= = +*"33D4G4GK*vv. =vvv  ww||//  r<cV^8dQhRR/#)r=rUzSequence[ResourceTemplate]rA)rBs"rCrDr,7s  0J rGc "VP4GRjxL pT;_uu_4GRjxL VP4GRjxL pVUu.uF#p\PVPV4NK% upuuRRR4GRjxL #LqL`LJuupiL +GRjxL 'giR#;i \ d-pTP P\8Xd.uRp?#hRp?ii;i5i)z3List all resource templates from the remote server.N) r^list_resource_templatesrrr>rr5r6r)rOr] mcp_templatesr8r9s& rC_list_resource_templates&ProxyProvider._list_resource_templates7s ++--Fvv&,&D&D&F F +*"33D4G4GK*vv. Fvvv  ww||//  r<cV^8dQhRR/#)r=rUzSequence[Prompt]rA)rBs"rCrDr,Js  %5 rGc "VP4GRjxL pT;_uu_4GRjxL VP4GRjxL pVUu.uF#p\PVPV4NK% upuuRRR4GRjxL #LqL`LJuupiL +GRjxL 'giR#;i \ d-pTP P\8Xd.uRp?#hRp?ii;i5i)z(List all prompts from the remote server.N) r^ list_promptsr rr>rr5r6r)rOr] mcp_promptspr9s& rC _list_promptsProxyProvider._list_promptsJs ++--Fvv$*$7$7$99 )( //0C0CQG(vv.9vvv  ww||//  r<cV^8dQhRR/#)r=rUzSequence[FastMCPComponent]rA)rBs"rCrDr,]s!;rGc ".#5i)aReturn empty list since proxy components don't support tasks. Override the base implementation to avoid calling list_tools() during server lifespan initialization, which would open the client before any context is set. All Proxy* components have task_config.mode="forbidden". rA)rOs&rC get_tasksProxyProvider.get_tasks]s  r>)rrrrrrLr^r:rBrHrOrSrrrs@rCrrs50 - - $ & & &rGrc V^8dQhRRRR/#)r=targetz}Client[ClientTransportT] | ClientTransport | FastMCP[Any] | FastMCP1Server | AnyUrl | Path | MCPConfig | dict[str, Any] | strrUr?rA)rBs"rCrDrDos -$-$ -$-$rGcaa\V\4'dDVoSP4'd!\P R4RV3RllpV#RV3RllpV#\ \ \V44oRV3RllpV#)aJCreate a client factory from the given target. Internal helper that handles the session strategy based on the target type: - Connected Client: reuses existing session (with warning about context mixing) - Disconnected Client: creates fresh sessions per request - Other targets: creates ProxyClient and fresh sessions per request zProxy detected connected client - reusing existing session for all requests. This may cause context mixing in concurrent scenarios.cV^8dQhRR/#rTrA)rBs"rCrD,_create_client_factory..__annotate__s  & rGc<S#rrAr]srCreuse_client_factory4_create_client_factory..reuse_client_factorys rGcV^8dQhRR/#rTrA)rBs"rCrDr[s $ $& $rGc$<SP4#rnewr]srCfresh_client_factory4_create_client_factory..fresh_client_factoryszz|#rGcV^8dQhRR/#rTrA)rBs"rCrDr[s % %f %rGc$<SP4#rrb) base_clientsrCproxy_client_factory4_create_client_factory..proxy_client_factorys??$ $rG)rr is_connectedloggerinfo ProxyClientrr)rXr^rdrirhr]s& @@rC_create_client_factoryroos(&&!!    KKI    ( ' $ $( '"$sF"34  % %$#rGc2a]tRtRtRtRV3RlltRtV;t#) FastMCPProxyiaA FastMCP server that acts as a proxy to a remote MCP-compliant server. This is a convenience wrapper that creates a FastMCP server with a ProxyProvider. For more control, use FastMCP with add_provider(ProxyProvider(...)). Example: ```python from fastmcp.server import create_proxy from fastmcp.server.providers.proxy import FastMCPProxy, ProxyClient # Create a proxy server using create_proxy (recommended) proxy = create_proxy("http://localhost:8000/mcp") # Or use FastMCPProxy directly with explicit client factory proxy = FastMCPProxy(client_factory=lambda: ProxyClient("http://localhost:8000/mcp")) ``` cV^8dQhRR/#rrA)rBs"rCrDFastMCPProxy.__annotate__s$$'$rGc l<\SV`!R/VBWn\V4pVP V4R#)aInitialize the proxy server. FastMCPProxy requires explicit session management via client_factory. Use create_proxy() for convenience with automatic session strategy. Args: 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. NrA)rKrLr>r add_provider)rOr>r@providerrPs&$, rCrLFastMCPProxy.__init__s3" "6",*>: (#rGrVrrrrrrLrrrs@rCrqrqs$$$rGrqc V^8dQhRRRR/#)r=r/RequestContext[ClientSession, LifespanContextT]rUrrA)rBs"rCrDrDs"" <""rGcR"\4pVP4GRjxL #L5i)zKForward list roots request from remote server to proxy's connected clients.N)r( list_roots)rrs& rCdefault_proxy_roots_handlerr}s! -C! !! !s '%'c(V^8dQhRRRRRRRR/#) r=r"zlist[mcp.types.SamplingMessage]rz$mcp.types.CreateMessageRequestParamsrrzrUzmcp.types.CreateMessageResultrA)rBs"rCrDrDs0- 0=# rGcn"\4pVP\V4VPVPVP VP R7GRjxL p\PPRVP;'gRR7p\PPRRVR7#L[5i) zIForward sampling request from remote server to proxy's connected clients.) system_prompt temperature max_tokensmodel_preferencesNrr)rr assistantzfastmcp-client)r!modelr) r(sampler systemPromptr maxTokensmodelPreferencesrrrrCreateMessageResult)r"rrrrrs&&& rCdefault_proxy_sampling_handlerrs -C:: X))&&## 11 Fii##fkk6G6GR#HG 99 ( (  ) sAB5B30B5 +B5c ,V^8dQhRRRRRRRRR R /#) r=messager response_typerrzmcp.types.ElicitRequestParamsrrzrUrrA)rBs"rCrDrDsAFF FF *F= F  FrGc"\4p\V\4'd VPMRRR//pVPP VVVP R7GRjxL p\VPVPR7#L%5i)zLForward elicitation request from remote server to proxy's connected clients.robject properties)rrequestedSchemarelated_request_idN)actionr) r(rrrsessionelicit request_idrrr)rrrrrrequested_schemars&&&& rC!default_proxy_elicitation_handlerrs -C f5 6 6 h b 1 ;;%%(>>&F v}}fnn EE sAB B!&Bc V^8dQhRRRR/#)r=rrrUNonerA)rBs"rCrDrDsUUZUDUrGc"\4pVPPR4pVPPR4pVPW PVP VR7GRjxL R#L5i)zIForward log notification from remote server to proxy's connected clients.msgextra)level logger_namerN)r(datarhlogrrl)rrrrs& rCdefault_proxy_log_handlerrsT -C ,,  5 !C LL  W %E ''#]]e' TTTsA,A7.A5/A7c(V^8dQhRRRRRRRR/#) r=progressfloattotalz float | Nonerr9rUrrA)rBs"rCrDrDs0888 88 8rGcZ"\4pVPWV4GRjxL R#L5i)zNForward progress notification from remote server to proxy's connected clients.N)r(report_progress)rrrrs&&& rCdefault_proxy_progress_handlerrs$ -C  hw 777s +)+c V^8dQhRRRR/#)r=rc_ref list[Any]rUrrA)rBs"rCrDrDs$3$3 $3 $3rGc^RIHpHpV^,pVfR#VwrE\P!4pTPTPJdZTPTP8wd=\P !T4T!4pTeTP T!T44R#R#R#R# \ d=\P !T4T!4pTeTP T!T44R#i;i)uSet the ``request_ctx`` and ``_current_context`` ContextVars from stashed values. Called at the start of proxy handler invocations in ``StatefulProxyClient`` to fix stale ContextVars in the receive-loop task. Only overrides when the ContextVar is genuinely stale (same session, different request_id) to avoid corrupting the concurrent case where multiple sessions share the same ref via ``copy.copy``. We stash a ``(RequestContext, weakref[FastMCP])`` tuple — never a ``Context`` instance — because ``Context`` properties are themselves ContextVar-dependent and would resolve stale values in the receive loop. Instead we construct a fresh ``Context`` here after restoring ``request_ctx``, so its property accesses read the correct values. )r'_current_contextN) fastmcp.server.contextr'rr rh LookupErrorsetrr)rr'rstashedrc fastmcp_ref current_rcfastmcps& rC_restore_request_contextrs"AQiGOB __& RZZ'J,A,AR]],R-    !1 2 -S' -    !1 2 sB''AC.-C.c$V^8dQhRRRRRR/#)r=handlerrrrrUrA)rBs"rCrDrDAs!  X y X rGcaaRVV3RllpV#)zWrap a proxy handler to restore request_ctx before delegating. The wrapper is a plain ``async def`` so it passes ``inspect.isfunction()`` checks in handler registration paths (e.g., ``create_roots_callback``). c$V^8dQhRRRRRR/#)r=argsrr@rUrA)rBs"rCrD-_make_restoring_handler..__annotate__Is!..S.C.C.rGcF<"\S4S!V/VBGRjxL #L5ir)r)rr@rrs*,rCwrapper(_make_restoring_handler..wrapperIs$ (d-f----s !!rA)rrrsff rC_make_restoring_handlerrAs.. NrGc2a]tRtRtRtRV3RlltRtV;t#)rniPzA 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. cV^8dQhRR/#)r= transportzcClientTransportT | FastMCP[Any] | FastMCP1Server | AnyUrl | Path | MCPConfig | dict[str, Any] | strrA)rBs"rCrDProxyClient.__annotate__Vs>>>rGc <RV9dVP4VR&RV9d \VR&RV9d \VR&RV9d \VR&RV9d \VR&RV9d \ VR&\ SV`!R/VRV/,BR#) rfrootssampling_handlerelicitation_handler log_handlerprogress_handlerrNrA) generate_namer}rrrrrKrL)rOrr@rPs&&,rCrLProxyClient.__init__Vs  !//1F6N & 9F7O V +)GF% &  .,MF( )  &$=F= ! V +)GF% & =6[)$<<=rGrArxrs@rCrnrnPs >>rGrnc\a]tRtRt$RtR]R&RV3RlltRRltR tR R lt R t V;t #) riqaA proxy client that provides a stateful client factory for the proxy server. The stateful proxy client bound its copy to the server session. And it will be disconnected when the session is exited. This is useful to proxy a stateful mcp server such as the Playwright MCP server. Note that it is essential to ensure that the proxy server itself is also stateful. Because session reuse means the receive-loop task inherits a stale ``request_ctx`` ContextVar snapshot, the default proxy handlers are replaced with versions that restore the ContextVar before forwarding. ``ProxyTool.run`` stashes the current ``RequestContext`` in ``_proxy_rc_ref`` before each backend call, and the handlers consult it to detect (and correct) staleness. rrc V^8dQhRRRR/#)r=rrr@rA)rBs"rCrD StatefulProxyClient.__annotate__sIIcISIrGc <R.VnR\3R\3R\3R\3R\ 33F$wr4W29gK \ W@P4W#&K& \SV` !V/VB/Vn R#)Nrrrrr) rr}rrrrrrKrL_caches)rOrr@key default_fnrPs&*, rCrLStatefulProxyClient.__init__s#V 1 2 !? @ "$E F 5 6 !? @  OC 5jBTBTU   $)&)FH rGcV^8dQhRR/#)r=rUrrA)rBs"rCrDrs   rGc "R#5i)zjThe stateful proxy client will be forced disconnected when the session is exited. So we do nothing here. NrA)rOexc_type exc_value tracebacks&&&&rC __aexit__StatefulProxyClient.__aexit__srUc "VP'd9VPP4wrVPRR7GRjxL KJR#L5i)z3Clear all cached clients and force disconnect them.TforceN)rpopitem _disconnect)rO_caches& rCclearStatefulProxyClient.clearsAlll||++-HA##$#/ / / /sA1AA AcV^8dQhRR/#)r=rUzClient[ClientTransportT]rA)rBs"rCrDrs6rGc ,aaa\4PoSPPSR4oSf]SP 4o\ P S RS 24SSPS&VVV3RlpSPPV4S#)zCreate 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<"SPPS4\PS R24SP RR7GRjxL R#L5i)z will be disconnectTrN)rpoprldebugr) proxy_clientrOrsrC_on_session_exit:StatefulProxyClient.new_stateful.._on_session_exitsC   ) ~-@AB"..T.:::sA A A A) r(rrrhrcrlr _exit_stackpush_async_callback)rOrrrsf @@rC new_stateful StatefulProxyClient.new_statefuls -''||''6  88:L LLL>wi@ A$0DLL ! ;    3 34D ErG)rr) rrrrrrrLrrrrrrs@rCrrqs02II" 0 rGr)gr __future__rrrZcollections.abcrrrtypingrrr urllib.parser mcp.typesrr mcp.client.sessionr mcp.server.lowlevel.serverr mcp.shared.contextr rmcp.shared.exceptionsrrrrrpydantic.networksrfastmcp.client.clientrrfastmcp.client.elicitationrfastmcp.client.loggingrfastmcp.client.rootsrfastmcp.client.telemetryrfastmcp.client.transportsrfastmcp.exceptionsrrfastmcp.mcp_configrfastmcp.promptsrr r!fastmcp.prompts.promptr"fastmcp.resourcesr#r$fastmcp.resources.resourcer%r&rr'fastmcp.server.dependenciesr(fastmcp.server.providers.baser)fastmcp.server.serverr*fastmcp.server.tasks.configr+fastmcp.tools.toolr,r-fastmcp.utilities.componentsr.r/fastmcp.utilities.loggingr0pathlibr1r2rrlr?r4rrr rrorqr}rrrrrrrnrrArGrCrsg# 99++,2?* %83-*067(9918F*32)2/O09 H "f*%Yv5F1F(GGg g Th Hh Vp $p fM &M jDHD^-$j'$7'$^".F,U8$3N >&)*>BM+&67MrG