forked from LupusNobilis/java-org.hwo
Compare commits
4 Commits
master
...
thobaben_s
Author | SHA1 | Date |
---|---|---|
Harald Wolff | ef6826c570 | |
niclasthobaben | e5832f7f2e | |
niclasthobaben | e5210fa6a2 | |
Niclas Thobaben | 7cb45827aa |
|
@ -320,6 +320,11 @@ public class NewSerialPort {
|
||||||
}
|
}
|
||||||
return nRead;
|
return nRead;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void close() throws IOException {
|
||||||
|
NewSerialPort.this.close();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public class NewSerialPortOutputStream extends OutputStream
|
public class NewSerialPortOutputStream extends OutputStream
|
||||||
|
@ -388,6 +393,10 @@ public class NewSerialPort {
|
||||||
write(b, 0, b.length);
|
write(b, 0, b.length);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void close() throws IOException {
|
||||||
|
NewSerialPort.this.close();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
static public String[] getPortNames(){
|
static public String[] getPortNames(){
|
||||||
|
|
|
@ -0,0 +1,200 @@
|
||||||
|
package org.hwo.serialize;
|
||||||
|
|
||||||
|
import java.nio.ByteBuffer;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
public class BinaryParser {
|
||||||
|
|
||||||
|
private static final String _hex = "0123456789ABCDEF";
|
||||||
|
|
||||||
|
static void printBytes(List<Byte> src) {
|
||||||
|
|
||||||
|
for(Byte b : src) {
|
||||||
|
System.out.print(Integer.toHexString(b) + " ");
|
||||||
|
}
|
||||||
|
|
||||||
|
System.out.print("\n");
|
||||||
|
}
|
||||||
|
|
||||||
|
static void printBytes(byte[] src) {
|
||||||
|
|
||||||
|
for(byte b : src) {
|
||||||
|
System.out.print(Integer.toHexString(b) + " ");
|
||||||
|
}
|
||||||
|
|
||||||
|
System.out.print("\n");
|
||||||
|
}
|
||||||
|
|
||||||
|
static void writeBytes(List<Byte> src, byte value) {
|
||||||
|
src.add(value);
|
||||||
|
}
|
||||||
|
|
||||||
|
static void writeBytes(List<Byte> src, short value) {
|
||||||
|
byte[] buf = ByteBuffer.allocate(Short.BYTES).putShort(value).array();
|
||||||
|
for(byte b : buf)
|
||||||
|
src.add(b);
|
||||||
|
}
|
||||||
|
|
||||||
|
static void writeBytes(List<Byte> src, int value) {
|
||||||
|
byte[] buf = ByteBuffer.allocate(Integer.BYTES).putInt(value).array();
|
||||||
|
for(byte b : buf)
|
||||||
|
src.add(b);
|
||||||
|
}
|
||||||
|
|
||||||
|
static void writeBytes(List<Byte> src, long value) {
|
||||||
|
byte[] buf = ByteBuffer.allocate(Long.BYTES).putLong(value).array();
|
||||||
|
for(byte b : buf)
|
||||||
|
src.add(b);
|
||||||
|
}
|
||||||
|
|
||||||
|
static void writeBytes(List<Byte> src, String value) {
|
||||||
|
char[] arr = value.toCharArray();
|
||||||
|
for(char c : arr)
|
||||||
|
src.add((byte)c);
|
||||||
|
}
|
||||||
|
|
||||||
|
static void writeBytes(List<Byte> src, float value) {
|
||||||
|
byte[] buf = ByteBuffer.allocate(Float.BYTES).putFloat(value).array();
|
||||||
|
for(byte b : buf)
|
||||||
|
src.add(b);
|
||||||
|
}
|
||||||
|
|
||||||
|
static byte readByte(List<Byte> src, int ptr) {
|
||||||
|
if(ptr >= src.size() || ptr < 0)
|
||||||
|
return 0;
|
||||||
|
return src.get(ptr);
|
||||||
|
}
|
||||||
|
|
||||||
|
static byte readByte(byte[] src, int ptr) {
|
||||||
|
if(ptr >= src.length || ptr < 0)
|
||||||
|
return 0;
|
||||||
|
return src[ptr];
|
||||||
|
}
|
||||||
|
|
||||||
|
static short readShort(List<Byte> src, int ptr) {
|
||||||
|
if(ptr >= src.size() || ptr < 0)
|
||||||
|
return 0;
|
||||||
|
|
||||||
|
byte[] temp = new byte[Short.BYTES];
|
||||||
|
for(int i = 0; i < Short.BYTES; i++)
|
||||||
|
temp[i] = src.get(i + ptr);
|
||||||
|
|
||||||
|
ByteBuffer bb = ByteBuffer.wrap(temp);
|
||||||
|
|
||||||
|
return bb.getShort();
|
||||||
|
}
|
||||||
|
|
||||||
|
static short readShort(byte[] src, int ptr) {
|
||||||
|
if(ptr >= src.length || ptr < 0)
|
||||||
|
return 0;
|
||||||
|
|
||||||
|
byte[] temp = new byte[Short.BYTES];
|
||||||
|
for(int i = 0; i < Short.BYTES; i++)
|
||||||
|
temp[i] = src[i + ptr];
|
||||||
|
|
||||||
|
ByteBuffer bb = ByteBuffer.wrap(temp);
|
||||||
|
|
||||||
|
return bb.getShort();
|
||||||
|
}
|
||||||
|
|
||||||
|
static int readInt(List<Byte> src, int ptr) {
|
||||||
|
if(ptr >= src.size() || ptr < 0)
|
||||||
|
return 0;
|
||||||
|
|
||||||
|
byte[] temp = new byte[Integer.BYTES];
|
||||||
|
for(int i = 0; i < Integer.BYTES; i++)
|
||||||
|
temp[i] = src.get(i + ptr);
|
||||||
|
|
||||||
|
ByteBuffer bb = ByteBuffer.wrap(temp);
|
||||||
|
|
||||||
|
return bb.getInt();
|
||||||
|
}
|
||||||
|
|
||||||
|
static int readInt(byte[] src, int ptr) {
|
||||||
|
if(ptr >= src.length || ptr < 0)
|
||||||
|
return 0;
|
||||||
|
|
||||||
|
byte[] temp = new byte[Integer.BYTES];
|
||||||
|
for(int i = 0; i < Integer.BYTES; i++)
|
||||||
|
temp[i] = src[i + ptr];
|
||||||
|
|
||||||
|
ByteBuffer bb = ByteBuffer.wrap(temp);
|
||||||
|
|
||||||
|
return bb.getInt();
|
||||||
|
}
|
||||||
|
|
||||||
|
static long readLong(List<Byte> src, int ptr) {
|
||||||
|
if(ptr >= src.size() || ptr < 0)
|
||||||
|
return 0;
|
||||||
|
|
||||||
|
byte[] temp = new byte[Long.BYTES];
|
||||||
|
for(int i = 0; i < Long.BYTES; i++)
|
||||||
|
temp[i] = src.get(i + ptr);
|
||||||
|
|
||||||
|
ByteBuffer bb = ByteBuffer.wrap(temp);
|
||||||
|
|
||||||
|
return bb.getLong();
|
||||||
|
}
|
||||||
|
|
||||||
|
static long readLong(byte[] src, int ptr) {
|
||||||
|
if(ptr >= src.length || ptr < 0)
|
||||||
|
return 0;
|
||||||
|
|
||||||
|
byte[] temp = new byte[Long.BYTES];
|
||||||
|
for(int i = 0; i < Long.BYTES; i++)
|
||||||
|
temp[i] = src[i + ptr];
|
||||||
|
|
||||||
|
ByteBuffer bb = ByteBuffer.wrap(temp);
|
||||||
|
|
||||||
|
return bb.getLong();
|
||||||
|
}
|
||||||
|
|
||||||
|
static String readString(List<Byte> src, int strLen, int ptr) {
|
||||||
|
if(ptr >= src.size() || ptr < 0)
|
||||||
|
return "";
|
||||||
|
|
||||||
|
char[] temp = new char[strLen];
|
||||||
|
for(int i = 0; i < strLen; i++)
|
||||||
|
temp[i] = (char)src.get(i + ptr).byteValue();
|
||||||
|
|
||||||
|
return new String(temp);
|
||||||
|
}
|
||||||
|
|
||||||
|
static String readString(byte[] src, int strLen, int ptr) {
|
||||||
|
if(ptr >= src.length || ptr < 0)
|
||||||
|
return "";
|
||||||
|
|
||||||
|
char[] temp = new char[strLen];
|
||||||
|
for(int i = 0; i < strLen; i++)
|
||||||
|
temp[i] = (char)src[i + ptr];
|
||||||
|
|
||||||
|
return new String(temp);
|
||||||
|
}
|
||||||
|
|
||||||
|
static float readFloat(List<Byte> src, int ptr) {
|
||||||
|
if(ptr >= src.size() || ptr < 0)
|
||||||
|
return 0;
|
||||||
|
|
||||||
|
byte[] temp = new byte[Float.BYTES];
|
||||||
|
for(int i = 0; i < Float.BYTES; i++)
|
||||||
|
temp[i] = src.get(i + ptr);
|
||||||
|
|
||||||
|
ByteBuffer bb = ByteBuffer.wrap(temp);
|
||||||
|
|
||||||
|
return bb.getFloat();
|
||||||
|
}
|
||||||
|
|
||||||
|
static float readFloat(byte[] src, int ptr) {
|
||||||
|
if(ptr >= src.length || ptr < 0)
|
||||||
|
return 0;
|
||||||
|
|
||||||
|
byte[] temp = new byte[Float.BYTES];
|
||||||
|
for(int i = 0; i < Float.BYTES; i++)
|
||||||
|
temp[i] = src[i + ptr];
|
||||||
|
|
||||||
|
ByteBuffer bb = ByteBuffer.wrap(temp);
|
||||||
|
|
||||||
|
return bb.getFloat();
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
|
@ -0,0 +1,118 @@
|
||||||
|
package org.hwo.serialize;
|
||||||
|
|
||||||
|
import java.util.ArrayList;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
public class Database {
|
||||||
|
|
||||||
|
//HEADER
|
||||||
|
//[4]String DatabaseID
|
||||||
|
//[4] Short ObjectCount
|
||||||
|
//[2] Short InfoSize
|
||||||
|
//[InfoSize] Info
|
||||||
|
//[4] String "DATA"
|
||||||
|
|
||||||
|
private static final String DATABASE_ID = "HF3B";
|
||||||
|
|
||||||
|
private List<DatabaseObject> objects;
|
||||||
|
private long sizeInBytes;
|
||||||
|
|
||||||
|
public Database() {
|
||||||
|
this.objects = new ArrayList<DatabaseObject>();
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
public void addObject(DatabaseObject obj) {
|
||||||
|
if(this.objects.contains(obj))
|
||||||
|
return;
|
||||||
|
this.objects.add(obj);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void addObject(String name) {
|
||||||
|
DatabaseObject temp = new DatabaseObject(name);
|
||||||
|
if(temp != null)
|
||||||
|
this.objects.add(temp);
|
||||||
|
}
|
||||||
|
|
||||||
|
public DatabaseObject getObject(String name) {
|
||||||
|
for(DatabaseObject o : objects)
|
||||||
|
if(o.getName().equals(name))
|
||||||
|
return o;
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void removeObject(DatabaseObject obj) {
|
||||||
|
if(this.objects.contains(obj))
|
||||||
|
return;
|
||||||
|
int index = this.objects.indexOf(obj);
|
||||||
|
this.objects.remove(index);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void removeObject(String obj) {
|
||||||
|
DatabaseObject temp = getObject(obj);
|
||||||
|
removeObject(temp);
|
||||||
|
}
|
||||||
|
|
||||||
|
public String toString() {
|
||||||
|
String result = new String();
|
||||||
|
|
||||||
|
result += "==========Database==========" + "\n";
|
||||||
|
for(DatabaseObject o : this.objects)
|
||||||
|
result += o.toString(5);
|
||||||
|
result += "\n";
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void print() {
|
||||||
|
System.out.print(this.toString());
|
||||||
|
}
|
||||||
|
|
||||||
|
public byte[] serialize() {
|
||||||
|
List<Byte> bytes = new ArrayList<Byte>();
|
||||||
|
|
||||||
|
BinaryParser.writeBytes(bytes, DATABASE_ID);
|
||||||
|
BinaryParser.writeBytes(bytes, (short)this.objects.size());
|
||||||
|
BinaryParser.writeBytes(bytes, "DATA");
|
||||||
|
|
||||||
|
for(DatabaseObject obj : this.objects) {
|
||||||
|
byte[] temp = obj.serialize();
|
||||||
|
for(byte b : temp)
|
||||||
|
bytes.add(b);
|
||||||
|
}
|
||||||
|
|
||||||
|
byte[] result = new byte[bytes.size()];
|
||||||
|
for(int i = 0; i < bytes.size(); i++)
|
||||||
|
result[i] = bytes.get(i);
|
||||||
|
|
||||||
|
this.sizeInBytes = result.length;
|
||||||
|
|
||||||
|
bytes = null;
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static Database deserialize(byte[] src) {
|
||||||
|
//HEADER
|
||||||
|
//[4]String DatabaseID
|
||||||
|
//[4] Short ObjectCount
|
||||||
|
//[4] String "DATA"
|
||||||
|
int ptr = 0;
|
||||||
|
String tDbId = BinaryParser.readString(src, 4, ptr);
|
||||||
|
ptr += 4;
|
||||||
|
if(!tDbId.equals(DATABASE_ID))
|
||||||
|
return null;
|
||||||
|
short tObjCount = BinaryParser.readShort(src, ptr);
|
||||||
|
ptr += 2;
|
||||||
|
String tDataId = BinaryParser.readString(src, 4, ptr);
|
||||||
|
ptr += 4;
|
||||||
|
|
||||||
|
Database result = new Database();
|
||||||
|
for(int i = 0; i < tObjCount; i++) {
|
||||||
|
DatabaseObject obj = DatabaseObject.deserialize(src, ptr);
|
||||||
|
ptr += obj.getSizeInBytes();
|
||||||
|
result.addObject(obj);
|
||||||
|
}
|
||||||
|
|
||||||
|
return result;
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,498 @@
|
||||||
|
package org.hwo.serialize;
|
||||||
|
|
||||||
|
import java.util.ArrayList;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
public class DatabaseField {
|
||||||
|
//FORMAT:
|
||||||
|
//[4] String FieldID (DFLD)
|
||||||
|
//[1] Byte FieldType
|
||||||
|
//[2] Short NameLength
|
||||||
|
//[NameLength] String Name
|
||||||
|
// if type==string [2] Short ValueLength
|
||||||
|
//[TypeLength] Value
|
||||||
|
|
||||||
|
//second nibble == type, first nibble == type if array
|
||||||
|
public static final byte BYTE = 0x00;
|
||||||
|
public static final byte SHORT = 0x01;
|
||||||
|
public static final byte INT = 0x02;
|
||||||
|
public static final byte LONG = 0x03;
|
||||||
|
public static final byte FLOAT = 0x06;
|
||||||
|
public static final byte STRING = 0x04;
|
||||||
|
public static final byte OBJECT = 0x05;
|
||||||
|
public static final byte ARRAY = 0x0F;
|
||||||
|
|
||||||
|
private static final String FIELD_ID = "DFLD";
|
||||||
|
|
||||||
|
public enum Type {
|
||||||
|
BYTE,
|
||||||
|
SHORT,
|
||||||
|
INT,
|
||||||
|
LONG,
|
||||||
|
FLOAT,
|
||||||
|
STRING,
|
||||||
|
OBJECT,
|
||||||
|
ARRAY
|
||||||
|
}
|
||||||
|
|
||||||
|
private class _valueType<T>{
|
||||||
|
private T value;
|
||||||
|
|
||||||
|
public _valueType(T value) {
|
||||||
|
this.value = value;
|
||||||
|
}
|
||||||
|
|
||||||
|
@SuppressWarnings("unused")
|
||||||
|
public void setValue(T value) {
|
||||||
|
this.value = value;
|
||||||
|
}
|
||||||
|
|
||||||
|
public T getValue() {
|
||||||
|
return value;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private byte type;
|
||||||
|
private String name;
|
||||||
|
@SuppressWarnings("rawtypes")
|
||||||
|
private _valueType value;
|
||||||
|
private List<?> arrayValue;
|
||||||
|
private int sizeInBytes;
|
||||||
|
|
||||||
|
|
||||||
|
//+++++++++++CONSTRUCTORS+++++++++++++++//
|
||||||
|
public DatabaseField(byte type, String name) {
|
||||||
|
this.type = type;
|
||||||
|
this.name = name;
|
||||||
|
}
|
||||||
|
|
||||||
|
public DatabaseField(byte type, String name, Object value, boolean array) {
|
||||||
|
if(array) {
|
||||||
|
this.type = ARRAY;
|
||||||
|
this.type |= type << 4;
|
||||||
|
this.name = name;
|
||||||
|
this.arrayValue = (ArrayList<?>)value;
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
this.type = type;
|
||||||
|
this.name = name;
|
||||||
|
initialize(value);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
private void initialize(Object value) {
|
||||||
|
switch(_byteToType(this.type)) {
|
||||||
|
case BYTE:
|
||||||
|
setValue((byte)value);
|
||||||
|
break;
|
||||||
|
case SHORT:
|
||||||
|
setValue((short)value);
|
||||||
|
break;
|
||||||
|
case INT:
|
||||||
|
setValue((int)value);
|
||||||
|
break;
|
||||||
|
case LONG:
|
||||||
|
setValue((long)value);
|
||||||
|
break;
|
||||||
|
case FLOAT:
|
||||||
|
setValue((float)value);
|
||||||
|
break;
|
||||||
|
case STRING:
|
||||||
|
setValue((String)value);
|
||||||
|
break;
|
||||||
|
case OBJECT:
|
||||||
|
setValue((DatabaseObject)value);
|
||||||
|
break;
|
||||||
|
case ARRAY:
|
||||||
|
//setValue((List<?>)value);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public Type getType() {
|
||||||
|
return _byteToType(this.type);
|
||||||
|
}
|
||||||
|
|
||||||
|
private static Type _byteToType(byte t) {
|
||||||
|
switch(t) {
|
||||||
|
case 0x00:
|
||||||
|
return Type.BYTE;
|
||||||
|
case 0x01:
|
||||||
|
return Type.SHORT;
|
||||||
|
case 0x02:
|
||||||
|
return Type.INT;
|
||||||
|
case 0x03:
|
||||||
|
return Type.LONG;
|
||||||
|
case 0x04:
|
||||||
|
return Type.STRING;
|
||||||
|
case 0x05:
|
||||||
|
return Type.OBJECT;
|
||||||
|
case 0x06:
|
||||||
|
return Type.FLOAT;
|
||||||
|
default:
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
if(t >= 0x0F)
|
||||||
|
return Type.ARRAY;
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
private static byte _typeToByte(Type t) {
|
||||||
|
switch(t) {
|
||||||
|
case BYTE:
|
||||||
|
return 0x00;
|
||||||
|
case SHORT:
|
||||||
|
return 0x01;
|
||||||
|
case INT:
|
||||||
|
return 0x02;
|
||||||
|
case LONG:
|
||||||
|
return 0x03;
|
||||||
|
case STRING:
|
||||||
|
return 0x04;
|
||||||
|
case OBJECT:
|
||||||
|
return 0x05;
|
||||||
|
case FLOAT:
|
||||||
|
return 0x06;
|
||||||
|
case ARRAY:
|
||||||
|
return 0x0F;
|
||||||
|
default:
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getName() {
|
||||||
|
return this.name;
|
||||||
|
}
|
||||||
|
|
||||||
|
private<T> void _setValue(T value) {
|
||||||
|
this.value = new _valueType<T>(value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setValue(byte value) { _setValue(value); }
|
||||||
|
public void setValue(short value) { _setValue(value); }
|
||||||
|
public void setValue(int value) { _setValue(value); }
|
||||||
|
public void setValue(long value) { _setValue(value); }
|
||||||
|
public void setValue(float value) { _setValue(value); }
|
||||||
|
public void setValue(String value) { _setValue(value); }
|
||||||
|
public void setValue(DatabaseObject value) { _setValue(value); }
|
||||||
|
public void setValue(List<?> value) { this.arrayValue = value; }
|
||||||
|
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
|
public<T> T getValue(){
|
||||||
|
|
||||||
|
if(this.type >= 0x0F)
|
||||||
|
return (T)this.arrayValue;
|
||||||
|
return (T)this.value.getValue();
|
||||||
|
}
|
||||||
|
|
||||||
|
public int getSizeInBytes() {
|
||||||
|
if(this.sizeInBytes <= 0)
|
||||||
|
this.sizeInBytes = 11 + typeSize(_byteToType(this.type)) + this.name.length();
|
||||||
|
|
||||||
|
return this.sizeInBytes;
|
||||||
|
}
|
||||||
|
|
||||||
|
private int typeSize(Type t) {
|
||||||
|
switch(t) {
|
||||||
|
case BYTE:
|
||||||
|
return Byte.BYTES;
|
||||||
|
case SHORT:
|
||||||
|
return Short.BYTES;
|
||||||
|
case INT:
|
||||||
|
return Integer.BYTES;
|
||||||
|
case LONG:
|
||||||
|
return Long.BYTES;
|
||||||
|
case FLOAT:
|
||||||
|
return Float.BYTES;
|
||||||
|
case STRING:
|
||||||
|
return ((String)(this.value.getValue())).length();
|
||||||
|
case OBJECT:
|
||||||
|
return ((DatabaseObject)(this.value.getValue())).getSizeInBytes();
|
||||||
|
case ARRAY:
|
||||||
|
return 0; //TODO:
|
||||||
|
default:
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
|
public String toString(int indendation) {
|
||||||
|
String indend = new String();
|
||||||
|
String result = new String();
|
||||||
|
for(int i = 0; i < indendation; i++)
|
||||||
|
indend += " ";
|
||||||
|
|
||||||
|
result += indend + "Field " + this.name + "\n";
|
||||||
|
result += indend + "Type: " + _byteToType(this.type) + "\n";
|
||||||
|
if(_byteToType(this.type) == Type.OBJECT)
|
||||||
|
result += indend + "Value " + ((DatabaseObject)getValue()).toString(indendation + 5);
|
||||||
|
else if(_byteToType(this.type) == Type.ARRAY) {
|
||||||
|
result += indend + "Value: \n";
|
||||||
|
result += indend;
|
||||||
|
for(int i = 0; i < arrayValue.size(); i++) {
|
||||||
|
result += "[" + i + "]" + " ";
|
||||||
|
//TODO: print values!
|
||||||
|
switch(_byteToType((byte)(this.type >> 4))) {
|
||||||
|
case BYTE:
|
||||||
|
result += ((ArrayList<Byte>)arrayValue).get(i) + " ";
|
||||||
|
break;
|
||||||
|
case SHORT:
|
||||||
|
result += ((ArrayList<Short>)arrayValue).get(i) + " ";
|
||||||
|
break;
|
||||||
|
case INT:
|
||||||
|
result += ((ArrayList<Integer>)arrayValue).get(i) + " ";
|
||||||
|
break;
|
||||||
|
case LONG:
|
||||||
|
result += ((ArrayList<Long>)arrayValue).get(i) + " ";
|
||||||
|
break;
|
||||||
|
case FLOAT:
|
||||||
|
result += ((ArrayList<Float>)arrayValue).get(i) + " ";
|
||||||
|
case STRING:
|
||||||
|
//result += (String)((List<Object>)getValue()).get(i) + " ";
|
||||||
|
break;
|
||||||
|
case OBJECT:
|
||||||
|
//result += indend + ((DatabaseObject)((List<Object>)getValue()).get(i)).toString(indendation + 5);
|
||||||
|
break;
|
||||||
|
case ARRAY:
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
if((i % 5) == 4)
|
||||||
|
result += "\n" + indend;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
result += indend + "Value: " + getValue() + "\n";
|
||||||
|
result += "\n";
|
||||||
|
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String toString() {
|
||||||
|
return toString(0);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void print(int indendation) {
|
||||||
|
System.out.print(this.toString(indendation));
|
||||||
|
}
|
||||||
|
|
||||||
|
public void print() {
|
||||||
|
print(0);
|
||||||
|
}
|
||||||
|
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
|
public byte[] serialize() {
|
||||||
|
List<Byte> bytes = new ArrayList<Byte>();
|
||||||
|
|
||||||
|
BinaryParser.writeBytes(bytes, FIELD_ID);
|
||||||
|
BinaryParser.writeBytes(bytes, this.type);
|
||||||
|
BinaryParser.writeBytes(bytes, (short)this.name.length());
|
||||||
|
BinaryParser.writeBytes(bytes, this.name);
|
||||||
|
|
||||||
|
switch(getType()) {
|
||||||
|
case BYTE:
|
||||||
|
BinaryParser.writeBytes(bytes, (int)Byte.BYTES);
|
||||||
|
BinaryParser.writeBytes(bytes, (byte)getValue());
|
||||||
|
break;
|
||||||
|
case SHORT:
|
||||||
|
BinaryParser.writeBytes(bytes, (int)Short.BYTES);
|
||||||
|
BinaryParser.writeBytes(bytes, (short)getValue());
|
||||||
|
break;
|
||||||
|
case INT:
|
||||||
|
BinaryParser.writeBytes(bytes, (int)Integer.BYTES);
|
||||||
|
BinaryParser.writeBytes(bytes, (int)getValue());
|
||||||
|
break;
|
||||||
|
case LONG:
|
||||||
|
BinaryParser.writeBytes(bytes, (int)Long.BYTES);
|
||||||
|
BinaryParser.writeBytes(bytes, (long)getValue());
|
||||||
|
break;
|
||||||
|
case FLOAT:
|
||||||
|
BinaryParser.writeBytes(bytes, (int)Float.BYTES);
|
||||||
|
BinaryParser.writeBytes(bytes, (float)getValue());
|
||||||
|
break;
|
||||||
|
case STRING:
|
||||||
|
BinaryParser.writeBytes(bytes, (int)((String)getValue()).length());
|
||||||
|
BinaryParser.writeBytes(bytes, (String)getValue());
|
||||||
|
break;
|
||||||
|
case OBJECT:
|
||||||
|
BinaryParser.writeBytes(bytes, (int)(((DatabaseObject)getValue()).getSizeInBytes()));
|
||||||
|
byte[] temp = ((DatabaseObject)getValue()).serialize();
|
||||||
|
for(byte b : temp)
|
||||||
|
bytes.add(b);
|
||||||
|
case ARRAY:
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
//serialize array
|
||||||
|
if(this.type >= 0x0F) {
|
||||||
|
int arrLen = arrayValue.size();
|
||||||
|
|
||||||
|
switch(_byteToType((byte)(this.type >> 4))) {
|
||||||
|
case BYTE:
|
||||||
|
BinaryParser.writeBytes(bytes, (int)(Byte.BYTES * arrLen));
|
||||||
|
for(int i = 0; i < arrLen; i++)
|
||||||
|
BinaryParser.writeBytes(bytes, ((List<Byte>)arrayValue).get(i));
|
||||||
|
break;
|
||||||
|
case SHORT:
|
||||||
|
BinaryParser.writeBytes(bytes, (int)(Short.BYTES * arrLen));
|
||||||
|
for(int i = 0; i < arrLen; i++)
|
||||||
|
BinaryParser.writeBytes(bytes, ((List<Short>)arrayValue).get(i));
|
||||||
|
break;
|
||||||
|
case INT:
|
||||||
|
BinaryParser.writeBytes(bytes, (int)(Integer.BYTES * arrLen));
|
||||||
|
for(int i = 0; i < arrLen; i++)
|
||||||
|
BinaryParser.writeBytes(bytes,((List<Integer>)arrayValue).get(i));
|
||||||
|
break;
|
||||||
|
case LONG:
|
||||||
|
BinaryParser.writeBytes(bytes, (int)(Long.BYTES * arrLen));
|
||||||
|
for(int i = 0; i < arrLen; i++)
|
||||||
|
BinaryParser.writeBytes(bytes, ((List<Long>)arrayValue).get(i));
|
||||||
|
break;
|
||||||
|
case FLOAT:
|
||||||
|
BinaryParser.writeBytes(bytes, (int)(Float.BYTES * arrLen));
|
||||||
|
for(int i = 0; i < arrLen; i++)
|
||||||
|
BinaryParser.writeBytes(bytes, ((List<Float>)arrayValue).get(i));
|
||||||
|
case STRING:
|
||||||
|
break;
|
||||||
|
case OBJECT:
|
||||||
|
break;
|
||||||
|
case ARRAY:
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
byte[] result = new byte[bytes.size()];
|
||||||
|
for(int i = 0; i < bytes.size(); i++)
|
||||||
|
result[i] = bytes.get(i);
|
||||||
|
|
||||||
|
this.sizeInBytes = result.length;
|
||||||
|
|
||||||
|
bytes = null;
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
|
public static DatabaseField deserialize(byte[] src, int ptr) {
|
||||||
|
String tid;
|
||||||
|
byte ttype;
|
||||||
|
short tnameLen;
|
||||||
|
String tname;
|
||||||
|
int tvalueLen = 0;
|
||||||
|
Object tvalue = null;
|
||||||
|
|
||||||
|
DatabaseField result = null;
|
||||||
|
|
||||||
|
tid = BinaryParser.readString(src, 4, ptr);
|
||||||
|
ptr += 4;
|
||||||
|
if(!tid.equals(FIELD_ID)) {
|
||||||
|
//throw new Exception();
|
||||||
|
System.out.println("Field to deserialize is not of type Field! \nID read: " + tid);
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
ttype = BinaryParser.readByte(src, ptr);
|
||||||
|
ptr += 1;
|
||||||
|
|
||||||
|
tnameLen = BinaryParser.readShort(src, ptr);
|
||||||
|
ptr += 2;
|
||||||
|
|
||||||
|
tname = BinaryParser.readString(src, tnameLen, ptr);
|
||||||
|
ptr += tnameLen;
|
||||||
|
|
||||||
|
tvalueLen = BinaryParser.readInt(src, ptr);
|
||||||
|
ptr += 4;
|
||||||
|
|
||||||
|
//Length = 11 + NameLength + TypeLength
|
||||||
|
switch(_byteToType(ttype)) {
|
||||||
|
case BYTE:
|
||||||
|
tvalue = BinaryParser.readByte(src, ptr);
|
||||||
|
result = new DatabaseField(ttype, tname, (byte)tvalue, false);
|
||||||
|
break;
|
||||||
|
case SHORT:
|
||||||
|
tvalue = BinaryParser.readShort(src, ptr);
|
||||||
|
result = new DatabaseField(ttype, tname, (short)tvalue, false);
|
||||||
|
break;
|
||||||
|
case INT:
|
||||||
|
tvalue = BinaryParser.readInt(src, ptr);
|
||||||
|
result = new DatabaseField(ttype, tname, (int)tvalue, false);
|
||||||
|
break;
|
||||||
|
case LONG:
|
||||||
|
tvalue = BinaryParser.readLong(src, ptr);
|
||||||
|
result = new DatabaseField(ttype, tname, (long)tvalue, false);
|
||||||
|
break;
|
||||||
|
case FLOAT:
|
||||||
|
tvalue = BinaryParser.readFloat(src, ptr);
|
||||||
|
result = new DatabaseField(ttype, tname, (float)tvalue, false);
|
||||||
|
case STRING:
|
||||||
|
tvalue = BinaryParser.readString(src, tvalueLen, ptr);
|
||||||
|
result = new DatabaseField(ttype, tname, (String)tvalue, false);
|
||||||
|
break;
|
||||||
|
case OBJECT:
|
||||||
|
tvalue = DatabaseObject.deserialize(src, ptr);
|
||||||
|
result = new DatabaseField(ttype, tname, (DatabaseObject)tvalue, false);
|
||||||
|
break;
|
||||||
|
case ARRAY:
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
//Array Type
|
||||||
|
if(ttype >= 0x06) {
|
||||||
|
switch(_byteToType((byte)(ttype >> 4))) {
|
||||||
|
case BYTE:
|
||||||
|
tvalue = new ArrayList<Byte>();
|
||||||
|
for(int i = 0; i < (tvalueLen / Byte.BYTES); i++) {
|
||||||
|
((ArrayList<Byte>)tvalue).add(BinaryParser.readByte(src, ptr));
|
||||||
|
ptr += Byte.BYTES;
|
||||||
|
}
|
||||||
|
result = new DatabaseField((byte)(ttype >> 4), tname, (ArrayList<Byte>)tvalue, true);
|
||||||
|
break;
|
||||||
|
case SHORT:
|
||||||
|
tvalue = new ArrayList<Short>();
|
||||||
|
for(int i = 0; i < (tvalueLen / Short.BYTES); i++) {
|
||||||
|
((ArrayList<Short>)tvalue).add(BinaryParser.readShort(src, ptr));
|
||||||
|
ptr += Short.BYTES;
|
||||||
|
}
|
||||||
|
result = new DatabaseField((byte)(ttype >> 4), tname, (ArrayList<Short>)tvalue, true);
|
||||||
|
break;
|
||||||
|
case INT:
|
||||||
|
tvalue = new ArrayList<Integer>();
|
||||||
|
for(int i = 0; i < (tvalueLen / Integer.BYTES); i++) {
|
||||||
|
((ArrayList<Integer>)tvalue).add(BinaryParser.readInt(src, ptr));
|
||||||
|
ptr += Integer.BYTES;
|
||||||
|
}
|
||||||
|
result = new DatabaseField((byte)(ttype >> 4), tname, (ArrayList<Integer>)tvalue, true);
|
||||||
|
break;
|
||||||
|
case LONG:
|
||||||
|
tvalue = new ArrayList<Long>();
|
||||||
|
for(int i = 0; i < (tvalueLen / Long.BYTES); i++) {
|
||||||
|
((ArrayList<Long>)tvalue).add(BinaryParser.readLong(src, ptr));
|
||||||
|
ptr += Long.BYTES;
|
||||||
|
}
|
||||||
|
result = new DatabaseField((byte)(ttype >> 4), tname, (ArrayList<Long>)tvalue, true);
|
||||||
|
break;
|
||||||
|
case FLOAT:
|
||||||
|
tvalue = new ArrayList<Float>();
|
||||||
|
for(int i = 0; i < (tvalueLen / Float.BYTES); i++) {
|
||||||
|
((ArrayList<Float>)tvalue).add(BinaryParser.readFloat(src, ptr));
|
||||||
|
ptr += Float.BYTES;
|
||||||
|
}
|
||||||
|
result = new DatabaseField((byte)(ttype >> 4), tname, (ArrayList<Float>)tvalue, true);
|
||||||
|
break;
|
||||||
|
case STRING:
|
||||||
|
break;
|
||||||
|
case OBJECT:
|
||||||
|
break;
|
||||||
|
case ARRAY:
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
//result.sizeInBytes = 11 + tnameLen + tvalueLen;
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
}
|
|
@ -0,0 +1,217 @@
|
||||||
|
package org.hwo.serialize;
|
||||||
|
|
||||||
|
import java.lang.reflect.*;
|
||||||
|
import java.util.ArrayList;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
public class DatabaseObject {
|
||||||
|
|
||||||
|
//OBJECT
|
||||||
|
//[4] String ObjectID ("OBJT")
|
||||||
|
//[2] Short NameLen
|
||||||
|
//[NameLen] String Name
|
||||||
|
//[2] Short NumFields
|
||||||
|
|
||||||
|
private static final String OBJECT_ID = "OBJT";
|
||||||
|
|
||||||
|
private List<DatabaseField> fields;
|
||||||
|
private String name;
|
||||||
|
private int sizeInBytes;
|
||||||
|
|
||||||
|
public DatabaseObject(String name) {
|
||||||
|
this.name = name;
|
||||||
|
this.fields = new ArrayList<DatabaseField>();
|
||||||
|
}
|
||||||
|
|
||||||
|
public void addField(DatabaseField field) {
|
||||||
|
if(fields.contains(field))
|
||||||
|
return;
|
||||||
|
fields.add(field);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void addField(String name, byte value) {
|
||||||
|
DatabaseField temp = new DatabaseField(DatabaseField.BYTE, name, value, false);
|
||||||
|
if(temp != null)
|
||||||
|
addField(temp);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void addField(String name, short value) {
|
||||||
|
DatabaseField temp = new DatabaseField(DatabaseField.SHORT, name, value, false);
|
||||||
|
if(temp != null)
|
||||||
|
addField(temp);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void addField(String name, int value) {
|
||||||
|
DatabaseField temp = new DatabaseField(DatabaseField.INT, name, value, false);
|
||||||
|
if(temp != null)
|
||||||
|
addField(temp);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void addField(String name, long value) {
|
||||||
|
DatabaseField temp = new DatabaseField(DatabaseField.LONG, name, value, false);
|
||||||
|
if(temp != null)
|
||||||
|
addField(temp);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void addField(String name, String value) {
|
||||||
|
DatabaseField temp = new DatabaseField(DatabaseField.STRING, name, value, false);
|
||||||
|
if(temp != null)
|
||||||
|
addField(temp);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void addField(String name, DatabaseObject value) {
|
||||||
|
DatabaseField temp = new DatabaseField(DatabaseField.OBJECT, name, value, false);
|
||||||
|
if(temp != null)
|
||||||
|
addField(temp);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void addField(String name, float value) {
|
||||||
|
DatabaseField temp = new DatabaseField(DatabaseField.FLOAT, name, value, false);
|
||||||
|
if(temp != null)
|
||||||
|
addField(temp);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void addField(String name, List<?> value){
|
||||||
|
|
||||||
|
DatabaseField temp;
|
||||||
|
Object check = value.get(0);
|
||||||
|
|
||||||
|
if(check instanceof Byte)
|
||||||
|
temp = new DatabaseField(DatabaseField.BYTE, name, value, true);
|
||||||
|
else if(check instanceof Short)
|
||||||
|
temp = new DatabaseField(DatabaseField.SHORT, name, value, true);
|
||||||
|
else if(check instanceof Integer)
|
||||||
|
temp = new DatabaseField(DatabaseField.INT, name, value, true);
|
||||||
|
else if(check instanceof Long)
|
||||||
|
temp = new DatabaseField(DatabaseField.LONG, name, value, true);
|
||||||
|
else if(check instanceof Float)
|
||||||
|
temp = new DatabaseField(DatabaseField.FLOAT, name, value, true);
|
||||||
|
else
|
||||||
|
return;
|
||||||
|
|
||||||
|
if(temp != null)
|
||||||
|
addField(temp);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void removeField(DatabaseField field) {
|
||||||
|
if(fields.contains(field))
|
||||||
|
return;
|
||||||
|
int index = fields.indexOf(field);
|
||||||
|
fields.remove(index);
|
||||||
|
}
|
||||||
|
|
||||||
|
public DatabaseField getField(String name) {
|
||||||
|
for(DatabaseField f : fields)
|
||||||
|
if(f.getName().equals(name))
|
||||||
|
return f;
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
public <T>T getValue(String name){
|
||||||
|
DatabaseField f = getField(name);
|
||||||
|
if(f != null)
|
||||||
|
return f.getValue();
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getName() {
|
||||||
|
return this.name;
|
||||||
|
}
|
||||||
|
|
||||||
|
public int getSizeInBytes() {
|
||||||
|
if(this.sizeInBytes <= 0) {
|
||||||
|
this.sizeInBytes = 8 + this.name.length();
|
||||||
|
for(int i = 0; i < this.fields.size(); i++)
|
||||||
|
this.sizeInBytes += this.fields.get(i).getSizeInBytes();
|
||||||
|
}
|
||||||
|
|
||||||
|
return this.sizeInBytes;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public String toString(int indendation) {
|
||||||
|
String indend = new String();
|
||||||
|
String result = new String();
|
||||||
|
|
||||||
|
for(int i = 0; i < indendation; i++)
|
||||||
|
indend += " ";
|
||||||
|
|
||||||
|
result += indend + "Object: " + this.name + "\n";
|
||||||
|
result += indend + "Fields: " + "\n";
|
||||||
|
|
||||||
|
for(DatabaseField f : this.fields) {
|
||||||
|
result += f.toString(indendation + 5);
|
||||||
|
}
|
||||||
|
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String toString() {
|
||||||
|
return toString(0);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void print(int indendation) {
|
||||||
|
System.out.print(this.toString(indendation));
|
||||||
|
}
|
||||||
|
|
||||||
|
public void print() {
|
||||||
|
print(0);
|
||||||
|
}
|
||||||
|
|
||||||
|
public byte[] serialize() {
|
||||||
|
List<Byte> bytes = new ArrayList<Byte>();
|
||||||
|
|
||||||
|
BinaryParser.writeBytes(bytes, OBJECT_ID); //Object ID
|
||||||
|
BinaryParser.writeBytes(bytes, (short)this.name.length()); //Name Length
|
||||||
|
BinaryParser.writeBytes(bytes, this.name); // Name
|
||||||
|
BinaryParser.writeBytes(bytes, (short)this.fields.size()); //Field Count
|
||||||
|
|
||||||
|
for(DatabaseField f : this.fields) {
|
||||||
|
byte[] temp = f.serialize();
|
||||||
|
for(byte b : temp)
|
||||||
|
bytes.add(b);
|
||||||
|
}
|
||||||
|
|
||||||
|
byte[] result = new byte[bytes.size()];
|
||||||
|
for(int i = 0; i < bytes.size(); i++)
|
||||||
|
result[i] = bytes.get(i);
|
||||||
|
|
||||||
|
this.sizeInBytes = result.length;
|
||||||
|
|
||||||
|
bytes = null;
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
|
//@SuppressWarnings("unused")
|
||||||
|
public static DatabaseObject deserialize(byte[] src, int ptr) {
|
||||||
|
String tObjId = BinaryParser.readString(src, 4, ptr);
|
||||||
|
ptr += 4;
|
||||||
|
|
||||||
|
if(!tObjId.equals(OBJECT_ID))
|
||||||
|
return null;
|
||||||
|
|
||||||
|
short tNameLen = BinaryParser.readShort(src, ptr);
|
||||||
|
ptr += 2;
|
||||||
|
String tName = BinaryParser.readString(src, tNameLen, ptr);
|
||||||
|
ptr += tNameLen;
|
||||||
|
short tFieldCount = BinaryParser.readShort(src, ptr);
|
||||||
|
ptr += 2;
|
||||||
|
|
||||||
|
DatabaseObject result = new DatabaseObject(tName);
|
||||||
|
DatabaseField field = null;
|
||||||
|
int fieldSize = 0;
|
||||||
|
|
||||||
|
for(short i = 0; i < tFieldCount; i++) {
|
||||||
|
field = DatabaseField.deserialize(src, ptr);
|
||||||
|
if(field != null) {
|
||||||
|
ptr += field.getSizeInBytes();
|
||||||
|
fieldSize += field.getSizeInBytes();
|
||||||
|
result.addField(field);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
result.sizeInBytes = 8 + tNameLen + fieldSize;
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
|
@ -0,0 +1,23 @@
|
||||||
|
|
||||||
|
HEADER
|
||||||
|
[4] String DatabaseID
|
||||||
|
[2] Short ObjectCount
|
||||||
|
[4] String "DATA"
|
||||||
|
|
||||||
|
|
||||||
|
OBJECT
|
||||||
|
[4] String ObjectID ("OBJT")
|
||||||
|
[2] Short NameLen
|
||||||
|
[NameLen] String Name
|
||||||
|
[2] Short NumFields
|
||||||
|
Length = 8 + NameLen + Fields.Length
|
||||||
|
|
||||||
|
FIELD
|
||||||
|
[4] String FieldID
|
||||||
|
[1] Byte FieldType
|
||||||
|
[2] Short NameLength
|
||||||
|
[NameLength] String Name
|
||||||
|
[4] Int ValueLength
|
||||||
|
[TypeLength] Value
|
||||||
|
Length = 11 + NameLength + TypeLength
|
||||||
|
|
Loading…
Reference in New Issue