ZiUddlmZmZddlmZddlmZmZmZm Z ddl m Z dddiddiddiddd d d Z e eefed <Gd de ZdedzdedzfdZGddeZdddddddeedzedfdeedzedfdeedzedfdeedzedfdeedzedfdef d Zd!Zd"Zeed#<y)$) AnnotatedAny)Doc)AfterValidator BaseModelFieldmodel_validator)StreamingResponseobjecttypestringinteger)r minimum)dataeventidretry)r properties_SSE_EVENT_SCHEMAceZdZdZdZy)EventSourceResponseaStreaming response with `text/event-stream` media type. Use as `response_class=EventSourceResponse` on a *path operation* that uses `yield` to enable Server Sent Events (SSE) responses. Works with **any HTTP method** (`GET`, `POST`, etc.), which makes it compatible with protocols like MCP that stream SSE over `POST`. The actual encoding logic lives in the FastAPI routing layer. This class serves mainly as a marker and sets the correct `Content-Type`. ztext/event-streamN)__name__ __module__ __qualname____doc__ media_typeG/home/portmadness/app/.venv/lib/python3.12/site-packages/fastapi/sse.pyrrs %JrrvNreturnc(|d|vr td|S)Nz)SSE 'id' must not contain null characters) ValueError)r s r_check_id_no_nullr%$s}DEE HrcFeZdZUdZdZeeedfed<dZ ee dzedfed<dZ ee dzedfed<dZ ee dze eed fed <dZeedzed ed fed<dZee dzedfed<edddZy)ServerSentEventatRepresents a single Server-Sent Event. When `yield`ed from a *path operation function* that uses `response_class=EventSourceResponse`, each `ServerSentEvent` is encoded into the [SSE wire format](https://html.spec.whatwg.org/multipage/server-sent-events.html#parsing-an-event-stream) (`text/event-stream`). If you yield a plain object (dict, Pydantic model, etc.) instead, it is automatically JSON-encoded and sent as the `data:` field. All `data` values **including plain strings** are JSON-serialized. For example, `data="hello"` produces `data: "hello"` on the wire (with quotes). NaB The event payload. Can be any JSON-serializable value: a Pydantic model, dict, list, string, number, etc. It is **always** serialized to JSON: strings are quoted (`"hello"` becomes `data: "hello"` on the wire). Mutually exclusive with `raw_data`. raQ Raw string to send as the `data:` field **without** JSON encoding. Use this when you need to send pre-formatted text, HTML fragments, CSV lines, or any non-JSON payload. The string is placed directly into the `data:` field as-is. Mutually exclusive with `data`. raw_dataz Optional event type name. Maps to `addEventListener(event, ...)` on the browser. When omitted, the browser dispatches on the generic `message` event. rz Optional event ID. The browser sends this value back as the `Last-Event-ID` header on automatic reconnection. **Must not contain null (`\0`) characters.** rr)gez Optional reconnection time in **milliseconds**. Tells the browser how long to wait before reconnecting after the connection is lost. Must be a non-negative integer. rz Optional comment line(s). Comment lines start with `:` in the SSE wire format and are ignored by `EventSource` clients. Useful for keep-alive pings to prevent proxy/load-balancer timeouts. commentafter)modecL|j|j td|S)NzCannot set both 'data' and 'raw_data' on the same ServerSentEvent. Use 'data' for JSON-serialized payloads or 'raw_data' for pre-formatted strings.)rr(r$)selfs r_check_data_exclusivez%ServerSentEvent._check_data_exclusives. 99 T]]%>;   r)r!r')rrrrrrrr__annotations__r(strrrrr%rintrr*r r/rrrr'r'*sF:  )        6  i d        0  9 d        ,   d ()       .  9 d          .  Y d        '"#rr')data_strrrrr*r3zQ Pre-serialized data string to use as the `data:` field. rzD Optional event type name (`event:` field). rz: Optional event ID (`id:` field). rzV Optional reconnection time in milliseconds (`retry:` field). r*z@ Optional comment line(s) (`:` prefix). cg}|)|jD]}|jd|||jd||)|jD]}|jd|||jd|||jd||jd|jddj|jdS) z|Build SSE wire-format bytes from **pre-serialized** data. The result always ends with ` ` (the event terminator). z: zevent: zdata: zid: zretry:  zutf-8) splitlinesappendjoinencode)r3rrrr*lineslines rformat_sse_eventr=s^E&&( &D LL2dV % &  wug&''') *D LL6$ ) * ~ tB4[!  wug&' LL LL 99U  " "7 ++rs: ping g.@_PING_INTERVAL)typingrr annotated_docrpydanticrrrr starlette.responsesr rdictr1r0rr%r'r2bytesr=KEEPALIVE_COMMENTr>floatrrrrGs!!FF1 "(#x #2 %4S> %+ %  t d  eieb     SD, d     D,  d      D,$  d      %D,4  d      5D,D d     ED,T UD,P"r