Support errorCode in triggered StatusNotifications (#359)

* add triggerStatusNotif which is aware about errorData

* update changelog

Author: matth-x

CHANGELOG.md

@@ -43,6 +43,7 @@
 - UnlockConnector NotSupported if connectorId invalid ([#344](https://github.com/matth-x/MicroOcpp/pull/344))
 - Fix regression bug of [#345](https://github.com/matth-x/MicroOcpp/pull/345) ([#353](https://github.com/matth-x/MicroOcpp/pull/353), [#356](https://github.com/matth-x/MicroOcpp/pull/356))
 - Correct MeterValue PreBoot timestamp ([#354](https://github.com/matth-x/MicroOcpp/pull/354))
+- Send errorCode in triggered StatusNotif ([#359](https://github.com/matth-x/MicroOcpp/pull/359))
 
 ## [1.1.0] - 2024-05-21
 

src/MicroOcpp/Model/ConnectorBase/Connector.cpp

@@ -1271,6 +1271,37 @@ std::unique_ptr<Request> Connector::fetchFrontRequest() {
     return nullptr;
 }
 
+bool Connector::triggerStatusNotification() {
+
+    ErrorData errorData {nullptr};
+    errorData.severity = 0;
+
+    if (reportedErrorIndex >= 0) {
+        errorData = errorDataInputs[reportedErrorIndex].operator()();
+    } else {
+        //find errorData with maximum severity
+        for (auto i = errorDataInputs.size(); i >= 1; i--) {
+            auto index = i - 1;
+            ErrorData error = errorDataInputs[index].operator()();
+            if (error.isError && error.severity >= errorData.severity) {
+                errorData = error;
+            }
+        }
+    }
+
+    auto statusNotification = makeRequest(new Ocpp16::StatusNotification(
+                connectorId,
+                getStatus(),
+                context.getModel().getClock().now(),
+                errorData));
+
+    statusNotification->setTimeout(60000);
+
+    context.getRequestQueue().sendRequestPreBoot(std::move(statusNotification));
+
+    return true;
+}
+
 unsigned int Connector::getTxNrBeginHistory() {
     return txNrBegin;
 }

src/MicroOcpp/Model/ConnectorBase/Connector.h

@@ -158,6 +158,8 @@ class Connector : public RequestEmitter, public MemoryManaged {
     unsigned int getFrontRequestOpNr() override;
     std::unique_ptr<Request> fetchFrontRequest() override;
 
+    bool triggerStatusNotification();
+
     unsigned int getTxNrBeginHistory(); //if getTxNrBeginHistory() != getTxNrFront(), then return value is the txNr of the oldest tx history entry. If equal to getTxNrFront(), then the history is empty
     unsigned int getTxNrFront(); //if getTxNrEnd() != getTxNrFront(), then return value is the txNr of the oldest transaction queued to be sent to the server. If equal to getTxNrEnd(), then there is no tx to be sent to the server
     unsigned int getTxNrEnd(); //upper limit for the range of valid txNrs

src/MicroOcpp/Operations/TriggerMessage.cpp

@@ -5,7 +5,6 @@
 #include <MicroOcpp/Operations/TriggerMessage.h>
 #include <MicroOcpp/Model/ConnectorBase/Connector.h>
 #include <MicroOcpp/Model/Metering/MeteringService.h>
-#include <MicroOcpp/Operations/StatusNotification.h>
 #include <MicroOcpp/Model/Model.h>
 #include <MicroOcpp/Core/Context.h>
 #include <MicroOcpp/Core/Request.h>
@@ -63,16 +62,9 @@ void TriggerMessage::processReq(JsonObject payload) {
 
         for (auto i = cIdRangeBegin; i < cIdRangeEnd; i++) {
             auto connector = context.getModel().getConnector(i);
-
-            auto statusNotification = makeRequest(new Ocpp16::StatusNotification(
-                        i,
-                        connector->getStatus(), //will be determined in StatusNotification::initiate
-                        context.getModel().getClock().now()));
-
-            statusNotification->setTimeout(60000);
-
-            context.getRequestQueue().sendRequestPreBoot(std::move(statusNotification));
-            statusMessage = "Accepted";
+            if (connector->triggerStatusNotification()) {
+                statusMessage = "Accepted";
+            }
         }
     } else {
         auto msg = context.getOperationRegistry().deserializeOperation(requestedMessage);