Dekescordes/spacebar
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Disable gateway status until I get some like child process thing done

Browse Source
This commit is contained in:
Madeline 2022-07-22 14:02:09 +10:00
parent 63687631ea
commit c273dacd7a
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
slowcord/status/src/index.ts
View File

@ -7,6 +7,7 @@ const dbConn = mysql.createConnection(process.env.DATABASE as string);
const executePromise = (sql: string, args: any[]) => new Promise((resolve, reject) => dbConn.execute(sql, args, (err, res) => { if (err) reject(err); else resolve(res); })); const executePromise = (sql: string, args: any[]) => new Promise((resolve, reject) => dbConn.execute(sql, args, (err, res) => { if (err) reject(err); else resolve(res); }));
const instance = { const instance = {
app: process.env.INSTANCE_WEB_APP as string,
api: process.env.INSTANCE_API as string, api: process.env.INSTANCE_API as string,
cdn: process.env.INSTANCE_CDN as string, cdn: process.env.INSTANCE_CDN as string,
token: process.env.INSTANCE_TOKEN as string, token: process.env.INSTANCE_TOKEN as string,
@ -48,7 +49,7 @@ const savePerf = async (time: number, name: string, error: string | null) => {
} }
}; };
const measureApi = async (name: string, path: string, body?: object) => { const measureApi = async (name: string, path: string, isJson?: boolean, body?: object) => {
const start = Date.now(); const start = Date.now();
let error: Error | null = null; let error: Error | null = null;
@ -60,7 +61,7 @@ const measureApi = async (name: string, path: string, body?: object) => {
}, },
body: body ? JSON.stringify(body) : undefined, body: body ? JSON.stringify(body) : undefined,
}); });
await res.json(); if (isJson !== false) await res.json();
} }
catch (e) { catch (e) {
error = e as Error; error = e as Error;
@ -75,14 +76,15 @@ const measureApi = async (name: string, path: string, body?: object) => {
const app = async () => { const app = async () => {
await new Promise((resolve) => dbConn.connect(resolve)); await new Promise((resolve) => dbConn.connect(resolve));
console.log("Connected to db"); console.log("Connected to db");
await client.login(instance.token); // await client.login(instance.token);
console.log(`Monitoring performance for instance at ${new URL(instance.api).hostname}`); console.log(`Monitoring performance for instance at ${new URL(instance.api).hostname}`);
const doMeasurements = async () => { const doMeasurements = async () => {
await measureApi("ping", `${instance.api}/ping`); await measureApi("ping", `${instance.api}/ping`);
await measureApi("users/@me", `${instance.api}/users/@me`); await measureApi("users/@me", `${instance.api}/users/@me`);
await gatewayMeasure("websocketPing"); await measureApi("login", `${instance.app}/login`, false);
// await gatewayMeasure("websocketPing");
setTimeout(doMeasurements, parseInt(process.env.MEASURE_INTERVAL as string)); setTimeout(doMeasurements, parseInt(process.env.MEASURE_INTERVAL as string));
}; };