o
    }jh                  
   @   s  U d dl mZmZmZmZmZmZ d dlmZm	Z	m
Z
 d dlmZmZ ddlmZmZmZmZmZmZmZmZ G dd deZG dd	 d	eZG d
d deZG dd deZG dd deZG dd deZG dd deZG dd deZG dd deZG dd deZ G dd deZ!G dd deZ"G dd deZ#G d d! d!eZ$G d"d# d#eZ%G d$d% d%eZ&G d&d' d'eZ'G d(d) d)eZ(G d*d+ d+eZ)G d,d- d-eZ*G d.d/ d/eZ+ee ee"e&e(e)e%e*e+f	 Z,ee-d0< e
e,Z.e
e, e-d1< eee"e&e'e$f Z/ee-d2< d3S )4    )AnyListLiteralMappingOptionalUnion)	BaseModelFieldTypeAdapter)	TypeAlias	TypedDict   )BroadcastPayloadChannelEventsPostgresChangesDataPostgresChangesPayloadRawPresenceDiffRawPresenceStateRealtimeChannelOptions"RealtimePostgresChangesListenEventc                   @   sR   e Zd ZU dZeed< eeef ed< eed< dZe	e ed< dZ
e	e ed< dS )Messagez+
    Dataclass abstraction for message
    eventpayloadtopicNrefjoin_ref)__name__
__module____qualname____doc__str__annotations__r   r   r   r   r    r"   r"   F/var/www/html/bot/env/lib/python3.10/site-packages/realtime/message.pyr      s   
 r   c                   @   s4   e Zd ZU eej ed< eed< eed< eed< dS )JoinMessager   r   r   r   N)	r   r   r   r   r   joinr!   r    r   r"   r"   r"   r#   r$      s
   
 r$   c                   @   sN   e Zd ZU eed< eed< eed< edddZe	e ed< dZ
e	e ed< dS )	PostgresRowChangeideventstableschemaN)aliasdefaultschema_filter)r   r   r   intr!   r   r    r	   r-   r   r.   r"   r"   r"   r#   r&   %   s   
 r&   c                   @   s"   e Zd ZU dZeee  ed< dS )ReplyPostgresChangesNpostgres_changes)r   r   r   r1   r   r   r&   r!   r"   r"   r"   r#   r0   -   s   
 r0   c                   @   s"   e Zd ZU ed ed< eed< dS )SuccessReplyMessageokstatusresponseN)r   r   r   r   r!   r0   r"   r"   r"   r#   r2   1   s   
 r2   c                   @   s*   e Zd ZU ed ed< eeef ed< dS )ErrorReplyMessageerrorr4   r5   N)r   r   r   r   r!   dictr    r   r"   r"   r"   r#   r6   6   s   
 r6   c                   @   s@   e Zd ZU eej ed< eed< ee	e
f ed< ee ed< dS )ReplyMessager   r   r   r   N)r   r   r   r   r   replyr!   r    r   r2   r6   r   r"   r"   r"   r#   r9   ;   
   
 r9   c                   @   2   e Zd ZU eed< eed< eed< ed ed< dS )SuccessSystemPayloadchannel	extensionmessager3   r4   Nr   r   r   r    r!   r   r"   r"   r"   r#   r=   B   
   
 r=   c                   @   r<   )ErrorSystemPayloadr>   r?   r@   r7   r4   NrA   r"   r"   r"   r#   rC   I   rB   rC   c                   @   s@   e Zd ZU eej ed< eed< ee	e
f ed< ed ed< dS )SystemMessager   r   r   Nr   )r   r   r   r   r   systemr!   r    r   r=   rC   r"   r"   r"   r#   rD   P   r;   rD   c                   @   s   e Zd ZdS )HeartbeatPayloadN)r   r   r   r"   r"   r"   r#   rF   W   s    rF   c                   @   s8   e Zd ZU eej ed< ed ed< eed< eed< dS )HeartbeatMessager   phoenixr   r   r   N)	r   r   r   r   r   	heartbeatr!   r    rF   r"   r"   r"   r#   rG   [   s
   
 rG   c                   @   s   e Zd ZU eed< dS )AccessTokenPayloadaccess_tokenN)r   r   r   r    r!   r"   r"   r"   r#   rJ   b   s   
 rJ   c                   @   8   e Zd ZU eej ed< eed< eed< ed ed< dS )AccessTokenMessager   r   r   Nr   )	r   r   r   r   r   rK   r!   r    rJ   r"   r"   r"   r#   rM   f   
   
 rM   c                   @   rL   )PostgresChangesMessager   r   r   Nr   )	r   r   r   r   r   r1   r!   r    r   r"   r"   r"   r#   rO   m   rN   rO   c                   @   rL   )BroadcastMessager   r   r   Nr   )	r   r   r   r   r   	broadcastr!   r    r   r"   r"   r"   r#   rP   t   rN   rP   c                   @   s@   e Zd ZU eej ed< eed< eee	f ed< ed ed< dS )PresenceMessager   r   r   Nr   )
r   r   r   r   r   presencer!   r    r8   r   r"   r"   r"   r#   rR   {   r;   rR   c                   @   rL   )PresenceStateMessager   r   r   Nr   )	r   r   r   r   r   presence_stater!   r    r   r"   r"   r"   r#   rT      rN   rT   c                   @   rL   )PresenceDiffMessager   r   r   Nr   )	r   r   r   r   r   presence_diffr!   r    r   r"   r"   r"   r#   rV      rN   rV   c                   @   @   e Zd ZU eej ed< eed< eee	f ed< e
e ed< dS )ChannelErrorMessager   r   r   r   N)r   r   r   r   r   r7   r!   r    r8   r   r   r"   r"   r"   r#   rY      r;   rY   c                   @   rX   )ChannelCloseMessager   r   r   r   N)r   r   r   r   r   closer!   r    r8   r   r   r"   r"   r"   r#   rZ      r;   rZ   ServerMessageServerMessageAdapterClientMessageN)0typingr   r   r   r   r   r   pydanticr   r	   r
   typing_extensionsr   r   typesr   r   r   r   r   r   r   r   r   r$   r&   r0   r2   r6   r9   r=   rC   rD   rF   rG   rJ   rM   rO   rP   rR   rT   rV   rY   rZ   r\   r!   r]   r^   r"   r"   r"   r#   <module>   s\   " (