repositories
/
e-mobility-charging-stations-simulator.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Ensure the OCPP message sending stop if the WS is not open
[e-mobility-charging-stations-simulator.git]
/
src
/
performance
/
storage
/
MikroORMStorage.ts
diff --git
a/src/performance/storage/MikroORMStorage.ts
b/src/performance/storage/MikroORMStorage.ts
index 96740a8f4564204d2180bebb4b228c7313404861..c06617f6253683f17065e90c9b7cba8cfa45eb20 100644
(file)
--- a/
src/performance/storage/MikroORMStorage.ts
+++ b/
src/performance/storage/MikroORMStorage.ts
@@
-12,7
+12,7
@@
import { TsMorphMetadataProvider } from '@mikro-orm/reflection';
export class MikroORMStorage extends Storage {
private storageType: StorageType;
export class MikroORMStorage extends Storage {
private storageType: StorageType;
- private orm: MikroORM;
+ private orm: MikroORM
| null
;
constructor(storageURI: string, logPrefix: string, storageType: StorageType) {
super(storageURI, logPrefix);
constructor(storageURI: string, logPrefix: string, storageType: StorageType) {
super(storageURI, logPrefix);
@@
-30,11
+30,24
@@
export class MikroORMStorage extends Storage {
}
public async open(): Promise<void> {
}
public async open(): Promise<void> {
- this.orm = await MikroORM.init(this.getOptions(), true);
+ try {
+ if (!this?.orm) {
+ this.orm = await MikroORM.init(this.getOptions(), true);
+ }
+ } catch (error) {
+ this.handleDBError(this.storageType, error);
+ }
}
public async close(): Promise<void> {
}
public async close(): Promise<void> {
- await this.orm.close();
+ try {
+ if (this?.orm) {
+ await this.orm.close();
+ this.orm = null;
+ }
+ } catch (error) {
+ this.handleDBError(this.storageType, error);
+ }
}
private getDBName(): string {
}
private getDBName(): string {