[central system] Add skeleton of quick start example

Author: c-jimenez

examples/README.md

@@ -8,4 +8,4 @@ The following examples are available :
 
 How to run the examples:
 * Customize the *config.ini* file of the selected example with the URL of the Central System and the other connection parameters has well has the OCPP configuration keys
-* Run the exmaple using the **-w** option to specify the path of the configuration file
+* Run the example using the **-w** option to specify the path of the configuration file

examples/common/CMakeLists.txt

@@ -1,6 +1,7 @@
 
 # Common utility class for examples library
 add_library(examples_common STATIC
+    DefaultCentralSystemEventsHandler.cpp
     DefaultChargePointEventsHandler.cpp
 
     config/OcppConfig.cpp
@@ -14,4 +15,5 @@ target_include_directories(examples_common PUBLIC . config simulators)
 target_link_libraries(examples_common
     json
     chargepoint
+    centralsystem
 )

examples/common/DefaultCentralSystemEventsHandler.cpp

@@ -0,0 +1,61 @@
+/*
+MIT License
+
+Copyright (c) 2020 Cedric Jimenez
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.
+*/
+
+#include "DefaultCentralSystemEventsHandler.h"
+
+#include <iostream>
+
+using namespace std;
+using namespace ocpp::centralsystem;
+
+/** @brief Constructor */
+DefaultCentralSystemEventsHandler::DefaultCentralSystemEventsHandler() : m_chargepoints() { }
+
+/** @brief Destructor */
+DefaultCentralSystemEventsHandler::~DefaultCentralSystemEventsHandler() { }
+
+// ICentralSystemEventsHandler interface
+
+/** @copydoc bool ICentralSystemEventsHandler::checkCredentials(const std::string&, const std::string&) */
+bool DefaultCentralSystemEventsHandler::checkCredentials(const std::string& chargepoint_id, const std::string& password)
+{
+    cout << "Check credentials for [" << chargepoint_id << "] : " << password << endl;
+    return true;
+}
+
+/** @copydoc bool ICentralSystemEventsHandler::chargePointConnected(std::shared_ptr<ICentralSystem::IChargePoint>) */
+void DefaultCentralSystemEventsHandler::chargePointConnected(std::shared_ptr<ocpp::centralsystem::ICentralSystem::IChargePoint> chargepoint)
+{
+    cout << "Charge point [" << chargepoint->identifier() << "] connected" << endl;
+    auto iter_chargepoint = m_chargepoints.find(chargepoint->identifier());
+    if (iter_chargepoint == m_chargepoints.end())
+    {
+        m_chargepoints[chargepoint->identifier()] = chargepoint;
+    }
+    else
+    {
+        cout << "Charge point [" << chargepoint->identifier() << "] already connected" << endl;
+        chargepoint.reset();
+    }
+}

examples/common/DefaultCentralSystemEventsHandler.h

@@ -0,0 +1,55 @@
+/*
+MIT License
+
+Copyright (c) 2020 Cedric Jimenez
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.
+*/
+
+#ifndef DEFAULTCENTRALSYSTEMEVENTSHANDLER_H
+#define DEFAULTCENTRALSYSTEMEVENTSHANDLER_H
+
+#include "ICentralSystemEventsHandler.h"
+
+#include <map>
+
+/** @brief Default central system event handlers implementation for the examples */
+class DefaultCentralSystemEventsHandler : public ocpp::centralsystem::ICentralSystemEventsHandler
+{
+  public:
+    /** @brief Constructor */
+    DefaultCentralSystemEventsHandler();
+
+    /** @brief Destructor */
+    virtual ~DefaultCentralSystemEventsHandler();
+
+    // ICentralSystemEventsHandler interface
+
+    /** @copydoc bool ICentralSystemEventsHandler::checkCredentials(const std::string&, const std::string&) */
+    bool checkCredentials(const std::string& chargepoint_id, const std::string& password) override;
+
+    /** @copydoc bool ICentralSystemEventsHandler::chargePointConnected(std::shared_ptr<ICentralSystem::IChargePoint>) */
+    void chargePointConnected(std::shared_ptr<ocpp::centralsystem::ICentralSystem::IChargePoint> chargepoint) override;
+
+  private:
+    /** @brief Connected charge points */
+    std::map<std::string, std::shared_ptr<ocpp::centralsystem::ICentralSystem::IChargePoint>> m_chargepoints;
+};
+
+#endif // DEFAULTCENTRALSYSTEMEVENTSHANDLER_H

examples/common/config/CentralSystemConfig.h

@@ -48,15 +48,29 @@ class CentralSystemConfig : public ocpp::config::ICentralSystemConfig
     // Communication parameters
 
     /** @brief Listen URL */
-    std::string listenUrl() const override { return getString("ListenUrl"); };
+    std::string listenUrl() const override { return getString("ListenUrl"); }
+    /** @brief Enable HTTP basic authentication */
+    bool httpBasicAuthent() const override { return getBool("HttpBasicAuthent"); }
     /** @brief Call request timeout */
     std::chrono::milliseconds callRequestTimeout() const override { return get<std::chrono::milliseconds>("CallRequestTimeout"); }
     /** @brief Cipher list to use for TLSv1.2 connections */
     std::string tlsv12CipherList() const override { return getString("Tlsv12CipherList"); }
     /** @brief Cipher list to use for TLSv1.3 connections */
     std::string tlsv13CipherList() const override { return getString("Tlsv13CipherList"); }
     /** @brief ECDH curve to use for TLS connections */
-    std::string tlsvEcdhCurve() const override { return getString("TlsEcdhCurve"); }
+    std::string tlsEcdhCurve() const override { return getString("TlsEcdhCurve"); }
+    /** @brief Server certificate */
+    std::string tlsServerCertificate() const override { return getString("TlsServerCertificate"); }
+    /** @brief Server certificate's private key */
+    std::string tlsServerCertificatePrivateKey() const override { return getString("TlsServerCertificatePrivateKey"); }
+    /** @brief Server certificate's private key passphrase */
+    std::string tlsServerCertificatePrivateKeyPassphrase() const override { return getString("TlsServerCertificatePrivateKeyPassphrase"); }
+    /** @brief Certification Authority signing chain for the server certificate */
+    std::string tlsServerCertificateCa() const override { return getString("TlsServerCertificateCa"); }
+    /** @brief Certification Authority signing chain for the clients certificates */
+    std::string tlsClientCertificateCa() const override { return getString("TlsClientCertificateCa"); }
+    /** @brief Enable client authentication using certificate */
+    bool tlsClientCertificateAuthent() const override { return getBool("TlsClientCertificateAuthent"); }
 
     // Logs
 

examples/common/config/ChargePointConfig.h

@@ -62,7 +62,7 @@ class ChargePointConfig : public ocpp::config::IChargePointConfig
     /** @brief Cipher list to use for TLSv1.3 connections */
     std::string tlsv13CipherList() const override { return getString("Tlsv13CipherList"); }
     /** @brief ECDH curve to use for TLS connections */
-    std::string tlsvEcdhCurve() const override { return getString("TlsEcdhCurve"); }
+    std::string tlsEcdhCurve() const override { return getString("TlsEcdhCurve"); }
     /** @brief Allow TLS connections using self-signed certificates
      *         (Warning : enabling this feature is not recommended in production) */
     bool tlsAllowSelfSignedCertificates() const override { return getBool("TlsAllowSelfSignedCertificates"); }

examples/quick_start_centralsystem/README.md

@@ -0,0 +1,19 @@
+# Quick start Central System example
+
+## Description
+
+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
+* Trigger messages : status notification, meter values
+
+There is a 10s break between 2 charge points communication.
+
+## Command line
+
+quick_start_centralsystem [-w working_dir] [-r]
+
+* -w : Working directory where to store the configuration file (Default = current directory)
+* -r : Reset all the OCPP persistent data

examples/quick_start_centralsystem/config/quick_start_centralsystem.ini

@@ -1,9 +1,16 @@
 [CentralSystem]
-DatabasePath=./quick_start_central_system.db
+DatabasePath=./quick_start_centralsystem.db
 JsonSchemasPath=../../schemas/ocpp16/
 ListenUrl=ws://127.0.0.1:8180/steve/websocket/CentralSystemService/
+HttpBasicAuthent=false
+CallRequestTimeout=2000
 Tlsv12CipherList=ECDHE-ECDSA-AES256-GCM-SHA384:ECDHE-RSA-WITH-AES-256-GCM-SHA384:DHE-RSA-AES256-GCM-SHA384:TLS-PSK-WITH-AES-256-GCM-SHA384:ECDHE-ECDSA-AES128-GCM-SHA256:ECDHE-RSA-WITH-AES-128-GCM-SHA256:DHE-RSA-AES128-GCM-SHA256:TLS-PSK-WITH-AES-128-GCM-SHA256
 Tlsv13CipherList=TLS_AES_128_GCM_SHA256:TLS_AES_256_GCM_SHA384
 TlsEcdhCurve=prime256v1
-CallRequestTimeout=2000
+TlsServerCertificate=../../examples/certificates/OpenOCPP_CentralSystem.pem
+TlsServerCertificatePrivateKey=../../examples/certificates/OpenOCPP_CentralSystem-private.key
+TlsServerCertificatePrivateKeyPassphrase=
+TlsServerCertificateCa=../../examples/certificates/OpenOCPP_CA.pem
+TlsClientCertificateCa=
+TlsClientCertificateAuthent=false
 LogMaxEntriesCount=2000

examples/quick_start_centralsystem/main.cpp

@@ -23,6 +23,7 @@ SOFTWARE.
 */
 
 #include "CentralSystemDemoConfig.h"
+#include "DefaultCentralSystemEventsHandler.h"
 #include "ICentralSystem.h"
 
 #include <cstring>
@@ -32,11 +33,6 @@ SOFTWARE.
 
 using namespace ocpp::centralsystem;
 
-/** @brief EVent handler */
-class CentralSystemEventHandler : public ICentralSystemEventsHandler
-{
-};
-
 /** @brief Entry point */
 int main(int argc, char* argv[])
 {
@@ -98,7 +94,7 @@ int main(int argc, char* argv[])
     CentralSystemDemoConfig config(path);
 
     // Event handler
-    CentralSystemEventHandler event_handler;
+    DefaultCentralSystemEventsHandler event_handler;
 
     // Instanciate central system
     std::unique_ptr<ICentralSystem> central_system = ICentralSystem::create(config.stackConfig(), event_handler);

src/centralsystem/CMakeLists.txt

@@ -6,13 +6,15 @@
 # Library target
 add_library(centralsystem STATIC
     CentralSystem.cpp
+
+    chargepoint/ChargePointProxy.cpp
 )
 
 # Exported includes
 target_include_directories(centralsystem PUBLIC interface)
 
 # Private includes
-target_include_directories(centralsystem PRIVATE authent
+target_include_directories(centralsystem PRIVATE chargepoint
                                                  config)
 
 # Dependencies