wgBddlZddlmZddlmZddlmZddlZeedZGddejZ Gdd Z e ejejeere ndejd Zy) N)queue)Event) selectorswebsocket_handshakec.eZdZdZgiffd ZdZxZS)Threadz This wrapper class provides gevent Greenlet interface that is compatible with the standard library's Thread class. c,t||g|i|yN)super__init__)selftargetargskwargs __class__s h/home/mcse/projects/flask/flask-venv/lib/python3.12/site-packages/engineio/async_drivers/gevent_uwsgi.pyr zThread.__init__s 1$1&1c"|jSr )runr s r_runz Thread._runsxxzr)__name__ __module__ __qualname____doc__r r __classcell__)rs@rrr s%'r2rrc:eZdZdZdZdZdZdZdZdZ dZ y ) uWSGIWebSocketzx This wrapper class provides a uWSGI WebSocket interface that is compatible with eventlet's implementation. c.||_d|_g|_yr )app_sockreceived_messages)r handlerservers rr zuWSGIWebSocket.__init__s !#rctj|_||_tjd|_t tdrtj|_n[t|_ tj|_ d}tj||j|j|_|j!|tj"y)Nrequest_contextctj}|j|tj |j |j !#t j$r|j|YywxYw)z5Sets event when data becomes available to read on fd.N) rDefaultSelectorregister EVENT_READselectsetgevent GreenletExit unregister)fdeventsels rselect_greenlet_runnerz7uWSGIWebSocket.__call__..select_greenlet_runner/sf//1 R!5!56'  **'NN2&'s"A$A?>A?)uwsgi connection_fdr!environr_req_ctxhasattrr&r_eventrQueue _send_queuer-spawn_select_greenletr disconnect)r r7start_responser3s r__call__zuWSGIWebSocket.__call__s((*   !!# 5+ ,!113DM 'DK${{}D  '%+LL&  %D !  rc|j5|jj|jj yy)z"Disconnects uWSGI from the client.N)r8r>killr:r,rs rclosezuWSGIWebSocket.closeBs1 ==  ! ! & & ( KKOO  !rct|trtj}ntj}|j |||j y||y)zUTransmits message either in binary or UTF-8 text mode, depending on its type.Nr&) isinstancebytesr5websocket_send_binarywebsocket_sendr8)r msgmethods r_sendzuWSGIWebSocket._sendIsC c5 !00F))F == $ 3 6 3Krcrt|ts|St|dd}|dk\r|jdS|S)z7Returns either bytes or str, depending on message type.r0zutf-8)rGrHorddecode)r rKtypes r_decode_receivedzuWSGIWebSocket._decode_receivedUs;#u%J3q8} 2:::g& & rc|j|j|y|jj||jj y)zQueues a message for sending. Real transmission is done in wait method. Sends directly if uWSGI version is new enough.N)r8rMr<putr:r,)r rKs rsendzuWSGIWebSocket.sendas; == $ JJsO     % KKOO rc |j2 tj|j}|j |S|j r|j jdS|jjd}|rJ|jjg} |j|jjd- tj$}|r+|j j|j |nnD|j r|j jdS;#t$r|j YywxYw#tjj $rYnwxYw|D]4} |j#|#t$r|j YywxYw#t$r|j YywxYw)aTWaits and returns received messages. If running in compatibility mode for older uWSGI versions, it also sends messages that have been queued by send(). A return value of None means that connection was closed. This must be called repeatedly. For uWSGI < 2.1.x it must be called from the main greenlet.NrFr)timeoutF)block)r8r5websocket_recvOSErrorrDrTr"popr:waitclearappendr<getr-rEmptyrMwebsocket_recv_nb)r rK event_setmsgss rr_zuWSGIWebSocket.waitks}}( ..t}}MC,,S11))1155a88!KK,,Q,7 KK%%'D" KK(8(8(<(<5(<(IJ$#557..55 11#68))1155a88Y JJL $ &||11"!"#(( JJsO&( JJL#'((#$ #$sG D=#+EF9=EEE<;E<FF43F49GGN) rrrrr rArDrMrTrWr_rrrrs+$ !F  39rr)threadr queue_emptyr1 websocketsleep)r-r gevent.eventrrr5r9_websocket_availableGreenletrr JoinableQueuercrk_asyncrgrrrqsl  u&;< V__ I9I9Z  ;; #7T \\  r