k7i$SrSSKrSSKrSSKrSSKJr SSKJr SSKJr SSK r SSK J r J r J r S\S \4S jr"S S \ 5r"S S\5r"SS\5rS\S \4Sjrg)z5Comprehensive logging middleware for FastMCP servers.N)Callable)Logger)Any)CallNext MiddlewareMiddlewareContextdatareturncP[R"U[S9R5$)z>The default serializer for Payloads in the logging middleware.)fallback) pydantic_coreto_jsonstrdecode)r s [/home/james-whalen/.local/lib/python3.13/site-packages/fastmcp/server/middleware/logging.pydefault_serializerrs   4 ; ; ==c \rSrSr%Sr\\S'\\S'\\S'\\S'\\S'\S-\S '\ \ S-\S '\\S '\ \ /\ 4S-\S 'S \ \ S\ 4SjrS\\ \ \-4S\ 4SjrS \ \ S\\ \ \-44SjrS \ \ S\S\S\\ \ \-\-44SjrS \ \ S\S\\ \ \-\-44SjrSS\\ \ \-\-4S\S-4SjjrS \ \ S\\ \ 4S\ 4SjrSrg)BaseLoggingMiddlewarez"Base class for logging middleware.logger log_levelinclude_payloadsinclude_payload_lengthestimate_payload_tokensNmax_payload_lengthmethodsstructured_loggingpayload_serializercontextr c tUR(d[UR5nU$URUR5nU$![afnURR SUSUR SURSURS3 5 [UR5nSnAU$SnAff=f)Nz#Failed to serialize payload due to z:  .) r rmessage Exceptionrwarningtypemethodsource)selfr!payloades r_serialize_payload(BaseLoggingMiddleware._serialize_payload!s&&(9G >11'//B  > ##9!Bw||nAgnnM]]^_f_m_m^nnop-W__=  >sA B7AB22B7r%c UR(a[R"U5$SRUR 5VVs/sH up#USU3PM snn5$s snnf)zFormat a message for logging.r#=)rjsondumpsjoinitems)r+r%kvs r_format_message%BaseLoggingMiddleware._format_message1sM  " "::g& &88GMMODODAs!A3ZODE EDsA! cURS-UR=(d SURS.nUR(d"UR(dUR (aUR U5nUR(dUR (a:[U5nUS-nUR (aXRS'UR(aXBS'UR(a+[U5UR:aUSURS-nUR(a&X2S'[UR5RUS 'U$) N_startunknown)eventr)r*payload_tokenspayload_lengthz...r, payload_type) r(r)r*rrrr.lenrr%__name__)r+r!r%r,r@r?s r_create_before_message,BaseLoggingMiddleware._create_before_message8s\\H,nn1 nn   ! !**++--g6G**d.J.J!$W!/1!4//0>,-..0>,-&&3w<$:Q:Q+Q!";D$;$; .j9 \\J.nn1 nn&   rcURRU=(d URURU55 gN)rlogrr8)r+r%rs r _log_message"BaseLoggingMiddleware._log_messagews*  3T^^T5I5I'5RSr call_nextc# UR(a*URUR;aU"U5IShvN $URURU55 [R "5nU"U5IShvN nURUR X55 U$NlN(![a6nURURXU5[R5 eSnAff=f7f)z$Log messages for configured methods.N) rr)rVrDtime perf_counterrQr&rMloggingERROR)r+r!rXrFresultr-s r on_message BaseLoggingMiddleware.on_message|s <"7++ + $55g>?&&(  $W--F   d88M NM, .     **7BGMM    sE7C-B&9C-4 B*?B(%B*%C-(B** C*41C%%C**C-rT)rC __module__ __qualname____firstlineno____doc__r__annotations__intboollistrrrr r.dictr8rDfloatr&rMrQrVrr___static_attributes__rarrrrs, NN  !!d " #Y  #,t33*;C*@S FtCsN';FF(- c39n B"3'  c39u$$ %  "3'   c39u$$ % NRTCsU!223T@Cd T (-:B38:L rrc\rSrSrSrS\R SSSSSSS.S\RS-S\S \ S \ S \ S \S \ \ S-S\ \ /\ 4S-4SjjrSrg)LoggingMiddlewareaMiddleware that provides comprehensive request and response logging. Logs all MCP messages with configurable detail levels. Useful for debugging, monitoring, and understanding server usage patterns. Example: ```python from fastmcp.server.middleware.logging import LoggingMiddleware import logging # Configure logging logging.basicConfig(level=logging.INFO) mcp = FastMCP("MyServer") mcp.add_middleware(LoggingMiddleware()) ``` NF)rrrrrrrr rrrrrrrr cU=(d [R"S5UlX lX0lX@lXPlX`lXplXl SUl g)aInitialize logging middleware. Args: logger: Logger instance to use. If None, creates a logger named 'fastmcp.requests' log_level: Log level for messages (default: INFO) include_payloads: Whether to include message payloads in logs include_payload_length: Whether to include response size in logs estimate_payload_tokens: Whether to estimate response tokens max_payload_length: Maximum length of payload to log (prevents huge logs) methods: List of methods to log. If None, logs all methods. payload_serializer: Callable that converts objects to a JSON string for the payload. If not provided, uses FastMCP's default tool serializer. zfastmcp.middleware.loggingFN) r\ getLoggerrrrrrrrr r) r+rrrrrrrr s r__init__LoggingMiddleware.__init__sL2%W(9(9:V(W "&6,B#-D$'9)0 ?Q(-r rrrrrrrr rrCrbrcrdrer\INFOrrgrhrirrrrsrlrarrrnrns*)- !&',(-"&$(:>!.%!. !.  !. !% !."&!. !.cT!!.%cUCZ047!.!.rrnc\rSrSrSrS\R SSSSSS.S\RS-S\S\ S \ S \ S \ \ S-S \ \ /\ 4S-4S jjrSrg)StructuredLoggingMiddlewareaMiddleware that provides structured JSON logging for better log analysis. Outputs structured logs that are easier to parse and analyze with log aggregation tools like ELK stack, Splunk, or cloud logging services. Example: ```python from fastmcp.server.middleware.logging import StructuredLoggingMiddleware import logging mcp = FastMCP("MyServer") mcp.add_middleware(StructuredLoggingMiddleware()) ``` NF)rrrrrrr rrrrrrr cU=(d [R"S5UlX lX0lX@lXPlX`lXplSUl SUl g)aoInitialize structured logging middleware. Args: logger: Logger instance to use. If None, creates a logger named 'fastmcp.structured' log_level: Log level for messages (default: INFO) include_payloads: Whether to include message payloads in logs include_payload_length: Whether to include payload size in logs estimate_payload_tokens: Whether to estimate token count using length // 4 methods: List of methods to log. If None, logs all methods. payload_serializer: Callable that converts objects to a JSON string for the payload. If not provided, uses FastMCP's default tool serializer. z%fastmcp.middleware.structured_loggingNT) r\rrrrrrrrr rr)r+rrrrrrr s rrs$StructuredLoggingMiddleware.__init__sT.% (9(9 3)  (&6,B#-D$)0 ?Q.2(,rrurvrarrryrys $)- !&',(-$(:>!-%!- !-  !- !% !-"&!-cT!!-%cUCZ047!-!-rryrFcH[[R"5U- S-SS9$)Nrp)numberndigits)roundrZr[)rFs rrLrLs" **,z9TA1 MMr)rer2r\rZcollections.abcrrtypingrr middlewarerrr rrrrnryrkrLrarrrsw;  $??>S>S> }J}@4.-4.n1-"71-hNNeNr