fix: ensure daily recurring charging profiles are adjusted on a day
[e-mobility-charging-stations-simulator.git] / src / charging-station / Bootstrap.ts
index 37fe0e6b5ae7c5506df07f5d17b94af3b37abfcf..16a590a9a493193c9dd7d4ede7789b6f4c8a2cfa 100644 (file)
@@ -230,7 +230,7 @@ export class Bootstrap extends EventEmitter {
     if (workerConfiguration?.elementsPerWorker === 'auto') {
       elementsPerWorker =
         this.numberOfChargingStations > availableParallelism()
-          ? Math.round(this.numberOfChargingStations / availableParallelism())
+          ? Math.round(this.numberOfChargingStations / (availableParallelism() * 1.5))
           : 1;
     }
     this.workerImplementation === null &&
@@ -260,9 +260,6 @@ export class Bootstrap extends EventEmitter {
     //     2,
     //   )}`,
     // );
-    if (isNullOrUndefined(msg?.event)) {
-      return;
-    }
     try {
       switch (msg.event) {
         case ChargingStationWorkerMessageEvents.started:
@@ -284,9 +281,20 @@ export class Bootstrap extends EventEmitter {
             msg.data as Statistics,
           );
           break;
+        case ChargingStationWorkerMessageEvents.startWorkerElementError:
+          logger.error(
+            `${this.logPrefix()} ${moduleName}.messageHandler: Error occured while starting worker element:`,
+            msg.data,
+          );
+          this.emit(ChargingStationWorkerMessageEvents.startWorkerElementError, msg.data);
+          break;
+        case ChargingStationWorkerMessageEvents.startedWorkerElement:
+          break;
         default:
           throw new BaseError(
-            `Unknown event type: '${msg.event}' for data: ${JSON.stringify(msg.data, null, 2)}`,
+            `Unknown charging station worker event: '${
+              msg.event
+            }' received with data: ${JSON.stringify(msg.data, null, 2)}`,
           );
       }
     } catch (error) {