Merge pull request #18 from juherr/bugfix/ocpp-answer-body

fix: the result payload must not have action

Author: shiv3

src/cp/OCPPMessageHandler.ts

@@ -83,7 +83,6 @@ export class OCPPMessageHandler {
     const messageId = this.generateMessageId();
     const payload: request.AuthorizeRequest = {idTag: tagId};
     this.sendRequest(
-      OCPPMessageType.CALL,
       OCPPAction.Authorize,
       messageId,
       payload
@@ -99,7 +98,6 @@ export class OCPPMessageHandler {
       timestamp: transaction.startTime.toISOString(),
     };
     this.sendRequest(
-      OCPPMessageType.CALL,
       OCPPAction.StartTransaction,
       messageId,
       payload,
@@ -116,7 +114,6 @@ export class OCPPMessageHandler {
       timestamp: transaction.stopTime!.toISOString(),
     };
     this.sendRequest(
-      OCPPMessageType.CALL,
       OCPPAction.StopTransaction,
       messageId,
       payload,
@@ -138,7 +135,6 @@ export class OCPPMessageHandler {
       meterSerialNumber: bootPayload.MeterSerialNumber,
     };
     this.sendRequest(
-      OCPPMessageType.CALL,
       OCPPAction.BootNotification,
       messageId,
       payload,
@@ -149,7 +145,6 @@ export class OCPPMessageHandler {
     const messageId = this.generateMessageId();
     const payload: request.HeartbeatRequest = {};
     this.sendRequest(
-      OCPPMessageType.CALL,
       OCPPAction.Heartbeat,
       messageId,
       payload
@@ -169,7 +164,6 @@ export class OCPPMessageHandler {
       ],
     };
     this.sendRequest(
-      OCPPMessageType.CALL,
       OCPPAction.MeterValues,
       messageId,
       payload
@@ -184,22 +178,20 @@ export class OCPPMessageHandler {
       status: status,
     };
     this.sendRequest(
-      OCPPMessageType.CALL,
       OCPPAction.StatusNotification,
       messageId,
       payload
     );
   }
 
   private sendRequest(
-    type: OCPPMessageType,
     action: OCPPAction,
     id: string,
     payload: OcppMessageRequestPayload,
     connectorId?: number
   ): void {
-    this._requests.add({type, action, id, payload, connectorId});
-    this._webSocket.send(type, id, action, payload);
+    this._requests.add({type: OCPPMessageType.CALL, action, id, payload, connectorId});
+    this._webSocket.sendAction(id, action, payload);
   }
 
   private handleIncomingMessage(
@@ -472,11 +464,9 @@ export class OCPPMessageHandler {
   }
 
   private sendCallResult(messageId: string, payload: OcppMessageResponsePayload): void {
-    this._webSocket.send(
-      OCPPMessageType.CALL_RESULT,
+    this._webSocket.sendResult(
       messageId,
-      "" as OCPPAction,
-      payload
+      payload,
     );
   }
 
@@ -489,11 +479,9 @@ export class OCPPMessageHandler {
       errorCode: errorCode,
       errorDescription: errorDescription,
     };
-    this._webSocket.send(
-      OCPPMessageType.CALL_ERROR,
+    this._webSocket.sendError(
       messageId,
-      "" as OCPPAction,
-      errorDetails
+      errorDetails,
     );
   }
 

src/cp/OCPPWebSocket.ts

@@ -104,14 +104,33 @@ export class OCPPWebSocket {
     }
   }
 
-  public send(
-    messageType: OCPPMessageType,
+  public sendAction(
     messageId: string,
     action: OCPPAction,
-    payload: OcppMessagePayload
+    payload: OcppMessageRequestPayload,
   ): void {
+    const message = JSON.stringify([OCPPMessageType.CALL, messageId, action, payload]);
+    this.send(message);
+  }
+
+  public sendResult(
+      messageId: string,
+      payload: OcppMessageResponsePayload,
+  ): void {
+    const message = JSON.stringify([OCPPMessageType.CALL_RESULT, messageId, payload]);
+    this.send(message);
+  }
+
+  public sendError(
+      messageId: string,
+      payload: OcppMessageErrorPayload,
+  ): void {
+    const message = JSON.stringify([OCPPMessageType.CALL_ERROR, messageId, payload]);
+    this.send(message);
+  }
+
+  private send(message: string): void {
     if (this._ws && this._ws.readyState === WebSocket.OPEN) {
-      const message = JSON.stringify([messageType, messageId, action, payload]);
       this._ws.send(message);
       this._logger.log(`Sent: ${message}`);
     } else {