mirror of
https://github.com/LingChair/LingChair-V0.git
synced 2025-12-08 01:55:50 +08:00
94 lines
3.2 KiB
JavaScript
94 lines
3.2 KiB
JavaScript
/*
|
|
* ©2024 满月叶
|
|
* Github: MoonLeeeaf
|
|
* 铃之椅 Node 服务端
|
|
*/
|
|
|
|
console.log("正在初始化...")
|
|
|
|
const log = (t) => {
|
|
console.log("[" + new Date().toLocaleTimeString('en-US', { hour12: false }) + "] " + t)
|
|
}
|
|
|
|
const sio = require("socket.io")
|
|
const http = require("http")
|
|
const https = require("https")
|
|
const fs = require("fs")
|
|
const process = require("process")
|
|
const vals = require("./val")
|
|
const color = require("./color")
|
|
|
|
//定义 Http 服务器回调
|
|
let httpServerCallback = require("./http-api")
|
|
|
|
// 定义 Socket.io 服务器回调
|
|
let wsServerCallback = require("./ws-api")
|
|
|
|
let httpServer
|
|
if (vals.LINGCHAIR_SERVER_CONFIG.useHttps)
|
|
httpServer = https.createServer({
|
|
key: fs.readFileSync(vals.LINGCHAIR_SERVER_CONFIG.https.key),
|
|
cert: fs.readFileSync(vals.LINGCHAIR_SERVER_CONFIG.https.cert),
|
|
}, httpServerCallback)
|
|
else
|
|
httpServer = http.createServer(httpServerCallback)
|
|
|
|
let wsServer = new sio.Server(httpServer)
|
|
|
|
const cachedClients = {}
|
|
|
|
let checkEmpty = (i) => {
|
|
if (i instanceof Array) {
|
|
for (k in i) {
|
|
if (checkEmpty(i[k])) return true
|
|
}
|
|
}
|
|
|
|
return (i == null) || ("" === i) || (0 === i)
|
|
}
|
|
|
|
wsServer.on("connect", (client) => {
|
|
|
|
log("客户端 " + client.handshake.address + " 已连接, 用户名(未经验证): " + client.handshake.auth.name)
|
|
|
|
for (const cb in wsServerCallback) {
|
|
client.on(cb, (...args) => {
|
|
log("客户端 " + client.handshake.address + " 对接口 [" + cb + "] 发起请求,参数为 " + JSON.stringify(args[0]))
|
|
let callback = args[args.length - 1]
|
|
try {
|
|
wsServerCallback[cb](args[0], (reArgs) => {
|
|
callback(reArgs)
|
|
log("返回接口 [" + cb + "] 到 " + client.handshake.address + ",参数为 " + JSON.stringify(reArgs))
|
|
}, client, cachedClients)
|
|
} catch (e) {
|
|
log(color.yellow + "调用接口或返回数据时出错: " + e + color.none)
|
|
callback({ code: -1, msg: e })
|
|
}
|
|
})
|
|
}
|
|
|
|
client.on("disconnect", () => {
|
|
if (!client.handshake.auth.passCheck)
|
|
return log("未验证的客户端 " + client.handshake.address + " 已断开, 未验证的用户名: " + client.handshake.auth.name)
|
|
|
|
// 为了支持多客户端登录 我豁出去了
|
|
if (cachedClients[client.handshake.auth.name].length === 1)
|
|
cachedClients[client.handshake.auth.name] = null
|
|
else
|
|
cachedClients[client.handshake.auth.name].forEach((item, index, arr) => {
|
|
if (item == client) {
|
|
arr.splice(index, 1)
|
|
}
|
|
})
|
|
log("客户端 " + client.handshake.address + " 已断开, 用户名: " + client.handshake.auth.name)
|
|
})
|
|
|
|
})
|
|
|
|
httpServer.listen(vals.LINGCHAIR_SERVER_CONFIG.port)
|
|
|
|
console.log(color.red + "=== 铃之椅 - Server ===" + color.none + "\n\r")
|
|
console.log(color.yellow + "Github: MoonLeeeaf" + color.none)
|
|
log(color.green + "运行服务于端口 " + vals.LINGCHAIR_SERVER_CONFIG.port + " 上，" + (vals.LINGCHAIR_SERVER_CONFIG.useHttps == true ? "已" : "未") + "使用 HTTPS" + color.none)
|
|
log(color.green + "服务已启动..." + color.none)
|