+ wiJ*Rt^RIt^RIHt^RIHt^RIHt^RIH t H t ^RI t ^RI H t Ht^RIHt^RIHt^R IHt^R IHt^R IHtHtHt^RIHt^R IHtHt^R I H!t!H"t"]PF!]$4t%!RR4t&R#)a SSE Server Transport Module This module implements a Server-Sent Events (SSE) transport layer for MCP servers. Example usage: ``` # Create an SSE transport at an endpoint sse = SseServerTransport("/messages/") # Create Starlette routes for SSE and message handling routes = [ Route("/sse", endpoint=handle_sse, methods=["GET"]), Mount("/messages/", app=sse.handle_post_message), ] # Define handler functions async def handle_sse(request): async with sse.connect_sse( request.scope, request.receive, request._send ) as streams: await app.run( streams[0], streams[1], app.create_initialization_options() ) # Return empty response to avoid NoneType error return Response() # Create and run Starlette app starlette_app = Starlette(routes=routes) uvicorn.run(starlette_app, host="127.0.0.1", port=port) ``` Note: The handle_sse function must return a Response to avoid a "TypeError: 'NoneType' object is not callable" error when client disconnects. The example above returns an empty Response() after the SSE connection ends to fix this. See SseServerTransport class documentation for more details. N)asynccontextmanager)Any)quote)UUIDuuid4)MemoryObjectReceiveStreamMemoryObjectSendStream)ValidationError)EventSourceResponse)Request)Response)ReceiveScopeSend)TransportSecurityMiddlewareTransportSecuritySettings)ServerMessageMetadataSessionMessagecaa]tRt^@toRtR V3RlV3Rlllt]V3RlRl4tV3RlRltV3Rlt R t Vt V;t #) SseServerTransporta SSE server transport for MCP. This class provides _two_ ASGI applications, suitable to be used with a framework like Starlette and a server like Hypercorn: 1. connect_sse() is an ASGI application which receives incoming GET requests, and sets up a new SSE stream to send server messages to the client. 2. handle_post_message() is an ASGI application which receives incoming POST requests, which should contain client messages that link to a previously-established SSE session. c8<V^8dQhRS[RS[R,RR/#)endpointsecurity_settingsNreturn)strr)format __classdict__s"B/home/ubuntu/.local/lib/python3.14/site-packages/mcp/server/sse.py __annotate__SseServerTransport.__annotate__Ps/'R'R'R9RUY9Y'Rei'Rc D<\SV`4RV9g&VPR4'gRV9gRV9d\RV R24hVPR4'g RV,pWn/Vn\ V4Vn\PRV 24R #) a? Creates a new SSE server transport, which will direct the client to POST messages to the relative path given. Args: endpoint: A relative path where messages should be posted (e.g., "/messages/"). security_settings: Optional security settings for DNS rebinding protection. Note: We use relative paths instead of full URLs for several reasons: 1. Security: Prevents cross-origin requests by ensuring clients only connect to the same origin they established the SSE connection with 2. Flexibility: The server can be mounted at any path without needing to know its full URL 3. Portability: The same endpoint configuration works across different environments (development, staging, production) Raises: ValueError: If the endpoint is a full URL instead of a relative path z://z//?#zGiven endpoint: z] is not a relative path (e.g., '/messages/'), expecting a relative path (e.g., '/messages/')./z.SseServerTransport initialized with endpoint: N) super__init__ startswith ValueError _endpoint_read_stream_writersr _securityloggerdebug)selfrr __class__s&&&rr'SseServerTransport.__init__Ps.  H  3 3D 9 9SH_PSW_P_"8*-BB  ""3''X~H!$&!45FG EhZPQr!c,<V^8dQhRS[RS[RS[/#rscopereceivesendrr r)rrs"rrr zs'M.M.uM.wM.dM.r!c~a a aaaaa"VR,R8wd!\PR4\R4h\W4pVPP VRR7GRjxL pV'dV!WV4GRjxL \R4h\P R4\P!^4wo p\P!^4wpo\4oS VPS&\P R S 24VPR R 4pVPR 4VP,p \V 4 R SP 2o \P\ \"\$3,,!^4wooV VV3Rlo\P&!4;_uu_4GRjxL p RV VVVV3Rllp \P R4V P)WW#4\P R4Wg35xRRR4GRjxL R#ELELLkL +GRjxL 'giR#;i5i)typehttpz%connect_sse received non-HTTP requestz)connect_sse can only handle HTTP requestsFis_postNzRequest validation failedzSetting up SSE connectionzCreated new session with ID: root_pathr%z ?session_id=cz<"\PR4S;_uu_4GRjxL S;_uu_4GRjxL SPRRRS/4GRjxL \PRS 24SRjxL p\PRV 24SPRRRVPP RRR 7/4GRjxL K\LLL~L]LD`RRR4GRjxL M +GRjxL 'giM;iRRR4GRjxL R# +GRjxL 'giR#;i5i) zStarting SSE writerNeventrdatazSent endpoint event: zSending message via SSE: messageT)by_alias exclude_none)r-r.r6rBmodel_dump_json)session_messageclient_post_uri_datasse_stream_writerwrite_stream_readers r sse_writer2SseServerTransport.connect_sse..sse_writers LL. /(((*=*=*=',,gz6K_-`aaa 45I4JKL-@/LL#<_*=*=*=*=*=((((((s$D;CD;DC DC/ C C/ 6C :C;C >A C/ C C/ D;DC/ C C/ C/  D(C+)D/D 5C86 D D D D;DD;D8 $D'% D8 0D8 2 D;c<V^8dQhR\R\R\/#r3r7)rs"rr4SseServerTransport.connect_sse..__annotate__s& K Ke Kg KT Kr!c<"\SSR7!WV4GRjxL SP4GRjxL SP4GRjxL \P!RS 24R#LOL9L#5i)z The EventSourceResponse returning signals a client close / disconnect. In this case we close our side of the streams to signal the client that the connection has been closed. )contentdata_sender_callableNzClient session disconnected )r acloseloggingr.)r4r5r6read_stream_writer session_idsse_stream_readerrJrIs&&&rresponse_wrapper8SseServerTransport.connect_sse..response_wrapperso *2CZdeD)//111)00222 >wPU>VV  6 6 689 9 01+0*K*KA*N'K,1,M,Ma,P) )W 0B!!*- 4ZLAB IIk2. (1'7'7'>wPT>UU '== ="//33LA  # NN@ A 8cJH!%$77 7 8"23J LL.zl; < **..z: NN>tDG LL5gY? @)A(D :?:KLMJC8ut,,,kk/***WV= 8  8 NN:;K:LM N 4#FH!%$777 7 88#     6 7 9sKH540 0 0++c" " "    -*sAKH K KHAK.H/K4$H "K;1K,I-KIK"7IA K"K#K;K<KKK rs^%N* R$-&(00E   8 $y+y+r!