tests: runtime: processor_content_modifier: OTEL scope autogenerated keys

Signed-off-by: Eduardo Silva <eduardo@chronosphere.io>

Author: edsiper

tests/runtime/processor_content_modifier.c

@@ -21,6 +21,7 @@
 #include <fluent-bit/flb_time.h>
 #include <msgpack.h>
 #include "flb_tests_runtime.h"
+#include "../../plugins/processor_content_modifier/cm.h"
 
 struct processor_test {
     flb_ctx_t *flb;    /* Fluent Bit library context */
@@ -183,6 +184,76 @@ static void processor_test_destroy(struct processor_test *ctx)
     flb_free(ctx);
 }
 
+static void assert_otel_scope_context_key(char *context_name, char *expected_key)
+{
+    int ret;
+    struct processor_test *ctx;
+    struct flb_lib_out_cb cb_data = {0};
+    struct cfl_variant action = {
+        .type = CFL_VARIANT_STRING,
+        .data.as_string = "upsert",
+    };
+    struct cfl_variant context = {
+        .type = CFL_VARIANT_STRING,
+        .data.as_string = context_name,
+    };
+    struct cfl_variant value = {
+        .type = CFL_VARIANT_STRING,
+        .data.as_string = "new value",
+    };
+    struct flb_processor_instance *ins;
+    struct content_modifier_ctx *cm_ctx;
+
+    ctx = processor_test_create(FLB_PROCESSOR_LOGS, &cb_data);
+    if (!TEST_CHECK(ctx != NULL)) {
+        TEST_MSG("failed to create ctx");
+        return;
+    }
+
+    ret = flb_processor_unit_set_property(ctx->pu, "action", &action);
+    TEST_CHECK(ret == 0);
+    ret = flb_processor_unit_set_property(ctx->pu, "context", &context);
+    TEST_CHECK(ret == 0);
+    ret = flb_processor_unit_set_property(ctx->pu, "value", &value);
+    TEST_CHECK(ret == 0);
+
+    ret = flb_start(ctx->flb);
+    if (!TEST_CHECK(ret == 0)) {
+        TEST_MSG("flb_start failed");
+        processor_test_destroy(ctx);
+        return;
+    }
+
+    ins = (struct flb_processor_instance *) ctx->pu->ctx;
+    if (!TEST_CHECK(ins != NULL)) {
+        TEST_MSG("processor instance is NULL");
+        processor_test_destroy(ctx);
+        return;
+    }
+
+    cm_ctx = (struct content_modifier_ctx *) ins->context;
+    if (!TEST_CHECK(cm_ctx != NULL)) {
+        TEST_MSG("content modifier context is NULL");
+        processor_test_destroy(ctx);
+        return;
+    }
+
+    TEST_CHECK(cm_ctx->key_is_autogenerated == FLB_TRUE);
+    TEST_CHECK(strcmp(cm_ctx->key, expected_key) == 0);
+
+    processor_test_destroy(ctx);
+}
+
+static void flb_logs_otel_scope_name_autogenerates_key()
+{
+    assert_otel_scope_context_key("otel_scope_name", "name");
+}
+
+static void flb_logs_otel_scope_version_autogenerates_key()
+{
+    assert_otel_scope_context_key("otel_scope_version", "version");
+}
+
 static void flb_logs_action_insert()
 {
     struct processor_test *ctx;
@@ -1431,6 +1502,8 @@ TEST_LIST = {
     {"logs.action.upsert"           , flb_logs_action_upsert },
     {"logs.action.hash"             , flb_logs_action_hash },
     {"logs.action.extract"          , flb_logs_action_extract },
+    {"logs.otel_scope_name.autogenerated_key" , flb_logs_otel_scope_name_autogenerates_key },
+    {"logs.otel_scope_version.autogenerated_key" , flb_logs_otel_scope_version_autogenerates_key },
     {"logs.action.convert_from_string_to_int" , flb_logs_action_convert_from_string_to_int },
     {"logs.action.convert_from_int_to_string" , flb_logs_action_convert_from_int_to_string },
     {"logs.action.convert_from_string_to_double" , flb_logs_action_convert_from_string_to_double },