]> source.dussan.org Git - rspamd.git/commitdiff
[Minor] Add scan_time and hostname to metadata_exporter 4166/head
authorLucas Rolff <lucas@lucasrolff.com>
Mon, 2 May 2022 20:40:13 +0000 (22:40 +0200)
committerLucas Rolff <lucas@lucasrolff.com>
Mon, 2 May 2022 20:40:13 +0000 (22:40 +0200)
src/plugins/lua/metadata_exporter.lua

index 20d388fefd9cbbb3378d93aef568ae735b12059a..6316ddc09dd4ec04c64efe40587555b9ffa12bda 100644 (file)
@@ -29,6 +29,7 @@ local rspamd_logger = require "rspamd_logger"
 local ucl = require "ucl"
 local E = {}
 local N = 'metadata_exporter'
+local HOSTNAME = rspamd_util.get_hostname()
 
 local settings = {
   pusher_enabled = {},
@@ -75,6 +76,7 @@ local function get_general_metadata(task, flatten, no_content)
   r.qid = task:get_queue_id() or 'unknown'
   r.subject = task:get_subject() or 'unknown'
   r.action = task:get_metric_action('default')
+  r.rspamd_server = HOSTNAME
 
   local s = task:get_metric_score('default')[1]
   r.score = flatten and string.format('%.2f', s) or s
@@ -151,6 +153,18 @@ local function get_general_metadata(task, flatten, no_content)
       return 'unknown'
     end
   end
+
+  local scan_real = task:get_scan_time()
+  scan_real = math.floor(scan_real * 1000)
+  if scan_real < 0 then
+    rspamd_logger.messagex(task,
+        'clock skew detected for message: %s ms real sca time (reset to 0)',
+        scan_real)
+    scan_real = 0
+  end
+
+  r.scan_time = scan_real
+
   if not no_content then
     r.header_from = process_header('from')
     r.header_to = process_header('to')