aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--src/plugins/lua/emails.lua11
1 files changed, 6 insertions, 5 deletions
diff --git a/src/plugins/lua/emails.lua b/src/plugins/lua/emails.lua
index 162809541..ffe45d5e2 100644
--- a/src/plugins/lua/emails.lua
+++ b/src/plugins/lua/emails.lua
@@ -4,13 +4,14 @@
-- symbol = sym, map = file:///path/to/file, domain_only = yes
-- symbol = sym2, dnsbl = bl.somehost.com, domain_only = no
local rules = {}
+local logger = require "rspamd_logger"
-- Check rule for a single email
local function check_email_rule(task, rule, addr)
local function emails_dns_cb(resolver, to_resolve, results, err)
task:inc_dns_req()
if results then
- rspamd_logger.info(string.format('<%s> email: [%s] resolved for symbol: %s',
+ logger.info(string.format('<%s> email: [%s] resolved for symbol: %s',
task:get_message():get_message_id(), to_resolve, rule['symbol']))
task:insert_result(rule['symbol'], 1)
end
@@ -29,14 +30,14 @@ local function check_email_rule(task, rule, addr)
local key = addr:get_host()
if rule['map']:get_key(key) then
task:insert_result(rule['symbol'], 1)
- rspamd_logger.info(string.format('<%s> email: \'%s\' is found in list: %s',
+ logger.info(string.format('<%s> email: \'%s\' is found in list: %s',
task:get_message():get_message_id(), key, rule['symbol']))
end
else
local key = string.format('%s@%s', addr:get_user(), addr:get_host())
if rule['map']:get_key(key) then
task:insert_result(rule['symbol'], 1)
- rspamd_logger.info(string.format('<%s> email: \'%s\' is found in list: %s',
+ logger.info(string.format('<%s> email: \'%s\' is found in list: %s',
task:get_message():get_message_id(), key, rule['symbol']))
end
end
@@ -66,7 +67,7 @@ if type(rspamd_config.get_api_version) ~= 'nil' then
if rspamd_config:get_api_version() >= 2 then
rspamd_config:register_module_option('emails', 'rule', 'string')
else
- rspamd_logger.err('Invalid rspamd version for this plugin')
+ logger.err('Invalid rspamd version for this plugin')
end
end
@@ -83,7 +84,7 @@ if opts and type(opts) == 'table' then
rule['map'] = rspamd_config:add_hash_map (rule['name'])
end
if not rule['symbol'] or (not rule['map'] and not rule['dnsbl']) then
- rspamd_logger.err('incomplete rule')
+ logger.err('incomplete rule')
else
table.insert(rules, rule)
rspamd_config:register_virtual_symbol(rule['symbol'], 1.0)