o Tj@sUddlmZmZddlmZddlmZmZmZm Z ddl m Z dddiddiddiddd d d Z e eefed <Gd dde ZdedBdededBfddZdedBdedBfddZdedBdedBfddZGdddeZdedeefddZdddddddeedBed fd!eedBed"fd#eedBed$fd%eedBed&fd'eedBed(fdef d)d*Zd+Zd,Zeed-<dS).) AnnotatedAny)Doc)AfterValidator BaseModelFieldmodel_validator)StreamingResponseobjecttypestringinteger)r minimum)dataeventidretry)r properties_SSE_EVENT_SCHEMAc@seZdZdZdZdS)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_typerrN/home/dinkstrade/pdmp-scanner/venv/lib/python3.10/site-packages/fastapi/sse.pyrs rvN field_namereturncCs,|durd|vs d|vrtd|d|S)N  zSSE 'z' must be a single line) ValueError)rrrrr_check_single_line$sr#cCs t|dS)Nr)r#rrrr_check_event_single_line*s r%cCs"|dur d|vr tdt|dS)Nz)SSE 'id' must not contain null charactersr)r"r#r$rrr_check_id_valid.s r'c@seZdZUdZdZeeedfed<dZ ee dBedfed<dZ ee dBe e edfed<dZee dBe eed fed <dZeedBed d ed fed<dZee dBedfed<edddddZdS)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. Must be a single line. rz Optional event ID. The browser sends this value back as the `Last-Event-ID` header on automatic reconnection. **Must be a single line** and 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)modercCs |jdur|jdurtd|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")selfrrr_check_data_exclusives z%ServerSentEvent._check_data_exclusive)rr()rrrrrrrr__annotations__r)strrrr%rr'rintrr+rr/rrrrr(4sn  r(valuecCs|dddddS)Nz r!r )replacesplit)r3rrr_split_sse_linessr6)data_strrrrr+r7zQ 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). cCsg}|durt|D] }|d|q |dur!|d||dur4t|D] }|d|q)|dur@|d||durL|d||d|dd|d S) z~Build SSE wire-format bytes from **pre-serialized** data. The result always ends with `\n\n` (the event terminator). Nz: zevent: zdata: zid: zretry: r!zutf-8)r6appendjoinencode)r7rrrr+lineslinerrrformat_sse_events /    r>s: ping g.@_PING_INTERVAL)typingrr annotated_docrpydanticrrrrstarlette.responsesr rdictr1r0rr#r%r'r(listr6r2bytesr>KEEPALIVE_COMMENTr?floatrrrrs   k "* H