1 // Partial Copyright Jerome Benoit. 2021-2023. All Rights Reserved.
3 import type { JSONSchemaType
} from
'ajv';
5 import type { ChargingStation
} from
'../../../charging-station';
6 import { OCPPError
} from
'../../../exception';
11 type OCPP20BootNotificationRequest
,
12 type OCPP20HeartbeatRequest
,
14 type OCPP20StatusNotificationRequest
,
17 } from
'../../../types';
18 import { Utils
} from
'../../../utils';
23 type OCPPResponseService
,
26 const moduleName
= 'OCPP20RequestService';
28 export class OCPP20RequestService
extends OCPPRequestService
{
29 protected jsonSchemas
: Map
<OCPP20RequestCommand
, JSONSchemaType
<JsonObject
>>;
31 public constructor(ocppResponseService
: OCPPResponseService
) {
32 if (new.target
?.name
=== moduleName
) {
33 throw new TypeError(`Cannot construct ${new.target?.name} instances directly`);
35 super(OCPPVersion
.VERSION_20
, ocppResponseService
);
36 this.jsonSchemas
= new Map
<OCPP20RequestCommand
, JSONSchemaType
<JsonObject
>>([
38 OCPP20RequestCommand
.BOOT_NOTIFICATION
,
39 OCPP20ServiceUtils
.parseJsonSchemaFile
<OCPP20BootNotificationRequest
>(
40 '../../../assets/json-schemas/ocpp/2.0/BootNotificationRequest.json',
46 OCPP20RequestCommand
.HEARTBEAT
,
47 OCPP20ServiceUtils
.parseJsonSchemaFile
<OCPP20HeartbeatRequest
>(
48 '../../../assets/json-schemas/ocpp/2.0/HeartbeatRequest.json',
54 OCPP20RequestCommand
.STATUS_NOTIFICATION
,
55 OCPP20ServiceUtils
.parseJsonSchemaFile
<OCPP20StatusNotificationRequest
>(
56 '../../../assets/json-schemas/ocpp/2.0/StatusNotificationRequest.json',
62 this.buildRequestPayload
.bind(this);
65 public async requestHandler
<RequestType
extends JsonType
, ResponseType
extends JsonType
>(
66 chargingStation
: ChargingStation
,
67 commandName
: OCPP20RequestCommand
,
68 commandParams
?: JsonType
,
69 params
?: RequestParams
70 ): Promise
<ResponseType
> {
71 if (OCPP20ServiceUtils
.isRequestCommandSupported(chargingStation
, commandName
) === true) {
72 return (await this.sendMessage(
75 this.buildRequestPayload
<RequestType
>(chargingStation
, commandName
, commandParams
),
80 // OCPPError usage here is debatable: it's an error in the OCPP stack but not targeted to sendError().
82 ErrorType
.NOT_SUPPORTED
,
83 `Unsupported OCPP command '${commandName}'`,
89 private buildRequestPayload
<Request
extends JsonType
>(
90 chargingStation
: ChargingStation
,
91 commandName
: OCPP20RequestCommand
,
92 commandParams
?: JsonType
94 commandParams
= commandParams
as JsonObject
;
95 switch (commandName
) {
96 case OCPP20RequestCommand
.BOOT_NOTIFICATION
:
97 return commandParams
as unknown
as Request
;
98 case OCPP20RequestCommand
.HEARTBEAT
:
99 return OCPPConstants
.OCPP_RESPONSE_EMPTY
as unknown
as Request
;
100 case OCPP20RequestCommand
.STATUS_NOTIFICATION
:
102 timestamp
: new Date(),
104 } as unknown
as Request
;
106 // OCPPError usage here is debatable: it's an error in the OCPP stack but not targeted to sendError().
108 ErrorType
.NOT_SUPPORTED
,
109 // eslint-disable-next-line @typescript-eslint/restrict-template-expressions
110 `Unsupported OCPP command '${commandName}'`,