X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fperformance%2FPerformanceStatistics.ts;h=6513bba5e98ade3a08b00f8e3fb41680c5a66296;hb=976d11ec6d2d38a5a82440de79f059638e28cdbd;hp=7338fa24cbfa8d3c1908b6c781ef2df7df4d1847;hpb=100680888f3b49453ddb4081988a480ee3030d07;p=e-mobility-charging-stations-simulator.git diff --git a/src/performance/PerformanceStatistics.ts b/src/performance/PerformanceStatistics.ts index 7338fa24..6513bba5 100644 --- a/src/performance/PerformanceStatistics.ts +++ b/src/performance/PerformanceStatistics.ts @@ -1,17 +1,19 @@ // Partial Copyright Jerome Benoit. 2021. All Rights Reserved. -import { CircularArray, DEFAULT_CIRCULAR_ARRAY_SIZE } from '../utils/CircularArray'; -import { IncomingRequestCommand, RequestCommand } from '../types/ocpp/Requests'; import { PerformanceEntry, PerformanceObserver, performance } from 'perf_hooks'; -import Statistics, { StatisticsData, TimeSeries } from '../types/Statistics'; +import type { URL } from 'url'; +import { parentPort } from 'worker_threads'; -import { ChargingStationWorkerMessageEvents } from '../types/ChargingStationWorker'; -import Configuration from '../utils/Configuration'; +import { MessageChannelUtils } from '../charging-station/MessageChannelUtils'; import { MessageType } from '../types/ocpp/MessageType'; -import { URL } from 'url'; -import Utils from '../utils/Utils'; +import type { IncomingRequestCommand, RequestCommand } from '../types/ocpp/Requests'; +import type Statistics from '../types/Statistics'; +// eslint-disable-next-line no-duplicate-imports +import type { StatisticsData, TimeSeries } from '../types/Statistics'; +import { CircularArray, DEFAULT_CIRCULAR_ARRAY_SIZE } from '../utils/CircularArray'; +import Configuration from '../utils/Configuration'; import logger from '../utils/Logger'; -import { parentPort } from 'worker_threads'; +import Utils from '../utils/Utils'; export default class PerformanceStatistics { private static readonly instances: Map = new Map< @@ -38,7 +40,11 @@ export default class PerformanceStatistics { }; } - public static getInstance(objId: string, objName: string, uri: URL): PerformanceStatistics { + public static getInstance( + objId: string, + objName: string, + uri: URL + ): PerformanceStatistics | undefined { if (!PerformanceStatistics.instances.has(objId)) { PerformanceStatistics.instances.set(objId, new PerformanceStatistics(objId, objName, uri)); } @@ -101,6 +107,7 @@ export default class PerformanceStatistics { } break; default: + // eslint-disable-next-line @typescript-eslint/restrict-template-expressions logger.error(`${this.logPrefix()} wrong message type ${messageType}`); break; } @@ -215,12 +222,7 @@ export default class PerformanceStatistics { } private addPerformanceEntryToStatistics(entry: PerformanceEntry): void { - let entryName = entry.name; - // Rename entry name - const MAP_NAME: Record = {}; - if (MAP_NAME[entryName]) { - entryName = MAP_NAME[entryName]; - } + const entryName = entry.name; // Initialize command statistics if (!this.statistics.statisticsData.has(entryName)) { this.statistics.statisticsData.set(entryName, {}); @@ -278,10 +280,9 @@ export default class PerformanceStatistics { ) ); if (Configuration.getPerformanceStorage().enabled) { - parentPort.postMessage({ - id: ChargingStationWorkerMessageEvents.PERFORMANCE_STATISTICS, - data: this.statistics, - }); + parentPort.postMessage( + MessageChannelUtils.buildPerformanceStatisticsMessage(this.statistics) + ); } }