Add uwebsocketsjs (#9189)

* Revert "Remove uwebsockets (#9160)"

This reverts commit 4b0a91f.

* Remove mysql

* Don't fetch types on connect

Author: porsager

frameworks/JavaScript/uwebsockets.js/README.md

@@ -0,0 +1,52 @@
+# uWebSockets.js Benchmarking Test
+
+uWebSockets is a web server written in C/C++ (https://github.com/uNetworking/uWebSockets)
+
+µWebSockets.js is a web server bypass for Node.js (https://github.com/uNetworking/uWebSockets.js)
+
+## Important Libraries
+
+The tests were run with:
+
+- [uWebSockets.js](https://github.com/uNetworking/uWebSockets.js/)
+- [postgres](https://github.com/porsager/postgres/)
+
+## Database
+
+There are individual handlers for each DB approach. The logic for each of them are found here:
+
+- [PostgreSQL](src/database/postgres.js)
+
+There are **no database endpoints** or drivers attached by default.
+
+To initialize the application with one of these, run any _one_ of the following commands:
+
+```sh
+$ DATABASE=postgres npm start
+```
+
+## Test Endpoints
+
+> Visit the test requirements [here](https://github.com/TechEmpower/FrameworkBenchmarks/wiki/Project-Information-Framework-Tests-Overview)
+
+```sh
+$ curl localhost:8080/json
+$ curl localhost:8080/plaintext
+
+# The following are only available with the DATABASE env var
+
+$ curl localhost:8080/db
+$ curl localhost:8080/fortunes
+
+$ curl localhost:8080/updates?queries=
+$ curl localhost:8080/updates?queries=2
+$ curl localhost:8080/updates?queries=1000
+$ curl localhost:8080/updates?queries=foo
+$ curl localhost:8080/updates?queries=0
+
+$ curl localhost:8080/queries?queries=
+$ curl localhost:8080/queries?queries=2
+$ curl localhost:8080/queries?queries=1000
+$ curl localhost:8080/queries?queries=foo
+$ curl localhost:8080/queries?queries=0
+```

frameworks/JavaScript/uwebsockets.js/benchmark_config.json

@@ -0,0 +1,47 @@
+{
+  "framework": "uwebsockets.js",
+  "tests": [
+    {
+      "default": {
+        "approach": "Realistic",
+        "classification": "Platform",
+        "database": "None",
+        "database_os": "Linux",
+        "display_name": "uWebSockets.js",
+        "flavor": "NodeJS",
+        "framework": "uWebSockets.js",
+        "json_url": "/json",
+        "language": "JavaScript",
+        "notes": "",
+        "orm": "Raw",
+        "os": "Linux",
+        "plaintext_url": "/plaintext",
+        "platform": "nodejs",
+        "port": 8080,
+        "versus": "nodejs",
+        "webserver": "None"
+      },
+      "postgres": {
+        "approach": "Realistic",
+        "classification": "Platform",
+        "database": "Postgres",
+        "database_os": "Linux",
+        "db_url": "/db",
+        "display_name": "uWebSockets.js",
+        "flavor": "NodeJS",
+        "fortune_url": "/fortunes",
+        "framework": "uWebSockets.js",
+        "language": "JavaScript",
+        "notes": "",
+        "orm": "Raw",
+        "os": "Linux",
+        "platform": "None",
+        "port": 8080,
+        "query_url": "/queries?queries=",
+        "update_url": "/updates?queries=",
+        "versus": "nodejs",
+        "webserver": "None"
+      }
+    }
+  ]
+}

frameworks/JavaScript/uwebsockets.js/package-lock.json

@@ -0,0 +1,17 @@
+{
+  "dependencies": {
+    "postgres": "3.4.4",
+    "slow-json-stringify": "^2.0.1",
+    "uWebSockets.js": "uNetworking/uWebSockets.js#v20.44.0"
+  },
+  "license": "MIT",
+  "main": "src/server.js",
+  "name": "uwebsockets.js",
+  "private": true,
+  "scripts": {
+    "dev": "node src/server.js",
+    "start": "node src/clustered.js"
+  },
+  "type": "module",
+  "version": "0.0.1"
+}

frameworks/JavaScript/uwebsockets.js/package.json

@@ -0,0 +1,23 @@
+import cluster from "node:cluster";
+import os from "node:os";
+import process from "node:process";
+
+if (cluster.isPrimary) {
+  // Master Node
+  console.log(`Primary ${process.pid} is running`);
+
+  // Fork workers
+  const numCPUs = os.availableParallelism();
+  for (let i = 0; i < numCPUs; i++) {
+    cluster.fork();
+  }
+
+  cluster.on("exit", (worker) => {
+    console.log(`worker ${worker.process.pid} died`);
+    process.exit(1);
+  });
+} else {
+  // Cluster Node
+  await import("./server.js");
+  console.log(`Worker ${process.pid} started`);
+}

frameworks/JavaScript/uwebsockets.js/src/clustered.js

@@ -0,0 +1,18 @@
+import postgres from "postgres";
+
+const sql = postgres({
+  host: "tfb-database",
+  user: "benchmarkdbuser",
+  password: "benchmarkdbpass",
+  database: "hello_world",
+  fetch_types: false,
+  max: 1
+});
+
+export const fortunes = async () => await sql`SELECT id, message FROM fortune`;
+
+export const find = async (id) => await sql`SELECT id, randomNumber FROM world WHERE id = ${id}`.then((arr) => arr[0]);
+
+export const bulkUpdate = async (worlds) => await sql`UPDATE world SET randomNumber = (update_data.randomNumber)::int
+  FROM (VALUES ${sql(worlds.map(world => [world.id, world.randomNumber]).sort((a, b) => (a[0] < b[0]) ? -1 : 1))}) AS update_data (id, randomNumber)
+  WHERE world.id = (update_data.id)::int`;

frameworks/JavaScript/uwebsockets.js/src/database/postgres.js

@@ -0,0 +1,194 @@
+import uWebSockets from "uWebSockets.js";
+import {
+  addBenchmarkHeaders,
+  generateRandomNumber,
+  getQueriesCount,
+  handleError,
+  escape,
+  jsonSerializer,
+  worldObjectSerializer,
+  sortByMessage
+} from "./utils.js";
+
+let db;
+const { DATABASE } = process.env;
+if (DATABASE) db = await import(`./database/${DATABASE}.js`);
+
+const webserver = uWebSockets.App();
+
+webserver.get("/plaintext", new uWebSockets.DeclarativeResponse()
+              .writeHeader("Server", "uWebSockets.js")
+              .writeHeader("Content-Type", "text/plain")
+              .end("Hello, World!")
+);
+
+webserver.get("/json", (response) => {
+  addBenchmarkHeaders(response);
+  response.writeHeader("Content-Type", "application/json");
+  // response.end(JSON.stringify({ message: "Hello, World!" }));
+  response.end(jsonSerializer({ message: "Hello, World!" }));
+});
+
+if (db) {
+  webserver.get("/db", async (response) => {
+    response.onAborted(() => {
+      response.aborted = true;
+    });
+
+    try {
+      const row = await db.find(generateRandomNumber());
+
+      if (response.aborted) {
+        return;
+      }
+
+      response.cork(() => {
+        addBenchmarkHeaders(response);
+        response.writeHeader("Content-Type", "application/json");
+        // response.end(JSON.stringify(rows));
+        response.end(worldObjectSerializer(row));
+      });
+    } catch (error) {
+      if (response.aborted) {
+        return;
+      }
+
+      handleError(error, response);
+    }
+  });
+
+  webserver.get("/queries", async (response, request) => {
+    response.onAborted(() => {
+      response.aborted = true;
+    });
+
+    try {
+      const queriesCount = getQueriesCount(request);
+
+      const databaseJobs = new Array(queriesCount);
+
+      for (let i = 0; i < queriesCount; i++) {
+        databaseJobs[i] = db.find(generateRandomNumber());
+      }
+
+      const worldObjects = await Promise.all(databaseJobs);
+
+      if (response.aborted) {
+        return;
+      }
+
+      response.cork(() => {
+        addBenchmarkHeaders(response);
+        response.writeHeader("Content-Type", "application/json");
+        response.end(JSON.stringify(worldObjects));
+      });
+    } catch (error) {
+      if (response.aborted) {
+        return;
+      }
+
+      handleError(error, response);
+    }
+  });
+  
+  const extra = { id: 0, message: "Additional fortune added at request time." };
+
+  webserver.get("/fortunes", async (response) => {
+    response.onAborted(() => {
+      response.aborted = true;
+    });
+
+    try {
+      const rows = [extra, ...await db.fortunes()];
+
+      if (response.aborted) {
+        return;
+      }
+
+      // rows.push({
+      //   id: 0,
+      //   message: "Additional fortune added at request time.",
+      // });
+
+      // rows.sort((a, b) => (a.message < b.message) ? -1 : 1);
+      sortByMessage(rows)
+
+      const n = rows.length
+
+      let html = "", i = 0;
+      for (; i < n; i++) {
+        html += `<tr><td>${rows[i].id}</td><td>${escape(rows[i].message)}</td></tr>`;
+      }
+
+      response.cork(() => {
+        addBenchmarkHeaders(response);
+        response.writeHeader("Content-Type", "text/html; charset=utf-8");
+        response.end(`<!DOCTYPE html><html><head><title>Fortunes</title></head><body><table><tr><th>id</th><th>message</th></tr>${html}</table></body></html>`);
+      });
+    } catch (error) {
+      if (response.aborted) {
+        return;
+      }
+
+      handleError(error, response);
+    }
+  });
+
+  webserver.get("/updates", async (response, request) => {
+    response.onAborted(() => {
+      response.aborted = true;
+    });
+
+    try {
+      const queriesCount = getQueriesCount(request);
+
+      const databaseJobs = new Array(queriesCount);
+
+      for (let i = 0; i < queriesCount; i++) {
+        databaseJobs[i] = db.find(generateRandomNumber());
+      }
+
+      const worldObjects = await Promise.all(databaseJobs);
+
+      for (let i = 0; i < queriesCount; i++) {
+        worldObjects[i].randomNumber = generateRandomNumber();
+      }
+
+      await db.bulkUpdate(worldObjects);
+
+      if (response.aborted) {
+        return;
+      }
+
+      response.cork(() => {
+        addBenchmarkHeaders(response);
+        response.writeHeader("Content-Type", "application/json");
+        response.end(JSON.stringify(worldObjects));
+      });
+    } catch (error) {
+      if (response.aborted) {
+        return;
+      }
+
+      handleError(error, response);
+    }
+  });
+}
+
+webserver.any("/*", (response) => {
+  response.writeStatus("404 Not Found");
+  addBenchmarkHeaders(response);
+  response.writeHeader("Content-Type", "text/plain");
+  response.end("Not Found");
+});
+
+const host = process.env.HOST || "0.0.0.0";
+const port = parseInt(process.env.PORT || "8080");
+webserver.listen(host, port, (socket) => {
+  if (!socket) {
+    console.error(`Couldn't bind to http://${host}:${port}!`);
+    process.exit(1);
+  }
+
+  console.log(`Successfully bound to http://${host}:${port}.`);
+});