
    Wh	                     J    d dl T d dlT d dlT d Zd Zd Z G d d          ZdS )   )*c                     g }	 |                                  }|t          t          fv rn-|                    |           t	          |          t
          u rnR|S N)
next_event	NEED_DATAPAUSEDappendtypeConnectionClosed)conn
got_eventsevents      W/var/www/html/movieo_spanner_bot/venv/lib/python3.11/site-packages/h11/tests/helpers.pyget_all_eventsr      sd    J!!Y'''%   ;;***     c                 J    |                      |           t          |           S r   )receive_datar   )r   datas     r   receive_and_getr      s$    d$r   c                 V   g }| D ]}t          |          t          u r't          |j                  |_        d|_        d|_        |rMt          |d                   t          |          cxu r	t          u rn n|d         xj        |j        z  c_        |                    |           |S )NF)r
   Databytesr   chunk_start	chunk_endr	   )	in_events
out_eventsr   s      r   normalize_data_eventsr      s    J % %;;$uz**EJ %E#EO 	%$z"~..$u++EEEEEEEEErN5:-e$$$$r   c                   2    e Zd Zd Zed             ZddZdS )ConnectionPairc                     t           t          t                     t          t          t                    i| _        t           t          t          t           i| _        d S r   )CLIENT
ConnectionSERVERr   otherselfs    r   __init__zConnectionPair.__init__,   s6    Z//F9K9KL	fff5


r   c                 4    | j                                         S r   )r   valuesr&   s    r   connszConnectionPair.conns0   s    y!!!r   matchc                    t          |t                    s|g}d}d}|D ],}| j        |                             |          }|d}'||z  }-|r+| j        | j        |                                      |           |r+| j        | j        |                                      d           t          | j        | j        |                            }|dk    r|}t          |t                    s|g}||k    sJ |S )Nr   FTr,   )
isinstancelistr   sendr%   r   r   )	r'   rolesend_eventsexpectr   closed
send_eventnew_datar   s	            r   r0   zConnectionPair.send5   s   +t,, 	(&-K% 	! 	!Jy++J77H   	;Idj&'44T::: 	:Idj&'44S999#DIdj.>$?@@
W F&$'' 	XFV####r   N)r,   )__name__
__module____qualname__r(   propertyr+   r0    r   r   r    r    +   sR        6 6 6 " " X"     r   r    N)_connection_events_stater   r   r   r    r;   r   r   <module>r?      s               	 	 	       $" " " " " " " " " "r   