handler.ts

import { ensureError } from "@mainsail/utils";
import { parentPort } from "worker_threads";

export class Handler<T extends object> {
	private readonly handler: T;

	public constructor(handler: T) {
		this.handler = handler;

		parentPort?.on("message", (message) => {
			void this.#onMessage(message);
		});
	}

	async #onMessage(message: { method: string; id: string; args: [] }) {
		try {
			if (this.handler[message.method] === undefined) {
				throw new Error(`Method ${message.method} is not defined on the handler`);
			}

			const result = await this.handler[message.method](...message.args);
			parentPort?.postMessage({ id: message.id, result });
		} catch (rawError) {
			const error = ensureError(rawError);
			parentPort?.postMessage({ error: error.message, id: message.id });
		}
	}
}