From 0cc327f9fc6f9425c22b56497f4739e47a9d714a Mon Sep 17 00:00:00 2001
From: Stelios Fragkakis <52996999+stelfrag@users.noreply.github.com>
Date: Wed, 27 Dec 2023 10:56:15 +0200
Subject: [PATCH] Fix coverity issues (#16655)

---
 collectors/log2journal/log2journal-replace.c | 2 ++
 collectors/log2journal/log2journal-yaml.c    | 2 ++
 logsmanagement/parser.c                      | 1 -
 logsmanagement/query.c                       | 4 ++--
 logsmanagement/unit_test/unit_test.c         | 3 +++
 5 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/collectors/log2journal/log2journal-replace.c b/collectors/log2journal/log2journal-replace.c
index 429d615da5919f..7075d109dda89f 100644
--- a/collectors/log2journal/log2journal-replace.c
+++ b/collectors/log2journal/log2journal-replace.c
@@ -74,6 +74,7 @@ bool replace_pattern_set(REPLACE_PATTERN *rp, const char *pattern) {
                 log2stderr("Error: Failed to add replacement node for variable.");
                 return false;
             }
+            freez(variable_name);
 
             current = end + 1; // Move past the variable
         }
@@ -97,6 +98,7 @@ bool replace_pattern_set(REPLACE_PATTERN *rp, const char *pattern) {
                 log2stderr("Error: Failed to add replacement node for text.");
                 return false;
             }
+            freez(text);
         }
     }
 
diff --git a/collectors/log2journal/log2journal-yaml.c b/collectors/log2journal/log2journal-yaml.c
index 862e7bf4b77a70..2a0da81df8888a 100644
--- a/collectors/log2journal/log2journal-yaml.c
+++ b/collectors/log2journal/log2journal-yaml.c
@@ -561,6 +561,8 @@ static size_t yaml_parse_rewrites(yaml_parser_t *parser, LOG_JOB *jb) {
 
                     yaml_event_delete(&sub_event);
                 }
+                freez(replace_pattern);
+                replace_pattern = NULL;
             }
                 break;
 
diff --git a/logsmanagement/parser.c b/logsmanagement/parser.c
index f704abb3da3035..f637bef278aed4 100644
--- a/logsmanagement/parser.c
+++ b/logsmanagement/parser.c
@@ -226,7 +226,6 @@ int search_keyword( char *src, size_t src_sz __maybe_unused,
             size_t regcomp_err_str_size = regerror(rc, &regex_compiled, 0, 0);
             char *regcomp_err_str = mallocz(regcomp_err_str_size);
             regerror(rc, &regex_compiled, regcomp_err_str, regcomp_err_str_size);
-            freez(regcomp_err_str);
             fatal("Could not compile regular expression:%.*s, error: %s", (int) MAX_REGEX_SIZE, regexString, regcomp_err_str);
         }
     }
diff --git a/logsmanagement/query.c b/logsmanagement/query.c
index 77b066eab7f237..c98e0ccc3bec79 100644
--- a/logsmanagement/query.c
+++ b/logsmanagement/query.c
@@ -95,8 +95,8 @@ const logs_qry_res_err_t *fetch_log_sources(BUFFER *wb){
         buffer_json_member_add_string(wb, "filename", p_file_infos_arr->data[i]->filename);
         buffer_json_member_add_string(wb, "log_type", log_src_type_t_str[p_file_infos_arr->data[i]->log_type]);
         buffer_json_member_add_string(wb, "db_dir", p_file_infos_arr->data[i]->db_dir);
-        buffer_json_member_add_uint64(wb, "db_version", db_user_version(p_file_infos_arr->data[i]->db, -1));
-        buffer_json_member_add_uint64(wb, "db_flush_freq", db_user_version(p_file_infos_arr->data[i]->db, -1));
+        buffer_json_member_add_int64(wb, "db_version", db_user_version(p_file_infos_arr->data[i]->db, -1));
+        buffer_json_member_add_int64(wb, "db_flush_freq", db_user_version(p_file_infos_arr->data[i]->db, -1));
         buffer_json_member_add_int64( wb, "db_disk_space_limit", p_file_infos_arr->data[i]->blob_max_size * BLOB_MAX_FILES);
         buffer_json_object_close(wb); // options object
     }
diff --git a/logsmanagement/unit_test/unit_test.c b/logsmanagement/unit_test/unit_test.c
index 6c1d76e59e459b..d9a490d4372352 100644
--- a/logsmanagement/unit_test/unit_test.c
+++ b/logsmanagement/unit_test/unit_test.c
@@ -169,6 +169,7 @@ static int test_compression_decompression() {
         fprintf(stderr, "- Error, original and decompressed data not the same\n");
         ++errors;
     }
+    freez(decompressed_text);
 
     fprintf(stderr, "%s\n", errors ? "FAIL" : "OK");
     return errors;
@@ -183,6 +184,7 @@ static int test_read_last_line() {
     #else
     char tmpname[] = "/tmp/tmp.XXXXXX";
     #endif
+    (void) umask(0022);
 
     int fd = mkstemp(tmpname);
     if (fd == -1){
@@ -219,6 +221,7 @@ static int test_read_last_line() {
 
     unlink(tmpname);
     close(fd);
+    fclose(tmpfp);
 
     fprintf(stderr, "%s\n", errors ? "FAIL" : "OK");
     return errors;