summary refs log tree commit diff
path: root/bundle/scripts/benchmark
diff options
context:
space:
mode:
authorMadeline <46743919+MaddyUnderStars@users.noreply.github.com>2022-09-25 18:24:21 +1000
committerMadeline <46743919+MaddyUnderStars@users.noreply.github.com>2022-09-25 23:35:18 +1000
commitf44f5d7ac2d24ff836c2e1d4b2fa58da04b13052 (patch)
treea6655c41bb3db79c30fd876b06ee60fe9cf70c9b /bundle/scripts/benchmark
parentAllow edited_timestamp to passthrough in handleMessage (diff)
downloadserver-f44f5d7ac2d24ff836c2e1d4b2fa58da04b13052.tar.xz
Refactor to mono-repo + upgrade packages
Diffstat (limited to 'bundle/scripts/benchmark')
-rw-r--r--bundle/scripts/benchmark/connections.js64
-rw-r--r--bundle/scripts/benchmark/index.js4
-rw-r--r--bundle/scripts/benchmark/users.js25
3 files changed, 0 insertions, 93 deletions
diff --git a/bundle/scripts/benchmark/connections.js b/bundle/scripts/benchmark/connections.js
deleted file mode 100644

index ffca2628..00000000 --- a/bundle/scripts/benchmark/connections.js +++ /dev/null
@@ -1,64 +0,0 @@ -require("dotenv").config(); -const cluster = require("cluster"); -const WebSocket = require("ws"); -const endpoint = process.env.GATEWAY || "ws://localhost:3001"; -const connections = Number(process.env.CONNECTIONS) || 50; -const token = process.env.TOKEN; -var cores = 1; -try { - cores = Number(process.env.THREADS) || os.cpus().length; -} catch { - console.log("[Bundle] Failed to get thread count! Using 1...") -} - -if (!token) { - console.error("TOKEN env var missing"); - process.exit(); -} - -if (cluster.isMaster) { - for (let i = 0; i < threads; i++) { - cluster.fork(); - } - - cluster.on("exit", (worker, code, signal) => { - console.log(`worker ${worker.process.pid} died`); - }); -} else { - for (let i = 0; i < connections; i++) { - connect(); - } -} - -function connect() { - const client = new WebSocket(endpoint); - client.on("message", (data) => { - data = JSON.parse(data); - - switch (data.op) { - case 10: - client.interval = setInterval(() => { - client.send(JSON.stringify({ op: 1 })); - }, data.d.heartbeat_interval); - - client.send( - JSON.stringify({ - op: 2, - d: { - token, - properties: {}, - }, - }) - ); - - break; - } - }); - client.once("close", (code, reason) => { - clearInterval(client.interval); - connect(); - }); - client.on("error", (err) => { - // console.log(err); - }); -} diff --git a/bundle/scripts/benchmark/index.js b/bundle/scripts/benchmark/index.js deleted file mode 100644
index 37ac5633..00000000 --- a/bundle/scripts/benchmark/index.js +++ /dev/null
@@ -1,4 +0,0 @@ -require("dotenv").config(); - -require("./connections"); -require("./messages"); diff --git a/bundle/scripts/benchmark/users.js b/bundle/scripts/benchmark/users.js deleted file mode 100644
index bce67bf4..00000000 --- a/bundle/scripts/benchmark/users.js +++ /dev/null
@@ -1,25 +0,0 @@ -require("dotenv").config(); -const fetch = require("node-fetch"); -const count = Number(process.env.COUNT) || 50; -const endpoint = process.env.API || "http://localhost:3001"; - -async function main() { - for (let i = 0; i < count; i++) { - fetch(`${endpoint}/api/auth/register`, { - method: "POST", - body: JSON.stringify({ - fingerprint: `${i}.wR8vi8lGlFBJerErO9LG5NViJFw`, - username: `test${i}`, - invite: null, - consent: true, - date_of_birth: "2000-01-01", - gift_code_sku_id: null, - captcha_key: null, - }), - headers: { "content-type": "application/json" }, - }); - console.log(i); - } -} - -main();