X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fperformance%2Fstorage%2FMongoDBStorage.ts;h=f10481a0f96622cbe000e22def7da71e22936516;hb=5aefc345de84b04a0bd5529830948da4d5c2f547;hp=6bc43bbb8d16e15850aceda9a9b503cd6e1af00b;hpb=1f5df42ad17d09d3a1f53f6618eba325a403d7ad;p=e-mobility-charging-stations-simulator.git diff --git a/src/performance/storage/MongoDBStorage.ts b/src/performance/storage/MongoDBStorage.ts index 6bc43bbb..f10481a0 100644 --- a/src/performance/storage/MongoDBStorage.ts +++ b/src/performance/storage/MongoDBStorage.ts @@ -1,10 +1,11 @@ // Copyright Jerome Benoit. 2021. All Rights Reserved. -import Constants from '../../utils/Constants'; import { MongoClient } from 'mongodb'; -import Statistics from '../../types/Statistics'; -import { Storage } from './Storage'; + +import type Statistics from '../../types/Statistics'; import { StorageType } from '../../types/Storage'; +import Constants from '../../utils/Constants'; +import { Storage } from './Storage'; export class MongoDBStorage extends Storage { private readonly client: MongoClient | null; @@ -14,13 +15,18 @@ export class MongoDBStorage extends Storage { super(storageUri, logPrefix); this.client = new MongoClient(this.storageUri.toString()); this.connected = false; - this.dbName = this.storageUri.pathname.replace(/(?:^\/)|(?:\/$)/g, '') ?? Constants.DEFAULT_PERFORMANCE_RECORDS_DB_NAME; + this.dbName = + this.storageUri.pathname.replace(/(?:^\/)|(?:\/$)/g, '') ?? + Constants.DEFAULT_PERFORMANCE_RECORDS_DB_NAME; } public async storePerformanceStatistics(performanceStatistics: Statistics): Promise { try { this.checkDBConnection(); - await this.client.db(this.dbName).collection(Constants.PERFORMANCE_RECORDS_TABLE).insertOne(performanceStatistics); + await this.client + .db(this.dbName) + .collection(Constants.PERFORMANCE_RECORDS_TABLE) + .insertOne(performanceStatistics); } catch (error) { this.handleDBError(StorageType.MONGO_DB, error as Error, Constants.PERFORMANCE_RECORDS_TABLE); } @@ -50,10 +56,18 @@ export class MongoDBStorage extends Storage { private checkDBConnection() { if (!this?.client) { - throw new Error(`${this.logPrefix} ${this.getDBNameFromStorageType(StorageType.MONGO_DB)} client initialization failed while trying to issue a request`); + throw new Error( + `${this.logPrefix} ${this.getDBNameFromStorageType( + StorageType.MONGO_DB + )} client initialization failed while trying to issue a request` + ); } if (!this.connected) { - throw new Error(`${this.logPrefix} ${this.getDBNameFromStorageType(StorageType.MONGO_DB)} connection not opened while trying to issue a request`); + throw new Error( + `${this.logPrefix} ${this.getDBNameFromStorageType( + StorageType.MONGO_DB + )} connection not opened while trying to issue a request` + ); } } }