ipfixprobe - introduce process MPLS plugin

Author: Pavel Siska

src/plugins/process/CMakeLists.txt

@@ -24,4 +24,5 @@ add_subdirectory(tls)
 if (ENABLE_PROCESS_EXPERIMENTAL)
 	add_subdirectory(sip)
 	add_subdirectory(rtsp)
+	add_subdirectory(mpls)
 endif()

src/plugins/process/mpls.cpp

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

src/plugins/process/mpls/CMakeLists.txt

@@ -0,0 +1,57 @@
+/**
+ * @file
+ * @brief Plugin for parsing mpls traffic.
+ * @author Jakub Antonín Štigler [email protected]
+ * @author Pavel Siska <[email protected]>
+ * @date 2025
+ *
+ * Copyright (c) 2025 CESNET
+ *
+ * SPDX-License-Identifier: BSD-3-Clause
+ */
+
+#include "mpls.hpp"
+
+#include <iostream>
+
+#include <ipfixprobe/pluginFactory/pluginManifest.hpp>
+#include <ipfixprobe/pluginFactory/pluginRegistrar.hpp>
+
+namespace ipxp {
+
+int RecordExtMPLS::REGISTERED_ID = ProcessPluginIDGenerator::instance().generatePluginID();
+
+static const PluginManifest mplsPluginManifest = {
+	.name = "mpls",
+	.description = "Mpls process plugin for parsing mpls traffic.",
+	.pluginVersion = "1.0.0",
+	.apiVersion = "1.0.0",
+	.usage = nullptr,
+};
+
+MPLSPlugin::MPLSPlugin(const std::string& params)
+{
+	(void) params;
+}
+
+ProcessPlugin* MPLSPlugin::copy()
+{
+	return new MPLSPlugin(*this);
+}
+
+int MPLSPlugin::post_create(Flow& rec, const Packet& pkt)
+{
+	if (pkt.mplsTop == 0) {
+		return 0;
+	}
+
+	auto ext = new RecordExtMPLS();
+	ext->mpls = pkt.mplsTop;
+
+	rec.add_extension(ext);
+	return 0;
+}
+
+static const PluginRegistrar<MPLSPlugin, ProcessPluginFactory> mplsRegistrar(mplsPluginManifest);
+
+} // namespace ipxp

src/plugins/process/mpls/README.md

@@ -1,33 +1,16 @@
 /**
- * \file mpls.hpp
- * \brief Plugin for parsing mpls traffic.
- * \author Jakub Antonín Štigler [email protected]
- * \date 2023
- */
-/*
- * Copyright (C) 2023 CESNET
- *
- * LICENSE TERMS
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions
- * are met:
- * 1. Redistributions of source code must retain the above copyright
- *    notice, this list of conditions and the following disclaimer.
- * 2. Redistributions in binary form must reproduce the above copyright
- *    notice, this list of conditions and the following disclaimer in
- *    the documentation and/or other materials provided with the
- *    distribution.
- * 3. Neither the name of the Company nor the names of its contributors
- *    may be used to endorse or promote products derived from this
- *    software without specific prior written permission.
- *
+ * @file
+ * @brief Plugin for parsing mpls traffic.
+ * @author Jakub Antonín Štigler [email protected]
+ * @author Pavel Siska <[email protected]>
+ * @date 2025
  *
+ * Copyright (c) 2025 CESNET
  *
+ * SPDX-License-Identifier: BSD-3-Clause
  */
 
-#ifndef IPXP_PROCESS_MPLS_HPP
-#define IPXP_PROCESS_MPLS_HPP
+#pragma once
 
 #include <cstring>
 #include <sstream>
@@ -40,7 +23,7 @@
 #include <ipfixprobe/flowifc.hpp>
 #include <ipfixprobe/ipfix-elements.hpp>
 #include <ipfixprobe/packet.hpp>
-#include <ipfixprobe/process.hpp>
+#include <ipfixprobe/processPlugin.hpp>
 
 namespace ipxp {
 
@@ -113,6 +96,7 @@ struct RecordExtMPLS : public RecordExt {
  */
 class MPLSPlugin : public ProcessPlugin {
 public:
+	MPLSPlugin(const std::string& params);
 	OptionsParser* get_parser() const { return new OptionsParser("mpls", "Parse MPLS traffic"); }
 	std::string get_name() const { return "mpls"; }
 	RecordExt* get_ext() const { return new RecordExtMPLS(); }
@@ -122,4 +106,3 @@ class MPLSPlugin : public ProcessPlugin {
 };
 
 } // namespace ipxp
-#endif /* IPXP_PROCESS_MPLS_HPP */