[central system] Add charge point proxy implementation + update quick start central system example

Author: c-jimenez

examples/common/DefaultCentralSystemEventsHandler.cpp

@@ -43,7 +43,7 @@ bool DefaultCentralSystemEventsHandler::checkCredentials(const std::string& char
     cout << "Check credentials for [" << chargepoint_id << "] : " << password << endl;
     return true;
 }
-
+#include <thread>
 /** @copydoc bool ICentralSystemEventsHandler::chargePointConnected(std::shared_ptr<ICentralSystem::IChargePoint>) */
 void DefaultCentralSystemEventsHandler::chargePointConnected(std::shared_ptr<ocpp::centralsystem::ICentralSystem::IChargePoint> chargepoint)
 {

examples/common/DefaultCentralSystemEventsHandler.h

@@ -47,6 +47,11 @@ class DefaultCentralSystemEventsHandler : public ocpp::centralsystem::ICentralSy
     /** @copydoc bool ICentralSystemEventsHandler::chargePointConnected(std::shared_ptr<ICentralSystem::IChargePoint>) */
     void chargePointConnected(std::shared_ptr<ocpp::centralsystem::ICentralSystem::IChargePoint> chargepoint) override;
 
+    // API
+
+    /** @brief Get the list of the connected charge points */
+    std::map<std::string, std::shared_ptr<ocpp::centralsystem::ICentralSystem::IChargePoint>>& chargePoints() { return m_chargepoints; }
+
   private:
     /** @brief Connected charge points */
     std::map<std::string, std::shared_ptr<ocpp::centralsystem::ICentralSystem::IChargePoint>> m_chargepoints;

examples/quick_start_centralsystem/README.md

@@ -7,6 +7,7 @@ This example simulates a central system which accepts any charge point.
 The central system loops on its connected charge points. For each charge point it simulates the following operations :
 
 * Get configuration
+* Set heartbeat interval to 10s
 * Trigger messages : status notification, meter values
 
 There is a 10s break between 2 charge points communication.

examples/quick_start_centralsystem/main.cpp

@@ -32,6 +32,7 @@ SOFTWARE.
 #include <thread>
 
 using namespace ocpp::centralsystem;
+using namespace ocpp::types;
 
 /** @brief Entry point */
 int main(int argc, char* argv[])
@@ -106,6 +107,58 @@ int main(int argc, char* argv[])
 
     // From now on the stack is alive :)
 
+    // App loop
+    while (true)
+    {
+        // Wait for at least 1 connected charge point
+        while (event_handler.chargePoints().size() == 0)
+        {
+            std::this_thread::sleep_for(std::chrono::milliseconds(250));
+        }
+
+        // For each connected charge point
+        for (auto& iter_chargepoint : event_handler.chargePoints())
+        {
+            auto& chargepoint = iter_chargepoint.second;
+
+            std::cout << "---------------------------------------------" << std::endl;
+            std::cout << "Charge point : " << chargepoint->identifier() << std::endl;
+            std::cout << "---------------------------------------------" << std::endl;
+
+            std::cout << "Read whole charge point configuration..." << std::endl;
+            std::vector<std::string> keys;
+            std::vector<KeyValue>    config_keys;
+            std::vector<std::string> unknown_keys;
+            if (chargepoint->getConfiguration(keys, config_keys, unknown_keys))
+            {
+                std::cout << "Configuration keys :" << std::endl;
+                for (const KeyValue& key_value : config_keys)
+                {
+                    std::cout << " - " << key_value.key.str() << " = " << (key_value.value.isSet() ? key_value.value.value().str() : "")
+                              << " " << (key_value.readonly ? "(read-only)" : "") << std::endl;
+                }
+            }
+            else
+            {
+                std::cout << "Failed!" << std::endl;
+            }
+
+            std::cout << "Configure heartbeat interval..." << std::endl;
+            ConfigurationStatus config_status = chargepoint->changeConfiguration("HeartbeatInterval", "10");
+            std::cout << ConfigurationStatusHelper.toString(config_status) << std::endl;
+
+            std::cout << "Trigger status notification..." << std::endl;
+            TriggerMessageStatus trigger_status = chargepoint->triggerMessage(MessageTrigger::StatusNotification, Optional<unsigned int>());
+            std::cout << TriggerMessageStatusHelper.toString(trigger_status) << std::endl;
+
+            std::cout << "Trigger meter values on connector 0..." << std::endl;
+            trigger_status = chargepoint->triggerMessage(MessageTrigger::MeterValues, 0);
+            std::cout << TriggerMessageStatusHelper.toString(trigger_status) << std::endl;
+
+            std::this_thread::sleep_for(std::chrono::seconds(10));
+        }
+    }
+
     std::this_thread::sleep_for(std::chrono::milliseconds(5000000));
 
     return 0;

src/centralsystem/CentralSystem.cpp

@@ -51,6 +51,7 @@ CentralSystem::CentralSystem(const ocpp::config::ICentralSystemConfig& stack_con
       m_worker_pool(2u), // 1 asynchronous timer operations + 1 for asynchronous responses
       m_database(),
       m_internal_config(m_database),
+      m_messages_converter(),
       m_ws_server(),
       m_rpc_server(),
       m_uptime_timer(m_timer_pool, "Uptime timer"),
@@ -233,8 +234,8 @@ void CentralSystem::rpcClientConnected(const std::string& chargepoint_id, std::s
     LOG_INFO << "Connection from Charge Point [" << chargepoint_id << "]";
 
     // Instanciate proxy
-    std::shared_ptr<ICentralSystem::IChargePoint> chargepoint(
-        new ChargePointProxy(chargepoint_id, client, m_stack_config.jsonSchemasPath()));
+    std::shared_ptr<ICentralSystem::IChargePoint> chargepoint(new ChargePointProxy(
+        chargepoint_id, client, m_stack_config.jsonSchemasPath(), m_messages_converter, m_stack_config.callRequestTimeout()));
 
     // Notify connection
     m_events_handler.chargePointConnected(chargepoint);

src/centralsystem/CentralSystem.h

@@ -22,6 +22,7 @@ along with OpenOCPP. If not, see <http://www.gnu.org/licenses/>.
 #include "Database.h"
 #include "ICentralSystem.h"
 #include "InternalConfigManager.h"
+#include "MessagesConverter.h"
 #include "RpcServer.h"
 #include "Timer.h"
 #include "TimerPool.h"
@@ -88,6 +89,9 @@ class CentralSystem : public ICentralSystem, public ocpp::rpc::RpcServer::IListe
     /** @brief Internal configuration manager */
     ocpp::config::InternalConfigManager m_internal_config;
 
+    /** @brief Messages converter */
+    ocpp::messages::MessagesConverter m_messages_converter;
+
     /** @brief Websocket server */
     std::unique_ptr<ocpp::websockets::IWebsocketServer> m_ws_server;
     /** @brief RPC server */