uptime-kuma/server/socket-handlers/general-socket-handler.js

113 lines
3.1 KiB
JavaScript
Raw Normal View History

2022-12-12 14:57:57 +00:00
const { log } = require("../../src/util");
const { Settings } = require("../settings");
const { sendInfo } = require("../client");
2022-12-16 04:56:40 +00:00
const { checkLogin } = require("../util-server");
2023-01-24 15:03:01 +00:00
const GameResolver = require("gamedig/lib/GameResolver");
2023-06-27 07:54:33 +00:00
const { testChrome } = require("../monitor-types/real-browser-monitor-type");
2023-12-04 12:04:31 +00:00
const fs = require("fs/promises");
const path = require("path");
2023-01-24 15:03:01 +00:00
let gameResolver = new GameResolver();
let gameList = null;
/**
* Get a game list via GameDig
* @returns {object[]} list of games supported by GameDig
2023-01-24 15:03:01 +00:00
*/
function getGameList() {
if (gameList == null) {
2023-01-24 15:03:01 +00:00
gameList = gameResolver._readGames().games.sort((a, b) => {
if ( a.pretty < b.pretty ) {
return -1;
}
if ( a.pretty > b.pretty ) {
return 1;
}
return 0;
});
}
return gameList;
2023-01-24 15:03:01 +00:00
}
2022-12-12 14:57:57 +00:00
module.exports.generalSocketHandler = (socket, server) => {
socket.on("initServerTimezone", async (timezone) => {
try {
2022-12-16 04:56:40 +00:00
checkLogin(socket);
2022-12-12 14:57:57 +00:00
log.debug("generalSocketHandler", "Timezone: " + timezone);
await Settings.set("initServerTimezone", true);
await server.setTimezone(timezone);
await sendInfo(socket);
} catch (e) {
2022-12-16 04:56:40 +00:00
log.warn("initServerTimezone", e.message);
2022-12-12 14:57:57 +00:00
}
});
2023-01-24 15:03:01 +00:00
socket.on("getGameList", async (callback) => {
try {
checkLogin(socket);
2023-06-27 07:54:33 +00:00
callback({
ok: true,
gameList: getGameList(),
2023-06-27 07:54:33 +00:00
});
} catch (e) {
2023-06-27 07:54:33 +00:00
callback({
ok: false,
msg: e.message,
2023-11-24 09:33:13 +00:00
});
}
2023-01-24 15:03:01 +00:00
});
2023-06-27 07:54:33 +00:00
socket.on("testChrome", (executable, callback) => {
try {
checkLogin(socket);
// Just noticed that await call could block the whole socket.io server!!! Use pure promise instead.
testChrome(executable).then((version) => {
callback({
ok: true,
msg: {
key: "foundChromiumVersion",
values: [ version ],
},
msgi18n: true,
});
}).catch((e) => {
callback({
ok: false,
msg: e.message,
});
2023-06-27 07:54:33 +00:00
});
} catch (e) {
2023-06-27 07:54:33 +00:00
callback({
ok: false,
msg: e.message,
});
}
2023-06-27 07:54:33 +00:00
});
2023-12-04 12:04:31 +00:00
socket.on("getPushExample", async (language, callback) => {
try {
let dir = path.join("./extra/push-examples", language);
2023-12-04 12:04:31 +00:00
let files = await fs.readdir(dir);
for (let file of files) {
if (file.startsWith("index.")) {
callback({
ok: true,
2023-12-04 12:04:31 +00:00
code: await fs.readFile(path.join(dir, file), "utf8"),
});
return;
}
}
} catch (e) {
}
callback({
ok: false,
msg: "Not found",
});
});
2022-12-12 14:57:57 +00:00
};