Compare commits
5 Commits
46efd6b6dc
...
renovate/a
Author | SHA1 | Date | |
---|---|---|---|
564cfd11cc | |||
f621f6c5ae | |||
3621941a0d | |||
fe15f660e6 | |||
5c2416e7ee |
14
package-lock.json
generated
14
package-lock.json
generated
@ -296,11 +296,11 @@
|
|||||||
"integrity": "sha512-Oei9OH4tRh0YqU3GxhX79dM/mwVgvbZJaSNaRk+bshkj0S5cfHcgYakreBjrHwatXKbz+IoIdYLxrKim2MjW0Q=="
|
"integrity": "sha512-Oei9OH4tRh0YqU3GxhX79dM/mwVgvbZJaSNaRk+bshkj0S5cfHcgYakreBjrHwatXKbz+IoIdYLxrKim2MjW0Q=="
|
||||||
},
|
},
|
||||||
"node_modules/axios": {
|
"node_modules/axios": {
|
||||||
"version": "1.6.2",
|
"version": "1.6.8",
|
||||||
"resolved": "https://registry.npmjs.org/axios/-/axios-1.6.2.tgz",
|
"resolved": "https://registry.npmjs.org/axios/-/axios-1.6.8.tgz",
|
||||||
"integrity": "sha512-7i24Ri4pmDRfJTR7LDBhsOTtcm+9kjX5WiY1X3wIisx6G9So3pfMkEiU7emUBe46oceVImccTEM3k6C5dbVW8A==",
|
"integrity": "sha512-v/ZHtJDU39mDpyBoFVkETcd/uNdxrWRrg3bKpOKzXFA6Bvqopts6ALSMU3y6ijYxbw2B+wPrIv46egTzJXCLGQ==",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"follow-redirects": "^1.15.0",
|
"follow-redirects": "^1.15.6",
|
||||||
"form-data": "^4.0.0",
|
"form-data": "^4.0.0",
|
||||||
"proxy-from-env": "^1.1.0"
|
"proxy-from-env": "^1.1.0"
|
||||||
}
|
}
|
||||||
@ -723,9 +723,9 @@
|
|||||||
"integrity": "sha512-Tpp60P6IUJDTuOq/5Z8cdskzJujfwqfOTkrwIwj7IRISpnkJnT6SyJ4PCPnGMoFjC9ddhal5KVIYtAt97ix05A=="
|
"integrity": "sha512-Tpp60P6IUJDTuOq/5Z8cdskzJujfwqfOTkrwIwj7IRISpnkJnT6SyJ4PCPnGMoFjC9ddhal5KVIYtAt97ix05A=="
|
||||||
},
|
},
|
||||||
"node_modules/follow-redirects": {
|
"node_modules/follow-redirects": {
|
||||||
"version": "1.15.3",
|
"version": "1.15.6",
|
||||||
"resolved": "https://registry.npmjs.org/follow-redirects/-/follow-redirects-1.15.3.tgz",
|
"resolved": "https://registry.npmjs.org/follow-redirects/-/follow-redirects-1.15.6.tgz",
|
||||||
"integrity": "sha512-1VzOtuEM8pC9SFU1E+8KfTjZyMztRsgEfwQl44z8A25uy13jSzTj6dyK2Df52iV0vgHCfBwLhDWevLn95w5v6Q==",
|
"integrity": "sha512-wWN62YITEaOpSK584EZXJafH1AGpO8RVgElfkuXbTOrPX4fIfOyEpW/CsiNd8JdYrAoOvafRTOEnvsO++qCqFA==",
|
||||||
"funding": [
|
"funding": [
|
||||||
{
|
{
|
||||||
"type": "individual",
|
"type": "individual",
|
||||||
|
@ -6,6 +6,7 @@
|
|||||||
"scripts": {
|
"scripts": {
|
||||||
"start": "node dist/index.js",
|
"start": "node dist/index.js",
|
||||||
"tsc": "tsc -w",
|
"tsc": "tsc -w",
|
||||||
|
"build": "tsc",
|
||||||
"dev": "nodemon dist/index.js"
|
"dev": "nodemon dist/index.js"
|
||||||
},
|
},
|
||||||
"author": "",
|
"author": "",
|
||||||
|
1526
pnpm-lock.yaml
generated
1526
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
|
// Thee last time a map was heard
|
||||||
let lastMap: number = Date.now();
|
let lastMap: number = Date.now();
|
||||||
|
let socket: WebsocketClient | undefined;
|
||||||
|
|
||||||
async function update() {
|
async function update() {
|
||||||
if (totalCreated == undefined) {
|
if (totalCreated == undefined) {
|
||||||
@ -45,7 +46,7 @@ async function update() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
async function connectWebsocket() {
|
async function connectWebsocket() {
|
||||||
const socket = new WebsocketClient(WEBSOCKET_URL);
|
socket = new WebsocketClient(WEBSOCKET_URL);
|
||||||
await connectMongo();
|
await connectMongo();
|
||||||
let beatSaver = await BeatSaverSchema.findOne({ _id: "beatsaver" });
|
let beatSaver = await BeatSaverSchema.findOne({ _id: "beatsaver" });
|
||||||
if (!beatSaver) {
|
if (!beatSaver) {
|
||||||
@ -129,8 +130,10 @@ async function connectWebsocket() {
|
|||||||
connectWebsocket();
|
connectWebsocket();
|
||||||
cron.schedule("*/5 * * * *", update);
|
cron.schedule("*/5 * * * *", update);
|
||||||
cron.schedule("*/1 * * * *", () => {
|
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");
|
console.log("Beatsaver websocket is dead, reconnecting");
|
||||||
|
socket?.close();
|
||||||
connectWebsocket();
|
connectWebsocket();
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
@ -12,6 +12,7 @@ let totalScores: number | undefined;
|
|||||||
|
|
||||||
// Thee last time a score was heard
|
// Thee last time a score was heard
|
||||||
let lastScore: number = Date.now();
|
let lastScore: number = Date.now();
|
||||||
|
let socket: WebsocketClient | undefined;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Updates the player count and adds data to influx
|
* 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
|
// set total scores to the current total plays in the database
|
||||||
totalScores = leaderboard?.totalPlays || 0;
|
totalScores = leaderboard?.totalPlays || 0;
|
||||||
|
|
||||||
const socket = new WebsocketClient("wss://scoresaber.com/ws");
|
socket = new WebsocketClient("wss://scoresaber.com/ws");
|
||||||
socket.onopen = () => {
|
socket.onopen = () => {
|
||||||
console.log("Connected to scoresaber websocket");
|
console.log("Connected to scoresaber websocket");
|
||||||
};
|
};
|
||||||
@ -157,8 +158,10 @@ update();
|
|||||||
connectWebsocket();
|
connectWebsocket();
|
||||||
cron.schedule("*/1 * * * *", update);
|
cron.schedule("*/1 * * * *", update);
|
||||||
cron.schedule("*/1 * * * *", () => {
|
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");
|
console.log("Scoresaber websocket is dead, reconnecting");
|
||||||
|
socket?.close();
|
||||||
connectWebsocket();
|
connectWebsocket();
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
Reference in New Issue
Block a user