Class

LiveKitRtcConnection

Voice connection using LiveKit RTC. Used when Fluxer routes voice to LiveKit. Supports both audio playback (play) and video streaming (playVideo) to voice channels. Video uses node-webcodecs for decoding (no ffmpeg subprocess). Audio uses prism-media WebM demuxer.

Extends EventEmitter

Constructor1 Properties18 Methods21 Source

Constructor

new LiveKitRtcConnection(client: Client, channel: VoiceChannel, : string)

Param	Type	Description
client	`Client`	The Fluxer client instance
channel	`VoiceChannel`	The voice channel to connect to
_userId	`string`	The user ID (reserved for future use)

Properties

activeSpeakers: Set<string> (readonly)

audioSource: AudioSource | null

audioTrack: LocalAudioTrack | null

channel: VoiceChannel (readonly)

client: Client (readonly)

currentStream: { destroy?: () => void } | null

currentVideoStream: { destroy?: () => void } | null

guildId: string (readonly)

lastServerEndpoint: string | null

lastServerToken: string | null

participantTrackSids: Map<string, string> (readonly)

playing: boolean (readonly)

Whether audio is currently playing.

playingVideo: boolean (readonly)

Whether a video track is currently playing in the voice channel.

receiveSubscriptions: Map<string, LiveKitReceiveSubscription> (readonly)

requestedSubscriptions: Map<string, boolean> (readonly)

room: Room | null

videoSource: VideoSource | null

videoTrack: LocalVideoTrack | null

Methods

audioDebug(msg: string, data?: object): void

Param	Type	Description
msg	`string`
data?	`object`

clearReceiveSubscriptions(): void

connect(server: GatewayVoiceServerUpdateDispatchData, : GatewayVoiceStateUpdateDispatchData): Promise<void>

Connect to the LiveKit room using voice server and state from the gateway. Called internally by VoiceManager; typically not used directly.

Param	Type	Description
server	`GatewayVoiceServerUpdateDispatchData`	Voice server update data (endpoint, token)
_state	`GatewayVoiceStateUpdateDispatchData`	Voice state update data (session, channel)

debug(msg: string, data?: object | string): void

Param	Type	Description
msg	`string`
data?	`object \| string`

destroy(): void

Disconnect from the room and remove all event listeners.

disconnect(): void

Disconnect from the LiveKit room and stop all playback.

emitDisconnect(source: string): void

Param	Type	Description
source	`string`

getParticipantId(participant: RemoteParticipant): string

Param	Type	Description
participant	`RemoteParticipant`

getVolume(): number

Get current volume (0-200).

isAudioTrack(track: RemoteTrack): boolean

Param	Type	Description
track	`RemoteTrack`

isConnected(): boolean

Returns true if the LiveKit room is connected and not destroyed.

isSameServer(endpoint: string | null, token: string): boolean

Returns true if we're already connected to the given server (skip migration).

Param	Type	Description
endpoint	`string \| null`	Voice server endpoint from the gateway
token	`string`	Voice server token

play(urlOrStream: string | NodeJS.ReadableStream): Promise<void>

Play audio from a WebM/Opus source. Publishes to the LiveKit room as an audio track. When `urlOrStream` is a string: `http(s)://` is fetched; `file://` or any other string is read from the local filesystem (path). Otherwise pass a Node.js ReadableStream.

Param	Type	Description
urlOrStream	`string \| NodeJS.ReadableStream`	WebM/Opus HTTP(S) URL, `file://` URL, filesystem path, or ReadableStream

playOpus(: NodeJS.ReadableStream): void

Param	Type	Description
_stream	`NodeJS.ReadableStream`

playVideo(urlOrBuffer: string | ArrayBuffer | Uint8Array, options?: VideoPlayOptions): Promise<void>

Play video from an MP4 URL or buffer. Streams decoded frames to the LiveKit room as a video track. Uses node-webcodecs for decoding (no ffmpeg). Supports H.264 (avc1) and H.265 (hvc1/hev1) codecs.

Param	Type	Description
urlOrBuffer	`string \| ArrayBuffer \| Uint8Array`	Video source: HTTP(S) URL to an MP4 file, or raw ArrayBuffer/Uint8Array of MP4 data
options?	`VideoPlayOptions`	Optional playback options (see VideoPlayOptions)

playVideoFFmpeg(url: string, options?: VideoPlayOptions): Promise<void>

FFmpeg-based video playback. Bypasses node-webcodecs to avoid libc++abi crashes on macOS. Requires ffmpeg and ffprobe in PATH. URL input only.

Param	Type	Description
url	`string`
options?	`VideoPlayOptions`

setVolume(volumePercent: number): void

Set playback volume (0-200, 100 = normal). Affects current and future playback.

Param	Type	Description
volumePercent	`number`

stop(): void

Stop playback and clear both audio and video tracks.

stopVideo(): void

subscribeParticipantAudio(participantId: string, options: { autoResubscribe?: boolean; }): LiveKitReceiveSubscription

Param	Type	Description
participantId	`string`
options	`{ autoResubscribe?: boolean; }`

subscribeParticipantTrack(participant: RemoteParticipant, track: RemoteTrack, options: { autoSubscribe?: boolean; }): void

Param	Type	Description
participant	`RemoteParticipant`
track	`RemoteTrack`
options	`{ autoSubscribe?: boolean; }`