X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Futils%2FConfiguration.ts;h=9ab2582d140d54ddb068aaac229aeba9577734b1;hb=71a77ac2f725a07cf391ad34e56dbd0dbb194329;hp=57ee31df0c355f0ddc6dd736d35a402ae9e70cb6;hpb=100680888f3b49453ddb4081988a480ee3030d07;p=e-mobility-charging-stations-simulator.git diff --git a/src/utils/Configuration.ts b/src/utils/Configuration.ts index 57ee31df..9ab2582d 100644 --- a/src/utils/Configuration.ts +++ b/src/utils/Configuration.ts @@ -7,17 +7,19 @@ import ConfigurationData, { import Constants from './Constants'; import { EmptyObject } from '../types/EmptyObject'; +import { FileType } from '../types/FileType'; import { HandleErrorParams } from '../types/Error'; import { ServerOptions } from 'ws'; import { StorageType } from '../types/Storage'; import type { WorkerChoiceStrategy } from 'poolifier'; +import WorkerConstants from '../worker/WorkerConstants'; import { WorkerProcessType } from '../types/Worker'; import chalk from 'chalk'; import fs from 'fs'; import path from 'path'; export default class Configuration { - private static configurationFilePath = path.join( + private static configurationFile = path.join( path.resolve(__dirname, '../'), 'assets', 'config.json' @@ -40,7 +42,7 @@ export default class Configuration { // Read conf return Configuration.objectHasOwnProperty(Configuration.getConfig(), 'logStatisticsInterval') ? Configuration.getConfig().logStatisticsInterval - : 60; + : Constants.DEFAULT_LOG_STATISTICS_INTERVAL; } static getUIWebSocketServer(): UIWebSocketServerConfiguration { @@ -158,9 +160,9 @@ export default class Configuration { static getWorkerProcess(): WorkerProcessType { Configuration.warnDeprecatedConfigurationKey( - 'useWorkerPool;', + 'useWorkerPool', null, - "Use 'workerProcess' to define the type of worker process to use instead" + "Use 'workerProcess' to define the type of worker process model to use instead" ); return Configuration.objectHasOwnProperty(Configuration.getConfig(), 'workerProcess') ? Configuration.getConfig().workerProcess @@ -170,19 +172,19 @@ export default class Configuration { static getWorkerStartDelay(): number { return Configuration.objectHasOwnProperty(Configuration.getConfig(), 'workerStartDelay') ? Configuration.getConfig().workerStartDelay - : Constants.WORKER_START_DELAY; + : WorkerConstants.DEFAULT_WORKER_START_DELAY; } static getElementStartDelay(): number { return Configuration.objectHasOwnProperty(Configuration.getConfig(), 'elementStartDelay') ? Configuration.getConfig().elementStartDelay - : Constants.ELEMENT_START_DELAY; + : WorkerConstants.DEFAULT_ELEMENT_START_DELAY; } static getWorkerPoolMinSize(): number { return Configuration.objectHasOwnProperty(Configuration.getConfig(), 'workerPoolMinSize') ? Configuration.getConfig().workerPoolMinSize - : Constants.DEFAULT_WORKER_POOL_MIN_SIZE; + : WorkerConstants.DEFAULT_POOL_MIN_SIZE; } static getWorkerPoolMaxSize(): number { @@ -193,7 +195,7 @@ export default class Configuration { ); return Configuration.objectHasOwnProperty(Configuration.getConfig(), 'workerPoolMaxSize') ? Configuration.getConfig().workerPoolMaxSize - : Constants.DEFAULT_WORKER_POOL_MAX_SIZE; + : WorkerConstants.DEFAULT_POOL_MAX_SIZE; } static getWorkerPoolStrategy(): WorkerChoiceStrategy { @@ -206,7 +208,7 @@ export default class Configuration { 'chargingStationsPerWorker' ) ? Configuration.getConfig().chargingStationsPerWorker - : Constants.DEFAULT_CHARGING_STATIONS_PER_WORKER; + : WorkerConstants.DEFAULT_ELEMENTS_PER_WORKER; } static getLogConsole(): boolean { @@ -295,11 +297,12 @@ export default class Configuration { sectionName?: string, logMsgToAppend = '' ) { - // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access if ( sectionName && !Configuration.isUndefined(Configuration.getConfig()[sectionName]) && - !Configuration.isUndefined(Configuration.getConfig()[sectionName][key]) + !Configuration.isUndefined( + (Configuration.getConfig()[sectionName] as Record)[key] + ) ) { console.error( chalk`{green ${Configuration.logPrefix()}} {red Deprecated configuration key '${key}' usage in section '${sectionName}'${ @@ -320,14 +323,14 @@ export default class Configuration { if (!Configuration.configuration) { try { Configuration.configuration = JSON.parse( - fs.readFileSync(Configuration.configurationFilePath, 'utf8') + fs.readFileSync(Configuration.configurationFile, 'utf8') ) as ConfigurationData; } catch (error) { Configuration.handleFileException( Configuration.logPrefix(), - 'Configuration', - Configuration.configurationFilePath, - error + FileType.Configuration, + Configuration.configurationFile, + error as NodeJS.ErrnoException ); } if (!Configuration.configurationFileWatcher) { @@ -339,7 +342,7 @@ export default class Configuration { private static getConfigurationFileWatcher(): fs.FSWatcher { try { - return fs.watch(Configuration.configurationFilePath, (event, filename): void => { + return fs.watch(Configuration.configurationFile, (event, filename): void => { if (filename && event === 'change') { // Nullify to force configuration file reading Configuration.configuration = null; @@ -353,9 +356,9 @@ export default class Configuration { } catch (error) { Configuration.handleFileException( Configuration.logPrefix(), - 'Configuration', - Configuration.configurationFilePath, - error as Error + FileType.Configuration, + Configuration.configurationFile, + error as NodeJS.ErrnoException ); } } @@ -385,7 +388,7 @@ export default class Configuration { private static handleFileException( logPrefix: string, - fileType: string, + fileType: FileType, filePath: string, error: NodeJS.ErrnoException, params: HandleErrorParams = { throwError: true }