Generic OPCUA client

CMakeLists.txt

@@ -31,6 +31,7 @@ opendaq_setup_project_specific_build_options(${REPO_OPTION_PREFIX})
 option(${REPO_OPTION_PREFIX}_ENABLE_EXAMPLE_APP "Enable ${REPO_NAME} example applications" ${PROJECT_IS_TOP_LEVEL})
 option(${REPO_OPTION_PREFIX}_ENABLE_TESTS "Enable ${REPO_NAME} testing" ${PROJECT_IS_TOP_LEVEL})
 option(${REPO_OPTION_PREFIX}_ENABLE_CLIENT "Enable ${REPO_NAME} client module" ${PROJECT_IS_TOP_LEVEL})
+option(${REPO_OPTION_PREFIX}_ENABLE_GENERIC_CLIENT "Enable ${REPO_NAME} client module" ${PROJECT_IS_TOP_LEVEL})
 option(${REPO_OPTION_PREFIX}_ENABLE_SERVER "Enable ${REPO_NAME} server module" ${PROJECT_IS_TOP_LEVEL})
 option(OPCUA_ENABLE_ENCRYPTION "Enable OpcUa encryption" OFF)
 cmake_dependent_option(OPENDAQ_ENABLE_OPCUA_INTEGRATION_TESTS "Enable ${REPO_NAME} integration testing" ${PROJECT_IS_TOP_LEVEL} "${REPO_OPTION_PREFIX}_ENABLE_TESTS" OFF)

modules/CMakeLists.txt

@@ -8,6 +8,10 @@ if (${REPO_OPTION_PREFIX}_ENABLE_CLIENT)
     add_subdirectory(opcua_client_module)
 endif()
 
+if (${REPO_OPTION_PREFIX}_ENABLE_GENERIC_CLIENT)
+    add_subdirectory(opcua_generic_client_module)
+endif()
+
 if (${REPO_OPTION_PREFIX}_ENABLE_SERVER)
     add_subdirectory(opcua_server_module)
 endif()

modules/opcua_generic_client_module/CMakeLists.txt

@@ -0,0 +1,9 @@
+cmake_minimum_required(VERSION 3.10)
+opendaq_set_cmake_folder_context(TARGET_FOLDER_NAME)
+project(ClientModule VERSION ${${REPO_OPTION_PREFIX}_VERSION} LANGUAGES C CXX)
+
+add_subdirectory(src)
+
+if (${REPO_OPTION_PREFIX}_ENABLE_TESTS)
+    add_subdirectory(tests)
+endif()

modules/opcua_generic_client_module/include/opcua_generic_client_module/common.h

@@ -0,0 +1,21 @@
+/*
+ * Copyright 2022-2025 openDAQ d.o.o.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#pragma once
+#include <coretypes/common.h>
+
+#define BEGIN_NAMESPACE_OPENDAQ_OPCUA_GENERIC_CLIENT_MODULE BEGIN_NAMESPACE_OPENDAQ_MODULE(opcua_generic_client_module)
+#define END_NAMESPACE_OPENDAQ_OPCUA_GENERIC_CLIENT_MODULE END_NAMESPACE_OPENDAQ_MODULE

modules/opcua_generic_client_module/include/opcua_generic_client_module/constants.h

@@ -0,0 +1,32 @@
+/*
+ * Copyright 2022-2025 openDAQ d.o.o.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#pragma once
+
+#include <opcua_generic_client_module/common.h>
+
+BEGIN_NAMESPACE_OPENDAQ_OPCUA_GENERIC_CLIENT_MODULE
+
+static const char* DaqOpcUaGenericProtocolId = "OPCUAGeneric";
+static const char* DaqOpcUaGenericProtocolName = "OPCUAGeneric";
+static const char* DaqOpcUaGenericComponentName = "OPCUAGenericClient";
+static const char* DaqOpcUaGenericDevicePrefix = "daq.opcua.generic";
+static const char* OpcUaGenericScheme = "opc.tcp";
+
+static const char* MODULE_NAME = "OpenDAQOPCUAGenericClientModule";
+static const char* MODULE_ID = "OpenDAQOPCUAGenericClientModule";
+
+END_NAMESPACE_OPENDAQ_OPCUA_GENERIC_CLIENT_MODULE

modules/opcua_generic_client_module/include/opcua_generic_client_module/module_dll.h

@@ -0,0 +1,20 @@
+/*
+ * Copyright 2022-2025 openDAQ d.o.o.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#pragma once
+#include <opendaq/module_exports.h>
+
+DECLARE_MODULE_EXPORTS(OpcUaGenericClientModule)

modules/opcua_generic_client_module/include/opcua_generic_client_module/opcua_generic_client_module_impl.h

@@ -0,0 +1,49 @@
+/*
+ * Copyright 2022-2025 openDAQ d.o.o.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#pragma once
+#include <opcua_generic_client_module/common.h>
+#include <opendaq/module_impl.h>
+#include <daq_discovery/daq_discovery_client.h>
+#include <opendaq/device_ptr.h>
+
+BEGIN_NAMESPACE_OPENDAQ_OPCUA_GENERIC_CLIENT_MODULE
+
+class OpcUaGenericClientModule final : public Module
+{
+public:
+    OpcUaGenericClientModule(ContextPtr context);
+
+    ListPtr<IDeviceInfo> onGetAvailableDevices() override;
+    DictPtr<IString, IDeviceType> onGetAvailableDeviceTypes() override;
+    DevicePtr onCreateDevice(const StringPtr& connectionString,
+                             const ComponentPtr& parent,
+                             const PropertyObjectPtr& config) override;
+    bool acceptsConnectionParameters(const StringPtr& connectionString, const PropertyObjectPtr& config);
+    Bool onCompleteServerCapability(const ServerCapabilityPtr& source, const ServerCapabilityConfigPtr& target) override;
+
+private:
+    StringPtr formConnectionString(const StringPtr& connectionString, const PropertyObjectPtr& config, std::string& host, int& port, std::string& hostType);
+    static DeviceTypePtr createDeviceType();
+    static PropertyObjectPtr createDefaultConfig();
+    static PropertyObjectPtr populateDefaultConfig(const PropertyObjectPtr& config);
+    static DeviceInfoPtr populateDiscoveredDevice(const discovery::MdnsDiscoveredDevice& discoveredDevice);
+    discovery::DiscoveryClient discoveryClient;
+
+    std::mutex sync;
+};
+
+END_NAMESPACE_OPENDAQ_OPCUA_GENERIC_CLIENT_MODULE

modules/opcua_generic_client_module/src/CMakeLists.txt

@@ -0,0 +1,50 @@
+set(LIB_NAME opcua_generic_client_module)
+set(MODULE_HEADERS_DIR ../include/${TARGET_FOLDER_NAME})
+
+set(SRC_Include common.h
+                constants.h
+                module_dll.h
+                opcua_generic_client_module_impl.h
+)
+
+set(SRC_Srcs module_dll.cpp
+             opcua_generic_client_module_impl.cpp
+)
+
+opendaq_prepend_include(${TARGET_FOLDER_NAME} SRC_Include)
+
+source_group("module" FILES ${MODULE_HEADERS_DIR}/opcua_generic_client_module_impl.h
+                            ${MODULE_HEADERS_DIR}/module_dll.h
+                            ${MODULE_HEADERS_DIR}/common.h
+                            ${MODULE_HEADERS_DIR}/constants.h
+                            module_dll.cpp
+                            opcua_generic_client_module_impl.cpp
+)
+
+
+add_library(${LIB_NAME} SHARED ${SRC_Include}
+                               ${SRC_Srcs}
+)
+add_library(${OPENDAQ_SDK_TARGET_NAMESPACE}::${LIB_NAME} ALIAS ${LIB_NAME})
+
+if (MSVC)
+    target_compile_options(${LIB_NAME} PRIVATE /bigobj)
+endif()
+
+target_link_libraries(${LIB_NAME} PUBLIC  ${OPENDAQ_SDK_TARGET_NAMESPACE}::opendaq
+                                          Boost::uuid
+                                  PRIVATE ${OPENDAQ_SDK_TARGET_NAMESPACE}::discovery
+                                          ${OPENDAQ_SDK_TARGET_NAMESPACE}::opcuageneric_client
+)
+
+if (MSVC)
+    target_compile_options(${LIB_NAME} PRIVATE /bigobj)
+endif()
+
+target_include_directories(${LIB_NAME} PUBLIC $<BUILD_INTERFACE:${CMAKE_CURRENT_SOURCE_DIR}/../include>
+                                              $<BUILD_INTERFACE:${CMAKE_CURRENT_BINARY_DIR}/../include>
+                                              $<INSTALL_INTERFACE:include>
+)
+
+opendaq_set_module_properties(${LIB_NAME} ${PROJECT_VERSION_MAJOR})
+opendaq_generate_version_header(${LIB_NAME})

modules/opcua_generic_client_module/src/module_dll.cpp

@@ -0,0 +1,9 @@
+#include <opcua_generic_client_module/module_dll.h>
+#include <opcua_generic_client_module/opcua_generic_client_module_impl.h>
+
+#include <opendaq/module_factory.h>
+
+using namespace daq::modules::opcua_generic_client_module;
+
+DEFINE_MODULE_EXPORTS(OpcUaGenericClientModule)
+