Minecraft/asys
Archived
0
Fork 0
Code Activity

bridge-protocol -> libprotocol

Browse Source
This commit is contained in:
DmitriyMX
2017-06-15 22:52:09 +03:00
parent 2fca454179
commit 6ffb63ceb2
17 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
libprotocol/build.gradle Normal file
View File

@@ -0,0 +1,15 @@
group = 'asys'
version = '0.5-SNAPSHOT'
task jar(type: Jar, overwrite: true) {
// не собирать jar
}
ext {
nettyVersion = '4.0.23.Final'
}
dependencies {
compile group: 'com.google.guava', name: 'guava', version: '21.0'
compile group: 'io.netty', name: 'netty-codec', version: nettyVersion
}

56
libprotocol/src/main/java/asys/mcsmanager/packets/CS_ConsoleMessage.java Normal file
View File

@@ -0,0 +1,56 @@
/*
* DmitriyMX <dimon550@gmail.com>
* 2017-05-17
*/
package asys.mcsmanager.packets;
import io.netty.buffer.ByteBuf;
public class CS_ConsoleMessage extends Packet {
private long time;
private int level;
private String loggerName,
message;
public CS_ConsoleMessage() {
}
public CS_ConsoleMessage(long time, int level, String loggerName, String message) {
this.time = time;
this.level = level;
this.loggerName = loggerName;
this.message = message;
}
public long getTime() {
return time;
}
public int getLevel() {
return level;
}
public String getLoggerName() {
return loggerName;
}
public String getMessage() {
return message;
}
@Override
public void readSelfData(ByteBuf buffer) {
this.time = buffer.readLong();
this.level = buffer.readInt();
this.loggerName = readString(buffer);
this.message = readString(buffer);
}
@Override
public void writeSelfData(ByteBuf buffer) {
buffer.writeLong(time);
buffer.writeInt(level);
writeString(buffer, loggerName);
writeString(buffer, message);
}
}

40
libprotocol/src/main/java/asys/mcsmanager/packets/CS_Handshake.java Normal file
View File

@@ -0,0 +1,40 @@
/*
* DmitriyMX <dimon550@gmail.com>
* 2017-04-26
*/
package asys.mcsmanager.packets;
import io.netty.buffer.ByteBuf;
public class CS_Handshake extends Packet {
private String clientId;
private String passcode;
public CS_Handshake() {
}
public CS_Handshake(String clientId, String passcode) {
this.clientId = clientId;
this.passcode = passcode;
}
public String getClientId() {
return clientId;
}
public String getPasscode() {
return passcode;
}
@Override
public void readSelfData(ByteBuf buffer) {
this.clientId = this.readString(buffer);
this.passcode = this.readString(buffer);
}
@Override
public void writeSelfData(ByteBuf buffer) {
this.writeString(buffer, clientId);
this.writeString(buffer, passcode);
}
}

48
libprotocol/src/main/java/asys/mcsmanager/packets/CS_Ping.java Normal file
View File

@@ -0,0 +1,48 @@
/*
* DmitriyMX <dimon550@gmail.com>
* 2017-04-26
*/
package asys.mcsmanager.packets;
import io.netty.buffer.ByteBuf;
public class CS_Ping extends Packet {
private long time;
private double tps;
private int countPlayers;
public CS_Ping() {
}
public CS_Ping(long time, double tps, int countPlayers) {
this.time = time;
this.tps = tps;
this.countPlayers = countPlayers;
}
public long getTime() {
return time;
}
public double getTps() {
return tps;
}
public int getCountPlayers() {
return countPlayers;
}
@Override
public void readSelfData(ByteBuf buffer) {
this.time = buffer.readLong();
this.tps = buffer.readDouble();
this.countPlayers = buffer.readUnsignedShort();
}
@Override
public void writeSelfData(ByteBuf buffer) {
buffer.writeLong(time);
buffer.writeDouble(tps);
buffer.writeShort(countPlayers);
}
}

11
libprotocol/src/main/java/asys/mcsmanager/packets/IPacketHandler.java Normal file
View File

@@ -0,0 +1,11 @@
/*
* DmitriyMX <dimon550@gmail.com>
* 2017-04-26
*/
package asys.mcsmanager.packets;
import io.netty.channel.ChannelHandlerContext;
public interface IPacketHandler {
void handle(Packet packet, ChannelHandlerContext context);
}

34
libprotocol/src/main/java/asys/mcsmanager/packets/Packet.java Normal file
View File

@@ -0,0 +1,34 @@
/*
* DmitriyMX <dimon550@gmail.com>
* 2017-04-26
*/
package asys.mcsmanager.packets;
import io.netty.buffer.ByteBuf;
public abstract class Packet {
public String readString(ByteBuf buffer) {
int length = buffer.readUnsignedShort();
StringBuilder sb = new StringBuilder();
for (int i = 0; i < length; i++) {
sb.append(buffer.readChar());
}
return sb.toString();
}
public void writeString(ByteBuf buffer, String string) {
int length = string.length();
buffer.writeShort(length);
if (length > 0) {
for (int i = 0; i < length; i++) {
buffer.writeChar(string.charAt(i));
}
}
}
public abstract void readSelfData(ByteBuf buffer);
public abstract void writeSelfData(ByteBuf buffer);
}

32
libprotocol/src/main/java/asys/mcsmanager/packets/SC_Command.java Normal file
View File

@@ -0,0 +1,32 @@
/*
* DmitriyMX <d.mihailov@samson-rus.com>
* 2017-06-05
*/
package asys.mcsmanager.packets;
import io.netty.buffer.ByteBuf;
public class SC_Command extends Packet {
private String command;
public SC_Command() {
}
public SC_Command(String command) {
this.command = command;
}
public String getCommand() {
return command;
}
@Override
public void readSelfData(ByteBuf buffer) {
command = readString(buffer);
}
@Override
public void writeSelfData(ByteBuf buffer) {
writeString(buffer, command);
}
}

40
libprotocol/src/main/java/asys/mcsmanager/packets/SC_HandshakeResult.java Normal file
View File

@@ -0,0 +1,40 @@
/*
* DmitriyMX <dimon550@gmail.com>
* 2017-04-26
*/
package asys.mcsmanager.packets;
import io.netty.buffer.ByteBuf;
public class SC_HandshakeResult extends Packet {
private int errorCode;
private String message;
public SC_HandshakeResult() {
}
public SC_HandshakeResult(int errorCode, String message) {
this.errorCode = errorCode;
this.message = message;
}
public int getErrorCode() {
return errorCode;
}
public String getMessage() {
return message;
}
@Override
public void readSelfData(ByteBuf buffer) {
this.errorCode = buffer.readUnsignedByte();
this.message = this.readString(buffer);
}
@Override
public void writeSelfData(ByteBuf buffer) {
buffer.writeByte(errorCode);
this.writeString(buffer, message);
}
}

32
libprotocol/src/main/java/asys/mcsmanager/packets/SC_ToggleSendMessages.java Normal file
View File

@@ -0,0 +1,32 @@
/*
* DmitriyMX <dimon550@gmail.com>
* 2017-06-11
*/
package asys.mcsmanager.packets;
import io.netty.buffer.ByteBuf;
public class SC_ToggleSendMessages extends Packet {
private boolean needSend;
public SC_ToggleSendMessages() {
}
public SC_ToggleSendMessages(boolean needSend) {
this.needSend = needSend;
}
public boolean isNeedSend() {
return needSend;
}
@Override
public void readSelfData(ByteBuf buffer) {
needSend = (buffer.readUnsignedByte() == 1);
}
@Override
public void writeSelfData(ByteBuf buffer) {
buffer.writeByte(needSend ? 1 : 0);
}
}

33
libprotocol/src/main/java/asys/mcsmanager/packets/codec/PacketDecoder.java Normal file
View File

@@ -0,0 +1,33 @@
/*
* DmitriyMX <dimon550@gmail.com>
* 2017-04-26
*/
package asys.mcsmanager.packets.codec;
import asys.mcsmanager.packets.Packet;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ReplayingDecoder;
import java.util.List;
import static asys.mcsmanager.packets.codec.Params.KNOWN_HANDLERS;
import static asys.mcsmanager.packets.codec.Params.KNOWN_PACKETS;
public class PacketDecoder extends ReplayingDecoder<Packet> {
@Override
protected void decode(ChannelHandlerContext contect, ByteBuf inBuf, List<Object> out) throws Exception {
int id = inBuf.readUnsignedByte();
Class<? extends Packet> pktClass = contect.channel().attr(KNOWN_PACKETS).get().get(id);
if (pktClass == null) return; //TODO надо бы в логгере писать про отсутствующий пакет
if (contect.channel().attr(KNOWN_HANDLERS).get().containsKey(pktClass)) {
Packet packet = pktClass.newInstance();
packet.readSelfData(inBuf);
out.add(packet);
} else {
//TODO по хорошему, надо информровать, что отсутствует обработчик пакета
inBuf.skipBytes(inBuf.readableBytes());
}
}
}

23
libprotocol/src/main/java/asys/mcsmanager/packets/codec/PacketEncoder.java Normal file
View File

@@ -0,0 +1,23 @@
/*
* DmitriyMX <dimon550@gmail.com>
* 2017-04-26
*/
package asys.mcsmanager.packets.codec;
import asys.mcsmanager.packets.Packet;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.MessageToByteEncoder;
import static asys.mcsmanager.packets.codec.Params.KNOWN_PACKETS;
public class PacketEncoder extends MessageToByteEncoder<Packet> {
@Override
protected void encode(ChannelHandlerContext context, Packet packet, ByteBuf outBuf) throws Exception {
Integer id = context.channel().attr(KNOWN_PACKETS).get().inverse().get(packet.getClass());
if (id == null) return; //TODO в логгере хорошо бы информировать о дропе исходящего пакета
outBuf.writeByte(id);
packet.writeSelfData(outBuf);
}
}

18
libprotocol/src/main/java/asys/mcsmanager/packets/codec/PacketHandler.java Normal file
View File

@@ -0,0 +1,18 @@
/*
* DmitriyMX <dimon550@gmail.com>
* 2017-04-26
*/
package asys.mcsmanager.packets.codec;
import asys.mcsmanager.packets.Packet;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import static asys.mcsmanager.packets.codec.Params.KNOWN_HANDLERS;
public class PacketHandler extends SimpleChannelInboundHandler<Packet> {
@Override
protected void channelRead0(ChannelHandlerContext context, Packet packet) throws Exception {
context.channel().attr(KNOWN_HANDLERS).get().get(packet.getClass()).handle(packet, context);
}
}

17
libprotocol/src/main/java/asys/mcsmanager/packets/codec/Params.java Normal file
View File

@@ -0,0 +1,17 @@
/*
* DmitriyMX <dimon550@gmail.com>
* 2017-04-26
*/
package asys.mcsmanager.packets.codec;
import asys.mcsmanager.packets.Packet;
import asys.mcsmanager.packets.IPacketHandler;
import com.google.common.collect.BiMap;
import io.netty.util.AttributeKey;
import java.util.Map;
public final class Params {
public static final AttributeKey<BiMap<Integer, Class<? extends Packet>>> KNOWN_PACKETS = AttributeKey.valueOf("KNOWN_PACKETS");
public static final AttributeKey<Map<Class<? extends Packet>, IPacketHandler>> KNOWN_HANDLERS = AttributeKey.valueOf("KNOWN_HANDLERS");
}