
    E0j                         d dl Z  G d de          Z G d de          Z G d de          Z G d d	e          Z G d
 de          ZdS )    Nc                   :    e Zd ZdZd Zd Zd Zed             ZdS )Headerszapplication/jsonc                     d | _         d | _        d | _        d | _        d | _        d | _        i | _        d | _        d | _        d | _	        d | _
        d | _        d S )N)app_idconnection_idcontent_type
message_idtimetopic
extensionsevent_born_timeevent_corp_idevent_id
event_typeevent_unified_app_idselfs    ^/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/dingtalk_stream/frames.py__init__zHeaders.__init__   sa    ! 	
#!$(!!!    c                 6   | j         | j        | j        | j        | j        | j        | j        d}| j        2| j        |d<   | j        |d<   | j	        |d<   | j
        |d<   | j        |d<   dd                    d	 |                                D                       z  S )
N)r   r   r   r	   r
   r   r   r   r   r   r   r   zHeaders(%s)z, c                 "    g | ]\  }}|d |S )= ).0kvs      r   
<listcomp>z#Headers.__str__.<locals>.<listcomp>'   s'    )V)V)Vtq!QQQ*:)V)V)Vr   )r   r   r   r	   r
   r   r   r   r   r   r   r   joinitems)r   fieldss     r   __str__zHeaders.__str__   s    k!/ -/IZ/
 
 =$(,(<F$%!%F:&*&8F?##'?F< -1-FF)*tyy)V)Vv||~~)V)V)VWWWWr   c                    | j                                         }| j        
| j        |d<   | j        
| j        |d<   | j        
| j        |d<   | j        
| j        |d<   | j        
| j        |d<   | j        t          | j                  |d<   |S )NappIdconnectionIdcontentType	messageIdr   r
   )	r   copyr   r   r   r	   r   r
   str)r   results     r   to_dictzHeaders.to_dict)   s    %%'';""kF7O)%)%7F>"($($5F=!?&"&/F;:!"jF7O9  ^^F6Nr   c                    t                      }|                                D ]\  }}|dk    r||_        |dk    r||_        !|dk    r||_        /|dk    r||_        =|dk    r||_        K|dk    rt          |          |_        f|dk    rt          |          |_	        |dk    r||_
        |d	k    r||_        |d
k    r||_        |dk    r||_        ||j        |<   |S )Nr$   r%   r&   r'   r   r
   eventBornTimeeventCorpIdeventId	eventTypeeventUnifiedAppId)r   r    r   r   r   r	   r   intr
   r   r   r   r   r   r   )clsdheadersnamevalues        r   	from_dictzHeaders.from_dict9   s.   ))7799 	1 	1KD%w!&''(-%%&&',$$$$%*"" %"5zz((*-e**''&&(-%%""#(  $$%*"",,,/4,,+0"4((r   N)	__name__
__module____qualname__CONTENT_TYPE_APPLICATION_JSONr   r"   r+   classmethodr8   r   r   r   r   r      se        $6!) ) ) X X X$      [  r   r   c                   4    e Zd ZdZd Zd Zed             ZdS )EventMessageEVENTc                 x    d| _         t          j        | _        t	                      | _        i | _        i | _        d S N )spec_versionr?   TYPEtyper   r5   datar   r   s    r   r   zEventMessage.__init__[   s1     %	yy	r   c                 X    d| j         d| j        d| j        d| j        d| j        dS )NzEventMessage(spec_version=, type=
, headers=, data=, extensions=)rD   rF   r5   rG   r   r   s    r   r"   zEventMessage.__str__b   >     IIILLLIIIOOO 	r   c                 ,   t                      }d}|                                D ]S\  }}|dk    r||_        |dk    r|}|dk    r#|dk    r t                              |          |_        I||j        |<   T|rt          j        |          |_	        |S NrC   specVersionrG   rF   r5   )
r?   r    rD   r   r8   r5   r   jsonloadsrG   r3   r4   msgrG   r6   r7   s         r   r8   zEventMessage.from_dictj   s    nn7799 
	- 
	-KD%}$$#(  ""%//66',t$$ 	(z$''CH
r   Nr9   r:   r;   rE   r   r"   r=   r8   r   r   r   r?   r?   X   sR        D       [  r   r?   c                   4    e Zd ZdZd Zd Zed             ZdS )CallbackMessageCALLBACKc                 x    d| _         t          j        | _        t	                      | _        i | _        i | _        d S rB   )rD   rY   rE   rF   r   r5   rG   r   r   s    r   r   zCallbackMessage.__init__   s1    #(	yy	r   c                 X    d| j         d| j        d| j        d| j        d| j        dS )NzCallbackMessage(spec_version=rI   rJ   rK   rL   rM   rN   r   s    r   r"   zCallbackMessage.__str__   rO   r   c                 ,   t                      }d}|                                D ]S\  }}|dk    r||_        |dk    r|}|dk    r#|dk    r t                              |          |_        I||j        |<   T|rt          j        |          |_	        |S rQ   )
rY   r    rD   r   r8   r5   r   rS   rT   rG   rU   s         r   r8   zCallbackMessage.from_dict   s    7799 
	- 
	-KD%}$$#(  ""%//66',t$$ 	(z$''CH
r   NrW   r   r   r   rY   rY   }   sR        D       [  r   rY   c                   8    e Zd ZdZdZd Zd Zed             ZdS )SystemMessageSYSTEM
disconnectc                     d| _         t          j        | _        t	                      | _        i | _        i | _        t          d             }d S )NrC   c                 ,   t                      }d}|                                D ]S\  }}|dk    r||_        |dk    r|}|dk    r#|dk    r t                              |          |_        I||j        |<   T|rt          j        |          |_	        |S rQ   
r_   r    rD   r   r8   r5   r   rS   rT   rG   rU   s         r   r8   z)SystemMessage.__init__.<locals>.from_dict   s    //CD wwyy 
1 
1e=((',C$$V^^ DDV^^Y&&")"3"3E":":CKK+0CN4(( ,:d++Jr   )	rD   r_   rE   rF   r   r5   rG   r   r=   )r   r8   s     r   r   zSystemMessage.__init__   sP    !&	yy			 	 
	 	 	r   c                 X    d| j         d| j        d| j        d| j        d| j        dS )NzSystemMessage(spec_version=rI   rJ   rK   rL   rM   rN   r   s    r   r"   zSystemMessage.__str__   s>     IIILLLIIIOOO
 	
r   c                 ,   t                      }d}|                                D ]S\  }}|dk    r||_        |dk    r|}|dk    r#|dk    r t                              |          |_        I||j        |<   T|rt          j        |          |_	        |S rQ   rd   rU   s         r   r8   zSystemMessage.from_dict   s    oo7799 
	- 
	-KD%}$$#(  ""%//66',t$$ 	(z$''CH
r   N)	r9   r:   r;   rE   TOPIC_DISCONNECTr   r"   r=   r8   r   r   r   r_   r_      sX        D#  4
 
 
   [  r   r_   c                   *    e Zd ZdZdZdZdZd Zd ZdS )
AckMessage   i  i  i  c                 j    t           j        | _        t                      | _        d| _        i | _        d S rB   )ri   	STATUS_OKcoder   r5   messagerG   r   s    r   r   zAckMessage.__init__   s)    (	yy			r   c                     | j         | j                                        | j        t	          j        | j                  dS )N)rm   r5   rn   rG   )rm   r5   r+   rn   rS   dumpsrG   r   s    r   r+   zAckMessage.to_dict   s;    I|++--|Jty))	
 
 	
r   N)	r9   r:   r;   rl   STATUS_BAD_REQUESTSTATUS_NOT_IMPLEMENTSTATUS_SYSTEM_EXCEPTIONr   r+   r   r   r   ri   ri      sI        I!  
 
 
 
 
r   ri   )rS   objectr   r?   rY   r_   ri   r   r   r   <module>ru      s    Q Q Q Q Qf Q Q Qh# # # # #6 # # #J# # # # #f # # #J8 8 8 8 8F 8 8 8v
 
 
 
 
 
 
 
 
 
r   