refactor: syntax check in worker configuration section

[e-mobility-charging-stations-simulator.git] / src / utils / Configuration.ts

import { type FSWatcher, readFileSync, watch } from 'node:fs';
import { dirname, join, resolve } from 'node:path';
import { fileURLToPath } from 'node:url';

import chalk from 'chalk';
import merge from 'just-merge';

import { Constants } from './Constants';
import { hasOwnProp, isCFEnvironment, isNotEmptyString, isUndefined } from './Utils';
import {
  ApplicationProtocol,
  type ConfigurationData,
  FileType,
  type LogConfiguration,
  type StationTemplateUrl,
  type StorageConfiguration,
  StorageType,
  SupervisionUrlDistribution,
  type UIServerConfiguration,
  type WorkerConfiguration,
} from '../types';
import { WorkerConstants, WorkerProcessType } from '../worker';

export class Configuration {
  private static configurationFile = join(
    dirname(fileURLToPath(import.meta.url)),
    'assets',
    'config.json',
  );

  private static configurationFileWatcher: FSWatcher | undefined;
  private static configuration: ConfigurationData | null = null;
  private static configurationChangeCallback: () => Promise<void>;

  private constructor() {
    // This is intentional
  }

  public static setConfigurationChangeCallback(cb: () => Promise<void>): void {
    Configuration.configurationChangeCallback = cb;
  }

  public static getUIServer(): UIServerConfiguration {
    if (hasOwnProp(Configuration.getConfig(), 'uiWebSocketServer')) {
      console.error(
        `${chalk.green(Configuration.logPrefix())} ${chalk.red(
          "Deprecated configuration section 'uiWebSocketServer' usage. Use 'uiServer' instead",
        )}`,
      );
    }
    let uiServerConfiguration: UIServerConfiguration = {
      enabled: false,
      type: ApplicationProtocol.WS,
      options: {
        host: Constants.DEFAULT_UI_SERVER_HOST,
        port: Constants.DEFAULT_UI_SERVER_PORT,
      },
    };
    if (hasOwnProp(Configuration.getConfig(), 'uiServer')) {
      uiServerConfiguration = merge<UIServerConfiguration>(
        uiServerConfiguration,
        Configuration.getConfig()!.uiServer!,
      );
    }
    if (isCFEnvironment() === true) {
      delete uiServerConfiguration.options?.host;
      uiServerConfiguration.options!.port = parseInt(process.env.PORT!);
    }
    return uiServerConfiguration;
  }

  public static getPerformanceStorage(): StorageConfiguration {
    Configuration.warnDeprecatedConfigurationKey('URI', 'performanceStorage', "Use 'uri' instead");
    let storageConfiguration: StorageConfiguration = {
      enabled: false,
      type: StorageType.JSON_FILE,
      uri: this.getDefaultPerformanceStorageUri(StorageType.JSON_FILE),
    };
    if (hasOwnProp(Configuration.getConfig(), 'performanceStorage')) {
      storageConfiguration = {
        ...storageConfiguration,
        ...Configuration.getConfig()?.performanceStorage,
        ...(Configuration.getConfig()?.performanceStorage?.type === StorageType.JSON_FILE &&
          Configuration.getConfig()?.performanceStorage?.uri && {
            uri: Configuration.buildPerformanceUriFilePath(
              new URL(Configuration.getConfig()!.performanceStorage!.uri!).pathname,
            ),
          }),
      };
    }
    return storageConfiguration;
  }

  public static getAutoReconnectMaxRetries(): number | undefined {
    Configuration.warnDeprecatedConfigurationKey(
      'autoReconnectTimeout',
      undefined,
      "Use 'ConnectionTimeOut' OCPP parameter in charging station template instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'connectionTimeout',
      undefined,
      "Use 'ConnectionTimeOut' OCPP parameter in charging station template instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'autoReconnectMaxRetries',
      undefined,
      'Use it in charging station template instead',
    );
    // Read conf
    if (hasOwnProp(Configuration.getConfig(), 'autoReconnectMaxRetries')) {
      return Configuration.getConfig()?.autoReconnectMaxRetries;
    }
  }

  public static getStationTemplateUrls(): StationTemplateUrl[] | undefined {
    Configuration.warnDeprecatedConfigurationKey(
      'stationTemplateURLs',
      undefined,
      "Use 'stationTemplateUrls' instead",
    );
    // eslint-disable-next-line @typescript-eslint/dot-notation
    !isUndefined(Configuration.getConfig()!['stationTemplateURLs']) &&
      (Configuration.getConfig()!.stationTemplateUrls = Configuration.getConfig()![
        // eslint-disable-next-line @typescript-eslint/dot-notation
        'stationTemplateURLs'
      ] as StationTemplateUrl[]);
    Configuration.getConfig()!.stationTemplateUrls.forEach(
      (stationTemplateUrl: StationTemplateUrl) => {
        // eslint-disable-next-line @typescript-eslint/dot-notation
        if (!isUndefined(stationTemplateUrl['numberOfStation'])) {
          console.error(
            `${chalk.green(Configuration.logPrefix())} ${chalk.red(
              `Deprecated configuration key 'numberOfStation' usage for template file '${stationTemplateUrl.file}' in 'stationTemplateUrls'. Use 'numberOfStations' instead`,
            )}`,
          );
        }
      },
    );
    // Read conf
    return Configuration.getConfig()?.stationTemplateUrls;
  }

  public static getLog(): LogConfiguration {
    Configuration.warnDeprecatedConfigurationKey(
      'logEnabled',
      undefined,
      "Use 'log' section to define the logging enablement instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'logFile',
      undefined,
      "Use 'log' section to define the log file instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'logErrorFile',
      undefined,
      "Use 'log' section to define the log error file instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'logConsole',
      undefined,
      "Use 'log' section to define the console logging enablement instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'logStatisticsInterval',
      undefined,
      "Use 'log' section to define the log statistics interval instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'logLevel',
      undefined,
      "Use 'log' section to define the log level instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'logFormat',
      undefined,
      "Use 'log' section to define the log format instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'logRotate',
      undefined,
      "Use 'log' section to define the log rotation enablement instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'logMaxFiles',
      undefined,
      "Use 'log' section to define the log maximum files instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'logMaxSize',
      undefined,
      "Use 'log' section to define the log maximum size instead",
    );
    const defaultLogConfiguration: LogConfiguration = {
      enabled: true,
      file: 'logs/combined.log',
      errorFile: 'logs/error.log',
      statisticsInterval: Constants.DEFAULT_LOG_STATISTICS_INTERVAL,
      level: 'info',
      format: 'simple',
      rotate: true,
    };
    const deprecatedLogConfiguration: LogConfiguration = {
      ...(hasOwnProp(Configuration.getConfig(), 'logEnabled') && {
        enabled: Configuration.getConfig()?.logEnabled,
      }),
      ...(hasOwnProp(Configuration.getConfig(), 'logFile') && {
        file: Configuration.getConfig()?.logFile,
      }),
      ...(hasOwnProp(Configuration.getConfig(), 'logErrorFile') && {
        errorFile: Configuration.getConfig()?.logErrorFile,
      }),
      ...(hasOwnProp(Configuration.getConfig(), 'logStatisticsInterval') && {
        statisticsInterval: Configuration.getConfig()?.logStatisticsInterval,
      }),
      ...(hasOwnProp(Configuration.getConfig(), 'logLevel') && {
        level: Configuration.getConfig()?.logLevel,
      }),
      ...(hasOwnProp(Configuration.getConfig(), 'logConsole') && {
        console: Configuration.getConfig()?.logConsole,
      }),
      ...(hasOwnProp(Configuration.getConfig(), 'logFormat') && {
        format: Configuration.getConfig()?.logFormat,
      }),
      ...(hasOwnProp(Configuration.getConfig(), 'logRotate') && {
        rotate: Configuration.getConfig()?.logRotate,
      }),
      ...(hasOwnProp(Configuration.getConfig(), 'logMaxFiles') && {
        maxFiles: Configuration.getConfig()?.logMaxFiles,
      }),
      ...(hasOwnProp(Configuration.getConfig(), 'logMaxSize') && {
        maxSize: Configuration.getConfig()?.logMaxSize,
      }),
    };
    const logConfiguration: LogConfiguration = {
      ...defaultLogConfiguration,
      ...deprecatedLogConfiguration,
      ...(hasOwnProp(Configuration.getConfig(), 'log') && Configuration.getConfig()?.log),
    };
    return logConfiguration;
  }

  public static getWorker(): WorkerConfiguration {
    Configuration.warnDeprecatedConfigurationKey(
      'useWorkerPool',
      undefined,
      "Use 'worker' section to define the type of worker process model instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'workerProcess',
      undefined,
      "Use 'worker' section to define the type of worker process model instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'workerStartDelay',
      undefined,
      "Use 'worker' section to define the worker start delay instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'chargingStationsPerWorker',
      undefined,
      "Use 'worker' section to define the number of element(s) per worker instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'elementStartDelay',
      undefined,
      "Use 'worker' section to define the worker's element start delay instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'workerPoolMinSize',
      undefined,
      "Use 'worker' section to define the worker pool minimum size instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'workerPoolSize;',
      undefined,
      "Use 'worker' section to define the worker pool maximum size instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'workerPoolMaxSize;',
      undefined,
      "Use 'worker' section to define the worker pool maximum size instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'workerPoolStrategy;',
      undefined,
      "Use 'worker' section to define the worker pool strategy instead",
    );
    const defaultWorkerConfiguration: WorkerConfiguration = {
      processType: WorkerProcessType.workerSet,
      startDelay: WorkerConstants.DEFAULT_WORKER_START_DELAY,
      elementsPerWorker: 'auto',
      elementStartDelay: WorkerConstants.DEFAULT_ELEMENT_START_DELAY,
      poolMinSize: WorkerConstants.DEFAULT_POOL_MIN_SIZE,
      poolMaxSize: WorkerConstants.DEFAULT_POOL_MAX_SIZE,
    };
    hasOwnProp(Configuration.getConfig(), 'workerPoolStrategy') &&
      delete Configuration.getConfig()?.workerPoolStrategy;
    const deprecatedWorkerConfiguration: WorkerConfiguration = {
      ...(hasOwnProp(Configuration.getConfig(), 'workerProcess') && {
        processType: Configuration.getConfig()?.workerProcess,
      }),
      ...(hasOwnProp(Configuration.getConfig(), 'workerStartDelay') && {
        startDelay: Configuration.getConfig()?.workerStartDelay,
      }),
      ...(hasOwnProp(Configuration.getConfig(), 'chargingStationsPerWorker') && {
        elementsPerWorker: Configuration.getConfig()?.chargingStationsPerWorker,
      }),
      ...(hasOwnProp(Configuration.getConfig(), 'elementStartDelay') && {
        elementStartDelay: Configuration.getConfig()?.elementStartDelay,
      }),
      ...(hasOwnProp(Configuration.getConfig(), 'workerPoolMinSize') && {
        poolMinSize: Configuration.getConfig()?.workerPoolMinSize,
      }),
      ...(hasOwnProp(Configuration.getConfig(), 'workerPoolMaxSize') && {
        poolMaxSize: Configuration.getConfig()?.workerPoolMaxSize,
      }),
    };
    Configuration.warnDeprecatedConfigurationKey(
      'poolStrategy',
      'worker',
      'Not publicly exposed to end users',
    );
    const workerConfiguration: WorkerConfiguration = {
      ...defaultWorkerConfiguration,
      ...deprecatedWorkerConfiguration,
      ...(hasOwnProp(Configuration.getConfig(), 'worker') && Configuration.getConfig()?.worker),
    };
    if (!Object.values(WorkerProcessType).includes(workerConfiguration.processType!)) {
      throw new SyntaxError(
        `Invalid worker process type '${workerConfiguration.processType}' defined in configuration`,
      );
    }
    return workerConfiguration;
  }

  public static workerPoolInUse(): boolean {
    return [WorkerProcessType.dynamicPool, WorkerProcessType.staticPool].includes(
      Configuration.getWorker().processType!,
    );
  }

  public static workerDynamicPoolInUse(): boolean {
    return Configuration.getWorker().processType === WorkerProcessType.dynamicPool;
  }

  public static getSupervisionUrls(): string | string[] | undefined {
    Configuration.warnDeprecatedConfigurationKey(
      'supervisionURLs',
      undefined,
      "Use 'supervisionUrls' instead",
    );
    // eslint-disable-next-line @typescript-eslint/dot-notation
    if (!isUndefined(Configuration.getConfig()!['supervisionURLs'])) {
      // eslint-disable-next-line @typescript-eslint/dot-notation
      Configuration.getConfig()!.supervisionUrls = Configuration.getConfig()!['supervisionURLs'] as
        | string
        | string[];
    }
    // Read conf
    return Configuration.getConfig()?.supervisionUrls;
  }

  public static getSupervisionUrlDistribution(): SupervisionUrlDistribution | undefined {
    Configuration.warnDeprecatedConfigurationKey(
      'distributeStationToTenantEqually',
      undefined,
      "Use 'supervisionUrlDistribution' instead",
    );
    Configuration.warnDeprecatedConfigurationKey(
      'distributeStationsToTenantsEqually',
      undefined,
      "Use 'supervisionUrlDistribution' instead",
    );
    return hasOwnProp(Configuration.getConfig(), 'supervisionUrlDistribution')
      ? Configuration.getConfig()?.supervisionUrlDistribution
      : SupervisionUrlDistribution.ROUND_ROBIN;
  }

  private static logPrefix = (): string => {
    return `${new Date().toLocaleString()} Simulator configuration |`;
  };

  private static warnDeprecatedConfigurationKey(
    key: string,
    sectionName?: string,
    logMsgToAppend = '',
  ) {
    if (
      sectionName &&
      !isUndefined(Configuration.getConfig()![sectionName]) &&
      !isUndefined((Configuration.getConfig()![sectionName] as Record<string, unknown>)[key])
    ) {
      console.error(
        `${chalk.green(Configuration.logPrefix())} ${chalk.red(
          `Deprecated configuration key '${key}' usage in section '${sectionName}'${
            logMsgToAppend.trim().length > 0 ? `. ${logMsgToAppend}` : ''
          }`,
        )}`,
      );
    } else if (!isUndefined(Configuration.getConfig()![key])) {
      console.error(
        `${chalk.green(Configuration.logPrefix())} ${chalk.red(
          `Deprecated configuration key '${key}' usage${
            logMsgToAppend.trim().length > 0 ? `. ${logMsgToAppend}` : ''
          }`,
        )}`,
      );
    }
  }

  // Read the config file
  private static getConfig(): ConfigurationData | null {
    if (!Configuration.configuration) {
      try {
        Configuration.configuration = JSON.parse(
          readFileSync(Configuration.configurationFile, 'utf8'),
        ) as ConfigurationData;
      } catch (error) {
        Configuration.handleFileException(
          Configuration.configurationFile,
          FileType.Configuration,
          error as NodeJS.ErrnoException,
          Configuration.logPrefix(),
        );
      }
      if (!Configuration.configurationFileWatcher) {
        Configuration.configurationFileWatcher = Configuration.getConfigurationFileWatcher();
      }
    }
    return Configuration.configuration;
  }

  private static getConfigurationFileWatcher(): FSWatcher | undefined {
    try {
      return watch(Configuration.configurationFile, (event, filename): void => {
        if (filename!.trim()!.length > 0 && event === 'change') {
          // Nullify to force configuration file reading
          Configuration.configuration = null;
          if (!isUndefined(Configuration.configurationChangeCallback)) {
            Configuration.configurationChangeCallback().catch((error) => {
              throw typeof error === 'string' ? new Error(error) : error;
            });
          }
        }
      });
    } catch (error) {
      Configuration.handleFileException(
        Configuration.configurationFile,
        FileType.Configuration,
        error as NodeJS.ErrnoException,
        Configuration.logPrefix(),
      );
    }
  }

  private static handleFileException(
    file: string,
    fileType: FileType,
    error: NodeJS.ErrnoException,
    logPrefix: string,
  ): void {
    const prefix = isNotEmptyString(logPrefix) ? `${logPrefix} ` : '';
    let logMsg: string;
    switch (error.code) {
      case 'ENOENT':
        logMsg = `${fileType} file ${file} not found:`;
        break;
      case 'EEXIST':
        logMsg = `${fileType} file ${file} already exists:`;
        break;
      case 'EACCES':
        logMsg = `${fileType} file ${file} access denied:`;
        break;
      case 'EPERM':
        logMsg = `${fileType} file ${file} permission denied:`;
        break;
      default:
        logMsg = `${fileType} file ${file} error:`;
    }
    console.error(`${chalk.green(prefix)}${chalk.red(`${logMsg} `)}`, error);
    throw error;
  }

  private static getDefaultPerformanceStorageUri(storageType: StorageType) {
    switch (storageType) {
      case StorageType.JSON_FILE:
        return Configuration.buildPerformanceUriFilePath(
          `${Constants.DEFAULT_PERFORMANCE_DIRECTORY}/${Constants.DEFAULT_PERFORMANCE_RECORDS_FILENAME}`,
        );
      case StorageType.SQLITE:
        return Configuration.buildPerformanceUriFilePath(
          `${Constants.DEFAULT_PERFORMANCE_DIRECTORY}/${Constants.DEFAULT_PERFORMANCE_RECORDS_DB_NAME}.db`,
        );
      default:
        throw new Error(`Performance storage URI is mandatory with storage type '${storageType}'`);
    }
  }

  private static buildPerformanceUriFilePath(file: string) {
    return `file://${join(resolve(dirname(fileURLToPath(import.meta.url)), '../'), file)}`;
  }
}