ipfixprobe - introduce process NETTISA plugin

Author: Pavel Siska

src/plugins/process/CMakeLists.txt

@@ -27,4 +27,5 @@ if (ENABLE_PROCESS_EXPERIMENTAL)
 	add_subdirectory(rtsp)
 	add_subdirectory(mpls)
 	add_subdirectory(ntp)
+	add_subdirectory(nettisa)
 endif()

src/plugins/process/nettisa/CMakeLists.txt

@@ -0,0 +1,24 @@
+project(ipfixprobe-process-nettisa VERSION 1.0.0 DESCRIPTION "ipfixprobe-process-nettisa plugin")
+
+add_library(ipfixprobe-process-nettisa MODULE
+    src/nettisa.cpp
+    src/nettisa.hpp
+)
+
+set_target_properties(ipfixprobe-process-nettisa PROPERTIES
+    CXX_VISIBILITY_PRESET hidden
+    VISIBILITY_INLINES_HIDDEN YES
+)
+
+target_include_directories(ipfixprobe-process-nettisa PRIVATE
+    ${CMAKE_SOURCE_DIR}/include/
+)
+
+target_link_libraries(ipfixprobe-process-nettisa PRIVATE 
+    ipfixprobe-core
+)
+
+install(
+    TARGETS ipfixprobe-process-nettisa
+    LIBRARY DESTINATION "${INSTALL_DIR_LIB}/ipfixprobe/process/"
+)

src/plugins/process/nettisa/README.md

@@ -1,26 +1,38 @@
 /**
- * \file nettisa.cpp
- * \brief Plugin for creating NetTiSA flow.
- * \author Josef Koumar [email protected]
- * \date 2023
+ * @file
+ * @brief Plugin for parsing Nettisa flow.
+ * @author Josef Koumar [email protected]
+ * @date 2025
+ *
+ * Copyright (c) 2025 CESNET
+ *
+ * SPDX-License-Identifier: BSD-3-Clause
  */
 
 #include "nettisa.hpp"
 
 #include <cmath>
 #include <iostream>
 
+#include <ipfixprobe/pluginFactory/pluginManifest.hpp>
+#include <ipfixprobe/pluginFactory/pluginRegistrar.hpp>
 #include <ipfixprobe/utils.hpp>
 
 namespace ipxp {
 
-int RecordExtNETTISA::REGISTERED_ID = -1;
+int RecordExtNETTISA::REGISTERED_ID = ProcessPluginIDGenerator::instance().generatePluginID();
 
-__attribute__((constructor)) static void register_this_plugin()
+static const PluginManifest nettisaPluginManifest = {
+	.name = "nettisa",
+	.description = "Nettisa process plugin for parsing Nettisa flow.",
+	.pluginVersion = "1.0.0",
+	.apiVersion = "1.0.0",
+	.usage = nullptr,
+};
+
+NETTISAPlugin::NETTISAPlugin(const std::string& params)
 {
-	static PluginRecord rec = PluginRecord("nettisa", []() { return new NETTISAPlugin(); });
-	register_plugin(&rec);
-	RecordExtNETTISA::REGISTERED_ID = register_extension();
+	(void) params;
 }
 
 ProcessPlugin* NETTISAPlugin::copy()
@@ -115,4 +127,7 @@ void NETTISAPlugin::pre_export(Flow& rec)
 	nettisa_data->average_dispersion = nettisa_data->average_dispersion / n;
 }
 
+static const PluginRegistrar<NETTISAPlugin, ProcessPluginFactory>
+	nettisaRegistrar(nettisaPluginManifest);
+
 } // namespace ipxp

src/plugins/process/nettisa.cpp …/plugins/process/nettisa/src/nettisa.cppsrc/plugins/process/nettisa.cpp renamed to src/plugins/process/nettisa/src/nettisa.cpp src/plugins/process/nettisa.cpp renamed to src/plugins/process/nettisa/src/nettisa.cpp

@@ -1,12 +1,12 @@
-/* SPDX-License-Identifier: BSD-3-Clause
- * Copyright (C) 2023, CESNET z.s.p.o.
- */
-
 /**
- * \file nettisa.hpp
- * \brief Class for creating NetTiSA flow.
- * \author Josef Koumar [email protected]
- * \date 2023
+ * @file
+ * @brief Plugin for parsing Nettisa flow.
+ * @author Josef Koumar [email protected]
+ * @date 2025
+ *
+ * Copyright (c) 2025 CESNET
+ *
+ * SPDX-License-Identifier: BSD-3-Clause
  */
 
 #pragma once
@@ -22,7 +22,7 @@
 #include <ipfixprobe/flowifc.hpp>
 #include <ipfixprobe/ipfix-elements.hpp>
 #include <ipfixprobe/packet.hpp>
-#include <ipfixprobe/process.hpp>
+#include <ipfixprobe/processPlugin.hpp>
 
 namespace ipxp {
 
@@ -173,6 +173,7 @@ struct RecordExtNETTISA : public RecordExt {
  */
 class NETTISAPlugin : public ProcessPlugin {
 public:
+	NETTISAPlugin(const std::string& params);
 	OptionsParser* get_parser() const { return new OptionsParser("nettisa", "Parse NetTiSA flow"); }
 	std::string get_name() const { return "nettisa"; }
 	RecordExt* get_ext() const { return new RecordExtNETTISA(); }