/Jf{.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|_|jj|_tj|_tj|_ g|_ |j D]\}}| d}d|vr|dkrt||_L|j || df|j}|j}t)|drQt)|drAt+|j|jg|_t+|j|jg|_nd|_d|_|jjrUt7t9|j |jj|jj|jj|j\|_|_g}|j D]J\}}|dkr?dt| d!d D}K|j" d|_"tGj$|jj%|d t|j" d|j"|j|j |j&|j|j|d |_'|j'>|j'(|j)|j'*|j+n:#tX$r-tZ.t_j0wxYwtGj1|_2|j2S) Nascii_sdaphne-root-pathlatin1hostportssec-websocket-protocolc6g|]}|S)strip).0xs U/home/alex/cs2snipeproduction/venv/lib/python3.11/site-packages/daphne/ws_protocol.py z/WebSocketProtocol.onConnect..Gs-$$$&' $$$,r ) typepathraw_path root_pathheaders query_stringclientserver subprotocols)3factory server_classr#protocol_connectedrequestprotocol_to_acceptrtime socket_opened last_ping clean_headersr itemsencodelowerrappend transportgetPeergetHosthasattrstrrr client_addr server_addrproxy_forwarded_address_headerr dictproxy_forwarded_port_headerproxy_forwarded_proto_header client_schemedecodesplitrr maybeDeferredcreate_application_raw_query_stringapplication_deferred addCallbackapplicationCreateWorked addErrbackapplicationCreateFailed Exceptionloggererror traceback format_excDeferredhandshake_deferred)selfr(namevaluepeerrr$headers r onConnectzWebSocketProtocol.onConnectsal/  &&t,,, "&.!Y[[= !#D &4466 V V e{{7++4<<::<<#666%,U^^DNN&--tzz||U\\(=S=S.TUUUU>))++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 )rOpayloadisBinarys 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 %srYzwebsocket.disconnect)rcoder disconnectedrWNrX) r#protocol_disconnectedrIrar7rhr5rYrZr[r(rr\)rOwasCleanrmreasons ronClosezWebSocketProtocol.onCloses ))$/// .0@AAAz gd,?@@   " - -/>>       )9=9ISGeD$45555t   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.closermrmzwebsocket.sendz4Socket has not been accepted, so cannot send over itrergz'Got invalid WebSocket reply message on z$ - contains both bytes and text keysTF) ValueError serverAcceptgetstateSTATE_CONNECTING serverReject serverClose serverSend)rOmessages 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 rNizInternal server errorrmrqiruN)r5rNerrbackrsendCloseFrame)rO 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)rNcallbackrIrar7)rOrts rrwzWebSocketProtocol.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 rejectedrWNrX) rNrrr#rorIrar7r[r(rr\rbs rr{zWebSocketProtocol.serverRejects '' O < < <     # ))$/// ;T=MNNN    )9=9ISGeD$45555t   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 %srfN)ryrzrwrIrar7 sendMessager/)rOcontentbinarys rr}zWebSocketProtocol.serverSends :. . .       =t?OPPP  =   Wf - - - - -   W^^F33V < < < < |dn|}||dS)zA Server-side channel message to close the socket Niru) sendClose)rOrms rr|zWebSocketProtocol.serverCloses+|tt D!!!!!rc8tj|jz S)z> Returns the time since the socket was opened )r*r+rbs rdurationzWebSocketProtocol.durationsy{{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|ryrzwebsocket_connect_timeoutr{ STATE_OPENr*r, ping_interval _sendAutoPingrbs rcheck_timeoutsz WebSocketProtocol.check_timeoutss MMOOdk; ; ; -22       :. . .}}!FFF!!#####GF Z4? * * dn, 0III""$$$!%+ *IIrc:tt|SN)hashidrbs r__hash__zWebSocketProtocol.__hash__*sBtHH~~rcBt|t|kSr)r)rOothers r__eq__zWebSocketProtocol.__eq__-s$xx2e99$$rc(d|jd|jdS)Nz)r7rrbs r__repr__zWebSocketProtocol.__repr__0s TD,<TTdiTTTTrr)F)__name__ __module__ __qualname____doc__application_typerhrTrErGrcrkrrrrrwr{r}r|rrrrrrrrr r sH # EI'I'I'V   (        .888. + + +OOOO   * = = = =""""000 ---(%%%UUUUUrr 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__)rOr&argskwargss rrzWebSocketFactory.__init__=s1('>t>>>v>>>>>rc t|}||_|S#t$r0tdt jzwxYw)zh Builds protocol instances. We use this to inject the factory object into the protocol. zCannot build protocol: %s)super buildProtocolr%rHrIrJrKrL)rOaddrprotocol __class__s rrzWebSocketFactory.buildProtocolAsk ww,,T22H#H O    LL4y7K7M7MM N N N  s )-:A') rrrrr rrr __classcell__)rs@rrr4sX !H???         rr)loggingr*rK urllib.parserautobahn.twisted.websocketrrrtwisted.internetrutilsr getLoggerrrIr rrrrrs   #"""""((((((  8 $ $_U_U_U_U_U/_U_U_UD -r