Package moe.kyokobot.koe.internal.gateway

Class MediaGatewayV8Connection

java.lang.Object

moe.kyokobot.koe.internal.gateway.AbstractMediaGatewayConnection

moe.kyokobot.koe.internal.gateway.MediaGatewayV5Connection

moe.kyokobot.koe.internal.gateway.MediaGatewayV8Connection

All Implemented Interfaces:

MediaGatewayConnection

public class MediaGatewayV8Connection
extends MediaGatewayV5Connection

Adds message buffering, the server re-delivers messages after the last acknowledged sequence number on resume. Koe implements DAVE only on this version.

Field Summary

Fields inherited from class moe.kyokobot.koe.internal.gateway.AbstractMediaGatewayConnection

allocator, bootstrap, channel, connectAttempt, connectFuture, connection, eventExecutor, resumable, sslContext, version, voiceServerInfo, websocketURI

Constructor Summary

Constructors

Constructor	Description
MediaGatewayV8Connection(MediaConnectionImpl connection, VoiceServerInfo voiceServerInfo)

Method Summary

Modifier and Type	Method	Description
@Nullable DAVEManager	getDAVEManager()
protected void	handlePayload(io.netty.buffer.ByteBuf byteBuf)
protected void	handlePayload(JsonObject object)	Handles the opcodes all gateway versions share, newer versions override it to handle their own opcodes first.
protected Object	heartbeatPayload()
protected JsonObject	identifyPayload()
protected void	onSessionDescription(JsonObject data)	Called after the connection handler got the session description.
protected void	onUserDisconnected(String userId)	Called before the listeners are notified.
protected void	onUsersConnected(List<String> userIds)	Called after the listeners were notified.
protected JsonObject	resumePayload()
void	sendMLSCommitWelcome(byte[] commitWelcome)
void	sendMLSInvalidCommitWelcome(int transitionId)
void	sendMLSKeyPackage(byte[] keyPackage)	Send a marshalled MLS key package
void	sendSecureFramesReadyForTransition(int transitionId)

Methods inherited from class moe.kyokobot.koe.internal.gateway.MediaGatewayV5Connection

codecs, getValve, onProtocolSelected, onReady, onStreamsChanged

Methods inherited from class moe.kyokobot.koe.internal.gateway.AbstractMediaGatewayConnection

close, getPing, identify, isOpen, onClose, reconnect, resume, sendInternalBinPayload, sendInternalPayload, sendRaw, sendRawBin, start, stripPort80, stripScheme, updateSpeaking

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MediaGatewayV8Connection

public MediaGatewayV8Connection(MediaConnectionImpl connection,
 VoiceServerInfo voiceServerInfo)

Method Details

getDAVEManager

@Nullable
public @Nullable DAVEManager getDAVEManager()

identifyPayload

protected JsonObject identifyPayload()

Overrides:

identifyPayload in class MediaGatewayV5Connection

resumePayload

protected JsonObject resumePayload()

Overrides:

resumePayload in class MediaGatewayV5Connection

heartbeatPayload

protected Object heartbeatPayload()

Overrides:

heartbeatPayload in class AbstractMediaGatewayConnection

handlePayload

protected void handlePayload(JsonObject object)

Description copied from class: AbstractMediaGatewayConnection

Handles the opcodes all gateway versions share, newer versions override it to handle their own opcodes first.

Overrides:

handlePayload in class AbstractMediaGatewayConnection

handlePayload

protected void handlePayload(io.netty.buffer.ByteBuf byteBuf)

Overrides:

handlePayload in class AbstractMediaGatewayConnection

onSessionDescription

protected void onSessionDescription(JsonObject data)

Description copied from class: AbstractMediaGatewayConnection

Called after the connection handler got the session description.

Overrides:

onSessionDescription in class AbstractMediaGatewayConnection

onUsersConnected

protected void onUsersConnected(List<String> userIds)

Description copied from class: AbstractMediaGatewayConnection

Called after the listeners were notified.

Overrides:

onUsersConnected in class AbstractMediaGatewayConnection

onUserDisconnected

protected void onUserDisconnected(String userId)

Description copied from class: AbstractMediaGatewayConnection

Called before the listeners are notified.

Overrides:

onUserDisconnected in class MediaGatewayV5Connection

sendMLSKeyPackage

public void sendMLSKeyPackage(byte[] keyPackage)

Description copied from interface: MediaGatewayConnection

Send a marshalled MLS key package

sendMLSCommitWelcome

public void sendMLSCommitWelcome(byte[] commitWelcome)

sendMLSInvalidCommitWelcome

public void sendMLSInvalidCommitWelcome(int transitionId)

sendSecureFramesReadyForTransition

public void sendSecureFramesReadyForTransition(int transitionId)