add polyfillers

msg-polyfill/base-polyfiller.js

+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.BasePolyfiller = void 0;
+class BasePolyfiller {
+    async polyfillGameMsg(msgTitle, buffer) {
+        return false;
+    }
+    async polyfillResponse(msgTitle, buffer) {
+        return false;
+    }
+    splice(buf, offset, deleteCount = 1) {
+        if (offset < 0 || offset >= buf.length)
+            return Buffer.alloc(0);
+        deleteCount = Math.min(deleteCount, buf.length - offset);
+        const end = offset + deleteCount;
+        const deleted = Buffer.allocUnsafe(deleteCount);
+        buf.copy(deleted, 0, offset, end);
+        const moveLength = buf.length - end;
+        if (moveLength > 0) {
+            buf.copy(buf, offset, end, buf.length);
+        }
+        buf.fill(0, buf.length - deleteCount);
+        return deleted;
+    }
+    insert(buf, offset, insertBuf) {
+        const availableSpace = buf.length - offset;
+        const insertLength = Math.min(insertBuf.length, availableSpace);
+        buf.copy(buf, offset + insertLength, offset, buf.length - insertLength);
+        insertBuf.copy(buf, offset, 0, insertLength);
+        return buf;
+    }
+}
+exports.BasePolyfiller = BasePolyfiller;

msg-polyfill/base-polyfiller.ts

+export class BasePolyfiller {
+  async polyfillGameMsg(msgTitle: string, buffer: Buffer) {
+    return false;
+  }
+
+  async polyfillResponse(msgTitle: string, buffer: Buffer) {
+    return false;
+  }
+
+  splice(buf: Buffer, offset: number, deleteCount = 1): Buffer {
+    if (offset < 0 || offset >= buf.length) return Buffer.alloc(0);
+  
+    deleteCount = Math.min(deleteCount, buf.length - offset);
+    const end = offset + deleteCount;
+  
+    const deleted = Buffer.allocUnsafe(deleteCount);
+    buf.copy(deleted, 0, offset, end);
+  
+    const moveLength = buf.length - end;
+    if (moveLength > 0) {
+      buf.copy(buf, offset, end, buf.length);
+    }
+  
+    buf.fill(0, buf.length - deleteCount);
+  
+    return deleted;
+  }
+
+  insert(buf: Buffer, offset: number, insertBuf: Buffer) {
+    const availableSpace = buf.length - offset;
+    const insertLength = Math.min(insertBuf.length, availableSpace);
+  
+    buf.copy(buf, offset + insertLength, offset, buf.length - insertLength);
+
+    insertBuf.copy(buf, offset, 0, insertLength);
+  
+    return buf;
+  }
+}

msg-polyfill/index.js

+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.polyfillGameMsg = polyfillGameMsg;
+exports.polyfillResponse = polyfillResponse;
+const registry_1 = require("./registry");
+const getPolyfillers = (version) => {
+    const polyfillers = [];
+    for (const [pVersion, instance] of registry_1.polyfillRegistry.entries()) {
+        if (version <= pVersion) {
+            polyfillers.push({ version: pVersion, polyfiller: instance });
+        }
+    }
+    polyfillers.sort((a, b) => a.version - b.version);
+    return polyfillers.map(p => p.polyfiller);
+};
+async function polyfillGameMsg(version, msgTitle, buffer) {
+    const polyfillers = getPolyfillers(version);
+    for (const polyfiller of polyfillers) {
+        if (await polyfiller.polyfillGameMsg(msgTitle, buffer)) {
+            return true;
+        }
+    }
+    return false;
+}
+async function polyfillResponse(version, msgTitle, buffer) {
+    const polyfillers = getPolyfillers(version);
+    for (const polyfiller of polyfillers) {
+        if (await polyfiller.polyfillResponse(msgTitle, buffer)) {
+            return true;
+        }
+    }
+    return false;
+}

msg-polyfill/index.ts

+import { BasePolyfiller } from "./base-polyfiller";
+import { polyfillRegistry } from "./registry";
+
+const getPolyfillers = (version: number) => {
+  const polyfillers: {version: number, polyfiller: BasePolyfiller}[] = [];
+  for (const [pVersion, instance] of polyfillRegistry.entries()) {
+    if (version <= pVersion) { 
+      polyfillers.push({version: pVersion, polyfiller: instance});
+    }
+  }
+  polyfillers.sort((a, b) => a.version - b.version);
+  return polyfillers.map(p => p.polyfiller);
+}
+
+
+export async function polyfillGameMsg(version: number, msgTitle: string, buffer: Buffer) {
+  const polyfillers = getPolyfillers(version);
+  for (const polyfiller of polyfillers) {
+    if (await polyfiller.polyfillGameMsg(msgTitle, buffer)) {
+      return true;
+    }
+  }
+  return false;
+}
+
+export async function polyfillResponse(version: number, msgTitle: string, buffer: Buffer) {
+  const polyfillers = getPolyfillers(version);
+  for (const polyfiller of polyfillers) {
+    if (await polyfiller.polyfillResponse(msgTitle, buffer)) {
+      return true;
+    }
+  }
+  return false;
+}

msg-polyfill/polyfillers/0x1361.js

+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.Polyfiller1361 = exports.gcd = void 0;
+const base_polyfiller_1 = require("../base-polyfiller");
+const gcd = (nums) => {
+    const gcdTwo = (a, b) => {
+        if (b === 0)
+            return a;
+        return gcdTwo(b, a % b);
+    };
+    return nums.reduce((acc, num) => gcdTwo(acc, num));
+};
+exports.gcd = gcd;
+class Polyfiller1361 extends base_polyfiller_1.BasePolyfiller {
+    async polyfillGameMsg(msgTitle, buffer) {
+        if (msgTitle === 'CONFIRM_CARDS') {
+            // buf[0]: MSG_CONFIRM_CARDS
+            // buf[1]: playerid
+            // buf[2]: ADDED skip_panel
+            this.splice(buffer, 2, 1);
+        }
+        else if (msgTitle === 'SELECT_CHAIN') {
+            // buf[0]: MSG_SELECT_CHAIN
+            // buf[1]: playerid
+            // buf[2]: size
+            // buf[3]: spe_count
+            // buf[REMOVED]: forced
+            // buf[4-7]: hint_timing player
+            // buf[8-11]: hint_timing 1-player
+            // then it's 14 bytes for each item
+            // item[0]: not related
+            // item[1]: ADDED forced
+            // item[2-13] not related
+            const size = buffer[2];
+            const itemStartOffset = 12; // after the header (up to hint timings)
+            // 判断是否存在任何 item 的 forced = 1（在原始 buffer 中判断）
+            let anyForced = false;
+            for (let i = 0; i < size; i++) {
+                const itemOffset = itemStartOffset + i * 14;
+                const forced = buffer[itemOffset + 1];
+                if (forced === 1) {
+                    anyForced = true;
+                    break;
+                }
+            }
+            // 从后往前 splice 每个 item 的 forced 字段
+            for (let i = size - 1; i >= 0; i--) {
+                const itemOffset = itemStartOffset + i * 14;
+                this.splice(buffer, itemOffset + 1, 1); // 删除每个 item 的 forced（第 1 字节）
+            }
+            // 最后再插入旧版所需的 forced 标志
+            this.insert(buffer, 4, Buffer.from([anyForced ? 1 : 0]));
+        }
+        else if (msgTitle === 'SELECT_SUM') {
+            // buf[0]: MSG_SELECT_SUM
+            // buf[1]: 0 => equal, 1 => greater
+            // buf[2]: playerid
+            // buf[3-6]: target_value
+            // buf[7]: min
+            // buf[8]: max
+            // buf[9]: forced_count
+            // then each item 11 bytes
+            // item[0-3] code
+            // item[4] controler
+            // item[5] location
+            // item[6] sequence
+            // item[7-10] value
+            // item[10 + forced_count * 11] card_count
+            // same as above items
+            const targetValue = buffer.readUInt32LE(3);
+            if (!(targetValue | 0x80000000)) {
+                return false;
+            }
+            const forcedCount = buffer[9];
+            const cardCount = buffer[10 + forcedCount * 11];
+            const valueOffsets = [];
+            for (let i = 0; i < forcedCount; i++) {
+                const itemOffset = 10 + i * 11;
+                valueOffsets.push(itemOffset + 7);
+            }
+            for (let i = 0; i < cardCount; i++) {
+                const itemOffset = 11 + forcedCount * 11 + i * 11;
+                valueOffsets.push(itemOffset + 7);
+            }
+            const values = valueOffsets.map(offset => buffer.readUInt32LE(offset));
+            const gcdValue = (0, exports.gcd)([...values, targetValue & 0x7FFFFFFF]);
+            buffer.writeUInt32LE(Math.floor(targetValue / gcdValue) & 0xffff, 3);
+            for (const offset of valueOffsets) {
+                const value = buffer.readUInt32LE(offset);
+                buffer.writeUInt32LE(Math.floor(value / gcdValue), offset);
+            }
+        }
+        return false;
+    }
+}
+exports.Polyfiller1361 = Polyfiller1361;

msg-polyfill/polyfillers/0x1361.ts

+import { BasePolyfiller } from "../base-polyfiller";
+
+export const gcd = (nums: number[]) => {
+  const gcdTwo = (a: number, b: number) => {
+    if (b === 0) return a;
+    return gcdTwo(b, a % b);
+  };
+
+  return nums.reduce((acc, num) => gcdTwo(acc, num));
+}
+
+export class Polyfiller1361 extends BasePolyfiller {
+  async polyfillGameMsg(msgTitle: string, buffer: Buffer) {
+    if (msgTitle === 'CONFIRM_CARDS') {
+      // buf[0]: MSG_CONFIRM_CARDS
+      // buf[1]: playerid
+      // buf[2]: ADDED skip_panel
+      this.splice(buffer, 2, 1);
+    } else if (msgTitle === 'SELECT_CHAIN') {
+      // buf[0]: MSG_SELECT_CHAIN
+      // buf[1]: playerid
+      // buf[2]: size
+      // buf[3]: spe_count
+      // buf[REMOVED]: forced
+      // buf[4-7]: hint_timing player
+      // buf[8-11]: hint_timing 1-player
+      // then it's 14 bytes for each item
+      // item[0]: not related
+      // item[1]: ADDED forced
+      // item[2-13] not related
+
+      const size = buffer[2];
+      const itemStartOffset = 12; // after the header (up to hint timings)
+    
+      // 判断是否存在任何 item 的 forced = 1（在原始 buffer 中判断）
+      let anyForced = false;
+      for (let i = 0; i < size; i++) {
+        const itemOffset = itemStartOffset + i * 14;
+        const forced = buffer[itemOffset + 1];
+        if (forced === 1) {
+          anyForced = true;
+          break;
+        }
+      }
+    
+      // 从后往前 splice 每个 item 的 forced 字段
+      for (let i = size - 1; i >= 0; i--) {
+        const itemOffset = itemStartOffset + i * 14;
+        this.splice(buffer, itemOffset + 1, 1); // 删除每个 item 的 forced（第 1 字节）
+      }
+    
+      // 最后再插入旧版所需的 forced 标志
+      this.insert(buffer, 4, Buffer.from([anyForced ? 1 : 0]));
+    } else if (msgTitle === 'SELECT_SUM') {
+      // buf[0]: MSG_SELECT_SUM
+      // buf[1]: 0 => equal, 1 => greater
+      // buf[2]: playerid
+      // buf[3-6]: target_value
+      // buf[7]: min
+      // buf[8]: max
+      // buf[9]: forced_count
+      // then each item 11 bytes
+
+      // item[0-3] code
+      // item[4] controler
+      // item[5] location
+      // item[6] sequence
+      // item[7-10] value
+      
+      // item[10 + forced_count * 11] card_count
+
+      // same as above items
+
+      const targetValue = buffer.readUInt32LE(3);
+      if (!(targetValue | 0x80000000)) {
+        return false;
+      }
+      const forcedCount = buffer[9];
+      const cardCount = buffer[10 + forcedCount * 11];
+      const valueOffsets: number[] = [];
+      for(let i = 0; i < forcedCount; i++) {
+        const itemOffset = 10 + i * 11;
+        valueOffsets.push(itemOffset + 7);
+      }
+      for(let i = 0; i < cardCount; i++) {
+        const itemOffset = 11 + forcedCount * 11 + i * 11;
+        valueOffsets.push(itemOffset + 7);
+      }
+      const values = valueOffsets.map(offset => buffer.readUInt32LE(offset));
+      const gcdValue = gcd([...values, targetValue & 0x7FFFFFFF]);
+      buffer.writeUInt32LE(Math.floor(targetValue / gcdValue) & 0xffff, 3);
+      for(const offset of valueOffsets) {
+        const value = buffer.readUInt32LE(offset);
+        buffer.writeUInt32LE(Math.floor(value / gcdValue), offset);
+      }
+    }
+    return false;
+  }
+}

msg-polyfill/registry.js

+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.polyfillRegistry = void 0;
+const _0x1361_1 = require("./polyfillers/0x1361");
+exports.polyfillRegistry = new Map();
+const addPolyfiller = (version, polyfiller) => {
+    exports.polyfillRegistry.set(version, new polyfiller());
+};
+addPolyfiller(0x1361, _0x1361_1.Polyfiller1361);

msg-polyfill/registry.ts

+import { BasePolyfiller } from "./base-polyfiller";
+import { Polyfiller1361 } from "./polyfillers/0x1361";
+
+export const polyfillRegistry = new Map<number, BasePolyfiller>();
+
+const addPolyfiller = (version: number, polyfiller: typeof BasePolyfiller) => {
+  polyfillRegistry.set(version, new polyfiller());
+}
+
+addPolyfiller(0x1361, Polyfiller1361);

tsconfig.json

@@ -12,6 +12,8 @@
 	"include": [
 		"*.ts",
 		"data-manager/*.ts",
-		"data-manager/entities/*.ts"
+		"data-manager/entities/*.ts",
+		"msg-polyfill/*.ts",
+		"msg-polyfill/polyfillers/*.ts"
 	]
 }

ygopro-server.coffee

@@ -99,6 +99,8 @@ aragami = global.aragami = new Aragami() # we use memory mode only
 
 aragami_classes = global.aragami_classes = require('./aragami-classes.js')
 
+msg_polyfill = global.msg_polyfill = require('./msg-polyfill/index.js')
+
 #heapdump = require 'heapdump'
 
 checkFileExists = (path) =>
@@ -2592,6 +2594,8 @@ ygopro.stoc_follow 'GAME_MSG', true, (buffer, info, client, server, datas)->
   return unless room and !client.reconnecting
   msg = buffer.readInt8(0)
   msg_name = ygopro.constants.MSG[msg]
+  if await msg_polyfill.polyfillGameMsg(client.actual_version, msg_name, buffer)
+    return true
   #console.log client.pos, "MSG", msg_name
   if msg_name == 'RETRY' and room.recovering
     room.finish_recover(true)
@@ -3468,11 +3472,13 @@ ygopro.ctos_follow 'UPDATE_DECK', true, (buffer, info, client, server, datas)->
             return deck_bad("#{client.name}${deck_not_found}")
   await return false
 
-ygopro.ctos_follow 'RESPONSE', false, (buffer, info, client, server, datas)->
+ygopro.ctos_follow 'RESPONSE', true, (buffer, info, client, server, datas)->
   room=ROOM_all[client.rid]
-  return unless room and (room.random_type or room.arena)
-  room.refreshLastActiveTime()
-  await return
+  if room and (room.random_type or room.arena)
+    room.refreshLastActiveTime()
+  if await msg_polyfill.polyfillResponse(client.actual_version, client.last_game_msg_title, buffer)
+    return true
+  return false
 
 ygopro.stoc_follow 'TIME_LIMIT', true, (buffer, info, client, server, datas)->
   room=ROOM_all[client.rid]

ygopro-server.js

 // Generated by CoffeeScript 2.7.0
 (function() {
   // 标准库
-  var Aragami, CLIENT_get_absolute_pos, CLIENT_get_authorize_key, CLIENT_get_kick_reconnect_target, CLIENT_get_partner, CLIENT_heartbeat_register, CLIENT_heartbeat_unregister, CLIENT_import_data, CLIENT_is_able_to_kick_reconnect, CLIENT_is_able_to_reconnect, CLIENT_is_banned_by_mc, CLIENT_is_player, CLIENT_kick, CLIENT_kick_reconnect, CLIENT_pre_reconnect, CLIENT_reconnect, CLIENT_reconnect_register, CLIENT_reconnect_unregister, CLIENT_send_pre_reconnect_info, CLIENT_send_reconnect_info, CLIENT_send_replays, CLIENT_send_replays_and_kick, CLIENT_set_ip, Q, ROOM_all, ROOM_bad_ip, ROOM_ban_player, ROOM_clear_disconnect, ROOM_connected_ip, ROOM_find_by_name, ROOM_find_by_pid, ROOM_find_by_port, ROOM_find_by_title, ROOM_find_or_create_ai, ROOM_find_or_create_by_name, ROOM_find_or_create_random, ROOM_kick, ROOM_player_flee, ROOM_player_get_score, ROOM_player_lose, ROOM_player_win, ROOM_players_oppentlist, ROOM_unwelcome, ROOM_validate, ReplayParser, ResolveData, Room, SERVER_clear_disconnect, SERVER_kick, SOCKET_flush_data, YGOProDeck, _, _async, addCallback, aragami, aragami_classes, athleticChecker, auth, axios, badwordR, badwords, ban_user, bunyan, challonge, checkFileExists, createDirectoryIfNotExists, crypto, dataManager, deck_name_match, dialogues, disconnect_list, exec, execFile, extra_mode_list, fs, geoip, getDuelLogQueryFromQs, getRealIp, get_memory_usage, http, httpRequestListener, importOldConfig, import_datas, init, ip6addr, isTrustedProxy, lflists, loadJSON, loadJSONAsync, loadLFList, loadRemoteData, load_dialogues, load_tips, log, long_resolve_cards, memory_usage, merge, moment, moment_long_ago_string, moment_now, moment_now_string, neosRequestListener, net, netRequestHandler, os, osu, path, qs, real_windbot_server_ip, release_disconnect, report_to_big_brother, request, roomlist, rooms_count, setting_change, setting_get, setting_save, settings, spawn, spawnSync, spawn_windbot, tips, toIpv4, toIpv6, url, users_cache, util, wait_room_start, wait_room_start_arena, windbot_looplimit, windbot_process, windbots, ygopro, zlib;
+  var Aragami, CLIENT_get_absolute_pos, CLIENT_get_authorize_key, CLIENT_get_kick_reconnect_target, CLIENT_get_partner, CLIENT_heartbeat_register, CLIENT_heartbeat_unregister, CLIENT_import_data, CLIENT_is_able_to_kick_reconnect, CLIENT_is_able_to_reconnect, CLIENT_is_banned_by_mc, CLIENT_is_player, CLIENT_kick, CLIENT_kick_reconnect, CLIENT_pre_reconnect, CLIENT_reconnect, CLIENT_reconnect_register, CLIENT_reconnect_unregister, CLIENT_send_pre_reconnect_info, CLIENT_send_reconnect_info, CLIENT_send_replays, CLIENT_send_replays_and_kick, CLIENT_set_ip, Q, ROOM_all, ROOM_bad_ip, ROOM_ban_player, ROOM_clear_disconnect, ROOM_connected_ip, ROOM_find_by_name, ROOM_find_by_pid, ROOM_find_by_port, ROOM_find_by_title, ROOM_find_or_create_ai, ROOM_find_or_create_by_name, ROOM_find_or_create_random, ROOM_kick, ROOM_player_flee, ROOM_player_get_score, ROOM_player_lose, ROOM_player_win, ROOM_players_oppentlist, ROOM_unwelcome, ROOM_validate, ReplayParser, ResolveData, Room, SERVER_clear_disconnect, SERVER_kick, SOCKET_flush_data, YGOProDeck, _, _async, addCallback, aragami, aragami_classes, athleticChecker, auth, axios, badwordR, badwords, ban_user, bunyan, challonge, checkFileExists, createDirectoryIfNotExists, crypto, dataManager, deck_name_match, dialogues, disconnect_list, exec, execFile, extra_mode_list, fs, geoip, getDuelLogQueryFromQs, getRealIp, get_memory_usage, http, httpRequestListener, importOldConfig, import_datas, init, ip6addr, isTrustedProxy, lflists, loadJSON, loadJSONAsync, loadLFList, loadRemoteData, load_dialogues, load_tips, log, long_resolve_cards, memory_usage, merge, moment, moment_long_ago_string, moment_now, moment_now_string, msg_polyfill, neosRequestListener, net, netRequestHandler, os, osu, path, qs, real_windbot_server_ip, release_disconnect, report_to_big_brother, request, roomlist, rooms_count, setting_change, setting_get, setting_save, settings, spawn, spawnSync, spawn_windbot, tips, toIpv4, toIpv6, url, users_cache, util, wait_room_start, wait_room_start_arena, windbot_looplimit, windbot_process, windbots, ygopro, zlib;
 
   net = require('net');
 
@@ -90,6 +90,8 @@
 
   aragami_classes = global.aragami_classes = require('./aragami-classes.js');
 
+  msg_polyfill = global.msg_polyfill = require('./msg-polyfill/index.js');
+
   //heapdump = require 'heapdump'
   checkFileExists = async(path) => {
     var e;
@@ -3411,6 +3413,9 @@
     }
     msg = buffer.readInt8(0);
     msg_name = ygopro.constants.MSG[msg];
+    if ((await msg_polyfill.polyfillGameMsg(client.actual_version, msg_name, buffer))) {
+      return true;
+    }
     //console.log client.pos, "MSG", msg_name
     if (msg_name === 'RETRY' && room.recovering) {
       room.finish_recover(true);
@@ -4661,13 +4666,16 @@
     return false;
   });
 
-  ygopro.ctos_follow('RESPONSE', false, async function(buffer, info, client, server, datas) {
+  ygopro.ctos_follow('RESPONSE', true, async function(buffer, info, client, server, datas) {
     var room;
     room = ROOM_all[client.rid];
-    if (!(room && (room.random_type || room.arena))) {
-      return;
+    if (room && (room.random_type || room.arena)) {
+      room.refreshLastActiveTime();
     }
-    room.refreshLastActiveTime();
+    if ((await msg_polyfill.polyfillResponse(client.version, client.last_game_msg_title, buffer))) {
+      return true;
+    }
+    return false;
   });
 
   ygopro.stoc_follow('TIME_LIMIT', true, async function(buffer, info, client, server, datas) {