X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerTypes.ts;h=b180983e8a9594c3e1308fa12679a4fc2cfd4493;hb=8fb8f42ace8b9295865adebaeb7845e064c05e71;hp=fa1c82b037a60c92dcdfe9366c9bde682b1fd8be;hpb=810f4caf2bf0b12d5c429d1d21af62b1fe67f965;p=e-mobility-charging-stations-simulator.git

diff --git a/src/worker/WorkerTypes.ts b/src/worker/WorkerTypes.ts
index fa1c82b0..b180983e 100644
--- a/src/worker/WorkerTypes.ts
+++ b/src/worker/WorkerTypes.ts
@@ -1,53 +1,70 @@
-import type { Worker } from 'node:worker_threads';
+import type { Worker } from 'node:worker_threads'
 
-import { type PoolEvent, PoolEvents, type PoolOptions } from 'poolifier';
+import { type PoolEvent, PoolEvents, type ThreadPoolOptions } from 'poolifier'
 
 export enum WorkerProcessType {
   workerSet = 'workerSet',
-  dynamicPool = 'dynamicPool',
-  staticPool = 'staticPool',
+  fixedPool = 'fixedPool',
+  /** @experimental */
+  dynamicPool = 'dynamicPool'
 }
 
-export type SetInfo = {
-  size: number;
-  runningElements: number;
-  elementsPerWorker: number;
-};
+export interface SetInfo {
+  version: string
+  type: string
+  worker: string
+  started: boolean
+  size: number
+  elementsExecuting: number
+  elementsPerWorker: number
+}
 
 export enum WorkerSetEvents {
+  started = 'started',
+  stopped = 'stopped',
   error = 'error',
+  elementAdded = 'elementAdded',
+  elementError = 'elementError'
 }
 
 export const WorkerEvents = {
   ...PoolEvents,
-  ...WorkerSetEvents,
-} as const;
-export type WorkerEvents = PoolEvent | WorkerSetEvents;
-
-export type MessageHandler<T> = (this: T, message: unknown) => void;
-
-export type WorkerOptions = {
-  workerStartDelay?: number;
-  elementStartDelay?: number;
-  poolMaxSize: number;
-  poolMinSize: number;
-  elementsPerWorker?: number;
-  poolOptions?: PoolOptions<Worker>;
-  messageHandler?: MessageHandler<Worker>;
-};
-
-export type WorkerData = Record<string, unknown>;
-
-export type WorkerSetElement = {
-  worker: Worker;
-  numberOfWorkerElements: number;
-};
-
-export type WorkerMessage<T extends WorkerData> = {
-  id: WorkerMessageEvents;
-  data: T;
-};
+  ...WorkerSetEvents
+} as const
+// eslint-disable-next-line @typescript-eslint/no-redeclare
+export type WorkerEvents = PoolEvent | WorkerSetEvents
+
+export interface WorkerOptions {
+  workerStartDelay?: number
+  elementAddDelay?: number
+  poolMaxSize: number
+  poolMinSize: number
+  elementsPerWorker?: number
+  poolOptions?: ThreadPoolOptions
+}
+
+export type WorkerData = Record<string, unknown>
+
+export interface WorkerDataError extends WorkerData {
+  event: WorkerMessageEvents
+  name: string
+  message: string
+  stack?: string
+}
+
+export interface WorkerSetElement {
+  worker: Worker
+  numberOfWorkerElements: number
+}
+
+export interface WorkerMessage<T extends WorkerData> {
+  uuid: `${string}-${string}-${string}-${string}`
+  event: WorkerMessageEvents
+  data: T
+}
 
 export enum WorkerMessageEvents {
-  startWorkerElement = 'startWorkerElement',
+  addWorkerElement = 'addWorkerElement',
+  addedWorkerElement = 'addedWorkerElement',
+  workerElementError = 'workerElementError'
 }