:tj<UddlmZmZddlmZddlmZmZmZm Z ddl m Z dddiddiddiddd d d Z e eefed <Gd de ZdedzdededzfdZdedzdedzfdZdedzdedzfdZGddeZdedeefdZdddddddeedzedfdeedzedfdeedzed fd!eedzed"fd#eedzed$fdef d%Zd&Zd'Zeed(<dS))) AnnotatedAny)Doc)AfterValidator BaseModelFieldmodel_validator)StreamingResponseobjecttypestringinteger)r minimum)dataeventidretry)r properties_SSE_EVENT_SCHEMAceZdZdZdZdS)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_typeI/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/fastapi/sse.pyrrs  %JJJrrvN field_namereturnc@|d|vsd|vrtd|d|S)N  zSSE 'z' must be a single line) ValueError)r r!s r_check_single_liner'$s6}$!))tqyyDDDDEEE Hrc"t|dS)Nr)r'r s r_check_event_single_liner**s a ) ))rcL|d|vrtdt|dS)Nz)SSE 'id' must not contain null charactersr)r&r'r)s r_check_id_validr-.s.}DEEE a & &&rceZdZUdZdZeeedfed<dZ ee dzedfed<dZ ee dze e edfed<dZee dze eed fed <dZeedzed ed fed<dZee dzedfed<edddZdS)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)moder"c@|j|jtd|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/ 9 T]%>;   r)r"r/)rrrrrrrr__annotations__r0strrrr*rr-rintrr2r r7rrrr/r/4s:  )          6  i d          4  9 d /00          2   d ''          0  9 d             .  Y d           _'"""#"rr/valuec||dddddS)Nz r%r$)replacesplit)r;s r_split_sse_linesr?s6 == & & . .tT : : @ @ F FFr)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}|*t|D]}|d|||d||*t|D]}|d|||d|||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)r?appendjoinencode)r@rrrr2lineslines rformat_sse_eventrHs^E$W-- & &D LLd % % % %  &u&&'''$X.. * *D LL$ ) ) ) ) ~ [B[[!!!  &u&&''' LL LL 99U   " "7 + ++rs: ping g.@_PING_INTERVAL)typingrr annotated_docrpydanticrrrr starlette.responsesr rdictr9r8rr'r*r-r/listr?r:bytesrHKEEPALIVE_COMMENTrIfloatrrrrSs+!!!!!!!!!FFFFFFFFFFFF111111 "(#x #22 %%4S> % % % % %+ % % %  #* # #*    *d *sTz****'sTz'cDj'''' hhhhhihhhVGCGDIGGGG     SD,D,D, d      D,  d       D,$  d       %D,4  d       5D,D d      ED,T UD,D,D,D,P"r