]> source.dussan.org Git - rspamd.git/commitdiff
[Minor] Fix more lua issues
authorVsevolod Stakhov <vsevolod@rspamd.com>
Thu, 14 Apr 2022 19:59:31 +0000 (20:59 +0100)
committerVsevolod Stakhov <vsevolod@rspamd.com>
Thu, 14 Apr 2022 19:59:31 +0000 (20:59 +0100)
src/plugins/lua/dynamic_conf.lua
src/plugins/lua/forged_recipients.lua
src/plugins/lua/fuzzy_collect.lua
src/plugins/lua/neural.lua

index 833aa45df0fec442dc3b17d2eb9cc09d554684d1..8a2f95accf1eb15ef799cd250fb9e902886af24d 100644 (file)
@@ -249,8 +249,8 @@ if section then
   rspamd_config:add_on_load(function(_, ev_base, worker)
     if worker:is_scanner() then
       rspamd_config:add_periodic(ev_base, 0.0,
-          function(cfg, _ev_base)
-            check_dynamic_conf(cfg, _ev_base)
+          function(cfg, _)
+            check_dynamic_conf(cfg, ev_base)
             return settings.redis_watch_interval
           end, true)
     end
index f3667ea076edef694d9eee193fcffbce1c59965a..a0fcd09ec142a6b23a5d0e877ba41689a0e616ed 100644 (file)
@@ -141,7 +141,7 @@ local function check_forged_headers(task)
   if smtp_from and smtp_from[1] and smtp_from[1]['addr'] ~= '' then
     local mime_from = task:get_from(2)
     if not mime_from or not mime_from[1] or
-      not (string.lower(mime_from[1]['addr']) == string.lower(smtp_from[1]['addr'])) then
+        (string.lower(mime_from[1]['addr']) ~= string.lower(smtp_from[1]['addr'])) then
       task:insert_result(symbol_sender, 1, ((mime_from or E)[1] or E).addr or '', smtp_from[1].addr)
     end
   end
index 9a63823d9351e2ae50e06c99804ce2f54b6a9cda..d64830c6bd226fcfd87aec1f2f58a3a8a7614b75 100644 (file)
@@ -180,8 +180,8 @@ if opts and type(opts) == 'table' then
     rspamd_config:add_on_load(function(_, ev_base, worker)
       if worker:is_primary_controller() then
         rspamd_config:add_periodic(ev_base, 0.0,
-          function(_cfg, _ev_base)
-            return collect_fuzzy_hashes(_cfg, _ev_base)
+          function(cfg, _)
+            return collect_fuzzy_hashes(cfg, ev_base)
           end)
       end
     end)
index 7b414b5a32f8607295d55e32c6ebbb5519c9f140..5389f5ab2800428f08fa4aa9c48e0b08356614df 100644 (file)
@@ -243,10 +243,10 @@ local function ann_push_task_result(rule, task, verdict, score, set)
           local str = rspamd_util.zstd_compress(table.concat(vec, ';'))
           local target_key = set.ann.redis_key .. '_' .. learn_type .. '_set'
 
-          local function learn_vec_cb(_err)
-            if _err then
+          local function learn_vec_cb(redis_err)
+            if redis_err then
               rspamd_logger.errx(task, 'cannot store train vector for %s:%s: %s',
-                  rule.prefix, set.name, _err)
+                  rule.prefix, set.name, redis_err)
             else
               lua_util.debugm(N, task,
                   "add train data for ANN rule " ..