PandacubeFr/BungeeCord
1
0
Fork 0
Code Releases Activity

Reformat API + Protocol

Browse Source
This commit is contained in:
md_5 2013-02-09 19:13:40 +11:00
parent 8840dade68
commit ce6656afc0
20 changed files with 531 additions and 260 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

378
protocol/src/main/java/net/md_5/mendax/PacketDefinitions.java
View File

@ -2,126 +2,350 @@ package net.md_5.mendax;
import static net.md_5.mendax.PacketDefinitions.OpCode.*; import static net.md_5.mendax.PacketDefinitions.OpCode.*;
public class PacketDefinitions { public class PacketDefinitions
{
public static final OpCode[][] opCodes = new OpCode[ 256 ][]; public static final OpCode[][] opCodes = new OpCode[ 256 ][];
public enum OpCode { public enum OpCode
{
BOOLEAN, BULK_CHUNK, BYTE, BYTE_INT, DOUBLE, FLOAT, INT, INT_3, INT_BYTE, ITEM, LONG, METADATA, OPTIONAL_MOTION, SHORT, SHORT_BYTE, SHORT_ITEM, STRING, USHORT_BYTE BOOLEAN, BULK_CHUNK, BYTE, BYTE_INT, DOUBLE, FLOAT, INT, INT_3, INT_BYTE, ITEM, LONG, METADATA, OPTIONAL_MOTION, SHORT, SHORT_BYTE, SHORT_ITEM, STRING, USHORT_BYTE
} }
static { static
opCodes[0x00] = new OpCode[]{INT}; {
opCodes[0x01] = new OpCode[]{INT, STRING, BYTE, BYTE, BYTE, BYTE, BYTE}; opCodes[0x00] = new OpCode[]
opCodes[0x02] = new OpCode[]{BYTE, STRING, STRING, INT}; {
opCodes[0x03] = new OpCode[]{STRING}; INT
opCodes[0x04] = new OpCode[]{LONG, LONG}; };
opCodes[0x05] = new OpCode[]{INT, SHORT, ITEM}; opCodes[0x01] = new OpCode[]
opCodes[0x06] = new OpCode[]{INT, INT, INT}; {
opCodes[0x07] = new OpCode[]{INT, INT, BOOLEAN}; INT, STRING, BYTE, BYTE, BYTE, BYTE, BYTE
opCodes[0x08] = new OpCode[]{SHORT, SHORT, FLOAT}; };
opCodes[0x09] = new OpCode[]{INT, BYTE, BYTE, SHORT, STRING}; opCodes[0x02] = new OpCode[]
opCodes[0x0A] = new OpCode[]{BOOLEAN}; {
opCodes[0x0B] = new OpCode[]{DOUBLE, DOUBLE, DOUBLE, DOUBLE, BOOLEAN}; BYTE, STRING, STRING, INT
opCodes[0x0C] = new OpCode[]{FLOAT, FLOAT, BOOLEAN}; };
opCodes[0x0D] = new OpCode[]{DOUBLE, DOUBLE, DOUBLE, DOUBLE, FLOAT, FLOAT, BOOLEAN}; opCodes[0x03] = new OpCode[]
opCodes[0x0E] = new OpCode[]{BYTE, INT, BYTE, INT, BYTE}; {
opCodes[0x0F] = new OpCode[]{INT, BYTE, INT, BYTE, ITEM, BYTE, BYTE, BYTE}; STRING
opCodes[0x10] = new OpCode[]{SHORT}; };
opCodes[0x11] = new OpCode[]{INT, BYTE, INT, BYTE, INT}; opCodes[0x04] = new OpCode[]
opCodes[0x12] = new OpCode[]{INT, BYTE}; {
opCodes[0x13] = new OpCode[]{INT, BYTE}; LONG, LONG
opCodes[0x14] = new OpCode[]{INT, STRING, INT, INT, INT, BYTE, BYTE, SHORT, METADATA}; };
opCodes[0x16] = new OpCode[]{INT, INT}; opCodes[0x05] = new OpCode[]
opCodes[0x17] = new OpCode[]{INT, BYTE, INT, INT, INT, BYTE, BYTE, OPTIONAL_MOTION}; {
opCodes[0x18] = new OpCode[]{INT, BYTE, INT, INT, INT, BYTE, BYTE, BYTE, SHORT, SHORT, SHORT, METADATA}; INT, SHORT, ITEM
opCodes[0x19] = new OpCode[]{INT, STRING, INT, INT, INT, INT}; };
opCodes[0x1A] = new OpCode[]{INT, INT, INT, INT, SHORT}; opCodes[0x06] = new OpCode[]
{
INT, INT, INT
};
opCodes[0x07] = new OpCode[]
{
INT, INT, BOOLEAN
};
opCodes[0x08] = new OpCode[]
{
SHORT, SHORT, FLOAT
};
opCodes[0x09] = new OpCode[]
{
INT, BYTE, BYTE, SHORT, STRING
};
opCodes[0x0A] = new OpCode[]
{
BOOLEAN
};
opCodes[0x0B] = new OpCode[]
{
DOUBLE, DOUBLE, DOUBLE, DOUBLE, BOOLEAN
};
opCodes[0x0C] = new OpCode[]
{
FLOAT, FLOAT, BOOLEAN
};
opCodes[0x0D] = new OpCode[]
{
DOUBLE, DOUBLE, DOUBLE, DOUBLE, FLOAT, FLOAT, BOOLEAN
};
opCodes[0x0E] = new OpCode[]
{
BYTE, INT, BYTE, INT, BYTE
};
opCodes[0x0F] = new OpCode[]
{
INT, BYTE, INT, BYTE, ITEM, BYTE, BYTE, BYTE
};
opCodes[0x10] = new OpCode[]
{
SHORT
};
opCodes[0x11] = new OpCode[]
{
INT, BYTE, INT, BYTE, INT
};
opCodes[0x12] = new OpCode[]
{
INT, BYTE
};
opCodes[0x13] = new OpCode[]
{
INT, BYTE
};
opCodes[0x14] = new OpCode[]
{
INT, STRING, INT, INT, INT, BYTE, BYTE, SHORT, METADATA
};
opCodes[0x16] = new OpCode[]
{
INT, INT
};
opCodes[0x17] = new OpCode[]
{
INT, BYTE, INT, INT, INT, BYTE, BYTE, OPTIONAL_MOTION
};
opCodes[0x18] = new OpCode[]
{
INT, BYTE, INT, INT, INT, BYTE, BYTE, BYTE, SHORT, SHORT, SHORT, METADATA
};
opCodes[0x19] = new OpCode[]
{
INT, STRING, INT, INT, INT, INT
};
opCodes[0x1A] = new OpCode[]
{
INT, INT, INT, INT, SHORT
};
opCodes[0x1B] = null; // Does not exist opCodes[0x1B] = null; // Does not exist
opCodes[0x1C] = new OpCode[]{INT, SHORT, SHORT, SHORT}; opCodes[0x1C] = new OpCode[]
opCodes[0x1D] = new OpCode[]{BYTE_INT}; {
opCodes[0x1E] = new OpCode[]{INT}; INT, SHORT, SHORT, SHORT
opCodes[0x1F] = new OpCode[]{INT, BYTE, BYTE, BYTE}; };
opCodes[0x20] = new OpCode[]{INT, BYTE, BYTE}; opCodes[0x1D] = new OpCode[]
opCodes[0x21] = new OpCode[]{INT, BYTE, BYTE, BYTE, BYTE, BYTE}; {
opCodes[0x22] = new OpCode[]{INT, INT, INT, INT, BYTE, BYTE}; BYTE_INT
opCodes[0x23] = new OpCode[]{INT, BYTE}; };
opCodes[0x1E] = new OpCode[]
{
INT
};
opCodes[0x1F] = new OpCode[]
{
INT, BYTE, BYTE, BYTE
};
opCodes[0x20] = new OpCode[]
{
INT, BYTE, BYTE
};
opCodes[0x21] = new OpCode[]
{
INT, BYTE, BYTE, BYTE, BYTE, BYTE
};
opCodes[0x22] = new OpCode[]
{
INT, INT, INT, INT, BYTE, BYTE
};
opCodes[0x23] = new OpCode[]
{
INT, BYTE
};
opCodes[0x24] = null; // Does not exist opCodes[0x24] = null; // Does not exist
opCodes[0x25] = null; // Does not exist opCodes[0x25] = null; // Does not exist
opCodes[0x26] = new OpCode[]{INT, BYTE}; opCodes[0x26] = new OpCode[]
opCodes[0x27] = new OpCode[]{INT, INT}; {
opCodes[0x28] = new OpCode[]{INT, METADATA}; INT, BYTE
opCodes[0x29] = new OpCode[]{INT, BYTE, BYTE, SHORT}; };
opCodes[0x2A] = new OpCode[]{INT, BYTE}; opCodes[0x27] = new OpCode[]
opCodes[0x2B] = new OpCode[]{FLOAT, SHORT, SHORT}; {
INT, INT
};
opCodes[0x28] = new OpCode[]
{
INT, METADATA
};
opCodes[0x29] = new OpCode[]
{
INT, BYTE, BYTE, SHORT
};
opCodes[0x2A] = new OpCode[]
{
INT, BYTE
};
opCodes[0x2B] = new OpCode[]
{
FLOAT, SHORT, SHORT
};
// //
// //
// 0x2C -> 0x32 Do not exist // 0x2C -> 0x32 Do not exist
// //
// //
opCodes[0x33] = new OpCode[]{INT, INT, BOOLEAN, SHORT, SHORT, INT_BYTE}; opCodes[0x33] = new OpCode[]
opCodes[0x34] = new OpCode[]{INT, INT, SHORT, INT_BYTE}; {
opCodes[0x35] = new OpCode[]{INT, BYTE, INT, SHORT, BYTE}; INT, INT, BOOLEAN, SHORT, SHORT, INT_BYTE
opCodes[0x36] = new OpCode[]{INT, SHORT, INT, BYTE, BYTE, SHORT}; };
opCodes[0x37] = new OpCode[]{INT, INT, INT, INT, BYTE}; opCodes[0x34] = new OpCode[]
opCodes[0x38] = new OpCode[]{BULK_CHUNK}; {
INT, INT, SHORT, INT_BYTE
};
opCodes[0x35] = new OpCode[]
{
INT, BYTE, INT, SHORT, BYTE
};
opCodes[0x36] = new OpCode[]
{
INT, SHORT, INT, BYTE, BYTE, SHORT
};
opCodes[0x37] = new OpCode[]
{
INT, INT, INT, INT, BYTE
};
opCodes[0x38] = new OpCode[]
{
BULK_CHUNK
};
opCodes[0x39] = null; // Does not exist opCodes[0x39] = null; // Does not exist
opCodes[0x3A] = null; // Does not exist opCodes[0x3A] = null; // Does not exist
opCodes[0x3B] = null; // Does not exist opCodes[0x3B] = null; // Does not exist
opCodes[0x3C] = new OpCode[]{DOUBLE, DOUBLE, DOUBLE, FLOAT, INT_3, FLOAT, FLOAT, FLOAT}; opCodes[0x3C] = new OpCode[]
opCodes[0x3D] = new OpCode[]{INT, INT, BYTE, INT, INT, BOOLEAN}; {
opCodes[0x3E] = new OpCode[]{STRING, INT, INT, INT, FLOAT, BYTE}; DOUBLE, DOUBLE, DOUBLE, FLOAT, INT_3, FLOAT, FLOAT, FLOAT
};
opCodes[0x3D] = new OpCode[]
{
INT, INT, BYTE, INT, INT, BOOLEAN
};
opCodes[0x3E] = new OpCode[]
{
STRING, INT, INT, INT, FLOAT, BYTE
};
// //
// //
// 0x3F -> 0x45 Do not exist // 0x3F -> 0x45 Do not exist
// //
// //
opCodes[0x46] = new OpCode[]{BYTE, BYTE}; opCodes[0x46] = new OpCode[]
opCodes[0x47] = new OpCode[]{INT, BYTE, INT, INT, INT}; {
BYTE, BYTE
};
opCodes[0x47] = new OpCode[]
{
INT, BYTE, INT, INT, INT
};
// //
// //
// 0x4A -> 0x63 Do not exist // 0x4A -> 0x63 Do not exist
// //
// //
opCodes[0x64] = new OpCode[]{BYTE, BYTE, STRING, BYTE}; opCodes[0x64] = new OpCode[]
opCodes[0x65] = new OpCode[]{BYTE}; {
opCodes[0x66] = new OpCode[]{BYTE, SHORT, BYTE, SHORT, BOOLEAN, ITEM}; BYTE, BYTE, STRING, BYTE
opCodes[0x67] = new OpCode[]{BYTE, SHORT, ITEM}; };
opCodes[0x68] = new OpCode[]{BYTE, SHORT_ITEM}; opCodes[0x65] = new OpCode[]
opCodes[0x69] = new OpCode[]{BYTE, SHORT, SHORT}; {
opCodes[0x6A] = new OpCode[]{BYTE, SHORT, BOOLEAN}; BYTE
opCodes[0x6B] = new OpCode[]{SHORT, ITEM}; };
opCodes[0x6C] = new OpCode[]{BYTE, BYTE}; opCodes[0x66] = new OpCode[]
{
BYTE, SHORT, BYTE, SHORT, BOOLEAN, ITEM
};
opCodes[0x67] = new OpCode[]
{
BYTE, SHORT, ITEM
};
opCodes[0x68] = new OpCode[]
{
BYTE, SHORT_ITEM
};
opCodes[0x69] = new OpCode[]
{
BYTE, SHORT, SHORT
};
opCodes[0x6A] = new OpCode[]
{
BYTE, SHORT, BOOLEAN
};
opCodes[0x6B] = new OpCode[]
{
SHORT, ITEM
};
opCodes[0x6C] = new OpCode[]
{
BYTE, BYTE
};
// //
// //
// 0x6D -> 0x81 Do not exist // 0x6D -> 0x81 Do not exist
// //
// //
opCodes[0x82] = new OpCode[]{INT, SHORT, INT, STRING, STRING, STRING, STRING}; opCodes[0x82] = new OpCode[]
opCodes[0x83] = new OpCode[]{SHORT, SHORT, USHORT_BYTE}; {
opCodes[0x84] = new OpCode[]{INT, SHORT, INT, BYTE, SHORT_BYTE}; INT, SHORT, INT, STRING, STRING, STRING, STRING
};
opCodes[0x83] = new OpCode[]
{
SHORT, SHORT, USHORT_BYTE
};
opCodes[0x84] = new OpCode[]
{
INT, SHORT, INT, BYTE, SHORT_BYTE
};
// //
// //
// 0x85 -> 0xC7 Do not exist // 0x85 -> 0xC7 Do not exist
// //
// //
opCodes[0xC8] = new OpCode[]{INT, BYTE}; opCodes[0xC8] = new OpCode[]
opCodes[0xC9] = new OpCode[]{STRING, BOOLEAN, SHORT}; {
opCodes[0xCA] = new OpCode[]{BYTE, BYTE, BYTE}; INT, BYTE
opCodes[0xCB] = new OpCode[]{STRING}; };
opCodes[0xCC] = new OpCode[]{STRING, BYTE, BYTE, BYTE, BOOLEAN}; opCodes[0xC9] = new OpCode[]
opCodes[0xCD] = new OpCode[]{BYTE}; {
STRING, BOOLEAN, SHORT
};
opCodes[0xCA] = new OpCode[]
{
BYTE, BYTE, BYTE
};
opCodes[0xCB] = new OpCode[]
{
STRING
};
opCodes[0xCC] = new OpCode[]
{
STRING, BYTE, BYTE, BYTE, BOOLEAN
};
opCodes[0xCD] = new OpCode[]
{
BYTE
};
// //
// //
// 0xCE -> 0xF9 Do not exist // 0xCE -> 0xF9 Do not exist
// //
// //
opCodes[0xFA] = new OpCode[]{STRING, SHORT_BYTE}; opCodes[0xFA] = new OpCode[]
{
STRING, SHORT_BYTE
};
opCodes[0xFB] = null; // Does not exist opCodes[0xFB] = null; // Does not exist
opCodes[0xFC] = new OpCode[]{SHORT_BYTE, SHORT_BYTE}; opCodes[0xFC] = new OpCode[]
opCodes[0xFD] = new OpCode[]{STRING, SHORT_BYTE, SHORT_BYTE}; {
opCodes[0xFE] = new OpCode[]{}; // Should be byte, screw you too bitchy server admins! SHORT_BYTE, SHORT_BYTE
opCodes[0xFF] = new OpCode[]{STRING}; };
opCodes[0xFD] = new OpCode[]
{
STRING, SHORT_BYTE, SHORT_BYTE
};
opCodes[0xFE] = new OpCode[]
{
}; // Should be byte, screw you too bitchy server admins!
opCodes[0xFF] = new OpCode[]
{
STRING
};
} }
} }

6
protocol/src/main/java/net/md_5/mendax/datainput/BulkChunk.java
View File

@ -3,10 +3,12 @@ package net.md_5.mendax.datainput;
import java.io.DataInput; import java.io.DataInput;
import java.io.IOException; import java.io.IOException;
public class BulkChunk extends Instruction { public class BulkChunk extends Instruction
{
@Override @Override
void read(DataInput in, byte[] buffer) throws IOException { void read(DataInput in, byte[] buffer) throws IOException
{
short count = in.readShort(); short count = in.readShort();
int size = in.readInt(); int size = in.readInt();
in.readBoolean(); in.readBoolean();

12
protocol/src/main/java/net/md_5/mendax/datainput/ByteHeader.java
View File

@ -3,18 +3,22 @@ package net.md_5.mendax.datainput;
import java.io.DataInput; import java.io.DataInput;
import java.io.IOException; import java.io.IOException;
class ByteHeader extends Instruction { class ByteHeader extends Instruction
{
private final Instruction child; private final Instruction child;
ByteHeader(Instruction child) { ByteHeader(Instruction child)
{
this.child = child; this.child = child;
} }
@Override @Override
void read(DataInput in, byte[] buffer) throws IOException { void read(DataInput in, byte[] buffer) throws IOException
{
byte size = in.readByte(); byte size = in.readByte();
for (byte b = 0; b < size; b++) { for ( byte b = 0; b < size; b++ )
{
child.read( in, buffer ); child.read( in, buffer );
} }
} }

45
protocol/src/main/java/net/md_5/mendax/datainput/DataInputPacketReader.java
View File

@ -7,38 +7,50 @@ import java.util.List;
import net.md_5.mendax.PacketDefinitions; import net.md_5.mendax.PacketDefinitions;
import net.md_5.mendax.PacketDefinitions.OpCode; import net.md_5.mendax.PacketDefinitions.OpCode;
public class DataInputPacketReader { public class DataInputPacketReader
{
private static final Instruction[][] instructions = new Instruction[ 256 ][]; private static final Instruction[][] instructions = new Instruction[ 256 ][];
static { static
for (int i = 0; i < instructions.length; i++) { {
for ( int i = 0; i < instructions.length; i++ )
{
List<Instruction> output = new ArrayList<Instruction>(); List<Instruction> output = new ArrayList<Instruction>();
OpCode[] enums = PacketDefinitions.opCodes[i]; OpCode[] enums = PacketDefinitions.opCodes[i];
if (enums != null) { if ( enums != null )
for (OpCode struct : enums) { {
try { for ( OpCode struct : enums )
{
try
{
output.add( (Instruction) Instruction.class.getDeclaredField( struct.name() ).get( null ) ); output.add( (Instruction) Instruction.class.getDeclaredField( struct.name() ).get( null ) );
} catch (Exception ex) { } catch ( Exception ex )
{
throw new UnsupportedOperationException( "No definition for " + struct.name() ); throw new UnsupportedOperationException( "No definition for " + struct.name() );
} }
} }
List<Instruction> crushed = new ArrayList<Instruction>(); List<Instruction> crushed = new ArrayList<Instruction>();
int nextJumpSize = 0; int nextJumpSize = 0;
for (Instruction child : output) { for ( Instruction child : output )
if (child instanceof Jump) { {
if ( child instanceof Jump )
{
nextJumpSize += ( (Jump) child ).len; nextJumpSize += ( (Jump) child ).len;
} else { } else
if (nextJumpSize != 0) { {
if ( nextJumpSize != 0 )
{
crushed.add( new Jump( nextJumpSize ) ); crushed.add( new Jump( nextJumpSize ) );
} }
crushed.add( child ); crushed.add( child );
nextJumpSize = 0; nextJumpSize = 0;
} }
} }
if (nextJumpSize != 0) { if ( nextJumpSize != 0 )
{
crushed.add( new Jump( nextJumpSize ) ); crushed.add( new Jump( nextJumpSize ) );
} }
@ -47,15 +59,18 @@ public class DataInputPacketReader {
} }
} }
public static void readPacket(DataInput in, byte[] buffer) throws IOException { public static void readPacket(DataInput in, byte[] buffer) throws IOException
{
int packetId = in.readUnsignedByte(); int packetId = in.readUnsignedByte();
Instruction[] packetDef = instructions[packetId]; Instruction[] packetDef = instructions[packetId];
if (packetDef == null) { if ( packetDef == null )
{
throw new IOException( "Unknown packet id " + packetId ); throw new IOException( "Unknown packet id " + packetId );
} }
for (Instruction instruction : packetDef) { for ( Instruction instruction : packetDef )
{
instruction.read( in, buffer ); instruction.read( in, buffer );
} }
} }

6
protocol/src/main/java/net/md_5/mendax/datainput/Instruction.java
View File

@ -3,7 +3,8 @@ package net.md_5.mendax.datainput;
import java.io.DataInput; import java.io.DataInput;
import java.io.IOException; import java.io.IOException;
abstract class Instruction { abstract class Instruction
{
static final Instruction BOOLEAN = new Jump( 1 ); static final Instruction BOOLEAN = new Jump( 1 );
static final Instruction BULK_CHUNK = new BulkChunk(); static final Instruction BULK_CHUNK = new BulkChunk();
@ -28,7 +29,8 @@ abstract class Instruction {
abstract void read(DataInput in, byte[] buffer) throws IOException; abstract void read(DataInput in, byte[] buffer) throws IOException;
final void skip(DataInput in, byte[] buffer, int len) throws IOException { final void skip(DataInput in, byte[] buffer, int len) throws IOException
{
in.readFully( buffer, 0, len ); in.readFully( buffer, 0, len );
} }
} }

12
protocol/src/main/java/net/md_5/mendax/datainput/IntHeader.java
View File

@ -3,18 +3,22 @@ package net.md_5.mendax.datainput;
import java.io.DataInput; import java.io.DataInput;
import java.io.IOException; import java.io.IOException;
class IntHeader extends Instruction { class IntHeader extends Instruction
{
private final Instruction child; private final Instruction child;
IntHeader(Instruction child) { IntHeader(Instruction child)
{
this.child = child; this.child = child;
} }
@Override @Override
void read(DataInput in, byte[] buffer) throws IOException { void read(DataInput in, byte[] buffer) throws IOException
{
int size = in.readInt(); int size = in.readInt();
for (int i = 0; i < size; i++) { for ( int i = 0; i < size; i++ )
{
child.read( in, buffer ); child.read( in, buffer );
} }
} }

9
protocol/src/main/java/net/md_5/mendax/datainput/Item.java
View File

@ -3,12 +3,15 @@ package net.md_5.mendax.datainput;
import java.io.DataInput; import java.io.DataInput;
import java.io.IOException; import java.io.IOException;
class Item extends Instruction { class Item extends Instruction
{
@Override @Override
void read(DataInput in, byte[] buffer) throws IOException { void read(DataInput in, byte[] buffer) throws IOException
{
short type = in.readShort(); short type = in.readShort();
if (type >= 0) { if ( type >= 0 )
{
skip( in, buffer, 3 ); skip( in, buffer, 3 );
SHORT_BYTE.read( in, buffer ); SHORT_BYTE.read( in, buffer );
} }

12
protocol/src/main/java/net/md_5/mendax/datainput/Jump.java
View File

@ -3,19 +3,23 @@ package net.md_5.mendax.datainput;
import java.io.DataInput; import java.io.DataInput;
import java.io.IOException; import java.io.IOException;
class Jump extends Instruction { class Jump extends Instruction
{
final int len; final int len;
Jump(int len) { Jump(int len)
if (len < 0) { {
if ( len < 0 )
{
throw new IndexOutOfBoundsException(); throw new IndexOutOfBoundsException();
} }
this.len = len; this.len = len;
} }
@Override @Override
void read(DataInput in, byte[] buffer) throws IOException { void read(DataInput in, byte[] buffer) throws IOException
{
skip( in, buffer, len ); skip( in, buffer, len );
} }
} }

12
protocol/src/main/java/net/md_5/mendax/datainput/MetaData.java
View File

@ -3,14 +3,18 @@ package net.md_5.mendax.datainput;
import java.io.DataInput; import java.io.DataInput;
import java.io.IOException; import java.io.IOException;
class MetaData extends Instruction { class MetaData extends Instruction
{
@Override @Override
void read(DataInput in, byte[] buffer) throws IOException { void read(DataInput in, byte[] buffer) throws IOException
{
int x = in.readUnsignedByte(); int x = in.readUnsignedByte();
while (x != 127) { while ( x != 127 )
{
int type = x >> 5; int type = x >> 5;
switch (type) { switch ( type )
{
case 0: case 0:
BYTE.read( in, buffer ); BYTE.read( in, buffer );
break; break;

9
protocol/src/main/java/net/md_5/mendax/datainput/OptionalMotion.java
View File

@ -3,12 +3,15 @@ package net.md_5.mendax.datainput;
import java.io.DataInput; import java.io.DataInput;
import java.io.IOException; import java.io.IOException;
public class OptionalMotion extends Instruction { public class OptionalMotion extends Instruction
{
@Override @Override
void read(DataInput in, byte[] buffer) throws IOException { void read(DataInput in, byte[] buffer) throws IOException
{
int data = in.readInt(); int data = in.readInt();
if (data > 0) { if ( data > 0 )
{
skip( in, buffer, 6 ); skip( in, buffer, 6 );
} }
} }

12
protocol/src/main/java/net/md_5/mendax/datainput/ShortHeader.java
View File

@ -3,18 +3,22 @@ package net.md_5.mendax.datainput;
import java.io.DataInput; import java.io.DataInput;
import java.io.IOException; import java.io.IOException;
class ShortHeader extends Instruction { class ShortHeader extends Instruction
{
private final Instruction child; private final Instruction child;
ShortHeader(Instruction child) { ShortHeader(Instruction child)
{
this.child = child; this.child = child;
} }
@Override @Override
void read(DataInput in, byte[] buffer) throws IOException { void read(DataInput in, byte[] buffer) throws IOException
{
short size = in.readShort(); short size = in.readShort();
for (short s = 0; s < size; s++) { for ( short s = 0; s < size; s++ )
{
child.read( in, buffer ); child.read( in, buffer );
} }
} }

6
protocol/src/main/java/net/md_5/mendax/datainput/UnsignedShortByte.java
View File

@ -3,10 +3,12 @@ package net.md_5.mendax.datainput;
import java.io.DataInput; import java.io.DataInput;
import java.io.IOException; import java.io.IOException;
public class UnsignedShortByte extends Instruction { public class UnsignedShortByte extends Instruction
{
@Override @Override
void read(DataInput in, byte[] buffer) throws IOException { void read(DataInput in, byte[] buffer) throws IOException
{
int size = in.readUnsignedShort(); int size = in.readUnsignedShort();
skip( in, buffer, size ); skip( in, buffer, size );
} }