i%TUdZddlmZddlZddlZddlZddlmZmZm Z m Z m Z m Z m Z ddlmZddlTddlmZdd lmZmZdd lmZdd lmZmZe rLdd lmZdd lmZddlmZddl m!Z!ddl"m#Z#ddlm$Z$m%Z%m&Z&m'Z'ddl(m)Z)m*Z*ddlm+Z+ddl,m-Z.m/Z0m1Z1e e*e)fZ2de3d< ddl4Z5ddl6Z5dZ7n #e8$rdZ7YnwxYwdZ9ej:e;Z<GddZ=Gdde=Z>dS)a: The MIT License (MIT) Copyright (c) 2015-present Rapptz 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)AnyCallableListOptional TYPE_CHECKINGTupleUnion)opus)*)ClientException) AudioPlayer AudioSource)MISSING)VoiceConnectionStatehas_dave)DiscordVoiceWebSocket)Client)Guild)ConnectionState) ClientUser)EncoderAPPLICATION_CTLBAND_CTL SIGNAL_CTL) StageChannel VoiceChannel)abc)GuildVoiceStateVoiceServerUpdateSupportedModesboolhas_naclTF) VoiceProtocol VoiceClientcJeZdZdZddZdd Zdd ZdddddZddZd dZ dS)!r%aA class that represents the Discord voice protocol. This is an abstract class. The library provides a concrete implementation under :class:`VoiceClient`. This class allows you to implement a protocol to allow for an external method of sending voice, such as Lavalink_ or a native library implementation. These classes are passed to :meth:`abc.Connectable.connect `. .. _Lavalink: https://github.com/freyacodes/Lavalink Parameters ------------ client: :class:`Client` The client (or its subclasses) that started the connection request. channel: :class:`abc.Connectable` The voice channel that is being connected to. clientrchannelabc.ConnectablereturnNonec"||_||_dSN)r(r))selfr(r)s U/usr/local/lib/hermes-agent/venv/lib/python3.11/site-packages/discord/voice_client.py__init__zVoiceProtocol.__init__bs$ (/ dataGuildVoiceStatePayloadcKt)a|coro| An abstract method that is called when the client's voice state has changed. This corresponds to ``VOICE_STATE_UPDATE``. .. warning:: This method is not the same as the event. See: :func:`on_voice_state_update` Parameters ------------ data: :class:`dict` The raw :ddocs:`voice state payload `. NotImplementedErrorr/r3s r0on_voice_state_updatez#VoiceProtocol.on_voice_state_updatefs"!r2VoiceServerUpdatePayloadcKt)a>|coro| An abstract method that is called when initially connecting to voice. This corresponds to ``VOICE_SERVER_UPDATE``. Parameters ------------ data: :class:`dict` The raw :ddocs:`voice server update payload `. r6r8s r0on_voice_server_updatez$VoiceProtocol.on_voice_server_updatews"!r2F self_deaf self_mutetimeoutfloat reconnectr#r>r?cKt)a@|coro| An abstract method called when the client initiates the connection request. When a connection is requested initially, the library calls the constructor under ``__init__`` and then calls :meth:`connect`. If :meth:`connect` fails at some point then :meth:`disconnect` is called. Within this method, to start the voice connection flow it is recommended to use :meth:`Guild.change_voice_state` to start the flow. After which, :meth:`on_voice_server_update` and :meth:`on_voice_state_update` will be called. The order that these two are called is unspecified. Parameters ------------ timeout: :class:`float` The timeout for the connection. reconnect: :class:`bool` Whether reconnection is expected. self_mute: :class:`bool` Indicates if the client should be self-muted. .. versionadded:: 2.0 self_deaf: :class:`bool` Indicates if the client should be self-deafened. .. versionadded:: 2.0 r6)r/r@rBr>r?s r0connectzVoiceProtocol.connects:"!r2forcecKt)z|coro| An abstract method called when the client terminates the connection. See :meth:`cleanup`. Parameters ------------ force: :class:`bool` Whether the disconnection was forced. r6r/rEs r0 disconnectzVoiceProtocol.disconnects"!r2c||j\}}|jj|dS)aThis method *must* be called to ensure proper clean-up during a disconnect. It is advisable to call this from within :meth:`disconnect` when you are completely done with the voice protocol instance. This method removes it from the internal state cache that keeps track of currently alive voice clients. Failure to clean-up will cause subsequent connections to report that it's still connected. N)r)_get_voice_client_keyr( _connection_remove_voice_client)r/key_id_s r0cleanupzVoiceProtocol.cleanups:L6688  44V<<<<r#r?r#r+r,rEr#r+r,r+r,) __name__ __module__ __qualname____doc__r1r9r<rDrHrOr2r0r%r%Ms(0000""""" " " " "SXkp""""""> " " " " = = = = = =r2r%ceZdZUdZded<djfd Ze Zd ed <e Z d ed <d Z ded<e dkdZ e dldZ e dmdZe dmdZe dmdZe dndZe dodZe dpdZe dqdZe drd!Ze dmd"Zdsd'Zdtd)Zdud,Zdvd.Zd/d/d0dwd5Zdxdyd8Ze drd9Ze drd:Zd/d;dzd=Zd6d>d{d@Z d|dAZ!d}dCZ"d~dEZ#d~dFZ$d~dGZ%d~dHZ&dIdJdKdLdMdNdOdPdd^Z'd|d_Z(d|d`Z)ddaZ*ddbZ+ddcZ,e ddeZ-e-j.ddfZ-dLdgddiZ/xZ0S)r&aRepresents a Discord voice connection. You do not create these, you typically get them from e.g. :meth:`VoiceChannel.connect`. Warning -------- In order to use PCM based AudioSources, you must have the opus library installed on your system and loaded through :func:`opus.load_opus`. Otherwise, your AudioSources must be opus encoded (e.g. using :class:`FFmpegOpusAudio`) or the library will not be able to transmit audio. Attributes ----------- session_id: :class:`str` The voice connection session ID. token: :class:`str` The voice connection token. endpoint: :class:`str` The endpoint we are connecting to. channel: Union[:class:`VoiceChannel`, :class:`StageChannel`] The voice channel connected to. VocalGuildChannelr)r(rr*r+r,ctstdtstdt|||j}t |_t |_|j |_ ||_ d|_ d|_ d|_ t |_d|_||_dS)Nz+PyNaCl library needed in order to use voicez*davey library needed in order to use voicer)r$ RuntimeErrorrsuperr1rKr server_idsocketloop_statesequence timestamp_playerencoder _incr_noncecreate_connection_state)r/r(r)state __class__s r0r1zVoiceClient.__init__s NLMM M MKLL L )))"% /4z ',  .2 ' !151M1M1O1Or2r# warn_nacl warn_dave)aead_xchacha20_poly1305_rtpsizexsalsa20_poly1305_litexsalsa20_poly1305_suffixxsalsa20_poly1305zTuple[SupportedModes, ...]supported_modesrc|jjS)z-:class:`Guild`: The guild we're connected to.)r)guildr/s r0rszVoiceClient.guilds|!!r2rc|jjS)zB:class:`ClientUser`: The user connected to voice (i.e. ourselves).)rbuserrts r0rvzVoiceClient.users{r2 Optional[str]c|jjSr.)rK session_idrts r0ryzVoiceClient.session_id**r2c|jjSr.)rKtokenrts r0r|zVoiceClient.tokens%%r2c|jjSr.)rKendpointrts r0r~zVoiceClient.endpoint s((r2intc|jjSr.)rKssrcrts r0rzVoiceClient.ssrc$$r2r"c|jjSr.)rKmoderts r0rzVoiceClient.moderr2 List[int]c|jjSr.)rK secret_keyrts r0rzVoiceClient.secret_keyrzr2rc|jjSr.)rKwsrts r0rzVoiceClient.wss""r2rAc|jjSr.)rKr@rts r0r@zVoiceClient.timeouts''r2c@|jjr|jjjndS)a:class:`str`: Get the voice privacy code of this E2EE session's group. A new privacy code is created and cached each time a new transition is executed. This can be None if there is no active DAVE session happening. .. versionadded:: 2.7 N)rK dave_sessionvoice_privacy_coderts r0rzVoiceClient.voice_privacy_code"s&DHCSC`jt,??fjjr2attrstrvaluelimitct||}||z|krt||ddSt||||zdS)Nr)getattrsetattr)r/rrrvals r0 checked_addzVoiceClient.checked_add-sTdD!! ;   D$ " " " " " D$e , , , , ,r2rc t|Sr.)rrts r0rhz#VoiceClient.create_connection_state6s#D)))r2r3r4cJK|j|d{VdSr.)rKvoice_state_updater8s r0r9z!VoiceClient.on_voice_state_update9s511$77777777777r2r:cJK|j|d{VdSr.)rKvoice_server_updater8s r0r<z"VoiceClient.on_voice_server_update<s522488888888888r2Fr=rBr@r>r?cTK|j||||dd{VdS)NF)rBr@r>r?resume)rKrD)r/rBr@r>r?s r0rDzVoiceClient.connect?s[&&IQZch'           r2>@Optional[float]ch|j||jSr.)rKwait is_connected)r/r@s r0wait_until_connectedz VoiceClient.wait_until_connectedDs. g&&&,,...r2cJ|jj}|stdn|jS)a:class:`float`: Latency between a HEARTBEAT and a HEARTBEAT_ACK in seconds. This could be referred to as the Discord Voice WebSocket latency and is an analogue of user's voice latencies as seen in the Discord client. .. versionadded:: 1.4 inf)rKrrAlatencyr/rs r0rzVoiceClient.latencyHs&  #%5uU|||2:5r2cJ|jj}|stdn|jS)zq:class:`float`: Average of most recent 20 HEARTBEAT latencies in seconds. .. versionadded:: 1.4 r)rKrrAaverage_latencyrs r0rzVoiceClient.average_latencyTs'   #%=uU|||2+==r2)rErEcK||j|dd{V|dS)zB|coro| Disconnects this voice client from voice. T)rErN)stoprKrHrOrGs r0rHzVoiceClient.disconnect]sT ))D)AAAAAAAAA r2)r@Optional[abc.Snowflake]cLK|j||d{VdS)a|coro| Moves you to a different voice channel. Parameters ----------- channel: Optional[:class:`abc.Snowflake`] The channel to move to. Must be a voice channel. timeout: Optional[:class:`float`] How long to wait for the move to complete. .. versionadded:: 2.4 Raises ------- asyncio.TimeoutError The move did not complete in time, but may still be ongoing. N)rKmove_to)r/r)r@s r0rzVoiceClient.move_tofs9&&&w88888888888r2c4|jS)z4Indicates if the voice client is connected to voice.)rKrrts r0rzVoiceClient.is_connected{s,,...r2bytesc|jjr+|jjr|jj|n|}t d}d|d<d|d<t jd|d|jt jd|d |jt jd|d |j t|d |j z}|||S) N rxr z>H>I _encrypt_) rKr can_encrypt encrypt_opus bytearraystruct pack_intorcrdrrr)r/r3packetheaderencrypt_packets r0_get_voice_packetzVoiceClient._get_voice_packets, 151A1M D  ) 6 6t < < <  2q q vq$-888vq$.999vq$)444 {TY'>??~ff---r2rctjt|j}t d}t jd|j|dd<| ddd|| t|t|t|j z|ddzSNrrrgr ) naclsecretAeadrrrrpackrgrencrypt ciphertextr/rr3boxnonces r0(_encrypt_aead_xchacha20_poly1305_rtpsizez4VoiceClient._encrypt_aead_xchacha20_poly1305_rtpsizeskuT_5566" Kd&677bqb  :666 E$KKve MMXX[`acbcac[dddr2ctjt|j}t d}||dd<||t|t|jzS)Nrr)rr SecretBoxrrrrrrs r0_encrypt_xsalsa20_poly1305z&VoiceClient._encrypt_xsalsa20_poly1305sck##E$/$:$:;;" crc  E$KKu>>IIIr2c&tjt|j}tjtjjj}||t||j z|zSr.) rrrrrutilsrandom NONCE_SIZErrrs r0!_encrypt_xsalsa20_poly1305_suffixz-VoiceClient._encrypt_xsalsa20_poly1305_suffixsgk##E$/$:$:;; !!$+"7"BCC E$KK77BBUJJr2cttjt|j}t d}t jd|j|dd<| ddd|| t|t|j z|ddzSr) rrrrrrrrrgrrrrs r0_encrypt_xsalsa20_poly1305_litez+VoiceClient._encrypt_xsalsa20_poly1305_litesk##E$/$:$:;;" Kd&677bqb  :666 E$KKu>>IIERTSTRTIUUr2NaudiorTg333333?fullauto)after applicationbitratefecexpected_packet_loss bandwidth signal_typesourcerr.Optional[Callable[[Optional[Exception]], Any]]rrrrrrrrrc|std|rtdt|tst d|jj|stj |||||||_ t||||_ |j dS)a Plays an :class:`AudioSource`. The finalizer, ``after`` is called after the source has been exhausted or an error occurred. If an error happens while the audio player is running, the exception is caught and the audio player is then stopped. If no after callback is passed, any caught exception will be logged using the library logger. Extra parameters may be passed to the internal opus encoder if a PCM based source is used. Otherwise, they are ignored. .. versionchanged:: 2.0 Instead of writing to ``sys.stderr``, the library's logger is used. .. versionchanged:: 2.4 Added encoder parameters as keyword arguments. Parameters ----------- source: :class:`AudioSource` The audio source we're reading from. after: Callable[[Optional[:class:`Exception`]], Any] The finalizer that is called after the stream is exhausted. This function must have a single parameter, ``error``, that denotes an optional exception that was raised during playing. application: :class:`str` Configures the encoder's intended application. Can be one of: ``'audio'``, ``'voip'``, ``'lowdelay'``. Defaults to ``'audio'``. bitrate: :class:`int` Configures the bitrate in the encoder. Can be between ``16`` and ``512``. Defaults to ``128``. fec: :class:`bool` Configures the encoder's use of inband forward error correction. Defaults to ``True``. expected_packet_loss: :class:`float` Configures the encoder's expected packet loss percentage. Requires FEC. Defaults to ``0.15``. bandwidth: :class:`str` Configures the encoder's bandpass. Can be one of: ``'narrow'``, ``'medium'``, ``'wide'``, ``'superwide'``, ``'full'``. Defaults to ``'full'``. signal_type: :class:`str` Configures the type of signal being encoded. Can be one of: ``'auto'``, ``'voice'``, ``'music'``. Defaults to ``'auto'``. Raises ------- ClientException Already playing audio or not connected. TypeError Source is not a :class:`AudioSource` or after is not a callable. OpusNotLoaded Source is not opus encoded and opus is not loaded. ValueError An improper value was passed as an encoder parameter. zNot connected to voice.zAlready playing audio.z"source must be an AudioSource not )rrrrrr)rN)rr is_playing isinstancer TypeErrorrjrUis_opusr rrfrrestart) r/rrrrrrrrs r0playzVoiceClient.playsP  "" =!";<< < ??   <!":;; ;&+.. ^\AQAZ\\]] ]~~ <'%9#' DL#64u===  r2cF|jduo|jS)z+Indicates if we're currently playing audio.N)rerrts r0rzVoiceClient.is_playings"|4'EDL,C,C,E,EEr2cF|jduo|jS)z6Indicates if we're playing audio, but if we're paused.N)re is_pausedrts r0rzVoiceClient.is_pauseds"|4'DDL,B,B,D,DDr2cX|jr"|jd|_dSdS)zStops playing audio.N)rerrts r0rzVoiceClient.stop!s5 < L     DLLL  r2cJ|jr|jdSdS)zPauses the audio playing.N)repauserts r0rzVoiceClient.pause's0 < ! L    ! !r2cJ|jr|jdSdS)zResumes the audio playing.N)rerrts r0rzVoiceClient.resume,s0 < " L   ! ! ! ! ! " "r2Optional[AudioSource]c,|jr |jjndS)zOptional[:class:`AudioSource`]: The audio source being played, if playing. This property can also be used to change the audio source currently being played. N)rerrts r0rzVoiceClient.source1s '+lr#r?r#r+r,)r)r@rr+r#rS)r)rr@rr+r,)r+r#)r3r)rrr+r)rrrrrrrrrr#rrArrrrr+r,rT)r+r)rrr+r,)r3rrr#r+r,)1rUrVrWrX__annotations__r1r$rkrrlrqpropertyrsrvryr|r~rrrrr@rrrhr9r<rDrrrrHrrrrrrrrrrrrrrsetterr __classcell__)rjs@r0r&r&s0PPPPPP*#lI"""""lI""""3O"""X"   X +++X+&&&X&)))X)%%%X%%%%X%+++X+###X#(((X(kkkXk----****88889999SXkp      ///// 6 6 6X 6>>>X>16]a999999*//// ....$ e e e eJJJJKKKK V V V VAE'.&*$"(\\\\\\|FFFFEEEE    !!!! """" ===X= ]''']'@DRRRRRRRRRRr2r&)?rX __future__rasynciologgingrtypingrrrrrr r r gatewayerrorsrplayerrrrr voice_staterrrr(rrsrrirrvrrrrrr)rrr types.voicer r4r!r:r"r[r nacl.secretr nacl.utilsr$ ImportError__all__ getLoggerrUrr%r&rYr2r0rs0#""""" MMMMMMMMMMMMMMMMMM######,,,,,,,,77777777:......&&&&&&      DDDDDDDDDDDD33333333 lL89HHHHH  w""o=o=o=o=o=o=o=o=dcRcRcRcRcR-cRcRcRcRcRs" B--B76B7