in_someip: SOME/IP input plugin

CMakeLists.txt

@@ -617,6 +617,11 @@ if(FLB_WASM)
   endif ()
 endif()
 
+# SOME/IP
+if(FLB_IN_SOMEIP)
+  add_subdirectory(${FLB_PATH_LIB_SOMEIP_C} EXCLUDE_FROM_ALL)
+endif()
+
 # AWS
 if (FLB_AWS)
   FLB_DEFINITION(FLB_HAVE_AWS)

cmake/libraries.cmake

@@ -24,3 +24,4 @@ set(FLB_PATH_LIB_SNAPPY      "lib/snappy-fef67ac")
 set(FLB_PATH_LIB_RDKAFKA     "lib/librdkafka-2.4.0")
 set(FLB_PATH_LIB_RING_BUFFER "lib/lwrb")
 set(FLB_PATH_LIB_WASM_MICRO_RUNTIME  "lib/wasm-micro-runtime-WAMR-1.3.0")
+set(FLB_PATH_LIB_SOMEIP_C    "lib/libsomeip-c")

cmake/plugins_options.cmake

@@ -47,6 +47,7 @@ DEFINE_OPTION(FLB_IN_PROMETHEUS_REMOTE_WRITE  "Enable prometheus remote write in
 DEFINE_OPTION(FLB_IN_PROMETHEUS_SCRAPE        "Enable Prometheus Scrape input plugin"        ON)
 DEFINE_OPTION(FLB_IN_RANDOM                   "Enable random input plugin"                   ON)
 DEFINE_OPTION(FLB_IN_SERIAL                   "Enable Serial input plugin"                   ON)
+DEFINE_OPTION(FLB_IN_SOMEIP                   "Enable SOME/IP input plugin"                  OFF)
 DEFINE_OPTION(FLB_IN_SPLUNK                   "Enable Splunk HTTP HEC input plugin"          ON)
 DEFINE_OPTION(FLB_IN_STATSD                   "Enable StatsD input plugin"                   ON)
 DEFINE_OPTION(FLB_IN_STDIN                    "Enable Standard input plugin"                 ON)

conf/in_someip.conf

@@ -0,0 +1,54 @@
+[SERVICE]
+    # Flush
+    # =====
+    # Set an interval of seconds before to flush records to a destination
+    Flush        5
+
+    # Daemon
+    # ======
+    # Instruct Fluent Bit to run in foreground or background mode.
+    Daemon       Off
+
+    # Log_Level
+    # =========
+    # Set the verbosity level of the service, values can be:
+    #
+    # - error
+    # - warning
+    # - info
+    # - debug
+    # - trace
+    #
+    # By default 'info' is set, that means it includes 'error' and 'warning'.
+    Log_Level    trace
+
+    # HTTP Monitoring Server
+    # ======================
+    #
+    # HTTP_Monitor: enable/disable the HTTP Server to monitor
+    #               Fluent Bit internals.
+    # HTTP_Port   : specify the TCP port of the HTTP Server
+    HTTP_Monitor Off
+    HTTP_Port    2020
+
+[INPUT]
+    Name someip
+    Tag  in.someip
+
+    # Events to subscribe to.
+    # Each event should have form:
+    #    Event <service id>,<instance id>,<event id>,<event group 1>,...
+    #
+    # Each event must have at least one event group
+    Event 4,1,32768,1
+    Event 4,1,32769,2
+
+    # RPC to send on startup
+    # Each RPC entry should have form:
+    #    RPC <service id>,<instance id>,<method id>,<Request Payload>
+    #
+    # Request payload should be base64 encoded
+    RPC   4,1,1,CgAQAw==
+[OUTPUT]
+    Name  stdout
+    Match *

dockerfiles/Dockerfile

@@ -55,6 +55,9 @@ RUN echo "deb http://deb.debian.org/debian bookworm-backports main" >> /etc/apt/
     flex \
     bison \
     libyaml-dev \
+    libboost-system-dev \
+    libboost-thread-dev \
+    libboost-filesystem-dev \
     && apt-get clean \
     && rm -rf /var/lib/apt/lists/*
 
@@ -141,6 +144,9 @@ RUN echo "deb http://deb.debian.org/debian bookworm-backports main" >> /etc/apt/
     liblzma5 \
     libyaml-0-2 \
     libcap2 \
+    libboost-system-dev \
+    libboost-thread-dev \
+    libboost-filesystem-dev \
     && \
     mkdir -p /dpkg/var/lib/dpkg/status.d/ && \
     for deb in *.deb; do \
@@ -221,6 +227,9 @@ RUN echo "deb http://deb.debian.org/debian bookworm-backports main" >> /etc/apt/
     libatomic1 \
     libgcrypt20 \
     libyaml-0-2 \
+    libboost-system-dev \
+    libboost-thread-dev \
+    libboost-filesystem-dev \
     bash gdb valgrind build-essential  \
     git bash-completion vim tmux jq \
     dnsutils iputils-ping iputils-arping iputils-tracepath iputils-clockdiff \

lib/libsomeip-c/CMakeLists.txt

@@ -0,0 +1,12 @@
+project(someipc CXX)
+
+add_subdirectory(vsomeip-3.5.1)
+
+find_package(vsomeip3 REQUIRED)
+
+add_library(someip-c SHARED src/someip_wrapper.cc)
+target_include_directories(someip-c PUBLIC include)
+target_link_libraries(someip-c PRIVATE vsomeip3 vsomeip3-sd vsomeip3-cfg vsomeip3-e2e)
+target_link_options(someip-c PUBLIC "-Wl,--disable-new-dtags")
+
+add_subdirectory(example)

lib/libsomeip-c/example/CMakeLists.txt

@@ -0,0 +1,3 @@
+
+add_executable(someip_test_service test_service.c)
+target_link_libraries(someip_test_service PRIVATE someip-c)

lib/libsomeip-c/example/test_service.c

@@ -0,0 +1,133 @@
+/*  Fluent Bit
+ *  ==========
+ *  Copyright (C) 2015-2024 The Fluent Bit Authors
+ *
+ *  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.
+ */
+#include <stdint.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+
+#include "someip_api.h"
+
+
+static const char* NAME = "Test Service";
+static const uint16_t SERVICE_ID     = 4;
+static const uint16_t INSTANCE_ID    = 1;
+static const uint16_t METHOD_ID      = 1;
+static const uint16_t EVENT_ID       = 0x8000U;
+static const uint16_t EVENT_GROUP_ID = 1;
+
+static uint16_t client_id = 0;
+
+/*
+ * Function to handle callback when a request is received.
+ * @param request_ptr Pointer to the structure that has the request details.
+ */
+void HandleRequest(void*, struct some_ip_request *request_ptr) {
+    static const char* response = "This is the response to the request";
+    int ret = 0;
+    if (request_ptr == NULL) {
+        return;
+    }
+    printf("Received request (method = %d)\n", request_ptr->method_id);
+    printf("Payload length = %ld\n", request_ptr->payload_len);
+
+    /* Normal service would Parse the request and perform/initiate some actions on it*/
+    /* For this example just send back a canned response */
+
+    ret = someip_send_response(client_id, request_ptr->request_id.client_request_id,
+                               (void*)response, strlen(response));
+    if (ret != SOMEIP_RET_SUCCESS) {
+        printf("Failed to send response: %d\n", ret);
+    }
+}
+
+/*
+ * Function to initialize the test service with the SOME/IP library.
+ * @return 0 on success, -1 on failure.
+ */
+int Initialize() {
+    int ret = someip_initialize(NAME, &client_id);
+    if (ret != SOMEIP_RET_SUCCESS) {
+        printf("Failed to initialize SOME/IP: %d\n", ret);
+        return -1;
+    }
+
+    /* Register Request Handler */
+    ret = someip_register_request_handler(client_id, SERVICE_ID, INSTANCE_ID,
+                                          METHOD_ID, NULL, HandleRequest);
+
+    if (ret != SOMEIP_RET_SUCCESS) {
+        printf("Failed to register request handler: %d\n", ret);
+        someip_shutdown(client_id);
+        return -1;
+    }
+
+    /* Offer Event */
+    ret = someip_offer_event(client_id, SERVICE_ID, INSTANCE_ID, EVENT_ID, (uint16_t*)&EVENT_GROUP_ID, 1);
+    if (ret != SOMEIP_RET_SUCCESS) {
+        printf("Failed to Offer Event: %d\n", ret);
+        someip_shutdown(client_id);
+        return -1;
+    }
+
+    /* Offer Service */
+    ret = someip_offer_service(client_id, SERVICE_ID, INSTANCE_ID);
+    if (ret != SOMEIP_RET_SUCCESS) {
+        printf("Failed to Offer Service: %d\n", ret);
+        someip_shutdown(client_id);
+        return -1;
+    }
+
+    return 0;
+}
+
+void Teardown() {
+    someip_shutdown(client_id);
+}
+
+void SendEvent(const int num) {
+    const char* base_msg = "Event Number ";
+    char buffer[128];
+    int ret = 0;
+    strcpy(buffer, base_msg);
+    sprintf(buffer + strlen(base_msg), "%d", num);
+
+    printf("Sending event with message %s\n", buffer);
+
+    ret = someip_send_event(client_id, SERVICE_ID, INSTANCE_ID, EVENT_ID,
+                            buffer, strlen(buffer));
+    if (ret != SOMEIP_RET_SUCCESS) {
+        printf ("Failed to send event, %d\n", ret);
+    }
+}
+
+
+int main() {
+    int num_events = 10;
+    if (Initialize() != 0) {
+        return EXIT_FAILURE;
+    }
+
+
+    for (int i = 0; i <= num_events; ++i) {
+        SendEvent(i);
+        sleep(2);
+    }
+
+    Teardown();
+    return EXIT_SUCCESS;
+}