Restart script logic after 2 hours and change timeout settings

This commit is contained in:
Wizzard 2024-08-06 08:24:38 -04:00
parent 2e019f202c
commit 2372aa5300
1 changed files with 45 additions and 8 deletions

51
main.js
View File

@ -5,11 +5,14 @@ const fs = require("fs");
const config = JSON.parse(fs.readFileSync("config.json")); const config = JSON.parse(fs.readFileSync("config.json"));
const updateInterval = 5000; const updateInterval = 1000;
const retryInterval = 30000; const retryInterval = 30000;
const restartInterval = 2 * 60 * 60 * 1000;
const reconnectDelay = 10000;
let rp; let rp;
let startTime = Date.now(); let startTime = Date.now();
let reconnecting = false;
function formatNumber(number) { function formatNumber(number) {
var x = number.split("."); var x = number.split(".");
@ -23,6 +26,8 @@ function formatNumber(number) {
} }
function createClient() { function createClient() {
if (reconnecting) return;
rp = new rpc.Client({ transport: "ipc" }); rp = new rpc.Client({ transport: "ipc" });
rp.on("ready", () => { rp.on("ready", () => {
@ -33,24 +38,31 @@ function createClient() {
rp.on("disconnected", () => { rp.on("disconnected", () => {
console.log("Disconnected from Discord!"); console.log("Disconnected from Discord!");
rp = null; rp = null;
setTimeout(createClient, retryInterval); reconnect();
}); });
rp.login({ clientId: config.clientId }).catch((error) => { rp.login({ clientId: config.clientId }).catch((error) => {
console.error("Error connecting to Discord:", error); console.error("Error connecting to Discord:", error);
rp = null; rp = null;
setTimeout(createClient, retryInterval); reconnect();
}); });
} }
createClient(); function reconnect() {
if (reconnecting) return;
reconnecting = true;
setTimeout(() => {
reconnecting = false;
createClient();
}, reconnectDelay);
}
async function updateStatus() { async function updateStatus() {
try { try {
const data = await fetchCurrentScrobble(config.username); const data = await fetchCurrentScrobble(config.username);
if (!data || !rp) { if (!data || !rp) {
console.log("Reconnecting to Discord..."); console.log("Reconnecting to Discord...");
setTimeout(updateStatus, retryInterval); reconnect();
return; return;
} }
@ -71,12 +83,11 @@ async function updateStatus() {
console.log("Discord status updated. Current track: " + data.trackName + ", Artist: " + data.artist); console.log("Discord status updated. Current track: " + data.trackName + ", Artist: " + data.artist);
setTimeout(updateStatus, updateInterval); setTimeout(updateStatus, updateInterval);
} catch (error) { } catch (error) {
console.error("Failed to update status:", error); console.error("Failed to update status:", error);
rp = null; rp = null;
setTimeout(updateStatus, retryInterval); reconnect();
} }
} }
@ -154,3 +165,29 @@ async function fetchCurrentScrobble(user) {
} }
} }
function cleanupAndRestart() {
if (rp) {
rp.clearActivity().then(() => {
rp.destroy();
rp = null;
console.log("RPC connection closed.");
setTimeout(main, reconnectDelay);
}).catch(error => {
console.error("Error clearing activity:", error);
rp = null;
setTimeout(main, reconnectDelay);
});
} else {
setTimeout(main, reconnectDelay);
}
}
function main() {
createClient();
setTimeout(() => {
console.log("Restarting internal logic...");
cleanupAndRestart();
}, restartInterval);
}
main();