CjRLSrSSKrSSKrSSKrSSKrSSKJrJr SSKJrJ r SSK J r J r J r JrJrJrJrJrJrJr SSKrSSKJr SSKJr SSKJr SS KJr SS KJrJ r J!r!J"r" SS K#J$r$ SS K%J&r&J'r' \RP"\)5r*\"S S55r+\RX"5r-S\+4Sjr.Sr/SSjr0SSjr1S\!S\!4Sjr2"SS\35r4"SS5r5SSK6J7r7 \7Rp\5l9\5Rp\7l8\\<\=\>\&\ 4r?\\?r@\ \?rA\\A\@4rB"SS\5rCg!\:a \*RwS5 N@f=f)uServer-Sent Events response for Starlette / FastAPI. Intentional divergence from ``starlette.responses.StreamingResponse`` -------------------------------------------------------------------- ``EventSourceResponse`` is modelled on Starlette's ``StreamingResponse`` and re-syncs most of its behaviour (WebSocket denial, ``collapse_excgroups()`` around the task group, ``memoryview`` chunk handling). The following points are deliberate divergences — DO NOT "fix" them without reading the rationale: 1. ASGI ``spec_version >= 2.4`` fast path is NOT adopted. Upstream short-circuits to ``await stream_response(send)`` and converts ``OSError`` into ``ClientDisconnect``, skipping ``listen_for_disconnect``. We keep ``_listen_for_disconnect`` running because it (a) invokes ``client_close_handler_callable`` on disconnect, (b) flips ``self.active = False`` so ``_ping`` and the cooperative shutdown grace loop exit promptly. Adopting the upstream fast path would regress both features. 2. ``_wrap_websocket_denial_send`` is inlined in this module rather than inherited from ``starlette.responses.Response``. The helper landed on Starlette ``main`` after our minimum pin (``starlette>=0.41.3``); inline until the floor moves past the release that contains it. 3. ``collapse_excgroups()`` is vendored in ``sse_starlette._utils`` rather than imported from ``starlette._utils`` (private module). N) dataclassfield)datetimetimezone) Any AsyncIterable AwaitableCallable CoroutineIteratorMappingOptionalSetUnion)BackgroundTask)iterate_in_threadpool)MutableHeaders)Response)ReceiveScopeSendMessage)collapse_excgroups)ServerSentEvent ensure_bytescX\rSrSr%Sr\"\S9r\\ R\ S'Sr \ \ S'Srg) _ShutdownState>zPer-thread state for shutdown coordination. Issue #152 fix: Uses threading.local() instead of ContextVar to ensure one watcher per thread rather than one per async context. )default_factoryeventsFwatcher_startedN)__name__ __module__ __qualname____firstlineno____doc__rsetr ranyioEvent__annotations__r!bool__static_attributes__r"c/home/rurouni/.local/share/pipx/venvs/strix-agent/lib/python3.13/site-packages/sse_starlette/sse.pyrr>s+ %S9FC 9!OT!r.rreturncX[[SS5nUc[5nU[lU$)z4Get or create shutdown state for the current thread.shutdown_stateN)getattr _thread_staterr2)states r/_get_shutdown_stater6Ns+ M#3T :E } ', $ Lr.c[R"[R5n[US5(aURn[US5(aU$g![ a gf=f)aM Try to get uvicorn Server instance via signal handler introspection. When uvicorn registers signal handlers, they're bound methods on the Server instance. We can retrieve the Server from the handler's __self__ attribute. Returns None if: - Not running under uvicorn - Signal handler isn't a bound method - Any introspection fails __self__ should_exitN)signal getsignalSIGTERMhasattrr8 Exception)handlerservers r/_get_uvicorn_serverrAWsa ""6>>2 7J ' '%%Fv}--      sAA A$#A$c# [5n[5n[R(aOU[R(a UbUR(a S[lO [ R "S5IShvN Mk[UR5HnUR5 M SUl gN:!SUl f=f7f)aO Poll for shutdown and broadcast to all events in this context. One watcher runs per thread (event loop). Checks two shutdown sources: 1. AppStatus.should_exit - set when our monkey-patch works 2. uvicorn Server.should_exit - via signal handler introspection (Issue #132 fix) When either becomes True, signals all registered events. TNg?F) r6rA AppStatusr9enable_automatic_graceful_drainr)sleeplistr r(r!)r5uvicorn_serverevents r/_shutdown_watcherrIns !E(*N&$$99"."..(, %++c" " "%,,'E IIK(!& #!&s/CA%B:=B8>2B:0C8B:: CCc[5nUR(d7SUl[R"5nUR [ 55 gg![ a SUlgf=f)zDEnsure the shutdown watcher is running for this thread (event loop).TFN)r6r!asyncioget_running_loop create_taskrI RuntimeError)r5loops r/$_ensure_watcher_started_on_this_looprPs^  !E  $ *++-D   .0 1 !  *$)E ! *s.AA('A(sendc(^S[SS4U4SjjnU$)a'Mirror of ``starlette.responses.Response._wrap_websocket_denial_send``. Divergence #2 (see module docstring): inlined because the helper landed on Starlette ``main`` (commit 9ee9519) after our minimum pin ``starlette>=0.41.3``. Drop this once the floor moves past the release that contains it. messager0Nc^># USnUS;a 0UESSU-0EnT"U5IShvN gN7f)Ntype>http.response.bodyhttp.response.startz websocket.r")rS message_typerQs r/wrapped,_wrap_websocket_denial_send..wrappeds;v H HFF&,*EFG7ms "-+-)r)rQrYs` r/_wrap_websocket_denial_sendr[sw4 Nr.c\rSrSrSrg)SendTimeoutErrorr"N)r#r$r%r&r-r"r.r/r]r]sr.r]cf\rSrSr%SrSrSrSr\\ \ S'\ S5r \ S5r \ S 5rS rg) rCz\Helper to capture a shutdown signal from Uvicorn so we can gracefully terminate SSE streams.FTNoriginal_handlercS[lg)a Prevent automatic SSE stream termination on server shutdown. WARNING: When disabled, you MUST set AppStatus.should_exit = True at some point during shutdown, or streams will never close and the server will hang indefinitely (or until uvicorn's graceful shutdown timeout expires). FNrCrDr"r.r/ disable_automatic_graceful_drain*AppStatus.disable_automatic_graceful_drains 5: 1r.cS[lg)z Re-enable automatic SSE stream termination on server shutdown. This restores the default behavior where SIGTERM triggers immediate stream draining. Call this to undo a previous call to disable_automatic_graceful_drain(). TNrcr"r.r/$enable_automatic_graceful_drain_mode.AppStatus.enable_automatic_graceful_drain_modes 59 1r.c[R(a S[l[Rb[R"U0UD6 gg)NT)rCrDr9ra)argskwargss r/ handle_exitAppStatus.handle_exits7  4 4$(I !  % % 1  & & 7 7 2r.r")r#r$r%r&r'r9rDrarr r+ staticmethodrdrgrlr-r"r.r/rCrCsZfK&*#+/hx(/ : :9988r.rC)ServerzHUvicorn not installed. Graceful shutdown on server termination disabled.c\rSrSrSrSrSrS%S\S\S\ \ \ \ 4S \ S \ \ S \ \S \ \ S \ \ /\4S\ \ /\S4S\ \S\ \ \/\S4S\ \R(S\SS4Sjjr\S\\\44Sj5r\R2S\\\4SS4Sj5rS&S\SS4SjjrS\SS4SjrS\SS4Sjr\ S'Sj5r!S'S jr"S\SS4S!jr#S"\$S\S\SS4S#jr%S$r&g)(EventSourceResponseaStreaming response implementing the SSE (Server-Sent Events) specification. Args: content: Async iterable or sync iterator yielding SSE event data. status_code: HTTP status code. Default: 200. headers: Additional HTTP headers. media_type: Response media type. Default: "text/event-stream". background: Background task to run after response completes. ping: Ping interval in seconds (0 to disable). Default: 15. sep: Line separator for SSE messages ("\r\n", "\r", or "\n"). ping_message_factory: Callable returning custom ping ServerSentEvent. data_sender_callable: Async callable for push-based data sending. send_timeout: Timeout in seconds for individual send operations. client_close_handler_callable: Async callback on client disconnect. shutdown_event: Optional ``anyio.Event`` set by the library when server shutdown is detected. Generators can watch this event to send farewell messages and exit cooperatively instead of receiving CancelledError. shutdown_grace_period: Seconds to wait after setting ``shutdown_event`` before force-cancelling the generator. Must be >= 0. Should be less than your ASGI server's graceful shutdown timeout. Default: 0 (immediate cancel, identical to pre-v3.3.0 behavior).  Ncontent status_codeheaders media_type backgroundpingsepping_message_factorydata_sender_callable)NNN send_timeoutclient_close_handler_callableshutdown_eventshutdown_grace_periodr0cjUS;a[SU35eU=(d URUl[U[5(aXlO[ U5UlX lUc UROUUlXPl Xl Xl [5nUbURU5 URSS5 SUS'SUS'URU5 Uc UR OUUlXlXlU S :a [S 5eXlXlS Ul[.R0"5Ulg) N)Nrt  z'sep must be one of: \r\n, \r, \n, got: z Cache-Controlzno-storez keep-alive ConnectionnozX-Accel-Bufferingrz"shutdown_grace_period must be >= 0T) ValueErrorDEFAULT_SEPARATORr{ isinstancer body_iteratorrrvrxryr}r~rupdate setdefault init_headersDEFAULT_PING_INTERVAL ping_intervalr|r_shutdown_event_shutdown_grace_periodactiver)Lock _send_lock)selfrurvrwrxryrzr{r|r}r~rrr_headerss r/__init__EventSourceResponse.__init__s$* 0 0J3%PQ Q0$00 g} - -!( !6w!?D &-7-?$//Z$$8!("#   OOG $ OZ8!-(,$% (#;?E E/EE/E,E  E,(E/receivec# UR(asU"5IShvN nUSS:XaGSUl[RS5 UR(aURU5IShvN gUR(aMrggNiN7f)uIWatch for a disconnect message from the client. Divergence #1 (see module docstring): kept unconditionally instead of adopting Starlette's ASGI 2.4 ``OSError → ClientDisconnect`` fast path, because this loop drives ``client_close_handler_callable`` and flips ``self.active = False`` for ``_ping`` and the shutdown grace loop. NrUzhttp.disconnectFz+Got event: http.disconnect. Stop streaming.)rrrr)rrrSs r/_listen_for_disconnect*EventSourceResponse._listen_for_disconnectzslkk#IoGv"33#  JK55<# U"5IShvN TRR5 gN7fr)rcancel)r task_groups r/cancel_on_finish6EventSourceResponse.__call__..cancel_on_finishs&&LL++224!s 0. 0c&>TRT5$r)rrrQsr/.EventSourceResponse.__call__..sd.C.CD.Ir.c&>TRT5$r)rrsr/rrs 4@Pr.c&>TRT5$r)r)rrsr/rrsd.I.I'.Rr.) r[rr)create_task_groupr r start_soonrr}ry)rrrrQrrs` `` @r/__call__EventSourceResponse.__call__s =K '.t4D  !..00J5"io:M1N5%%$&I%%&68PQ%%$d&M&M,,))$*C*CD%%$&R%10". ?? &//# # # '-1000" !0 $spEED*EB(D.+ E6D,7E;(E#E$E*E,E.E 4D75 E E EE)rrrrrryrrr}rxrr|r~r{rv) Nztext/event-streamNNNNNNNNr)Fr0N)'r#r$r%r&r'rr ContentStreamrrr strrr rr rrr r)r*rpropertyrrsetterr,rrrrrrnrrrrrr-r"r.r/rqrqs&. /3-/3"!HL (, 04'(%G'G'G''#s(+, G'  G' ^, G'smG'c]G''xO0C'DEG'' R#344 5 G'uoG'(0 gY $/ 0( G'"!-#G'$ %%G'& 'G'R#uS%Z0##$5e#4$$$SSSX4XDX8G"((&+(6($E($G($4($D($r.rqr)Dr'rKloggingr: threading dataclassesrrrrtypingrrr r r r r rrrr)starlette.backgroundrstarlette.concurrencyrstarlette.datastructuresrstarlette.responsesrstarlette.typesrrrrsse_starlette._utilsrsse_starlette.eventrr getLoggerr#rrlocalr4r6rArIrPr[ TimeoutErrorr]rC uvicorn.mainrorlra ImportErrorrrbytesdictContentSyncContentStreamAsyncContentStreamrrqr"r.r/rsY8 ('    /73(993=   8 $ "" "! ^.!&H *dt$ | #8#8L#!'!3!3I"..F UD/36 7W%"7+(*;;< K$(K$ LLRs(D%%D?>D?