CrescentLeaf/LingChair
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

feat: 支持異步接口調用方法體

Browse Source
This commit is contained in:
CrescentLeaf
2025-09-23 23:08:50 +08:00
parent 14f5bbfec9
commit 20f5484e90
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
server/api/ApiManager.ts
View File

@@ -66,11 +66,16 @@ export default class ApiManager {
})
console.log(chalk.yellow('[連]') + ` ${ip} connected`)
socket.on("The_White_Silk", (name: string, args: { [key: string]: unknown }, callback_: (ret: ApiCallbackMessage) => void) => {
socket.on("The_White_Silk", async (name: string, args: { [key: string]: unknown }, callback_: (ret: ApiCallbackMessage) => void) => {
function callback(ret: ApiCallbackMessage) {
console.log(chalk.blue('[發]') + ` ${ip} <- ${ret.code == 200 ? chalk.green(ret.msg) : chalk.red(ret.msg)} [${ret.code}]${ret.data ? (' <extras: ' + JSON.stringify(ret.data) + '>') : ''}`)
return callback_(ret)
}
async function checkIsPromiseAndAwait(value: Promise<unknown> | unknown) {
if (value instanceof Promise)
return await value
return value
}
try {
if (name == null || args == null) return callback({
msg: "Invalid request.",
@@ -78,7 +83,7 @@ export default class ApiManager {
})
console.log(chalk.red('[收]') + ` ${ip} -> ${chalk.yellow(name)} <args: ${JSON.stringify(args)}>`)
return callback(this.event_listeners[name]?.(args, clientInfo) || {
return callback(await checkIsPromiseAndAwait(this.event_listeners[name]?.(args, clientInfo)) || {
code: 501,
msg: "Not implmented",
})