Ë
    ïñþiñ
  ã                   ó|   — d dl Z d dlZd dlZd dlmZmZmZ  G d„ d«      Z G d„ de«      Zdee	e
eef   ded	e	fd
„Zy)é    N)ÚOptionalÚAnyÚUnionc                   óž   — e Zd ZdZ ej
                  d«      ZdZ	 dddddddœdee	   dee
   dee
   d	ee   d
ee
   dee
   ddfd„Zdefd„Zy)ÚServerSentEventzC
    Helper class to format data for Server-Sent Events (SSE).
    z
\r\n|\r|\nz
N)ÚeventÚidÚretryÚcommentÚsepÚdatar   r	   r
   r   r   Úreturnc                ó€   — || _         || _        || _        || _        || _        |�|| _        y | j
                  | _        y ©N)r   r   r	   r
   r   ÚDEFAULT_SEPARATORÚ_sep)Úselfr   r   r	   r
   r   r   s          úS/root/aria/mcps/aria-brain/venv/lib/python3.12/site-packages/sse_starlette/event.pyÚ__init__zServerSentEvent.__init__   s>   € ð ˆŒ	ØˆŒ
ØˆŒØˆŒ
ØˆŒØ˜?�Cˆ�	°×0FÑ0Fˆ�	ó    c                 ó  — t        j                  «       }| j                  �S| j                  j	                  t        | j                  «      «      D ]"  }|j                  d|› | j                  › �«       Œ$ | j                  �E|j                  d| j                  j                  d| j                  «      z   | j                  z   «       | j                  �E|j                  d| j                  j                  d| j                  «      z   | j                  z   «       | j                  �S| j                  j	                  t        | j                  «      «      D ]"  }|j                  d|› | j                  › �«       Œ$ | j                  �Ot        | j                  t        «      st        d«      ‚|j                  d| j                  › | j                  › �«       |j                  | j                  «       |j!                  «       j#                  d«      S )	Nz: zid: Ú zevent: zdata: zretry argument must be intzretry: zutf-8)ÚioÚStringIOr   Ú_LINE_SEP_EXPRÚsplitÚstrÚwriter   r	   Úsubr   r   r
   Ú
isinstanceÚintÚ	TypeErrorÚgetvalueÚencode)r   ÚbufferÚchunks      r   r$   zServerSentEvent.encode    s’  € Ü—‘“ˆØ�<‰<Ð#Ø×,Ñ,×2Ñ2´3°t·|±|Ó3DÓEò 6�Ø—‘˜r % ¨¯©¨Ð4Õ5ð6ð �7‰7Ðà�L‰L˜ $×"5Ñ"5×"9Ñ"9¸"¸d¿g¹gÓ"FÑFÈÏÉÑRÔSà�:‰:Ð!à�L‰LØ˜D×/Ñ/×3Ñ3°B¸¿
¹
ÓCÑCÀdÇiÁiÑOôð �9‰9Ð à×,Ñ,×2Ñ2´3°t·y±y³>ÓBò :�Ø—‘˜v e W¨T¯Y©Y¨KÐ8Õ9ð:ð �:‰:Ð!Ü˜dŸj™j¬#Ô.ÜÐ <Ó=Ð=Ø�L‰L˜7 4§:¡: ,¨t¯y©y¨kÐ:Ô;à�‰�T—Y‘YÔØ�‰Ó ×'Ñ'¨Ó0Ð0r   r   )Ú__name__Ú
__module__Ú__qualname__Ú__doc__ÚreÚcompiler   r   r   r   r   r!   r   Úbytesr$   © r   r   r   r      s°   „ ñð  �R—Z‘Z Ó.€NØÐð #ðGð  $Ø Ø#Ø!%Ø!òGà�s‰mðGð ˜‰}ð	Gð
 �S‰MðGð ˜‰}ðGð ˜#‘ðGð �c‰]ðGð 
óGð"1˜ô 1r   r   c                   ó6   ‡ — e Zd ZdZ	 ddee   ddfˆ fd„Zˆ xZS )ÚJSONServerSentEventzH
    Helper class to format JSON data for Server-Sent Events (SSE).
    Nr   r   c           	      ód   •— t        ‰| �  |�t        j                  |ddd d¬«      nd g|¢­i |¤Ž y )NF)ú,ú:)Úensure_asciiÚ	allow_nanÚindentÚ
separators)Úsuperr   ÚjsonÚdumps)r   r   ÚargsÚkwargsÚ	__class__s       €r   r   zJSONServerSentEvent.__init__C   sP   ø€ ô 	‰Ñð Ðô �J‰JØØ"ØØØ%õð ð	
ð ò	
ð ó	
r   r   )r'   r(   r)   r*   r   r   r   Ú__classcell__)r=   s   @r   r0   r0   >   s-   ø„ ñð #ñ
à�s‰mð
ð
 
÷
ñ 
r   r0   r   r   r   c                 ó(  — t        | t        t        f«      rt        | «      S t        | t        «      r| j	                  «       S t        | t
        «      r|| d<   t        di | ¤Žj	                  «       S t        t        | «      |¬«      j	                  «       S )Nr   )r   r.   )r    r-   Ú
memoryviewr   r$   Údictr   )r   r   s     r   Úensure_bytesrB   X   su   € Ü�$œ¤
Ð+Ô,Ü�T‹{ÐÜ�$œÔ(Ø�{‰{‹}ÐÜ�$œÔØˆˆU‰ÜÑ& Ñ&×-Ñ-Ó/Ð/Üœ3˜t›9¨#Ô.×5Ñ5Ó7Ð7r   )r   r+   r9   Útypingr   r   r   r   r0   r-   rA   r   rB   r.   r   r   ú<module>rD      sS   ðÛ 	Û 	Û ß 'Ñ '÷41ñ 41ôn
˜/ô 
ð48�u˜U D¨/¸3Ð>Ñ?ð 8Àcð 8Èeô 8r   