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
Release 1.0.27
[e-mobility-charging-stations-simulator.git]
/
src
/
charging-station
/
ocpp
/
OCPPIncomingRequestService.ts
diff --git
a/src/charging-station/ocpp/OCPPIncomingRequestService.ts
b/src/charging-station/ocpp/OCPPIncomingRequestService.ts
index 897127b6e2ffa029073db6e365c969356c4490da..9980e5d89ec7a8406ec82aae4ddf261820be5bf5 100644
(file)
--- a/
src/charging-station/ocpp/OCPPIncomingRequestService.ts
+++ b/
src/charging-station/ocpp/OCPPIncomingRequestService.ts
@@
-1,5
+1,6
@@
import ChargingStation from '../ChargingStation';
import { IncomingRequestCommand } from '../../types/ocpp/Requests';
import ChargingStation from '../ChargingStation';
import { IncomingRequestCommand } from '../../types/ocpp/Requests';
+import logger from '../../utils/Logger';
export default abstract class OCPPIncomingRequestService {
protected chargingStation: ChargingStation;
export default abstract class OCPPIncomingRequestService {
protected chargingStation: ChargingStation;
@@
-8,5
+9,10
@@
export default abstract class OCPPIncomingRequestService {
this.chargingStation = chargingStation;
}
this.chargingStation = chargingStation;
}
+ public handleIncomingRequestError(commandName: IncomingRequestCommand, error: Error): void {
+ logger.error(this.chargingStation.logPrefix() + ' Incoming request command ' + commandName + ' error: %j', error);
+ throw error;
+ }
+
public abstract handleRequest(messageId: string, commandName: IncomingRequestCommand, commandPayload: Record<string, unknown>): Promise<void>;
}
public abstract handleRequest(messageId: string, commandName: IncomingRequestCommand, commandPayload: Record<string, unknown>): Promise<void>;
}