ConnectPacketInterceptor

class ConnectPacketInterceptor(session: PlayerSession, tokenService: TokenService, transferTokenValidator: TransferTokenValidator, router: Router, playerManager: PlayerManagerImpl, eventBus: EventBus, transferService: PlayerTransferService, onBackendSelected: (String) -> Unit) : ChannelInboundHandlerAdapter

Intercepts the Connect packet on stream 0 to inject proxy referral data.

Constructors

constructor(session: PlayerSession, tokenService: TokenService, transferTokenValidator: TransferTokenValidator, router: Router, playerManager: PlayerManagerImpl, eventBus: EventBus, transferService: PlayerTransferService, onBackendSelected: (String) -> Unit)

open fun channelActive(ctx: ChannelHandlerContext?)

open fun channelInactive(ctx: ChannelHandlerContext?)

open override fun channelRead(ctx: ChannelHandlerContext, msg: Any)

open fun channelReadComplete(ctx: ChannelHandlerContext?)

open fun channelRegistered(ctx: ChannelHandlerContext?)

open fun channelUnregistered(ctx: ChannelHandlerContext?)

open fun channelWritabilityChanged(ctx: ChannelHandlerContext?)

open fun exceptionCaught(ctx: ChannelHandlerContext?, cause: Throwable?)

open override fun handlerAdded(ctx: ChannelHandlerContext)

open override fun handlerRemoved(ctx: ChannelHandlerContext)

fun setBackendStream(stream: QuicStreamChannel)

Assigns the backend stream used for forwarding the modified Connect packet.

open fun userEventTriggered(ctx: ChannelHandlerContext?, evt: Any?)