)`idZddlZddlZddlZddlmZmZddlmZm Z m Z ddl m Z ddl mZddlmZddlmZddlZdd lmZmZdd lmZdd lmZdd lmZdd lmZddlm Z m!Z!m"Z"ddl#m$Z$m%Z%ddl&m'Z'm(Z(ddl)m*Z*ddl+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6ej7e8Z9dZ:dZ;dZdZ?ej@dZAeBZCeBZDeGddZEe eEge dfZFGddeZGGddZHdS) z StreamableHTTP Server Transport Module This module implements an HTTP transport layer with Streamable HTTP. The transport handles bidirectional communication using HTTP requests and responses, with streaming support for long-running operations. N)ABCabstractmethod)AsyncGenerator AwaitableCallable)asynccontextmanager) dataclass) HTTPStatus)Any)MemoryObjectReceiveStreamMemoryObjectSendStream)ValidationError)EventSourceResponse)Request)Response)ReceiveScopeSend)TransportSecurityMiddlewareTransportSecuritySettings)ServerMessageMetadataSessionMessage)SUPPORTED_PROTOCOL_VERSIONS) DEFAULT_NEGOTIATED_VERSIONINTERNAL_ERRORINVALID_PARAMSINVALID_REQUEST PARSE_ERROR ErrorData JSONRPCErrorJSONRPCMessageJSONRPCRequestJSONRPCResponse RequestIdzmcp-session-idzmcp-protocol-versionz last-event-idzapplication/jsonztext/event-stream _GET_streamz^[\x21-\x7E]+$c2eZdZUdZeed<dZedzed<dS) EventMessagezM A JSONRPCMessage with an optional event ID for stream resumability. messageNevent_id)__name__ __module__ __qualname____doc__r!__annotations__r)strn/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/mcp/server/streamable_http.pyr'r'Hs>HcDjr1r'cfeZdZdZedededzdefdZedede dedzfd Z dS) EventStorez? Interface for resumability support via event storage. stream_idr(Nreturnc KdS)a Stores an event for later retrieval. Args: stream_id: ID of the stream the event belongs to message: The JSON-RPC message to store, or None for priming events Returns: The generated event ID for the stored event Nr0)selfr5r(s r2 store_eventzEventStore.store_eventZs  r1 last_event_id send_callbackc KdS)a2 Replays events that occurred after the specified event ID. Args: last_event_id: The ID of the last event the client received send_callback: A callback function to send events to the client Returns: The stream ID of the replayed events Nr0)r8r:r;s r2replay_events_afterzEventStore.replay_events_afterhs r1) r*r+r,r-rStreamIdr!EventIdr9 EventCallbackr=r0r1r2r4r4Us  8  nt>S  X_    ^    %  D    ^   r1r4c eZdZUdZdZeeezdzed<dZ e eezdzed<dZ eedzed<dZ e edzed<e ed< d7d edzd ed edzd edzd edzddf dZedefdZdeddfdZd8dZdededededef dZdedeeeefdeddfdZedfdede dedeeefdzde!f dZ"e j#dfdedzde deeefdzde!fd Z$dededzfd!Z%d"e&deeeffd#Z'deddfd$Z(d%e)d&e*d'e+ddfd(Z,dede-eeffd)Z.dedefd*Z/ded%e)d'e+defd+Z0d%e)ded&e*d'e+ddf d,Z1ded'e+ddfd-Z2ded'e+ddfd.Z3d8d/Z4ded'e+ddfd0Z5ded'e+defd1Z6ded'e+defd2Z7ded'e+defd3Z8d4eded'e+ddfd5Z9e:de;e-e eezeefdffd6Z.Z.Z %`aa a,(@%'45FGG-  ]_  r1c|jS)z7Check if this transport has been explicitly terminated.)rUr8s r2 is_terminatedz+StreamableHTTPServerTransport.is_terminateds r1 request_idc|j|d}|r|||jvrG|j|\}}||dSdS)a Close SSE connection for a specific request without terminating the stream. This method closes the HTTP connection for the specified request, triggering client reconnection. Events continue to be stored in the event store and will be replayed when the client reconnects with Last-Event-ID. Use this to implement polling behavior during long-running operations - client will reconnect after the retry interval specified in the priming event. Args: request_id: The request ID whose SSE stream should be closed. Note: This is a no-op if there is no active stream for the request ID. Requires event_store to be configured for events to be stored during the disconnect. N)rTpopcloserS)r8rZwriter send_streamreceive_streams r2close_sse_streamz.StreamableHTTPServerTransport.close_sse_streams$)--j$??   LLNNN . . .*.*?*C*CJ*O*O 'K        " " " " " / .r1c:|tdS)aFClose the standalone GET SSE stream, triggering client reconnection. This method closes the HTTP connection for the standalone GET stream used for unsolicited server-to-client notifications. The client SHOULD reconnect with Last-Event-ID to resume receiving notifications. Use this to implement polling behavior for the notification stream - client will reconnect after the retry interval specified in the priming event. Note: This is a no-op if there is no active standalone SSE stream. Requires event_store to be configured for events to be stored during the disconnect. Currently, client reconnection for standalone GET streams is NOT implemented - this is a known gap (see test_standalone_get_stream_reconnection). N)raGET_STREAM_KEYrXs r2close_standalone_sse_streamz9StreamableHTTPServerTransport.close_standalone_sse_streams" n-----r1r(requestprotocol_versioncjr&|dkr d fd }d fd }t|||}nt|}t||S) aJCreate a session message with metadata including close_sse_stream callback. The close_sse_stream callbacks are only provided when the client supports resumability (protocol version >= 2025-11-25). Old clients can't resume if the stream is closed early because they didn't receive a priming event. 2025-11-25r6Nc6KdSN)ra)rZr8sr2close_stream_callbackzTStreamableHTTPServerTransport._create_session_message..close_stream_callbacks!%%j11111r1c4KdSrj)rdrXsr2 close_standalone_stream_callbackz_StreamableHTTPServerTransport._create_session_message..close_standalone_stream_callbacks0022222r1)request_contextrardrnmetadatar6N)rQrr)r8r(rerZrfrkrmrqs` ` r2_create_session_messagez5StreamableHTTPServerTransport._create_session_messages   F!1\!A!A 2 2 2 2 2 2 2 3 3 3 3 3 3- '!6,LHH -WEEEHg9999r1sse_stream_writercK|jsdS|dkrdS|jt|dd{V}|dd}|j |j|d<||d{VdS)a#Send priming event for SSE resumability if event_store is configured. Only sends priming events to clients with protocol version >= 2025-11-25, which includes the fix for handling empty SSE data. Older clients would crash trying to parse empty data as JSON. Nrh)iddataretry)rQr9r/rRsend)r8rZrtrfpriming_event_id priming_events r2_maybe_send_priming_eventz7StreamableHTTPServerTransport._maybe_send_priming_event s   F l * * F!%!2!>!>  OO " "       6Fr.R.R   +%)%9M' "$$]33333333333r1 error_message status_code error_codeheaderscdti}|r|||jr|j|t<t ddt ||}t |dd||S) z6Create an error response with a simple string message. Content-Typez2.0z server-error)coder()jsonrpcrwerrorTby_alias exclude_nonerr)CONTENT_TYPE_JSONupdaterHMCP_SESSION_ID_HEADERr rrmodel_dump_json)r8r~rrrresponse_headerserror_responses r2_create_error_responsez4StreamableHTTPServerTransport._create_error_response&s+,=>  -  # #G , , ,   J6:6I 2 3&%     * *Dt * L L#$    r1response_messagecdti}|r|||jr|j|t<t |r|ddnd||S)z,Create a JSON response from a JSONRPCMessagerTrNr)rrrHrrr)r8rrrrs r2_create_json_responsez3StreamableHTTPServerTransport._create_json_responseEs+,=>  -  # #G , , ,   J6:6I 2 3Rb l  , ,d , N N Nhl#$    r1c@|jtS)z,Extract the session ID from request headers.)rgetr)r8res r2_get_session_idz-StreamableHTTPServerTransport._get_session_idYs""#8999r1 event_messagecfd|jddd}|jr |j|d<|S)z2Create event data dictionary from an EventMessage.r(Tr)eventrxrw)r(rr))r8r event_datas r2_create_event_dataz0StreamableHTTPServerTransport._create_event_data]sM!)994VZ9[[   ! 6,5Jt r1cK||jvr |j|dd{V|j|dd{Vn*#t$rtdYnwxYw|j|ddS#|j|dwxYwdS)z/Clean up memory streams for a given request ID.rNz4Error closing memory streams - may already be closed)rSaclose Exceptionloggerdebugr\)r8rZs r2_clean_up_memory_streamsz6StreamableHTTPServerTransport._clean_up_memory_streamsjs . . . <+J7:AACCCCCCCCC+J7:AACCCCCCCCCC U U U STTTTT U %))*d;;;;;%))*d;;;; / .s*AA$#B+$$B B+ B  B++Cscopereceiverzc\Kt||}|jdk}|j||d{V}|r||||d{VdS|jr5|dt j}||||d{VdS|jdkr |||||d{VdS|jdkr| ||d{VdS|jdkr| ||d{VdS| ||d{VdS)z6Application entry point that handles all HTTP requestsPOST)is_postNz&Not Found: Session has been terminatedGETDELETE) rmethodrGvalidate_requestrUrr NOT_FOUND_handle_post_request_handle_get_request_handle_delete_request_handle_unsupported_request)r8rrrzrerrresponses r2handle_requestz,StreamableHTTPServerTransport.handle_requestxs%)).F*#~>>wPW>XXXXXXXX   .66 6 6 6 6 6 6 6 F   228$H(5'400 0 0 0 0 0 0 0 F >V # #++E7GTJJ J J J J J J J J J ^u $ $**7D99 9 9 9 9 9 9 9 9 9 ^x ' '--gt<< < < < < < < < < <227DAA A A A A A A A A Ar1c|jdd}d|dD}td|D}td|D}||fS)z6Check if the request accepts the required media types.acceptrvc6g|]}|Sr0strip.0 media_types r2 zGStreamableHTTPServerTransport._check_accept_headers..s$VVVz ((**VVVr1,c3JK|]}|tVdSrj) startswithrrs r2 zFStreamableHTTPServerTransport._check_accept_headers..s1__Jz,,->??______r1c3JK|]}|tVdSrj)rCONTENT_TYPE_SSErs r2rzFStreamableHTTPServerTransport._check_accept_headers..s1]]*j++,<==]]]]]]r1rrsplitany)r8re accept_header accept_typeshas_jsonhas_sses r2_check_accept_headersz3StreamableHTTPServerTransport._check_accept_headerss++Hb99 VV]=P=PQT=U=UVVV __R^_____]]P\]]]]]  r1c|jdd}d|dddD}td|DS)z2Check if the request has the correct Content-Type.z content-typervc6g|]}|Sr0rrparts r2rzEStreamableHTTPServerTransport._check_content_type..s ]]]tdjjll]]]r1;rrc3,K|]}|tkVdSrj)rrs r2rzDStreamableHTTPServerTransport._check_content_type..s(LL4,,LLLLLLr1r)r8re content_typecontent_type_partss r2_check_content_typez1StreamableHTTPServerTransport._check_content_typesm**>2>> ]]|7I7I#7N7Nq7Q7W7WX[7\7\]]]LL9KLLLLLLr1c>K||\}}|jr=|s:|dtj}|||j|d{VdSn>|r|s:|dtj}|||j|d{VdSdS)zEValidate Accept header based on response mode. Returns True if valid.z3Not Acceptable: Client must accept application/jsonNFzNNot Acceptable: Client must accept both application/json and text/event-streamT)rrIrr NOT_ACCEPTABLEr)r8rerrzrrrs r2_validate_accept_headerz5StreamableHTTPServerTransport._validate_accept_headers 66w??'  (  66I-hugot<<<<<<<<<u   w 22`)H(5'/488 8 8 8 8 8 8 85tr1cKj}|td |||d{VsdS|s5dt j}||||d{VdS|d{V} tj |}nf#tj $rT} dt| t j t}||||d{VYd} ~ dSd} ~ wwxYw tj|} na#t $rT} dt| t j t"}||||d{VYd} ~ dSd} ~ wwxYwt%| jt(o| jjdk} | r_jrW|} | r@| jkr5dt j}||||d{VdSn||d{VsdSt%| jt(sqdt j}||||d{Vt9|} t;| | }||d{VdS| r>| jjr2t| jj d tBn$|j" tFtBt| jj$tKj&tNd j(<j(d j)rt9|} t;| | }||d{V d}23d{V}t%|j*jtVtXzr |j*}n.tZ.d |j*jjd6|r)|}||||d{VnMtZ/ddt j0}||||d{Vnc#tb$rVtZ2ddt j0tf}||||d{VYnwxYw4d{VdS#4d{VwxYwtKj&tjttfd \}j6<fd}ddtndjrtpjini}ts|||} tKj:4d{V}|;||||<| |}||d{Vdddd{Vn#1d{VswxYwYdSdS#tb$rmtZ2d=d{V|=d{V4d{VYdSwxYw#tb$r}tZ2dd|t j0tf}||||d{V|r(|tc|d{VYd}~dSd}~wwxYw)z2Handle POST requests containing JSON-RPC messages.NBNo read stream writer available. Ensure connect() is called first.z=Unsupported Media Type: Content-Type must be application/jsonz Parse error: zValidation error: initialize(Not Found: Invalid or expired session IDrorpprotocolVersionrrz received: z1No response message received before stream closedz.Error processing request: No response receivedzError processing JSON responsezError processing requestcK 4d{V4d{Vd{V23d{V}|}|d{Vt|jjt tzrna6 dddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwYnT#tj $rt dYn)t$rt dYnwxYwt djdd{VdS#t djdd{VwxYw)Nz'SSE stream closed by close_sse_stream()zError in SSE writerzClosing SSE writer)r}rrz isinstancer(rootr#r anyioClosedResourceErrorrrr exceptionrTr\r)rrrfrZrequest_stream_readerr8rts r2 sse_writerzFStreamableHTTPServerTransport._handle_post_request..sse_writerKsdH#4********6K********"&"@"@M^`p"q"qqqqqqqq8M * * * * * * *m-1-D-D]-S-S &7&<&$3l$B$"$"!*%*E !* 8M7L ****************************************************** !4PPP %NOOOOO$@@@(()>?????@ %9:::044ZFFF";;JGGGGGGGGGGG %9:::044ZFFF";;JGGGGGGGGGGsC C B+BAB+C+ B5 5C8B5 9C<C  CC CC F )D1 F #D1.F0D11FAGno-cache, no-transform keep-alivez Cache-Control Connectionrcontentdata_sender_callablerzSSE response errorzError handling POST requestzError handling POST request: )>rCrPrrrr UNSUPPORTED_MEDIA_TYPEbodyjsonloadsJSONDecodeErrorr/ BAD_REQUESTrr!model_validaterrrrr"rrHrr_validate_request_headersrACCEPTEDrrrzparamsrrrMCP_PROTOCOL_VERSION_HEADERrwrcreate_memory_object_streamr'rSrIr(r#r rrrINTERNAL_SERVER_ERRORrrrrdictrTrrrcreate_task_group start_soonrsr)r8rrerrzr^rr raw_messageer(is_initialization_requestrequest_session_idrqsession_messagerrsse_stream_readerrrtgerrrfrZrrts` @@@@r2rz2StreamableHTTPServerTransport._handle_post_requests ) >abb bN 55gudKKKKKKKK ++G44 66S5hugt444444444!''''''D "j.. '   667Os1vv7O7OQ[Qgituuhugt444444444  (7 DD"   661Q11*" hugt444444444 7<88`W\=PT`=` &) & )-)=)=g)F)F&*.@DDW.W.W#'#>#>F&0$$'hugt<<<<<<<<<99'4HHHHHHHH glN;; 55'hugt4444444441III"08"L"L"Lkk/222222222-b181DbGL'++,=?YZZ[[[_(()DF`aa W\_--J050QR^0_`a0b0bD !* -$($9*$Ea$H !,j D0III"08"L"L"Lkk/222222222%D(,$0E[[[[[[[m%m&;&@/T`B`aa[/N#O#O&hugt<<<<<<<<<< %XYYY#'#>#>L&<$$'hugt<<<<<<<<< 999$$%EFFF#::2"8&  H #(5'488888888888977 CCCCCCCCCCC$77 CCCCCCCCCC8=7XY]^acf^fYg7hij7k7k4!#48I(4HHHHHHHHHB&>".$4HLGZb-t/BCC`b  /-)3# D$688;;;;;;;B hwEEE*.*F*FwPWYceu*v*v$kk/::::::::: ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;; !DDD$$%9:::+22444444444+2244444444477 CCCCCCCCCCCC D       : ; ; ;225550H (5'400 0 0 0 0 0 0 0 2kk)C..111111111 FFFFF s[ A[ [ %B:9[ :D A D[ D[ !D65[ 6 FA F [ FB [ ![ B [ C<[ R* P0CR*)T**AT T* T  T* [ *UA>[ YA X=+Y= YY Y YA3[ [ [  [ ]!B]]!cZ Kj}|td|\}}|s?dtj}||j|j|d{VdS||d{VsdS|j tx}r |||d{VdSddtd}jrj|t<t jvr?dtj}||j|j|d{VdSt'jt*t,t,fd\ } fd } t/| | | } ||j|j|d{VdS#t0$rrt2d  d{V| d{Vt d{VYdSwxYw) a Handle GET request to establish SSE. This allows the server to communicate to the client without the client first sending data via HTTP POST. The server can send JSON-RPC requests and notifications on this stream. Nrz4Not Acceptable: Client must accept text/event-streamrrrz4Conflict: Only one SSE stream is allowed per sessionrcK tjtdjt<jtd}4d{V|4d{V|23d{V}|}|d{V86 dddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwYn*#t$rt dYnwxYwt d td{VdS#t d td{VwxYw)NrrzError in standalone SSE writerzClosing standalone SSE writer) rrr'rSrcrrzrrrrr)standalone_stream_readerrrr8rts r2standalone_sse_writerzPStreamableHTTPServerTransport._handle_get_request..standalone_sse_writers( D9>8YZf8ghi8j8j%n5+/+@+PQR+S(, A A A A A A A A.F A A A A A A A A/GAAAAAAAm&*%<%<]%K%K /44Z@@@@@@@@@@0H/G A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A A C C C  !ABBBBB C <===33NCCCCCCCCCCC <===33NCCCCCCCCCCs~A C C B)B#3B)C ) B3 3C 6B3 7C :C CCCCE$DEDEabb b//88 7 22F)H(7='/4@@ @ @ @ @ @ @ @ F33GTBBBBBBBB  F$O//0DEE E= %%mWdCC C C C C C C C F6&,     A-1-@G) * T2 2 222F#H(7='/4@@ @ @ @ @ @ @ @ F05/PQUVY[^V^Q_/`ab/c/c,, D D D D D D2'%!6     @(7='/4@@ @ @ @ @ @ @ @ @ @ @ @ @   ? @ @ @#**,, , , , , , , ,#**,, , , , , , , ,//?? ? ? ? ? ? ? ? ? ? ?  @sF..A8H*)H*cK|js?|dtj}||j|j|d{VdS|||d{VsdS|d{V|dtj }||j|j|d{VdS)z8Handle DELETE requests for explicit session termination.z5Method Not Allowed: Session termination not supportedN) rHrr METHOD_NOT_ALLOWEDrrr terminaterOK)r8rerzrs r2rz4StreamableHTTPServerTransport._handle_delete_requests" 22G-H(7='/4@@ @ @ @ @ @ @ @ F33GTBBBBBBBB  Fnn--  M  hw}got<<<<<<<<<< > >!%+F!G!G 22R>NRRR=);==>&H (7='/4@@ @ @ @ @ @ @ @5tr1r:c KjsdS ddtd}jrj|t<|jt t tj tttfd\ } fd}t|||} ||j |j|d{Vn*#t$rt dYnwxYw d{V|d{VdS# d{V|d{VwxYw#t$rat d d t(jt,}||j |j|d{VYdSwxYw) z Replays events that would have been sent after the specified event ID. Only used when resumability is enabled. NrrrrcK 4d{Vdtddf fd }|d{V}|r|jvrɉ j|<| d{Vt jtdj|<j|d}|4d{V|23d{V}|} |d{V86 dddd{Vn#1d{VswxYwYdddd{VdS#1d{VswxYwYdS#t j $rt dYdSt$rt dYdSwxYw)Nrr6clK|}|d{VdSrj)rrz)rrr8rts r2 send_eventzWStreamableHTTPServerTransport._replay_events..replay_sender..send_eventsF)-)@)@)O)OJ"3"8"8"D"DDDDDDDDDDr1rrz.Replay SSE stream closed by close_sse_stream()zError in replay sender)r'r=rSrTr}rrrrzrrrrr) r#r5 msg_readerrrrJr:replay_protocol_versionr8rts r2 replay_senderzCStreamableHTTPServerTransport._replay_events..replay_senders ?0MMMMMMMMELETEEEEEEE +6*I*I-Yc*d*d$d$d$d$d$d$d %M$:O)O)OBSD4Y?#'"@"@L]_v"w"wwwwwwww@E?`am?nop?q?qD1)<)-)>y)I!)LJ(2MMMMMMMM;E!M!M!M!M!M!M!M-151H1H1W1WJ*;*@*@*L*L$L$L$L$L$L$L$L$L>>>>>?skD4B!D!.C=1C)73C=+D!= D D! D D!D4! D++D4.D+/D44)F #FFrzError in replay responsezError replaying events)rQrrHrrrrrrrrr/rrrrrrrrr rr) r8r:rerzrrr&rrJr%rts `` @@@r2rz,StreamableHTTPServerTransport._replay_eventsms '   FI A!9* 0G " E151D-.'.o&9&9:UWq&r&r #493TUYZ]_bZbUc3def3g3g 0 0! ?! ?! ?! ?! ?! ?! ?! ?! ?H+)%2H  1hw}gotDDDDDDDDDD = = =  !;<<<<< =(..000000000'..00000000000(..000000000'..0000000000 A A A   5 6 6 622(0H (7='/4@@ @ @ @ @ @ @ @ @ @ @ AsIBE!*CD($C/,D(.C//D(24E!(6EE!!A'G  G cKtjttzd\}}tjtd\}|_|__|_tj4d{V}fd}| | ||fWVtj D]} |d{Vj  |d{V|d{Vd{V|d{Vn4#t$r(}t d|Yd}~nd}~wwxYw#tj D]} |d{Vj  |d{V|d{Vd{V|d{Vw#t$r'}t d|Yd}~wd}~wwxYwxYwdddd{VdS#1d{VswxYwYdS)zContext manager that provides read and write streams for a connection. Yields: Tuple of (read_stream, write_stream) for bidirectional communication rNc K 23d{V}|j}d}t|jttzrt |jj}|}nF|j?t|jtr%|jj t |jj }||nt}d}j rAj ||d{V}td|d||jvrz j|dt#||d{V/#t$jt$jf$rj|dYhwxYwtd|d6dS#t$j$rBjrtdYdStdYdSt0$rtdYdSwxYw) NzStored z from rzRequest stream z not found for message. Still processing message as the client might reconnect and replay.zRead stream closed by clientz3Unexpected closure of read stream in message routerzError in message router)r(rrr#r r/rwrqrrelated_request_idrcrQr9rrrSrzr'rBrokenResourceErrorrr\rUrr)rr(target_request_id response_idrequest_stream_idr)r8write_stream_readers r2message_routerz=StreamableHTTPServerTransport.connect..message_routers6@1D.......o"1"9,0)%glOl4RSSa*-glo*>*>K1<--,4@ * / 8 5!!A !0 8 K W03O4L4_0`0`-ARA^,=,=dr) $(,X-1->-J-JK\^e-f-f'f'f'f'f'f'fH"LL)V8)V)VCT)V)VWWW,0EEES&*&;??????@sLFFC,F::D64F66E0,F/E00$F0H  H &#H  H r)rrrrrCrDrFrErrrrSrrrrrr) r8read_stream_writer read_stream write_streamrr/r5rr.s ` @r2connectz%StreamableHTTPServerTransport.connectsr$+0*KN]fLf*ghi*j*j'K,1,Mn,]^_,`,`) )$6 '$7!)*,,N @N @N @N @N @N @N @7 @7 @7 @7 @7 @7 @t MM. ) ) ) @!</////!%d&;&@&@&B&B!C!CCCI77 BBBBBBBBBB%++---@,33555555555%,,.........-44666666666&--////////// @@@LL!>1!>!>????????@"&d&;&@&@&B&B!C!CCCI77 BBBBBBBBBB%++---@,33555555555%,,.........-44666666666&--////////// @@@LL!>1!>!>????????@YN @N @N @N @N @N @N @N @N @N @N @N @N @N @N @N @N @N @N @N @N @N @N @N @N @N @N @N @N @N @sJ9#F'*AJ9A(E20J92 F$<FJ9F$$J9'AJ#A(I/.J#/ J 9J J#J J##J99 KK)FNNNrr)=r*r+r,r-rCr rrr.rDr rErFrr/boolr4rintrVpropertyrYr$rardr!rrsrr r}rr rrrrrr'rrrrrrtuplerrrrrrr rrrrrrrr3r0r1r2rBrB{sVZ/0JKdRYYYQUL+NY,FG$NUUUCGM).9D@GGGMQ3NCdJQQQ**** */)->B%) ,!,!d ,!#',! $& ,! 5t; ,! d ,! ,!,!,!,!\ t   X #9#####8....&::: :  :  ::::@442$sCx.A4 4  4444<*)-        c3h$&       D#--)-   (4/   c3h$&       (:w:3:::::  c3h     < ===QU==== wdtwdt:tPT,RA#RARAtRAX\RARARARAhi@  %ny&@ A "> 2 4    i@i@i@i@i@i@r1rB)Ir-rloggingreabcrrcollections.abcrrr contextlibr dataclassesr httpr typingr ranyio.streams.memoryr r pydanticr sse_starletterstarlette.requestsrstarlette.responsesrstarlette.typesrrrmcp.server.transport_securityrrmcp.shared.messagerrmcp.shared.versionr mcp.typesrrrrrrr r!r"r#r$ getLoggerr*rrrrrrrccompilerNr/r>r?r'r@r4rBr0r1r2rLs"  ########??????????******!!!!!! RRRRRRRR$$$$$$------&&&&&&((((((0000000000EDDDDDDD::::::                            8 $ $)4&'& RZ 122            ,489 # # # # # # # # Lp@p@p@p@p@p@p@p@p@p@r1