feature(OCPP): Subscribing to powermeter public key and call set_powermeter_public_key at the ChargePoint when it is recieved

Added e2e test case for powermeter public key

Signed-off-by: Piet Gömpel <pietgoempel@gmail.com>

Author: Pietfried

modules/EVSE/OCPP/OCPP.cpp

@@ -338,6 +338,18 @@ void OCPP::init_evse_subscriptions() {
 
             this->process_session_event(evse_id, session_event);
         });
+
+        evse->subscribe_powermeter_public_key_ocmf([this, evse_id](std::string public_key_ocmf) {
+            if (!this->started) {
+                this->event_queue.emplace(evse_id, PowermeterPublicKey{public_key_ocmf});
+                return;
+            }
+
+            if (!this->charge_point->set_powermeter_public_key(evse_id, public_key_ocmf)) {
+                EVLOG_error << "Failed to set powermeter public key for evse_id: " << evse_id;
+            }
+        });
+
         evse_id++;
     }
 
@@ -1077,6 +1089,9 @@ void OCPP::ready() {
                 [&](const types::system::FirmwareUpdateStatus& fw) {
                     charge_point->on_firmware_update_status_notification(
                         fw.request_id, conversions::to_ocpp_firmware_status_notification(fw.firmware_update_status));
+                },
+                [&](const PowermeterPublicKey public_key) {
+                    this->charge_point->set_powermeter_public_key(queued_event.evse_id, public_key.value);
                 }},
             queued_event.data);
     }

modules/EVSE/OCPP/OCPP.hpp

@@ -48,9 +48,12 @@
 
 struct ErrorRaised : public Everest::error::Error {};
 struct ErrorCleared : public Everest::error::Error {};
+struct PowermeterPublicKey {
+    std::string value;
+};
 
 using EventData = std::variant<types::evse_manager::SessionEvent, ErrorRaised, ErrorCleared, types::system::LogStatus,
-                               types::system::FirmwareUpdateStatus>;
+                               types::system::FirmwareUpdateStatus, PowermeterPublicKey>;
 
 struct Event {
     EventData data;

modules/Simulation/YetiSimulator/powermeter/powermeterImpl.cpp

@@ -10,6 +10,7 @@ void powermeterImpl::init() {
 }
 
 void powermeterImpl::ready() {
+    this->publish_public_key_ocmf("TESTPUBLICKEY" + std::to_string(this->mod->config.connector_id));
 }
 
 types::powermeter::TransactionStartResponse

tests/ocpp_tests/test_sets/everest-aux/config/everest-config-two-connectors.yaml

@@ -44,7 +44,7 @@ active_modules:
   yeti_driver_2:
     module: YetiSimulator
     config_module:
-      connector_id: 1
+      connector_id: 2
   car_simulator_1:
     module: EvManager
     config_module:

tests/ocpp_tests/test_sets/ocpp16/eichrecht.py

@@ -0,0 +1,127 @@
+import pytest
+
+from everest.testing.core_utils.controller.test_controller_interface import (
+    TestController,
+)
+from everest.testing.ocpp_utils.charge_point_utils import (
+    wait_for_and_validate,
+    TestUtility,
+)
+from everest.testing.ocpp_utils.central_system import ChargePoint16
+from everest.testing.ocpp_utils.fixtures import test_utility, charge_point_v16
+from everest_test_utils import get_everest_config_path_str
+
+from ocpp.v16 import call_result
+
+
+@pytest.mark.asyncio
+@pytest.mark.everest_core_config(
+    get_everest_config_path_str("everest-config-two-connectors.yaml")
+)
+async def test_meter_public_key(
+    charge_point_v16: ChargePoint16, test_utility: TestUtility
+):
+    await charge_point_v16.get_configuration_req(key=["MeterPublicKey[1]"])
+    assert await wait_for_and_validate(
+        test_utility,
+        charge_point_v16,
+        "GetConfiguration",
+        call_result.GetConfiguration(
+            [{"key": "MeterPublicKey[1]", "readonly": True, "value": "TESTPUBLICKEY1"}]
+        ),
+    )
+
+    await charge_point_v16.get_configuration_req(key=["MeterPublicKey[2]"])
+    assert await wait_for_and_validate(
+        test_utility,
+        charge_point_v16,
+        "GetConfiguration",
+        call_result.GetConfiguration(
+            [{"key": "MeterPublicKey[2]", "readonly": True, "value": "TESTPUBLICKEY2"}]
+        ),
+    )
+
+    await charge_point_v16.get_configuration_req(key=["MeterPublicKey[3]"])
+
+    assert await wait_for_and_validate(
+        test_utility,
+        charge_point_v16,
+        "GetConfiguration",
+        {"unknownKey": ["MeterPublicKey[3]"]}
+    )
+
+    test_utility.messages.clear()
+
+    response : call_result.GetConfiguration = await charge_point_v16.get_configuration_req()
+
+    assert any(
+        entry['key'] == "MeterPublicKey[1]" and entry['value'] == "TESTPUBLICKEY1"
+        for entry in response.configuration_key)
+
+    assert any(
+        entry['key'] == "MeterPublicKey[2]" and entry['value'] == "TESTPUBLICKEY2"
+        for entry in response.configuration_key)
+    
+    await charge_point_v16.get_configuration_req(key=["MeterPublicKey[]"])
+
+    assert await wait_for_and_validate(
+        test_utility,
+        charge_point_v16,
+        "GetConfiguration",
+        {"unknownKey": ["MeterPublicKey[]"]}
+    )
+
+    await charge_point_v16.get_configuration_req(key=["MeterPublicKey[MeterPublicKey[1]]"])
+
+    assert await wait_for_and_validate(
+        test_utility,
+        charge_point_v16,
+        "GetConfiguration",
+        {"unknownKey": ["MeterPublicKey[MeterPublicKey[1]]"]}
+    )
+    
+    await charge_point_v16.get_configuration_req(key=["MeterPublicKey[1X"])
+
+    assert await wait_for_and_validate(
+        test_utility,
+        charge_point_v16,
+        "GetConfiguration",
+        {"unknownKey": ["MeterPublicKey[1X"]}
+    )
+
+    await charge_point_v16.get_configuration_req(key=["MeterPublicKey[1X]"])
+
+    assert await wait_for_and_validate(
+        test_utility,
+        charge_point_v16,
+        "GetConfiguration",
+        {"unknownKey": ["MeterPublicKey[1X]"]}
+    )
+
+    await charge_point_v16.get_configuration_req(key=["MeterPublicKey[banana]"])
+
+    assert await wait_for_and_validate(
+        test_utility,
+        charge_point_v16,
+        "GetConfiguration",
+        {"unknownKey": ["MeterPublicKey[banana]"]}
+    )
+
+    await charge_point_v16.get_configuration_req(key=["MeterPublicKey[0]"])
+
+    assert await wait_for_and_validate(
+        test_utility,
+        charge_point_v16,
+        "GetConfiguration",
+        {"unknownKey": ["MeterPublicKey[0]"]}
+    )
+
+    await charge_point_v16.change_configuration_req(
+        key="MeterPublicKey[1]", value="TEST"
+    )
+    assert await wait_for_and_validate(
+        test_utility,
+        charge_point_v16,
+        "ChangeConfiguration",
+        {"status": "Rejected"}
+    )