Rename DeviceModelStorage to DeviceModelInterface

config/v201/component_config/standardized/AlignedDataCtrlr.json

@@ -6,6 +6,7 @@
   "properties": {
     "AlignedDataCtrlrEnabled": {
       "variable_name": "Enabled",
+      "source": "OCPP",
       "characteristics": {
         "supportsMonitoring": true,
         "dataType": "boolean"
@@ -22,6 +23,7 @@
     },
     "AlignedDataCtrlrAvailable": {
       "variable_name": "Available",
+      "source": "OCPP",
       "characteristics": {
         "supportsMonitoring": true,
         "dataType": "boolean"
@@ -38,6 +40,7 @@
     },
     "AlignedDataInterval": {
       "variable_name": "Interval",
+      "source": "OCPP",
       "characteristics": {
         "unit": "s",
         "supportsMonitoring": true,

config/v201/component_config/standardized/ClockCtrlr.json

@@ -6,6 +6,7 @@
   "properties": {
     "ClockCtrlrEnabled": {
       "variable_name": "Enabled",
+      "source": "OCPP",
       "characteristics": {
         "supportsMonitoring": true,
         "dataType": "boolean"

config/v201/component_config/standardized/SecurityCtrlr.json

@@ -22,6 +22,7 @@
     },
     "AdditionalRootCertificateCheck": {
       "variable_name": "AdditionalRootCertificateCheck",
+      "source": "OCPP",
       "characteristics": {
         "supportsMonitoring": true,
         "dataType": "boolean"
@@ -38,6 +39,7 @@
     },
     "BasicAuthPassword": {
       "variable_name": "BasicAuthPassword",
+      "source": "OCPP",
       "characteristics": {
         "minLimit": 16,
         "maxLimit": 40,
@@ -75,6 +77,7 @@
     },
     "CertSigningRepeatTimes": {
       "variable_name": "CertSigningRepeatTimes",
+      "source": "OCPP",
       "characteristics": {
         "supportsMonitoring": true,
         "dataType": "integer"
@@ -92,6 +95,7 @@
     },
     "CertSigningWaitMinimum": {
       "variable_name": "CertSigningWaitMinimum",
+      "source": "OCPP",
       "characteristics": {
         "unit": "s",
         "supportsMonitoring": true,
@@ -110,6 +114,7 @@
     },
     "SecurityCtrlrIdentity": {
       "variable_name": "Identity",
+      "source": "OCPP",
       "characteristics": {
         "supportsMonitoring": true,
         "dataType": "string"
@@ -127,6 +132,7 @@
     },
     "MaxCertificateChainSize": {
       "variable_name": "MaxCertificateChainSize",
+      "source": "OCPP",
       "characteristics": {
         "supportsMonitoring": true,
         "dataType": "integer"
@@ -142,6 +148,7 @@
     },
     "OrganizationName": {
       "variable_name": "OrganizationName",
+      "source": "OCPP",
       "characteristics": {
         "supportsMonitoring": true,
         "dataType": "string"
@@ -159,6 +166,7 @@
     },
     "SecurityProfile": {
       "variable_name": "SecurityProfile",
+      "source": "OCPP",
       "characteristics": {
         "minLimit": 1,
         "maxLimit": 3,

config/v201/device_model_migrations/2_down-variable_source.sql

@@ -0,0 +1,2 @@
+ALTER TABLE VARIABLE
+DROP COLUMN SOURCE;

config/v201/device_model_migrations/2_up-variable_source.sql

@@ -0,0 +1,2 @@
+ALTER TABLE VARIABLE
+ADD COLUMN SOURCE TEXT;

include/ocpp/v201/charge_point.hpp

@@ -14,7 +14,7 @@
 #include <ocpp/v201/ctrlr_component_variables.hpp>
 #include <ocpp/v201/database_handler.hpp>
 #include <ocpp/v201/device_model.hpp>
-#include <ocpp/v201/device_model_storage.hpp>
+#include <ocpp/v201/device_model_interface.hpp>
 #include <ocpp/v201/evse_manager.hpp>
 #include <ocpp/v201/monitoring_updater.hpp>
 #include <ocpp/v201/ocpp_enums.hpp>
@@ -838,14 +838,14 @@ class ChargePoint : public ChargePointInterface, private ocpp::ChargingStationBa
     /// \param evse_connector_structure Map that defines the structure of EVSE and connectors of the chargepoint. The
     /// key represents the id of the EVSE and the value represents the number of connectors for this EVSE. The ids of
     /// the EVSEs have to increment starting with 1.
-    /// \param device_model_storage device model storage instance
+    /// \param device_model_interface device model interface instance
     /// \param ocpp_main_path Path where utility files for OCPP are read and written to
     /// \param core_database_path Path to directory where core database is located
     /// \param message_log_path Path to where logfiles are written to
     /// \param evse_security Pointer to evse_security that manages security related operations
     /// \param callbacks Callbacks that will be registered for ChargePoint
     ChargePoint(const std::map<int32_t, int32_t>& evse_connector_structure,
-                std::unique_ptr<DeviceModelStorage> device_model_storage, const std::string& ocpp_main_path,
+                std::unique_ptr<DeviceModelInterface> device_model_interface, const std::string& ocpp_main_path,
                 const std::string& core_database_path, const std::string& sql_init_path,
                 const std::string& message_log_path, const std::shared_ptr<EvseSecurity> evse_security,
                 const Callbacks& callbacks);
@@ -854,7 +854,7 @@ class ChargePoint : public ChargePointInterface, private ocpp::ChargingStationBa
     /// \param evse_connector_structure Map that defines the structure of EVSE and connectors of the chargepoint. The
     /// key represents the id of the EVSE and the value represents the number of connectors for this EVSE. The ids of
     /// the EVSEs have to increment starting with 1.
-    /// \param device_model_storage device model storage instance
+    /// \param device_model device model instance
     /// \param database_handler database handler instance
     /// \param message_queue message queue instance
     /// \param message_log_path Path to where logfiles are written to

include/ocpp/v201/device_model.hpp

@@ -8,7 +8,7 @@
 
 #include <everest/logging.hpp>
 
-#include <ocpp/v201/device_model_storage.hpp>
+#include <ocpp/v201/device_model_interface.hpp>
 
 namespace ocpp {
 namespace v201 {
@@ -91,13 +91,13 @@ typedef std::function<void(const VariableMonitoringMeta& updated_monitor, const
                            const VariableAttribute& attribute, const std::string& current_value)>
     on_monitor_updated;
 
-/// \brief This class manages access to the device model representation and to the device model storage and provides
+/// \brief This class manages access to the device model representation and to the device model interface and provides
 /// functionality to support the use cases defined in the functional block Provisioning
 class DeviceModel {
 
 private:
-    DeviceModelMap device_model;
-    std::unique_ptr<DeviceModelStorage> storage;
+    DeviceModelMap device_model_map;
+    std::unique_ptr<DeviceModelInterface> device_model;
 
     /// \brief Listener for the internal change of a variable
     on_variable_changed variable_listener;
@@ -106,7 +106,7 @@ class DeviceModel {
 
     /// \brief Private helper method that does some checks with the device model representation in memory to evaluate if
     /// a value for the given parameters can be requested. If it can be requested it will be retrieved from the device
-    /// model storage and the given \p value will be set to the value that was retrieved
+    /// model interface and the given \p value will be set to the value that was retrieved
     /// \param component_id
     /// \param variable_id
     /// \param attribute_enum
@@ -138,15 +138,15 @@ class DeviceModel {
 
 public:
     /// \brief Constructor for the device model
-    /// \param device_model_storage pointer to a device model storage class
-    explicit DeviceModel(std::unique_ptr<DeviceModelStorage> device_model_storage);
+    /// \param device_model_interface pointer to a device model interface class
+    explicit DeviceModel(std::unique_ptr<DeviceModelInterface> device_model_interface);
 
     /// \brief Direct access to value of a VariableAttribute for the given component, variable and attribute_enum. This
     /// should only be called for variables that have a role standardized in the OCPP2.0.1 specification.
     /// \tparam T datatype of the value that is requested
     /// \param component_variable Combination of Component and Variable that identifies the Variable
     /// \param attribute_enum defaults to AttributeEnum::Actual
-    /// \return the requested value from the device model storage
+    /// \return the requested value from the device model interface
     template <typename T>
     T get_value(const RequiredComponentVariable& component_variable,
                 const AttributeEnum& attribute_enum = AttributeEnum::Actual) {
@@ -159,11 +159,10 @@ class DeviceModel {
         if (response == GetVariableStatusEnum::Accepted) {
             return to_specific_type<T>(value);
         } else {
-            EVLOG_critical
-                << "Directly requested value for ComponentVariable that doesn't exist in the device model storage: "
-                << component_variable;
+            EVLOG_critical << "Directly requested value for ComponentVariable that doesn't exist in the device model: "
+                           << component_variable;
             EVLOG_AND_THROW(std::runtime_error(
-                "Directly requested value for ComponentVariable that doesn't exist in the device model storage."));
+                "Directly requested value for ComponentVariable that doesn't exist in the device model."));
         }
     }
 
@@ -190,7 +189,7 @@ class DeviceModel {
     }
 
     /// \brief Requests a value of a VariableAttribute specified by combination of \p component_id and \p variable_id
-    /// from the device model storage
+    /// from the device model
     /// \tparam T datatype of the value that is requested
     /// \param component_id
     /// \param variable_id

include/ocpp/v201/device_model_storage.hpp → include/ocpp/v201/device_model_interface.hpp

@@ -1,8 +1,7 @@
 // SPDX-License-Identifier: Apache-2.0
 // Copyright 2020 - 2023 Pionix GmbH and Contributors to EVerest
 
-#ifndef OCPP_V201_DEVICE_MODEL_STORAGE_HPP
-#define OCPP_V201_DEVICE_MODEL_STORAGE_HPP
+#pragma once
 
 #include <map>
 #include <memory>
@@ -34,36 +33,37 @@ struct VariableMonitoringPeriodic {
 struct VariableMetaData {
     VariableCharacteristics characteristics;
     std::unordered_map<int64_t, VariableMonitoringMeta> monitors;
+    std::optional<std::string> source;
 };
 
 using VariableMap = std::map<Variable, VariableMetaData>;
 using DeviceModelMap = std::map<Component, VariableMap>;
 
-class DeviceModelStorageError : public std::exception {
+class DeviceModelError : public std::exception {
 public:
     [[nodiscard]] const char* what() const noexcept override {
         return this->reason.c_str();
     }
-    explicit DeviceModelStorageError(std::string msg) {
+    explicit DeviceModelError(std::string msg) {
         this->reason = std::move(msg);
     }
-    explicit DeviceModelStorageError(const char* msg) {
+    explicit DeviceModelError(const char* msg) {
         this->reason = std::string(msg);
     }
 
 private:
     std::string reason;
 };
 
-/// \brief Abstract base class for device model storage. This class provides an interface for accessing and modifying
+/// \brief Abstract base class for device model interface. This class provides an interface for accessing and modifying
 /// device model data. Implementations of this class should provide concrete implementations for the virtual methods
 /// declared here.
-class DeviceModelStorage {
+class DeviceModelInterface {
 
 public:
-    virtual ~DeviceModelStorage() = default;
+    virtual ~DeviceModelInterface() = default;
 
-    /// \brief Gets the device model from the device model storage
+    /// \brief Gets the device model from the device model interface
     /// \return std::map<Component, std::map<Variable, VariableMetaData>> that will contain a full representation of the
     /// device model except for the VariableAttribute(s) of each Variable.
     virtual DeviceModelMap get_device_model() = 0;
@@ -140,5 +140,3 @@ class DeviceModelStorage {
 
 } // namespace v201
 } // namespace ocpp
-
-#endif // OCPP_V201_DEVICE_MODEL_STORAGE_HPP

include/ocpp/v201/device_model_storage_sqlite.hpp

@@ -9,12 +9,12 @@
 
 #include <everest/logging.hpp>
 #include <ocpp/common/database/database_connection.hpp>
-#include <ocpp/v201/device_model_storage.hpp>
+#include <ocpp/v201/device_model_interface.hpp>
 
 namespace ocpp {
 namespace v201 {
 
-class DeviceModelStorageSqlite : public DeviceModelStorage {
+class DeviceModelStorageSqlite : public DeviceModelInterface {
 
 private:
     std::unique_ptr<ocpp::common::DatabaseConnectionInterface> db;

include/ocpp/v201/enums.hpp

@@ -5,6 +5,8 @@
 #ifndef OCPP_V201_ENUMS_HPP
 #define OCPP_V201_ENUMS_HPP
 
+#include <string>
+
 namespace ocpp {
 namespace v201 {
 

include/ocpp/v201/init_device_model_db.hpp

@@ -18,7 +18,7 @@
 /// database is not set by an external source, like the CSMS.
 ///
 /// The data from the schema json files or database are read into some structs. Some structs could be reused from
-/// the DeviceModelStorage class, but some members are missing there and and to prevent too many database reads, some
+/// the DeviceModelInterface class, but some members are missing there and and to prevent too many database reads, some
 /// structs are 'redefined' in this class with the proper members.
 ///
 /// Since the DeviceModel class creates a map based on the device model database in the constructor, this class should
@@ -36,7 +36,7 @@
 #include <filesystem>
 
 #include <ocpp/common/database/database_handler_common.hpp>
-#include <ocpp/v201/device_model_storage.hpp>
+#include <ocpp/v201/device_model_interface.hpp>
 
 namespace ocpp::v201 {
 ///
@@ -93,6 +93,8 @@ struct DeviceModelVariable {
     std::optional<std::string> default_actual_value;
     /// \brief Config monitors, if any
     std::vector<VariableMonitoringMeta> monitors;
+    /// \brief Source of the variable.
+    std::optional<std::string> source;
 };
 
 /// \brief Convert from json to a ComponentKey struct.

include/ocpp/v201/monitoring_updater.hpp

@@ -11,7 +11,7 @@
 #include <ocpp/v201/ocpp_enums.hpp>
 #include <ocpp/v201/ocpp_types.hpp>
 
-#include <ocpp/v201/device_model_storage.hpp>
+#include <ocpp/v201/device_model_interface.hpp>
 
 namespace ocpp::v201 {
 
@@ -187,4 +187,4 @@ class MonitoringUpdater {
     std::unordered_map<std::int32_t, UpdaterMonitorMeta> updater_monitors_meta;
 };
 
-} // namespace ocpp::v201
+} // namespace ocpp::v201