proxy package (#8)

* proxy package

* aborted

biome.json

@@ -1,5 +1,5 @@
 {
-	"$schema": "https://biomejs.dev/schemas/1.9.1/schema.json",
+	"$schema": "https://biomejs.dev/schemas/1.9.4/schema.json",
 	"vcs": {
 		"enabled": true,
 		"clientKind": "git",

package.json

@@ -13,7 +13,7 @@
 		"check": "turbo run --concurrency 32 lint format build test checkb"
 	},
 	"devDependencies": {
-		"@biomejs/biome": "1.9.1",
+		"@biomejs/biome": "1.9.4",
 		"turbo": "^2.3.0",
 		"vitest": "^2.1.5"
 	},

packages/chartjs/biome.json

@@ -1,4 +1,4 @@
 {
-	"$schema": "https://biomejs.dev/schemas/1.9.1/schema.json",
+	"$schema": "https://biomejs.dev/schemas/1.9.4/schema.json",
 	"extends": ["../../biome.json"]
 }

packages/chartjs/package.json

@@ -24,7 +24,7 @@
 		"typescript": "^5.6.3"
 	},
 	"dependencies": {
-		"@napi-rs/canvas": "^0.1.61",
+		"@napi-rs/canvas": "^0.1.62",
 		"chart.js": "^4.4.6"
 	}
 }

packages/cooldown/biome.json

@@ -1,4 +1,4 @@
 {
-	"$schema": "https://biomejs.dev/schemas/1.9.1/schema.json",
+	"$schema": "https://biomejs.dev/schemas/1.9.4/schema.json",
 	"extends": ["../../biome.json"]
 }

packages/cooldown/package.json

@@ -25,6 +25,6 @@
 		"typescript": "^5.6.3"
 	},
 	"dependencies": {
-		"seyfert": "2.1.1-dev-11882952397.0"
+		"seyfert": "2.1.1-dev-11916234323.0"
 	}
 }

packages/generic-adapter/biome.json

@@ -1,4 +1,4 @@
 {
-	"$schema": "https://biomejs.dev/schemas/1.9.1/schema.json",
+	"$schema": "https://biomejs.dev/schemas/1.9.4/schema.json",
 	"extends": ["../../biome.json"]
 }

packages/generic-adapter/package.json

@@ -20,7 +20,7 @@
 		"checkb": "biome check --write --no-errors-on-unmatched ./src"
 	},
 	"dependencies": {
-		"seyfert": "2.1.1-dev-11882952397.0",
+		"seyfert": "2.1.1-dev-11916234323.0",
 		"tweetnacl": "^1.0.3"
 	},
 	"devDependencies": {

packages/proxy/README.md

@@ -0,0 +1,11 @@
+# Rest proxy using [uWebSockets.js](https://github.com/uNetworking/uWebSockets.js)
+
+```ts
+const { app } = await createProxy({
+	port: 4444,
+	token: "MzUxNDMzMTk0MDAxNjYxOTUy........",
+	baseUrl?...
+	app?...
+	rest?...
+});
+```

packages/proxy/biome.json

@@ -0,0 +1,4 @@
+{
+	"$schema": "https://biomejs.dev/schemas/1.9.4/schema.json",
+	"extends": ["../../biome.json"]
+}

packages/proxy/package.json

@@ -0,0 +1,30 @@
+{
+	"name": "@slipher/proxy",
+	"version": "0.0.1",
+	"private": false,
+	"license": "MIT",
+	"publishConfig": {
+		"access": "public"
+	},
+	"files": [
+		"lib/**"
+	],
+	"main": "./lib/index.js",
+	"module": "./lib/index.js",
+	"types": "./lib/index.d.ts",
+	"scripts": {
+		"dev": "tsc --watch",
+		"build": "tsc",
+		"lint": "biome lint --write ./src",
+		"format": "biome format --write ./src",
+		"checkb": "biome check --write --no-errors-on-unmatched ./src"
+	},
+	"dependencies": {
+		"seyfert": "2.1.1-dev-11916234323.0",
+		"uWebSockets.js": "github:uNetworking/uWebSockets.js#v20.49.0"
+	},
+	"devDependencies": {
+		"@types/node": "^22.9.0",
+		"typescript": "^5.6.3"
+	}
+}

packages/proxy/src/adapter.ts

@@ -0,0 +1,126 @@
+import { ApiHandler, type HttpMethods, type RawFile } from 'seyfert';
+import {
+	App,
+	type HttpRequest,
+	type HttpResponse,
+	type TemplatedApp,
+	getParts,
+	type us_listen_socket,
+} from 'uWebSockets.js';
+export function createProxy(options: {
+	token: string;
+	port: number;
+	baseUrl?: `/${string}`;
+	app?: TemplatedApp;
+	rest?: ApiHandler;
+}) {
+	const rest =
+		options.rest ??
+		new ApiHandler({
+			token: options.token,
+		});
+	const app = options.app ?? App();
+	const authKey = `Bot ${options.token}`;
+	const sliceLength = options.baseUrl ? options.baseUrl.length + 1 : 8;
+
+	app.any('/*', async (res, req) => {
+		res.onAborted(() => {
+			res.aborted = true;
+		});
+		if (res.aborted) {
+			res.writeStatus('401');
+			return;
+		}
+
+		const auth = req.getHeader('authorization');
+		if (auth !== authKey) {
+			res.writeStatus('401').end('');
+			return;
+		}
+		let body: undefined | Record<string, unknown>;
+		const files: RawFile[] = [];
+		const method = <HttpMethods>req.getMethod().toUpperCase();
+		const query = new URLSearchParams(req.getQuery());
+		const path = <`/${string}`>req.getUrl().slice(sliceLength);
+		if (method !== 'GET' && method !== 'DELETE') {
+			const contentType = req.getHeader('content-type');
+			if (contentType.includes('multipart/form-data')) {
+				const form = await readBody(res, req);
+				if (form) {
+					for (let i = 0; i < form.length; i++) {
+						const field = form[i];
+						if (field.name === 'payload_json') {
+							body = JSON.parse(Buffer.from(field.data).toString());
+						} else {
+							files.push({
+								filename: field.filename!,
+								data: field.data,
+							});
+						}
+					}
+				}
+			} else body = await readJson(res);
+		}
+		try {
+			const reason = req.getHeader('x-audit-log-reason');
+			const result = await rest.request(method, path, {
+				body,
+				files,
+				query,
+				reason,
+			});
+			if (!res.aborted)
+				res.cork(() => {
+					res.writeHeader('content-type', 'application/json').end(JSON.stringify(result));
+				});
+		} catch (e) {
+			const message = typeof e === 'object' && e && 'message' in e ? (e.message as string) : String(e);
+			if (!res.aborted)
+				res.cork(() => {
+					res
+						.writeStatus(message.match(/\[[0-9]{1,3}/g)?.[0].slice(1) ?? '500')
+						.writeHeader('content-type', 'application/json')
+						.end(JSON.stringify({ message }));
+				});
+		}
+	});
+
+	return new Promise<{ result: us_listen_socket | false; app: TemplatedApp }>(r => {
+		app.listen(options.port, result => {
+			r({ result, app });
+		});
+	});
+}
+
+export function readBuffer(res: HttpResponse) {
+	return new Promise<Buffer>((ok, rej) => {
+		const buffers: Buffer[] = [];
+		res.onData((ab, isLast) => {
+			const chunk = Buffer.from(ab);
+			if (isLast) {
+				try {
+					buffers.push(chunk);
+					ok(Buffer.concat(buffers));
+				} catch (e) {
+					res.close();
+					return;
+				}
+			} else {
+				buffers.push(chunk);
+			}
+		});
+
+		res.onAborted(rej);
+	});
+}
+
+export async function readJson<T extends Record<string, any>>(res: HttpResponse): Promise<T> {
+	const buffer = await readBuffer(res);
+	return JSON.parse(buffer.toString());
+}
+
+export async function readBody(res: HttpResponse, req: HttpRequest) {
+	const contentType = req.getHeader('content-type');
+	const buffer = await readBuffer(res);
+	return getParts(buffer, contentType);
+}

packages/proxy/src/index.ts

@@ -0,0 +1 @@
+export { createProxy } from './adapter';

packages/proxy/tsconfig.json

@@ -0,0 +1,34 @@
+{
+	"compilerOptions": {
+		"module": "CommonJS",
+		"target": "ESNext",
+		"lib": [
+			"ESNext"
+		],
+		"moduleResolution": "node",
+		"declaration": true,
+		"sourceMap": false,
+		"strict": true,
+		"esModuleInterop": true,
+		"experimentalDecorators": true,
+		"emitDecoratorMetadata": true,
+		"preserveConstEnums": true,
+		/* Type Checking */
+		"noImplicitAny": true,
+		"strictNullChecks": true,
+		"strictFunctionTypes": true,
+		"noImplicitThis": true,
+		"noUnusedLocals": true,
+		"noUnusedParameters": true,
+		"noImplicitReturns": true,
+		"noFallthroughCasesInSwitch": true,
+		"skipLibCheck": true,
+		"noErrorTruncation": true,
+		"outDir": "./lib",
+		"stripInternal": true,
+	},
+	"exclude": [
+		"**/lib",
+		"**/test"
+	],
+}

packages/redis-adapter/biome.json

@@ -1,4 +1,4 @@
 {
-	"$schema": "https://biomejs.dev/schemas/1.9.1/schema.json",
+	"$schema": "https://biomejs.dev/schemas/1.9.4/schema.json",
 	"extends": ["../../biome.json"]
 }

packages/redis-adapter/package.json

@@ -26,7 +26,7 @@
 	},
 	"dependencies": {
 		"@redis/client": "^1.6.0",
-		"seyfert": "2.1.1-dev-11882952397.0"
+		"seyfert": "2.1.1-dev-11916234323.0"
 	},
 	"devDependencies": {
 		"@types/node": "^22.9.0",

packages/uws-adapter/biome.json

@@ -1,4 +1,4 @@
 {
-	"$schema": "https://biomejs.dev/schemas/1.9.1/schema.json",
+	"$schema": "https://biomejs.dev/schemas/1.9.4/schema.json",
 	"extends": ["../../biome.json"]
 }

packages/uws-adapter/package.json

@@ -20,9 +20,9 @@
 		"checkb": "biome check --write --no-errors-on-unmatched ./src"
 	},
 	"dependencies": {
-		"seyfert": "2.1.1-dev-11882952397.0",
+		"seyfert": "2.1.1-dev-11916234323.0",
 		"tweetnacl": "^1.0.3",
-		"uWebSockets.js": "github:uNetworking/uWebSockets.js#v20.47.0"
+		"uWebSockets.js": "github:uNetworking/uWebSockets.js#v20.49.0"
 	},
 	"devDependencies": {
 		"@types/node": "^22.9.0",

packages/watcher/biome.json

@@ -1,4 +1,4 @@
 {
-	"$schema": "https://biomejs.dev/schemas/1.9.1/schema.json",
+	"$schema": "https://biomejs.dev/schemas/1.9.4/schema.json",
 	"extends": ["../../biome.json"]
 }

packages/watcher/package.json

@@ -21,7 +21,7 @@
 	},
 	"dependencies": {
 		"chokidar": "^4.0.1",
-		"seyfert": "2.1.1-dev-11882952397.0",
+		"seyfert": "2.1.1-dev-11916234323.0",
 		"tweetnacl": "^1.0.3"
 	},
 	"devDependencies": {

packages/webhooks/biome.json

@@ -1,4 +1,4 @@
 {
-	"$schema": "https://biomejs.dev/schemas/1.9.1/schema.json",
+	"$schema": "https://biomejs.dev/schemas/1.9.4/schema.json",
 	"extends": ["../../biome.json"]
 }