tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-08-18 04:28:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat[js]: javascript support compatible field

Browse Source
This commit is contained in:
sun
2023-09-27 18:20:22 +08:00
parent 1891702ae5
commit 72e4c9acc0
14 changed files with 464 additions and 466 deletions
Download Patch File Download Diff File Expand all files Collapse all files
protocol/src/test/javascript/.eslintrc.js
-5
View File
@@ -1,5 +0,0 @@
module.exports = {
env: {
jest: true
}
};
protocol/src/test/javascript/babel.config.js
-5
View File
@@ -1,5 +0,0 @@
module.exports = {
presets: [
'@vue/app'
]
};
protocol/src/test/javascript/main.js
+100
View File
@@ -0,0 +1,100 @@
import ByteBuffer from './zfoojs/buffer/ByteBuffer.js';
import ProtocolManager from './zfoojs/ProtocolManager.js';
import fs from "fs";
function assert(flag) {
if (!flag) {
console.error("exception happen");
}
}
// const data = fs.readFileSync('D:\\Project\\zfoo\\protocol\\src\\test\\resources\\compatible\\normal-no-compatible.bytes');
// const data = fs.readFileSync('D:\\Project\\zfoo\\protocol\\src\\test\\resources\\compatible\\normal-out-compatible.bytes');
// const data = fs.readFileSync('D:\\Project\\zfoo\\protocol\\src\\test\\resources\\compatible\\normal-inner-compatible.bytes');
// const data = fs.readFileSync('D:\\Project\\zfoo\\protocol\\src\\test\\resources\\compatible\\normal-out-inner-compatible.bytes');
const data = fs.readFileSync('D:\\Project\\zfoo\\protocol\\src\\test\\resources\\compatible\\normal-out-inner-inner-compatible.bytes');
const arrayBytes = new Uint8Array(data.length);
data.copy(arrayBytes, 0, 0, data.length);
const byteBuffer = new ByteBuffer();
byteBuffer.writeBytes(arrayBytes);
const packet = ProtocolManager.read(byteBuffer);
console.log(packet);
const newByteBuffer = new ByteBuffer();
ProtocolManager.write(newByteBuffer, packet);
const newPacket = ProtocolManager.read(newByteBuffer);
console.log(newPacket);
// set和map是无序的，所以有的时候输入和输出的字节流有可能不一致，但是长度一定是一致的
// assert(byteBuffer.readOffset == newByteBuffer.writeOffset)
byteBufferTest();
function byteBufferTest() {
let buffer = new ByteBuffer();
assert(buffer.getCapacity() == 128);
// boolean
const testBoolean = [false, true];
testBoolean.forEach((value) => {
buffer.writeBoolean(value);
assert(buffer.readBoolean() == value);
});
assert(buffer.writeOffset == testBoolean.length);
assert(buffer.readOffset == testBoolean.length);
// byte
buffer = new ByteBuffer();
const testByte = [-128, -99, 0, 99, 127];
testByte.forEach((value) => {
buffer.writeByte(value);
assert(buffer.readByte() == value);
});
assert(buffer.writeOffset == testByte.length);
assert(buffer.readOffset == testByte.length);
// short
buffer = new ByteBuffer();
const testShort = [-32768, -99, 0, 99, 32767];
testShort.forEach((value) => {
buffer.writeShort(value);
assert(buffer.readShort() == value);
});
assert(buffer.writeOffset == testShort.length * 2);
assert(buffer.readOffset == testShort.length * 2);
// int
buffer = new ByteBuffer();
const testInt = [-2147483648, -99, 0, 99, 2147483647];
testInt.forEach((value) => {
buffer.writeInt(value);
assert(buffer.readInt() == value);
});
// float
buffer = new ByteBuffer();
const testFloat = [-999.5, -99.5, 0, 99.5, 999.5];
testFloat.forEach((value) => {
buffer.writeFloat(value);
assert(buffer.readFloat() == value);
});
// double
buffer = new ByteBuffer();
const testDouble = [-999.5, -99.5, 0, 99.5, 999.5];
testDouble.forEach((value) => {
buffer.writeDouble(value);
assert(buffer.readDouble() == value);
});
// string
buffer = new ByteBuffer();
const testString = 'hello world!';
buffer.writeString(testString);
assert(buffer.readString() == testString);
}
protocol/src/test/javascript/main.spec.js
-107
View File
@@ -1,107 +0,0 @@
import ByteBuffer from './zfoojs/buffer/ByteBuffer.js';
import ProtocolManager from './zfoojs/ProtocolManager.js';
const fs = require('fs');
describe('jsProtocolTest', () => {
it('complexObjectTest', () => {
const data = fs.readFileSync('../resources/ComplexObject.bytes');
const arrayBytes = new Uint8Array(data.length);
data.copy(arrayBytes, 0, 0, data.length);
const byteBuffer = new ByteBuffer();
byteBuffer.writeBytes(arrayBytes);
const packet = ProtocolManager.read(byteBuffer);
// complexObjec是老的协议，所以序列化回来myCompatible是nil，所以要重新赋值
packet.myCompatible = 0
console.log(packet);
const newByteBuffer = new ByteBuffer();
ProtocolManager.write(newByteBuffer, packet);
const newPacket = ProtocolManager.read(newByteBuffer);
console.log(newPacket);
expect(byteBuffer.readOffset).toBeLessThan(newByteBuffer.writeOffset);
// set和map是无序的，所以有的时候输入和输出的字节流有可能不一致，但是长度一定是一致的
const length = newByteBuffer.writeOffset;
byteBuffer.setReadOffset(0);
newByteBuffer.setReadOffset(0);
for (let i = 0; i < length; i++) {
expect(byteBuffer.readByte()).toBe(newByteBuffer.readByte());
}
});
it('byteBufferTest', () => {
let buffer = new ByteBuffer();
expect(buffer.getCapacity()).toBe(128);
// boolean
const testBoolean = [false, true];
testBoolean.forEach((value) => {
buffer.writeBoolean(value);
expect(buffer.readBoolean()).toBe(value);
});
expect(buffer.writeOffset).toBe(testBoolean.length);
expect(buffer.readOffset).toBe(testBoolean.length);
// byte
buffer = new ByteBuffer();
const testByte = [-128, -99, 0, 99, 127];
testByte.forEach((value) => {
buffer.writeByte(value);
expect(buffer.readByte()).toBe(value);
});
expect(buffer.writeOffset).toBe(testByte.length);
expect(buffer.readOffset).toBe(testByte.length);
// short
buffer = new ByteBuffer();
const testShort = [-32768, -99, 0, 99, 32767];
testShort.forEach((value) => {
buffer.writeShort(value);
expect(buffer.readShort()).toBe(value);
});
expect(buffer.writeOffset).toBe(testShort.length * 2);
expect(buffer.readOffset).toBe(testShort.length * 2);
// int
buffer = new ByteBuffer();
const testInt = [-2147483648, -99, 0, 99, 2147483647];
testInt.forEach((value) => {
buffer.writeInt(value);
expect(buffer.readInt()).toBe(value);
});
// float
buffer = new ByteBuffer();
const testFloat = [-999.5, -99.5, 0, 99.5, 999.5];
testFloat.forEach((value) => {
buffer.writeFloat(value);
expect(buffer.readFloat()).toBe(value);
});
// double
buffer = new ByteBuffer();
const testDouble = [-999.5, -99.5, 0, 99.5, 999.5];
testDouble.forEach((value) => {
buffer.writeDouble(value);
expect(buffer.readDouble()).toBe(value);
});
// string
buffer = new ByteBuffer();
const testString = 'hello world!';
buffer.writeString(testString);
expect(buffer.readString()).toBe(testString);
// char
buffer = new ByteBuffer();
const testChar = 'h';
buffer.writeChar(testString);
expect(buffer.readChar()).toBe(testChar);
});
});
protocol/src/test/javascript/package.json
+7 -48
View File
@@ -1,51 +1,10 @@
{
"name": "zfoo",
"version": "0.0.0",
"description": "This is a common config for all projects",
"author": "godotg@gmail.com",
"license": "MIT",
"scripts": {
},
"dependencies": {
"vue": "2.6.11",
"vue-i18n": "8.12.0",
"vue-meta": "^2.2.2",
"vue-router": "3.1.6",
"vuelidate": "^0.7.5",
"vuetify": "^2.3.3",
"vuex": "3.1.3",
"vuex-router-sync": "^5.0.0"
},
"name": "zfoo-javascript",
"version": "1.0.0",
"description": "",
"main": "main.js",
"type": "module",
"devDependencies": {
"@vue/cli-plugin-babel": "~4.3.0",
"@vue/cli-plugin-eslint": "~4.3.0",
"@vue/cli-plugin-pwa": "^4.3.1",
"@vue/cli-service": "~4.3.0",
"@vue/cli-plugin-unit-jest": "~4.3.0",
"@vue/eslint-config-standard": "^4.0.0",
"@vue/test-utils": "1.0.0-beta.33",
"babel-core": "7.0.0-bridge.0",
"babel-jest": "23.6.0",
"babel-eslint": "^10.1.0",
"eslint": "^6.7.2",
"eslint-plugin-vue": "^6.2.2",
"node-sass": "^4.13.0",
"sass": "^1.19.0",
"sass-loader": "^8.0.0",
"stylus": "^0.54.5",
"stylus-loader": "^3.0.1",
"mockjs": "1.0.0",
"vue-template-compiler": "2.6.11",
"vue-cli-plugin-vuetify": "^2.0.6",
"vuetify-loader": "^1.5.0"
},
"engines": {
"node": ">=8.9",
"npm": ">= 3.0.0"
},
"browserslist": [
"> 1%",
"last 2 versions",
"not dead"
]
"express": "^4.18.2"
}
}
protocol/src/test/javascript/zfoojs/ProtocolManager.js
+2
View File
@@ -1,3 +1,4 @@
import EmptyObject from './packet/EmptyObject.js';
import ComplexObject from './packet/ComplexObject.js';
import NormalObject from './packet/NormalObject.js';
import ObjectA from './packet/ObjectA.js';
@@ -9,6 +10,7 @@ const protocols = new Map();
const ProtocolManager = {};
// initProtocol
protocols.set(0, EmptyObject);
protocols.set(100, ComplexObject);
protocols.set(101, NormalObject);
protocols.set(102, ObjectA);
protocol/src/test/javascript/zfoojs/buffer/ByteBuffer.js
+52 -60
View File
@@ -49,6 +49,32 @@ const ByteBuffer = function() {
this.buffer = new ArrayBuffer(initSize);
this.bufferView = new DataView(this.buffer, 0, this.buffer.byteLength);
this.adjustPadding = function(predictionLength, beforeWriteIndex) {
const currentWriteIndex = this.writeOffset;
const predictionCount = this.writeIntCount(predictionLength);
const length = currentWriteIndex - beforeWriteIndex - predictionCount;
const lengthCount = this.writeIntCount(length);
const padding = lengthCount - predictionCount;
if (padding === 0) {
this.setWriteOffset(beforeWriteIndex);
this.writeInt(length);
this.setWriteOffset(currentWriteIndex);
} else {
const retainedByteBuf = this.buffer.slice(currentWriteIndex - length, currentWriteIndex);
this.setWriteOffset(beforeWriteIndex);
this.writeInt(length);
this.writeBytes(retainedByteBuf);
}
}
this.compatibleRead = function(beforeReadIndex, length) {
return length !== -1 && this.getReadOffset() < length + beforeReadIndex;
}
this.getWriteOffset = function() {
return this.writeOffset;
}
this.setWriteOffset = function(writeOffset) {
if (writeOffset > this.buffer.byteLength) {
throw new Error('index out of bounds exception: readerIndex: ' + this.readOffset +
@@ -58,6 +84,10 @@ const ByteBuffer = function() {
this.writeOffset = writeOffset;
};
this.getReadOffset = function() {
return this.readOffset;
}
this.setReadOffset = function(readOffset) {
if (readOffset > this.writeOffset) {
throw new Error('index out of bounds exception: readerIndex: ' + this.readOffset +
@@ -201,6 +231,25 @@ const ByteBuffer = function() {
this.writeByte(value >>> 28);
};
this.writeIntCount = function(value) {
if (!(minInt <= value && value <= maxInt)) {
throw new Error('value must range between minInt:-2147483648 and maxInt:2147483647');
}
if (value >>> 7 === 0) {
return 1;
}
if (value >>> 14 === 0) {
return 2;
}
if (value >>> 21 === 0) {
return 3;
}
if (value >>> 28 === 0) {
return 4;
}
return 5;
}
this.readInt = function() {
let b = this.readByte();
let value = b & 0x7F;
@@ -272,7 +321,7 @@ const ByteBuffer = function() {
}
}
}
return readInt64(new Uint8Array(buffer.slice(0, count))).toString();
return readInt64(new Uint8Array(buffer.slice(0, count)));
};
this.writeFloat = function(value) {
@@ -305,18 +354,6 @@ const ByteBuffer = function() {
return value;
};
this.writeChar = function(value) {
if (value === null || value === undefined || value.length === 0) {
this.writeString(empty_str);
return;
}
this.writeString(value.charAt(0));
};
this.readChar = function() {
return this.readString();
};
this.writeString = function(value) {
if (value === null || value === undefined || value.trim().length === 0) {
this.writeInt(0);
@@ -534,28 +571,6 @@ const ByteBuffer = function() {
return array;
};
this.writeCharArray = function(array) {
if (array === null) {
this.writeInt(0);
} else {
this.writeInt(array.length);
array.forEach(element => {
this.writeChar(element);
});
}
};
this.readCharArray = function() {
const array = [];
const length = this.readInt();
if (length > 0) {
for (let index = 0; index < length; index++) {
array.push(this.readChar());
}
}
return array;
};
this.writePacketArray = function(array, protocolId) {
if (array === null) {
this.writeInt(0);
@@ -645,14 +660,6 @@ const ByteBuffer = function() {
return this.readStringArray();
};
this.writeCharList = function(list) {
this.writeCharArray(list);
};
this.readCharList = function() {
return this.readCharArray();
};
this.writePacketList = function(list, protocolId) {
this.writePacketArray(list, protocolId);
};
@@ -723,8 +730,8 @@ const ByteBuffer = function() {
};
this.writeLongSet = function(set) {
if (array === null) {
set.writeInt(0);
if (set === null) {
this.writeInt(0);
} else {
this.writeInt(set.size);
set.forEach(element => {
@@ -782,21 +789,6 @@ const ByteBuffer = function() {
return new Set(this.readStringArray());
};
this.writeCharSet = function(set) {
if (set === null) {
this.writeInt(0);
} else {
this.writeInt(set.size);
set.forEach(element => {
this.writeChar(element);
});
}
};
this.readCharSet = function() {
return new Set(this.readCharArray());
};
this.writePacketSet = function(set, protocolId) {
if (set === null) {
this.writeInt(0);
protocol/src/test/javascript/zfoojs/buffer/long.js
+2 -1
View File
@@ -1,6 +1,5 @@
/* eslint-disable */
// from https://github.com/dcodeIO/long.js/blob/master/src/long.js
module.exports = Long;
/**
* wasm optimizations, to do native i64 multiplication and divide
@@ -1323,3 +1322,5 @@ Long.fromBytesBE = function fromBytesBE(bytes, unsigned) {
unsigned
);
};
export default Long;
protocol/src/test/javascript/zfoojs/packet/ComplexObject.js
+187 -200
View File
@@ -1,66 +1,58 @@
// 复杂的对象
// 包括了各种复杂的结构，数组，List，Set，Map
//
// @author godotg
const ComplexObject = function(a, aa, aaa, aaaa, b, bb, bbb, bbbb, c, cc, ccc, cccc, d, dd, ddd, dddd, e, ee, eee, eeee, f, ff, fff, ffff, g, gg, ggg, gggg, h, hh, hhh, hhhh, jj, jjj, kk, kkk, l, ll, lll, llll, lllll, m, mm, mmm, mmmm, mmmmm, s, ss, sss, ssss, sssss, myCompatible, myObject) {
// 复杂的对象，包括了各种复杂的结构，数组，List，Set，Map
const ComplexObject = function() {
// byte类型，最简单的整形
this.a = a; // byte
// byte的包装类型
// 优先使用基础类型，包装类型会有装箱拆箱
this.aa = aa; // java.lang.Byte
this.a = 0; // number
// byte的包装类型，优先使用基础类型，包装类型会有装箱拆箱
this.aa = 0; // number
// 数组类型
this.aaa = aaa; // byte[]
this.aaaa = aaaa; // java.lang.Byte[]
this.b = b; // short
this.bb = bb; // java.lang.Short
this.bbb = bbb; // short[]
this.bbbb = bbbb; // java.lang.Short[]
this.c = c; // int
this.cc = cc; // java.lang.Integer
this.ccc = ccc; // int[]
this.cccc = cccc; // java.lang.Integer[]
this.d = d; // long
this.dd = dd; // java.lang.Long
this.ddd = ddd; // long[]
this.dddd = dddd; // java.lang.Long[]
this.e = e; // float
this.ee = ee; // java.lang.Float
this.eee = eee; // float[]
this.eeee = eeee; // java.lang.Float[]
this.f = f; // double
this.ff = ff; // java.lang.Double
this.fff = fff; // double[]
this.ffff = ffff; // java.lang.Double[]
this.g = g; // boolean
this.gg = gg; // java.lang.Boolean
this.ggg = ggg; // boolean[]
this.gggg = gggg; // java.lang.Boolean[]
this.h = h; // char
this.hh = hh; // java.lang.Character
this.hhh = hhh; // char[]
this.hhhh = hhhh; // java.lang.Character[]
this.jj = jj; // java.lang.String
this.jjj = jjj; // java.lang.String[]
this.kk = kk; // com.zfoo.protocol.packet.ObjectA
this.kkk = kkk; // com.zfoo.protocol.packet.ObjectA[]
this.l = l; // java.util.List<java.lang.Integer>
this.ll = ll; // java.util.List<java.util.List<java.util.List<java.lang.Integer>>>
this.lll = lll; // java.util.List<java.util.List<com.zfoo.protocol.packet.ObjectA>>
this.llll = llll; // java.util.List<java.lang.String>
this.lllll = lllll; // java.util.List<java.util.Map<java.lang.Integer, java.lang.String>>
this.m = m; // java.util.Map<java.lang.Integer, java.lang.String>
this.mm = mm; // java.util.Map<java.lang.Integer, com.zfoo.protocol.packet.ObjectA>
this.mmm = mmm; // java.util.Map<com.zfoo.protocol.packet.ObjectA, java.util.List<java.lang.Integer>>
this.mmmm = mmmm; // java.util.Map<java.util.List<java.util.List<com.zfoo.protocol.packet.ObjectA>>, java.util.List<java.util.List<java.util.List<java.lang.Integer>>>>
this.mmmmm = mmmmm; // java.util.Map<java.util.List<java.util.Map<java.lang.Integer, java.lang.String>>, java.util.Set<java.util.Map<java.lang.Integer, java.lang.String>>>
this.s = s; // java.util.Set<java.lang.Integer>
this.ss = ss; // java.util.Set<java.util.Set<java.util.List<java.lang.Integer>>>
this.sss = sss; // java.util.Set<java.util.Set<com.zfoo.protocol.packet.ObjectA>>
this.ssss = ssss; // java.util.Set<java.lang.String>
this.sssss = sssss; // java.util.Set<java.util.Map<java.lang.Integer, java.lang.String>>
this.aaa = []; // Array<number>
this.aaaa = []; // Array<number>
this.b = 0; // number
this.bb = 0; // number
this.bbb = []; // Array<number>
this.bbbb = []; // Array<number>
this.c = 0; // number
this.cc = 0; // number
this.ccc = []; // Array<number>
this.cccc = []; // Array<number>
this.d = 0; // number
this.dd = 0; // number
this.ddd = []; // Array<number>
this.dddd = []; // Array<number>
this.e = 0; // number
this.ee = 0; // number
this.eee = []; // Array<number>
this.eeee = []; // Array<number>
this.f = 0; // number
this.ff = 0; // number
this.fff = []; // Array<number>
this.ffff = []; // Array<number>
this.g = false; // boolean
this.gg = false; // boolean
this.ggg = []; // Array<boolean>
this.gggg = []; // Array<boolean>
this.jj = ""; // string
this.jjj = []; // Array<string>
this.kk = null; // ObjectA | null
this.kkk = []; // Array<ObjectA>
this.l = []; // Array<number>
this.ll = []; // Array<Array<Array<number>>>
this.lll = []; // Array<Array<ObjectA>>
this.llll = []; // Array<string>
this.lllll = []; // Array<Map<number, string>>
this.m = new Map(); // Map<number, string>
this.mm = new Map(); // Map<number, ObjectA>
this.mmm = new Map(); // Map<ObjectA, Array<number>>
this.mmmm = new Map(); // Map<Array<Array<ObjectA>>, Array<Array<Array<number>>>>
this.mmmmm = new Map(); // Map<Array<Map<number, string>>, Set<Map<number, string>>>
this.s = new Set(); // Set<number>
this.ss = new Set(); // Set<Set<Array<number>>>
this.sss = new Set(); // Set<Set<ObjectA>>
this.ssss = new Set(); // Set<string>
this.sssss = new Set(); // Set<Map<number, string>>
// 如果要修改协议并且兼容老协议，需要加上Compatible注解，按照增加的顺序添加order
this.myCompatible = myCompatible; // int
this.myObject = myObject; // com.zfoo.protocol.packet.ObjectA
this.myCompatible = 0; // number
this.myObject = null; // ObjectA | null
};
ComplexObject.prototype.protocolId = function() {
@@ -68,9 +60,12 @@ ComplexObject.prototype.protocolId = function() {
};
ComplexObject.write = function(buffer, packet) {
if (buffer.writePacketFlag(packet)) {
if (packet === null) {
buffer.writeInt(0);
return;
}
const beforeWriteIndex = buffer.getWriteOffset();
buffer.writeInt(36962);
buffer.writeByte(packet.a);
buffer.writeByte(packet.aa);
buffer.writeByteArray(packet.aaa);
@@ -99,10 +94,6 @@ ComplexObject.write = function(buffer, packet) {
buffer.writeBoolean(packet.gg);
buffer.writeBooleanArray(packet.ggg);
buffer.writeBooleanArray(packet.gggg);
buffer.writeChar(packet.h);
buffer.writeChar(packet.hh);
buffer.writeCharArray(packet.hhh);
buffer.writeCharArray(packet.hhhh);
buffer.writeString(packet.jj);
buffer.writeStringArray(packet.jjj);
buffer.writePacket(packet.kk, 102);
@@ -239,12 +230,15 @@ ComplexObject.write = function(buffer, packet) {
}
buffer.writeInt(packet.myCompatible);
buffer.writePacket(packet.myObject, 102);
buffer.adjustPadding(36962, beforeWriteIndex);
};
ComplexObject.read = function(buffer) {
if (!buffer.readBoolean()) {
const length = buffer.readInt();
if (length === 0) {
return null;
}
const beforeReadIndex = buffer.getReadOffset();
const packet = new ComplexObject();
const result19 = buffer.readByte();
packet.a = result19;
@@ -302,177 +296,170 @@ ComplexObject.read = function(buffer) {
packet.ggg = array45;
const array46 = buffer.readBooleanArray();
packet.gggg = array46;
const result47 = buffer.readChar();
packet.h = result47;
const result48 = buffer.readChar();
packet.hh = result48;
const array49 = buffer.readCharArray();
packet.hhh = array49;
const array50 = buffer.readCharArray();
packet.hhhh = array50;
const result51 = buffer.readString();
packet.jj = result51;
const array52 = buffer.readStringArray();
packet.jjj = array52;
const result53 = buffer.readPacket(102);
packet.kk = result53;
const array54 = buffer.readPacketArray(102);
packet.kkk = array54;
const list55 = buffer.readIntList();
packet.l = list55;
const result56 = [];
const size57 = buffer.readInt();
if (size57 > 0) {
for (let index58 = 0; index58 < size57; index58++) {
const result59 = [];
const size60 = buffer.readInt();
if (size60 > 0) {
for (let index61 = 0; index61 < size60; index61++) {
const list62 = buffer.readIntList();
result59.push(list62);
const result47 = buffer.readString();
packet.jj = result47;
const array48 = buffer.readStringArray();
packet.jjj = array48;
const result49 = buffer.readPacket(102);
packet.kk = result49;
const array50 = buffer.readPacketArray(102);
packet.kkk = array50;
const list51 = buffer.readIntList();
packet.l = list51;
const result52 = [];
const size53 = buffer.readInt();
if (size53 > 0) {
for (let index54 = 0; index54 < size53; index54++) {
const result55 = [];
const size56 = buffer.readInt();
if (size56 > 0) {
for (let index57 = 0; index57 < size56; index57++) {
const list58 = buffer.readIntList();
result55.push(list58);
}
}
result56.push(result59);
result52.push(result55);
}
}
packet.ll = result56;
const result63 = [];
const size64 = buffer.readInt();
if (size64 > 0) {
for (let index65 = 0; index65 < size64; index65++) {
const list66 = buffer.readPacketList(102);
result63.push(list66);
packet.ll = result52;
const result59 = [];
const size60 = buffer.readInt();
if (size60 > 0) {
for (let index61 = 0; index61 < size60; index61++) {
const list62 = buffer.readPacketList(102);
result59.push(list62);
}
}
packet.lll = result63;
const list67 = buffer.readStringList();
packet.llll = list67;
const result68 = [];
const size69 = buffer.readInt();
if (size69 > 0) {
for (let index70 = 0; index70 < size69; index70++) {
const map71 = buffer.readIntStringMap();
result68.push(map71);
packet.lll = result59;
const list63 = buffer.readStringList();
packet.llll = list63;
const result64 = [];
const size65 = buffer.readInt();
if (size65 > 0) {
for (let index66 = 0; index66 < size65; index66++) {
const map67 = buffer.readIntStringMap();
result64.push(map67);
}
}
packet.lllll = result68;
const map72 = buffer.readIntStringMap();
packet.m = map72;
const map73 = buffer.readIntPacketMap(102);
packet.mm = map73;
const result74 = new Map();
const size75 = buffer.readInt();
if (size75 > 0) {
for (let index76 = 0; index76 < size75; index76++) {
const result77 = buffer.readPacket(102);
const list78 = buffer.readIntList();
result74.set(result77, list78);
packet.lllll = result64;
const map68 = buffer.readIntStringMap();
packet.m = map68;
const map69 = buffer.readIntPacketMap(102);
packet.mm = map69;
const result70 = new Map();
const size71 = buffer.readInt();
if (size71 > 0) {
for (let index72 = 0; index72 < size71; index72++) {
const result73 = buffer.readPacket(102);
const list74 = buffer.readIntList();
result70.set(result73, list74);
}
}
packet.mmm = result74;
const result79 = new Map();
const size80 = buffer.readInt();
if (size80 > 0) {
for (let index81 = 0; index81 < size80; index81++) {
packet.mmm = result70;
const result75 = new Map();
const size76 = buffer.readInt();
if (size76 > 0) {
for (let index77 = 0; index77 < size76; index77++) {
const result78 = [];
const size79 = buffer.readInt();
if (size79 > 0) {
for (let index80 = 0; index80 < size79; index80++) {
const list81 = buffer.readPacketList(102);
result78.push(list81);
}
}
const result82 = [];
const size83 = buffer.readInt();
if (size83 > 0) {
for (let index84 = 0; index84 < size83; index84++) {
const list85 = buffer.readPacketList(102);
result82.push(list85);
}
}
const result86 = [];
const size87 = buffer.readInt();
if (size87 > 0) {
for (let index88 = 0; index88 < size87; index88++) {
const result89 = [];
const size90 = buffer.readInt();
if (size90 > 0) {
for (let index91 = 0; index91 < size90; index91++) {
const list92 = buffer.readIntList();
result89.push(list92);
const result85 = [];
const size86 = buffer.readInt();
if (size86 > 0) {
for (let index87 = 0; index87 < size86; index87++) {
const list88 = buffer.readIntList();
result85.push(list88);
}
}
result86.push(result89);
result82.push(result85);
}
}
result79.set(result82, result86);
result75.set(result78, result82);
}
}
packet.mmmm = result79;
const result93 = new Map();
const size94 = buffer.readInt();
if (size94 > 0) {
for (let index95 = 0; index95 < size94; index95++) {
const result96 = [];
packet.mmmm = result75;
const result89 = new Map();
const size90 = buffer.readInt();
if (size90 > 0) {
for (let index91 = 0; index91 < size90; index91++) {
const result92 = [];
const size93 = buffer.readInt();
if (size93 > 0) {
for (let index94 = 0; index94 < size93; index94++) {
const map95 = buffer.readIntStringMap();
result92.push(map95);
}
}
const result96 = new Set();
const size97 = buffer.readInt();
if (size97 > 0) {
for (let index98 = 0; index98 < size97; index98++) {
const map99 = buffer.readIntStringMap();
result96.push(map99);
result96.add(map99);
}
}
const result100 = new Set();
const size101 = buffer.readInt();
if (size101 > 0) {
for (let index102 = 0; index102 < size101; index102++) {
const map103 = buffer.readIntStringMap();
result100.add(map103);
result89.set(result92, result96);
}
}
packet.mmmmm = result89;
const set100 = buffer.readIntSet();
packet.s = set100;
const result101 = new Set();
const size102 = buffer.readInt();
if (size102 > 0) {
for (let index103 = 0; index103 < size102; index103++) {
const result104 = new Set();
const size105 = buffer.readInt();
if (size105 > 0) {
for (let index106 = 0; index106 < size105; index106++) {
const list107 = buffer.readIntList();
result104.add(list107);
}
}
result93.set(result96, result100);
result101.add(result104);
}
}
packet.mmmmm = result93;
const set104 = buffer.readIntSet();
packet.s = set104;
const result105 = new Set();
const size106 = buffer.readInt();
if (size106 > 0) {
for (let index107 = 0; index107 < size106; index107++) {
const result108 = new Set();
const size109 = buffer.readInt();
if (size109 > 0) {
for (let index110 = 0; index110 < size109; index110++) {
const list111 = buffer.readIntList();
result108.add(list111);
}
}
result105.add(result108);
packet.ss = result101;
const result108 = new Set();
const size109 = buffer.readInt();
if (size109 > 0) {
for (let index110 = 0; index110 < size109; index110++) {
const set111 = buffer.readPacketSet(102);
result108.add(set111);
}
}
packet.ss = result105;
const result112 = new Set();
const size113 = buffer.readInt();
if (size113 > 0) {
for (let index114 = 0; index114 < size113; index114++) {
const set115 = buffer.readPacketSet(102);
result112.add(set115);
packet.sss = result108;
const set112 = buffer.readStringSet();
packet.ssss = set112;
const result113 = new Set();
const size114 = buffer.readInt();
if (size114 > 0) {
for (let index115 = 0; index115 < size114; index115++) {
const map116 = buffer.readIntStringMap();
result113.add(map116);
}
}
packet.sss = result112;
const set116 = buffer.readStringSet();
packet.ssss = set116;
const result117 = new Set();
const size118 = buffer.readInt();
if (size118 > 0) {
for (let index119 = 0; index119 < size118; index119++) {
const map120 = buffer.readIntStringMap();
result117.add(map120);
}
packet.sssss = result113;
if (buffer.compatibleRead(beforeReadIndex, length)) {
const result117 = buffer.readInt();
packet.myCompatible = result117;
}
packet.sssss = result117;
if (!buffer.isReadable()) {
return packet;
if (buffer.compatibleRead(beforeReadIndex, length)) {
const result118 = buffer.readPacket(102);
packet.myObject = result118;
}
const result121 = buffer.readInt();
packet.myCompatible = result121;
if (!buffer.isReadable()) {
return packet;
if (length > 0) {
buffer.setReadOffset(beforeReadIndex + length);
}
const result122 = buffer.readPacket(102);
packet.myObject = result122;
return packet;
};
protocol/src/test/javascript/zfoojs/packet/EmptyObject.js
+32
View File
@@ -0,0 +1,32 @@
const EmptyObject = function() {
};
EmptyObject.prototype.protocolId = function() {
return 0;
};
EmptyObject.write = function(buffer, packet) {
if (packet === null) {
buffer.writeInt(0);
return;
}
buffer.writeInt(-1);
};
EmptyObject.read = function(buffer) {
const length = buffer.readInt();
if (length === 0) {
return null;
}
const beforeReadIndex = buffer.getReadOffset();
const packet = new EmptyObject();
if (length > 0) {
buffer.setReadOffset(beforeReadIndex + length);
}
return packet;
};
export default EmptyObject;
protocol/src/test/javascript/zfoojs/packet/NormalObject.js
+43 -22
View File
@@ -1,23 +1,25 @@
// @author godotg
const NormalObject = function(a, aaa, b, c, d, e, f, g, jj, kk, l, ll, lll, llll, m, mm, s, ssss) {
this.a = a; // byte
this.aaa = aaa; // byte[]
this.b = b; // short
this.c = c; // int
this.d = d; // long
this.e = e; // float
this.f = f; // double
this.g = g; // boolean
this.jj = jj; // java.lang.String
this.kk = kk; // com.zfoo.protocol.packet.ObjectA
this.l = l; // java.util.List<java.lang.Integer>
this.ll = ll; // java.util.List<java.lang.Long>
this.lll = lll; // java.util.List<com.zfoo.protocol.packet.ObjectA>
this.llll = llll; // java.util.List<java.lang.String>
this.m = m; // java.util.Map<java.lang.Integer, java.lang.String>
this.mm = mm; // java.util.Map<java.lang.Integer, com.zfoo.protocol.packet.ObjectA>
this.s = s; // java.util.Set<java.lang.Integer>
this.ssss = ssss; // java.util.Set<java.lang.String>
const NormalObject = function() {
this.a = 0; // number
this.aaa = []; // Array<number>
this.b = 0; // number
this.c = 0; // number
this.d = 0; // number
this.e = 0; // number
this.f = 0; // number
this.g = false; // boolean
this.jj = ""; // string
this.kk = null; // ObjectA | null
this.l = []; // Array<number>
this.ll = []; // Array<number>
this.lll = []; // Array<ObjectA>
this.llll = []; // Array<string>
this.m = new Map(); // Map<number, string>
this.mm = new Map(); // Map<number, ObjectA>
this.s = new Set(); // Set<number>
this.ssss = new Set(); // Set<string>
this.outCompatibleValue = 0; // number
this.outCompatibleValue2 = 0; // number
};
NormalObject.prototype.protocolId = function() {
@@ -25,9 +27,12 @@ NormalObject.prototype.protocolId = function() {
};
NormalObject.write = function(buffer, packet) {
if (buffer.writePacketFlag(packet)) {
if (packet === null) {
buffer.writeInt(0);
return;
}
const beforeWriteIndex = buffer.getWriteOffset();
buffer.writeInt(857);
buffer.writeByte(packet.a);
buffer.writeByteArray(packet.aaa);
buffer.writeShort(packet.b);
@@ -46,12 +51,17 @@ NormalObject.write = function(buffer, packet) {
buffer.writeIntPacketMap(packet.mm, 102);
buffer.writeIntSet(packet.s);
buffer.writeStringSet(packet.ssss);
buffer.writeInt(packet.outCompatibleValue);
buffer.writeInt(packet.outCompatibleValue2);
buffer.adjustPadding(857, beforeWriteIndex);
};
NormalObject.read = function(buffer) {
if (!buffer.readBoolean()) {
const length = buffer.readInt();
if (length === 0) {
return null;
}
const beforeReadIndex = buffer.getReadOffset();
const packet = new NormalObject();
const result0 = buffer.readByte();
packet.a = result0;
@@ -89,6 +99,17 @@ NormalObject.read = function(buffer) {
packet.s = set16;
const set17 = buffer.readStringSet();
packet.ssss = set17;
if (buffer.compatibleRead(beforeReadIndex, length)) {
const result18 = buffer.readInt();
packet.outCompatibleValue = result18;
}
if (buffer.compatibleRead(beforeReadIndex, length)) {
const result19 = buffer.readInt();
packet.outCompatibleValue2 = result19;
}
if (length > 0) {
buffer.setReadOffset(beforeReadIndex + length);
}
return packet;
};
protocol/src/test/javascript/zfoojs/packet/ObjectA.js
+14 -7
View File
@@ -1,8 +1,8 @@
// @author godotg
const ObjectA = function(a, m, objectB) {
this.a = a; // int
this.m = m; // java.util.Map<java.lang.Integer, java.lang.String>
this.objectB = objectB; // com.zfoo.protocol.packet.ObjectB
const ObjectA = function() {
this.a = 0; // number
this.m = new Map(); // Map<number, string>
this.objectB = null; // ObjectB | null
};
ObjectA.prototype.protocolId = function() {
@@ -10,18 +10,22 @@ ObjectA.prototype.protocolId = function() {
};
ObjectA.write = function(buffer, packet) {
if (buffer.writePacketFlag(packet)) {
if (packet === null) {
buffer.writeInt(0);
return;
}
buffer.writeInt(-1);
buffer.writeInt(packet.a);
buffer.writeIntStringMap(packet.m);
buffer.writePacket(packet.objectB, 103);
};
ObjectA.read = function(buffer) {
if (!buffer.readBoolean()) {
const length = buffer.readInt();
if (length === 0) {
return null;
}
const beforeReadIndex = buffer.getReadOffset();
const packet = new ObjectA();
const result0 = buffer.readInt();
packet.a = result0;
@@ -29,6 +33,9 @@ ObjectA.read = function(buffer) {
packet.m = map1;
const result2 = buffer.readPacket(103);
packet.objectB = result2;
if (length > 0) {
buffer.setReadOffset(beforeReadIndex + length);
}
return packet;
};
protocol/src/test/javascript/zfoojs/packet/ObjectB.js
+12 -5
View File
@@ -1,6 +1,6 @@
// @author godotg
const ObjectB = function(flag) {
this.flag = flag; // boolean
const ObjectB = function() {
this.flag = false; // boolean
};
ObjectB.prototype.protocolId = function() {
@@ -8,19 +8,26 @@ ObjectB.prototype.protocolId = function() {
};
ObjectB.write = function(buffer, packet) {
if (buffer.writePacketFlag(packet)) {
if (packet === null) {
buffer.writeInt(0);
return;
}
buffer.writeInt(-1);
buffer.writeBoolean(packet.flag);
};
ObjectB.read = function(buffer) {
if (!buffer.readBoolean()) {
const length = buffer.readInt();
if (length === 0) {
return null;
}
const beforeReadIndex = buffer.getReadOffset();
const packet = new ObjectB();
const result0 = buffer.readBoolean();
packet.flag = result0;
if (length > 0) {
buffer.setReadOffset(beforeReadIndex + length);
}
return packet;
};
protocol/src/test/javascript/zfoojs/packet/SimpleObject.js
+13 -6
View File
@@ -1,7 +1,7 @@
// @author godotg
const SimpleObject = function(c, g) {
this.c = c; // int
this.g = g; // boolean
const SimpleObject = function() {
this.c = 0; // number
this.g = false; // boolean
};
SimpleObject.prototype.protocolId = function() {
@@ -9,22 +9,29 @@ SimpleObject.prototype.protocolId = function() {
};
SimpleObject.write = function(buffer, packet) {
if (buffer.writePacketFlag(packet)) {
if (packet === null) {
buffer.writeInt(0);
return;
}
buffer.writeInt(-1);
buffer.writeInt(packet.c);
buffer.writeBoolean(packet.g);
};
SimpleObject.read = function(buffer) {
if (!buffer.readBoolean()) {
const length = buffer.readInt();
if (length === 0) {
return null;
}
const beforeReadIndex = buffer.getReadOffset();
const packet = new SimpleObject();
const result0 = buffer.readInt();
packet.c = result0;
const result1 = buffer.readBoolean();
packet.g = result1;
if (length > 0) {
buffer.setReadOffset(beforeReadIndex + length);
}
return packet;
};