Add WorkerEvents enum.

Signed-off-by: Jérôme Benoit <jerome.benoit@sap.com>

diff --git a/src/charging-station/StationWorker.ts b/src/charging-station/StationWorker.ts
index 32c75ca79724e114daad68c9cfb08e8459a92d70..c0e85748ec0918b2f184d3561ee1f30100eddfb8 100644 (file)
--- a/src/charging-station/StationWorker.ts
+++ b/src/charging-station/StationWorker.ts
@@ -1,8 +1,8 @@
 import { isMainThread, parentPort, workerData } from 'worker_threads';
 
 import ChargingStation from './ChargingStation';
-import Constants from '../utils/Constants';
 import Utils from '../utils/Utils';
+import { WorkerEvents } from '../types/WorkerEvents';
 
 if (!isMainThread) {
   // Add listener to start charging station from main thread
@@ -13,9 +13,9 @@ if (!isMainThread) {
 }
 
 function addListener() {
-  parentPort.on('message', (e) => {
-    if (e.id === Constants.START_WORKER_ELEMENT) {
-      startChargingStation(e.workerData);
+  parentPort.on('message', (message) => {
+    if (message.id === WorkerEvents.START_WORKER_ELEMENT) {
+      startChargingStation(message.workerData);
     }
   });
 }

diff --git a/src/utils/Constants.ts b/src/utils/Constants.ts
index 5fa60e9997a14bda7ae9f78bff845660f787f7ef..3e002e600a7882f99de7fc2e1782d05b2b62c11c 100644 (file)
--- a/src/utils/Constants.ts
+++ b/src/utils/Constants.ts
@@ -36,5 +36,4 @@ export default class Constants {
   static readonly TRANSACTION_DEFAULT_TAGID = '00000000';
 
   static readonly START_WORKER_DELAY = 500;
-  static readonly START_WORKER_ELEMENT = 'startWorkerElement';
 }

diff --git a/src/worker/WorkerSet.ts b/src/worker/WorkerSet.ts
index 50b99f027a94ff7f6417f5e51dbdb009e6b03282..af753c8fc8dc8f1129e0d4ed2779234554414566 100644 (file)
--- a/src/worker/WorkerSet.ts
+++ b/src/worker/WorkerSet.ts
@@ -2,6 +2,7 @@ import Constants from '../utils/Constants';
 import Utils from '../utils/Utils';
 import { Worker } from 'worker_threads';
 import WorkerData from '../types/WorkerData';
+import { WorkerEvents } from '../types/WorkerEvents';
 import Wrk from './Wrk';
 
 export default class WorkerSet extends Wrk {
@@ -41,7 +42,7 @@ export default class WorkerSet extends Wrk {
       // Start worker sequentially to optimize memory at startup
       void Utils.sleep(Constants.START_WORKER_DELAY);
     }
-    this.getLastWorker().postMessage({ id: Constants.START_WORKER_ELEMENT, workerData: elementData });
+    this.getLastWorker().postMessage({ id: WorkerEvents.START_WORKER_ELEMENT, workerData: elementData });
     this.lastWorkerNumberOfElements++;
   }