cjh}dZddlmZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZmZddlZddlmZddlmZddlmZdd lmZmZej4eZd ZGd d eZGd deZ eddZ!GddZ"Gdde jFZ$Gdde$Z%GddejLZ'GddZ(GddZ)y)ae The MIT License (MIT) Copyright (c) 2015-2021 Rapptz Copyright (c) 2021-present Pycord Development Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software. THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. ) annotationsN)deque namedtuple)utils) BaseActivity) SpeakingState)ConnectionClosedInvalidArgument)DiscordWebSocketKeepAliveHandlerVoiceKeepAliveHandlerDiscordVoiceWebSocketReconnectWebSocketceZdZdZdddZy)rz*Signals to safely reconnect the WebSocket.TresumecB||_||_|rd|_yd|_y)NRESUMEIDENTIFY)shard_idrop)selfrrs B/var/www/html/venv/lib/python3.12/site-packages/discord/gateway.py__init__zReconnectWebSocket.__init__<s   $(*N)__name__ __module__ __qualname____doc__rrrrr9s 4+/5rrceZdZdZy)WebSocketClosurezIAn exception to make up for the fact that aiohttp doesn't signal closure.N)rrrr r!rrr#r#BsSrr# EventListenerzpredicate event result futurec&eZdZddZdZdZdZy)GatewayRatelimiterc|||_||_d|_||_t j |_d|_y)N)max remainingwindowperasyncioLocklockr)rcountr,s rrzGatewayRatelimiter.__init__Js2 LLN  rctj}||j|jzkDry|jdk(S)NFr)timer+r,r*rcurrents ris_ratelimitedz!GatewayRatelimiter.is_ratelimitedSs4))+ T[[488+ +~~""rcrtj}||j|jzkDr|j|_|j|jk(r||_|jdk(r|j||jz z S|xjdzc_|jdk(r||_y)Nrrr()r2r+r,r)r*r3s r get_delayzGatewayRatelimiter.get_delayYs))+ T[[488+ +!XXDN >>TXX %!DK >>Q 88w45 5 ! >>Q !DKrc,K|j4d{|j}|r>tjd|j|t j |d{dddd{y7e77 #1d{7swYyxYww)Nz=WebSocket in shard ID %s is ratelimited, waiting %.2f seconds)r/r7_logwarningrr-sleep)rdeltas rblockzGatewayRatelimiter.blockks~99 + +NN$E SMM mmE*** + + ++ + + + +sWBA9BA A?#A;$A?( B3A=4B;A?=B?BB B BN)nN@)rrrrr5r7r=r!rrr&r&Is# $ +rr&c0eZdZdZdZdZdZdZdZy)r cD|jdd}|jdd}|jdd}tjj|g|i|||_|j |_||_d|_||_ d|_ d|_ d|_ tj|_tj |_tj |_tj |_t)d|_|j,|_y) NwsintervalrTz5Keeping shard ID %s websocket alive with sequence %s.z7Shard ID %s heartbeat blocked for more than %s seconds.z5Can't keep up, shard ID %s websocket is %.1fs behind.inf)pop threadingThreadrrB thread_id_main_thread_idrCdaemonrmsg block_msg behind_msgEvent_stop_evr2 perf_counter _last_ack _last_send _last_recvfloatlatency_max_heartbeat_timeoutheartbeat_timeout)rargskwargsrBrCrs rrzKeepAliveHandler.__init__xs ZZd #::j$/::j$/!!$888!||     JRQ!) **,++-++-U| !#!:!:rc|jj|js|j|jzt j krtjd|j|jjd}tj||jj} |j|j%y|j'}tj)|j*|j|d|jj-|}tj||jj} d} |jd t j |_"|jj|jsyy#t $rtj#dYwxYw#|j%YyxYw#t.j0j2$r|dz } t5j6|j8}dj;t=j>|}|j@d |}n#tB$r|j@}YnwxYwtj||j|YnwxYwO#t $r|j%Y?wxYw) NzJShard ID %s has stopped responding to the gateway. Closing and restarting.loopz7An error occurred while stopping the gateway. Ignoring.dr z0 Loop thread traceback (most recent call last): )#rOwaitrCrSrWr2rPr9r:rrBcloser-run_coroutine_threadsafer]result Exception exceptionstop get_payloaddebugrKsend_heartbeat concurrentfutures TimeoutErrorsys_current_framesrIjoin traceback format_stackrLKeyErrorrR)rcorofdatatotalframestackrKs rrunzKeepAliveHandler.runs?--$$T]]3!7!77$:K:K:MM 'MM ww}}T*44T MHHJ IIK##%D JJtxxS :77))$/D00DGGLLIA 6@ $#'"3"3"5e--$$T]]33!NNQ IIK&--:: @  $'$7$7$9$:N:N$OE%'GGI,B,B5,I$JE#'>>"23116!9 (1"&..C1 S$--? @ $   sx<F:"J4&G6:GGGGG36"J/!I0:6J/0JJ/J$J/,J4.J//J44KKc\|jj|jjdS)Nrr^)rB HEARTBEATsequencers rrhzKeepAliveHandler.get_payloads!gg''dgg.>.>??rc8|jjyN)rOsetrs rrgzKeepAliveHandler.stops rc6tj|_yr)r2rPrSrs rtickzKeepAliveHandler.ticks++-rctj}||_||jz |_|jdkDr6t j |j|j|jyy)Nr_) r2rPrQrRrUr9r:rMrrack_times rackzKeepAliveHandler.acksT$$&!$//1 <<"  LL$-- F rN) rrrrrzrhrgrrr!rrr r ws#;(36j@.Grr c*eZdZfdZdZdZxZS)rcpt||i|td|_d|_d|_d|_y)N)maxlenz>>>s )rrrbytesreturnbool)rrrrbrrs@rrrs)-??rrceZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZedZdZdZdZeddddddddZd*dZdZdZdZed+dZdZdZdZ d Z!d!Z"d"Z#ddd#d$d%Z$ d*dddd&d'Z%d,d(Z&d-d)Z'y).r a Implements a WebSocket for Discord's gateway v6. Attributes ---------- DISPATCH Receive only. Denotes an event to be sent to Discord, such as READY. HEARTBEAT When received tells Discord to keep the connection alive. When sent asks if your connection is currently alive. IDENTIFY Send only. Starts a new session. PRESENCE Send only. Updates your presence. VOICE_STATE Send only. Starts a new connection to a voice guild. VOICE_PING Send only. Checks ping time to a voice guild, do not use. RESUME Send only. Resumes an existing connection. RECONNECT Receive only. Tells the client to reconnect to a new gateway. REQUEST_MEMBERS Send only. Asks for the full member list of a guild. INVALIDATE_SESSION Receive only. Tells the client to optionally invalidate the session and IDENTIFY again. HELLO Receive only. Tells the client the heartbeat interval. HEARTBEAT_ACK Receive only. Confirms receiving of a heartbeat. Not having one implies a connection issue. GUILD_SYNC Send only. Requests a guild sync. gateway The gateway we are currently connected to. token The authentication token for discord. rr r_ c$||_||_d|_g|_d|_t j |_d|_d|_ d|_ tj|_ t|_d|_t#|_y)Ncyrr!)rXs rz+DiscordWebSocket.__init__..%sr)socketr] _dispatch_dispatch_listeners _keep_aliverF get_identrH session_idr~resume_gateway_urlzlib decompressobj_zlib bytearray_buffer _close_coder& _rate_limiter)rrr]s rrzDiscordWebSocket.__init__ s}  ,#% ",,. "&'')  { /1rc0|jj Sr)rclosedrs ropenzDiscordWebSocket.open5s;;%%%%rc6|jjSr)rr5rs rr5zDiscordWebSocket.is_ratelimited9s!!0022rc(|jd|y)Nsocket_raw_receive)rrrvs rdebug_log_receivez"DiscordWebSocket.debug_log_receive<s +T2rcyrr!)r_s r log_receivezDiscordWebSocket.log_receive?s rFN)initialgatewayrsessionr~rcK|xs"|jjd{}|jj|d{}|||j} |jj| _|j | _|j j | _|j| _ || _ |j j| _ || _ || _ || j_ |j j| _|| _|| _|j j$| _|j(r"| j*| _| j.| _|j j3| t4j7d|| j9d{|s| j;d{| S| j=d{| S777@7(7w)zmCreates a main websocket for Discord from a :class:`Client`. This is for internal use only. Nr\z!Created websocket connected to %s)http get_gateway ws_connectr]token _connectionparsers_discord_parsersdispatchrr call_hooks_initial_identifyrr shard_countrr~rWrV_enable_debug_events debug_sendsendrr_update_referencesr9ri poll_eventidentifyr) clsclientrrrrr~rrrBs r from_clientzDiscordWebSocket.from_clientBs <6;;#:#:#<<{{--g66 fkk *;;$$++$0088  **55 & $,!++77  $*$6$6$H$H!  & &mmBG11BN--b1 6@mmo++-  Iiik G=66   sX"G6G*"G6G-E'G6/G00G6 G2 G6#G4$G6-G60G62G64G6c|jj}t||||}|jj ||S)a`Waits for a DISPATCH'd event that meets the predicate. Parameters ---------- event: :class:`str` The event name in all upper case to wait for. predicate A function that takes a data parameter to check for event properties. The data parameter is the 'd' key in the JSON message. result A function that takes the same data parameter and executes to send the result to the future. If ``None``, returns the data. Returns ------- asyncio.Future A future to wait for. )event predicaterdfuture)r] create_futurer$rr)rrrrdrentrys rwait_forzDiscordWebSocket.wait_forwsD(((*9VF    ''. rcK|j|jtjdddddddd}|j*|j |j|j g|d d <|j }|j |j!|j|jd d d |d d<|j|jj|d d<|jd|j|jd{|j|d{tjd|jy7>7'w)zSends the IDENTIFY packet.pycord)osbrowserdeviceTr)r propertiescompresslarge_thresholdvr|Nr^shardrF)statusgamesinceafkpresenceintentsbefore_identify)rz*Shard ID %s has sent the IDENTIFY payload.)rrrnplatformrrr _activity_status_intentsvaluerr send_as_jsonr9info)rpayloadstates rrzDiscordWebSocket.identifys9--,,'& !#&    == $)9)9)E%)]]D4D4D$EGCL !   ?? &%--*C-- (GCL $ >> %&+nn&:&:GCL #oo t}}d6L6L   ((( > N   )s$DEEEE&EEcK|j|j|j|jdd}|j |d{t j d|jy7%w)zSends the RESUME packet.)seqrrr|Nz(Shard ID %s has sent the RESUME payload.)rr~rrrr9rrrrs rrzDiscordWebSocket.resumes^++}}"oo ((( >**'' 5C**W%C$;DL s# 94==#N   NN. 6 WWT]wws|ggcl ?DM       ! ! #  T^^# 78jjl""(77T'''##$$((*T^^###++779D++D111TZZ 45>#3h$ ''(8(8(D(D(FGGG  &&(T,,,4<**,&&,T]];; $ "& Et}}Ujjdj+++(uEE LL. 3  G "&((8R"8 8DK%HDM"<0DO&*+?&@D ##'==D IIL  %   i "&((8R"8 8DK%#'==D IIQ  %   ((/D J%d&>&>? *LE5{{e#\\F!u% *- "',,"6$ELLU??V; V8 "V3-V;3V88V;cL|j}| tdS|jS)zDMeasures latency between a HEARTBEAT and a HEARTBEAT_ACK in seconds.rDrrTrUr heartbeats rrUzDiscordWebSocket.latencyF)$$ (0uU|Gi6G6GGrcR|jxs|jj}|dvS)N)riiiiii)rr close_coderrs r_can_handle_closez"DiscordWebSocket._can_handle_closeLs(94;;#9#9EEErcK |jj|jd{}|jtj j ur$|j|jd{y|jtj jur$|j|jd{y|jtj jtj jtj jtj jfvrtjd|t y7(77#t"j$t f$r}|j&r!|j&j)d|_t+|t"j$r+tj-dt/|j0d|j2xs|jj4}|j7r,tj-d|t/|j0dtj-d|t9|j|j0|dd}~wwxYww)zPolls for a DISPATCH event and handles the general gateway loop. Raises ------ ConnectionClosed The websocket connection was terminated for unhandled reasons. timeoutN Received %sz3Timed out receiving packet. Attempting a reconnect.z1Websocket closed with %s, attempting a reconnect.z+Websocket closed with %s, cannot reconnect.rr)rreceiverVraiohttp WSMsgTypeTEXTr+rvBINARYCLOSEDCLOSINGCLOSEERRORr9rir#r-rmrrg isinstancerrrrr2r4r )rrKers rrzDiscordWebSocket.poll_eventPs  ++D4O4O+PPCxx7,,111++CHH555W..555++CHH555!!((!!))!!''!!''   =#.&& Q55$$&67   %%'#' !W112 OP(7TA##=t{{'='=D%%' MtT(7TA GN&KK$--d! sxJ )EEAE6E7E;J (((s?A AA cK|jr!|jjd|_||_|jj |d{y7wNr )rrgrrrbr3s rrbzDiscordWebSocket.closesL       ! ! ##D kkT***sAAAArrrT)FF)r[)(rrrr rr}rrUre VOICE_PINGrrr_rrr GUILD_SYNCrpropertyrr5rr classmethodrrrrr+rUr4rrrrrjrWr`rfrbr!rrr r s%NHIHHKJ FIO EMJ2*&&33  22h6$OL M~0@HH F(T) )UU15T4#)7;uTX)& )+rr ceZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdddZdZdZeZdZdZeddddZdZdZej6fdZdZdZed"dZ ed#dZ!dZ"d Z#d$d!Z$y)%raGImplements the WebSocket protocol for handling voice connections. Attributes ---------- IDENTIFY Send only. Starts a new voice session. SELECT_PROTOCOL Send only. Tells discord what encryption mode and how to connect for voice. READY Receive only. Tells the websocket that the initial connection has completed. HEARTBEAT Send only. Keeps your websocket connection alive. SESSION_DESCRIPTION Receive only. Gives you the secret key required for voice. SPEAKING Send only. Notifies the client if you are currently speaking. HEARTBEAT_ACK Receive only. Tells you your heartbeat has been acknowledged. RESUME Sent only. Tells the client to resume its session. HELLO Receive only. Tells you that your websocket connection was acknowledged. RESUMED Sent only. Tells you that your RESUME request has succeeded. CLIENT_CONNECT Indicates a user has connected to voice. CLIENT_DISCONNECT Receive only. Indicates a user has disconnected from voice. rrrrrrrrrrr N)hookcl||_||_d|_d|_d|_i|_|r||_yyr)rBr]rr secret_keyssrc_map_hook)rrr]rps rrzDiscordVoiceWebSocket.__init__s=  DJ rc Kywrr!)rrXs rrtzDiscordVoiceWebSocket._hook s  scKtjd||jjt j |d{y7w)Nz"Sending voice websocket frame: %s.)r9rirBrGrrLrs rrz"DiscordVoiceWebSocket.send_as_jsons6 7>ggu~~d3444sAA A AcK|j}|j|jt|j|j dd}|j |d{y7w)N)r server_idrr|)rrrstrrxrrrrrs rrzDiscordVoiceWebSocket.resumesV  ++ 1#.. (((sAA%A#A%c K|j}|jt|jt|jj |j |jdd}|j|d{y7w)N)rxuser_idrrr|) rrryrxuseridrrrrzs rrzDiscordVoiceWebSocket.identify sf  -- 1uzz}}-#..  (((sA9B;B<BF)rrpcKd|jd}|jj}|j|dd{}|||j|}||_||_d|_tj|_ |r|jd{|S|jd{|S7}7"7 w)z7Creates a voice websocket for the :class:`VoiceClient`.zwss://z/?v=4)rN)r]rpr?) endpoint_staterrr]rrrVrFrrHrr)rrrrprrrrBs rrz!DiscordVoiceWebSocket.from_client-s6??+51}}!!w<< fkk 5 $(! **, ))+   ++-   =  s5=CB=ACB?C6C7C?CCcnK|jd|||ddd}|j|d{y7w)Nudp)addressportmode)protocolrvr|)SELECT_PROTOCOLr)riprrrs rselect_protocolz%DiscordVoiceWebSocket.select_protocol@s>&&!$&dC (((s +535cK|jd|jjid}|j|d{y7w)N audio_ssrcr|)CLIENT_CONNECTrssrcrrs rclient_connectz$DiscordVoiceWebSocket.client_connectKs@%% 0 0 5 56  (((s:AAAcxK|jt|ddd}|j|d{y7w)Nr)speakingdelayr|)SPEAKINGrrrzs rspeakzDiscordVoiceWebSocket.speakSs1#e*q-QR(((s 0:8:cKtjd||d}|jd}||jk(r|j |d{nC||j k(r|j jn||jk(rtjdn||jk(r.|d|j_ |j|d{n||jk(r?|ddz }t|t!|d |_|j j#nh||j$k(rY|d }t'|d }|d }||j(vr||j(|d <n |j(j+|||d i|j-||d{y7e77 w)Nz"Voice websocket frame received: %srr^zVoice RESUME succeeded.rr r g@)rBrCrr|r)r|r)r9rirr initial_connectionrrrrrSESSION_DESCRIPTIONrrload_secret_keyrrminrrrrsupdatert)rrKrrvrCrr}rs rr+z&DiscordVoiceWebSocket.received_messageXs 7= Ywws|  ))$/ / / 4%% %    " 4<<  II/ 0 4++ +$(LD   !&&t, , , 4:: 01F:H4#h"4 D     " " $ 4== F7B F> F:!CF>1F<2F>:F><F>cTK|j}|d|_|d|_|d|_t d}t j d|ddt j d|dd t j d |d |j|jj||j|jf|jj|jdd{}tjd |d }|jd|}|||jd|_t j d|t#|dz d|_tjd|j|j$|dDcgc]}||jj&vs|}}tjddj)||d}|j+|j|j$|d{tj-d|y79cc}w7#w)NrrrJz>HrrrFz>Irz)received packet in initial_connection: %srasciizdetected ip: %s port: %smodesz'received supported encryption modes: %srz(selected the voice protocol for use (%s))rr voice_port endpoint_iprstruct pack_intorsendtor] sock_recvr9rir'rr unpack_fromrrsupported_modesrprr) rrvrpacketrecvip_startip_endrrs rrz(DiscordVoiceWebSocket.initial_connectionxs  &\ < J2vq!,vq"-vq%**5 FU%6%68H8H$IJYY((r:: >EAx((//8''dCIMB1E  -uxxD"'] dd6F6F6V6V.VD   NOQx""588UZZ>>> @r6r8rKr9)r-rrBr:rr;r<r=r+rrrvrBr9rir r?rAr@r)rrKs rrz DiscordVoiceWebSocket.poll_events$$TWW__%6EE 88w((-- -''(8(8(BC C C XX**00 0 JJ}c *"477T: H XX    $ $    # #    % %  JJ}c *"477T@P@PQ Q  F Cs#3F FAF F C6F  F cK|j|jj||_|jj |d{y7wrh)rrgrrBrbr3s rrbzDiscordVoiceWebSocket.closesD    '    ! ! #ggmmm&&&sA AAAri)rzlist[float] | float)r)%rrrr rrr r}rrrrrrrCLIENT_DISCONNECTrrtrrjrrrmrrrr voicerr+rrlrUrrrrbr!rrrrs<HO EIHM F EGN-1 5"N ) )16T$ ))!. 3 3) $@D@HH YY R 'rr)*r __future__rr-concurrent.futuresrkloggingrrnrFr2rqr collectionsrrr;r`rrPrenumsr errorsr r getLoggerrr9__all__rerr#r$r&rGr rClientWebSocketResponserr rr!rrrs2#   )" 5w" 55TyT?,KL ++++\XGy''XGv7,7&?W%D%D? h+h+Vm'm'r