Imported history

external/streaming_protocol/CMakeLists.txt

@@ -0,0 +1,13 @@
+set(STREAMING_PROTOCOL_ALWAYS_FETCH_DEPS ON CACHE BOOL "" FORCE)
+
+if (OPENDAQ_ENABLE_WS_SIGGEN_INTEGRATION_TESTS)
+    set(STREAMING_PROTOCOL_TOOLS ON CACHE BOOL "" FORCE)
+endif()
+
+opendaq_dependency(
+    NAME                streaming_protocol
+    REQUIRED_VERSION    1.2.7
+    GIT_REPOSITORY      https://github.com/openDAQ/streaming-protocol-lt.git
+    GIT_REF             v1.2.7
+    EXPECT_TARGET       daq::streaming_protocol
+)

modules/websocket_streaming_client_module/CMakeLists.txt

@@ -0,0 +1,21 @@
+cmake_minimum_required(VERSION 3.10)
+set_cmake_folder_context(TARGET_FOLDER_NAME)
+project(WebsocketStreamingClientModule VERSION ${OPENDAQ_PACKAGE_VERSION} LANGUAGES C CXX)
+
+if (MSVC)
+    # loss of data / precision, unsigned <--> signed
+    #
+    # 'argument' : conversion from 'type1' to 'type2', possible loss of data
+    # https://learn.microsoft.com/en-us/cpp/error-messages/compiler-warnings/compiler-warning-level-2-c4244
+    add_compile_options(/wd4244)
+
+    # 'var' : conversion from 'size_t' to 'type', possible loss of data
+    # https://learn.microsoft.com/en-us/cpp/error-messages/compiler-warnings/compiler-warning-level-3-c4267
+    add_compile_options(/wd4267)
+endif()
+
+add_subdirectory(src)
+
+if (OPENDAQ_ENABLE_TESTS)
+    add_subdirectory(tests)
+endif()

modules/websocket_streaming_client_module/include/websocket_streaming_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_WEBSOCKET_STREAMING_CLIENT_MODULE BEGIN_NAMESPACE_OPENDAQ_MODULE(websocket_streaming_client_module)
+#define END_NAMESPACE_OPENDAQ_WEBSOCKET_STREAMING_CLIENT_MODULE END_NAMESPACE_OPENDAQ_MODULE

modules/websocket_streaming_client_module/include/websocket_streaming_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(WebsocketStreamingClientModule)

modules/websocket_streaming_client_module/include/websocket_streaming_client_module/websocket_streaming_client_module_impl.h

@@ -0,0 +1,55 @@
+/*
+ * 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 <websocket_streaming_client_module/common.h>
+#include <opendaq/module_impl.h>
+#include <daq_discovery/daq_discovery_client.h>
+
+BEGIN_NAMESPACE_OPENDAQ_WEBSOCKET_STREAMING_CLIENT_MODULE
+
+class WebsocketStreamingClientModule final : public Module
+{
+public:
+    WebsocketStreamingClientModule(ContextPtr context);
+
+    ListPtr<IDeviceInfo> onGetAvailableDevices() override;
+    DictPtr<IString, IDeviceType> onGetAvailableDeviceTypes() override;
+    DictPtr<IString, IStreamingType> onGetAvailableStreamingTypes() override;
+    DevicePtr onCreateDevice(const StringPtr& connectionString,
+                             const ComponentPtr& parent,
+                             const PropertyObjectPtr& config) override;
+    bool acceptsConnectionParameters(const StringPtr& connectionString, const PropertyObjectPtr& config);
+    bool acceptsStreamingConnectionParameters(const StringPtr& connectionString, const PropertyObjectPtr& config);
+    StreamingPtr onCreateStreaming(const StringPtr& connectionString, const PropertyObjectPtr& config) override;
+    Bool onCompleteServerCapability(const ServerCapabilityPtr& source, const ServerCapabilityConfigPtr& target) override;
+
+private:
+    static DeviceTypePtr createWebsocketDeviceType(bool useOldPrefix);
+    static StringPtr createUrlConnectionString(const StringPtr& host,
+                                               const IntegerPtr& port,
+                                               const StringPtr& path);
+    static StreamingTypePtr createWebsocketStreamingType();
+    static PropertyObjectPtr createDefaultConfig();
+    static StringPtr formConnectionString(const StringPtr& connectionString, const PropertyObjectPtr& config);
+    static DeviceInfoPtr populateDiscoveredDevice(const discovery::MdnsDiscoveredDevice& discoveredDevice);
+
+    std::mutex sync;
+    size_t deviceIndex;
+    discovery::DiscoveryClient discoveryClient;
+};
+
+END_NAMESPACE_OPENDAQ_WEBSOCKET_STREAMING_CLIENT_MODULE

modules/websocket_streaming_client_module/src/CMakeLists.txt

@@ -0,0 +1,47 @@
+# Windows NSIS package manager limits lenght of variables
+# "openDAQ_[MODULE_NAME]_[SUFFIX]" with 60 characters max
+# The suffix with max lenght is [Development_was_installed]
+# so the shorter module name [ws_stream_cl_module] should be used instead of full name:
+# [websocket_streaming_client_module]
+set(LIB_NAME ws_stream_cl_module)
+set(MODULE_HEADERS_DIR ../include/${TARGET_FOLDER_NAME})
+
+set(SRC_Include common.h
+                module_dll.h
+                websocket_streaming_client_module_impl.h
+)
+
+set(SRC_Srcs module_dll.cpp
+             websocket_streaming_client_module_impl.cpp
+)
+
+prepend_include(${TARGET_FOLDER_NAME} SRC_Include)
+
+source_group("module" FILES ${MODULE_HEADERS_DIR}/websocket_streaming_client_module_impl.h
+                            ${MODULE_HEADERS_DIR}/module_dll.h
+                            module_dll.cpp
+                            websocket_streaming_client_module_impl.cpp
+)
+
+
+add_library(${LIB_NAME} SHARED ${SRC_Include}
+                               ${SRC_Srcs}
+)
+add_library(${SDK_TARGET_NAMESPACE}::${LIB_NAME} ALIAS ${LIB_NAME})
+
+if (MSVC)
+    target_compile_options(${LIB_NAME} PRIVATE /bigobj)
+endif()
+
+target_link_libraries(${LIB_NAME} PUBLIC  daq::opendaq
+                                  PRIVATE daq::discovery
+                                          daq::websocket_streaming
+)
+
+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})
+create_version_header(${LIB_NAME})

modules/websocket_streaming_client_module/src/module_dll.cpp

@@ -0,0 +1,8 @@
+#include <websocket_streaming_client_module/module_dll.h>
+#include <websocket_streaming_client_module/websocket_streaming_client_module_impl.h>
+
+#include <opendaq/module_factory.h>
+
+using namespace daq::modules::websocket_streaming_client_module;
+
+DEFINE_MODULE_EXPORTS(WebsocketStreamingClientModule)