h{.ddlZddlZddlZddlmZddlmZmZmZddl m Z ddl m Z ejeZGddeZGd d eZy) N)unquote)ConnectionDenyWebSocketServerFactoryWebSocketServerProtocol)defer)parse_x_forwarded_forceZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z dd ZdZddZddZdZdZdZdZdZy )WebSocketProtocolzj Protocol which supports WebSockets and forwards incoming messages to the websocket channels. websocketFc^|jj|_|jj|||_d|_|jj |_tj|_tj|_ g|_ |jjD]y\}}|jd}d|vr|jdk(rt||_@|jj!|j|jdf{|j"j%}|j"j'}t)|drYt)|drMt+|j,|j.g|_t+|j,|j.g|_nd|_d|_|jj4rut7t9|j|jj4|jj:|jj<|j0\|_|_g}|jD]O\}}|dk(s t|jAdjCdDcgc]}|jE}}Q|jFjd|_#tIjJ|jjL|d t|jFjAd|jF|j |j|jN|j0|j2|d |_(|jPJ|jPjS|jT|jPjW|jXtIjd|_3|jfScc}w#tZ$r)t\j_tajbwxYw) Nascii_sdaphne-root-pathlatin1hostportssec-websocket-protocol,r ) typepathraw_path root_pathheaders query_stringclientserver subprotocols)4factory server_classrprotocol_connectedrequestprotocol_to_acceptrtime socket_opened last_ping clean_headersritemsencodelowerrappend transportgetPeergetHosthasattrstrrr client_addr server_addrproxy_forwarded_address_headerr dictproxy_forwarded_port_headerproxy_forwarded_proto_header client_schemedecodesplitstriprr maybeDeferredcreate_application_raw_query_stringapplication_deferred addCallbackapplicationCreateWorked addErrbackapplicationCreateFailed Exceptionloggererror traceback format_excDeferredhandshake_deferred) selfr namevaluepeerrrheaderxs N/var/www/Befach/backend/env/lib/python3.12/site-packages/daphne/ws_protocol.py onConnectzWebSocketProtocol.onConnects9ll//  &&t, "&..!YY[= !#D &446 e{{7+4<::<#66%,U^DN&&--tzz|U\\(=S.TU 7>>))+D>>))+DtV$v)>$' NDII#> $' NDII#> #' #' {{997L++,KK>>KK;;KK<<$$ 84 $"4L!%!3!3 66+25<<3H+I+O+OPS+T$&' $L$"4  ++G4DI(-(;(; ..'#DII$4$4W$=> $ !%#11$($:$:".."..$0 )D %((4))55d6R6RS))44T5Q5QR#(.."2&&&?$.  LL--/ 0   s&G(O:<+O:'O5>DO:5O::2P,c ||_|jjddi|jjdd|jj |j rdt|j znddy)zk Called when the background thread has successfully made the application instance. rzwebsocket.connectr connecting%s:%sNrr)application_queue put_nowaitr log_actionr rr/tuple)rHrTs rNr>z)WebSocketProtocol.applicationCreateWorkedhsm "3 ))63F*GH    ))9=9I9IGeD$4$455t  c0tj||S)z9 Called when application creation fails. )rBrC)rHfailures rNr@z)WebSocketProtocol.applicationCreateFailed|s  WrXc tjd|j|jj dd|j j |jrdt|jznddy)Nz!WebSocket %s open and establishedr connectedrRrS)rBdebugr/rrVr rrWrHs rNonOpenzWebSocketProtocol.onOpens^ 8$:J:JK    ))9=9I9IGeD$4$455t  rXcl|jr!tjd|jytjd|jt j|_|r|j jd|dy|j jd|jddy)NzMuting incoming frame on %szWebSocket incoming frame on %szwebsocket.receive)rbytesutf8)rtext) mutedrBr]r/r"r$rTrUr6)rHpayloadisBinarys rN onMessagezWebSocketProtocol.onMessages :: LL68H8H I  5t7G7GH   " " - -,w?   " " - -,gnnV6LM rXc |jj|tjd|j|j s*t |dr|jjd|d|jjdd|jj|jrdt|jzndd y) z8 Called when Twisted closes the socket. zWebSocket closed for %srTzwebsocket.disconnect)rcoder disconnectedrRNrS) rprotocol_disconnectedrBr]r/rdr-rTrUrVr rrW)rHwasCleanrireasons rNonClosezWebSocketProtocol.onCloses ))$/ .0@0@Azzgd,?@  " " - -/>     ))9=9I9IGeD$4$455t  rXc~d|vr td|ddk(r"|j|jddy|ddk(rM|j|jk(r|j y|j |jddy|ddk(r|j|jk(r td |jd dr!|jd drtd |d |jd dr|j|d d|jd dr|j|d dyyy)NrzMessage has no type definedzwebsocket.accept subprotocolzwebsocket.closeririzwebsocket.sendz4Socket has not been accepted, so cannot send over itrarcz'Got invalid WebSocket reply message on z$ - contains both bytes and text keysTF) ValueError serverAcceptgetstateSTATE_CONNECTING serverReject serverClose serverSend)rHmessages rN handle_replyzWebSocketProtocol.handle_replys+  :; ; 6?0 0   gkk-> ? V_ 1 1zzT222!!#  gkk&$&? @ V_ 0 0zzT222 !WXX{{7D)gkk&$.G !{{7D) 0$7{{64(7)1rXct|dr'|jjtddy|j dy)zF Called by the server when our application tracebacks rGizInternal server errorrirmirqN)r-rGerrbackrsendCloseFrame)rH exceptions rNhandle_exceptionz"WebSocketProtocol.handle_exceptionsC 4- .  # # + +C0GH    T  *rXNc~|jj||`tjd|jy)zO Called when we get a message saying to accept the connection. z$WebSocket %s accepted by applicationN)rGcallbackrBr]r/)rHrps rNrszWebSocketProtocol.serverAccepts3 ((5  # ;T=M=MNrXc z|jjtdd|`|jj |t j d|j|jjdd|jj|jrdt|jzndd y) zO Called when we get a message saying to reject the connection. iz Access deniedr}z$WebSocket %s rejected by applicationr rejectedrRNrS) rGr~rrrkrBr]r/rVr rrWr^s rNrwzWebSocketProtocol.serverRejects '' O <   # ))$/ ;T=M=MN    ))9=9I9IGeD$4$455t  rXc|j|jk(r|jtj d|j |r|j ||y|j |jd|y)z@ Server-side channel message to send a message. z&Sent WebSocket packet to client for %srbN)rurvrsrBr]r/ sendMessager')rHcontentbinarys rNryzWebSocketProtocol.serverSendsc ::.. .     =t?O?OP    Wf -   W^^F3V Returns the time since the socket was opened )r"r#r^s rNdurationzWebSocketProtocol.durationsyy{T////rXc@|j|jjkDr)|jjdk\r|j|j|j k(r9|j|jj kDr|jyy|j|jk(rctj|jz |jjkDr*|jtj|_ yyy)zK Called periodically to see if we should timeout something rN) rrwebsocket_timeoutrxrurvwebsocket_connect_timeoutrw STATE_OPENr"r$ ping_interval _sendAutoPingr^s rNcheck_timeoutsz WebSocketProtocol.check_timeoutss MMOdkk;; ; --2     ::.. .}}!F!FF!!#G ZZ4?? * dnn, 0I0II""$!%J+rXc*tt|SN)hashidr^s rN__hash__zWebSocketProtocol.__hash__*sBtH~rXc0t|t|k(Sr)r)rHothers rN__eq__zWebSocketProtocol.__eq__-s$x2e9$$rXc<d|jd|jdS)Nz)r/rr^s rN__repr__zWebSocketProtocol.__repr__0s#+D,<,<+?vdii]RSTTrXr)F)__name__ __module__ __qualname____doc__application_typerdrOr>r@r_rgrnr{rrsrwryrxrrrrrrXrNr r so # EI'V (    .8. +O * ="0 -(%UrXr c,eZdZdZeZdZfdZxZS)WebSocketFactoryz Factory subclass that remembers what the "main" factory is, so WebSocket protocols can access it to get reply ID info. cD||_tj|g|i|yr)rr__init__)rHrargskwargss rNrzWebSocketFactory.__init__=s"(''>t>v>rXc t||}||_|S#t$r,tj dt jzwxYw)zh Builds protocol instances. We use this to inject the factory object into the protocol. zCannot build protocol: %s)super buildProtocolrrArBrCrDrE)rHaddrprotocol __class__s rNrzWebSocketFactory.buildProtocolAsQ w,T2H#H O  LL4y7K7K7MM N  s 5A) rrrrr rrr __classcell__)rs@rNrr4s !H?  rXr)loggingr"rD urllib.parserautobahn.twisted.websocketrrrtwisted.internetrutilsr getLoggerrrBr rrrXrNrsT   #(   8 $_U/_UD -rX