Spacebar/server
1
0
Fork 0
mirror of https://github.com/spacebarchat/server.git synced 2024-11-10 12:42:44 +01:00
Code Issues Releases Activity

Do measurements one at a time in order

Browse Source
This commit is contained in:
Madeline 2022-07-21 17:58:10 +10:00
parent 0363b41890
commit 66fc4fb953
No known key found for this signature in database
GPG Key ID: 1958E017C36F2E47
1 changed files with 15 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -20,17 +20,14 @@ const client = new Fosscord.Client({
}
});
const gatewayMeasure = async (name: string) => {
const time = Math.max(client.ws.ping, 0);
await savePerf(time, name, null);
console.log(`${name} took ${time}ms`);
};
client.on("ready", () => {
console.log(`Ready on gateway as ${client.user!.tag}`);
const gatewayMeasure = async (name: string) => {
const time = Math.max(client.ws.ping, 0);
await savePerf(time, name, null);
console.log(`${name} took ${time}ms`);
setTimeout(gatewayMeasure, parseInt(process.env.MEASURE_INTERVAL as string), name);
};
gatewayMeasure("websocketPing")
});
client.on("error", (error) => {
@ -73,8 +70,6 @@ const measureApi = async (name: string, path: string, body?: object) => {
console.log(`${name} took ${time}ms ${(error ? "with error" : "")}`, error ?? "");
await savePerf(time, name, error?.message ?? null);
setTimeout(measureApi, parseInt(process.env.MEASURE_INTERVAL as string), name, path, body);
};
const app = async () => {
@ -84,8 +79,15 @@ const app = async () => {
console.log(`Monitoring performance for instance at ${new URL(instance.api).hostname}`);
measureApi("ping", `${instance.api}/ping`);
measureApi("users/@me", `${instance.api}/users/@me`);
const doMeasurements = async () => {
await measureApi("ping", `${instance.api}/ping`);
await measureApi("users/@me", `${instance.api}/users/@me`);
await gatewayMeasure("websocketPing");
setTimeout(doMeasurements, parseInt(process.env.MEASURE_INTERVAL as string));
};
doMeasurements();
};
app();