X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerAbstract.ts;h=9a10e6f2afa1de4c463dd8a2803917b61f5b76b5;hb=55ae7b758f478a2beb4557bbc96363fb913dcc73;hp=9f16af737457cf5daa522a1d25859514a6b6b3b1;hpb=e71cccf31ce6e57fc1b0a8aeb97ef3d218f22b28;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerAbstract.ts b/src/worker/WorkerAbstract.ts index 9f16af73..9a10e6f2 100644 --- a/src/worker/WorkerAbstract.ts +++ b/src/worker/WorkerAbstract.ts @@ -1,20 +1,53 @@ -import { WorkerData } from '../types/Worker'; +import type { EventEmitterAsyncResource } from 'node:events' +import { existsSync } from 'node:fs' -export default abstract class WorkerAbstract { - protected workerScript: string; - public abstract size: number; - public abstract maxElementsPerWorker: number; +import type { PoolInfo } from 'poolifier' + +import type { SetInfo, WorkerData, WorkerOptions } from './WorkerTypes.js' + +export abstract class WorkerAbstract { + protected readonly workerScript: string + protected readonly workerOptions: WorkerOptions + public abstract readonly info: PoolInfo | SetInfo + public abstract readonly size: number + public abstract readonly maxElementsPerWorker: number | undefined + public abstract readonly emitter: EventEmitterAsyncResource | undefined /** * `WorkerAbstract` constructor. * - * @param {string} workerScript + * @param workerScript - + * @param workerOptions - */ - constructor(workerScript: string) { - this.workerScript = workerScript; + constructor (workerScript: string | undefined, workerOptions: WorkerOptions) { + if (workerScript == null) { + throw new TypeError('Worker script is not defined') + } + if (typeof workerScript !== 'string') { + throw new TypeError('Worker script must be a string') + } + if (workerScript.trim().length === 0) { + throw new Error('Worker script is an empty string') + } + if (!existsSync(workerScript)) { + throw new Error('Worker script file does not exist') + } + this.workerScript = workerScript + this.workerOptions = workerOptions } - public abstract start(): Promise; - public abstract stop(): Promise; - public abstract addElement(elementData: WorkerData): Promise; + /** + * Starts the worker pool/set. + */ + public abstract start (): Promise + /** + * Stops the worker pool/set. + */ + public abstract stop (): Promise + /** + * Adds a task element to the worker pool/set. + * + * @param elementData - + */ + public abstract addElement (elementData: T): Promise }