
    h                        d dl Z d dlZd dlZd dlZd dlmZ d dlmZ d Zej                  j                  e j                  j                  dd       d      ej                  j                  d	               Zej                  j                  e j                  j                  dd       d      d
        Zej                  j                  e j                  j                  dd       d      ej                  j                  d               Zy)    N)Mock)WebSocketServerFactoryc                 L   K   t        j                  |       d {    | S 7 wNasynciosleep)whatwhens     d/var/www/Befach/backend/env/lib/python3.12/site-packages/autobahn/asyncio/test/test_aio_websocket.py
echo_asyncr      s"     
--
K s   $"$USE_ASYNCIOFztest runs on asyncio only)reasonc                  B   K   dt        dd       d {   k(  sJ y 7 	w)NzHello!r   )r        r   test_echo_asyncr      s#      Z!444444s   
c                 `    t        |       } |       }t               }|j                  |       y )N)loop)r   r   connection_made)
event_loopfactoryserver	transports       r   test_websocket_custom_loopr      s(    $*5GYFI
9%r   c                 b  K   dt        j                         g d fd}t               } |       }||_        t	               }|j                  |       dj                  g d      |_        |j                           d {    t              dk(  sJ d   z  k(  sJ y 7 "w)N*   c                 R   K   t        j                  d       d {    | | z  S 7 	w)N   r   )xs    r   fooz)test_async_on_connect_server.<locals>.foo)   s&     mmA1u 	s   '%
'c                    K           d {   }j                  |       t        j                  |        y 7 ,wr   )appendtxaioresolve)reqvdoner!   numvaluess     r   
on_connectz0test_async_on_connect_server.<locals>.on_connect-   s1     c(NadC  s   ><->   
)	s   GET /ws HTTP/1.1s   Host: www.example.coms   Sec-WebSocket-Version: 13s,   Origin: http://www.example.com.malicious.coms,   Sec-WebSocket-Extensions: permessage-deflates+   Sec-WebSocket-Key: tXAxWFUqnhi86Ajj7dRY5g==s   Connection: keep-alive, Upgrades   Upgrade: websocketr,   r   r   )
r$   create_futurer   	onConnectr   r   joindataprocessHandshakelen)	r   r+   r   r   r   r(   r!   r)   r*   s	        @@@@r   test_async_on_connect_serverr3   !   s      C DF!
 %&GYF!FI
9%,, 
  
FK 
JJv;!!9c	!!! s   BB/
B-#B/)osr   pytestr$   unittest.mockr   autobahn.asyncio.websocketr   r   markskipifenvirongetr   r   r3   r   r   r   <module>r<      s    	     =
 

}e<<E`a5  b5
 

}e<<E`a& b& 

}e<<E`a$"  b$"r   