Fixing transactionData omitted in StopTransaction.req

include/ocpp/v16/transaction.hpp

@@ -38,6 +38,7 @@
     std::optional<int32_t> reservation_id;
     bool active;
     bool finished;
+    bool has_signed_meter_values;
     std::unique_ptr<Everest::SteadyTimer> meter_values_sample_timer;
     std::string start_transaction_message_id;
     std::string stop_transaction_message_id;
@@ -130,6 +131,15 @@
     /// \brief Sets the finished flag for this transaction. This is done when a StopTransaction.req has been pushed to
     /// the message queue
     void set_finished();
+
+    /// \brief Sets the has_signed_meter_value flag for this transaction, this function is called
+    /// from \p on_transaction_started and \p on_transaction_stopped
+    void set_has_signed_meter_values();
+
+    /// \brief Indicates if this transaction has signed meter values or not, this function is called
+    /// from \p on_transaction_started and \p on_transaction_stopped
+    /// \returns a boolean value indicating if this transaction has signed meter values or not
+    bool get_has_signed_meter_values();
 };
 
 /// \brief Contains transactions for all available connectors and manages access to these transactions

lib/ocpp/v16/charge_point_impl.cpp

@@ -3379,7 +3379,8 @@ ChargePointImpl::get_filtered_transaction_data(const std::shared_ptr<Transaction
 
     std::vector<TransactionData> filtered_transaction_data_vec;
 
-    if (!stop_txn_sampled_data_measurands.empty() or !stop_txn_aligned_data_measurands.empty()) {
+    if (!stop_txn_sampled_data_measurands.empty() or !stop_txn_aligned_data_measurands.empty() or
+        transaction->get_has_signed_meter_values()) {
         std::vector<TransactionData> transaction_data_vec = transaction->get_transaction_data();
         for (const auto& entry : transaction_data_vec) {
             std::vector<SampledValue> sampled_values;

lib/ocpp/v16/transaction.cpp

@@ -21,6 +21,7 @@ Transaction::Transaction(const int32_t& connector, const std::string& session_id
     reservation_id(reservation_id),
     active(true),
     finished(false),
+    has_signed_meter_values(false),
     meter_values_sample_timer(std::move(meter_values_sample_timer)),
     start_transaction_message_id(""),
     stop_transaction_message_id("") {
@@ -38,6 +39,13 @@ void Transaction::add_meter_value(MeterValue meter_value) {
     if (this->active) {
         std::lock_guard<std::mutex> lock(this->meter_values_mutex);
         this->meter_values.push_back(meter_value);
+
+        if (std::find_if(meter_value.sampledValue.begin(), meter_value.sampledValue.end(),
+                         [](SampledValue const& SampledValueItem) {
+                             return SampledValueItem.format == ValueFormat::SignedData;
+                         }) != meter_value.sampledValue.end()) {
+            this->set_has_signed_meter_values();
+        }
     }
 }
 
@@ -118,6 +126,15 @@ void Transaction::add_stop_energy_wh(std::shared_ptr<StampedEnergyWh> stop_energ
     this->stop();
 }
 
+void Transaction::set_has_signed_meter_values() {
+    this->has_signed_meter_values = true;
+}
+
+bool Transaction::get_has_signed_meter_values() {
+    std::lock_guard<std::mutex> lock(this->meter_values_mutex);
+    return this->has_signed_meter_values;
+}
+
 std::shared_ptr<StampedEnergyWh> Transaction::get_stop_energy_wh() {
     return this->stop_energy_wh;
 }