Merge branch 'optimize/reflect' into 'main'

Optimize/reflect

See merge request mycard/Neos!74

src/api/ocgcore/ocgAdapter/stoc/stocGameMsg/mod.ts

@@ -13,12 +13,12 @@ import MsgNewPhaseAdapter from "./newPhase";
 import MsgHintAdapter from "./hint";
 import MsgSelectIdleCmdAdapter from "./selectIdleCmd";
 import MsgSelectPlaceAdapter from "./selectPlace";
-import MsgMoveAdapter from "./move";
 import MsgSelectCardAdapter from "./selectCard";
 import MsgSelectChainAdapter from "./selectChain";
 import MsgSelectEffectYnAdapter from "./selectEffectYn";
 import MsgSelectPositionAdapter from "./selectPosition";
 import MsgSelectOptionAdapter from "./selectOption";
+import PENETRATE from "./penetrate";
 
 /*
  * STOC GameMsg
@@ -41,8 +41,9 @@ export default class GameMsgAdapter implements StocAdapter {
 
     const func = dataView.getUint8(0);
     const gameData = exData.slice(1);
-    const gameMsg = new ygopro.StocGameMessage({});
+    let gameMsg: any = new ygopro.StocGameMessage({}).toObject();
 
+    if (!PENETRATE.penetrate(func, gameMsg, gameData)) {
       switch (func) {
         case GAME_MSG.MSG_START: {
           gameMsg.start = MsgStartAdapter(gameData);
@@ -79,11 +80,6 @@ export default class GameMsgAdapter implements StocAdapter {
 
           break;
         }
-      case GAME_MSG.MSG_MOVE: {
-        gameMsg.move = MsgMoveAdapter(gameData);
-
-        break;
-      }
         case GAME_MSG.MSG_SELECT_CARD: {
           gameMsg.select_card = MsgSelectCardAdapter(gameData);
 
@@ -115,9 +111,10 @@ export default class GameMsgAdapter implements StocAdapter {
           break;
         }
       }
+    }
 
     return new ygopro.YgoStocMsg({
-      stoc_game_msg: gameMsg,
+      stoc_game_msg: new ygopro.StocGameMessage(gameMsg),
     });
   }
 }

src/api/ocgcore/ocgAdapter/stoc/stocGameMsg/penetrate.json

+{
+  "50": {
+    "protoType": "move",
+    "fields": [
+      {
+        "fieldName": "code",
+        "fieldType": "uint32"
+      },
+      {
+        "fieldName": "from",
+        "fieldType": "CardLocation"
+      },
+      {
+        "fieldName": "to",
+        "fieldType": "CardLocation"
+      },
+      {
+        "fieldName": "reason",
+        "fieldType": "uint8"
+      }
+    ]
+  }
+}

src/api/ocgcore/ocgAdapter/stoc/stocGameMsg/penetrate.ts

+//! 透传协议
+
+import PenetrateData from "./penetrate.json";
+import { BufferReader } from "../../bufferIO";
+import { ygopro } from "../../../idl/ocgcore";
+
+type Constructor<T = any> = new (...args: any[]) => T;
+
+const ReadFieldHandlerMap: Map<string, readFieldHandler> = new Map([
+  ["uint8", ((reader) => reader.readUint8()) as readFieldHandler],
+  ["uint16", (reader) => reader.readUint16()],
+  ["uint32", (reader) => reader.readUint32()],
+  ["CardLocation", (reader) => reader.readCardLocation()],
+]);
+const MsgConstructorMap: Map<string, Constructor> = new Map([
+  ["move", ygopro.StocGameMessage.MsgMove],
+]);
+
+export interface penetrateType {
+  protoType: string;
+  fields: {
+    fieldName: string;
+    fieldType: string;
+  }[];
+}
+
+interface readFieldHandler {
+  (reader: BufferReader): any;
+}
+
+class PenetrateManager {
+  config: Map<string, penetrateType>;
+  readFieldHandlerMap: Map<string, readFieldHandler> = ReadFieldHandlerMap;
+  msgConstructorMap: Map<string, Constructor> = MsgConstructorMap;
+
+  constructor(config: any) {
+    this.config = _objToMap(config);
+  }
+
+  private readField(reader: BufferReader, fieldType: string): any {
+    const handler = this.readFieldHandlerMap.get(fieldType);
+
+    if (handler) {
+      return handler(reader);
+    }
+    return undefined;
+  }
+
+  private constructMsg(protoType: string, object: any): any {
+    const constructor = this.msgConstructorMap.get(protoType);
+
+    if (constructor) {
+      return new constructor(object);
+    }
+    return undefined;
+  }
+
+  penetrate(msgKey: number, gameMsg: any, gameData: Uint8Array): boolean {
+    const config = this.config.get(msgKey.toString());
+    const reader = new BufferReader(gameData, true);
+
+    if (config) {
+      const protoType = config.protoType;
+      const fields = config.fields;
+
+      let object: any = {};
+      for (let field of fields) {
+        object[field.fieldName] = this.readField(reader, field.fieldType);
+      }
+
+      gameMsg[protoType] = this.constructMsg(protoType, object);
+    }
+
+    return config ? true : false;
+  }
+}
+
+function _objToMap(obj: any): Map<string, penetrateType> {
+  let map = new Map();
+
+  for (let key of Object.keys(obj)) {
+    map.set(key, obj[key]);
+  }
+
+  return map;
+}
+
+const PENETRATE = new PenetrateManager(PenetrateData);
+export default PENETRATE;