Merge pull request #14 from c-jimenez/develop

Version 1.1.0

Author: c-jimenez

README.md

@@ -186,6 +186,7 @@ cp_simu
  |   |-status
  |--cps
  |   |-simu_cp_XXX
+ |   |  |-cmd
  |   |  |-status
  |   |  |-connectors
  |   |  |  |-1
@@ -197,6 +198,7 @@ cp_simu
  |   |  |  | |-id_tag
  |   |  |  | |-status
  |   |-simu_cp_YYY
+ |   |  |-cmd
  |   |  |-status
  |   |  |-connectors
  |   |  |  |-1
@@ -348,4 +350,17 @@ The expected command payload is :
  {
     "faulted": false
  }
- ```
+ ```
+
+
+Each simulated Charge Point are listening to the following topic to execute a certain command: **cp_simu/cps/simu_cp_XXX/cmd**.
+
+The expected command payload is :
+ ```
+ {
+    "type": "<cmd>"
+ }
+ ```
+So far there are 2 commands:
+* close: ask to end the application
+* ocpp_config: ask to send on MQTT topic **cp_simu/cps/simu_cp_XXX/ocpp_config** all the OCPP config of the Charge Point

docker/Dockerfile

@@ -16,7 +16,7 @@ RUN apt-get update && apt-get install build-essential clang cmake python3 python
 
 RUN git clone https://github.com/c-jimenez/open-ocpp.git
 
-RUN cd open-ocpp && git fetch --tags && git checkout v1.1.0 && make gcc && make install-gcc
+RUN cd open-ocpp && git fetch --tags && git checkout v1.2.0 && make gcc && make install-gcc
 
 RUN apt-get update && apt-get install pkg-config &&  apt-get -q autoremove  &&  rm -rf "/var/lib/apt/lists/*"
 

docker/Dockerfile_cp_simulator

@@ -14,9 +14,10 @@ COPY gcc_native/config.ini /var/chargepoint/config.ini
 RUN chown ${simu_uid}:${simu_gid} /var/chargepoint/config.ini
 
 COPY gcc_native  /cp_simulator
+COPY cp_simu_entrypoint.sh /cp_simu_entrypoint.sh
 
 USER cp_simu
 
 WORKDIR "/var/chargepoint"
 
-ENTRYPOINT  ["/cp_simulator/chargepoint"]
+ENTRYPOINT  ["/cp_simu_entrypoint.sh"]

docker/Entrypoint/cp_simu_entrypoint.sh

@@ -0,0 +1,32 @@
+#!/bin/bash
+
+cp_args=""
+diagnostic_file_size=0
+
+for i in "$@"; do
+  case $i in
+    --diagnostic_file_size*)
+      diagnostic_file_size="$2"
+      shift
+      ;;
+    -*)
+      cp_args+=" $i $2"
+      shift
+      ;;
+    *)
+      shift
+      ;;
+  esac
+done
+
+# create big file and add it in diagnostic zip of charge point
+if [ $diagnostic_file_size -gt 0 ]
+then
+  echo "generate $diagnostic_file_size random strings in cp config file"
+  echo "$(tr -dc A-Za-z0-9 < /dev/urandom | head -c $diagnostic_file_size)" >>  /var/chargepoint/blob.txt
+  cp_args+=" -f blob.txt"
+fi
+
+# start simulator
+echo "start charpoint with arguments : $cp_args"
+/cp_simulator/chargepoint $cp_args

imgs/connect.png

@@ -104,11 +104,12 @@ docker-build-simu-compile:
 	@${DOCKER_BUILD}  -f docker/Dockerfile -t $(DOCKER_COMPILE_IMAGE)  $(ROOT_DIR)/docker
 
 docker-build-cp-simulator:
+	cp docker/Entrypoint/cp_simu_entrypoint.sh $(ROOT_DIR)/bin/
 	@${DOCKER_BUILD}  -f docker/Dockerfile_cp_simulator -t $(DOCKER_SIMULATOR_IMAGE)  $(ROOT_DIR)/bin/
 
 
 run-simu:
-	docker run $(DOCKER_INTERACTIVE) --rm  --network=host --name ocpp-simu $(DOCKER_SIMULATOR_IMAGE) -c test_ocpp
+	docker run $(DOCKER_INTERACTIVE) --rm  --network=host --name ocpp-simu $(DOCKER_SIMULATOR_IMAGE)
 
 run-launcher:
 	docker run $(DOCKER_INTERACTIVE) --rm  --network=host --name ocpp-launcher --entrypoint /cp_simulator/launcher $(DOCKER_SIMULATOR_IMAGE)

imgs/instances.png

@@ -26,6 +26,6 @@ SOFTWARE.
 #define VERSION_H
 
 /** @brief Firmware version of the simulated charge point */
-#define CHARGEPOINT_FW_VERSION "1.0.0"
+#define CHARGEPOINT_FW_VERSION "1.1.0"
 
 #endif // VERSION_H

makefile

@@ -30,20 +30,29 @@ SOFTWARE.
 #include "OcppConfig.h"
 
 #include <openocpp/IniFile.h>
+#include <set>
 
 /** @brief Configuration of the simulated charge point */
 class SimulatedChargePointConfig
 {
   public:
     /** @brief Constructor */
-    SimulatedChargePointConfig(const std::string& working_dir, const std::string& config_file)
-        : m_working_dir(working_dir), m_config(config_file), m_stack_config(m_config), m_ocpp_config(m_config), m_mqtt_config(m_config)
+    SimulatedChargePointConfig(const std::string& working_dir, const std::string& config_file, std::set<std::string>& diag_files)
+        : m_working_dir(working_dir),
+          m_config(config_file),
+          m_diag_files(diag_files),
+          m_stack_config(m_config),
+          m_ocpp_config(m_config),
+          m_mqtt_config(m_config)
     {
     }
 
     /** @brief Working directory */
     const std::string& workingDir() const { return m_working_dir; }
 
+    /** @brief files to put diagnostic zip */
+    const std::set<std::string>& diagFiles() const { return m_diag_files; }
+
     /** @brief Stack internal configuration */
     ocpp::config::IChargePointConfig& stackConfig() { return m_stack_config; }
 
@@ -67,6 +76,8 @@ class SimulatedChargePointConfig
     std::string m_working_dir;
     /** @brief Configuration file */
     ocpp::helpers::IniFile m_config;
+    /** @brief files to put diagnostic zip */
+    std::set<std::string> m_diag_files;
 
     /** @brief Stack internal configuration */
     ChargePointConfig m_stack_config;

src/chargepoint/Version.h

@@ -33,6 +33,7 @@ SOFTWARE.
 #include <iostream>
 #include <string.h>
 #include <thread>
+#include <set>
 
 using namespace std;
 
@@ -73,6 +74,7 @@ int main(int argc, char* argv[])
     std::string  mqtt_broker_url          = "tcp://localhost:1883";
     unsigned int max_charge_point_current = 32u;
     unsigned int max_connector_current    = 32u;
+    std::set<std::string> diag_files     = {"ocpp.db"};
 
     // Check parameters
     if (argc > 1)
@@ -140,6 +142,19 @@ int main(int argc, char* argv[])
                 argc--;
                 max_connector_current = static_cast<unsigned int>(std::atoi(*argv));
             }
+            else if ((strcmp(*argv, "-f") == 0) && (argc > 1))
+            {
+                argv++;
+                argc--;
+                // add all files in diag file list:
+                diag_files.insert(*argv);
+                while((argc > 2) && (*argv[1] != '-'))
+                {
+                    argv++;
+                    argc--;
+                    diag_files.insert(*argv);
+                }
+            }
             else
             {
                 param     = *argv;
@@ -168,14 +183,16 @@ int main(int argc, char* argv[])
             std::cout << "    -b : URL of the MQTT broker (Default = tcp://localhost:1883)" << std::endl;
             std::cout << "    -m : Max current in A for the whole Charge Point (Default = 32A)" << std::endl;
             std::cout << "    -i : Max current in A for a connector of the Charge Point (Default = 32A)" << std::endl;
+            std::cout << "    -f : Files to put in diagnostic zip. Absolute path or relative path from working directory. " << std::endl;
+            std::cout <<          "Default = [ocpp.db]" << std::endl;
             return 1;
         }
     }
 
     // Open configuration file
     std::filesystem::path path(working_dir);
     path /= "config.ini";
-    SimulatedChargePointConfig config(working_dir, path.string());
+    SimulatedChargePointConfig config(working_dir, path.string(), diag_files);
 
     // Update configuration file
     std::filesystem::path db_path(working_dir);