Enable gvametapublishkafka gvametapublishmqtt on Windows (#718)

* Enable gvametapublishkafka gvametapublishmqtt on Windows

* apply suggestions

Co-authored-by: Lena Onyshchenko <olena.onyshchenko@intel.com>

* comments

---------

Co-authored-by: Lena Onyshchenko <olena.onyshchenko@intel.com>

Author: yunowo

.github/workflows/dls-build-and-test-windows.yaml

@@ -26,7 +26,7 @@ env:
   VIDEO_INPUTS_PATH: 'C:\videos\videos'
   TESTS_RESULTS_DIRECTORY: 'C:\dlstreamer_test_results'
   PYTHON_VERSION: '3.12.7'
-  DLL_EXPECTED_COUNT: 16
+  DLL_EXPECTED_COUNT: 19
 
 jobs:
   DLS_Building_and_Testing:

CMakeLists.txt

@@ -6,6 +6,11 @@
 
 cmake_minimum_required(VERSION 3.20)
 
+if(WIN32)
+    set(VCPKG_OVERLAY_TRIPLETS "${CMAKE_SOURCE_DIR}/cmake/vcpkg/triplets")
+    set(VCPKG_TARGET_TRIPLET "x64-windows-mixed")
+endif()
+
 project(DL_Streamer C CXX)
 
 include_directories("${CMAKE_BINARY_DIR}/deps/install/include;${CMAKE_BINARY_DIR}/deps/gstreamer-bin/include;${CMAKE_BINARY_DIR}/deps/opencv-bin/include")
@@ -112,10 +117,10 @@ option(ENABLE_SAMPLES "Parameter to enable samples building" ON)
 cmake_dependent_option(TREAT_WARNING_AS_ERROR "Treat build warnings as errors" ON "UNIX" OFF)
 cmake_dependent_option(ENABLE_ITT "Enable ITT for tracing" ON "UNIX AND NOT ${CMAKE_SYSTEM_PROCESSOR} STREQUAL aarch64" OFF)
 cmake_dependent_option(ENABLE_VAAPI "Parameter to enable VAAPI for image pre-processing" ON "UNIX" ON)
-cmake_dependent_option(ENABLE_PAHO_INSTALLATION "Enables paho-mqtt3c installation" OFF "UNIX" OFF)
+cmake_dependent_option(ENABLE_PAHO_INSTALLATION "Enables paho-mqtt3c installation" OFF "UNIX" ON "WIN32" OFF)
 cmake_dependent_option(ENABLE_TESTS "Parameter to enable tests building" ON "UNIX" OFF)
 cmake_dependent_option(ENABLE_FUZZING "Parameter to enable fuzzy tests building" OFF "UNIX" OFF)
-cmake_dependent_option(ENABLE_RDKAFKA_INSTALLATION "Enables rdkafka installation" OFF "UNIX" OFF)
+cmake_dependent_option(ENABLE_RDKAFKA_INSTALLATION "Enables rdkafka installation" OFF "UNIX" ON "WIN32" OFF)
 option(ENABLE_AUDIO_INFERENCE_ELEMENTS "Enables audio inference elements" ON)
 option(ENABLE_REALSENSE "Parameter to enable RelaseSense plugin compilation" OFF)
 option(ENABLE_GENAI "Enables GenAI elements" OFF)

cmake/vcpkg/triplets/x64-windows-mixed.cmake

@@ -0,0 +1,14 @@
+# ==============================================================================
+# Copyright (C) 2026 Intel Corporation
+#
+# SPDX-License-Identifier: MIT
+# ==============================================================================
+
+set(VCPKG_TARGET_ARCHITECTURE x64)
+set(VCPKG_CRT_LINKAGE dynamic)
+set(VCPKG_BUILD_TYPE release)
+if(${PORT} MATCHES "curl|dlfcn-win32|lz4|opencl|openssl|zlib|zstd")
+	set(VCPKG_LIBRARY_LINKAGE static)
+else()
+	set(VCPKG_LIBRARY_LINKAGE dynamic)
+endif()

src/monolithic/gst/elements/gvametapublish/kafka/CMakeLists.txt

@@ -1,14 +1,20 @@
 # ==============================================================================
-# Copyright (C) 2021 Intel Corporation
+# Copyright (C) 2021-2026 Intel Corporation
 #
 # SPDX-License-Identifier: MIT
 # ==============================================================================
 
 set (TARGET_NAME "gvametapublishkafka")
 
 find_package(PkgConfig REQUIRED)
-find_library(KAFKA rdkafka++ REQUIRED)
+if(WIN32)
+    find_package(RdKafka CONFIG REQUIRED)
+    set(KAFKA RdKafka::rdkafka++)
+else()
+    find_library(KAFKA rdkafka++ REQUIRED)
+endif()
 pkg_check_modules(GSTREAMER gstreamer-1.0>=1.16 REQUIRED)
+pkg_check_modules(GSTBASE gstreamer-base-1.0>=1.16 REQUIRED)
 
 
 file (GLOB MAIN_SRC
@@ -20,20 +26,25 @@ file (GLOB MAIN_HEADERS
 
 add_library(${TARGET_NAME} SHARED ${MAIN_SRC} ${MAIN_HEADERS})
 set_compile_flags(${TARGET_NAME})
+if(WIN32)
+    add_vs_version_resource(${TARGET_NAME})
+endif()
 
 target_include_directories(${TARGET_NAME}
 PUBLIC
     ${CMAKE_CURRENT_SOURCE_DIR}
 PRIVATE
     ${GLIB2_INCLUDE_DIRS}
     ${GSTREAMER_INCLUDE_DIRS}
+    ${GSTBASE_INCLUDE_DIRS}
 )
 
 target_link_libraries(${TARGET_NAME}
 PUBLIC
     gvametapublish
 PRIVATE
     ${GSTREAMER_LIBRARIES}
+    ${GSTBASE_LIBRARIES}
     ${KAFKA}
 )
 

src/monolithic/gst/elements/gvametapublish/mqtt/CMakeLists.txt

@@ -1,14 +1,20 @@
 # ==============================================================================
-# Copyright (C) 2021-2024 Intel Corporation
+# Copyright (C) 2021-2026 Intel Corporation
 #
 # SPDX-License-Identifier: MIT
 # ==============================================================================
 
 set (TARGET_NAME "gvametapublishmqtt")
 
 find_package(PkgConfig REQUIRED)
-find_library(UUID uuid REQUIRED)
-find_library(MQTT paho-mqtt3as REQUIRED)
+if(WIN32)
+    find_package(eclipse-paho-mqtt-c CONFIG REQUIRED)
+    set(MQTT eclipse-paho-mqtt-c::paho-mqtt3as)
+    set(UUID rpcrt4)
+else()
+    find_library(MQTT paho-mqtt3as REQUIRED)
+    find_library(UUID uuid REQUIRED)
+endif()
 pkg_check_modules(GSTREAMER gstreamer-1.0>=1.16 REQUIRED)
 
 file (GLOB MAIN_SRC
@@ -20,6 +26,9 @@ file (GLOB MAIN_HEADERS
 
 add_library(${TARGET_NAME} SHARED ${MAIN_SRC} ${MAIN_HEADERS})
 set_compile_flags(${TARGET_NAME})
+if(WIN32)
+    add_vs_version_resource(${TARGET_NAME})
+endif()
 
 target_include_directories(${TARGET_NAME}
 PRIVATE

src/monolithic/gst/elements/gvametapublish/mqtt/generate_client_id.hpp

@@ -0,0 +1,44 @@
+/*******************************************************************************
+ * Copyright (C) 2026 Intel Corporation
+ *
+ * SPDX-License-Identifier: MIT
+ ******************************************************************************/
+
+#pragma once
+
+#include <string>
+
+#ifdef _WIN32
+#define RPC_USE_NATIVE_WCHAR
+#include <rpc.h>
+#include <stdexcept>
+
+inline std::string generate_client_id() {
+    UUID uuid;
+    RPC_STATUS status = UuidCreate(&uuid);
+    if (status != RPC_S_OK && status != RPC_S_UUID_LOCAL_ONLY)
+        throw std::runtime_error("UuidCreate failed with status " + std::to_string(status));
+    RPC_WSTR szUuid = nullptr;
+    status = UuidToStringW(&uuid, &szUuid);
+    if (status != RPC_S_OK)
+        throw std::runtime_error("UuidToStringW failed with status " + std::to_string(status));
+    std::wstring wide(szUuid);
+    std::string result(wide.begin(), wide.end());
+    RpcStringFreeW(&szUuid);
+    return result;
+}
+
+#else
+#include <uuid/uuid.h>
+
+inline std::string generate_client_id() {
+    // 36 character UUID string plus terminating character
+    static constexpr int kUuidStringLen = UUID_STR_LEN + 1;
+    uuid_t binuuid;
+    uuid_generate_random(binuuid);
+    char uuid[kUuidStringLen];
+    uuid_unparse(binuuid, uuid);
+    return uuid;
+}
+
+#endif

src/monolithic/gst/elements/gvametapublish/mqtt/gvametapublishmqtt.cpp

@@ -1,5 +1,5 @@
 /*******************************************************************************
- * Copyright (C) 2018-2025 Intel Corporation
+ * Copyright (C) 2018-2026 Intel Corporation
  *
  * SPDX-License-Identifier: MIT
  ******************************************************************************/
@@ -9,13 +9,13 @@
 #include <nlohmann/json.hpp>
 using json = nlohmann::json;
 
+#include "generate_client_id.hpp"
 #include "gvametapublishmqtt.hpp"
 
 #include <common.hpp>
 #include <safe_arithmetic.hpp>
 
 #include <MQTTAsync.h>
-#include <uuid/uuid.h>
 
 #include <cstdint>
 #include <string>
@@ -24,18 +24,6 @@ using json = nlohmann::json;
 GST_DEBUG_CATEGORY_STATIC(gva_meta_publish_mqtt_debug_category);
 #define GST_CAT_DEFAULT gva_meta_publish_mqtt_debug_category
 
-namespace {
-std::string generate_client_id() {
-    uuid_t binuuid;
-    uuid_generate_random(binuuid);
-    char uuid[37];
-    // 36 character UUID string plus terminating character
-    uuid_unparse(binuuid, uuid);
-    return uuid;
-}
-
-} // namespace
-
 /* Properties */
 enum {
     PROP_0,

vcpkg.json

@@ -3,17 +3,15 @@
         {
             "name": "opencv4",
             "default-features": false,
-            "features": ["world", "opencl", "calib3d", "dshow", "fs", "intrinsics", "msmf", "thread", "win32ui"]
+            "features": ["world", "opencl", "calib3d", "fs", "intrinsics", "thread", "win32ui"]
         },
         "pkgconf",
         "opencl",
         "dlfcn-win32",
-        "fmt"
-    ],
-    "overrides": [
-    {
-        "name": "fmt",
-        "version": "10.2.1"
-    }
-]
+        "paho-mqttpp3",
+        {
+            "name": "librdkafka",
+            "features": ["curl", "ssl", "zlib", "zstd"]
+        }
+    ]
 }