From: Dmitriy Alekseev <1865999+dragoangel@users.noreply.github.com>
Date: Mon, 14 Oct 2024 14:16:44 +0000 (+0200)
Subject: round time_diff to seconds on interval check, improve log message readability
X-Git-Tag: 3.11.0~33^2~18
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=0a73f356e6af18d1f78534667a4bd298bb08ce19;p=thirdparty%2Frspamd.git

round time_diff to seconds on interval check, improve log message readability
---

diff --git a/src/plugins/lua/elastic.lua b/src/plugins/lua/elastic.lua
index 45c5c2edf3..18c29711fc 100644
--- a/src/plugins/lua/elastic.lua
+++ b/src/plugins/lua/elastic.lua
@@ -658,9 +658,10 @@ local function periodic_send_data(cfg, ev_base)
     local first_row = buffer['logs']:get(1)
     if first_row then
       local time_diff = now - first_row['@timestamp']
-      if time_diff > settings.limits.max_interval * 1000 then
-        rspamd_logger.infox(rspamd_config, 'flushing buffer by reaching max interval, diff: %s, current time: %s, log timestamp: %s',
-          time_diff, now, first_row['@timestamp'])
+      local time_diff_sec = lua_util.round((time_diff / 1000), 1)
+      if time_diff_sec > settings.limits.max_interval then
+        rspamd_logger.infox(rspamd_config, 'flushing buffer for %s by reaching max interval, oldest log in buffer written %s sec ago',
+          time_diff_sec, first_row['@timestamp'])
         flush_needed = true
       else
         local size = buffer['logs']:size()