chore(deps): update dependency @types/node to v20.12.7

package-lock.json

@@ -155,9 +155,9 @@
       "dev": true
     },
     "node_modules/@types/node": {
-      "version": "20.10.1",
-      "resolved": "https://registry.npmjs.org/@types/node/-/node-20.10.1.tgz",
-      "integrity": "sha512-T2qwhjWwGH81vUEx4EXmBKsTJRXFXNZTL4v0gi01+zyBmCwzE6TyHszqX01m+QHTEq+EZNo13NeJIdEqf+Myrg==",
+      "version": "20.12.7",
+      "resolved": "https://registry.npmjs.org/@types/node/-/node-20.12.7.tgz",
+      "integrity": "sha512-wq0cICSkRLVaf3UGLMGItu/PtdY7oaXaI/RVU+xliKVOtRna3PRY57ZDfztpDL0n11vfymMUnXv8QwYCO7L1wg==",
       "dependencies": {
         "undici-types": "~5.26.4"
       }

package.json

@@ -6,6 +6,7 @@
   "scripts": {
     "start": "node dist/index.js",
     "tsc": "tsc -w",
+    "build": "tsc",
     "dev": "nodemon dist/index.js"
   },
   "author": "",

src/services/beatsaver.ts

@@ -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();
   }
 });

src/services/scoresaber.ts

@@ -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();
   }
 });