Use eslint extension for import sorting instead of unmaintained external ones

[e-mobility-charging-stations-simulator.git] / src / performance / storage / Storage.ts

// Copyright Jerome Benoit. 2021. All Rights Reserved.

import { URL } from 'url';

import { EmptyObject } from '../../types/EmptyObject';
import { HandleErrorParams } from '../../types/Error';
import Statistics from '../../types/Statistics';
import { DBName, StorageType } from '../../types/Storage';
import logger from '../../utils/Logger';
import Utils from '../../utils/Utils';

export abstract class Storage {
  protected readonly storageUri: URL;
  protected readonly logPrefix: string;
  protected dbName: string;

  constructor(storageUri: string, logPrefix: string) {
    this.storageUri = new URL(storageUri);
    this.logPrefix = logPrefix;
  }

  protected handleDBError(
    type: StorageType,
    error: Error,
    table?: string,
    params: HandleErrorParams<EmptyObject> = { throwError: false }
  ): void {
    const inTableOrCollectionStr =
      (!Utils.isNullOrUndefined(table) || !table) && ` in table or collection '${table}'`;
    logger.error(
      `${this.logPrefix} ${this.getDBNameFromStorageType(type)} error '${
        error.message
      }'${inTableOrCollectionStr}: %j`,
      error
    );
    if (params?.throwError) {
      throw error;
    }
  }

  protected getDBNameFromStorageType(type: StorageType): DBName {
    switch (type) {
      case StorageType.MARIA_DB:
        return DBName.MARIA_DB;
      case StorageType.MONGO_DB:
        return DBName.MONGO_DB;
      case StorageType.MYSQL:
        return DBName.MYSQL;
      case StorageType.SQLITE:
        return DBName.SQLITE;
    }
  }

  public abstract open(): void | Promise<void>;
  public abstract close(): void | Promise<void>;
  public abstract storePerformanceStatistics(
    performanceStatistics: Statistics
  ): void | Promise<void>;
}