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

94 lines
2.8 KiB
JavaScript
Raw Normal View History

2022-03-30 03:59:49 +00:00
const { checkLogin, setSetting, setting, doubleCheckPassword } = require("../util-server");
const { CloudflaredTunnel } = require("node-cloudflared-tunnel");
const { UptimeKumaServer } = require("../uptime-kuma-server");
const io = UptimeKumaServer.getInstance().io;
2022-03-29 06:48:02 +00:00
const prefix = "cloudflared_";
const cloudflared = new CloudflaredTunnel();
cloudflared.change = (running, message) => {
io.to("cloudflared").emit(prefix + "running", running);
io.to("cloudflared").emit(prefix + "message", message);
};
cloudflared.error = (errorMessage) => {
io.to("cloudflared").emit(prefix + "errorMessage", errorMessage);
};
2022-03-29 06:48:02 +00:00
module.exports.cloudflaredSocketHandler = (socket) => {
socket.on(prefix + "join", async () => {
2022-03-29 06:48:02 +00:00
try {
checkLogin(socket);
socket.join("cloudflared");
io.to(socket.userID).emit(prefix + "installed", cloudflared.checkInstalled());
2022-03-30 03:59:49 +00:00
io.to(socket.userID).emit(prefix + "running", cloudflared.running);
io.to(socket.userID).emit(prefix + "token", await setting("cloudflaredTunnelToken"));
} catch (error) { }
});
2022-03-29 06:48:02 +00:00
socket.on(prefix + "leave", async () => {
try {
checkLogin(socket);
socket.leave("cloudflared");
} catch (error) { }
});
socket.on(prefix + "start", async (token) => {
try {
checkLogin(socket);
if (token && typeof token === "string") {
await setSetting("cloudflaredTunnelToken", token);
cloudflared.token = token;
} else {
cloudflared.token = null;
}
cloudflared.start();
} catch (error) { }
});
2022-03-30 03:59:49 +00:00
socket.on(prefix + "stop", async (currentPassword, callback) => {
try {
checkLogin(socket);
2022-03-30 03:59:49 +00:00
await doubleCheckPassword(socket, currentPassword);
cloudflared.stop();
2022-03-30 03:59:49 +00:00
} catch (error) {
callback({
ok: false,
msg: error.message,
});
}
});
socket.on(prefix + "removeToken", async () => {
try {
checkLogin(socket);
await setSetting("cloudflaredTunnelToken", "");
} catch (error) { }
2022-03-29 06:48:02 +00:00
});
};
2022-03-30 03:59:49 +00:00
module.exports.autoStart = async (token) => {
if (!token) {
token = await setting("cloudflaredTunnelToken");
} else {
// Override the current token via args or env var
await setSetting("cloudflaredTunnelToken", token);
console.log("Use cloudflared token from args or env var");
}
2022-03-30 03:59:49 +00:00
if (token) {
console.log("Start cloudflared");
cloudflared.token = token;
cloudflared.start();
}
};
module.exports.stop = async () => {
console.log("Stop cloudflared");
2022-04-18 16:39:49 +00:00
if (cloudflared) {
cloudflared.stop();
}
};