Feature/add visidentifier handler

CMakeLists.txt

@@ -67,7 +67,17 @@ set(CMAKE_MODULE_PATH ${PROJECT_SOURCE_DIR}/CMakeModules)
 include(AosCoreLib)
 
 # Poco lib
-find_package(Poco REQUIRED Util DataSQLite JSON)
+find_package(
+    Poco
+    REQUIRED
+    Crypto
+    DataSQLite
+    Foundation
+    JSON
+    Net
+    NetSSL
+    Util
+)
 
 # Systemd lib
 find_package(PkgConfig REQUIRED)

CMakeModules/AosCoreLib.cmake

@@ -13,7 +13,7 @@ ExternalProject_Add(
     aoscore
     PREFIX ${aoscore_build_dir}
     GIT_REPOSITORY https://github.com/aoscloud/aos_core_lib_cpp.git
-    GIT_TAG main
+    GIT_TAG develop
     GIT_PROGRESS TRUE
     GIT_SHALLOW TRUE
     CMAKE_ARGS -DCMAKE_INSTALL_PREFIX=${aoscore_build_dir}
@@ -23,6 +23,7 @@ ExternalProject_Add(
 file(MAKE_DIRECTORY ${aoscore_build_dir}/include)
 
 add_library(aoscommon STATIC IMPORTED GLOBAL)
+add_dependencies(aoscommon aoscore)
 set_target_properties(aoscommon PROPERTIES INTERFACE_INCLUDE_DIRECTORIES ${aoscore_build_dir}/include)
 set_target_properties(aoscommon PROPERTIES IMPORTED_LOCATION ${aoscore_build_dir}/lib/libaoscommoncpp.a)
 

src/CMakeLists.txt

@@ -22,10 +22,11 @@ include_directories(${CMAKE_CURRENT_SOURCE_DIR})
 # ######################################################################################################################
 
 add_subdirectory(app)
+add_subdirectory(config)
 add_subdirectory(database)
 add_subdirectory(logger)
-add_subdirectory(config)
 add_subdirectory(utils)
+add_subdirectory(visidentifier)
 
 # ######################################################################################################################
 # Sources

src/logger/logger.hpp

@@ -19,17 +19,19 @@ class LogModuleType {
 public:
     enum class Enum {
         eApp,
-        eDatabase,
         eConfig,
+        eDatabase,
+        eVISIdentifier,
         eNumModules,
     };
 
     static const aos::Array<const char* const> GetStrings()
     {
         static const char* const sLogModuleTypeStrings[] = {
             "app",
-            "database",
             "config",
+            "database",
+            "visidentifier",
         };
 
         return aos::Array<const char* const>(sLogModuleTypeStrings, aos::ArraySize(sLogModuleTypeStrings));

src/utils/CMakeLists.txt

@@ -11,7 +11,11 @@ set(TARGET utils)
 # Sources
 # ######################################################################################################################
 
-set(SOURCES time.cpp)
+set(SOURCES json.cpp time.cpp)
+
+# ######################################################################################################################
+# Includes
+# ######################################################################################################################
 
 # ######################################################################################################################
 # Target
@@ -23,4 +27,8 @@ add_library(${TARGET} STATIC ${SOURCES})
 # Labraries
 # ######################################################################################################################
 
-target_link_libraries(${TARGET} PUBLIC aoscommon)
+target_link_libraries(
+    ${TARGET}
+    PUBLIC aoscommon Poco::Foundation
+    PRIVATE Poco::JSON
+)

src/utils/json.cpp

@@ -0,0 +1,66 @@
+/*
+ * Copyright (C) 2024 Renesas Electronics Corporation.
+ * Copyright (C) 2024 EPAM Systems, Inc.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+#include <Poco/JSON/JSONException.h>
+#include <Poco/JSON/Object.h>
+#include <Poco/JSON/Parser.h>
+
+#include "utils/json.hpp"
+
+namespace UtilsJson {
+
+aos::RetWithError<Poco::Dynamic::Var> ParseJson(const std::string& json) noexcept
+{
+    try {
+        auto parser = Poco::JSON::Parser();
+
+        return parser.parse(json);
+    } catch (const Poco::JSON::JSONException& e) {
+        return {{}, aos::ErrorEnum::eInvalidArgument};
+    } catch (...) {
+        return {{}, aos::ErrorEnum::eFailed};
+    }
+}
+
+aos::RetWithError<Poco::Dynamic::Var> ParseJson(std::istream& in) noexcept
+{
+    try {
+        auto parser = Poco::JSON::Parser();
+
+        return parser.parse(in);
+    } catch (const Poco::JSON::JSONException& e) {
+        return {{}, aos::ErrorEnum::eInvalidArgument};
+    } catch (...) {
+        return {{}, aos::ErrorEnum::eFailed};
+    }
+}
+
+Poco::Dynamic::Var FindByPath(const Poco::Dynamic::Var object, const std::vector<std::string>& keys)
+{
+    if (keys.empty()) {
+        return object;
+    }
+
+    Poco::Dynamic::Var result = object;
+
+    for (const auto& key : keys) {
+
+        if (result.type() == typeid(Poco::JSON::Object)) {
+            result = result.extract<Poco::JSON::Object>().get(key);
+        } else if (result.type() == typeid(Poco::JSON::Object::Ptr)) {
+            result = result.extract<Poco::JSON::Object::Ptr>()->get(key);
+        } else {
+            result.clear();
+
+            break;
+        }
+    }
+
+    return result;
+}
+
+} // namespace UtilsJson

src/utils/json.hpp

@@ -0,0 +1,46 @@
+/*
+ * Copyright (C) 2024 Renesas Electronics Corporation.
+ * Copyright (C) 2024 EPAM Systems, Inc.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+#ifndef UTILS_JSON_HPP_
+#define UTILS_JSON_HPP_
+
+#include <string>
+#include <vector>
+
+#include <Poco/Dynamic/Var.h>
+
+#include <aos/common/tools/error.hpp>
+
+namespace UtilsJson {
+/**
+ * Parses json string.
+ *
+ * @param json json string.
+ * @return aos::RetWithError<Poco::Dynamic::Var> .
+ */
+aos::RetWithError<Poco::Dynamic::Var> ParseJson(const std::string& json) noexcept;
+
+/**
+ * Parses input stream.
+ *
+ * @param in input stream.
+ * @return aos::RetWithError<Poco::Dynamic::Var> .
+ */
+aos::RetWithError<Poco::Dynamic::Var> ParseJson(std::istream& in) noexcept;
+
+/**
+ * Finds value of the json by path
+ *
+ * @param object json object.
+ * @param path json path.
+ * @return Poco::Dynamic::Var.
+ */
+Poco::Dynamic::Var FindByPath(const Poco::Dynamic::Var object, const std::vector<std::string>& path);
+
+} // namespace UtilsJson
+
+#endif

src/visidentifier/CMakeLists.txt

@@ -0,0 +1,34 @@
+#
+# Copyright (C) 2024 Renesas Electronics Corporation.
+# Copyright (C) 2024 EPAM Systems, Inc.
+#
+# SPDX-License-Identifier: Apache-2.0
+#
+
+set(TARGET visidentifier)
+
+# ######################################################################################################################
+# Sources
+# ######################################################################################################################
+
+set(SOURCES pocowsclient.cpp visconfig.cpp visidentifier.cpp vismessage.cpp wsclientevent.cpp wspendingrequests.cpp)
+
+# ######################################################################################################################
+# Includes
+# ######################################################################################################################
+
+# ######################################################################################################################
+# Target
+# ######################################################################################################################
+
+add_library(${TARGET} STATIC ${SOURCES})
+
+# ######################################################################################################################
+# Labraries
+# ######################################################################################################################
+
+target_link_libraries(
+    ${TARGET}
+    PUBLIC aoscommon aosiam Poco::Foundation
+    PRIVATE Poco::Crypto Poco::Net Poco::NetSSL
+)

src/visidentifier/log.hpp

@@ -0,0 +1,18 @@
+/*
+ * Copyright (C) 2024 Renesas Electronics Corporation.
+ * Copyright (C) 2024 EPAM Systems, Inc.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+#ifndef LOG_HPP_
+#define LOG_HPP_
+
+#include "logger/logger.hpp"
+
+#define LOG_DBG() LOG_MODULE_DBG(AosLogModule(LogModuleEnum::eVISIdentifier))
+#define LOG_INF() LOG_MODULE_INF(AosLogModule(LogModuleEnum::eVISIdentifier))
+#define LOG_WRN() LOG_MODULE_WRN(AosLogModule(LogModuleEnum::eVISIdentifier))
+#define LOG_ERR() LOG_MODULE_ERR(AosLogModule(LogModuleEnum::eVISIdentifier))
+
+#endif