~h~dZddlmZddlZddlZddlZddlZddlmZm Z m Z ddl m Z m Z mZddlmZddlmZddlmZmZmZmZmZddlZddlZddlZdd lmZdd lmZm Z dd lm!Z"dd l#m$Z$dd l%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+ddl%m,Z-ddl%m.Z/ddl%m0Z1ddl%m2Z3ddl4m5Z5ddl6m7Z7ddl8m9Z9ddl:m;Z;ddlZ>ddl?Z?ddl@Z?ddlAmBZBmCZCddlDm,Z,mEZEddlFmGZGddlHm.Z.mIZIddlJm0Z0ddlKmLZLddlMmNZNddlOmPZPmQZQmRZRddlSmTZTddlUmVZVdd lWmXZXm2Z2dd!lYmZZZdd"l[m\Z\dd#l]m^Z^dd$l_m`Z`er(dd%lambZbdd&lcmdZdmeZedd'lfmgZhdd(lfmiZimjZjdd)lfmkZldd*lmmnZne^eoZped+Zqejd,Zsed6d-Zt d7d.ZuGd/d0eeZvGd1d2Zw d8 d9d3Zx d8 d9d4Zy d8 d:d5Zzy);z5FastMCP - A more ergonomic interface for MCP servers.) annotationsN) AsyncIterator AwaitableCallable)AbstractAsyncContextManagerAsyncExitStackasynccontextmanager)partial)Path) TYPE_CHECKINGAnyGenericLiteraloverload)ReadResourceContents)LifespanResultTNotificationOptions)Server) stdio_server) AnyFunctionEmbeddedResourceGetPromptResult ImageContent TextContentToolAnnotations)Prompt)Resource)ResourceTemplate)Tool)AnyUrl) Middleware)Request)Response) BaseRouteRoute) DisabledError NotFoundError)r PromptManager)FunctionPrompt)rResourceManager) OAuthProvider)EnvBearerAuthProvider)StarletteWithLifespancreate_sse_appcreate_streamable_http_app)Settings) ToolManager) FunctionToolr) TimedCache)FastMCPComponent) get_logger) MCPConfigClient)ClientTransportClientTransportT) ComponentFn)FastMCPOpenAPIRouteMap) RouteMapFn FastMCPProxy)warnerrorreplaceignorez^([^:]+://)(.*?)$cKiyw)zDefault lifespan context manager that does nothing. Args: server: The server instance this lifespan is managing Returns: An empty context object N)servers Q/opt/mcp/mcp-sentiment/venv/lib/python3.12/site-packages/fastmcp/server/server.pydefault_lifespanrIQs  Hs c*tdfd }|S)NcKt4d{}|jd{}|dddd{y7977 #1d{7swYyxYwwN)renter_async_context)sstackcontextapplifespans rHwrapz_lifespan_wrapper..wrapfs^!#  u!55hsmDDGM   D    sSA'A A'AA A A'AA'AA'A$A A$ A')rNzMCPServer[LifespanResultT]returnzAsyncIterator[LifespanResultT])r )rQrRrSs`` rH_lifespan_wrapperrU^s Kc eZdZ d= d>dZd?dZ d@dZed?dZedAdZ dB dCdZ dB dCdZ dDd Z dEd Z dFd Z dGd ZdHd ZdIdZdJdZdKdZdLdZ dM dNdZdOdZdPdZdQdZdRdZ dSdZ dSdZdTdZdTdZ dB dUdZ dB dUdZdVdZdWdZ e!ddddddd dXd Z"e! dBddddddd dYd!Z" dBddddddd dZd"Z"dBd[d#Z#dBd\d$Z$ d] d^d%Z%dddddd& d_d'Z&d`d(Z'e!ddddd) dad*Z(e! dBddddd) dbd+Z( dBddddd) dcd,Z(dDd-Z) dd ded.Z* df dgd/Z+ dh did0Z, dj dkd1Z- dl dmd2Z. dn dod3Z/ dBdddd4 dpd5Z0dqd6Z1 dh drd7Z2e3 dn dsd8Z4e3 dt dud9Z5e3 dvd:Z6e3 dwd;Z7 dxd<Z8y)yFastMCPNc \| xstjj|_tt j |xsd|_i|_g|_t|| |_ t|| |_ t| | |_||_|d|_t"}nd|_t%t&|xsd|t)|||_|'tjj,d k(r t/}||_| rI| D]D}t3|t4s!t5j6||j }|j9|F||_||_|j?| xstjj@|_!|jE||||||||| y) Nr)seconds) expiration)duplicate_behaviormask_error_detailsFTrX)name instructionsrR bearer_env) serializer) log_leveldebughostportsse_path message_pathstreamable_http_path json_responsestateless_http)#fastmcpsettingsresource_prefix_formatr3datetime timedelta_cache_mounted_servers_additional_http_routesr1 _tool_managerr*_resource_managerr(_prompt_manager_tool_serializer _has_lifespanrI MCPServerrrU _mcp_serverdefault_auth_providerr,auth isinstancer from_functionadd_tool include_tags exclude_tags_setup_handlersserver_dependencies dependencies_handle_deprecated_settings)selfr^r_r{rRtool_serializercache_expiration_secondson_duplicate_toolson_duplicate_resourceson_duplicate_promptsrmr]toolsrrrrbrcrdrerfrgrhrirjtools rH__init__zFastMCP.__init__psN # Mg&6&6&M&M #!))2J2OaP  ;=8:$(11 "151"  -31 !0  !&D 'H!%D $_5"%&tX6  sserstreamable-httpzUnknown transport: >rr transportrF) ValueErrorrun_stdio_asyncrun_http_asyncrrtransport_kwargss rH run_asynczFastMCP.run_asyncs  I ? ?29+>? ?  &$&&:)9: : : 4 4%$%%N N=MN N N29+>? ? ; Ns!1A,A( A,A*A,*A,c Xtjt|j|fi|y)zRun the FastMCP server. Note this is a synchronous function. Args: transport: Transport protocol to use ("stdio", "sse", or "streamable-http") N)anyiorunr rrs rHrz FastMCP.runs!  '$..)H7GHIrVcP|jj|j|jj|j|jj |j |jj|j|jj|j|jj|j|jj|jy)z"Set up core MCP protocol handlers.N)ry list_tools_mcp_list_toolslist_resources_mcp_list_resourceslist_resource_templates_mcp_list_resource_templates list_prompts_mcp_list_prompts call_tool_mcp_call_tool read_resource_mcp_read_resource get_prompt_mcp_get_promptrs rHrzFastMCP._setup_handlers*s%##%d&:&:;)'')$*B*BC200243T3TU'%%'(>(>?$""$T%8%89(&&()@)@A%##%d&:&:;rVcK|jjdx}|jjuri}|jj D]/\}} |j d{}|j |1|j |jj |jjd||S7^#t$r%}tjd|d|Yd}~d}~wwxYww)z4Get all registered tools, indexed by registered key.rNz)Failed to get tools from mounted server '': ) rpget NOT_FOUNDrqitems get_toolsupdate Exceptionloggerwarningrsset)rrprefixrG server_toolses rHrzFastMCP.get_tools4s[[__W- -E$++2G2G G%'E"&"7"7"="="? )/)9)9);#;LLL.  LL++557 8 KKOOGU + $< NNCF83qcR CAC>C ,C -C A C> C  C;C61C>6C;;C>clK|jd{}||vrtd|||S7w)NUnknown tool: )rr')rkeyrs rHget_toolzFastMCP.get_toolEs>nn&& e . 67 7Sz' 424cK|jjdx}|jjuri}|jj D]/\}} |j d{}|j |1|j |jj |jjd||S7^#t$r%}tjd|d|Yd}~d}~wwxYww)z8Get all registered resources, indexed by registered key. resourcesNz-Failed to get resources from mounted server 'r) rprrrqr get_resourcesrrrrrtr)rrrrGserver_resourcesrs rHrzFastMCP.get_resourcesKs5 5I$++:O:O O-/I"&"7"7"="="? -3-A-A-C'C$$$%56    T33AAC D KKOOK 3(D NNGxsSTRUV rclK|jd{}||vrtd|||S7w)NUnknown resource: )rr')rrrs rH get_resourcezFastMCP.get_resource\sA,,.. i "4SE :; ;~/rcK|jjdx}|jjuri}|jj D]/\}} |j d{}|j |1|j |jj|jjd||S7^#t$r%}tjd|d|Yd}~d}~wwxYww)zAGet all registered resource templates, indexed by registered key.resource_templatesNz6Failed to get resource templates from mounted server 'r) rprrrqrget_resource_templatesrrrrrt get_templatesr)r templatesrrGserver_templatesrs rHrzFastMCP.get_resource_templatesbs)=> >I [[ " " #68I"&"7"7"="="? -3-J-J-L'L$$$%56    T33AAC D KKOO0) <(M NN"83qc+ rclK|jd{}||vrtd|||S7w)NzUnknown resource template: )rr')rrrs rHget_resource_templatezFastMCP.get_resource_templatevsA5577 i "=cU CD D~8rcK|jjdx}|jjuri}|jj D]/\}} |j d{}|j |1|j |jj |jjd||S7^#t$r%}tjd|d|Yd}~d}~wwxYww)z- List all available prompts. promptsNz+Failed to get prompts from mounted server 'r) rprrrqr get_promptsrrrrrur)rrrrGserver_promptsrs rHrzFastMCP.get_prompts|s{{y1 1Gdkk6K6K K)+G"&"7"7"="="? +1+=+=+?%?NNN>2  NN4//;;= > KKOOIw /&@ NNEfXSQRPST rclK|jd{}||vrtd|||S7w)NUnknown prompt: )rr')rrrs rHrzFastMCP.get_promptsA((** g "23% 89 9s|+rc, dfd }|S)a Decorator to register a custom HTTP route on the FastMCP server. Allows adding arbitrary HTTP endpoints outside the standard MCP protocol, which can be useful for OAuth callbacks, health checks, or admin APIs. The handler function must be an async function that accepts a Starlette Request and returns a Response. Args: path: URL path for the route (e.g., "/oauth/callback") methods: List of HTTP methods to support (e.g., ["GET", "POST"]) name: Optional name for the route (to reference this route with Starlette's reverse URL lookup feature) include_in_schema: Whether to include in OpenAPI schema, defaults to True Example: @server.custom_route("/health", methods=["GET"]) async def health_check(request: Request) -> Response: return JSONResponse({"status": "ok"}) c Zjjt||S)N)endpointmethodsr^include_in_schema)rrappendr%)fnrrr^pathrs rH decoratorz'FastMCP.custom_route..decorators7  ( ( / /#&7  IrV)r(Callable[[Request], Awaitable[Response]]rTrrF)rrrr^rrs````` rH custom_routezFastMCP.custom_routes%8 8  5  rVcK|jd{}g}|jD]8\}}|j|s|j|j |:|S7Sw)zh List all available tools, in the format expected by the low-level MCP server. Nr^)rr_should_enable_componentr to_mcp_tool)rr mcp_toolsrrs rHrzFastMCP._mcp_list_toolssl nn&&#%  =IC,,T2  !1!1s!1!;< ='A,A*-A,&A,cK|jd{}g}|jD]8\}}|j|s|j|j |:|S7Sw)zl List all available resources, in the format expected by the low-level MCP server. N)uri)rrrrto_mcp_resource)rr mcp_resourcesrresources rHrzFastMCP._mcp_list_resourcessq ,,.. +- &__. HMC,,X6$$X%=%=#%=%FG H /rcK|jd{}g}|jD]8\}}|j|s|j|j |:|S7Sw)zu List all available resource templates, in the format expected by the low-level MCP server. N) uriTemplate)rrrrto_mcp_template)rr mcp_templatesrtemplates rHrz$FastMCP._mcp_list_resource_templatessq 5577 35 &__. PMC,,X6$$X%=%=#%=%NO P 8rcK|jd{}g}|jD]8\}}|j|s|j|j |:|S7Sw)zj List all available prompts, in the format expected by the low-level MCP server. Nr)rrrr to_mcp_prompt)rr mcp_promptsrprompts rHrzFastMCP._mcp_list_promptssp ((**') "==? CKC,,V4""6#7#7S#7#AB C +rcTKtjd||tjjj |5 |j ||d{cdddS7 #t$rtd|t$rtd|wxYw#1swYyxYww)aM Handle MCP 'callTool' requests. Delegates to _call_tool, which should be overridden by FastMCP subclasses. Args: key: The name of the tool to call arguments: Arguments to pass to the tool Returns: List of MCP Content objects containing the tool results zCall tool: %s with %srkNr) rrcrkrGrPContext _call_toolr&r')rr argumentss rHrzFastMCP._mcp_call_tools  ,c9=^^ # # + +D + 9 < <!__S)<< < <<  <#nSE$:;;  <#nSE$:;; <  < ??!FFKs;:D1D+A D1D- AD18D1D/D1-D1/D1cTKtjd||tjjj |5 |j ||d{cdddS7 #t$rtd|t$rtd|wxYw#1swYyxYww)z Handle MCP 'getPrompt' requests. Delegates to _get_prompt, which should be overridden by FastMCP subclasses. Get prompt: %s with %srNr) rrcrkrGrPr  _get_promptr&r')rr^r s rHrzFastMCP._mcp_get_prompt[s  -tY? ^^ # # + +D + 9 ? ?!--dI>> ? ?>  ?#&6tf$=>>  ?#&6tf$=>> ?  ? ?r cKtjd|||jj|r_|jj |}|j |st d|d|jj||d{S|jjD]J}|j|s|j|}|jj||d{cStd|7y7w)zHandle MCP 'getPrompt' requests. Args: name: The name of the prompt to render arguments: Arguments to pass to the prompt Returns: GetPromptResult containing the rendered prompt messages rzPrompt rNr)rrcru has_promptrrr& render_promptrqr match_promptstrip_prompt_prefixrGrr')rr^r rrG prompt_names rHr zFastMCP._get_promptos  -tY?    * *4 0))44T:F008#gdX\$BCC--;;D)LL L++224 SF""4($88> #]]::; RRR S .tf566M Ss*B D D 2D 0D 3D 4D  D cn|jj||jjy)a Add a tool to the server. The tool function can optionally request a Context object by adding a parameter with the Context type annotation. See the @tool decorator for examples. Args: tool: The Tool instance to register N)rsr~rpclear)rrs rHr~zFastMCP.add_tools( ##D) rVcn|jj||jjy)zRemove a tool from the server. Args: name: The name of the tool to remove Raises: NotFoundError: If the tool is not found N)rs remove_toolrpr()rr^s rHr*zFastMCP.remove_tools( &&t, rVr^ descriptiontagsr exclude_argsenabledcyrLrFr name_or_fnr^r,r-rr.r/s rHrz FastMCP.toolsrVcyrLrFr1s rHrz FastMCP.tools14rVc t|tr tdi|}t|trt t j dt j|r>|}|} tj|| |||||j|} |j| | St|tr|td|d|d|} n||} ntdt|t|j | |||||S) aDecorator to register a tool. Tools can optionally request a Context object by adding a parameter with the Context type annotation. The context provides access to MCP capabilities like logging, progress reporting, and resource access. This decorator supports multiple calling patterns: - @server.tool (without parentheses) - @server.tool (with empty parentheses) - @server.tool("custom_name") (with name as first argument) - @server.tool(name="custom_name") (with name as keyword argument) - server.tool(function, name="custom_name") (direct function call) Args: name_or_fn: Either a function (when used as @tool), a string name, or None name: Optional name for the tool (keyword-only, alternative to name_or_fn) description: Optional description of what the tool does tags: Optional set of tags for categorizing the tool annotations: Optional annotations about the tool's behavior (e.g. {"is_async": True}) exclude_args: Optional list of argument names to exclude from the tool schema enabled: Optional boolean to enable or disable the tool Example: @server.tool def my_tool(x: int) -> str: return str(x) @server.tool def my_tool(x: int) -> str: return str(x) @server.tool("custom_name") def my_tool(x: int) -> str: return str(x) @server.tool(name="custom_name") def my_tool(x: int) -> str: return str(x) # Direct function call server.tool(my_function, name="custom_name") aA To decorate a classmethod, first define the method and then call tool() directly on the method instead of using it as a decorator. See https://gofastmcp.com/patterns/decorating-methods for examples and more information. )r^r,r-rr.rar/zXCannot specify both a name as first argument and as keyword argument. Use either @tool('z') or @tool(name=' '), not both.zAFirst argument to @tool must be a function, string, or None, got r+rF)r|dictr classmethodrinspectcleandoc isroutinerr}rvr~r TypeErrorrr r) rr2r^r,r-rr.r/r tool_namers rHrz FastMCP.tools4j k4 ()8K8K j+ .       Z (BI%%'')00 D MM$ K  C ())3 4FtfM[#I  ISTXYcTdSef   II##%  rVcr|jj|||jjy)zfAdd a resource to the server. Args: resource: A Resource instance to add rN)rt add_resourcerpr()rrrs rHr?zFastMCP.add_resource2s- ++H#+> rVc>|jj||y)zwAdd a resource template to the server. Args: template: A ResourceTemplate instance to add r>N)rt add_template)rrrs rHrAzFastMCP.add_template<s ++H#+>rVctjdtd|jj |||||||j j y)a;Add a resource or template to the server from a function. If the URI contains parameters (e.g. "resource://{param}") or the function has parameters, it will be registered as a template resource. Args: fn: The function to register as a resource uri: The URI for the resource name: Optional name for the resource description: Optional description of the resource mime_type: Optional MIME type for the resource tags: Optional set of tags for categorizing the resource zMThe add_resource_fn method is deprecated. Use the resource decorator instead.rr)rrr^r,rr-N)rrArrt add_resource_or_template_from_fnrpr()rrrr^r,rr-s rHadd_resource_fnzFastMCP.add_resource_fnDsY.  [  ??# @  rV)r^r,rr-r/cltjr tddfd }|S)aDecorator to register a function as a resource. The function will be called when the resource is read to generate its content. The function can return: - str for text content - bytes for binary content - other types will be converted to JSON Resources can optionally request a Context object by adding a parameter with the Context type annotation. The context provides access to MCP capabilities like logging, progress reporting, and session information. If the URI contains parameters (e.g. "resource://{param}") or the function has parameters, it will be registered as a template resource. Args: uri: URI for the resource (e.g. "resource://my-resource" or "resource://{param}") name: Optional name for the resource description: Optional description of the resource mime_type: Optional MIME type for the resource tags: Optional set of tags for categorizing the resource enabled: Optional boolean to enable or disable the resource Example: @server.resource("resource://my-resource") def get_data() -> str: return "Hello, world!" @server.resource("resource://my-resource") async get_data() -> str: data = await fetch_data() return f"Hello, world! {data}" @server.resource("resource://{city}/weather") def get_weather(city: str) -> str: return f"Weather for {city}" @server.resource("resource://{city}/weather") def get_weather_with_context(city: str, ctx: Context) -> str: ctx.info(f"Fetching weather for {city}") return f"Weather for {city}" @server.resource("resource://{city}/weather") async def get_weather(city: str) -> str: data = await fetch_weather(city) return f"Weather for {city}: {data}" zrThe @resource decorator was used incorrectly. Did you forget to call it? Use @resource('uri') instead of @resourcec ddlmt|trt t j dd vxrd v}tfdt j|jjD}|s|r/tj|  } j||S|s1|s/tj|  } j||St d ) Nr)r aY To decorate a classmethod, first define the method and then call resource() directly on the method instead of using it as a decorator. See https://gofastmcp.com/patterns/decorating-methods for examples and more information. {}c3>K|]}|jur|ywrL) annotation).0pr s rH z6FastMCP.resource..decorator..s%"<.decorators 6"k* $$  !CZ6C3JN!" **2.99@@B"O +99!$ +'#!!(+#O#11 +'#!!(+ OrV)rrrTzResource | ResourceTemplate)r8r:r;)rrr^r,rr-r/rs``````` rHrzFastMCP.resourcejs:t   S !W  4 4 lrVcn|jj||jjy)z`Add a prompt to the server. Args: prompt: A Prompt instance to add N)ru add_promptrpr()rrs rHrVzFastMCP.add_prompts( ''/ rVr^r,r-r/cyrLrFrr2r^r,r-r/s rHrzFastMCP.promptsrVcyrLrFrYs rHrzFastMCP.prompts36rVct|trttjdtj |r1|}|}t j|||||}|j||St|tr|td|d|d|}n||}ntdt|t|j||||S)am Decorator to register a prompt. Prompts can optionally request a Context object by adding a parameter with the Context type annotation. The context provides access to MCP capabilities like logging, progress reporting, and session information. This decorator supports multiple calling patterns: - @server.prompt (without parentheses) - @server.prompt() (with empty parentheses) - @server.prompt("custom_name") (with name as first argument) - @server.prompt(name="custom_name") (with name as keyword argument) - server.prompt(function, name="custom_name") (direct function call) Args: name_or_fn: Either a function (when used as @prompt), a string name, or None name: Optional name for the prompt (keyword-only, alternative to name_or_fn) description: Optional description of what the prompt does tags: Optional set of tags for categorizing the prompt enabled: Optional boolean to enable or disable the prompt Example: @server.prompt def analyze_table(table_name: str) -> list[Message]: schema = read_table_schema(table_name) return [ { "role": "user", "content": f"Analyze this schema: {schema}" } ] @server.prompt() def analyze_with_context(table_name: str, ctx: Context) -> list[Message]: ctx.info(f"Analyzing table {table_name}") schema = read_table_schema(table_name) return [ { "role": "user", "content": f"Analyze this schema: {schema}" } ] @server.prompt("custom_name") def analyze_file(path: str) -> list[Message]: content = await read_file(path) return [ { "role": "user", "content": { "type": "resource", "resource": { "uri": f"file://{path}", "text": content } } } ] @server.prompt(name="custom_name") def another_prompt(data: str) -> list[Message]: return [{"role": "user", "content": data}] # Direct function call server.prompt(my_function, name="custom_name") aC To decorate a classmethod, first define the method and then call prompt() directly on the method instead of using it as a decorator. See https://gofastmcp.com/patterns/decorating-methods for examples and more information. )rr^r,r-r/zZCannot specify both a name as first argument and as keyword argument. Use either @prompt('z') or @prompt(name='r5zCFirst argument to @prompt must be a function, string, or None, got rW)r|r7rr8r9r:rr}rVrr;rr r) rr2r^r,r-r/rr&rs rHrzFastMCP.prompts V j+ .       Z (BK)) ' F OOF #M  C (++5,6J4&P]_%K  KUVZ[eVfUgh   KK#   rVc dKt4d{\}}tjd|jd|jj |||jj tdd{dddd{y777 #1d{7swYyxYww)z%Run the server using stdio transport.NStarting MCP server z with transport 'stdio'T) tools_changed)rrinfor^ryrcreate_initialization_optionsr)r read_stream write_streams rHrzFastMCP.run_stdio_asyncs>  %@k< KK.tyym;RS T""&&  >>'d;          sWB0BB0A*B?BB B0BB0BB0B-!B$ "B-)B0c tK|xs|jj}|xs|jj}|xs|jjj }|j |||} |xsi} ddd} | j | d| vr d| vr|| d<tj| f||d| } tj| } | jjjd}tjd |jd |d |d |d| | j!d {y 7w)a%Run the server using HTTP transport. Args: transport: Transport protocol to use - either "streamable-http" (default) or "sse" host: Host address to bind to (defaults to settings.host) port: Port to bind to (defaults to settings.port) log_level: Log level for the server (defaults to settings.log_level) path: Path for the endpoint (defaults to settings.streamable_http_path or settings.sse_path) uvicorn_config: Additional configuration for the Uvicorn server )rr middlewareron)timeout_graceful_shutdownrR log_configrb)rdre/r]z with transport z on http://:N)rrdrerblowerhttp_appruvicornConfigrstaterlstriprr_r^serve)rrrdrerbruvicorn_configrddefault_log_level_to_userQ_uvicorn_config_from_user config_kwargsconfigrGs rHrzFastMCP.run_http_asyncs:(5t00555t0055  <22<< %' !mmzmR$2$8b!*+)  67 } ,M1Q)AM+ &K$TK]K'yy~~$$S) "499-/? }KX\W]]^_c^ddefjek l llnsD.D80D61D8cKtjdtd|jd|||||d{y7w)z#Run the server using SSE transport.zThe run_sse_async method is deprecated (as of 2.3.2). Use run_http_async for a modern (non-SSE) alternative, or create an SSE app with `fastmcp.server.http.create_sse_app` and run it directly.rrrrrdrerbrrqNrrArr)rrdrerbrrgrqs rH run_sse_asynczFastMCP.run_sse_asyncsS   H   !!) "   7A?Actjdtdt||xs|jj |xs|jj |j|jj|S)z Create a Starlette app for the SSE server. Args: path: The path to the SSE endpoint message_path: The path to the message endpoint middleware: A list of middleware to apply to the app zThe sse_app method is deprecated (as of 2.3.2). Use http_app as a modern (non-SSE) alternative, or call `fastmcp.server.http.create_sse_app` directly.rrrGrgrfr{rcrd) rrArr.rrgrfr{rc)rrrgrds rHsse_appzFastMCP.sse_appso   R   %O)B)B)O)O?T66??++11!   rVc`tjdtd|j||S)z Create a Starlette app for the StreamableHTTP server. Args: path: The path to the StreamableHTTP endpoint middleware: A list of middleware to apply to the app zSThe streamable_http_app method is deprecated (as of 2.3.2). Use http_app() instead.rr)rrd)rrArrk)rrrds rHstreamable_http_appzFastMCP.streamable_http_apps.  a  }}$:}>>rVc |dk(rqt||xs|jjd|j|jj|jj |jj |S|dk(r[t||jj|xs|jj|j|jj |Sy)aCreate a Starlette app using the specified HTTP transport. Args: path: The path for the HTTP endpoint middleware: A list of middleware to apply to the app transport: Transport protocol to use - either "streamable-http" (default) or "sse" Returns: A Starlette application configured with the specified transport rN)rGrh event_storer{rirjrcrdrr|) r/rrhr{rirjrcr.rgrf)rrrdrirjrs rHrkzFastMCP.http_app s& ) )-%)&B,,AA YY"77EE#88GG//55%  % !!66CCC!:!:!C!CYY//55%   rVcKtjdtd|jd|||||d{y7w)Nz]The run_streamable_http_async method is deprecated (as of 2.3.2). Use run_http_async instead.rrrrwrx)rrdrerbrrqs rHrun_streamable_http_asyncz!FastMCP.run_streamable_http_async6sP   *   !!') "   rz)tool_separatorresource_separatorprompt_separatorcddlm}ddlm}ddlm} |t jdtd|t jd td|t jd td| |j}|r!t|| s| ||| }t|| } | |j|<|jjy) a Mount another FastMCP server on this server with the given prefix. Unlike importing (with import_server), mounting establishes a dynamic connection between servers. When a client interacts with a mounted server's objects through the parent server, requests are forwarded to the mounted server in real-time. This means changes to the mounted server are immediately reflected when accessed through the parent. When a server is mounted: - Tools from the mounted server are accessible with prefixed names. Example: If server has a tool named "get_weather", it will be available as "prefix_get_weather". - Resources are accessible with prefixed URIs. Example: If server has a resource with URI "weather://forecast", it will be available as "weather://prefix/forecast". - Templates are accessible with prefixed URI templates. Example: If server has a template with URI "weather://location/{id}", it will be available as "weather://prefix/location/{id}". - Prompts are accessible with prefixed names. Example: If server has a prompt named "weather_prompt", it will be available as "prefix_weather_prompt". There are two modes for mounting servers: 1. Direct mounting (default when server has no custom lifespan): The parent server directly accesses the mounted server's objects in-memory for better performance. In this mode, no client lifecycle events occur on the mounted server, including lifespan execution. 2. Proxy mounting (default when server has a custom lifespan): The parent server treats the mounted server as a separate entity and communicates with it via a Client transport. This preserves all client-facing behaviors, including lifespan execution, but with slightly higher overhead. Args: prefix: Prefix to use for the mounted server's objects. server: The FastMCP server to mount. as_proxy: Whether to treat the mounted server as a proxy. If None (default), automatically determined based on whether the server has a custom lifespan (True if it has a custom lifespan, False otherwise). tool_separator: Deprecated. Separator character for tool names. resource_separator: Deprecated. Separator character for resource URIs. prompt_separator: Deprecated. Separator character for prompt names. rr7)FastMCPTransportr?NThe tool_separator parameter is deprecated and will be removed in a future version. Tools are now prefixed using 'prefix_toolname' format.rrThe resource_separator parameter is deprecated and ignored. Resource prefixes are now added using the protocol://prefix/path format.The prompt_separator parameter is deprecated and will be removed in a future version. Prompts are now prefixed using 'prefix_promptname' format.)rrGr)rkr8fastmcp.client.transportsrfastmcp.server.proxyr@rrArrwr| MountedServerrqrpr() rrrGas_proxyrrrr8rr@mounted_servers rHmountz FastMCP.mountNsh #>5  % MMI"    ) MM["    ' MMM"    ++H Jv|<!&3CF3K"LMF& )7f% rVcn|jj||jjyrL)rqpoprpr()rrs rHunmountzFastMCP.unmounts& !!&) rVcK|tjdtd|tjdtd|tjdtd|d}|jd{j D]&\}}|j j |||(|jd{j D]9\}} t|||j} |jj| | ;|jd{j D]9\}} t|||j} |jj| | ;|d} |jd{j D]&\}} |jj!| | |(t"j%d |j&d |d t"j)d |d t"j)d |dt"j)d| d |j*j-y77757Эw)a~ Import the MCP objects from another FastMCP server into this one, optionally with a given prefix. Note that when a server is *imported*, its objects are immediately registered to the importing server. This is a one-time operation and future changes to the imported server will not be reflected in the importing server. Server-level configurations and lifespans are not imported. When a server is imported: - The tools are imported with prefixed names Example: If server has a tool named "get_weather", it will be available as "prefix_get_weather" - The resources are imported with prefixed URIs using the new format Example: If server has a resource with URI "weather://forecast", it will be available as "weather://prefix/forecast" - The templates are imported with prefixed URI templates using the new format Example: If server has a template with URI "weather://location/{id}", it will be available as "weather://prefix/location/{id}" - The prompts are imported with prefixed names Example: If server has a prompt named "weather_prompt", it will be available as "prefix_weather_prompt" Args: prefix: The prefix to use for the imported server server: The FastMCP server to import tool_separator: Deprecated. Separator for tool names. resource_separator: Deprecated and ignored. Prefix is now applied using the protocol://prefix/path format prompt_separator: Deprecated. Separator for prompt names. Nrrrrr_r>zImported server z with prefix ''zImported tools with prefix 'z.Imported resources and templates with prefix 'z/'zImported prompts with prefix ')rrArrrrsr~radd_resource_prefixrmrtr?rrArrurVrr_r^rcrpr()rrrGrrr tool_prefixrrr prefixed_keyr prompt_prefixrs rH import_serverzFastMCP.import_serversWN  % MMI"    ) MM["    ' MMM"   l & 0 0 2299; IIC    ' '[M#2G ' H I%+$8$8$::AAC LMC.sFD&KL 3K=BC EfXRPQ 5m_AFG -3;D 7sLA3I 5I6AI IA!I &I'A&I  ICI I I I c .ddlm} | d|||||||d|S)zH Create a FastMCP server from an OpenAPI specification. r<) openapi_specclient route_maps route_map_fnmcp_component_fn mcp_namesr-rF)openapir<) clsrrrrrrr-rlr<s rH from_openapizFastMCP.from_openapis8 ,  %!%-    rVc ddlm} |i}|jddtjddtj |i|} |xs |j }| d|j| ||||||d| S) zE Create a FastMCP server from a FastAPI application. rrbase_urlzhttp://fastapir)rQ)rrr^rrrrr-rF)rr< setdefaulthttpx AsyncClient ASGITransporttitle) rrQr^rrrrhttpx_client_kwargsr-rlr<rs rH from_fastapizFastMCP.from_fastapi,s" ,  &"$ &&z3CD"" ))c2 !   syy  !%-    rVc \ddlm}ddlm}t ||r|}n||}|dd|i|S)aNCreate a FastMCP proxy server for the given backend. The ``backend`` argument can be either an existing :class:`~fastmcp.client.Client` instance or any value accepted as the ``transport`` argument of :class:`~fastmcp.client.Client`. This mirrors the convenience of the ``Client`` constructor. rr7r?rrF)fastmcp.client.clientr8rr@r|)rbackendrlr8r@rs rHrzFastMCP.as_proxyVs5( 15 gv &FG_F666X66rVc `tjdtd|j|fi|S)zF Create a FastMCP proxy server from a FastMCP client. zDFastMCP.from_client() is deprecated; use FastMCP.as_proxy() instead.rr)rrArr)rrrls rH from_clientzFastMCP.from_clientts1  R  s||F/h//rVcjsy|j |jy|jtfd|jDry|j tfd|jDryyy)u! Given a component, determine if it should be enabled. Returns True if it should be enabled; False if it should not. Rules: • If the component's enabled property is False, always return False. • If both include_tags and exclude_tags are None, return True. • If exclude_tags is provided, check each exclude tag: - If the exclude tag is a string, it must be present in the input tags to exclude. • If include_tags is provided, check each include tag: - If the include tag is a string, it must be present in the input tags to include. • If include_tags is provided and none of the include tags match, return False. • If include_tags is not provided, return True. FTc3:K|]}|jvywrLr-)rKetag components rHrMz3FastMCP._should_enable_component..Hd49>>)Hc3:K|]}|jvywrLr)rKitagrs rHrMz3FastMCP._should_enable_component..rr)r/rrrP)rrs `rHrz FastMCP._should_enable_componentsw"      $):):)B    (Hd6G6GHH    (Hd6G6GHHrV)NNNNNNNNNNNNNNNNNNNNNNNN)0r^ str | Noner_rr{zOAuthProvider | NonerRzYCallable[[FastMCP[LifespanResultT]], AbstractAsyncContextManager[LifespanResultT]] | NonerzCallable[[Any], str] | Nonerz float | NonerDuplicateBehavior | Nonerrrrrm"Literal['protocol', 'path'] | Noner] bool | Nonerz&list[Tool | Callable[..., Any]] | Nonerlist[str] | Nonerset[str] | Nonerrrbrrcrrdrre int | Nonerfrrgrrhrrirrjr)rTr)rbrrcrrdrrerrfrrgrrhrrirrjrrTNone)rTrrL)rz1Literal['stdio', 'streamable-http', 'sse'] | Nonerr rTr)rTrrTzdict[str, Tool])rrrTrrTzdict[str, Resource])rrrTrrTzdict[str, ResourceTemplate])rrrTrrTzdict[str, Prompt])rrrTr)NT)rrrz list[str]r^rrbool)rTz list[MCPTool])rTzlist[MCPResource])rTzlist[MCPResourceTemplate])rTzlist[MCPPrompt])rrr dict[str, Any]rTz3list[TextContent | ImageContent | EmbeddedResource])rz AnyUrl | strrTzlist[ReadResourceContents])r^rr dict[str, Any] | NonerTr)rrrTr)r^rrTr)r2rr^rr,rr-rr'ToolAnnotations | dict[str, Any] | Noner.rr/rrTr2)r2rr^rr,rr-rrrr.rr/rrTz%Callable[[AnyFunction], FunctionTool])r2str | AnyFunction | Noner^rr,rr-rrrr.rr/rrTz4Callable[[AnyFunction], FunctionTool] | FunctionTool)rrrrrTr)rrrrrTr)NNNN)rrrrr^rr,rrrr-rrTr)rrr^rr,rrrr-rr/rrTz4Callable[[AnyFunction], Resource | ResourceTemplate])rrrTr) r2rr^rr,rr-rr/rrTr)) r2rr^rr,rr-rr/rrTz'Callable[[AnyFunction], FunctionPrompt]) r2rr^rr,rr-rr/rrTz8Callable[[AnyFunction], FunctionPrompt] | FunctionPrompt)rNNNNNN)r!Literal['streamable-http', 'sse']rdrrerrbrrrrqrrdlist[Middleware] | NonerTr)NNNNNN)rdrrerrbrrrrgrrqrrTr)NNN)rrrgrrdrrTr-)NN)rrrdrrTr-)NNNNr) rrrdrrirrjrrrrTr-)NNNNN) rdrrerrbrrrrqrrTr)rrrGFastMCP[LifespanResultT]rrrrrrrrrTr)rrrTr) rrrGrrrrrrrrTr)rrrzhttpx.AsyncClientrlist[RouteMap] | NonerOpenAPIRouteMapFn | NonerOpenAPIComponentFn | Nonerdict[str, str] | Noner-rrlr rTr<)NNNNNNN)rQr r^rrrrrrrrrrrr-rrlr rTr<)rzlClient[ClientTransportT] | ClientTransport | FastMCP[Any] | AnyUrl | Path | MCPConfig | dict[str, Any] | strrlr rTr@)rzClient[ClientTransportT]rlr rTr@)rr4rTr)9r __module__ __qualname__rrrpropertyr^r_rrrrrrrrrrrrrrrrrr rrrr r~r*rrr?rArDrrVrrrryr}rrkrrrrr7rrrrrrFrVrHrXrXos  #'%) 7;157;;?9=EI*.8<)-(,(, !%!##'+/%)&*Id d !d # d   d 5d #/d 5d !9d 7!d "!C#d $(%d &6'd (')d *&+d ,&-d 89d :;d <=d >?d @Ad B!Cd D)Ed F#Gd H$Id L7$B$B$B $B  $B  $B!$B)$B#$B$$B $BL%%-- HL@D@ @  @0HL JD J  J  J<" " ( & "& *** *  *X    <<#1< <<866#16 <6<G$@2=A??$9? ?*=A77$97 7:    "& $?C)-#       = '     "& 4 "& $?C)-# 4 4 4  4  4= 4' 4 4 / 4 404r  "& $?C)-#r ,r  r  r  r =r 'r r  >r h? "& $ $$ $$ $  $  $$ $T "& $ $#v v v  v  vvv >vp  "& $#      "&6 "& $#66 6  6  66 16604A  "& $#A ,A  A  A  A A  BA F 8I $04.2-4-- -  -  -.-,- -b  $#'04       !  .   < #'.2   ! ,    @ .2??,?  ?, .2%)&*7H '','# ' $ ' 5 ' 'V  $04        .    8!% ` &*)-'+``)` ` # `'`%` `D&*)-'+ ZZ)Z# Z ' Z % Z Zx -1156:+/ $ $ " *  /  4  )      6 ,0156:+/59 $' ' ' * ' / ' 4 ' )' 3' ' '  ' ' R777 77: 0- 0;> 0  0 0!#! !rVrXcleZdZ d dZddZddZddZddZddZddZ ddZ dd Z dd Z dd Z y )rc ||_||_yrLr)rrrGs rHrzMountedServer.__init__s   rVcK|jjd{}|jDcic]\}}|jd||c}}S77cc}}wwNr)rGrrr)rrrrs rHrzMountedServer.get_toolssRkk++-->CkkmLd4;;-q&,LL.L A AA AA A c K|jjd{}|jDcic]1\}}t||j|jj |3c}}S7Qcc}}wwrL)rGrrrrrm)rrrrs rHrzMountedServer.get_resourcessq++3355 "+!2  X T[[$++"D"D    6 A:A2A:6A4.A:4A:c K|jjd{}|jDcic]1\}}t||j|jj |3c}}S7Qcc}}wwrL)rGrrrrrm)rrrrs rHrz$MountedServer.get_resource_templatessq++<<>> "+!2  X T[[$++"D"D    ? rcK|jjd{}|jDcic]\}}|jd||c}}S77cc}}wwr)rGrrr)rrrrs rHrzMountedServer.get_promptssR //11BI--/R;34;;-q&.RR2Rrc>|j|jdSr startswithrrrs rHrzMountedServer.match_tool~~ Q/00rVc>|j|jdSr removeprefixrrs rHrzMountedServer.strip_tool_prefix4;;-q 122rVcXt||j|jjSrL)has_resource_prefixrrGrmrs rHrzMountedServer.match_resources"3 T[[5W5WXXrVcXt||j|jjSrL)remove_resource_prefixrrGrmrs rHrz#MountedServer.strip_resource_prefixs$% dkk@@  rVc>|j|jdSrrrs rHr$zMountedServer.match_promptrrVc>|j|jdSrrrs rHr%z!MountedServer.strip_prompt_prefixrrVN)rrrGrrrrr)rrrTr)rrrTr)rrrrrrrrrrrrr$r%rFrVrHrrsN)M  S13Y 13rVrc|s|S|tjj}|dk(r|d|S|dk(rBtj |}|st d|d|j \}}||d|St d|)aAdd a prefix to a resource URI. Args: uri: The original resource URI prefix: The prefix to add Returns: The resource URI with the prefix added Examples: >>> add_resource_prefix("resource://path/to/resource", "prefix") "resource://prefix/path/to/resource" # with new style >>> add_resource_prefix("resource://path/to/resource", "prefix") "prefix+resource://path/to/resource" # with legacy style >>> add_resource_prefix("resource:///absolute/path", "prefix") "resource://prefix//absolute/path" # with new style Raises: ValueError: If the URI doesn't match the expected protocol://path format protocol+rInvalid URI format: ". Expected protocol://path format.rhInvalid prefix format: )rkrlrm URI_PATTERNmatchrgroups)rr prefix_formatrrrs rHrrs.  ((??  "3%  & !!#&&se+MN $F81TF++2=/BCCrVc|s|S|tjj}|dk(r&|d}|j|r|t |dS|S|dk(rt j |}|std|d|j\}}dtj|d}tj ||}|s|S||jd Std |) a Remove a prefix from a resource URI. Args: uri: The resource URI with a prefix prefix: The prefix to remove prefix_format: The format of the prefix to remove Returns: The resource URI with the prefix removed Examples: >>> remove_resource_prefix("resource://prefix/path/to/resource", "prefix") "resource://path/to/resource" # with new style >>> remove_resource_prefix("prefix+resource://path/to/resource", "prefix") "resource://path/to/resource" # with legacy style >>> remove_resource_prefix("resource://prefix//absolute/path", "prefix") "resource:///absolute/path" # with new style Raises: ValueError: If the URI doesn't match the expected protocol://path format Nrrrrr^z/(.*?)$rr) rkrlrmrlenrrrrreescapegroup) rrr legacy_prefixrrrprefix_pattern path_matchs rHrrs.  ((??  "!(! >>- (s=)+, , & !!#&&se+MN $RYYv./w7XXnd3 JJ,,Q/0112=/BCCrVc~|sy|tjj}|dk(r|d}|j|S|dk(rqtj |}|st d|d|j\}}dtj|d}ttj ||St d |) aCheck if a resource URI has a specific prefix. Args: uri: The resource URI to check prefix: The prefix to look for Returns: True if the URI has the specified prefix, False otherwise Examples: >>> has_resource_prefix("resource://prefix/path/to/resource", "prefix") True # with new style >>> has_resource_prefix("prefix+resource://path/to/resource", "prefix") True # with legacy style >>> has_resource_prefix("resource://other/path/to/resource", "prefix") False Raises: ValueError: If the URI doesn't match the expected protocol://path format Frrrrrrrhr) rkrlrmrrrrrrrr)rrrrrrrrs rHrrMs. ((??  "!(! ~~m,, & !!#&&se+MN ,,.4RYYv./q1BHH^T2332=/BCCrV)rGrrTzAsyncIterator[Any])rQrrRzRCallable[[FastMCP[LifespanResultT]], AbstractAsyncContextManager[LifespanResultT]]rTzTCallable[[MCPServer[LifespanResultT]], AbstractAsyncContextManager[LifespanResultT]]rL)rrrrrrrTr)rrrrrrrTr){__doc__ __future__rrnr8rrcollections.abcrrr contextlibrrr functoolsr pathlibr typingr r rrrrrrl mcp.server.lowlevel.helper_typesrmcp.server.lowlevel.serverrrrrxmcp.server.stdior mcp.typesrrrrrrr MCPPromptr MCPResourcerMCPResourceTemplaterMCPToolpydanticr starlette.middlewarer!starlette.requestsr"starlette.responsesr#starlette.routingr$r%rkfastmcp.serverfastmcp.exceptionsr&r'fastmcp.promptsr(fastmcp.prompts.promptr)fastmcp.resourcesr*fastmcp.resources.templatefastmcp.server.auth.authr+(fastmcp.server.auth.providers.bearer_envr,fastmcp.server.httpr-r.r/fastmcp.settingsr0 fastmcp.toolsr1fastmcp.tools.toolr2fastmcp.utilities.cacher3fastmcp.utilities.componentsr4fastmcp.utilities.loggingr5fastmcp.utilities.mcp_configr6fastmcp.clientr8rr9r:fastmcp.server.openapir;OpenAPIComponentFnr<r=r>OpenAPIRouteMapFnrr@rrDuplicateBehaviorcompilerrIrUrXrrrrrFrVrHr2s;" >> AA AK:)*-=%+&(.;11772J &%1.902%KH?F1 H @Abjj-.      !  "vgo&vr15353rPT0D 0D0D*L0D0DhPT7D 7D7D*L7D7DvPT2D 2D2D*L2D 2DrV