Ch+SrSSKJr SSKrSSKrSSKJr SSKJr SSK J r SSK J r SSK r SSKJr SS KJr SS KJr SS KJrJrJr SS KJr SS KJrJrJr SSKJ r \RB"\"5r#"SS5r$g)z/StreamableHTTP Session Manager for MCP servers.) annotationsN) AsyncIterator) HTTPStatus)Any)uuid4) TaskStatus)Request)Response)ReceiveScopeSend)Server)MCP_SESSION_ID_HEADER EventStoreStreamableHTTPServerTransport)TransportSecuritySettingsc\rSrSrSrS S Sjjr\RS Sj5rS Sjr S Sjr S Sjr S r g)StreamableHTTPSessionManagerap Manages StreamableHTTP sessions with optional resumability via event store. This class abstracts away the complexity of session management, event storage, and request handling for StreamableHTTP transports. It handles: 1. Session tracking for clients 2. Resumability via an optional event store 3. Connection management and lifecycle 4. Request handling and transport setup Important: Only one StreamableHTTPSessionManager instance should be created per application. The instance cannot be reused after its run() context has completed. If you need to restart the manager, create a new instance. Args: app: The MCP server instance event_store: Optional event store for resumability support. If provided, enables resumable connections where clients can reconnect and receive missed events. If None, sessions are still tracked but not resumable. json_response: Whether to use JSON responses instead of SSE streams stateless: If True, creates a completely fresh transport for each request with no session tracking or state persistence between requests. NcXlX lX0lX@lXPl[ R "5Ul0UlSUl [ R "5Ul SUl g)NF) app event_store json_response statelesssecurity_settingsanyioLock_session_creation_lock_server_instances _task_group _run_lock _has_started)selfrrrrrs \/home/james-whalen/.local/lib/python3.13/site-packages/mcp/server/streamable_http_manager.py__init__%StreamableHTTPSessionManager.__init__8sW&*"!2',jjl#KM !c# URIShvN UR(a [S5eSUlSSS5IShvN [R"5IShvN nXl[ RS5 S7v [ RS5 URR5 SUlURR5 SSS5IShvN gNN!,IShvN (df  N=fN![ RS5 URR5 SUlURR5 f=fNz!,IShvN (df  g=f7f)a Run the session manager with proper lifecycle management. This creates and manages the task group for all session operations. Important: This method can only be called once per instance. The same StreamableHTTPSessionManager instance cannot be reused after this context manager exits. Create a new instance if you need to restart. Use this in the lifespan context manager of your Starlette app: @contextlib.asynccontextmanager async def lifespan(app: Starlette) -> AsyncIterator[None]: async with session_manager.run(): yield NzyStreamableHTTPSessionManager .run() can only be called once per instance. Create a new instance if you need to run again.Tz&StreamableHTTP session manager startedz,StreamableHTTP session manager shutting down) r!r" RuntimeErrorrcreate_task_groupr loggerinfo cancel_scopecancelrclear)r#tgs r$run StreamableHTTPSessionManager.runPs&>>>  "Y!%D  ">**,,!  KK@ A / JK&&(#' &&,,.-,,">>>- JK&&(#' &&,,.-,,,sE<C+E<$C/ E<C-E<$D %E<(E"D  AE" E<%E &E<-E</D5C8 6 DE< AEE" E<"E9(E+ ) E95E<c# URc [S5eUR(aURXU5IShvN gUR XU5IShvN gN N7f)z Process ASGI request with proper session handling and transport setup. Dispatches to the appropriate handler based on stateless mode. Args: scope: ASGI scope receive: ASGI receive function send: ASGI send function Nz6Task group is not initialized. Make sure to use run().)r r)r_handle_stateless_request_handle_stateful_request)r#scopereceivesends r$handle_request+StreamableHTTPSessionManager.handle_requestys]    #WX X >>00F F F//E E E G Es#?A&A"A&A$A&$A&c^^# [RS5 [STRSTRS9m[ R S.SUU4SjjjnTRceTRRU5IShvN TRXU5IShvN TR5IShvN gN7NN 7f)z Process request in stateless mode - creating a new transport for each request. Args: scope: ASGI scope receive: ASGI receive function send: ASGI send function z7Stateless mode: Creating new transport for this requestNmcp_session_idis_json_response_enabledrr task_statusc># TR5IShvN nUup#UR5 TRRUUTRR 5SS9IShvN SSS5IShvN gNfN![ a [ RS5 N6f=fN.!,IShvN (df  g=f7f)NTrzStateless session crashed)connectstartedrr1create_initialization_options Exceptionr+ exception)r@streams read_stream write_streamhttp_transportr#s r$run_stateless_serverTStreamableHTTPSessionManager._handle_stateless_request..run_stateless_servers%--//7,3) ##%B((,,#$>>@"& ' 0// !B$$%@AB0///ssCA?CB*7B)B*B. C9B(:CBB%"B*$B%%B*(C*C0B3 1 C=C)r@TaskStatus[None]) r+debugrrrrTASK_STATUS_IGNOREDr startr9 terminate)r#r6r7r8rLrKs` @r$r46StreamableHTTPSessionManager._handle_stateless_requests  NO6%)%7%7"44  KPJcJc B B+++$$%9:::++EDAAA&&((( ; B )s6A>CB:CB<C4B>5C<C>Cc^^ # [X5nURR[5nUbOUTR;a?TRUn[ R S5 URXU5IShvN gUGc [ R S5 TRIShvN [5Rn[UTRTRTRS9m T RceT TRT R'[ R!SU35 ["R$S.S U U4SjjjnTR&ceTR&R)U5IShvN T RXU5IShvN SSS5IShvN g[+S[,R.S 9n U "XU5IShvN gGNTGN(N_NGN9!,IShvN (df  g=fN+7f) z Process request in stateful mode - maintaining session state between requests. Args: scope: ASGI scope receive: ASGI receive function send: ASGI send function Nz1Session already exists, handling request directlyzCreating new transportr<z'Created new transport with session ID: r?c># TR5IShvN nUup#UR5 TRRUUTRR 5SS9IShvN TR(aeTRTR;aKTR(d:[ RSTRS35 TRTR SSS5IShvN gNN![ a.n[ RSTRSU3SS9 SnANSnAff=f!TR(ahTRTR;aMTR(d;[ RSTRS35 TRTR ffff=fN!,IShvN (df  g=f7f) NFrBzSession z crashed: T)exc_infozCleaning up crashed session z from active instances.) rCrDrr1rErFr+errorr=r is_terminatedr,)r@rHrIrJerKr#s r$ run_serverIStreamableHTTPSessionManager._handle_stateful_request..run_servers-557774;1 #++-Z"&((,, + , $ F F H*/ #/#!/ = =$2$A$ATE[E[$[(6(D(D & $B'5'D'D&EF8%8!" %)$:$:>;X;X$Y7 877 )"LL"*>+H+H*ITUSV W)-)!/ = =$2$A$ATE[E[$[(6(D(D & $B'5'D'D&EF8%8!" %)$:$:>;X;X$Y)E%\!>% 8777sGC5GF47C9)C7*C9.A6F4$ G/F20G7C99 D1$D,'D4,D11D44A;F//F42G4G :F= ; G Gz)Bad Request: No valid session ID provided) status_code)r@rNreturnNone)r headersgetrrr+rOr9rrhexrrrrr=r,rrPr rQr r BAD_REQUEST) r#r6r7r8requestrequest_mcp_session_id transportnew_session_idrZresponserKs ` @r$r55StreamableHTTPSessionManager._handle_stateful_requests%)!(!4!45J!K " -2HDLbLb2b../EFI LLL M**54@ @ @  ! ) LL1 2222!&!>#1-1-?-? $ 0 0&*&<&< "&44@@@HV&&~'D'DE EnEUVWINHaHaZZ>''333&&,,Z888%33EDIIIe322j ;&22H540 0 0 A 3^9Je3222r 1sA7G7;G<.G7*G+G7.CG5G6GGG G7G )G7 G5 G7G7GGG7G2!G$ " G2.G7) r"r!rrr rrrrr)NFFN) rzMCPServer[Any, Any]rzEventStore | Nonerboolrrirz TransportSecuritySettings | None)r]zAsyncIterator[None])r6r r7r r8r r]r^) __name__ __module__ __qualname____firstlineno____doc__r% contextlibasynccontextmanagerr1r9r4r5__static_attributes__r'r$rrs:*.#>B " "'" "  " < "0##&/$&/PFFF F  F2/)/)/) /)  /)bT1T1T1 T1  T1r'r)%rn __future__rrologgingcollections.abcrhttprtypingruuidrr anyio.abcrstarlette.requestsr starlette.responsesr starlette.typesr r r mcp.server.lowlevel.serverr MCPServermcp.server.streamable_httprrrmcp.server.transport_securityr getLoggerrjr+rrrr'r$rs^5") &(00: D   8 $z1z1r'