Compare commits
5 Commits
46efd6b6dc
...
renovate/e
Author | SHA1 | Date | |
---|---|---|---|
fc0cb210cc | |||
f621f6c5ae | |||
3621941a0d | |||
fe15f660e6 | |||
5c2416e7ee |
32
package-lock.json
generated
32
package-lock.json
generated
@ -319,12 +319,12 @@
|
||||
}
|
||||
},
|
||||
"node_modules/body-parser": {
|
||||
"version": "1.20.1",
|
||||
"resolved": "https://registry.npmjs.org/body-parser/-/body-parser-1.20.1.tgz",
|
||||
"integrity": "sha512-jWi7abTbYwajOytWCQc37VulmWiRae5RyTpaCyDcS5/lMdtwSz5lOpDE67srw/HYe35f1z3fDQw+3txg7gNtWw==",
|
||||
"version": "1.20.2",
|
||||
"resolved": "https://registry.npmjs.org/body-parser/-/body-parser-1.20.2.tgz",
|
||||
"integrity": "sha512-ml9pReCu3M61kGlqoTm2umSXTlRTuGTx0bfYj+uIUKKYycG5NtSbeetV3faSU6R7ajOPw0g/J1PvK4qNy7s5bA==",
|
||||
"dependencies": {
|
||||
"bytes": "3.1.2",
|
||||
"content-type": "~1.0.4",
|
||||
"content-type": "~1.0.5",
|
||||
"debug": "2.6.9",
|
||||
"depd": "2.0.0",
|
||||
"destroy": "1.2.0",
|
||||
@ -332,7 +332,7 @@
|
||||
"iconv-lite": "0.4.24",
|
||||
"on-finished": "2.4.1",
|
||||
"qs": "6.11.0",
|
||||
"raw-body": "2.5.1",
|
||||
"raw-body": "2.5.2",
|
||||
"type-is": "~1.6.18",
|
||||
"unpipe": "1.0.0"
|
||||
},
|
||||
@ -477,9 +477,9 @@
|
||||
}
|
||||
},
|
||||
"node_modules/cookie": {
|
||||
"version": "0.5.0",
|
||||
"resolved": "https://registry.npmjs.org/cookie/-/cookie-0.5.0.tgz",
|
||||
"integrity": "sha512-YZ3GUyn/o8gfKJlnlX7g7xq4gyO6OSuhGPKaaGssGB2qgDUS0gPgtTvoyZLTt9Ab6dC4hfc9dV5arkvc/OCmrw==",
|
||||
"version": "0.6.0",
|
||||
"resolved": "https://registry.npmjs.org/cookie/-/cookie-0.6.0.tgz",
|
||||
"integrity": "sha512-U71cyTamuh1CRNCfpGY6to28lxvNwPG4Guz/EVjgf3Jmzv0vlDp1atT9eS5dDjMYHucpHbWns6Lwf3BKz6svdw==",
|
||||
"engines": {
|
||||
"node": ">= 0.6"
|
||||
}
|
||||
@ -615,16 +615,16 @@
|
||||
}
|
||||
},
|
||||
"node_modules/express": {
|
||||
"version": "4.18.2",
|
||||
"resolved": "https://registry.npmjs.org/express/-/express-4.18.2.tgz",
|
||||
"integrity": "sha512-5/PsL6iGPdfQ/lKM1UuielYgv3BUoJfz1aUwU9vHZ+J7gyvwdQXFEBIEIaxeGf0GIcreATNyBExtalisDbuMqQ==",
|
||||
"version": "4.19.2",
|
||||
"resolved": "https://registry.npmjs.org/express/-/express-4.19.2.tgz",
|
||||
"integrity": "sha512-5T6nhjsT+EOMzuck8JjBHARTHfMht0POzlA60WV2pMD3gyXw2LZnZ+ueGdNxG+0calOJcWKbpFcuzLZ91YWq9Q==",
|
||||
"dependencies": {
|
||||
"accepts": "~1.3.8",
|
||||
"array-flatten": "1.1.1",
|
||||
"body-parser": "1.20.1",
|
||||
"body-parser": "1.20.2",
|
||||
"content-disposition": "0.5.4",
|
||||
"content-type": "~1.0.4",
|
||||
"cookie": "0.5.0",
|
||||
"cookie": "0.6.0",
|
||||
"cookie-signature": "1.0.6",
|
||||
"debug": "2.6.9",
|
||||
"depd": "2.0.0",
|
||||
@ -1391,9 +1391,9 @@
|
||||
}
|
||||
},
|
||||
"node_modules/raw-body": {
|
||||
"version": "2.5.1",
|
||||
"resolved": "https://registry.npmjs.org/raw-body/-/raw-body-2.5.1.tgz",
|
||||
"integrity": "sha512-qqJBtEyVgS0ZmPGdCFPWJ3FreoqvG4MVQln/kCgF7Olq95IbOp0/BWyMwbdtn4VTvkM8Y7khCQ2Xgk/tcrCXig==",
|
||||
"version": "2.5.2",
|
||||
"resolved": "https://registry.npmjs.org/raw-body/-/raw-body-2.5.2.tgz",
|
||||
"integrity": "sha512-8zGqypfENjCIqGhgXToC8aB2r7YrBX+AQAfIPs/Mlk+BtPTztOvTS01NRW/3Eh60J+a48lt8qsCzirQ6loCVfA==",
|
||||
"dependencies": {
|
||||
"bytes": "3.1.2",
|
||||
"http-errors": "2.0.0",
|
||||
|
@ -6,6 +6,7 @@
|
||||
"scripts": {
|
||||
"start": "node dist/index.js",
|
||||
"tsc": "tsc -w",
|
||||
"build": "tsc",
|
||||
"dev": "nodemon dist/index.js"
|
||||
},
|
||||
"author": "",
|
||||
|
1581
pnpm-lock.yaml
generated
1581
pnpm-lock.yaml
generated
File diff suppressed because it is too large
Load Diff
@ -13,6 +13,7 @@ let totalDeleted: number | undefined;
|
||||
|
||||
// Thee last time a map was heard
|
||||
let lastMap: number = Date.now();
|
||||
let socket: WebsocketClient | undefined;
|
||||
|
||||
async function update() {
|
||||
if (totalCreated == undefined) {
|
||||
@ -45,7 +46,7 @@ async function update() {
|
||||
}
|
||||
|
||||
async function connectWebsocket() {
|
||||
const socket = new WebsocketClient(WEBSOCKET_URL);
|
||||
socket = new WebsocketClient(WEBSOCKET_URL);
|
||||
await connectMongo();
|
||||
let beatSaver = await BeatSaverSchema.findOne({ _id: "beatsaver" });
|
||||
if (!beatSaver) {
|
||||
@ -129,8 +130,10 @@ async function connectWebsocket() {
|
||||
connectWebsocket();
|
||||
cron.schedule("*/5 * * * *", update);
|
||||
cron.schedule("*/1 * * * *", () => {
|
||||
if (lastMap && Date.now() - lastMap > 10000) {
|
||||
// 1 minute
|
||||
if (lastMap && Date.now() - lastMap > 60_000) {
|
||||
console.log("Beatsaver websocket is dead, reconnecting");
|
||||
socket?.close();
|
||||
connectWebsocket();
|
||||
}
|
||||
});
|
||||
|
@ -12,6 +12,7 @@ let totalScores: number | undefined;
|
||||
|
||||
// Thee last time a score was heard
|
||||
let lastScore: number = Date.now();
|
||||
let socket: WebsocketClient | undefined;
|
||||
|
||||
/**
|
||||
* Updates the player count and adds data to influx
|
||||
@ -50,7 +51,7 @@ async function connectWebsocket() {
|
||||
// set total scores to the current total plays in the database
|
||||
totalScores = leaderboard?.totalPlays || 0;
|
||||
|
||||
const socket = new WebsocketClient("wss://scoresaber.com/ws");
|
||||
socket = new WebsocketClient("wss://scoresaber.com/ws");
|
||||
socket.onopen = () => {
|
||||
console.log("Connected to scoresaber websocket");
|
||||
};
|
||||
@ -157,8 +158,10 @@ update();
|
||||
connectWebsocket();
|
||||
cron.schedule("*/1 * * * *", update);
|
||||
cron.schedule("*/1 * * * *", () => {
|
||||
if (lastScore && Date.now() - lastScore > 10000) {
|
||||
// 1 minute
|
||||
if (lastScore && Date.now() - lastScore > 60_000) {
|
||||
console.log("Scoresaber websocket is dead, reconnecting");
|
||||
socket?.close();
|
||||
connectWebsocket();
|
||||
}
|
||||
});
|
||||
|
Reference in New Issue
Block a user