BUGFIX: time is correct

This commit is contained in:
La Programmatrice Verde 2025-08-20 17:59:57 +02:00
parent f47ed4912a
commit db9e99cc52
5 changed files with 23 additions and 21 deletions

View File

@ -6,7 +6,7 @@ var monitorInterval;
async function Monitoring() { async function Monitoring() {
await initHostList(); await initHostList();
Log(`[${shared.now}] \nInizio monitoring`); Log(`\n[${shared.now()}] Inizio monitoring`);
//monitora tutti gli host della lista //monitora tutti gli host della lista
shared.eventEmitter.on("tokenRenewalStart", () => { shared.eventEmitter.on("tokenRenewalStart", () => {
clearInterval(monitorInterval); clearInterval(monitorInterval);
@ -39,7 +39,7 @@ async function isConnected(hostID) {
}, },
} }
); );
Log(`[${shared.now}] ${hostID} connected: ${response.data.connected}`); Log(`[${shared.now()}] ${hostID} connected: ${response.data.connected}`);
return response.data.connected; return response.data.connected;
} }
@ -71,7 +71,7 @@ async function initHostList() {
}); });
} catch (error) { } catch (error) {
Log( Log(
`[${shared.now}] Errore nella verifica e aggiunta al monitoraggio di un host: ${error}` `[${shared.now()}] Errore nella verifica e aggiunta al monitoraggio di un host: ${error}`
); );
process.exit(3); process.exit(3);
} }
@ -90,7 +90,7 @@ async function initHostList() {
hostIDs.push(response.data[0].id); hostIDs.push(response.data[0].id);
} catch (error) { } catch (error) {
Log( Log(
`[${shared.now}] Errore nella verifica e aggiunta al monitoraggio di un host: ${error}` `[${shared.now()}] Errore nella verifica e aggiunta al monitoraggio di un host: ${error}`
); );
process.exit(3); process.exit(3);
} }
@ -117,7 +117,7 @@ async function initHostList() {
hostIDs.push(response.data.id); hostIDs.push(response.data.id);
} catch (error) { } catch (error) {
Log( Log(
`[${shared.now}] Errore nella verifica e aggiunta al monitoraggio di un host: ${error}` `[${shared.now()}] Errore nella verifica e aggiunta al monitoraggio di un host: ${error}`
); );
process.exit(3); process.exit(3);
} }
@ -136,7 +136,7 @@ async function initHostList() {
hostIDs.push(response.data.id); hostIDs.push(response.data.id);
} catch (error) { } catch (error) {
Log( Log(
`[${shared.now}] Errore nella verifica e aggiunta al monitoraggio di un host: ${error}` `[${shared.now()}] Errore nella verifica e aggiunta al monitoraggio di un host: ${error}`
); );
process.exit(3); process.exit(3);
} }
@ -144,7 +144,7 @@ async function initHostList() {
} }
} else { } else {
Log( Log(
`[${shared.now}] Nessun peer specificato, verranno monitorati tutti i peer disponibili` `[${shared.now()}] Nessun peer specificato, verranno monitorati tutti i peer disponibili`
); );
try { try {
const response = await axios.get(`https://api.netbird.io/api/peers`, { const response = await axios.get(`https://api.netbird.io/api/peers`, {
@ -157,13 +157,13 @@ async function initHostList() {
hostIDs.push(element.id); hostIDs.push(element.id);
}); });
} catch (error) { } catch (error) {
Log(`[${shared.now}] ${error}`); Log(`[${shared.now()}] ${error}`);
} }
} }
Log(`[${shared.now}] ID rilevati:`); Log(`[${shared.now()}] ID rilevati:`);
hostIDs.forEach((element) => { hostIDs.forEach((element) => {
Log(`[${shared.now}] ${element}`); Log(`[${shared.now()}] ${element}`);
}); });
} }

View File

@ -16,20 +16,20 @@ global.hour = minute * 60;
global.day = hour * 24; global.day = hour * 24;
app.listen(port, () => { app.listen(port, () => {
Log(`[${shared.now}] Il server è online sulla porta ${port}`); Log(`[${shared.now()}] Il server è online sulla porta ${port}`);
}); });
if ("BASE_TOKEN" in process.env) { if ("BASE_TOKEN" in process.env) {
Log(`[${shared.now}] Token inserito: ${baseToken}`); Log(`[${shared.now()}] Token inserito: ${baseToken}`);
if (/^nbp_[a-z0-9A-Z]{36}$/.test(baseToken)) { if (/^nbp_[a-z0-9A-Z]{36}$/.test(baseToken)) {
Monitoring(); Monitoring();
TokenRenew(); TokenRenew();
} else { } else {
Log(`[${shared.now}] Il token inserito non è valido.`); Log(`[${shared.now()}] Il token inserito non è valido.`);
process.exit(2); process.exit(2);
} }
} else { } else {
Log(`[${shared.now}] Nessun token inserito.`); Log(`[${shared.now()}] Nessun token inserito.`);
process.exit(1); process.exit(1);
} }

View File

@ -9,7 +9,7 @@ if (!fs.existsSync(dir)){
fs.mkdirSync(dir); fs.mkdirSync(dir);
} }
logFile = path.join(__dirname + '/' + dir, "NetBird-UptimeKuma.log"); logFile = path.join(__dirname + '/' + dir, "NetBird-UptimeKuma.log");
console.log(`[${shared.now}] File di log situato in ${__dirname + dir}NetBird-UptimeKuma.log`); console.log(`[${shared.now()}] File di log situato in ${__dirname}/${dir}NetBird-UptimeKuma.log`);
function writeToLog(message) { function writeToLog(message) {
fs.appendFileSync(logFile, `${message}\n`); fs.appendFileSync(logFile, `${message}\n`);

View File

@ -16,5 +16,7 @@ module.exports = {
return this.hosts; return this.hosts;
}, },
eventEmitter: {}, eventEmitter: {},
now: dayjs().format('DD/MM/YYYY HH:mm:ss.sss') now() {
return dayjs().format('DD/MM/YYYY HH:mm:ss.sss')
}
}; };

View File

@ -22,7 +22,7 @@ async function TokenRenew() {
await deleteToken(tokenID); await deleteToken(tokenID);
shared.eventEmitter.emit("tokenRenewalEnd"); shared.eventEmitter.emit("tokenRenewalEnd");
} catch (error) { } catch (error) {
Log(`[${shared.now}] Errore nel rinnovo del token: ${error}`); Log(`[${shared.now()}] Errore nel rinnovo del token: ${error}`);
} }
}, day - hour); }, day - hour);
} }
@ -34,7 +34,7 @@ async function getUserID() {
Authorization: `Token ${shared.getToken()}`, Authorization: `Token ${shared.getToken()}`,
}, },
}); });
Log(`[${shared.now}] UserID: ${response.data.id}`); Log(`[${shared.now()}] UserID: ${response.data.id}`);
return response.data.id; return response.data.id;
} }
@ -47,7 +47,7 @@ async function deleteToken(tokenID) {
}, },
} }
); );
Log(`[${shared.now}] Token con ID ${tokenID} cancellato con successo`); Log(`[${shared.now()}] Token con ID ${tokenID} cancellato con successo`);
} }
async function getCurrentTokenID() { async function getCurrentTokenID() {
@ -64,7 +64,7 @@ async function getCurrentTokenID() {
const token = response.data.find((t) => t.name === "Uptime Kuma"); const token = response.data.find((t) => t.name === "Uptime Kuma");
if (!token) throw new Error("Token 'Uptime Kuma' non trovato"); if (!token) throw new Error("Token 'Uptime Kuma' non trovato");
Log(`[${shared.now}] CurrentTokenID: ${token.id}`); Log(`[${shared.now()}] CurrentTokenID: ${token.id}`);
return token.id; return token.id;
} }
@ -83,7 +83,7 @@ async function getNewToken() {
}, },
} }
); );
Log(`[${shared.now}] Nuovo token creato: ${response.data.plain_token}`); Log(`[${shared.now()}] Nuovo token creato: ${response.data.plain_token}`);
return response.data.plain_token; return response.data.plain_token;
} }