-// Copyright Jerome Benoit. 2021-2023. All Rights Reserved.
+// Copyright Jerome Benoit. 2021-2024. All Rights Reserved.
-import { URL } from 'node:url';
+import { URL } from 'node:url'
import {
DBName,
type EmptyObject,
type HandleErrorParams,
type Statistics,
- StorageType,
-} from '../../types';
-import { ErrorUtils, Utils, logger } from '../../utils';
+ StorageType
+} from '../../types/index.js'
+import { logger, setDefaultErrorParams } from '../../utils/index.js'
export abstract class Storage {
- protected readonly storageUri: URL;
- protected readonly logPrefix: string;
- protected dbName!: string;
+ protected readonly storageUri: URL
+ protected readonly logPrefix: string
+ protected dbName!: string
+ private static readonly performanceStatistics = new Map<string, Statistics>()
- constructor(storageUri: string, logPrefix: string) {
- this.storageUri = new URL(storageUri);
- this.logPrefix = logPrefix;
+ constructor (storageUri: string, logPrefix: string) {
+ this.storageUri = new URL(storageUri)
+ this.logPrefix = logPrefix
}
- protected handleDBError(
+ protected handleDBError (
type: StorageType,
error: Error,
table?: string,
params: HandleErrorParams<EmptyObject> = { throwError: false, consoleOut: false }
): void {
- ErrorUtils.setDefaultErrorParams(params, { throwError: false, consoleOut: false });
- const inTableOrCollectionStr =
- (!Utils.isNullOrUndefined(table) || !table) && ` in table or collection '${table}'`;
+ setDefaultErrorParams(params, { throwError: false, consoleOut: false })
+ const inTableOrCollectionStr = table != null && ` in table or collection '${table}'`
logger.error(
`${this.logPrefix} ${this.getDBNameFromStorageType(type)} error '${
error.message
}'${inTableOrCollectionStr}:`,
error
- );
- if (params?.throwError) {
- throw error;
+ )
+ if (params.throwError === true) {
+ throw error
}
}
- protected getDBNameFromStorageType(type: StorageType): DBName | undefined {
+ protected getDBNameFromStorageType (type: StorageType): DBName | undefined {
switch (type) {
+ case StorageType.SQLITE:
+ return DBName.SQLITE
case StorageType.MARIA_DB:
- return DBName.MARIA_DB;
- case StorageType.MONGO_DB:
- return DBName.MONGO_DB;
+ return DBName.MARIA_DB
case StorageType.MYSQL:
- return DBName.MYSQL;
- case StorageType.SQLITE:
- return DBName.SQLITE;
+ return DBName.MYSQL
+ case StorageType.MONGO_DB:
+ return DBName.MONGO_DB
}
}
- public abstract open(): void | Promise<void>;
- public abstract close(): void | Promise<void>;
- public abstract storePerformanceStatistics(
+ public getPerformanceStatistics (): IterableIterator<Statistics> {
+ return Storage.performanceStatistics.values()
+ }
+
+ protected setPerformanceStatistics (performanceStatistics: Statistics): void {
+ Storage.performanceStatistics.set(performanceStatistics.id, performanceStatistics)
+ }
+
+ protected clearPerformanceStatistics (): void {
+ Storage.performanceStatistics.clear()
+ }
+
+ public abstract open (): void | Promise<void>
+ public abstract close (): void | Promise<void>
+ public abstract storePerformanceStatistics (
performanceStatistics: Statistics
- ): void | Promise<void>;
+ ): void | Promise<void>
}