o
    ii                     @   sF  U d dl mZmZ d dlmZ d dlmZmZmZm	Z	 d dl
mZ dddiddiddidd d	d
dZeeef ed< G dd deZdedB dedB fddZG dd deZdddddddeedB edf deedB edf deedB edf deedB edf deedB ed f defd!d"Zd#Zd$Zeed%< dS )&    )	AnnotatedAny)Doc)AfterValidator	BaseModelFieldmodel_validator)StreamingResponseobjecttypestringinteger)r   minimum)dataeventidretry)r   
properties_SSE_EVENT_SCHEMAc                   @   s   e Zd ZdZdZdS )EventSourceResponsea  Streaming 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`.
    ztext/event-streamN)__name__
__module____qualname____doc__
media_type r   r   S/var/www/scraper.webshop2u.hu/html/venv/lib/python3.10/site-packages/fastapi/sse.pyr      s    r   vNreturnc                 C   s   | d urd| v rt d| S )N z)SSE 'id' must not contain null characters)
ValueError)r   r   r   r   _check_id_no_null$   s   r!   c                   @   s   e Zd ZU dZdZeeedf ed< dZ	ee
dB edf ed< dZee
dB edf ed< dZee
dB eeed	f ed
< dZeedB eddedf ed< dZee
dB edf ed< edddddZdS )ServerSentEventat  Represents 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`.
            r   aQ  
            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.
            r   z
            Optional event ID.

            The browser sends this value back as the `Last-Event-ID` header on
            automatic reconnection. **Must not contain null (`\0`) characters.**
            r   r   )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.
            r   z
            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.
            commentafter)moder   c                 C   s    | j d ur| jd urtd| 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.)r   r#   r    )selfr   r   r   _check_data_exclusive   s
   z%ServerSentEvent._check_data_exclusive)r   r"   )r   r   r   r   r   r   r   r   __annotations__r#   strr   r   r   r!   r   intr   r%   r   r)   r   r   r   r   r"   *   sl   
 r"   )data_strr   r   r   r%   r-   zQ
            Pre-serialized data string to use as the `data:` field.
            r   zD
            Optional event type name (`event:` field).
            r   z:
            Optional event ID (`id:` field).
            r   zV
            Optional reconnection time in milliseconds (`retry:` field).
            r%   z@
            Optional comment line(s) (`:` prefix).
            c                 C   s   g }|dur|  D ]
}|d|  q
|dur!|d|  | dur4|   D ]
}|d|  q)|dur@|d|  |durL|d|  |d |d d|d	S )
z|Build SSE wire-format bytes from **pre-serialized** data.

    The result always ends with `

` (the event terminator).
    Nz: zevent: zdata: zid: zretry:  
zutf-8)
splitlinesappendjoinencode)r-   r   r   r   r%   linesliner   r   r   format_sse_event   s    /

r6   s   : ping

g      .@_PING_INTERVAL)typingr   r   annotated_docr   pydanticr   r   r   r   starlette.responsesr	   r   dictr+   r*   r   r!   r"   r,   bytesr6   KEEPALIVE_COMMENTr7   floatr   r   r   r   <module>   s    q
"*
H