voice

type AEADEncrypter struct {
	// contains filtered or unexported fields
}

type AudioReceiver interface {
	// Open starts receiving audio from the voice connection.
	Open()

	// CleanupUser cleans up any audio resources for the given user.
	CleanupUser(userID snowflake.ID)

	// Close stops receiving audio from the voice connection.
	Close()
}

type AudioReceiverCreateFunc func(logger *slog.Logger, receiver OpusFrameReceiver, connection Conn) AudioReceiver

type AudioSender interface {
	Open()
	Close()
}

type AudioSenderCreateFunc func(logger *slog.Logger, provider OpusFrameProvider, conn Conn) AudioSender

type CloseHandlerFunc func(gateway Gateway, err error, reconnect bool)

type Conn interface {
	// Gateway returns the voice Gateway used by the voice Conn.
	Gateway() Gateway

	// UDP returns the voice UDPConn conn used by the voice Conn.
	UDP() UDPConn

	// ChannelID returns the ID of the voice channel the voice Conn is openedChan to.
	ChannelID() *snowflake.ID

	// GuildID returns the ID of the guild the voice Conn is openedChan to.
	GuildID() snowflake.ID

	// UserIDBySSRC returns the ID of the user for the given SSRC.
	UserIDBySSRC(ssrc uint32) snowflake.ID

	// SetSpeaking sends a speaking packet to the Conn socket discord.
	SetSpeaking(ctx context.Context, flags SpeakingFlags) error

	// SetOpusFrameProvider lets you inject your own OpusFrameProvider.
	SetOpusFrameProvider(handler OpusFrameProvider)

	// SetOpusFrameReceiver lets you inject your own OpusFrameReceiver.
	SetOpusFrameReceiver(handler OpusFrameReceiver)

	// SetEventHandlerFunc lets listen for voice gateway events.
	SetEventHandlerFunc(eventHandlerFunc EventHandlerFunc)

	// Open opens the voice conn. It will connect to the voice gateway and start the Conn conn after it receives the Gateway events.
	Open(ctx context.Context, channelID snowflake.ID, selfMute bool, selfDeaf bool) error

	// Close closes the voice conn. It will close the Conn conn and disconnect from the voice gateway.
	Close(ctx context.Context)

	// HandleVoiceStateUpdate provides the gateway.EventVoiceStateUpdate to the voice conn. Which is needed to connect to the voice Gateway.
	HandleVoiceStateUpdate(update botgateway.EventVoiceStateUpdate)

	// HandleVoiceServerUpdate provides the gateway.EventVoiceServerUpdate to the voice conn. Which is needed to connect to the voice Gateway.
	HandleVoiceServerUpdate(update botgateway.EventVoiceServerUpdate)
}

type ConnConfigOpt func(config *connConfig)

type ConnCreateFunc func(guildID snowflake.ID, userID snowflake.ID, voiceStateUpdateFunc StateUpdateFunc, removeConnFunc func(), opts ...ConnConfigOpt) Conn

type Encrypter interface {
	// Encrypt encrypts the given RTP header and opus data and returns the encrypted packet.
	Encrypt(header [RTPHeaderSize]byte, data []byte) []byte

	// Decrypt decrypts the given packet and returns the RTP header and opus data.
	Decrypt(rtpHeaderSize int, packet []byte) ([]byte, error)
}

type EncryptionMode string

type EventHandlerFunc func(gateway Gateway, opCode Opcode, sequenceNumber int, data GatewayMessageData)

type Gateway interface {
	// SSRC returns the SSRC of the current voice connection.
	SSRC() uint32

	// Open opens a new websocket connection to the voice gateway.
	Open(ctx context.Context, state State) error

	// Close closes the websocket connection to the voice gateway.
	Close()

	// CloseWithCode closes the websocket connection to the voice gateway with a specific close code.
	CloseWithCode(code int, message string)

	// Status returns the Status of the Gateway.
	Status() Status

	// Send sends a message to the voice gateway.
	Send(ctx context.Context, opCode Opcode, data GatewayMessageData) error

	// Latency returns the current latency of the voice gateway connection.
	Latency() time.Duration
}

type GatewayBinaryMessageUnknown []byte

type GatewayCloseEventCode struct {
	Code        int
	Description string
	Explanation string
	Reconnect   bool
}

type GatewayConfigOpt func(config *gatewayConfig)

type GatewayCreateFunc func(daveManager godave.Session, eventHandlerFunc EventHandlerFunc, closeHandlerFunc CloseHandlerFunc, opts ...GatewayConfigOpt) Gateway

type GatewayMessage struct {
	Op   Opcode             `json:"op"`
	D    GatewayMessageData `json:"d,omitempty"`
	RawD json.RawMessage    `json:"-"`
	Seq  int                `json:"s,omitempty"`
}

type GatewayMessageData interface {
	// contains filtered or unexported methods
}

type GatewayMessageDataClientConnect struct {
	UserID     snowflake.ID `json:"user_id"`
	AudioCodec string       `json:"audio_codec"`
	VideoCodec string       `json:"video_codec"`
}

type GatewayMessageDataClientDisconnect struct {
	UserID snowflake.ID `json:"user_id"`
}

type GatewayMessageDataClientsConnect struct {
	UserIDs []snowflake.ID `json:"user_ids"`
}

type GatewayMessageDataDaveInvalidCommitWelcome struct {
	TransitionID uint16 `json:"transition_id"`
}

type GatewayMessageDataDaveMLSAnnounceCommitTransition struct {
	TransitionID  uint16
	CommitMessage []byte
}

type GatewayMessageDataDaveMLSCommitWelcome []byte

type GatewayMessageDataDaveMLSExternalSenderPackage []byte

type GatewayMessageDataDaveMLSKeyPackage []byte

type GatewayMessageDataDaveMLSProposals []byte

type GatewayMessageDataDaveMLSWelcome struct {
	TransitionID   uint16
	WelcomeMessage []byte
}

type GatewayMessageDataDaveProtocolExecuteTransition struct {
	TransitionID uint16 `json:"transition_id"`
}

type GatewayMessageDataDaveProtocolPrepareEpoch struct {
	ProtocolVersion uint16 `json:"protocol_version"`
	Epoch           int    `json:"epoch"`
}

type GatewayMessageDataDaveProtocolPrepareTransition struct {
	ProtocolVersion uint16 `json:"protocol_version"`
	TransitionID    uint16 `json:"transition_id"`
}

type GatewayMessageDataDaveProtocolReadyForTransition struct {
	TransitionID uint16 `json:"transition_id"`
}

type GatewayMessageDataGuildSync struct{}

type GatewayMessageDataHeartbeat struct {
	T      int64 `json:"t"`
	SeqAck int   `json:"seq_ack"`
}

type GatewayMessageDataHeartbeatACK struct {
	T int64 `json:"t"`
}

type GatewayMessageDataHello struct {
	HeartbeatInterval float64 `json:"heartbeat_interval"`
}

type GatewayMessageDataIdentify struct {
	GuildID                snowflake.ID `json:"server_id"`
	UserID                 snowflake.ID `json:"user_id"`
	SessionID              string       `json:"session_id"`
	Token                  string       `json:"token"`
	MaxDaveProtocolVersion int          `json:"max_dave_protocol_version"`
}

type GatewayMessageDataReady struct {
	SSRC  uint32           `json:"ssrc"`
	IP    string           `json:"ip"`
	Port  int              `json:"port"`
	Modes []EncryptionMode `json:"modes"`
}

type GatewayMessageDataResume struct {
	GuildID   snowflake.ID `json:"server_id"` // wtf is this?
	SessionID string       `json:"session_id"`
	Token     string       `json:"token"`
	SeqAck    int          `json:"seq"`
}

type GatewayMessageDataResumed struct{}

type GatewayMessageDataSelectProtocol struct {
	Protocol Protocol                             `json:"protocol"`
	Data     GatewayMessageDataSelectProtocolData `json:"data"`
}

type GatewayMessageDataSelectProtocolData struct {
	Address string         `json:"address"`
	Port    int            `json:"port"`
	Mode    EncryptionMode `json:"mode"`
}

type GatewayMessageDataSessionDescription struct {
	Mode                EncryptionMode `json:"mode"`
	SecretKey           []byte         `json:"secret_key"`
	DaveProtocolVersion int            `json:"dave_protocol_version"`
}

type GatewayMessageDataSpeaking struct {
	Speaking SpeakingFlags `json:"speaking"`
	Delay    int           `json:"delay"`
	SSRC     uint32        `json:"ssrc"`
	UserID   snowflake.ID  `json:"user_id,omitempty"`
}

type GatewayMessageDataUnknown json.RawMessage

type Manager interface {
	// HandleVoiceStateUpdate handles a gateway.EventVoiceStateUpdate
	HandleVoiceStateUpdate(update gateway.EventVoiceStateUpdate)

	// HandleVoiceServerUpdate handles a gateway.EventVoiceServerUpdate
	HandleVoiceServerUpdate(update gateway.EventVoiceServerUpdate)

	// CreateConn creates a new voice connection for the given guild.
	CreateConn(guildID snowflake.ID) Conn

	// GetConn returns the voice connection for the given guild.
	GetConn(guildID snowflake.ID) Conn

	// Conns returns all voice connections. This function is thread-safe.
	Conns() iter.Seq[Conn]

	// RemoveConn removes the voice connection for the given guild.
	RemoveConn(guildID snowflake.ID)

	// Close closes all voice connections.
	Close(ctx context.Context)
}

type ManagerConfigOpt func(config *managerConfig)

type NoopEncrypter struct {
	// contains filtered or unexported fields
}

type Opcode int

type OpusFrameProvider interface {
	// ProvideOpusFrame provides an opus frame to the AudioSender.
	ProvideOpusFrame() ([]byte, error)

	// Close closes the OpusFrameProvider.
	Close()
}

type OpusFrameReceiver interface {
	// ReceiveOpusFrame receives an opus frame.
	ReceiveOpusFrame(userID snowflake.ID, packet *Packet) error

	// CleanupUser cleans up any audio resources for the given user.
	CleanupUser(userID snowflake.ID)

	// Close stops receiving audio from the voice connection.
	Close()
}

type OpusReader struct {
	// contains filtered or unexported fields
}

type OpusWriter struct {
	// contains filtered or unexported fields
}

type Packet struct {
	Type byte
	// Sequence is the sequence number of the packet.
	Sequence uint16
	// Timestamp is the timestamp of the packet.
	Timestamp uint32
	// SSRC is the users SSRC of the packet.
	SSRC         uint32
	HasExtension bool
	ExtensionID  int
	Extension    []byte
	CSRC         []uint32
	HeaderSize   int
	// Opus is the actual opus data of the packet.
	Opus []byte
}

type Protocol string

type SpeakingFlags int

type SsrcLookupFunc func(ssrc uint32) snowflake.ID

type State struct {
	GuildID snowflake.ID
	UserID  snowflake.ID

	ChannelID *snowflake.ID
	SessionID string
	Token     string
	Endpoint  string
}

type StateProviderFunc func() State

type StateUpdateFunc func(ctx context.Context, guildID snowflake.ID, channelID *snowflake.ID, selfMute bool, selfDeaf bool) error

type Status int

type UDPConn interface {
	// LocalAddr returns the local network address, if known.
	LocalAddr() net.Addr

	// RemoteAddr returns the remote network address, if known.
	RemoteAddr() net.Addr

	// SetSecretKey sets the secret key used to encrypt packets.
	SetSecretKey(encryptionMode EncryptionMode, secretKey []byte) error

	SetDeadline(t time.Time) error

	// SetReadDeadline sets the read deadline for the UDPConn connection.
	SetReadDeadline(t time.Time) error

	// SetWriteDeadline sets the write deadline for the UDPConn connection.
	SetWriteDeadline(t time.Time) error

	// Open opens the UDPConn connection.
	Open(ctx context.Context, ip string, port int, ssrc uint32) (string, int, error)

	// Close closes the UDPConn connection.
	Close() error

	// Read reads a packet from the UDPConn connection. This implements the io.Reader interface.
	Read(p []byte) (int, error)

	// ReadPacket reads a packet from the UDPConn connection.
	ReadPacket() (*Packet, error)

	// Write writes a packet to the UDPConn connection. This implements the io.Writer interface.
	Write(p []byte) (int, error)
}

type UDPConnConfigOpt func(config *udpConnConfig)

type UDPConnCreateFunc func(daveSession godave.Session, ssrcLookup SsrcLookupFunc, opts ...UDPConnConfigOpt) UDPConn

type UserFilterFunc func(userID snowflake.ID) bool