Open-source multiplayer game server compatible with the RuneScape client
https://www.openrs2.org/
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
37 lines
1.2 KiB
37 lines
1.2 KiB
package org.openrs2.archive.cache.nxt
|
|
|
|
import io.netty.buffer.ByteBuf
|
|
import io.netty.channel.ChannelHandler
|
|
import io.netty.channel.ChannelHandlerContext
|
|
import io.netty.handler.codec.MessageToByteEncoder
|
|
|
|
@ChannelHandler.Sharable
|
|
public object Js5RequestEncoder : MessageToByteEncoder<Js5Request>(Js5Request::class.java) {
|
|
override fun encode(ctx: ChannelHandlerContext, msg: Js5Request, out: ByteBuf) {
|
|
when (msg) {
|
|
is Js5Request.Group -> {
|
|
out.writeByte(if (msg.prefetch) 32 else 33)
|
|
out.writeByte(msg.archive)
|
|
out.writeInt(msg.group)
|
|
out.writeShort(msg.build)
|
|
out.writeShort(0)
|
|
}
|
|
|
|
is Js5Request.Connected -> {
|
|
out.writeByte(6)
|
|
out.writeMedium(5)
|
|
out.writeShort(0)
|
|
out.writeShort(msg.build)
|
|
out.writeShort(0)
|
|
}
|
|
}
|
|
}
|
|
|
|
override fun allocateBuffer(ctx: ChannelHandlerContext, msg: Js5Request, preferDirect: Boolean): ByteBuf {
|
|
return if (preferDirect) {
|
|
ctx.alloc().ioBuffer(10, 10)
|
|
} else {
|
|
ctx.alloc().heapBuffer(10, 10)
|
|
}
|
|
}
|
|
}
|
|
|