X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fstart.ts;h=596f0275e8335a9c36e0dc29cb31dff5539cc4fb;hb=8eac9a09368f841fc44e980f31674146833e449b;hp=fb58c2d28ca2187dbcf0bb48b8e5b4905f23c512;hpb=f29f53d00da5e3fb216e7b98b891bb2fc678d450;p=e-mobility-charging-stations-simulator.git diff --git a/src/start.ts b/src/start.ts index fb58c2d2..596f0275 100644 --- a/src/start.ts +++ b/src/start.ts @@ -1,62 +1,8 @@ -import Configuration from './utils/Configuration'; -import { StationTemplateURL } from './types/ConfigurationData'; -import Utils from './utils/Utils'; -import Wrk from './charging-station/Worker'; -import WorkerData from './types/WorkerData'; -import fs from 'fs'; +import Bootstrap from './charging-station/Bootstrap'; +import chalk from 'chalk'; -class Bootstrap { - static async start() { - try { - let numStationsTotal = 0; - let numConcurrentWorkers = 0; - let worker: Wrk; - let chargingStationsPerWorker = Configuration.getChargingStationsPerWorker(); - let counter = 0; - // Start each ChargingStation object in a worker thread - if (Configuration.getStationTemplateURLs()) { - for await (const stationURL of Configuration.getStationTemplateURLs()) { - try { - const nbStations = stationURL.numberOfStations ? stationURL.numberOfStations : 0; - numStationsTotal += nbStations; - for (let index = 1; index <= nbStations; index++) { - const workerData = { - index, - templateFile: stationURL.file - } as WorkerData; - if(counter === 0 || counter === chargingStationsPerWorker) { - // Start new worker with one charging station - worker = await new Wrk('./dist/charging-station/StationWorker.js', workerData, numStationsTotal); - worker.start().catch(() => {}); - counter = 0; - // Start workers sequentially to optimize memory at start time - await Utils.sleep(500); - } else { - // Add new charging station to existing Worker - worker.startNewChargingStation(workerData, numStationsTotal) - } - counter++; - // Start charging station sequentially to optimize memory at start time - numConcurrentWorkers = worker.concurrentWorkers; - } - } catch (error) { - // eslint-disable-next-line no-console - console.log('Charging station start with template file ' + stationURL.file + ' error ' + JSON.stringify(error, null, ' ')); - } - } - } else { - console.log('No stationTemplateURLs defined in configuration, exiting'); - } - if (numStationsTotal === 0) { - console.log('No charging station template enabled in configuration, exiting'); - } else { - console.log('Charging station simulator started with ' + numStationsTotal.toString() + ' charging station(s) of ' + numConcurrentWorkers.toString() + ' concurrently running'); - } - } catch (error) { - // eslint-disable-next-line no-console - console.log('Bootstrap start error ' + JSON.stringify(error, null, ' ')); - } +Bootstrap.getInstance().start().catch( + (error) => { + console.error(chalk.red(error)); } -} - -Bootstrap.start(); +);