From 735a0a6bb39a3da8fca76e76a0e7382e03bf13d9 Mon Sep 17 00:00:00 2001 From: JianMiau Date: Thu, 29 Aug 2024 18:00:41 +0800 Subject: [PATCH] =?UTF-8?q?[mod]=20=E5=85=88=E5=84=AA=E5=8C=96=E7=82=BACla?= =?UTF-8?q?ss?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .eslintrc.json | 367 ++++++++++++++++++ src/api/slot/spin.ts | 106 +++++ src/api/slot1/spin.ts | 101 +---- .../CatanEngine/NetManagerV2/NetConnector.ts | 53 ++- 4 files changed, 515 insertions(+), 112 deletions(-) create mode 100644 .eslintrc.json create mode 100644 src/api/slot/spin.ts diff --git a/.eslintrc.json b/.eslintrc.json new file mode 100644 index 0000000..2039228 --- /dev/null +++ b/.eslintrc.json @@ -0,0 +1,367 @@ +{ + "env": { + "browser": true, + "es2021": true, + "jest": true + }, + "extends": [ + "eslint:recommended", + "plugin:react/recommended", + "plugin:@typescript-eslint/recommended" + ], + "overrides": [], + "parser": "@typescript-eslint/parser", + "parserOptions": { + "ecmaFeatures": { + "jsx": true + }, + "ecmaVersion": "latest", + "sourceType": "module" + }, + "plugins": [ + "react", + "@typescript-eslint", + "react-hooks" + ], + "rules": { + "no-alert": 0, //禁止使用alert confirm prompt + "no-bitwise": 0, //禁止使用按位运算符 + "no-console": "off", //禁止使用console + "no-continue": 0, //禁止使用continue + "no-debugger": 2, //禁止使用debugger + "no-delete-var": 2, //不能对var声明的变量使用delete操作符 + "no-div-regex": 1, //不能使用看起来像除法的正则表达式/=foo/ + "no-dupe-args": 2, //函数参数不能重复 + "no-duplicate-case": 2, //switch中的case标签不能重复 + "no-else-return": "off", //如果if语句里面有return,后面不能跟else语句 + "no-empty-label": "off", //禁止使用空label + "no-eq-null": "off", //禁止对null使用==或!=运算符 + "no-extend-native": "off", //禁止扩展native对象 + "no-extra-parens": "off", //禁止非必要的括号 + "no-extra-semi": 2, //禁止多余的冒号 + "no-floating-decimal": 2, //禁止省略浮点数中的0 .5 3. + "no-implicit-coercion": "off", //禁止隐式转换 + "no-inline-comments": 0, //禁止行内备注 + "no-invalid-this": 2, //禁止无效的this，只能用在构造器，类，对象字面量 + "no-iterator": 2, //禁止使用__iterator__ 属性 + "no-lonely-if": "off", //禁止else语句内只有if语句 + "no-mixed-requires": [ + 0, + false + ], //声明时不能混用声明类型 + "no-mixed-spaces-and-tabs": "off", //禁止混用tab和空格 + "no-multiple-empty-lines": [ + 1, + { + "max": 2 + } + ], //空行最多不能超过2行 + "no-nested-ternary": 0, //禁止使用嵌套的三目运算 + "no-new": "off", //禁止在使用new构造一个实例后不赋值 + "no-new-require": 2, //禁止使用new require + "no-param-reassign": "off", //禁止给参数重新赋值 + "no-path-concat": 0, //node中不能使用__dirname或__filename做路径拼接 + "no-plusplus": 0, //禁止使用++，-- + "no-process-env": 0, //禁止使用process.env + "no-process-exit": 0, //禁止使用process.exit() + "no-redeclare": "off", //禁止重复声明变量 + "no-restricted-modules": 0, //如果禁用了指定模块，使用就会报错 + "no-return-assign": "off", //return 语句中不能有赋值表达式 + "no-self-compare": 2, //不能比较自身 + "no-sequences": 0, //禁止使用逗号运算符 + "no-shadow": "off", //外部作用域中的变量不能与它所包含的作用域中的变量或参数同名 + "no-sync": 0, //nodejs 禁止同步方法 + "no-ternary": 0, //禁止使用三目运算符 + "no-this-before-super": 0, //在调用super()之前不能使用this或super + "no-throw-literal": 2, //禁止抛出字面量错误 throw "error"; + "no-undef": "off", //不能有未定义的变量 + "no-undef-init": "off", //变量初始化时不能直接给它赋值为undefined + "no-undefined": "off", //不能使用undefined + "no-unexpected-multiline": 2, //避免多行表达式 + "no-underscore-dangle": "off", //标识符不能以_开头或结尾 + "no-unneeded-ternary": 2, //禁止不必要的嵌套 var isYes = answer === 1 ? true : false; + "no-unused-expressions": "off", //禁止无用的表达式 + "no-unused-vars": "off", //不能有声明后未被使用的变量或参数 + "no-use-before-define": "off", //未定义前不能使用 + "no-useless-call": "off", //禁止不必要的call和apply + "no-void": "off", //禁用void操作符 + "no-var": 0, //禁用var，用let和const代替 + "no-warning-comments": "off", //不能有警告备注 + "no-array-constructor": "error", // 禁止使用数组构造器 + "no-caller": "error", // 禁止使用arguments.caller或arguments.callee + "no-catch-shadow": "error", // 禁止catch子句参数与外部作用域变量同名 + "no-class-assign": "error", // 禁止给类赋值 + "no-cond-assign": [ + "error", + "except-parens" + ], // 禁止在条件表达式中使用赋值语句 + "no-constant-condition": "error", // 禁止在条件中使用常量表达式 if(true) if(1) + "no-control-regex": "error", // 禁止在正则表达式中使用控制字符 + "no-dupe-keys": "error", // 在创建对象字面量时不允许键重复 {a: 1, a: 1} + "no-empty": "error", // 块语句中的内容不能为空 + "no-empty-character-class": "error", // 正则表达式中的[]内容不能为空 + "no-eval": "error", // 禁止使用eval + "no-ex-assign": "error", // 禁止给catch语句中的异常参数赋值 + "no-extra-bind": "error", // 禁止不必要的函数绑定 + "no-extra-boolean-cast": "off", // 禁止不必要的bool转换 + "no-fallthrough": "error", // 禁止switch穿透 + "no-func-assign": "error", // 禁止重复的函数声明 + "no-implied-eval": "error", // 禁止使用隐式eval + "no-inner-declarations": "off", // 禁止在块语句中使用声明函数 + "no-invalid-regexp": "error", // 禁止无效的正则表达式 + "no-irregular-whitespace": "error", // 不能有不规则的空格 + "no-label-var": "error", // label名不能与var声明的变量名相同 + "no-labels": "error", // 禁止标签声明 + "no-lone-blocks": "error", // 禁止不必要的嵌套块 + "no-loop-func": "error", // 禁止在循环中使用函数（如果没有引用外部变量不形成闭包就可以） + "no-multi-spaces": "error", // 不能用多余的空格 + "no-multi-str": "error", // 字符串不能用\换行 + "no-native-reassign": "error", // 不能重写native对象 + "no-negated-in-lhs": "error", // in 操作符的左边不能有! + "no-new-func": "error", // 禁止使用new Function + "no-new-object": "error", // 禁止使用new Object() + "no-new-wrappers": "error", // 禁止使用new创建包装实例，new String new Boolean new Number + "no-obj-calls": "error", // 不能调用内置的全局对象，比如Math() JSON() + "no-octal": "error", // 禁止使用八进制数字(因为八进制数字以0开头) + "no-octal-escape": "error", // 禁止使用八进制转义序列 + "no-proto": "error", // 禁止使用__proto__属性(按照标准，__proto__为私有属性，不应公开) + "no-prototype-builtins": "off", + "no-regex-spaces": "error", // 禁止在正则表达式字面量中使用多个空格 /foo bar/ + "no-script-url": "off", // 禁止使用javascript:void(0) + "no-shadow-restricted-names": "error", // 严格模式中规定的限制标识符不能作为声明时的变量名使用 + "no-spaced-func": "error", // 函数调用时 函数名与()之间不能有空格 + "no-sparse-arrays": "error", // 禁止稀疏数组， [1,,2] + "no-trailing-spaces": [ + "error", + { + "skipBlankLines": true + } + ], // 一行结束后面不要有空格( 空白行忽略 ) + "no-unreachable": "error", // 不能有无法执行的代码 + "no-const-assign": "error", // 禁止修改const声明的变量 + "no-with": "error", // 禁用with + "comma-dangle": "off", // 数组或对象最后不允许出现多余的逗号 + "comma-spacing": "error", // 逗号前面不允许有空格，后面还有东西的时候必须有一个空格 + "curly": [ + "error", + "multi-line" + ], // 块级代码需要换行的时候必须使用 {}将代码裹起来 + "eqeqeq": "off", // 必须使用全等 + "indent": [ + "off", + "tab", + { + "SwitchCase": 1 + } + ], // 缩进用tab + "key-spacing": [ + "error", + { + "beforeColon": false, + "afterColon": true + } + ], // 对象字面量中冒号的后面必须有空格，前面不允许有空格 + "keyword-spacing": "off", // 关键字前后必须存在空格 + "new-parens": "error", // new时必须加小括号 const person = new Person(); + "quotes": [ + "error", + "double", + { + "allowTemplateLiterals": true + } + ], // 引号类型 '' + "semi": [ + "error", + "always" + ], // 语句必须分号结尾 + "semi-spacing": [ + 0, + { + "before": false, + "after": true + } + ], // 分号前面不允许有空格，后面有其他东西的时候必须空一空格 + "space-before-blocks": [ + "error", + "always" + ], // 不以新行开始的块 { 前面要有空格 + // "space-before-function-paren": ["error", "never"], // 函数定义时括号前面不允许有空格 + "space-infix-ops": "error", // 中缀操作符周围必须有空格 a + b + "space-unary-ops": [ + "error", + { + "words": true, + "nonwords": false + } + ], // 一元运算符的前/后如果是单词则空一空格，如果是运算符则不需要空空格 new Foo √ 1++ √ + // "spaced-comment": ["error", "always", { "markers": ["*!"] }], // 注释风格， 双斜杠后面空一格空格再写注释 + "strict": [ + "error", + "global" + ], // 使用全局严格模式 + "use-isnan": "error", // 禁止比较时使用NaN，只能用isNaN() + "arrow-parens": 0, //箭头函数用小括号括起来 + "arrow-spacing": 0, //=>的前/后括号 + "accessor-pairs": 0, //在对象中使用getter/setter + "block-scoped-var": 0, //块语句中使用var + "brace-style": "off", //大括号风格 + "callback-return": "off", //避免多次调用回调什么的 + "comma-style": [ + "error", + "last" + ], //逗号风格，换行时在行首还是行尾 + "complexity": [ + 0, + 11 + ], //循环复杂度 + "computed-property-spacing": [ + 0, + "never" + ], //是否允许计算后的键名什么的 + "consistent-return": 0, //return 后面是否允许省略 + "consistent-this": "off", //this别名 + "constructor-super": 0, //非派生类不能调用super，派生类必须调用super + "default-case": "off", //switch语句最后必须有default + "dot-location": 0, //对象访问符的位置，换行的时候在行首还是行尾 + "dot-notation": [ + 0, + { + "allowKeywords": true + } + ], //避免不必要的方括号 + "eol-last": 0, //文件以单一的换行符结束 + "func-names": 0, //函数表达式必须有名字 + "func-style": [ + 0, + "declaration" + ], //函数风格，规定只能使用函数声明/函数表达式 + "generator-star-spacing": 0, //生成器函数*的前后空格 + "guard-for-in": 0, //for in循环要用if语句过滤 + "handle-callback-err": 0, //nodejs 处理错误 + "id-length": 0, //变量名长度 + "init-declarations": 0, //声明时必须赋初值 + "lines-around-comment": 0, //行前/行后备注 + "max-depth": [ + 0, + 4 + ], //嵌套块深度 + "max-len": [ + 0, + 80, + 4 + ], //字符串最大长度 + "max-nested-callbacks": [ + 0, + 2 + ], //回调嵌套深度 + "max-params": [ + 0, + 3 + ], //函数最多只能有3个参数 + "max-statements": [ + 0, + 10 + ], //函数内最多有几个声明 + "new-cap": "off", //函数名首行大写必须使用new方式调用，首行小写必须用不带new方式调用 + "newline-after-var": "off", //变量声明后是否需要空一行 + "object-shorthand": 0, //强制对象字面量缩写语法 + "one-var": "off", //连续声明 + "operator-assignment": [ + 0, + "always" + ], //赋值运算符 += -=什么的 + "operator-linebreak": "off", //换行时运算符在行尾还是行首 + "padded-blocks": 0, //块语句内行首行尾是否要空行 + "prefer-spread": 0, //首选展开运算 + "prefer-reflect": 0, //首选Reflect的方法 + "quote-props": "off", //对象字面量中的属性名是否强制双引号 + "radix": "off", //parseInt必须指定第二个参数 + "id-match": 0, //命名检测 + "sort-vars": 0, //变量声明时排序 + "space-after-keywords": [ + 0, + "always" + ], //关键字后面是否要空一格 + "space-before-function-paren": [ + 0, + "always" + ], //函数定义时括号前面要不要有空格 + "space-in-parens": [ + 0, + "never" + ], //小括号里面要不要有空格 + "space-return-throw-case": "off", //return throw case后面要不要加空格 + "spaced-comment": 0, //注释风格不要有空格什么的 + "valid-jsdoc": 0, //jsdoc规则 + "valid-typeof": "error", //必须使用合法的typeof的值 + "vars-on-top": "error", //var必须放在作用域顶部 + "wrap-iife": [ + "error", + "inside" + ], //立即执行函数表达式的小括号风格 + "wrap-regex": 0, //正则表达式字面量用小括号包起来 + "yoda": [ + "error", + "never" + ], //禁止尤达条件 + "linebreak-style": [ + 0, + "windows" + ], //换行风格 + "array-bracket-spacing": [ + 2, + "never" + ], //是否允许非空数组里面有多余的空格 + "react/react-in-jsx-scope": "off", + "camelcase": "off", + "block-spacing": "error", + "no-duplicate-imports": "error", + "require-yield": "off", + "prefer-const": "off", + "object-curly-spacing": [ + "error", + "always" + ], + "react/jsx-curly-spacing": [ + "error", + "never" + ], + "@typescript-eslint/no-namespace": "off", + "@typescript-eslint/no-inferrable-types": "off", + "@typescript-eslint/no-explicit-any": "off", + "@typescript-eslint/no-empty-function": "off", + "@typescript-eslint/ban-ts-comment": "off", + "@typescript-eslint/prefer-namespace-keyword": "off", + "@typescript-eslint/ban-types": "off", + "@typescript-eslint/no-this-alias": "off", + "@typescript-eslint/no-empty-interface": "off", + "@typescript-eslint/no-unused-vars": "off", + "@typescript-eslint/explicit-function-return-type": [ + "off", + { + "allowExpressions": true + } + ], + "@typescript-eslint/typedef": [ + "warn", + { + "arrayDestructuring": false, + "arrowParameter": false, + "objectDestructuring": false, + "memberVariableDeclaration": true, + "parameter": true, + "propertyDeclaration": true, + "variableDeclaration": false, + "variableDeclarationIgnoreFunction": true + } + ] + }, + "settings": { + "import/resolver": { + "typescript": {} + }, + "react": { + "version": "detect" + } + } +} \ No newline at end of file diff --git a/src/api/slot/spin.ts b/src/api/slot/spin.ts new file mode 100644 index 0000000..2af2396 --- /dev/null +++ b/src/api/slot/spin.ts @@ -0,0 +1,106 @@ +import { INetRequest } from "../../script/Engine/CatanEngine/NetManagerV2/Core/INetRequest"; +import { INetResponse } from "../../script/Engine/CatanEngine/NetManagerV2/Core/INetResponse"; +import { ClientData } from "../../shared/protocols/define/interface"; +import { RpcSlot1SpinRequest, RpcSlot1SpinResponse } from "../../shared/protocols/Slot1Request"; +import { RandomEx } from "../../Utils/Number/RandomEx"; + + +export default class SlotBase { + protected temps: string[]; + protected freeTemps: string[]; + + public *spin(clientData: ClientData, req: INetRequest): IterableIterator { + const data: RpcSlot1SpinRequest = req.Data + clientData.free = null; + + const slotData: any = JSON.parse(this.temps[RandomEx.GetInt(0, this.temps.length)]); + + let totalGet: number = 0; + if (slotData.line) { + totalGet += this.getLineGet(slotData.line); + } + if (slotData.scatter) { + totalGet += this.getScatterGet(slotData.scatter); + } + if (slotData.free) { + const count = slotData.free[1]; + const { freeData, totalFreeGet } = this.getFree(count); + totalGet += totalFreeGet; + clientData.free = { count: 0, freeData }; + } + if (totalGet) { + slotData.get = [[1, totalGet]]; + } + + clientData.money -= data.pay; + if (slotData.get) { + clientData.money += slotData.get[0][1]; + } + slotData["pay"] = [[1, -data.pay]]; + slotData["money"] = clientData.money; + + const response: INetResponse = { + Status: 0, + Method: req.Method, + Data: slotData, + IsValid: true + }; + return response; + } + + protected getFree(count: number) { + const freeData = []; + let totalFreeGet = 0; + for (let i: number = 0; i < count; i++) { + const slotData: any = JSON.parse(this.freeTemps[RandomEx.GetInt(0, this.freeTemps.length)]); + freeData.push(slotData); + if (slotData.line) { + totalFreeGet += this.getLineGet(slotData.line); + } + } + return { freeData, totalFreeGet } + } + + getLineGet(lines: number[][]): number { + let totalGet: number = 0; + for (let i = 0; i < lines.length; i++) { + const line = lines[i]; + totalGet += line[2] + } + return totalGet; + } + + getScatterGet(scatter: number[][]): number { + let totalGet: number = scatter[0][1]; + return totalGet; + } +} + + + + +// // 原始的编码字符串 +// // // {"slot":[4,4,1,12,14,9,10,1,6,4,8,9,1,14,10],"scatter":[[[2,7,12],100]],"pay":[[1,-100]],"get":[[1,100]],"money":9990624} +// // const encodedStr = 'H4sIAAAAAAAAA1WOMQ+CMBCF/0vnG9paRdkcSRwMjoahQjE1hZIWooTw371TSLS54d3ru7tvYpylE4vO97mJg+uztvbkNNq2WcVSAax2/rnIe/BDR5qj7UNDUipgtq3M62Rjz9KrUrBNgMMGSxbw2b1+gQIBQoJQcADBsdmhtaeGPMGLGZhutRujjbkxLq50Zz0uaJh4dJexuXm3wlY2mJIiX16kOdI5CQkeo5Wx/B/oKMp/oshZB2PQnPG9ARdrnfUWAQAA'; + +// // {"slot":[5,6,14,6,5,11,12,3,14,11,6,2,11,2,12],"line":[[[5,11,12,13,9],161,1500]],"pay":[[1,-100]],"get":[[1,1500]],"money":9991524} +// const encodedStr = 'H4sIAAAAAAAAA11Pu27DMAz8F84cQjlSEG9FpwAdinQMMqi2XKiQJcOykRqB/72kH0OrQTreEXenJxygfEIOabi6PIbhEpskTGt9vNRQEkIT0mODX30aO8EHplPfClRHBB9r9/Pm8wDlrdBIZ6QjFoSk77iYb5pGI4pB3mFVYSEjQ4NKHr7UfUaw0YYp+3x1LuS94Lud9nZkaGGn9jMFbsbVqjRGjtAIDx/q13VSCMFHt7Q3JMNWY02nAs9csLMT63rm4O/uY/Hcg2rfu0qS1y/zP1/EQDrm6u9q93/pxNZN7xyzM59fbBqv0msBAAA='; + +// // 解码 Base64 +// const decodedBytes = Buffer.from(encodedStr, 'base64'); + +// // 解压缩 zlib 数据 +// gunzip(decodedBytes, (err, decompressedBytes) => { +// if (err) { +// console.error('解压缩失败:', err); +// return; +// } + +// // 解析 JSON 数据 +// try { +// const jsonData = JSON.parse(decompressedBytes.toString()); +// console.log(JSON.stringify(jsonData, null, 4)); +// } catch (parseErr) { +// console.error('JSON 解析失败:', parseErr); +// } +// }); \ No newline at end of file diff --git a/src/api/slot1/spin.ts b/src/api/slot1/spin.ts index da443ab..b4124b8 100644 --- a/src/api/slot1/spin.ts +++ b/src/api/slot1/spin.ts @@ -1,86 +1,15 @@ -import { INetRequest } from "../../script/Engine/CatanEngine/NetManagerV2/Core/INetRequest"; -import { INetResponse } from "../../script/Engine/CatanEngine/NetManagerV2/Core/INetResponse"; -import { ClientData } from "../../shared/protocols/define/interface"; -import { RpcSlot1SpinRequest, RpcSlot1SpinResponse } from "../../shared/protocols/Slot1Request"; -import { RandomEx } from "../../Utils/Number/RandomEx"; - -export default function* (clientData: ClientData, req: INetRequest): IterableIterator { - const data: RpcSlot1SpinRequest = req.Data - clientData.free = null; +import SlotBase from "../slot/spin"; - // // 原始的编码字符串 - // // // {"slot":[4,4,1,12,14,9,10,1,6,4,8,9,1,14,10],"scatter":[[[2,7,12],100]],"pay":[[1,-100]],"get":[[1,100]],"money":9990624} - // // const encodedStr = 'H4sIAAAAAAAAA1WOMQ+CMBCF/0vnG9paRdkcSRwMjoahQjE1hZIWooTw371TSLS54d3ru7tvYpylE4vO97mJg+uztvbkNNq2WcVSAax2/rnIe/BDR5qj7UNDUipgtq3M62Rjz9KrUrBNgMMGSxbw2b1+gQIBQoJQcADBsdmhtaeGPMGLGZhutRujjbkxLq50Zz0uaJh4dJexuXm3wlY2mJIiX16kOdI5CQkeo5Wx/B/oKMp/oshZB2PQnPG9ARdrnfUWAQAA'; - - // // {"slot":[5,6,14,6,5,11,12,3,14,11,6,2,11,2,12],"line":[[[5,11,12,13,9],161,1500]],"pay":[[1,-100]],"get":[[1,1500]],"money":9991524} - // const encodedStr = 'H4sIAAAAAAAAA11Pu27DMAz8F84cQjlSEG9FpwAdinQMMqi2XKiQJcOykRqB/72kH0OrQTreEXenJxygfEIOabi6PIbhEpskTGt9vNRQEkIT0mODX30aO8EHplPfClRHBB9r9/Pm8wDlrdBIZ6QjFoSk77iYb5pGI4pB3mFVYSEjQ4NKHr7UfUaw0YYp+3x1LuS94Lud9nZkaGGn9jMFbsbVqjRGjtAIDx/q13VSCMFHt7Q3JMNWY02nAs9csLMT63rm4O/uY/Hcg2rfu0qS1y/zP1/EQDrm6u9q93/pxNZN7xyzM59fbBqv0msBAAA='; - - // // 解码 Base64 - // const decodedBytes = Buffer.from(encodedStr, 'base64'); - - // // 解压缩 zlib 数据 - // gunzip(decodedBytes, (err, decompressedBytes) => { - // if (err) { - // console.error('解压缩失败:', err); - // return; - // } - - // // 解析 JSON 数据 - // try { - // const jsonData = JSON.parse(decompressedBytes.toString()); - // console.log(JSON.stringify(jsonData, null, 4)); - // } catch (parseErr) { - // console.error('JSON 解析失败:', parseErr); - // } - // }); - - const temps: string[] = [ +export default class Slot1 extends SlotBase { + protected temps: string[] = [ `{"slot":[11,4,8,9,5,2,13,10,7,9,10,6,6,12,4],"line":[[[5,11,12],161,2000]]}`, `{"slot":[9,6,2,5,4,14,10,9,13,10,4,5,5,2,2]}`, `{"slot":[4,3,3,3,9,10,14,14,9,4,7,8,8,5,10],"free":[[1,2,3],3],"scatter":[[[1,2,3],3000]]}`, ]; - const slotData: any = JSON.parse(temps[RandomEx.GetInt(0, temps.length)]); - - let totalGet: number = 0; - if (slotData.line) { - totalGet += getLineGet(slotData.line); - } - if (slotData.scatter) { - totalGet += getScatterGet(slotData.scatter); - } - if (slotData.free) { - const count = slotData.free[1]; - const { freeData, totalFreeGet } = getFree(count); - totalGet += totalFreeGet; - clientData.free = { count: 0, freeData }; - } - if (totalGet) { - slotData.get = [[1, totalGet]]; - } - - clientData.money -= data.pay; - if (slotData.get) { - clientData.money += slotData.get[0][1]; - } - slotData["pay"] = [[1, -data.pay]]; - slotData["money"] = clientData.money; - - const response: INetResponse = { - Status: 0, - Method: req.Method, - Data: slotData, - IsValid: true - }; - return response; -} - -function getFree(count: number) { - const freeData = []; - let totalFreeGet = 0; - const freeTemps: string[] = [ + protected freeTemps: string[] = [ `{"slot":[13,9,5,14,4,9,4,12,12,11,4,14,8,7,6],"line":[[[10,6],195,300],[[10,6],213,300]]}`, `{"slot":[9,9,10,13,4,5,4,3,4,11,10,14,14,14,5]}`, `{"slot":[12,6,8,12,11,7,12,11,5,5,11,5,3,10,9]}`, @@ -92,26 +21,4 @@ function getFree(count: number) { `{"slot":[10,14,13,9,8,6,6,6,4,13,13,12,9,14,4],"line":[[[5,6,7],122,3000]]}`, `{"slot":[11,13,9,8,5,8,5,5,13,9,14,9,12,4,7]}`, ]; - for (let i: number = 0; i < count; i++) { - const slotData: any = JSON.parse(freeTemps[RandomEx.GetInt(0, freeTemps.length)]); - freeData.push(slotData); - if (slotData.line) { - totalFreeGet += getLineGet(slotData.line); - } - } - return { freeData, totalFreeGet } -} - -function getLineGet(lines: number[][]): number { - let totalGet: number = 0; - for (let i = 0; i < lines.length; i++) { - const line = lines[i]; - totalGet += line[2] - } - return totalGet; -} - -function getScatterGet(scatter: number[][]): number { - let totalGet: number = scatter[0][1]; - return totalGet; } \ No newline at end of file diff --git a/src/script/Engine/CatanEngine/NetManagerV2/NetConnector.ts b/src/script/Engine/CatanEngine/NetManagerV2/NetConnector.ts index 87ba721..5ae85b2 100644 --- a/src/script/Engine/CatanEngine/NetManagerV2/NetConnector.ts +++ b/src/script/Engine/CatanEngine/NetManagerV2/NetConnector.ts @@ -58,33 +58,56 @@ export class NetConnector { try { // 动态导入文件 const module = await import(`../../../../api/${req.Method.replace(".", "/")}`); + const isClass = typeof module.default === 'function' && module.default.prototype && Object.getOwnPropertyNames(module.default.prototype).includes('constructor'); // 调用导入模块中的处理函数 if (module.default) { - let AsyncFunction: () => IterableIterator = function* (): IterableIterator { - const clientData: ClientData = NetConnector.clients.get(socket); - const response: INetResponse = yield* module.default(clientData, req); - if (response) { - NetConnector.Send(socket, response); - } - }; - CoroutineV2.Single(AsyncFunction()).Start(); + if (isClass) { + const moduleClass = new module.default(); + let AsyncFunction: () => IterableIterator = function* (): IterableIterator { + const clientData: ClientData = NetConnector.clients.get(socket); + const method: string = req.Method.split(".")[1]; + try { + const response: INetResponse = yield* moduleClass[method](clientData, req); + if (response) { + NetConnector.Send(socket, response); + } + } catch (error) { + console.error(`Error handling request ${req.Method}: ${error.message}`); + NetConnector.sendError(socket, req); + } + }; + CoroutineV2.Single(AsyncFunction()).Start(); + } else { + let AsyncFunction: () => IterableIterator = function* (): IterableIterator { + const clientData: ClientData = NetConnector.clients.get(socket); + const response: INetResponse = yield* module.default(clientData, req); + if (response) { + NetConnector.Send(socket, response); + } + }; + CoroutineV2.Single(AsyncFunction()).Start(); + } } else { throw new Error(`Module for ${req.Method} does not export a default function.`); } } catch (error) { console.error(`Error handling request ${req.Method}: ${error.message}`); - const response: INetResponse = { - Status: -1, - Method: req.Method, - Data: null, - IsValid: false - }; - NetConnector.Send(socket, response); + NetConnector.sendError(socket, req); } } } + private static sendError(socket: WebSocket, req: INetRequest) { + const response: INetResponse = { + Status: -1, + Method: req.Method, + Data: null, + IsValid: false + }; + NetConnector.Send(socket, response); + } + public static OnWebSocketClose() { console.log('Client disconnected'); }