z gk-ddlZddlZddlZddlmZddlmZmZmZddl m Z ddl m Z ej eZGddeZGd d eZdS) N)unquote)ConnectionDenyWebSocketServerFactoryWebSocketServerProtocol)defer)parse_x_forwarded_forceZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z dd ZdZddZddZdZdZdZdZdZd S)WebSocketProtocolzj Protocol which supports WebSockets and forwards incoming messages to the websocket channels. websocketFc |jj|_|j|||_d|_t j|_t j|_ g|_ |j D]`\}}| d}d|vr|j || dfa|j}|j}t%|drQt%|drAt'|j|jg|_t'|j|jg|_nd|_d|_|jjrUt3t5|j |jj|jj|jj|j\|_|_g}|j D]J\}}|dkr?dt=|d dD}K|j! d|_!tEj#|jj$|d t=|j!d|j!|j |j%|j|j|d |_&|j&>|j&'|j(|j&)|j*n:#tV$r-tX-t]j/wxYwtEj0|_1|j1S) Nascii_latin1hostportssec-websocket-protocolc6g|]}|S)strip).0xs D/var/www/html/env/lib/python3.11/site-packages/daphne/ws_protocol.py z/WebSocketProtocol.onConnect..Cs-$$$&' $$$,r )typepathraw_pathheaders query_stringclientserver subprotocols)2factory server_classr"protocol_connectedrequestprotocol_to_accepttime socket_opened last_ping clean_headersritemsencodeappendlower transportgetPeergetHosthasattrstrrr client_addr server_addrproxy_forwarded_address_headerr dictproxy_forwarded_port_headerproxy_forwarded_proto_header client_schemerdecodesplitrr maybeDeferredcreate_application_raw_query_stringapplication_deferred addCallbackapplicationCreateWorked addErrbackapplicationCreateFailed Exceptionloggererror traceback format_excDeferredhandshake_deferred)selfr'namevaluepeerrr#headers r onConnectzWebSocketProtocol.onConnects-l/  &&t,,, "&!Y[[9 !#D &4466 R R e{{7++4<<"))4::<<h9O9O*PQQQQ>))++D>))++DtV$$ (v)>)> ($' NNDI#> $' NNDI#>  #' #' {9 7L+,,K>K;K<$ 884 $"4L!%!3   666$$+25<<3H3H+I+I+O+OPS+T+T$$$L ++G44DI(-(; .'#DI$4$4W$=$=>> $ #1$($:".".$0   ) )D %(4)55d6RSSS)44T5QRRR    LL-// 0 0 0   #(."2"2&&s +J'L7M c ||_|jddi|jdd|jj|jrdt|jzndddS)zk Called when the background thread has successfully made the application instance. rzwebsocket.connectr connecting%s:%sNrr!)application_queue put_nowaitr" log_actionr'rr6tuple)rNrXs rrDz)WebSocketProtocol.applicationCreateWorkedcs "3 ))63F*GHHH    )#'E$*:$;$;;;    rc:t||S)z9 Called when application creation fails. )rHrI)rNfailures rrFz)WebSocketProtocol.applicationCreateFailedws  Wrc td|j|jdd|jj|jrdt|jzndddS)Nz!WebSocket %s open and establishedr connectedrVrW)rHdebugr6r"rZr'rr[rNs ronOpenzWebSocketProtocol.onOpensy 8$:JKKK    )#'E$*:$;$;;;    rcj|jr"td|jdStd|jt j|_|r|jd|ddS|jd|dddS)NzMuting incoming frame on %szWebSocket incoming frame on %szwebsocket.receive)rbytesutf8)rtext) mutedrHr`r6r)r+rXrYr=)rNpayloadisBinarys r onMessagezWebSocketProtocol.onMessages :  LL68H I I I F 5t7GHHH    " - -,w??       " - -,gnnV6L6LMM     rc p|j|td|j|js-t |dr|jd|d|j dd|j j |jrdt|jzndd dS) z8 Called when Twisted closes the socket. zWebSocket closed for %srXzwebsocket.disconnect)rcoder disconnectedrVNrW) r"protocol_disconnectedrHr`r6rgr4rXrYrZr'rr[)rNwasCleanrlreasons ronClosezWebSocketProtocol.onCloses ))$/// .0@AAAz gd,?@@   " - -/>>       )#'E$*:$;$;;;    rcd|vrtd|ddkr+||dddS|ddkrR|j|jkr|dS||dddS|ddkr|j|jkrtd |d dr)|d drtd |d |d dr||d d|d dr ||d ddSdSdS)NrzMessage has no type definedzwebsocket.accept subprotocolzwebsocket.closerlrlzwebsocket.sendz4Socket has not been accepted, so cannot send over itrdrfz'Got invalid WebSocket reply message on z$ - contains both bytes and text keysTF) ValueError serverAcceptgetstateSTATE_CONNECTING serverReject serverClose serverSend)rNmessages r handle_replyzWebSocketProtocol.handle_replys  :;; ; 6?0 0 0   gkk->> ? ? ? ? ? V_ 1 1 1zT222!!#####  gkk&$&?&? @@@@@ V_ 0 0 0zT222 !WXXX{{7D)) gkk&$.G.G  jww!{{7D)) 8 0$777{{64(( 8777771 0 8 8rct|dr+|jtdddS|ddS)zF Called by the server when our application tracebacks rMizInternal server errorrlrpirtN)r4rMerrbackrsendCloseFrame)rN exceptions rhandle_exceptionz"WebSocketProtocol.handle_exceptionsn 4- . . +  # + +C0GHHH        T  * * * * *rNc~|j||`td|jdS)zO Called when we get a message saying to accept the connection. z$WebSocket %s accepted by applicationN)rMcallbackrHr`r6)rNrss rrvzWebSocketProtocol.serverAccepts? ((555  # ;T=MNNNNNrc ^|jtdd|`|j|t d|j|jdd|j j |jrdt|jzndd dS) zO Called when we get a message saying to reject the connection. iz Access deniedrz$WebSocket %s rejected by applicationr rejectedrVNrW) rMrrr"rnrHr`r6rZr'rr[ras rrzzWebSocketProtocol.serverRejects '' O < < <     # ))$/// ;T=MNNN    )#'E$*:$;$;;;    rc|j|jkr|td|j|r|||dS||d|dS)z@ Server-side channel message to send a message. z&Sent WebSocket packet to client for %sreN)rxryrvrHr`r6 sendMessager.)rNcontentbinarys rr|zWebSocketProtocol.serverSends :. . .       =t?OPPP  =   Wf - - - - -   W^^F33V < < < < |dn|}||dS)zA Server-side channel message to close the socket Nirt) sendClose)rNrls rr{zWebSocketProtocol.serverCloses+|tt D!!!!!rc8tj|jz S)z> Returns the time since the socket was opened )r)r*ras rdurationzWebSocketProtocol.duration sy{{T///rc||jjkr$|jjdkr||j|jkr:||jjkr|dSdS|j|jkrWtj |j z |jj kr0| tj |_ dSdSdS)zK Called periodically to see if we should timeout something rN) rr"websocket_timeoutr{rxrywebsocket_connect_timeoutrz STATE_OPENr)r+ ping_interval _sendAutoPingras rcheck_timeoutsz WebSocketProtocol.check_timeoutss MMOOdk; ; ; -22       :. . .}}!FFF!!#####GF Z4? * * dn, 0III""$$$!%+ *IIrc:tt|SN)hashidras r__hash__zWebSocketProtocol.__hash__%sBtHH~~rcBt|t|kSr)r)rNothers r__eq__zWebSocketProtocol.__eq__(s$xx2e99$$rc(d|jd|jdS)Nz)r6rras r__repr__zWebSocketProtocol.__repr__+s:>:J:J:JDIIIVVrr)F)__name__ __module__ __qualname____doc__application_typergrSrDrFrbrjrqr~rrvrzr|r{rrrrrrrrr r sH # ED'D'D'L   (        .888. + + +OOOO   * = = = =""""000 ---(%%%WWWWWrr c,eZdZdZeZdZfdZxZS)WebSocketFactoryz Factory subclass that remembers what the "main" factory is, so WebSocket protocols can access it to get reply ID info. c>||_tj|g|Ri|dSr)r%r__init__)rNr%argskwargss rrzWebSocketFactory.__init__8s1('>t>>>v>>>>>rc tt||}||_|S#t$r0t dtjzwxYw)zh Builds protocol instances. We use this to inject the factory object into the protocol. zCannot build protocol: %s) superr buildProtocolr$rGrHrIrJrK)rNaddrprotocol __class__s rrzWebSocketFactory.buildProtocol<sr -t44BB4HHH#H O    LL4y7K7M7MM N N N  s 04:A.) rrrrr rrr __classcell__)rs@rrr/sX !H???         rr)loggingr)rJ urllib.parserautobahn.twisted.websocketrrrtwisted.internetrutilsr getLoggerrrHr rrrrrs   #"""""((((((  8 $ $ZWZWZWZWZW/ZWZWZWz-r