"tjtjSr')r nowr utcr(r,r*zMiddlewareContext.=s X\8R8Rr,)default_factoryr timestampkwargsr r$r#c t|fi|Sr')r)r)r@s r*copyzMiddlewareContext.copy?st&&v&&&r,)r@r r$r#) r-r.r/__doc____annotations__r4r6r8r9rr?rBr(r,r*rr/sJJJ&*O****+3F2222/8D8888F%0R0RSSSISSSS''''''r,r middlewarer call_nextCallNext[T, R]r$cdfd }|S)zCreate a wrapper that applies a single middleware to a context. The closure bakes in the middleware and call_next function, so it can be passed to other functions that expect a call_next function.r"r#r$rc,K|d{VSr'r()r"rFrEs r*wrapperz(make_middleware_wrapper..wrapperJs+Z333333333r,)r"r#r$rr()rErFrJs`` r*make_middleware_wrapperrKCs.4444444 Nr,czeZdZdZd4dZd5d Zd6d Zd7dZd8dZd9dZ d:dZ d;dZ dd*Zd?d.Zd@d2Zd3S)Arz9Base class for FastMCP middleware with dispatching hooks.r"r#rFCallNext[T, Any]r$r cbK|||d{V}||d{VS)z0Main entry point that orchestrates the pipeline.rFN)_dispatch_handler)r)r"rF handler_chains r*r+zMiddleware.__call__Ssj #44 5        #]7+++++++++r,MiddlewareContext[Any]CallNext[Any, Any]cK|}|jxdkrt|j|}nxdkrt|j|}nxdkrt|j|}nxdkrt|j|}nuxdkrt|j|}nWxdkrt|j|}n9xdkrt|j|}nd krt|j |}|j xd krt|j |}nd krt|j |}t|j |}|S) z/Builds a chain of handlers for a given message. initializerOz tools/callzresources/readz prompts/getz tools/listzresources/listzresources/templates/listz prompts/listr7 notification)r9r on_initialize on_call_toolon_read_resource on_get_prompt on_list_toolson_list_resourceson_list_resource_templateson_list_promptsr8 on_requeston_notification on_message)r)r"rFhandlers r*rPzMiddleware._dispatch_handler_sn!$"4HHH!$"3wGGG!!!!!!$"77KKK!$"4HHH!$"4HHH!!!!!!$"8GLLL+++++!$"AWUUU!$"6'JJJl!$/WEEE!$"6'JJJ$/W===r,c(K||d{VSr'r(r)r"rFs r*razMiddleware.on_message* Yw'''''''''r,'MiddlewareContext[mt.Request[Any, Any]]#CallNext[mt.Request[Any, Any], Any]c(K||d{VSr'r(rds r*r_zMiddleware.on_requestrer,,MiddlewareContext[mt.Notification[Any, Any]](CallNext[mt.Notification[Any, Any], Any]c(K||d{VSr'r(rds r*r`zMiddleware.on_notificationrer,'MiddlewareContext[mt.InitializeRequest]:CallNext[mt.InitializeRequest, mt.InitializeResult | None]mt.InitializeResult | Nonec(K||d{VSr'r(rds r*rWzMiddleware.on_initializerer,+MiddlewareContext[mt.CallToolRequestParams].CallNext[mt.CallToolRequestParams, ToolResult]rc(K||d{VSr'r(rds r*rXzMiddleware.on_call_toolrer,/MiddlewareContext[mt.ReadResourceRequestParams]FCallNext[mt.ReadResourceRequestParams, Sequence[ReadResourceContents]]Sequence[ReadResourceContents]c(K||d{VSr'r(rds r*rYzMiddleware.on_read_resource*Yw'''''''''r,,MiddlewareContext[mt.GetPromptRequestParams]7CallNext[mt.GetPromptRequestParams, mt.GetPromptResult]mt.GetPromptResultc(K||d{VSr'r(rds r*rZzMiddleware.on_get_promptrer,&MiddlewareContext[mt.ListToolsRequest]-CallNext[mt.ListToolsRequest, Sequence[Tool]]Sequence[Tool]c(K||d{VSr'r(rds r*r[zMiddleware.on_list_toolsrer,*MiddlewareContext[mt.ListResourcesRequest]5CallNext[mt.ListResourcesRequest, Sequence[Resource]]Sequence[Resource]c(K||d{VSr'r(rds r*r\zMiddleware.on_list_resourcesrer,2MiddlewareContext[mt.ListResourceTemplatesRequest]ECallNext[mt.ListResourceTemplatesRequest, Sequence[ResourceTemplate]]Sequence[ResourceTemplate]c(K||d{VSr'r(rds r*r]z%Middleware.on_list_resource_templatesrwr,(MiddlewareContext[mt.ListPromptsRequest]1CallNext[mt.ListPromptsRequest, Sequence[Prompt]]Sequence[Prompt]c(K||d{VSr'r(rds r*r^zMiddleware.on_list_promptsrer,N)r"r#rFrMr$r )r"rRrFrSr$rS)r"rRrFrSr$r )r"rfrFrgr$r )r"rirFrjr$r )r"rlrFrmr$rn)r"rprFrqr$r)r"rsrFrtr$ru)r"rxrFryr$rz)r"r|rFr}r$r~)r"rrFrr$r)r"rrFrr$r)r"rrFrr$r)r-r.r/rCr+rPrar_r`rWrXrYrZr[r\r]r^r(r,r*rrPsCC , , , ,    D((((((((((((((((((((((((((((((((((((((((((((((r,)rErrFrGr$rG)1 __future__rloggingcollections.abcrr dataclassesrrrr r functoolsr typingr r rrrr mcp.typestypesmt mcp.server.lowlevel.helper_typesrtyping_extensionsrfastmcp.prompts.promptrfastmcp.resources.resourcerfastmcp.resources.templaterfastmcp.tools.toolrrfastmcp.server.contextr__all__ getLoggerr-loggerrrrrrKrr(r,r*rs""""""////////1111111111''''''''AAAAAA%%%%%%))))))//////777777/////////......     8 $ $ GC GC4---KKKKKx1~KKK 4%%%''''' ''&%'&    @(@(@(@(@(@(@(@(@(@(r,