chore: remove unused method of probe module

Signed-off-by: Valentin Dimov <[email protected]>

everest-testing/src/everest/testing/core_utils/probe_module.py

@@ -88,13 +88,6 @@ def subscribe_variable_to_queue(self, connection_id: str, var_name: str):
         self._mod.subscribe_variable(self._setup.connections[connection_id][0], var_name, lambda message, _queue=queue: _queue.put(message))
         return queue
 
-    def init_done(self):
-        """
-        Signal that the initialization of the probe module is done. Call this after you've implemented needed commands and set up subscriptions.
-        """
-        self._mod.init_done(self._ready)
-        logging.info("ProbeModule init done")
-
     def _ready(self):
         """
         Internal function: callback triggered by the EVerest framework when all modules have been initialized

everest-testing/src/everest/testing/ocpp_utils/libocpp_configuration_helper.py.orig

@@ -0,0 +1,99 @@
+import json
+import os
+import shutil
+from abc import ABC, abstractmethod
+from pathlib import Path
+import subprocess
+import logging
+
+from everest.testing.ocpp_utils.common import OCPPVersion
+
+
+class LibOCPPConfigurationHelperBase(ABC):
+    """ Helper for parsing / adapting the LibOCPP configuration and dumping it a database file. """
+
+    def generate_ocpp_config(self,
+                             target_ocpp_config_file: Path,
+                             target_ocpp_user_config_file: Path,
+                             source_ocpp_config_file: Path,
+                             central_system_port: str):
+        config = self._get_occp_config(central_system_port=central_system_port,
+                                       source_ocpp_config_file=source_ocpp_config_file)
+        with target_ocpp_config_file.open("w") as f:
+            json.dump(config, f)
+        target_ocpp_user_config_file.write_text("{}")
+
+    @abstractmethod
+    def _get_occp_config(self, central_system_port, source_ocpp_config_file: Path):
+        pass
+
+    @staticmethod
+    def install_default_ocpp_certificates(source_certs_directory: Path, target_certs_directory: Path, ):
+        # install default certificates
+        shutil.copytree(
+            str(source_certs_directory / "ca"), str(target_certs_directory / "ca"), dirs_exist_ok=True)
+        shutil.copytree(
+            str(source_certs_directory / "client"), str(target_certs_directory / "client"), dirs_exist_ok=True)
+
+
+class LibOCPP16ConfigurationHelper(LibOCPPConfigurationHelperBase):
+
+    def _get_occp_config(self, central_system_port, source_ocpp_config_file: Path):
+        ocpp_config = json.loads(source_ocpp_config_file.read_text())
+        charge_point_id = ocpp_config["Internal"]["ChargePointId"]
+        ocpp_config["Internal"][
+            "CentralSystemURI"] = f"127.0.0.1:{central_system_port}/{charge_point_id}"
+        return ocpp_config
+
+
+class LibOCPP201ConfigurationHelper(LibOCPPConfigurationHelperBase):
+
+    @staticmethod
+    def create_temporary_ocpp_configuration_db(libocpp_path: Path,
+                                               ocpp_configuration_file: Path,
+                                               target_directory: Path):
+        wd = libocpp_path / "config/v201"
+        subprocess.run(
+            f"python3 {libocpp_path / 'config/v201/init_device_model_db.py'} --out {target_directory / 'device_model_storage.db'} --schemas {libocpp_path / 'config/v201/component_schemas'}",
+<<<<<<< Updated upstream
+            cwd=wd
+=======
+            cwd=wd,
+            check=True,
+            shell=True
+>>>>>>> Stashed changes
+        )
+        subprocess.run(
+            f"python3 {libocpp_path / 'config/v201/insert_device_model_config.py'} --config {ocpp_configuration_file} --db {target_directory / 'device_model_storage.db'}",
+            cwd=wd,
+            check=True,
+            shell=True
+        )
+
+    def _get_occp_config(self, central_system_port, source_ocpp_config_file: Path):
+        ocpp_config = json.loads(source_ocpp_config_file.read_text())
+        charge_point_id = self._get_value_from_v201_config(
+            ocpp_config, "InternalCtrlr", "ChargePointId", "Actual")
+        network_connection_profiles = json.loads(self._get_value_from_v201_config(
+            ocpp_config, "InternalCtrlr", "NetworkConnectionProfiles", "Actual"))
+        network_connection_profiles[0]["connectionData"][
+            "ocppCsmsUrl"] = f"ws://127.0.0.1:{central_system_port}/{charge_point_id}"
+        self._set_value_in_v201_config(ocpp_config, "InternalCtrlr", "NetworkConnectionProfiles",
+                                       "Actual", json.dumps(network_connection_profiles))
+        return ocpp_config
+
+    @staticmethod
+    def _get_value_from_v201_config(ocpp_config: json, component_name: str, variable_name: str,
+                                    variable_attribute_type: str):
+        for component in ocpp_config:
+            if (component["name"] == component_name):
+                return component["variables"][variable_name]["attributes"][variable_attribute_type]
+
+    @staticmethod
+    def _set_value_in_v201_config(ocpp_config: json, component_name: str, variable_name: str,
+                                  variable_attribute_type: str,
+                                  value: str):
+        for component in ocpp_config:
+            if (component["name"] == component_name):
+                component["variables"][variable_name]["attributes"][variable_attribute_type] = value
+                return