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
Fix and add log messages
[e-mobility-charging-stations-simulator.git]
/
src
/
charging-station
/
ChargingStation.ts
diff --git
a/src/charging-station/ChargingStation.ts
b/src/charging-station/ChargingStation.ts
index e531aa0f04bc5962518998a1affa76ded4b477c5..547a4f3693321bf271d23cdae07c6cb51df01876 100644
(file)
--- a/
src/charging-station/ChargingStation.ts
+++ b/
src/charging-station/ChargingStation.ts
@@
-1,7
+1,7
@@
// Partial Copyright Jerome Benoit. 2021-2023. All Rights Reserved.
// Partial Copyright Jerome Benoit. 2021-2023. All Rights Reserved.
-import crypto from 'crypto';
import fs from 'fs';
import fs from 'fs';
+import crypto from 'node:crypto';
import path from 'path';
import { URL } from 'url';
import { parentPort } from 'worker_threads';
import path from 'path';
import { URL } from 'url';
import { parentPort } from 'worker_threads';
@@
-65,6
+65,7
@@
import {
type IncomingRequest,
IncomingRequestCommand,
type MeterValuesRequest,
type IncomingRequest,
IncomingRequestCommand,
type MeterValuesRequest,
+ type OutgoingRequest,
RequestCommand,
type ResponseCallback,
type StatusNotificationRequest,
RequestCommand,
type ResponseCallback,
type StatusNotificationRequest,
@@
-769,6
+770,12
@@
export default class ChargingStation {
this.messageBuffer.forEach((message) => {
// TODO: evaluate the need to track performance
this.wsConnection.send(message);
this.messageBuffer.forEach((message) => {
// TODO: evaluate the need to track performance
this.wsConnection.send(message);
+ const [messageType] = JSON.parse(message) as OutgoingRequest | Response | ErrorResponse;
+ logger.debug(
+ `${this.logPrefix()} >> Buffered ${OCPPServiceUtils.getMessageTypeString(
+ messageType
+ )} payload sent: ${message}`
+ );
this.messageBuffer.delete(message);
});
}
this.messageBuffer.delete(message);
});
}
@@
-1568,7
+1575,7
@@
export default class ChargingStation {
logger.debug(
`${this.logPrefix()} << Command '${
requestCommandName ?? Constants.UNKNOWN_COMMAND
logger.debug(
`${this.logPrefix()} << Command '${
requestCommandName ?? Constants.UNKNOWN_COMMAND
- }' received error payload: ${JSON.stringify(request)}`
+ }' received error
response
payload: ${JSON.stringify(request)}`
);
errorCallback(new OCPPError(errorType, errorMessage, requestCommandName, errorDetails));
break;
);
errorCallback(new OCPPError(errorType, errorMessage, requestCommandName, errorDetails));
break;