¿#jUddlmZmZddlmZddlmZmZmZm Z ddl m Z dddiddiddiddd d d Z e eefed <Gd de ZdedzdededzfdZdedzdedzfdZdedzdedzfdZGddeZdddddddeedzedfdeedzedfdeedzedfdeedzed fd!eedzed"fdef 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_typea/home/mi/.openclaw/workspace/fridge-app/backend/.venv/lib/python3.12/site-packages/fastapi/sse.pyrrs %JrrvN field_namereturnc8|d|vsd|vrtd|d|S)N  zSSE 'z' must be a single line) ValueError)r r!s r_check_single_liner'$s-}$!)tqy5 ,CDEE Hrct|dS)Nr)r'r s r_check_event_single_liner**s a ))rc<|d|vr tdt|dS)Nz)SSE 'id' must not contain null charactersr)r&r'r)s r_check_id_validr-.s&}DEE a &&rcTeZdZUdZdZeeedfed<dZ ee dzedfed<dZ ee dze e edfed<dZee 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. 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)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.)rr0r&)selfs r_check_data_exclusivez%ServerSentEvent._check_data_exclusives. 99 T]]%>;   r)r"r/)rrrrrrrr__annotations__r0strrrr*rr-rintrr2r r7rrrr/r/4sN:  )        6  i d        4  9 d /0       2   d '       0  9 d          .  Y d        '"#rr/)data_strrrrr2r;zQ 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). r2z@ 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: r%zutf-8) splitlinesappendjoinencode)r;rrrr2lineslines rformat_sse_eventrDs^E&&( &D LL2dV % &  wug&''') *D LL6$ ) * ~ tB4[!  wug&' LL LL 99U  " "7 ++rs: ping g.@_PING_INTERVAL)typingrr annotated_docrpydanticrrrr starlette.responsesr rdictr9r8rr'r*r-r/r:bytesrDKEEPALIVE_COMMENTrEfloatrrrrNs!!FF1 "(#x #2 %4S> %+ %  #* # #* *d *sTz*'sTz'cDj' hihh     SD, d     D,  d      D,$  d      %D,4  d      5D,D d     ED,T UD,P"r