test: update test harness to use uws

Author: Nytelife26

jest.config.ts

@@ -8,8 +8,7 @@ export default async (): Promise<Config.InitialOptions> => ({
 	testEnvironment: "node",
 	testRunner: "jest-circus/runner",
 	testMatch: ["<rootDir>/tests/**/*.test.ts"],
-	globalSetup: "<rootDir>/tests/global-setup.ts",
-	globalTeardown: "<rootDir>/tests/global-teardown.ts",
+	setupFilesAfterEnv: ["<rootDir>/tests/setup.ts"],
 	globals: {
 		"ts-jest": {
 			tsconfig: "<rootDir>/tests/tsconfig.json"

tests/PetitioRequest.test.ts

@@ -1,13 +1,14 @@
-// eslint-disable-next-line node/no-extraneous-import
+import * as qs from "querystring";
 import { Agent, Client } from "undici";
 import type { HTTPMethod, TimeoutOptions } from "../src/lib/PetitioRequest";
 import AbortController from "node-abort-controller";
 import { URL as NURL } from "url";
 import { PetitioRequest } from "../src/lib/PetitioRequest";
 import { Readable } from "stream";
-import qs from "querystring";
 
-function url(host = "localhost:8080", method = "http") {
+const PORT = 8080 + Number(process.env.JEST_WORKER_ID);
+
+function url(host = `localhost:${PORT}`, method = "http") {
 	return `${method}://${host}`;
 }
 
@@ -16,7 +17,7 @@ describe("Constructor", () => {
 		expect.assertions(2);
 
 		function func() {
-			return new PetitioRequest(url("localhost:8080", "wss"));
+			return new PetitioRequest(url(`localhost:${PORT}`, "wss"));
 		}
 
 		expect(func).toThrow("Bad URL protocol: wss:");
@@ -170,7 +171,7 @@ describe("Query Parameters", () => {
 	test("GIVEN query param pair THEN transmit query", async () => {
 		expect.assertions(1);
 
-		const request = new PetitioRequest(url("localhost:8080/get-echo"));
+		const request = new PetitioRequest(url(`localhost:${PORT}/get-echo`));
 		const response = await request
 			.query("test", "test1")
 			.query("test1", "test")
@@ -182,7 +183,7 @@ describe("Query Parameters", () => {
 	test("GIVEN query params object THEN transmit query", async () => {
 		expect.assertions(1);
 
-		const request = new PetitioRequest(url("localhost:8080/get-echo"));
+		const request = new PetitioRequest(url(`localhost:${PORT}/get-echo`));
 		const response = await request
 			.query(OQS)
 			.json<{ args: Record<string, string> }>();
@@ -228,7 +229,7 @@ describe("URL", () => {
 		expect.assertions(1);
 
 		const path = "test";
-		const req = new PetitioRequest(url(`localhost:8080/${path}`));
+		const req = new PetitioRequest(url(`localhost:${PORT}/${path}`));
 
 		expect(req.url.pathname).toEqual(`/${path}`);
 	});
@@ -292,7 +293,7 @@ describe("Sending", () => {
 	test("GIVEN passed json THEN MATCH received raw", async () => {
 		expect.assertions(1);
 
-		const response = await new PetitioRequest(url("localhost:8080/get-echo"))
+		const response = await new PetitioRequest(url(`localhost:${PORT}/get-echo`))
 			.query("test", "test1")
 			.query("test1", "test")
 			.raw();
@@ -303,7 +304,7 @@ describe("Sending", () => {
 	test("GIVEN passed json THEN MATCH received text", async () => {
 		expect.assertions(1);
 
-		const response = await new PetitioRequest("http://localhost:8080/get-echo")
+		const response = await new PetitioRequest(`http://localhost:${PORT}/get-echo`)
 			.query("test", "test1")
 			.query("test1", "test")
 			.text();
@@ -315,7 +316,7 @@ describe("Sending", () => {
 	test("GIVEN passed json THEN MATCH received text", async () => {
 		expect.assertions(1);
 
-		const res = await new PetitioRequest("http://localhost:8080/get-echo")
+		const res = await new PetitioRequest(`http://localhost:${PORT}/get-echo`)
 			.query("test", "test1")
 			.query("test1", "test")
 			.json();

tests/PetitioResponse.test.ts

@@ -1,7 +1,9 @@
 import { PetitioRequest } from "../src/lib/PetitioRequest";
 import { PetitioResponse } from "../src/lib/PetitioResponse";
 
-function url(host = "localhost:8080", method = "http") {
+const PORT = 8080 + Number(process.env.JEST_WORKER_ID);
+
+function url(host = `localhost:${PORT}`, method = "http") {
 	return `${method}://${host}`;
 }
 
@@ -14,7 +16,7 @@ describe("Response Parsing", () => {
 			title: "in collaboration we trust",
 			body: "melius simul quam solus"
 		};
-		const request = new PetitioRequest(url("localhost:8080/json-test"));
+		const request = new PetitioRequest(url(`localhost:${PORT}/json-test`));
 		const response = await request.json();
 
 		expect(response).toEqual(json);

tests/global-setup.ts

@@ -0,0 +1,52 @@
+import {
+	App as createServer,
+	us_listen_socket as uSocket,
+	us_listen_socket_close as uSocketClose
+} from "uWebSockets.js";
+import { URL } from "url";
+
+const JSON_RESPONSE = JSON.stringify({
+	id: 0,
+	title: "in collaboration we trust",
+	body: "melius simul quam solus"
+});
+
+const socks: uSocket[] = [];
+
+const server = createServer()
+	.get("/get-echo", (res, req) => {
+		const headers: [string, string][] = [];
+		let query = req.getQuery();
+		query = query ? `?${query}` : "";
+		const url = new URL(`http://localhost:8080${req.getUrl()}${query}`);
+
+		req.forEach((key, val) => {
+			headers.push([key, val]);
+			res.writeHeader(key, val);
+		});
+
+		res.end(JSON.stringify({
+			args: Object.fromEntries(url.searchParams.entries()),
+			headers,
+			url: url.href
+		}));
+	})
+	.get("/json-test", (res) => {
+		res.writeHeader("Content-Type", "application/json");
+		res.end(JSON_RESPONSE);
+	})
+	.get("/*", (res) => {
+		res.end("No command specified");
+	});
+
+beforeAll(() => {
+	server.listen(
+		"127.0.0.1",
+		8080 + Number(process.env.JEST_WORKER_ID),
+		(sock) => socks.push(sock)
+	);
+});
+
+afterAll(() => {
+	for (const _i of socks) uSocketClose(socks.shift() as uSocket);
+});

tests/global-teardown.ts

@@ -1,4 +1,4 @@
 {
 	"extends": "./tsconfig.json",
-	"includes": ["src", "tests", "*.config.*", "docs"]
+	"include": ["src", "tests", "*.config.*", "docs"]
 }