1 files changed, 101 insertions, 0 deletions
diff --git a/src/fluent-bit/tests/internal/fuzzers/record_ac_fuzzer.c b/src/fluent-bit/tests/internal/fuzzers/record_ac_fuzzer.c
new file mode 100644
index 000000000..9f2ae5807
--- /dev/null
+++ b/src/fluent-bit/tests/internal/fuzzers/record_ac_fuzzer.c
@@ -0,0 +1,101 @@
+#include <fluent-bit/flb_info.h>
+#include <fluent-bit/flb_mem.h>
+#include <fluent-bit/flb_error.h>
+#include <fluent-bit/flb_sds.h>
+#include <fluent-bit/flb_pack.h>
+#include <fluent-bit/flb_record_accessor.h>
+#include <fluent-bit/record_accessor/flb_ra_parser.h>
+#include <msgpack.h>
+#include "flb_fuzz_header.h"
+
+int LLVMFuzzerTestOneInput(const uint8_t *data, size_t size)
+{
+    /* Limit size to 32KB */
+    if (size > 32768 || size < 6) {
+        return 0;
+    }
+
+    char *outbuf = NULL;
+    char *ra_str = NULL;
+    size_t outsize;
+    int type;
+    int len;
+    size_t off = 0;
+    msgpack_object map;
+
+    /* Set flb_malloc_mod to be fuzzer-data dependent */
+    flb_malloc_p = 0;
+    flb_malloc_mod = *(int*)data;
+    data += 4;
+    size -= 4;
+
+    /* Avoid division by zero for modulo operations */
+    if (flb_malloc_mod == 0) {
+        flb_malloc_mod = 1;
+    }
+
+    if (size < 100) {
+       return 0;
+    }
+
+    struct flb_record_accessor *ra = NULL;
+    
+    /* Sample JSON message */
+    len = 60;
+    char *json_raw = get_null_terminated(len, &data, &size);
+
+    /* Convert to msgpack */
+    int ret = flb_pack_json(json_raw, len, &outbuf, &outsize, &type, NULL);
+    if (ret == -1) {
+        flb_free(json_raw);
+        return 0;
+    }
+    flb_free(json_raw);
+
+    char *null_terminated = get_null_terminated(size, &data, &size);
+
+    ra_str = flb_sds_create(null_terminated);
+    if (ra_str != NULL) {
+        ra = flb_ra_create(ra_str, FLB_FALSE);
+        if (!ra) {
+            flb_sds_destroy(ra_str);
+            flb_free(null_terminated);
+            flb_free(outbuf);
+            return 0;
+        }
+
+        flb_ra_is_static(ra);
+
+        msgpack_unpacked result;
+        msgpack_unpacked_init(&result);
+        msgpack_unpack_next(&result, outbuf, outsize, &off);
+        map = result.data;
+
+        flb_sds_t str = flb_ra_translate(ra, NULL, -1, map, NULL);
+        if (!str) {
+            flb_ra_destroy(ra);
+            flb_sds_destroy(ra_str);
+            msgpack_unpacked_destroy(&result);
+
+            /* General cleanup */
+            flb_free(null_terminated);
+            flb_free(outbuf);
+            return 0;
+        }
+        flb_ra_dump(ra);
+
+
+        flb_sds_destroy(str);
+        flb_ra_destroy(ra);
+        flb_sds_destroy(ra_str);
+        msgpack_unpacked_destroy(&result);
+    }
+
+    if (outbuf != NULL) {
+        flb_free(outbuf);
+    }
+    if (null_terminated != NULL) {
+        flb_free(null_terminated);
+    }
+    return 0;
+}