Compare commits
43 Commits
434b0a3e99
...
renovate/e
Author | SHA1 | Date | |
---|---|---|---|
fc0cb210cc | |||
f621f6c5ae | |||
3621941a0d | |||
fe15f660e6 | |||
5c2416e7ee | |||
46efd6b6dc | |||
7749a570d6 | |||
62cbe6141d | |||
b8f0d84f69 | |||
5a8b3556b3 | |||
9a12e65f8a | |||
b99e8e979c | |||
6d213dd3eb | |||
454e1f2914 | |||
7f0ab00e3b | |||
b291c10402 | |||
06ea301120 | |||
7943fabcca | |||
9189f510db | |||
4afbb8f468 | |||
19dbd63c33 | |||
6ed9d3e3b5 | |||
3b76431cb9 | |||
cd33aae6ce | |||
a086f540ad | |||
d34c35ef5e | |||
7e2db095ec | |||
7f0415a1e5 | |||
3a3cdd89df | |||
cdbe6e519d | |||
afd65d2e91 | |||
1083f58372 | |||
0f6fe18257 | |||
f475e9c287 | |||
df40071d06 | |||
ec91033104 | |||
aaff6f8ac2 | |||
793b80e216 | |||
ba005cbfd5 | |||
f9077f739c | |||
5b3e7e8198 | |||
b9dedbc603 | |||
055e314731 |
4
.gitignore
vendored
4
.gitignore
vendored
@ -144,3 +144,7 @@ dist
|
||||
# Built Visual Studio Code Extensions
|
||||
*.vsix
|
||||
|
||||
# lock files
|
||||
package-lock.json
|
||||
yarn.lock
|
||||
|
||||
|
11
Dockerfile
11
Dockerfile
@ -1,9 +1,10 @@
|
||||
FROM node:alpine
|
||||
FROM fascinated/docker-images:node-pnpm-latest
|
||||
|
||||
WORKDIR /usr/src/app
|
||||
COPY package*.json ./
|
||||
RUN npm install
|
||||
COPY package.json pnpm-lock.yaml ./
|
||||
RUN pnpm install
|
||||
COPY . .
|
||||
RUN npx tsc -b
|
||||
RUN pnpm run build
|
||||
ENV PORT=80
|
||||
EXPOSE 80
|
||||
CMD [ "npm", "start" ]
|
||||
CMD [ "pnpm", "start" ]
|
150
package-lock.json
generated
150
package-lock.json
generated
@ -41,39 +41,39 @@
|
||||
}
|
||||
},
|
||||
"node_modules/@sentry-internal/tracing": {
|
||||
"version": "7.77.0",
|
||||
"resolved": "https://registry.npmjs.org/@sentry-internal/tracing/-/tracing-7.77.0.tgz",
|
||||
"integrity": "sha512-8HRF1rdqWwtINqGEdx8Iqs9UOP/n8E0vXUu3Nmbqj4p5sQPA7vvCfq+4Y4rTqZFc7sNdFpDsRION5iQEh8zfZw==",
|
||||
"version": "7.83.0",
|
||||
"resolved": "https://registry.npmjs.org/@sentry-internal/tracing/-/tracing-7.83.0.tgz",
|
||||
"integrity": "sha512-fY1ZyOiQaaUTuoq5rO+G4/5Ov3n8BnfNK7ck97yAGxy3w+E1CwhVZkXHEvTngNfdYV3ArxvlrtPRb9STFRqXvQ==",
|
||||
"dependencies": {
|
||||
"@sentry/core": "7.77.0",
|
||||
"@sentry/types": "7.77.0",
|
||||
"@sentry/utils": "7.77.0"
|
||||
"@sentry/core": "7.83.0",
|
||||
"@sentry/types": "7.83.0",
|
||||
"@sentry/utils": "7.83.0"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">=8"
|
||||
}
|
||||
},
|
||||
"node_modules/@sentry/core": {
|
||||
"version": "7.77.0",
|
||||
"resolved": "https://registry.npmjs.org/@sentry/core/-/core-7.77.0.tgz",
|
||||
"integrity": "sha512-Tj8oTYFZ/ZD+xW8IGIsU6gcFXD/gfE+FUxUaeSosd9KHwBQNOLhZSsYo/tTVf/rnQI/dQnsd4onPZLiL+27aTg==",
|
||||
"version": "7.83.0",
|
||||
"resolved": "https://registry.npmjs.org/@sentry/core/-/core-7.83.0.tgz",
|
||||
"integrity": "sha512-fglvpw8aWM6nWXzCjAVXIMTiTEAQ9G9b85IpDd/7L8fuwaFTPQAUSJXupF2PfbpQ3FUYbJt80dxshbERVJG8vQ==",
|
||||
"dependencies": {
|
||||
"@sentry/types": "7.77.0",
|
||||
"@sentry/utils": "7.77.0"
|
||||
"@sentry/types": "7.83.0",
|
||||
"@sentry/utils": "7.83.0"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">=8"
|
||||
}
|
||||
},
|
||||
"node_modules/@sentry/node": {
|
||||
"version": "7.77.0",
|
||||
"resolved": "https://registry.npmjs.org/@sentry/node/-/node-7.77.0.tgz",
|
||||
"integrity": "sha512-Ob5tgaJOj0OYMwnocc6G/CDLWC7hXfVvKX/ofkF98+BbN/tQa5poL+OwgFn9BA8ud8xKzyGPxGU6LdZ8Oh3z/g==",
|
||||
"version": "7.83.0",
|
||||
"resolved": "https://registry.npmjs.org/@sentry/node/-/node-7.83.0.tgz",
|
||||
"integrity": "sha512-ibnON+5ovoGOsvcLxcWQu5XAc4rbkvDkzCP74YGnME3/NzRuo3cKam8bUL5Wlm15h68QzxskyNOLuj6BEJ6AfQ==",
|
||||
"dependencies": {
|
||||
"@sentry-internal/tracing": "7.77.0",
|
||||
"@sentry/core": "7.77.0",
|
||||
"@sentry/types": "7.77.0",
|
||||
"@sentry/utils": "7.77.0",
|
||||
"@sentry-internal/tracing": "7.83.0",
|
||||
"@sentry/core": "7.83.0",
|
||||
"@sentry/types": "7.83.0",
|
||||
"@sentry/utils": "7.83.0",
|
||||
"https-proxy-agent": "^5.0.0"
|
||||
},
|
||||
"engines": {
|
||||
@ -81,19 +81,19 @@
|
||||
}
|
||||
},
|
||||
"node_modules/@sentry/types": {
|
||||
"version": "7.77.0",
|
||||
"resolved": "https://registry.npmjs.org/@sentry/types/-/types-7.77.0.tgz",
|
||||
"integrity": "sha512-nfb00XRJVi0QpDHg+JkqrmEBHsqBnxJu191Ded+Cs1OJ5oPXEW6F59LVcBScGvMqe+WEk1a73eH8XezwfgrTsA==",
|
||||
"version": "7.83.0",
|
||||
"resolved": "https://registry.npmjs.org/@sentry/types/-/types-7.83.0.tgz",
|
||||
"integrity": "sha512-Bd+zJcy8p1VgCfQqUprmUaw0QPWUV+GmCt6zJRHrHTb2pwLahXv6sHJvQ8F8Va6S7Keuy088U+kHzUFGQLMZMQ==",
|
||||
"engines": {
|
||||
"node": ">=8"
|
||||
}
|
||||
},
|
||||
"node_modules/@sentry/utils": {
|
||||
"version": "7.77.0",
|
||||
"resolved": "https://registry.npmjs.org/@sentry/utils/-/utils-7.77.0.tgz",
|
||||
"integrity": "sha512-NmM2kDOqVchrey3N5WSzdQoCsyDkQkiRxExPaNI2oKQ/jMWHs9yt0tSy7otPBcXs0AP59ihl75Bvm1tDRcsp5g==",
|
||||
"version": "7.83.0",
|
||||
"resolved": "https://registry.npmjs.org/@sentry/utils/-/utils-7.83.0.tgz",
|
||||
"integrity": "sha512-7SrZtgAn3pHFBqSSvV/VL0CWTBQ7VenJjok4+WGWd6/FhP3fKrEEd9rjVTUb2Pzq9WLJJYzdvxAG8RlggG+H4g==",
|
||||
"dependencies": {
|
||||
"@sentry/types": "7.77.0"
|
||||
"@sentry/types": "7.83.0"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">=8"
|
||||
@ -119,9 +119,9 @@
|
||||
}
|
||||
},
|
||||
"node_modules/@types/express": {
|
||||
"version": "4.17.20",
|
||||
"resolved": "https://registry.npmjs.org/@types/express/-/express-4.17.20.tgz",
|
||||
"integrity": "sha512-rOaqlkgEvOW495xErXMsmyX3WKBInbhG5eqojXYi3cGUaLoRDlXa5d52fkfWZT963AZ3v2eZ4MbKE6WpDAGVsw==",
|
||||
"version": "4.17.21",
|
||||
"resolved": "https://registry.npmjs.org/@types/express/-/express-4.17.21.tgz",
|
||||
"integrity": "sha512-ejlPM315qwLpaQlQDTjPdsUFSc6ZsP4AN6AlWnogPjQ7CVi7PYF3YVz+CY3jE2pwYf7E/7HlDAN0rV2GxTG0HQ==",
|
||||
"dev": true,
|
||||
"dependencies": {
|
||||
"@types/body-parser": "*",
|
||||
@ -155,9 +155,9 @@
|
||||
"dev": true
|
||||
},
|
||||
"node_modules/@types/node": {
|
||||
"version": "20.9.0",
|
||||
"resolved": "https://registry.npmjs.org/@types/node/-/node-20.9.0.tgz",
|
||||
"integrity": "sha512-nekiGu2NDb1BcVofVcEKMIwzlx4NjHlcjhoxxKBNLtz15Y1z7MYf549DFvkHSId02Ax6kGwWntIBPC3l/JZcmw==",
|
||||
"version": "20.10.1",
|
||||
"resolved": "https://registry.npmjs.org/@types/node/-/node-20.10.1.tgz",
|
||||
"integrity": "sha512-T2qwhjWwGH81vUEx4EXmBKsTJRXFXNZTL4v0gi01+zyBmCwzE6TyHszqX01m+QHTEq+EZNo13NeJIdEqf+Myrg==",
|
||||
"dependencies": {
|
||||
"undici-types": "~5.26.4"
|
||||
}
|
||||
@ -207,9 +207,9 @@
|
||||
"integrity": "sha512-uNv6b/uGRLlCVmelat2rA8bcVd3k/42mV2EmjhPh6JLkd35T5bgwR/t6xy7a9MWhd9sixIeBUzhBenvk3NO+DQ=="
|
||||
},
|
||||
"node_modules/@types/websocket": {
|
||||
"version": "1.0.9",
|
||||
"resolved": "https://registry.npmjs.org/@types/websocket/-/websocket-1.0.9.tgz",
|
||||
"integrity": "sha512-xrMBdqdKdlE+7L9Wg2PQblIkZGSgiMlEoP6UAaYKMHbbxqCJ6PV/pTZ2RcMcSSERurU2TtGbmO4lqpFOJd01ww==",
|
||||
"version": "1.0.10",
|
||||
"resolved": "https://registry.npmjs.org/@types/websocket/-/websocket-1.0.10.tgz",
|
||||
"integrity": "sha512-svjGZvPB7EzuYS94cI7a+qhwgGU1y89wUgjT6E2wVUfmAGIvRfT7obBvRtnhXCSsoMdlG4gBFGE7MfkIXZLoww==",
|
||||
"dev": true,
|
||||
"dependencies": {
|
||||
"@types/node": "*"
|
||||
@ -296,28 +296,15 @@
|
||||
"integrity": "sha512-Oei9OH4tRh0YqU3GxhX79dM/mwVgvbZJaSNaRk+bshkj0S5cfHcgYakreBjrHwatXKbz+IoIdYLxrKim2MjW0Q=="
|
||||
},
|
||||
"node_modules/axios": {
|
||||
"version": "1.6.0",
|
||||
"resolved": "https://registry.npmjs.org/axios/-/axios-1.6.0.tgz",
|
||||
"integrity": "sha512-EZ1DYihju9pwVB+jg67ogm+Tmqc6JmhamRN6I4Zt8DfZu5lbcQGw3ozH9lFejSJgs/ibaef3A9PMXPLeefFGJg==",
|
||||
"version": "1.6.2",
|
||||
"resolved": "https://registry.npmjs.org/axios/-/axios-1.6.2.tgz",
|
||||
"integrity": "sha512-7i24Ri4pmDRfJTR7LDBhsOTtcm+9kjX5WiY1X3wIisx6G9So3pfMkEiU7emUBe46oceVImccTEM3k6C5dbVW8A==",
|
||||
"dependencies": {
|
||||
"follow-redirects": "^1.15.0",
|
||||
"form-data": "^4.0.0",
|
||||
"proxy-from-env": "^1.1.0"
|
||||
}
|
||||
},
|
||||
"node_modules/axios/node_modules/form-data": {
|
||||
"version": "4.0.0",
|
||||
"resolved": "https://registry.npmjs.org/form-data/-/form-data-4.0.0.tgz",
|
||||
"integrity": "sha512-ETEklSGi5t0QMZuiXoA/Q6vcnxcLQP5vdugSpuAyi6SVGi2clPPp+xgEhuMaHC+zGgn31Kd235W35f7Hykkaww==",
|
||||
"dependencies": {
|
||||
"asynckit": "^0.4.0",
|
||||
"combined-stream": "^1.0.8",
|
||||
"mime-types": "^2.1.12"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">= 6"
|
||||
}
|
||||
},
|
||||
"node_modules/balanced-match": {
|
||||
"version": "1.0.2",
|
||||
"resolved": "https://registry.npmjs.org/balanced-match/-/balanced-match-1.0.2.tgz",
|
||||
@ -332,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",
|
||||
@ -345,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"
|
||||
},
|
||||
@ -490,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"
|
||||
}
|
||||
@ -628,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",
|
||||
@ -754,6 +741,19 @@
|
||||
}
|
||||
}
|
||||
},
|
||||
"node_modules/form-data": {
|
||||
"version": "4.0.0",
|
||||
"resolved": "https://registry.npmjs.org/form-data/-/form-data-4.0.0.tgz",
|
||||
"integrity": "sha512-ETEklSGi5t0QMZuiXoA/Q6vcnxcLQP5vdugSpuAyi6SVGi2clPPp+xgEhuMaHC+zGgn31Kd235W35f7Hykkaww==",
|
||||
"dependencies": {
|
||||
"asynckit": "^0.4.0",
|
||||
"combined-stream": "^1.0.8",
|
||||
"mime-types": "^2.1.12"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">= 6"
|
||||
}
|
||||
},
|
||||
"node_modules/forwarded": {
|
||||
"version": "0.2.0",
|
||||
"resolved": "https://registry.npmjs.org/forwarded/-/forwarded-0.2.0.tgz",
|
||||
@ -1147,9 +1147,9 @@
|
||||
}
|
||||
},
|
||||
"node_modules/mongoose": {
|
||||
"version": "8.0.0",
|
||||
"resolved": "https://registry.npmjs.org/mongoose/-/mongoose-8.0.0.tgz",
|
||||
"integrity": "sha512-PzwkLgm1Jhj0NQdgGfnFsu0QP9V1sBFgbavEgh/IPAUzKAagzvEhuaBuAQOQGjczVWnpIU9tBqyd02cOTgsPlA==",
|
||||
"version": "8.0.2",
|
||||
"resolved": "https://registry.npmjs.org/mongoose/-/mongoose-8.0.2.tgz",
|
||||
"integrity": "sha512-Vsi9GzTXjdBVzheT1HZOZ2jHNzzR9Xwb5OyLz/FvDEAhlwrRnXnuqJf0QHINUOQSm7aoyvnPks0q85HJkd6yDw==",
|
||||
"dependencies": {
|
||||
"bson": "^6.2.0",
|
||||
"kareem": "2.5.1",
|
||||
@ -1226,9 +1226,9 @@
|
||||
"integrity": "sha512-CXdUiJembsNjuToQvxayPZF9Vqht7hewsvy2sOWafLvi2awflj9mOC6bHIg50orX8IJvWKY9wYQ/zB2kogPslQ=="
|
||||
},
|
||||
"node_modules/node-cron": {
|
||||
"version": "3.0.2",
|
||||
"resolved": "https://registry.npmjs.org/node-cron/-/node-cron-3.0.2.tgz",
|
||||
"integrity": "sha512-iP8l0yGlNpE0e6q1o185yOApANRe47UPbLf4YxfbiNHt/RU5eBcGB/e0oudruheSf+LQeDMezqC5BVAb5wwRcQ==",
|
||||
"version": "3.0.3",
|
||||
"resolved": "https://registry.npmjs.org/node-cron/-/node-cron-3.0.3.tgz",
|
||||
"integrity": "sha512-dOal67//nohNgYWb+nWmg5dkFdIwDm8EpeGYMekPMrngV3637lqnX0lbUcCtgibHTz6SEz7DAIjKvKDFYCnO1A==",
|
||||
"dependencies": {
|
||||
"uuid": "8.3.2"
|
||||
},
|
||||
@ -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",
|
||||
@ -1671,9 +1671,9 @@
|
||||
}
|
||||
},
|
||||
"node_modules/typescript": {
|
||||
"version": "5.2.2",
|
||||
"resolved": "https://registry.npmjs.org/typescript/-/typescript-5.2.2.tgz",
|
||||
"integrity": "sha512-mI4WrpHsbCIcwT9cF4FZvr80QUeKvsUsUvKDoR+X/7XHQH98xYD8YHZg7ANtz2GtZt/CBq2QJ0thkGJMHfqc1w==",
|
||||
"version": "5.3.2",
|
||||
"resolved": "https://registry.npmjs.org/typescript/-/typescript-5.3.2.tgz",
|
||||
"integrity": "sha512-6l+RyNy7oAHDfxC4FzSJcz9vnjTKxrLpDG5M2Vu4SHRVNg6xzqZp6LYSR9zjqQTu8DU/f5xwxUdADOkbrIX2gQ==",
|
||||
"bin": {
|
||||
"tsc": "bin/tsc",
|
||||
"tsserver": "bin/tsserver"
|
||||
|
@ -6,6 +6,7 @@
|
||||
"scripts": {
|
||||
"start": "node dist/index.js",
|
||||
"tsc": "tsc -w",
|
||||
"build": "tsc",
|
||||
"dev": "nodemon dist/index.js"
|
||||
},
|
||||
"author": "",
|
||||
|
1381
pnpm-lock.yaml
generated
Normal file
1381
pnpm-lock.yaml
generated
Normal file
File diff suppressed because it is too large
Load Diff
@ -4,12 +4,12 @@ import { parseTimeToMilliseconds } from "../../utils/timeUtils";
|
||||
|
||||
// Query to get the player count history for tge last 24 hours in 1 hour intervals
|
||||
const getPlayerHistoryQuery = `from(bucket: "${INFLUXDB_BUCKET}")
|
||||
|> range(start: -{})
|
||||
|> filter(fn: (r) => r["_measurement"] == "scoresaber")
|
||||
|> filter(fn: (r) => r["_field"] == "value")
|
||||
|> filter(fn: (r) => r["type"] == "player_count")
|
||||
|> aggregateWindow(every: {}, fn: mean)
|
||||
|> yield()
|
||||
|> range(start: -{})
|
||||
|> filter(fn: (r) => r["_measurement"] == "scoresaber")
|
||||
|> filter(fn: (r) => r["type"] == "score")
|
||||
|> filter(fn: (r) => r["_field"] == "player_id")
|
||||
|> unique()
|
||||
|> aggregateWindow(every: {}, fn: count)
|
||||
`;
|
||||
|
||||
const getScoreCountHistoryQuery = `from(bucket: "${INFLUXDB_BUCKET}")
|
||||
|
@ -11,6 +11,10 @@ let totalUpdated: number | undefined;
|
||||
let totalCreated: number | undefined;
|
||||
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) {
|
||||
throw new Error("Total created is undefined");
|
||||
@ -42,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) {
|
||||
@ -125,3 +129,11 @@ async function connectWebsocket() {
|
||||
|
||||
connectWebsocket();
|
||||
cron.schedule("*/5 * * * *", update);
|
||||
cron.schedule("*/1 * * * *", () => {
|
||||
// 1 minute
|
||||
if (lastMap && Date.now() - lastMap > 60_000) {
|
||||
console.log("Beatsaver websocket is dead, reconnecting");
|
||||
socket?.close();
|
||||
connectWebsocket();
|
||||
}
|
||||
});
|
||||
|
@ -10,6 +10,10 @@ import { normalizedRegionName } from "../utils/regionUtils";
|
||||
|
||||
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
|
||||
*/
|
||||
@ -47,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");
|
||||
};
|
||||
@ -62,6 +66,7 @@ async function connectWebsocket() {
|
||||
};
|
||||
|
||||
socket.onmessage = async (message) => {
|
||||
lastScore = Date.now();
|
||||
const data = message.data;
|
||||
let json;
|
||||
try {
|
||||
@ -152,3 +157,11 @@ async function connectWebsocket() {
|
||||
update();
|
||||
connectWebsocket();
|
||||
cron.schedule("*/1 * * * *", update);
|
||||
cron.schedule("*/1 * * * *", () => {
|
||||
// 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