i d Z ddlZddlZddlZddlmZmZ ddlmZm Z m
Z
ddl m Z ddl
mZ ddlmZ ddlmZ ddlZdd lmZmZ dd
lmZ dd lmZ dd lm Z dd
l m Z ddl m 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/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6 ejn e8 Z9dZ:dZ;dZdZ? ej d ZAeBZCeBZDe G d d ZEe
eEge d f ZF G d d e ZG G d d ZHy) 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]+$c 0 e Zd ZU dZeed< dZedz ed< y) EventMessagezM
A JSONRPCMessage with an optional event ID for stream resumability.
messageNevent_id)__name__
__module__ __qualname____doc__r! __annotations__r) str Z/root/aria/mcps/aria-brain/venv/lib/python3.12/site-packages/mcp/server/streamable_http.pyr' r' H s HcDj r1 r' c X e Zd ZdZedededz defd Zedede dedz fd Z
y)
EventStorez?
Interface for resumability support via event storage.
stream_idr( Nreturnc K yw)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 )selfr5 r( s r2 store_eventzEventStore.store_eventZ s
last_event_id
send_callbackc K yw)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 )r8 r; r< s r2 replay_events_afterz EventStore.replay_events_afterh s
r: ) r* r+ r, r- r StreamIdr! EventIdr9
EventCallbackr> r0 r1 r2 r4 r4 U sj
8
nt>S
X_
%
D
r1 r4 c
H e Zd ZU dZdZeeez dz ed< dZ e
eez dz ed< dZ ee dz ed< dZ e
e dz ed< e
ed< d6dedz d ed
edz d edz d edz d
df dZed
efd Zded
dfdZd7dZdedededed
ef
dZdedee ee f ded
dfdZ e dfdede ded e eef dz d
e!f
d Z"e jF dfd edz de d e eef dz d
e!fd Z$ded
edz fd Z%d!e&d
e eef fd"Z'ded
dfd#Z(d$e)d%e*d&e+d
dfd'Z,ded
e-eef fd(Z.ded
efd)Z/ded$e)d&e+d
efd*Z0d$e)ded%e*d&e+d
df
d+Z1ded&e+d
dfd,Z2ded&e+d
dfd-Z3d7d.Z4ded&e+d
dfd/Z5ded&e+d
efd0Z6ded&e+d
efd1Z7ded&e+d
efd2Z8d3eded&e+d
dfd4Z9e:d
e;e-e
eez ee f df fd5 Z.Z `a a ,(@% '45FG -
]_ 48r1 c | j S )z7Check if this transport has been explicitly terminated.)rV r8 s r2
is_terminatedz+StreamableHTTPServerTransport.is_terminated s r1
request_idc | j j |d }|r|j || j v r?| j j | \ }}|j |j yy)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)rU popcloserT )r8 r\ writer send_streamreceive_streams r2 close_sse_streamz.StreamableHTTPServerTransport.close_sse_stream sp $ ))--j$? LLN .. .*.*?*?*C*CJ*O 'K " /r1 c . | j t y)aF Close 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)rc GET_STREAM_KEYrZ s r2 close_standalone_sse_streamz9StreamableHTTPServerTransport.close_standalone_sse_stream s "
n-r1 r( requestprotocol_versionc j r!|dk\ r d fd }d fd }t ||| }n t | }t || S )aJ Create 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-25c 0 K j y wN)rc )r\ r8 s r2 close_stream_callbackzTStreamableHTTPServerTransport._create_session_message..close_stream_callback s %%j1s c . K j y wrl )rf rZ s r2 close_standalone_stream_callbackz_StreamableHTTPServerTransport._create_session_message..close_standalone_stream_callback s 002s )request_contextrc rf rp metadatar6 N)rR r r )r8 r( rg r\ rh rm ro rs s ` ` r2 _create_session_messagez5StreamableHTTPServerTransport._create_session_message sN !1\!A
2
3 - '!6,LH -WEH g99r1 sse_stream_writerc K | j sy|dk ry| j j t | d d{ }|dd}| j | j |d< |j | d{ y7 >7 w)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.
Nrj )iddataretry)rR r9 r/ rS send)r8 r\ rv rh priming_event_id
priming_events r2 _maybe_send_priming_eventz7StreamableHTTPServerTransport._maybe_send_priming_event s l * !%!2!2!>!>
O "
6Fr.R
+%)%9%9M' " $$]333
4s! # #G , 6:6I6I 2 3 & %
* *Dt * L#$
r1 response_messagec dt i}|r|j | | j r| j |t < t |r|j dd nd|| S )z,Create a JSON response from a JSONRPCMessager Tr Nr )r r rI r r r )r8 r r r r s r2 _create_json_responsez3StreamableHTTPServerTransport._create_json_responseG sh +,=> # #G , 6:6I6I 2 3Rb , ,d , Nhl#$
r1 c @ |j j t S )z,Extract the session ID from request headers.)r getr )r8 rg s r2 _get_session_idz-StreamableHTTPServerTransport._get_session_id[ s ""#899r1
event_messagec | d|j j dd d}|j r|j |d< |S )z2Create event data dictionary from an EventMessage.r( Tr )eventrz ry )r( r r) )r8 r
event_datas r2 _create_event_dataz0StreamableHTTPServerTransport._create_event_data_ sI !))994VZ9[
! ! , 5 5Jt r1 c K || j v rn | j | d j d{ | j | d j d{ | j j |d yy7 J7 $# t $ r t j d Y Bw xY w# | j j |d w xY ww)z/Clean up memory streams for a given request ID.r N z4Error closing memory streams - may already be closed)rT aclose Exceptionloggerdebugr^ )r8 r\ s r2 _clean_up_memory_streamsz6StreamableHTTPServerTransport._clean_up_memory_streamsl s .. .
<++J7:AACCC++J7:AACCC %%))*d; / DC
U ST
U
%%))*d;sV C #B B 'B B B " C B B B%"B( $B%%B( ( CC scopereceiver| c K t || }|j dk( }| j j || d{ }|r |||| d{ y| j r3| j dt j } |||| d{ y|j dk( r | j |||| d{ y|j dk( r| j || d{ y|j dk( r| j || d{ y| j || d{ y7 7 7 7 z7 R7 *7 w)z6Application entry point that handles all HTTP requestsPOST)is_postNz&Not Found: Session has been terminatedGETDELETE) r methodrH validate_requestrV r r
NOT_FOUND_handle_post_request_handle_get_request_handle_delete_request_handle_unsupported_request)r8 r r r| rg r r responses r2 handle_requestz,StreamableHTTPServerTransport.handle_requestz s6 %) ..F* #~~ > >wPW > XX 6 6 6 228$$H 5'40 0 0 >>V #++E7GTJ J J
^^u
$**7D9 9 9
^^x
'--gt< < <227DA A A+ Y 6
1
K 9 < As{ E D6+E =D8>)E 'D:()E D<E ,D>-E 4E 6E 8E :E <E >E c |j j dd }|j d D cg c] }|j }}t d |D }t d |D }||fS c c}w )z6Check if the request accepts the required media types.acceptrx ,c 3 F K | ] }|j t y wrl )
startswithr .0
media_types r2 zFStreamableHTTPServerTransport._check_accept_headers.. s _Jz,,->?_ !c 3 F K | ] }|j t y wrl )r CONTENT_TYPE_SSEr s r2 r zFStreamableHTTPServerTransport._check_accept_headers.. s ]*j++,<=]r r r splitstripany)r8 rg
accept_headerr accept_typeshas_jsonhas_sses r2 _check_accept_headersz3StreamableHTTPServerTransport._check_accept_headers ss ++Hb9
=J=P=PQT=UVz
((*V V_R^__]P\]] Ws A1c |j j dd }|j d d j d D cg c] }|j }}t d |D S c c}w )z2Check if the request has the correct Content-Type.z content-typerx ;r r c 3 . K | ]
}|t k( y wrl )r )r parts r2 r zDStreamableHTTPServerTransport._check_content_type.. s L4,,Ls r )r8 rg content_typer content_type_partss r2 _check_content_typez1StreamableHTTPServerTransport._check_content_type sf **>2> 7C7I7I#7Nq7Q7W7WX[7\ ]tdjjl ] ]L9KLLL ^s A-c V K | j | \ }}| j r@|s=| j dt j } |||j
| d{ yy|r|s=| j dt j } |||j
| d{ yy7 H7 w)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)r rJ r r
NOT_ACCEPTABLEr )r8 rg r r| r r r s r2 _validate_accept_headerz5StreamableHTTPServerTransport._validate_accept_header s 6 6w ?' ( ( 66I -- ugoot<<< w22`))H 5'//48 8 8 =
9s% AB) B% AB) B' B)'B)c K j }| t d j ||| d{ sy j | s3 j dt
j } |||| d{ y|j d{ } t j | } t j | }
t% |
j& t( xr |
j& j* dk( } | ra j, rp j/ | } | r]| j, k7 rN j dt
j0 } |||| d{ y j3 || d{ syt% |
j& t( se j5 dt
j6 } |||| d{ t9 | }
t; |
|
}|j= | d{ y| rI|
j& j> r3t |
j& j> jA d
tB n#|jD jA tF tB t |
j& jH tK jL tN d jP < jP d jR r7t9 | }
t; |
|
}|j= | d{ d}2 3 d{ }t% |jT j& tV tX z r|jT } n7tZ j] d
|jT j& j* y|r$ j5 | } |||| d{ nGtZ j_ d j dt
j` } |||| d{ ji d{ ytK jL tj t t f d \ } jl < fd}ddtn d j, rtp j, ini }ts ||| } tK jt 4 d{ }|jw |||| jy |
| }|j= | d{ ddd d{ yy7 7 y7 c# t j $ rN} j dt | t
j t } |||| d{ 7 Y d} ~ yd} ~ ww xY w# t $ rN} j dt | t
j t" } |||| d{ 7 Y d} ~ yd} ~ ww xY w7 a7 I7 7 7 7 6 P7 07 # tb $ rQ tZ je d j dt
j` tf } |||| d{ 7 Y Bw xY w7 2# ji d{ 7 w xY w7 7 {7 n# 1 d{ 7 sw Y ~xY w# tb $ rd tZ je d j{ d{ 7 |j{ d{ 7 ji d{ 7 Y yw xY w# tb $ r}tZ je d j d| t
j` tf } |||| d{ 7 |r#|j= tc | d{ 7 Y d}~yd}~ww xY ww)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 IDrq rr protocolVersionr r z
received: z1No response message received before stream closedz.Error processing request: No response receivedz Error processing JSON responsezError processing requestc K 4 d { 4 d { j d { 2 3 d { } j | }j | d { t | j j
t t z s_ d d d d { d d d d { t j d j j d j! d { y 7 7 7 7 7 6 w7 k# 1 d { 7 sw Y {xY w7 r# 1 d { 7 sw Y xY w# t j $ r t j d Y t $ r t j d Y w xY w7 # t j d j j d j! d { 7 w xY ww)Nz'SSE stream closed by close_sse_stream()zError in SSE writerzClosing SSE writer)r r r|
isinstancer( rootr# r anyioClosedResourceErrorr r r exceptionrU r^ r )r r rh r\ request_stream_readerr8 rv s r2
sse_writerzFStreamableHTTPServerTransport._handle_post_request..sse_writerM s H#4 * *6K * *"&"@"@M^`p"q q q 8M
*
*m-1-D-D]-S
&7&<&$>$3l$B$" %* * * * *, %9: 0044ZF " ; ;J GGG1* * q
* !I 8M * * * * * * * * !44 P %NO$ @ (()>?@
H %9: 0044ZF " ; ;J GGGs3 G D= DD= D(DD(DDDD
D
D
&D&D
'/DD D(#D$D(( D= 3D&4D= 8AG =F
>G D= D(D D
D
DD(D# DD# D(&D= (D:.D1 /D:6D= =(F%F ' FF FF
G AGGGG no-cache, no-transform
keep-alivez
Cache-Control
Connectionr contentdata_sender_callabler zSSE response errorzError handling POST requestz Error handling POST request: )>rD rQ r r r r
UNSUPPORTED_MEDIA_TYPEbodyjsonloadsJSONDecodeErrorr/ BAD_REQUESTr r! model_validater r r r r" r rI r r _validate_request_headersr ACCEPTEDr r r| paramsr r r MCP_PROTOCOL_VERSION_HEADERry r create_memory_object_streamr' rT rJ r( r# r r r r INTERNAL_SERVER_ERRORr r r r dictrU r r r create_task_group
start_soonru r )r8 r rg r r| r` r r raw_messageer( is_initialization_requestrequest_session_idrs session_messager r sse_stream_readerr r tgerrrh r\ r rv s ` @@@@r2 r z2StreamableHTTPServerTransport._handle_post_request s )) > ab bN 55gudKKK ++G4 66S 55 ugt444 ! 'D
"jj .
(77 D 7<< 8`W\\=P=PT`=`
& )&&)-)=)=g)F& *.@DDWDW.W#'#>#> F & 0 0$ 'ugt <<< 99'4HHH gllN; 55 '' ugt444 1I"08"L kk/222 - 1D1D GLL''++,=?YZ[ __(()DF`a
W\\__-J050Q0QR^0_`a0bD ! !* -$($9$9*$Ea$H !,,0I"08"L kk/222%D (,$ 0E [ [m%m&;&;&@&@/T`B`a/N#O &ugt <<< %XY#'#>#> L & < <$ 'ugt <<< 77
CCC 8=7X7XY]^acf^fYg7hij7k4!#4 8I((4H HB &>".$4 HLGZGZ-t/B/BC`b / -)3 # D $ 6 6 8 ; ;B
hwE*.*F*FwPWYceu*v $kk/ ::: ; ; ;o L 5 ( ''
66 s1vh7OQ[QgQgitu ugt444
#
66(Q1 **"
ugt444
4 =H 5
3. 3[/D = = 9$$%EF # : :2"88& H
#5'48889 D$77
CCCn; ; ; ; ; ;
! D$$%9:+22444+22444 77
CCC D
: ;22/u500 H
5'40 0 0 kk)C.111
s ]-[" S2[" ]->[" <S5=[" ]-[" S8[" S; 1U B[" V9[" ]- [" 3V<4[" 8]-9A[" V?1[" 2W3[" 7]-8D[" ;W<[" W W W
W
BW W AW &W'W +[" ?X1 [" ]-A<[" Y2 YY2 =Y Y Y Y2 +Y,Y2 0]-2[" 5[" 8[" ;U >U U
U[" ]-U [" V6(>V1&V)'V1,[" 0]-1V66[" <[" ?[" [" [" W W W W AX.$X'%X.*X4 -X..X4 1[" 4Y Y
Y[" Y2 Y Y2 Y/"Y% #Y/*Y2 21[ #Z&$[ <Z?=[ [[ [" ]- [ [" " ]*+A
]%5\86$]%] ]% ]-%]**]-c ~ K j }| t d j | \ }}|sG j dt j
} ||j |j | d{ y j || d{ sy|j j t x}r j ||| d{ yddt d} j r j |t < t j" v rG j dt j$ } ||j |j | d{ yt' j( t* t, t, f d \ } fd }
t/ | |
|
} ||j |j | d{ y7 H7 07 7 u7 # t0 $ rh t2 j5 d j7 d{ 7 | j7 d{ 7 j9 t d{ 7 Y yw xY ww) 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.
Nr z4Not Acceptable: Client must accept text/event-streamr r r z4Conflict: Only one SSE stream is allowed per sessionr c K t j t d j t < j t d } 4 d { | 4 d { | 2 3 d { }j | }j
| d { 47 E7 <7 37 6 d d d d { 7 n# 1 d { 7 sw Y nxY wd d d d { 7 n# 1 d { 7 sw Y nxY wn$# t $ r t j d Y nw xY wt j d j t d { 7 y # t j d j t d { 7 w xY ww)Nr r z Error in standalone SSE writerz Closing standalone SSE writer) r r r' rT re r r| r r r r r )standalone_stream_readerr r r8 rv s r2 standalone_sse_writerzPStreamableHTTPServerTransport._handle_get_request..standalone_sse_writer se
D 9>8Y8YZf8ghi8j%%n5+/+@+@ +PQR+S(,
A
A.F
A
A/G A Am &*%<%<]%K
/ 4 4Z @@@
A
AA A 0H
A
A
A
A
A
A
A
A
A
A
C !AB
C <=33NCCC <=33NCCCs
E<A C, BC, CBC B/ B $B
%B (&B/B
B/C, CB B/ B/ C(B+)C/C 5B86C =C C, CC, C( C C($C, +E , D
E D
E -E<=E >E<.E92E53E99E<r z Error in standalone SSE response) rD rQ r r r
r r r r r r LAST_EVENT_ID_HEADER_replay_eventsr rI r re rT CONFLICTr r r r/ r r r r r r ) r8 rg r| r` _r r r; r r r rv s ` @r2 r z1StreamableHTTPServerTransport._handle_get_request s% )) > ab b //8
722F))H 7=='//4@ @ @ 33GTBBB $OO / /0D E E= E%%mWdC C C 6& ,
-1-@-@G) * T 2 2 222F##H 7=='//4@ @ @ 05/P/PQUVY[^V^Q_/`ab/c,, D2 '%!6
@7=='//4@ @ @C
A C
D$
AN
A @ ? @#**, , ,#**, , ,//? ? ? @s A1H=5F=6H=G :><>>c K | j sy| j | }|sG| j dt j } ||j
|j | d{ y|| j k7 rG| j dt j } ||j
|j | d{ yy7 \7 w)z'Validate the session ID in the request.Tz Bad Request: Missing session IDNFr )rI r r r
r r r r )r8 rg r| r r s r2 r z/StreamableHTTPServerTransport._validate_session@ s "" " 1 1' : "221&&H 7=='//4@ @ @ !4!4 422:$$H 7=='//4@ @ @
A
As% A"C$C%AC:C;CCc : K |j j t }|t }|t vrfdj t }| j
d| dd| z t j } ||j |j | d{ yy7 w)z4Validate the protocol version header in the request.Nz, z+Bad Request: Unsupported protocol version: z. zSupported versions: FT) r r r r r joinr r
r r r )r8 rg r| rh supported_versionsr s r2 r z8StreamableHTTPServerTransport._validate_protocol_version] s #??../JK # 9 #> >!%+F!G 22=>N=OrR();(<=>&&H
7=='//4@ @ @
As BBBBr; c
K j sy ddt d} j r j |t < |j j t t t j t t t f d \
}
fd}t ||| } ||j |j | d{
j% d{ |j% d{ y7 5# t $ r t j# d Y Sw xY w7 C7 -#
j% d{ 7 |j% d{ 7 w xY w# t $ rd t j# d j' d t( j* t, } ||j |j | d{ 7 Y yw xY ww)
z
Replays events that would have been sent after the specified event ID.
Only used when resumability is enabled.
Nr r r r c 4 K 4 d { dt dd f fd } j | d { }|r|j vr j |< j | d { t j t d j |< j | d }|4 d { |2 3 d { }j | } j | d { 4d d d d { y 7 7 7 7 Q7 H7 6 d d d d { 7 0# 1 d { 7 sw Y BxY w7 9# 1 d { 7 sw Y y xY w# t
j $ r t j d Y y t $ r t j d Y y w xY ww)Nr r6 c f K j | }j | d { y 7 wrl )r r| )r r r8 rv s r2
send_eventzWStreamableHTTPServerTransport._replay_events..replay_sender..send_event s+ )-)@)@ )OJ"3"8"8"D D Ds &1/1r r z.Replay SSE stream closed by close_sse_stream()zError in replay sender)r' r> rT rU r r r r r| r r r r r )
r! r5
msg_readerr r rK r; replay_protocol_versionr8 rv s
r2
replay_senderzCStreamableHTTPServerTransport._replay_events..replay_sender s ? 0 M MEL ET E
+6*I*I-Yc*d$d %$:O:O)OBSD 4 4Y ? #'"@"@L]_v"w w w @E?`?`am?nop?qD 1 1) <)-)>)>y)I!)LJ (2 M M;E !M !M-151H1H 1WJ*;*@*@*L$L$L5M M M %e x M!M %M ?s FE D E %D6D9D6.D/AD64D5D68D ;D ?D
D &D )D
*D / E :D4;E ?F E D6D6D6D
D D
D6DD6 D1 %D(&D1 -D64E 6E<D? =EE FE (F3F5 FFFFr zError in replay responsezError replaying events)rR r rI r r r r r r r r r/ r r r r r r r r r
r r ) r8 r; rg r| r r r$ r rK r# rv s `` @@@r2 r z,StreamableHTTPServerTransport._replay_eventss s
'' I A!9 * 0G ""151D1D-. '.oo&9&9:UWq&r # 493T3TUYZ]_bZbUc3def3g 0 0!
? !
?H +)%2 H
1 w}}gootDDD (..000'..000 E
= !;<
= 10 (..000'..000 A 5 622(00 H
7=='//4@ @ @ As GBE! )!D
D D E! "D&#E! :D(;E! ?G D D# D* "D##D* &E! (E! *E >E?E EE E! !A$GGG G
GGc n K t j t t z d \ }}t j t d \ }| _ | _ _ | _ t j 4 d{ } fd}|j | ||f t j j D ] } j | d{ j j |j d{ |j d{ j d{ |j d{ ddd d{ y7 7 7 a7 K7 57 # t $ r"}t j# d| Y d}~Cd}~ww xY w# t j j D ] } j | d{ 7 j j |j d{ 7 |j d{ 7 j d{ 7 |j d{ 7 w # t $ r"}t j# d| Y d}~w d}~ww xY wxY w7 4# 1 d{ 7 sw Y yxY ww)zContext manager that provides read and write streams for a connection.
Yields:
Tuple of (read_stream, write_stream) for bidirectional communication
r Nc f K 2 3 d { } | j }d }t |j t t z r"t |j j }|}n[| j Ot | j t r5| j j t | j j }||nt }d }j r?j j || d { }t j d| d| |j v r6 j | d j! t# || d { Pt j d| d k7 g7 7 &# t$ j& t$ j( f$ r j j+ |d Y w xY w6 y # t$ j( $ r; j, rt j d Y y t j/ d Y y t0 $ r t j/ d Y y w xY ww) NzStored z from r zRequest stream z not found
for message. Still processing message as the client
might reconnect and replay.z Read stream closed by clientz3Unexpected closure of read stream in message routerzError in message router)r( r r r# r r/ ry rs r related_request_idre rR r9 r r rT r| r' r BrokenResourceErrorr r^ rV r r )r r( target_request_id response_idrequest_stream_idr) r8 write_stream_readers r2 message_routerz=StreamableHTTPServerTransport.connect..message_router s 6@1D . . o"1"9"9,0)%gllOl4RS*-glloo*>K 1< - , 4 4 @ * / 8 8 5! !0 8 8 K K W03O4L4L4_4_0` -ARA^,=dr)
$( ,,-1->->-J-JK\^e-f'fH "LL78*FCTBU)V W,0E0EE S&*&;&;?@s H1G F?E2F?C$G 3E54-G ".E9E7E9 G 2F?5G 7E99?F<8G ;F<<G H14H.5H17H. H1 H.+H1-H..H1r )r r r r rD rE rG rF r r r rT r r r r r r ) r8 read_stream_writer read_stream write_streamr r- r5 r r, s ` @r2 connectz%StreamableHTTPServerTransport.connect s $ +0*K*KN]fLf*ghi*j'K,1,M,Mn,]^_,`) ) $6 '$7! ) **, N @ N @7
@t
MM. )
@!<//!%d&;&;&@&@&B!C CI 77 BBBC%%++-@,33555%,,...-44666&--///WN @ N @ N @F C
6.6/ @LL#:1#!>??@ "&d&;&;&@&@&B!C CI 77 BBBC%%++-@,33555%,,...-44666&--/// @LL#:1#!>??@YN @ N @ N @ N @sD A:J5>E/?J5J F)":J E1 J >E;E3E;)E5*E;E7E;E9E; J5)J *J51J 3E;5E;7E;9E;; F&F! J !F&&J );J$G' %!JI,H
I,3H6
4I, I
I,%I(
&I,+J, J 5J
JJ JJ J5 J2&J) 'J2.J5)FNNNrt )=r* r+ r, r- rD r
r r r. rE r rF rG r r/ boolr4 r intrX propertyr[ r$ rc rf r! r ru r r r r r
r r r r r r' r r r r r r tupler r r r r r r r r r r r r r r1 r0 r1 r2 rC rC { s& VZ/0JKdRYQUL+NY,FG$NUCGM).9D@GMQ3NCdJQ**
*/)->B%)
.9d
.9 #'.9 $& .9
5t; .9 d
.9
.9` t #9 # #8.& : : : :
:
:@4 4 2$sCx.A4 4
4< *)-
c3h $&
D #---)-
(4/
c3h $&
(:w :3: : c3h < 2
4
i@ i@r1 rC )Ir- r loggingreabcr r collections.abcr r r
contextlibr dataclassesr httpr
typingr r anyio.streams.memoryr r
pydanticr
sse_starletter starlette.requestsr starlette.responsesr starlette.typesr r r mcp.server.transport_securityr r mcp.shared.messager r mcp.shared.versionr mcp.typesr r r r r r r r! r" r# r$ getLoggerr* r r r r r r re compilerO r/ r? r@ r' rA r4 rC r0 r1 r2 rJ s # ? ? * ! R $ - & ( 0 0 E :
8 $ ) 4 & ' & RZZ 12
, 4 89
#
#
Lv@ v@r1