From ffda608b2e73179e3af67f783f84eb9eb31390c3 Mon Sep 17 00:00:00 2001
From: Dmitriy Alekseev <1865999+dragoangel@users.noreply.github.com>
Date: Tue, 15 Oct 2024 23:50:48 +0200
Subject: [PATCH] return item status and reasons on bulk push error

---
 src/plugins/lua/elastic.lua | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/src/plugins/lua/elastic.lua b/src/plugins/lua/elastic.lua
index e90c70260..ae7e577f3 100644
--- a/src/plugins/lua/elastic.lua
+++ b/src/plugins/lua/elastic.lua
@@ -380,7 +380,17 @@ local function elastic_send_data(flush_all, task, cfg, ev_base)
         push_done = true
         rspamd_logger.debugm(N, log_object, 'successfully sent payload with %s logs', nlogs_to_send)
         if obj['errors'] then
-          rspamd_logger.debugm(N, log_object, 'faced errors while pushing logs to elastic (%s): %s', obj['errors'])
+          for _, value in pairs(obj['items']) do
+            if value['index'] and value['index']['status'] >= 400 then
+              local status = value['index']['status']
+              local index = safe_get(value, 'index', '_index') or ''
+              local error_type = safe_get(value, 'index', 'error', 'type') or ''
+              local error_reason = safe_get(value, 'index', 'error', 'reason') or ''
+              rspamd_logger.warnx(log_object,
+                'error while pushing logs to elastic, status: %s, index: %s, type: %s, reason: %s',
+                status, index, error_type, error_reason)
+            end
+          end
         end
       else
         rspamd_logger.errx(log_object,
-- 
2.39.5